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

fix(server): fix Mutex change in reconnect

Browse Source
This commit is contained in:
wdvxdr 2021-12-26 15:48:08 +08:00
parent ef2223828f
commit 80e35fc800
No known key found for this signature in database
GPG Key ID: 703F8C071DE7A1B6
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
server/websocket.go
View File

@ -270,14 +270,22 @@ func (c *websocketClient) connect(typ, url string, conptr **wsConn) {
} }
log.Infof("已连接到反向WebSocket %s服务器 %v", typ, url) log.Infof("已连接到反向WebSocket %s服务器 %v", typ, url)
wrappedConn := &wsConn{conn: conn, apiCaller: api.NewCaller(c.bot)}
if c.limiter != nil {
wrappedConn.apiCaller.Use(c.limiter)
}
var wrappedConn *wsConn
if conptr != nil && *conptr != nil {
wrappedConn = *conptr
} else {
wrappedConn = new(wsConn)
if conptr != nil { if conptr != nil {
*conptr = wrappedConn *conptr = wrappedConn
} }
}
wrappedConn.conn = conn
wrappedConn.apiCaller = api.NewCaller(c.bot)
if c.limiter != nil {
wrappedConn.apiCaller.Use(c.limiter)
}
if typ != "Event" { if typ != "Event" {
go c.listenAPI(typ, url, wrappedConn) go c.listenAPI(typ, url, wrappedConn)