Commit f082b884 authored by Kirill Smelkov's avatar Kirill Smelkov

.

parent ae09ca4d
...@@ -1432,7 +1432,7 @@ func pktEncodeN(connId uint32, msg proto.Msg) *pktBuf { ...@@ -1432,7 +1432,7 @@ func pktEncodeN(connId uint32, msg proto.Msg) *pktBuf {
func pktDecodeHeadN(pkt *pktBuf) (connID uint32, msgCode uint16, payload []byte, err error) { func pktDecodeHeadN(pkt *pktBuf) (connID uint32, msgCode uint16, payload []byte, err error) {
if len(pkt.data) < proto.PktHeaderLenN { if len(pkt.data) < proto.PktHeaderLenN {
return 0, 0, nil, fmt.Errorf("packet too short") // XXX -> ErrTooShort? return 0, 0, nil, fmt.Errorf("packet too short")
} }
pkth := pkt.HeaderN() pkth := pkt.HeaderN()
connID = packed.Ntoh32(pkth.ConnId) connID = packed.Ntoh32(pkth.ConnId)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment