|
|
@ -76,7 +76,7 @@ func (this *UDPHub) start() {
|
|
|
|
oobBytes := make([]byte, 256)
|
|
|
|
oobBytes := make([]byte, 256)
|
|
|
|
for this.Running() {
|
|
|
|
for this.Running() {
|
|
|
|
buffer := alloc.NewBuffer()
|
|
|
|
buffer := alloc.NewBuffer()
|
|
|
|
nBytes, noob, _, addr, err := this.conn.ReadMsgUDP(buffer.Value, oobBytes)
|
|
|
|
nBytes, noob, _, addr, err := ReadUDPMsg(this.conn, buffer.Value, oobBytes)
|
|
|
|
if err != nil {
|
|
|
|
if err != nil {
|
|
|
|
log.Info("UDP|Hub: Failed to read UDP msg: ", err)
|
|
|
|
log.Info("UDP|Hub: Failed to read UDP msg: ", err)
|
|
|
|
buffer.Release()
|
|
|
|
buffer.Release()
|
|
|
|