liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

上传rpcx代码

Browse Source
This commit is contained in:
liwei1dao 2023-09-11 16:36:30 +08:00
parent 1955ce04ec
commit 4547453aba
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
lego/sys/rpcx/service.go
View File

@ -519,7 +519,7 @@ func (this *Service) clusterbroadcast(ctx context.Context, servicePath string, s
_call.Done = make(chan *client.Call, 10) _call.Done = make(chan *client.Call, 10)
this.send(_ctx, conn, spath[0], serviceMethod, metadata, _call) this.send(_ctx, conn, spath[0], serviceMethod, metadata, _call)
seq, _ := ctx.Value(seqKey{}).(*uint64) seq, _ := _ctx.Value(seqKey{}).(*uint64)
select { select {
case <-_ctx.Done(): // cancel by context case <-_ctx.Done(): // cancel by context
this.mutex.Lock() this.mutex.Lock()