fix
This commit is contained in:
parent
ab0935816d
commit
d7a5a8d9af
@ -165,6 +165,10 @@ func (p *Client) Accept() error {
|
|||||||
|
|
||||||
func (p *Client) processPacket(packet *Packet) {
|
func (p *Client) processPacket(packet *Packet) {
|
||||||
|
|
||||||
|
if packet.rproto != 0 {
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
if packet.msgType == PING {
|
if packet.msgType == PING {
|
||||||
t := time.Time{}
|
t := time.Time{}
|
||||||
t.UnmarshalBinary(packet.data)
|
t.UnmarshalBinary(packet.data)
|
||||||
@ -174,10 +178,6 @@ func (p *Client) processPacket(packet *Packet) {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
if packet.rproto != 0 {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
|
|
||||||
//fmt.Printf("processPacket %s %s %d\n", packet.id, packet.src.String(), len(packet.data))
|
//fmt.Printf("processPacket %s %s %d\n", packet.id, packet.src.String(), len(packet.data))
|
||||||
|
|
||||||
clientConn := p.localIdToConnMap[packet.id]
|
clientConn := p.localIdToConnMap[packet.id]
|
||||||
|
Loading…
x
Reference in New Issue
Block a user