Release the byte buffer when it's a broadcast packet
This commit is contained in:
parent
882b65ccf1
commit
7e32a2ff5b
@ -19,6 +19,7 @@ import java.net.InetSocketAddress;
|
|||||||
|
|
||||||
import dorkbox.network.Broadcast;
|
import dorkbox.network.Broadcast;
|
||||||
import dorkbox.network.Server;
|
import dorkbox.network.Server;
|
||||||
|
import dorkbox.network.connection.EndPoint;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.socket.DatagramPacket;
|
import io.netty.channel.socket.DatagramPacket;
|
||||||
@ -51,7 +52,9 @@ class BroadcastServer {
|
|||||||
|
|
||||||
channel.writeAndFlush(new DatagramPacket(directBuffer, remoteAddress, localAddress));
|
channel.writeAndFlush(new DatagramPacket(directBuffer, remoteAddress, localAddress));
|
||||||
|
|
||||||
logger.info("Responded to host discovery from: {}", remoteAddress);
|
logger.info("Responded to host discovery from [{}]", EndPoint.getHostDetails(remoteAddress));
|
||||||
|
|
||||||
|
byteBuf.release();
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user