diff --git a/server/imserver/WSPListener.go b/server/imserver/WSPListener.go index 0ec12ea1..c6606e69 100644 --- a/server/imserver/WSPListener.go +++ b/server/imserver/WSPListener.go @@ -13,7 +13,7 @@ import ( type WSPListener_ struct { listener net.Listener - ch <-chan *q5.MsgHdr + ch chan *q5.MsgHdr msgList q5.ListHead } @@ -119,6 +119,7 @@ func (this *WSPListener_) decodePacket(buf []byte, offset *int, bufLen int) { hdr := new(q5.MsgHdr) hdr.MsgId = int(buf[*offset + 2]) + int(buf[*offset + 3] << 16) //hdr.SeqId = int(recvBuf[4]) + int(recvBuf[5] ) + this.ch <- hdr *offset += 20 + packLen } else { warning = true