141142143144145146147148149150151
ListenerEndpoint endpoint = endpoints.iterator().next(); assertEquals(9999, ((InetSocketAddress) endpoint.getAddress()).getPort()); ioreactor.shutdown(1000); t.join(1000); assertEquals(IOReactorStatus.SHUT_DOWN, ioreactor.getStatus()); }
201202203204205206207208209210211
Set<ListenerEndpoint> endpoints = ioreactor.getEndpoints(); assertNotNull(endpoints); assertEquals(0, endpoints.size()); ioreactor.shutdown(1000); t.join(1000); assertEquals(IOReactorStatus.SHUT_DOWN, ioreactor.getStatus()); }
119120121122123124125126127128129
ListenerEndpoint endpoint = endpoints.iterator().next(); Assert.assertEquals(port, ((InetSocketAddress) endpoint.getAddress()).getPort()); ioreactor.shutdown(1000); t.join(1000); Assert.assertEquals(IOReactorStatus.SHUT_DOWN, ioreactor.getStatus()); }
165166167168169170171172173174175
Set<ListenerEndpoint> endpoints = ioreactor.getEndpoints(); Assert.assertNotNull(endpoints); Assert.assertEquals(0, endpoints.size()); ioreactor.shutdown(1000); t.join(1000); Assert.assertEquals(IOReactorStatus.SHUT_DOWN, ioreactor.getStatus()); }
198199200201202203204205206207208
137138139140141142143144145146147
121122123124125126127128129130131
ListenerEndpoint endpoint = endpoints.iterator().next(); Assert.assertEquals(9999, ((InetSocketAddress) endpoint.getAddress()).getPort()); ioreactor.shutdown(1000); t.join(1000); Assert.assertEquals(IOReactorStatus.SHUT_DOWN, ioreactor.getStatus()); }
185186187188189190191192193194195
140141142143144145146147148149150
200201202203204205206207208209210