221222223224225226227228229230231
e2.shutdownGracefully(); e3.shutdownGracefully(); e4.shutdownGracefully(); e5.shutdownGracefully(); l.terminationFuture().sync(); e1.terminationFuture().sync(); e2.terminationFuture().sync(); e3.terminationFuture().sync(); e4.terminationFuture().sync(); e5.terminationFuture().sync();
195196197198199200201202203204205
} finally { l.shutdownGracefully(); e1.shutdownGracefully(); e2.shutdownGracefully(); l.terminationFuture().sync(); e1.terminationFuture().sync(); e2.terminationFuture().sync(); } }
321322323324325326327328329330331
e2.shutdownGracefully(); e3.shutdownGracefully(); e4.shutdownGracefully(); e5.shutdownGracefully(); l0.terminationFuture().sync(); e1.terminationFuture().sync(); e2.terminationFuture().sync(); e3.terminationFuture().sync(); e4.terminationFuture().sync(); e5.terminationFuture().sync();
949596979899100101102103104
assertNull(String.format( "Expected null, got channel '%s' for local address '%s'", LocalChannelRegistry.get(addr), addr), LocalChannelRegistry.get(addr)); serverGroup.terminationFuture().sync(); clientGroup.terminationFuture().sync(); } } @Test
144145146147148149150151152153154
} } serverGroup.shutdownGracefully(); clientGroup.shutdownGracefully(); serverGroup.terminationFuture().sync(); clientGroup.terminationFuture().sync(); } @Test public void testServerCloseChannelSameEventLoop() throws Exception {
178179180181182183184185186187188
}); Channel channel = b.connect(addr).sync().channel(); channel.writeAndFlush(new Object()); latch.await(); group.shutdownGracefully(); group.terminationFuture().sync(); } @Test public void localChannelRaceCondition() throws Exception { final LocalAddress address = new LocalAddress("test");
5354555657585960
} bossGroup.shutdownGracefully(); workerGroup.shutdownGracefully(); bossGroup.terminationFuture().sync(); workerGroup.terminationFuture().sync(); } }