shkong/go-cqhttp
1
0
Fork 0
mirror of https://github.com/Mrs4s/go-cqhttp.git synced 2025-05-04 19:17:37 +08:00
Code Issues Projects Releases Wiki Activity

fix(ws server): add lock when accept a connection

Browse Source 
(cherry picked from commit 5d61a254e635182ca1e5051f8d38aa44d4188f53)
This commit is contained in:
wdvxdr 2021-03-19 22:17:31 +08:00
parent 190eb00143
commit 2aed5d5a16
No known key found for this signature in database
GPG Key ID: 55FF1414A69CEBA6
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/websocket.go
View File

@ -301,7 +301,9 @@ func (s *webSocketServer) any(w http.ResponseWriter, r *http.Request) {
} }
log.Infof("接受 WebSocket 连接: %v (/)", r.RemoteAddr) log.Infof("接受 WebSocket 连接: %v (/)", r.RemoteAddr)
conn := &webSocketConn{Conn: c, apiCaller: apiCaller{s.bot}} conn := &webSocketConn{Conn: c, apiCaller: apiCaller{s.bot}}
s.eventConnMutex.Lock()
s.eventConn = append(s.eventConn, conn) s.eventConn = append(s.eventConn, conn)
s.eventConnMutex.Unlock()
s.listenAPI(conn) s.listenAPI(conn)
} }