public DatagramBulkReflector(String name, InetSocketAddress bindAddress,
long limit,
CyclicBarrier readBarrier) throws IOException {
this.channel = DatagramChannel.open(StandardProtocolFamily.INET);
this.channel.configureBlocking(true);
this.channel.bind(bindAddress);
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Bulk reflector {}: BIND<{}>", new Object[]{name, bindAddress});
}
this.reflector = new Reflector(channel, name, limit, readBarrier);
}
DatagramBulkReflector.java 文件源码
java
阅读 15
收藏 0
点赞 0
评论 0
项目:netcrusher-java
作者:
评论列表
文章目录