aboutsummaryrefslogtreecommitdiffstats
path: root/pkg/rpcserver/rpcserver.go
diff options
context:
space:
mode:
authorTaras Madan <tarasmadan@google.com>2026-01-21 20:00:38 +0100
committerTaras Madan <tarasmadan@google.com>2026-01-21 22:46:06 +0000
commita16aed1db22739e7dea8098c79bc1963b871b5ec (patch)
treeac3968a697f9cbe78c66915abe2a8d00e58a787b /pkg/rpcserver/rpcserver.go
parent7ee46ad36cdaae818f74dea493b5ec30df3fe31b (diff)
all: fix context.Context usage
Diffstat (limited to 'pkg/rpcserver/rpcserver.go')
-rw-r--r--pkg/rpcserver/rpcserver.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/pkg/rpcserver/rpcserver.go b/pkg/rpcserver/rpcserver.go
index b0ab14c17..04c5d877f 100644
--- a/pkg/rpcserver/rpcserver.go
+++ b/pkg/rpcserver/rpcserver.go
@@ -408,11 +408,11 @@ func (serv *server) handleMachineInfo(infoReq *flatrpc.InfoRequestRawT) (handsha
}, nil
}
-func (serv *server) connectionLoop(baseCtx context.Context, runner *Runner) error {
+func (serv *server) connectionLoop(ctx context.Context, runner *Runner) error {
// To "cancel" the runner's loop we need to call runner.Stop().
// At the same time, we don't want to leak the goroutine that monitors it,
// so we derive a new context and cancel it on function exit.
- ctx, cancel := context.WithCancel(baseCtx)
+ ctx, cancel := context.WithCancel(ctx)
defer cancel()
go func() {
<-ctx.Done()