equal
deleted
inserted
replaced
92 .bind(new InetSocketAddress(0)); |
92 .bind(new InetSocketAddress(0)); |
93 |
93 |
94 for (int i=0; i<count; i++) { |
94 for (int i=0; i<count; i++) { |
95 final CountDownLatch latch = new CountDownLatch(1); |
95 final CountDownLatch latch = new CountDownLatch(1); |
96 |
96 |
97 listener.accept(null, new CompletionHandler<AsynchronousSocketChannel,Void>() { |
97 listener.accept((Void)null, new CompletionHandler<AsynchronousSocketChannel,Void>() { |
98 public void completed(AsynchronousSocketChannel ch, Void att) { |
98 public void completed(AsynchronousSocketChannel ch, Void att) { |
99 try { |
99 try { |
100 ch.close(); |
100 ch.close(); |
101 } catch (IOException ignore) { } |
101 } catch (IOException ignore) { } |
102 |
102 |