fix: concurrent map writes (#861)

zhangfangjie · zhangfangjie · commit c6a3acebd944 · 2025-12-03T11:57:38.000+08:00
Add your commit body here
diff --git a/common/remote/rpc/rpc_client.go b/common/remote/rpc/rpc_client.go
@@ -381,7 +381,9 @@ func (r *RpcClient) registerServerRequestHandlers() {
 func (r *RpcClient) Shutdown() {
 	atomic.StoreInt32((*int32)(&r.rpcClientStatus), (int32)(SHUTDOWN))
 	r.closeConnection()
+	cMux.Lock()
 	delete(clientMap, r.name)
+	cMux.Unlock()
 }
 
 func (r *RpcClient) RegisterServerRequestHandler(request func() rpc_request.IRequest, handler IServerRequestHandler) {

Original file line number	Diff line number	Diff line change
`@@ -381,7 +381,9 @@ func (r *RpcClient) registerServerRequestHandlers() {`
`381`	`381`	`func (r *RpcClient) Shutdown() {`
`382`	`382`	`atomic.StoreInt32((*int32)(&r.rpcClientStatus), (int32)(SHUTDOWN))`
`383`	`383`	`r.closeConnection()`
	`384`	`+ cMux.Lock()`
`384`	`385`	`delete(clientMap, r.name)`
	`386`	`+ cMux.Unlock()`
`385`	`387`	`}`
`386`	`388`
`387`	`389`	`func (r *RpcClient) RegisterServerRequestHandler(request func() rpc_request.IRequest, handler IServerRequestHandler) {`