123124125126127128129130131132133
{ participants[i].syncStop(); } Thread.sleep(2000); controller.syncStop(); System.out.println("END " + clusterName + " at " + new Date(System.currentTimeMillis())); }
117118119120121122123124125126127
Assert.assertTrue(result, "Cluster verification fails"); // clean up // wait for all zk callbacks done Thread.sleep(1000); controller.syncStop(); for (int i = 0; i < 5; i++) { participants[i].syncStop(); }
193194195196197198199200201202203
Assert.assertEquals(_errToOfflineInvoked, 2, "Should reset 2 partitions"); // clean up // wait for all zk callbacks done Thread.sleep(1000); controller.syncStop(); for (int i = 0; i < 5; i++) { participants[i].syncStop(); }
110111112113114115116117118119120
Assert.assertTrue(listener._maxNbOfChilds <= 2, "Should get no more than 2 messages (O->S and S->M)"); // clean up // wait for all zk callbacks done Thread.sleep(1000); controller.syncStop(); for (int i = 0; i < n; i++) { participants[i].syncStop(); }
199200201202203204205206207208209
// clean up // wait for all zk callbacks done Thread.sleep(1000); controller.syncStop(); for (int i = 0; i < n; i++) { participants[i].syncStop(); }
5152535455565758596061
MockParticipant other = _other.getAndSet(null); if (other != null) { System.err.println("Kill " + other.getInstanceName() + ". Interrupted exceptions are IGNORABLE"); other.syncStop(); } } } @Test()