From 4547453aba293f00dc7125781eee55f7c5e8bf3a Mon Sep 17 00:00:00 2001 From: liwei1dao Date: Mon, 11 Sep 2023 16:36:30 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8A=E4=BC=A0rpcx=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- lego/sys/rpcx/service.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()