diff --git a/lego/sys/rpcx/service.go b/lego/sys/rpcx/service.go index 71a8d78c7..f81017b62 100644 --- a/lego/sys/rpcx/service.go +++ b/lego/sys/rpcx/service.go @@ -519,7 +519,7 @@ func (this *Service) clusterbroadcast(ctx context.Context, servicePath string, s _call.Done = make(chan *client.Call, 10) this.send(_ctx, conn, spath[0], serviceMethod, metadata, _call) - seq, _ := ctx.Value(seqKey{}).(*uint64) + seq, _ := _ctx.Value(seqKey{}).(*uint64) select { case <-_ctx.Done(): // cancel by context this.mutex.Lock()