mirror of
https://github.com/hanzoai/visor.git
synced 2026-09-24 17:04:14 +00:00
zeekayandHanzo Dev
f42ae7beb2
encoding/json walked every payload on every call. ZAP reads a field at a
constant offset out of the buffer that arrived, and //tools/zap has
already stated those offsets for every payload, so the transport now asks
the payload for its own bytes and the parse step is gone.
The envelope collapses with it. clientCall and serverCall existed only
because JSON needed one type to hold an any and another to hold a
RawMessage; bytes are bytes, so one Call serves both ends. Framing comes
from the ZAP header, which declares its own length.
A payload that is nothing -- the *struct{} a method takes when it has no
argument or no result -- carries nothing. Anything else without a layout
fails the call naming the type, so a payload that would have arrived
silently empty does not arrive at all.
The methods that took a bare string or returned a bare int now take and
return named payloads, because a scalar has no layout to state and the
rest of the API was already shaped this way.
Co-authored-by: Hanzo Dev <[email protected]>
468 lines
11 KiB
Python
468 lines
11 KiB
Python
load("//pkg/sync/locking:locking.bzl", "declare_mutex", "declare_rwmutex")
|
|
load("//tools:defs.bzl", "go_library", "go_test", "proto_library")
|
|
load("//tools/go_generics:defs.bzl", "go_template_instance")
|
|
|
|
package(
|
|
default_applicable_licenses = ["//:license"],
|
|
licenses = ["notice"],
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "atomicptr_bucket_slice",
|
|
out = "atomicptr_bucket_slice_unsafe.go",
|
|
package = "kernel",
|
|
prefix = "descriptorBucketSlice",
|
|
template = "//pkg/sync/atomicptr:generic_atomicptr",
|
|
types = {
|
|
"Value": "descriptorBucketSlice",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "atomicptr_bucket",
|
|
out = "atomicptr_bucket_unsafe.go",
|
|
package = "kernel",
|
|
prefix = "descriptorBucket",
|
|
template = "//pkg/sync/atomicptr:generic_atomicptr",
|
|
types = {
|
|
"Value": "descriptorBucket",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "atomicptr_descriptor",
|
|
out = "atomicptr_descriptor_unsafe.go",
|
|
package = "kernel",
|
|
prefix = "descriptor",
|
|
template = "//pkg/sync/atomicptr:generic_atomicptr",
|
|
types = {
|
|
"Value": "descriptor",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "atomicptr_fscontext",
|
|
out = "atomicptr_fscontext_unsafe.go",
|
|
package = "kernel",
|
|
prefix = "fsContext",
|
|
template = "//pkg/sync/atomicptr:generic_atomicptr",
|
|
types = {
|
|
"Value": "fsContext",
|
|
},
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "user_counters_mutex",
|
|
out = "user_counters_mutex.go",
|
|
package = "kernel",
|
|
prefix = "userCounters",
|
|
)
|
|
|
|
declare_rwmutex(
|
|
name = "taskset_mutex",
|
|
out = "taskset_mutex.go",
|
|
package = "kernel",
|
|
prefix = "taskSet",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "task_mutex",
|
|
out = "task_mutex.go",
|
|
nested_lock_names = ["child"],
|
|
package = "kernel",
|
|
prefix = "task",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "task_work_mutex",
|
|
out = "task_work_mutex.go",
|
|
package = "kernel",
|
|
prefix = "taskWork",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "cgroup_mutex",
|
|
out = "cgroup_mutex.go",
|
|
package = "kernel",
|
|
prefix = "cgroup",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "cgroup_v2_mutex",
|
|
out = "cgroup_v2_mutex.go",
|
|
package = "kernel",
|
|
prefix = "cgroup2",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "fd_table_mutex",
|
|
out = "fd_table_mutex.go",
|
|
package = "kernel",
|
|
prefix = "fdTable",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "fs_context_mutex",
|
|
out = "fs_context_mutex.go",
|
|
package = "kernel",
|
|
prefix = "fsContext",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "fs_save_mutex",
|
|
out = "fs_save_mutex.go",
|
|
package = "kernel",
|
|
prefix = "fsSave",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "running_tasks_mutex",
|
|
out = "running_tasks_mutex.go",
|
|
package = "kernel",
|
|
prefix = "runningTasks",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "signal_handlers_mutex",
|
|
out = "signal_handlers_mutex.go",
|
|
nested_lock_names = ["tg"],
|
|
package = "kernel",
|
|
prefix = "signalHandlers",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "thread_group_timer_mutex",
|
|
out = "thread_group_timer_mutex.go",
|
|
package = "kernel",
|
|
prefix = "threadGroupTimer",
|
|
)
|
|
|
|
declare_mutex(
|
|
name = "cgroup_mounts_mutex",
|
|
out = "cgroup_mounts_mutex.go",
|
|
package = "kernel",
|
|
prefix = "cgroupMounts",
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "pending_signals_list",
|
|
out = "pending_signals_list.go",
|
|
package = "kernel",
|
|
prefix = "pendingSignal",
|
|
template = "//pkg/ilist:generic_list",
|
|
types = {
|
|
"Element": "*pendingSignal",
|
|
"Linker": "*pendingSignal",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "process_group_list",
|
|
out = "process_group_list.go",
|
|
package = "kernel",
|
|
prefix = "processGroup",
|
|
template = "//pkg/ilist:generic_list",
|
|
types = {
|
|
"Element": "*ProcessGroup",
|
|
"Linker": "*ProcessGroup",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "session_list",
|
|
out = "session_list.go",
|
|
package = "kernel",
|
|
prefix = "session",
|
|
template = "//pkg/ilist:generic_list",
|
|
types = {
|
|
"Element": "*Session",
|
|
"Linker": "*Session",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "task_list",
|
|
out = "task_list.go",
|
|
package = "kernel",
|
|
prefix = "task",
|
|
template = "//pkg/ilist:generic_list",
|
|
types = {
|
|
"Element": "*Task",
|
|
"Linker": "*Task",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "fd_table_refs",
|
|
out = "fd_table_refs.go",
|
|
package = "kernel",
|
|
prefix = "FDTable",
|
|
template = "//pkg/refs:refs_template",
|
|
types = {
|
|
"T": "FDTable",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "fs_context_refs",
|
|
out = "fs_context_refs.go",
|
|
package = "kernel",
|
|
prefix = "FSContext",
|
|
template = "//pkg/refs:refs_template",
|
|
types = {
|
|
"T": "FSContext",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "process_group_refs",
|
|
out = "process_group_refs.go",
|
|
package = "kernel",
|
|
prefix = "ProcessGroup",
|
|
template = "//pkg/refs:refs_template",
|
|
types = {
|
|
"T": "ProcessGroup",
|
|
},
|
|
)
|
|
|
|
go_template_instance(
|
|
name = "session_refs",
|
|
out = "session_refs.go",
|
|
package = "kernel",
|
|
prefix = "Session",
|
|
template = "//pkg/refs:refs_template",
|
|
types = {
|
|
"T": "Session",
|
|
},
|
|
)
|
|
|
|
proto_library(
|
|
name = "uncaught_signal",
|
|
srcs = ["uncaught_signal.proto"],
|
|
visibility = ["//visibility:public"],
|
|
deps = ["//pkg/sentry/arch:registers_proto"],
|
|
)
|
|
|
|
go_library(
|
|
name = "kernel",
|
|
srcs = [
|
|
"aio.go",
|
|
"atomicptr_bucket_slice_unsafe.go",
|
|
"atomicptr_bucket_unsafe.go",
|
|
"atomicptr_descriptor_unsafe.go",
|
|
"cgroup.go",
|
|
"cgroup2.go",
|
|
"cgroup_mounts_mutex.go",
|
|
"cgroup_mutex.go",
|
|
"cgroup_v2_mutex.go",
|
|
"context.go",
|
|
"fd_table.go",
|
|
"fd_table_mutex.go",
|
|
"fd_table_refs.go",
|
|
"fd_table_unsafe.go",
|
|
"file_hash.go",
|
|
"fs_context.go",
|
|
"fs_context_mutex.go",
|
|
"fs_context_refs.go",
|
|
"fs_save_mutex.go",
|
|
"fscheckpoint.go",
|
|
"ipc_namespace.go",
|
|
"kcov.go",
|
|
"kcov_unsafe.go",
|
|
"kernel.go",
|
|
"kernel_opts.go",
|
|
"kernel_restore.go",
|
|
"kernel_state.go",
|
|
"pending_signals.go",
|
|
"pending_signals_list.go",
|
|
"pending_signals_state.go",
|
|
"pidfd.go",
|
|
"posixtimer.go",
|
|
"process_group_list.go",
|
|
"process_group_refs.go",
|
|
"ptrace.go",
|
|
"ptrace_amd64.go",
|
|
"ptrace_arm64.go",
|
|
"rseq.go",
|
|
"running_tasks_mutex.go",
|
|
"seccheck.go",
|
|
"seccomp.go",
|
|
"session_list.go",
|
|
"session_refs.go",
|
|
"sessions.go",
|
|
"signal.go",
|
|
"signal_handlers.go",
|
|
"signal_handlers_mutex.go",
|
|
"syscalls.go",
|
|
"syscalls_state.go",
|
|
"syslog.go",
|
|
"task.go",
|
|
"task_acct.go",
|
|
"task_block.go",
|
|
"task_cgroup.go",
|
|
"task_clone.go",
|
|
"task_context.go",
|
|
"task_exec.go",
|
|
"task_exit.go",
|
|
"task_futex.go",
|
|
"task_identity.go",
|
|
"task_image.go",
|
|
"task_key.go",
|
|
"task_list.go",
|
|
"task_log.go",
|
|
"task_mutex.go",
|
|
"task_net.go",
|
|
"task_run.go",
|
|
"task_sched.go",
|
|
"task_signals.go",
|
|
"task_start.go",
|
|
"task_stop.go",
|
|
"task_syscall.go",
|
|
"task_usermem.go",
|
|
"task_work.go",
|
|
"task_work_mutex.go",
|
|
"taskset_mutex.go",
|
|
"thread_group.go",
|
|
"thread_group_timer_mutex.go",
|
|
"thread_group_unsafe.go",
|
|
"threads.go",
|
|
"threads_impl.go",
|
|
"timekeeper.go",
|
|
"timekeeper_state.go",
|
|
"tty.go",
|
|
"user_counters_mutex.go",
|
|
"uts_namespace.go",
|
|
"vdso.go",
|
|
"zap.go",
|
|
],
|
|
imports = [
|
|
"gvisor.dev/gvisor/pkg/bpf",
|
|
"gvisor.dev/gvisor/pkg/tcpip",
|
|
],
|
|
marshal = True,
|
|
visibility = ["//:sandbox"],
|
|
deps = [
|
|
"//pkg/abi",
|
|
"//pkg/abi/linux",
|
|
"//pkg/abi/linux/errno",
|
|
"//pkg/abi/sentry",
|
|
"//pkg/atomicbitops",
|
|
"//pkg/bitmap",
|
|
"//pkg/bits",
|
|
"//pkg/bpf",
|
|
"//pkg/cleanup",
|
|
"//pkg/context",
|
|
"//pkg/coverage",
|
|
"//pkg/cpuid",
|
|
"//pkg/devutil",
|
|
"//pkg/ebpf",
|
|
"//pkg/errors",
|
|
"//pkg/errors/linuxerr",
|
|
"//pkg/eventchannel",
|
|
"//pkg/fd",
|
|
"//pkg/fdnotifier",
|
|
"//pkg/fspath",
|
|
"//pkg/goid",
|
|
"//pkg/hostarch",
|
|
"//pkg/log",
|
|
"//pkg/marshal",
|
|
"//pkg/marshal/primitive",
|
|
"//pkg/metric",
|
|
"//pkg/refs",
|
|
"//pkg/safemem",
|
|
"//pkg/secio",
|
|
"//pkg/sentry/arch",
|
|
"//pkg/sentry/checkpoint",
|
|
"//pkg/sentry/devices/nvproxy/nvconf",
|
|
"//pkg/sentry/fdcollector",
|
|
"//pkg/sentry/fscheckpoint",
|
|
"//pkg/sentry/fscheckpoint:fscheckpoint_proto_go_proto",
|
|
"//pkg/sentry/fsimpl/kernfs",
|
|
"//pkg/sentry/fsimpl/lock",
|
|
"//pkg/sentry/fsimpl/mqfs",
|
|
"//pkg/sentry/fsimpl/nsfs",
|
|
"//pkg/sentry/fsimpl/overlay",
|
|
"//pkg/sentry/fsimpl/pipefs",
|
|
"//pkg/sentry/fsimpl/sockfs",
|
|
"//pkg/sentry/fsimpl/timerfd",
|
|
"//pkg/sentry/fsimpl/tmpfs",
|
|
"//pkg/sentry/hostcpu",
|
|
"//pkg/sentry/inet",
|
|
"//pkg/sentry/kernel/auth",
|
|
"//pkg/sentry/kernel/futex",
|
|
"//pkg/sentry/kernel/ipc",
|
|
"//pkg/sentry/kernel/mq",
|
|
"//pkg/sentry/kernel/msgqueue",
|
|
"//pkg/sentry/kernel/pipe",
|
|
"//pkg/sentry/kernel/sched",
|
|
"//pkg/sentry/kernel/semaphore",
|
|
"//pkg/sentry/kernel/shm",
|
|
"//pkg/sentry/ktime",
|
|
"//pkg/sentry/limits",
|
|
"//pkg/sentry/loader",
|
|
"//pkg/sentry/memmap",
|
|
"//pkg/sentry/mm",
|
|
"//pkg/sentry/pgalloc",
|
|
"//pkg/sentry/platform",
|
|
"//pkg/sentry/seccheck",
|
|
"//pkg/sentry/seccheck/points:points_go_proto",
|
|
"//pkg/sentry/socket/netlink/port",
|
|
"//pkg/sentry/socket/unix/transport",
|
|
"//pkg/sentry/state/stateio",
|
|
"//pkg/sentry/time",
|
|
"//pkg/sentry/unimpl",
|
|
"//pkg/sentry/unimpl:unimplemented_syscall_go_proto",
|
|
"//pkg/sentry/uniqueid",
|
|
"//pkg/sentry/usage",
|
|
"//pkg/sentry/vfs",
|
|
"//pkg/state",
|
|
"//pkg/state/wire",
|
|
"//pkg/sync",
|
|
"//pkg/sync/locking",
|
|
"//pkg/syserr",
|
|
"//pkg/tcpip",
|
|
"//pkg/tcpip/stack",
|
|
"//pkg/timing",
|
|
"//pkg/usermem",
|
|
"//pkg/waiter",
|
|
":uncaught_signal_go_proto",
|
|
"@com_github_zap_proto_go//:go",
|
|
"@org_golang_google_protobuf//proto:go_default_library",
|
|
"@org_golang_x_sys//unix:go_default_library",
|
|
],
|
|
)
|
|
|
|
go_test(
|
|
name = "kernel_test",
|
|
size = "small",
|
|
srcs = [
|
|
"fd_table_test.go",
|
|
"table_test.go",
|
|
"task_syscall_benchmark_test.go",
|
|
"task_test.go",
|
|
"timekeeper_test.go",
|
|
],
|
|
library = ":kernel",
|
|
deps = [
|
|
"//pkg/abi",
|
|
"//pkg/context",
|
|
"//pkg/errors/linuxerr",
|
|
"//pkg/hostarch",
|
|
"//pkg/sentry/arch",
|
|
"//pkg/sentry/contexttest",
|
|
"//pkg/sentry/kernel/auth",
|
|
"//pkg/sentry/kernel/sched",
|
|
"//pkg/sentry/ktime",
|
|
"//pkg/sentry/limits",
|
|
"//pkg/sentry/pgalloc",
|
|
"//pkg/sentry/seccheck",
|
|
"//pkg/sentry/seccheck/points:points_go_proto",
|
|
"//pkg/sentry/time",
|
|
"//pkg/sentry/usage",
|
|
"//pkg/sentry/vfs",
|
|
"//pkg/sync",
|
|
"//pkg/tcpip",
|
|
"@org_golang_google_protobuf//proto:go_default_library",
|
|
],
|
|
)
|