201202203204205206207208209210211
Set<ListenerEndpoint> endpoints = ioreactor.getEndpoints(); assertNotNull(endpoints); assertEquals(0, endpoints.size()); ioreactor.shutdown(1000); t.join(1000); assertEquals(IOReactorStatus.SHUT_DOWN, ioreactor.getStatus()); }
178179180181182183184185186187188
System.err.println("Interrupted"); } catch (IOException ex) { ex.printStackTrace(); } finally { try { listeningIOReactor.shutdown(); } catch (IOException ex2) { ex2.printStackTrace(); } } }
185186187188189190191192193194195
112113114115116117118119120121122
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()); }
157158159160161162163164165166167
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()); }
184185186187188189190191192193194
119120121122123124125126127128129
165166167168169170171172173174175
183184185186187188189190191192193