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

fix delay on reconnect.

Browse Source
This commit is contained in:
Mrs4s 2020-12-29 17:44:54 +08:00
parent b569935970
commit 2476ece99e
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
client/client.go
View File

@ -957,7 +957,7 @@ func (c *QQClient) sendAndWait(seq uint16, pkt []byte) (interface{}, error) {
select { select {
case rsp := <-ch: case rsp := <-ch:
return rsp.Response, rsp.Error return rsp.Response, rsp.Error
case <-time.After(time.Second * 30): case <-time.After(time.Second * 15):
retry++ retry++
if retry < 2 { if retry < 2 {
_ = c.send(pkt) _ = c.send(pkt)
@ -991,12 +991,14 @@ func (c *QQClient) netLoop() {
break break
} }
reader = binary.NewNetworkReader(c.Conn) reader = binary.NewNetworkReader(c.Conn)
go func() {
if e := c.registerClient(); e != nil && e.Error() != "Packet timed out" { // 掉线在心跳已经有判断了, 只需要处理返回值 if e := c.registerClient(); e != nil && e.Error() != "Packet timed out" { // 掉线在心跳已经有判断了, 只需要处理返回值
c.Disconnect()
c.lastLostMsg = "register client failed: " + e.Error() c.lastLostMsg = "register client failed: " + e.Error()
c.Disconnect()
c.Error("reconnect failed: " + e.Error()) c.Error("reconnect failed: " + e.Error())
break //break
} }
}()
} }
if l <= 0 { if l <= 0 {
retry++ retry++