lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-09-23 05:03:36 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Set the capacity of clientChan to 10000 (#5647)

Browse Source
This commit is contained in:
steve.wei
2024-06-05 20:41:46 +08:00
committed by GitHub
parent 1f2dc54647
commit d8da4bbaa7
1 changed files with 1 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
weed/server/master_grpc_server.go
View File

@@ -361,8 +361,7 @@ func (ms *MasterServer) addClient(filerGroup, clientType string, clientAddress p
// the KeepConnected loop is no longer listening on this channel but we're // the KeepConnected loop is no longer listening on this channel but we're
// trying to send to it in SendHeartbeat and so we can't lock the // trying to send to it in SendHeartbeat and so we can't lock the
// clientChansLock to remove the channel and we're stuck writing to it // clientChansLock to remove the channel and we're stuck writing to it
// 100 is probably overkill messageChan = make(chan *master_pb.KeepConnectedResponse, 10000)
messageChan = make(chan *master_pb.KeepConnectedResponse, 100)
ms.clientChansLock.Lock() ms.clientChansLock.Lock()
ms.clientChans[clientName] = messageChan ms.clientChans[clientName] = messageChan