|
@ -623,7 +623,7 @@ func (ch *Channel) writeMsgPacketTo(w io.Writer) (n int, err error) { |
|
|
func (ch *Channel) recvMsgPacket(packet msgPacket) ([]byte, error) { |
|
|
func (ch *Channel) recvMsgPacket(packet msgPacket) ([]byte, error) { |
|
|
// log.Debug("Read Msg Packet", "conn", ch.conn, "packet", packet)
|
|
|
// log.Debug("Read Msg Packet", "conn", ch.conn, "packet", packet)
|
|
|
if ch.desc.RecvMessageCapacity < len(ch.recving)+len(packet.Bytes) { |
|
|
if ch.desc.RecvMessageCapacity < len(ch.recving)+len(packet.Bytes) { |
|
|
return nil, wire.ErrBinaryReadSizeOverflow |
|
|
|
|
|
|
|
|
return nil, wire.ErrBinaryReadOverflow |
|
|
} |
|
|
} |
|
|
ch.recving = append(ch.recving, packet.Bytes...) |
|
|
ch.recving = append(ch.recving, packet.Bytes...) |
|
|
if packet.EOF == byte(0x01) { |
|
|
if packet.EOF == byte(0x01) { |
|
|