From 3f5a6cf6fc127a2d43189f37c61a9b2c794cd674 Mon Sep 17 00:00:00 2001 From: GoEdgeLab Date: Sat, 20 Nov 2021 19:17:57 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96RPC=E5=AE=A2=E6=88=B7?= =?UTF-8?q?=E7=AB=AF=E9=94=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/rpc/rpc_client.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/rpc/rpc_client.go b/internal/rpc/rpc_client.go index 84c30cc..f34eed7 100644 --- a/internal/rpc/rpc_client.go +++ b/internal/rpc/rpc_client.go @@ -231,8 +231,8 @@ func (this *RPCClient) init() error { // 随机选择一个连接 func (this *RPCClient) pickConn() *grpc.ClientConn { - this.locker.RLock() - defer this.locker.RUnlock() + this.locker.Lock() + defer this.locker.Unlock() // 检查连接状态 if len(this.conns) > 0 {