Update pool.go (#134)

vesoft-inc · Feb 14, 2023 · 04ec84c · 04ec84c
1 parent e133a77
commit 04ec84c
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/ccore/nebula/gateway/pool/pool.go b/ccore/nebula/gateway/pool/pool.go
@@ -274,13 +274,15 @@ func ClearClients() {
 }
 
 func recycleClients() {
+	clientMux.Lock()
 	for _, client := range clientPool {
 		now := time.Now().Unix()
 		expireAt := client.updateTime + SessionExpiredDuration
 		if now > expireAt {
 			client.CloseChannel <- true
 		}
 	}
+	clientMux.Unlock()
 }
 
 func handleRequest(nsid string) {