diff options
| author | Taras Madan <tarasmadan@google.com> | 2026-01-21 20:00:38 +0100 |
|---|---|---|
| committer | Taras Madan <tarasmadan@google.com> | 2026-01-21 22:46:06 +0000 |
| commit | a16aed1db22739e7dea8098c79bc1963b871b5ec (patch) | |
| tree | ac3968a697f9cbe78c66915abe2a8d00e58a787b /pkg/rpcserver/rpcserver.go | |
| parent | 7ee46ad36cdaae818f74dea493b5ec30df3fe31b (diff) | |
all: fix context.Context usage
Diffstat (limited to 'pkg/rpcserver/rpcserver.go')
| -rw-r--r-- | pkg/rpcserver/rpcserver.go | 4 |
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() |
