198199200201202203204205206207208
manager.stop(); } finally { server.stop(); } } public void testConnectIntoNonBackup() throws Exception {
232233234235236237238239240241242
manager.stop(); } finally { server.stop(); } } public void testSendPackets() throws Exception {
332333334335336337338339340341342
manager.stop(); } finally { server.stop(); } } public void testSendPacketsWithFailure() throws Exception {
384385386387388389390391392393394
{ latch.countDown(); } }); server.stop(); Assert.assertTrue(latch.await(50, TimeUnit.SECONDS)); } finally {
390391392393394395396397398399400
Assert.assertTrue(latch.await(50, TimeUnit.SECONDS)); } finally { server.stop(); } } public void testExceptionSettingActionBefore() throws Exception {
566567568569570571572573574575576
Assert.assertEquals(0, manager.getActiveTokens().size()); manager.stop(); } finally { server.stop(); } } public void testOrderOnNonPersistency() throws Exception {
636637638639640641642643644645646
Assert.assertEquals(0, manager.getActiveTokens().size()); manager.stop(); } finally { server.stop(); } } class FakeData implements EncodingSupport {
118119120121122123124125126127128
manager.start(); manager.stop(); } finally { server.stop(); } } public void testInvalidJournal() throws Exception {
158159160161162163164165166167168
manager.stop(); } finally { server.stop(); } } // should throw an exception if a second server connects to the same backup public void testInvalidConnection() throws Exception