fix
This commit is contained in:
parent
0117c80ec8
commit
b1654595ce
@ -202,6 +202,10 @@ func (p *Client) processPacket(packet *Packet) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if packet.echoId != p.id {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
if packet.msgType == PING {
|
if packet.msgType == PING {
|
||||||
t := time.Time{}
|
t := time.Time{}
|
||||||
t.UnmarshalBinary(packet.data)
|
t.UnmarshalBinary(packet.data)
|
||||||
@ -214,7 +218,7 @@ func (p *Client) processPacket(packet *Packet) {
|
|||||||
|
|
||||||
clientConn := p.localIdToConnMap[packet.id]
|
clientConn := p.localIdToConnMap[packet.id]
|
||||||
if clientConn == nil {
|
if clientConn == nil {
|
||||||
fmt.Printf("processPacket no conn %s \n", packet.id)
|
//fmt.Printf("processPacket no conn %s \n", packet.id)
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user