diff options
| author | Aleksandr Nogikh <nogikh@google.com> | 2025-01-24 17:08:36 +0100 |
|---|---|---|
| committer | Aleksandr Nogikh <nogikh@google.com> | 2025-01-24 16:31:11 +0000 |
| commit | 9fbd772e8b64ff0c8c90bdfb86237aefa530a06c (patch) | |
| tree | afc3a79ded0fff165a733c4ad9d20880e301137f /pkg/rpcserver/rpcserver.go | |
| parent | 2d19ddde3e0e272bddc8220c8752c3d649459a26 (diff) | |
pkg/vminfo: remove Context from the constructor
The context is assumed to be passed into the function doing the actual
processing. Refactor vminfo to follow this approach.
This will help refactor pkg/rpcserver later.
Diffstat (limited to 'pkg/rpcserver/rpcserver.go')
| -rw-r--r-- | pkg/rpcserver/rpcserver.go | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/pkg/rpcserver/rpcserver.go b/pkg/rpcserver/rpcserver.go index 9d259b733..003c5f4b9 100644 --- a/pkg/rpcserver/rpcserver.go +++ b/pkg/rpcserver/rpcserver.go @@ -153,7 +153,7 @@ func New(cfg *RemoteConfig) (Server, error) { if !cfg.Experimental.RemoteCover { features &= ^flatrpc.FeatureExtraCoverage } - return newImpl(context.Background(), &Config{ + return newImpl(&Config{ Config: vminfo.Config{ Target: cfg.Target, VMType: cfg.Type, @@ -180,11 +180,11 @@ func New(cfg *RemoteConfig) (Server, error) { }, cfg.Manager), nil } -func newImpl(ctx context.Context, cfg *Config, mgr Manager) *server { +func newImpl(cfg *Config, mgr Manager) *server { // Note that we use VMArch, rather than Arch. We need the kernel address ranges and bitness. sysTarget := targets.Get(cfg.Target.OS, cfg.VMArch) cfg.Procs = min(cfg.Procs, prog.MaxPids) - checker := vminfo.New(ctx, &cfg.Config) + checker := vminfo.New(&cfg.Config) baseSource := queue.DynamicSource(checker) return &server{ cfg: cfg, @@ -372,7 +372,9 @@ func checkRevisions(a *flatrpc.ConnectRequest, target *prog.Target) error { } func (serv *server) runCheck(info *flatrpc.InfoRequest) error { - enabledCalls, disabledCalls, features, checkErr := serv.checker.Run(info.Files, info.Features) + // TODO: take context as a parameter. + enabledCalls, disabledCalls, features, checkErr := serv.checker.Run(context.Background(), + info.Files, info.Features) enabledCalls, transitivelyDisabled := serv.target.TransitivelyEnabledCalls(enabledCalls) // Note: need to print disbled syscalls before failing due to an error. // This helps to debug "all system calls are disabled". |
