aboutsummaryrefslogtreecommitdiffstats
path: root/pkg/rpcserver/rpcserver.go
diff options
context:
space:
mode:
authorAleksandr Nogikh <nogikh@google.com>2025-01-24 17:08:36 +0100
committerAleksandr Nogikh <nogikh@google.com>2025-01-24 16:31:11 +0000
commit9fbd772e8b64ff0c8c90bdfb86237aefa530a06c (patch)
treeafc3a79ded0fff165a733c4ad9d20880e301137f /pkg/rpcserver/rpcserver.go
parent2d19ddde3e0e272bddc8220c8752c3d649459a26 (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.go10
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".