190191192193194195196197198199200
List<DiscoveryEntry> entries = dg.getDiscoveryEntries(); assertEqualsDiscoveryEntries(Arrays.asList(live1), entries); bg.stop(); dg.stop(); } public void testSimpleBroadcastWithStopStartDiscoveryGroup() throws Exception {
236237238239240241242243244245246
List<DiscoveryEntry> entries = dg.getDiscoveryEntries(); assertEqualsDiscoveryEntries(Arrays.asList(live1), entries); bg.stop(); dg.stop(); dg.start(); bg.start();
251252253254255256257258259260261
Assert.assertTrue(ok); entries = dg.getDiscoveryEntries(); assertEqualsDiscoveryEntries(Arrays.asList(live1), entries); dg.stop(); bg.stop(); } public void testIgnoreTrafficFromOwnNode() throws Exception
301302303304305306307308309310311
Assert.assertEquals(0, entries.size()); bg.stop(); dg.stop(); } // There is a bug in some OSes where different addresses but *Same port* will receive the traffic - hence this test // won't pass
386387388389390391392393394395396
Assert.assertFalse(ok); bg.stop(); dg.stop(); } public void testSimpleBroadcastDifferentAddressAndPort() throws Exception { final InetAddress groupAddress = InetAddress.getByName(address1);
429430431432433434435436437438439
Assert.assertFalse(ok); bg.stop(); dg.stop(); } public void testMultipleGroups() throws Exception { final int groupPort1 = getUDPDiscoveryPort();
542543544545546547548549550551552
bg2.stop(); bg3.stop(); dg1.stop(); dg2.stop(); dg3.stop(); } // -- fix this test // public void testBroadcastNullBackup() throws Exception // {
651652653654655656657658659660661
Assert.assertFalse(listener2.called); Assert.assertFalse(listener3.called); bg.stop(); dg.stop(); } public void testConnectorsUpdatedMultipleBroadcasters() throws Exception { final InetAddress groupAddress = InetAddress.getByName(address1);
841842843844845846847848849850851
bg1.stop(); bg2.stop(); bg3.stop(); dg.stop(); } public void testMultipleDiscoveryGroups() throws Exception { final InetAddress groupAddress = InetAddress.getByName(address1);
912913914915916917918919920921922
bg.stop(); dg1.stop(); dg2.stop(); dg3.stop(); } public void testDiscoveryGroupNotifications() throws Exception { SimpleNotificationService notifService = new SimpleNotificationService();