Examples of org.jgroups.stack.GossipRouter.stop()

org.jgroups.stack.GossipRouter.stop()
Always called before destroy(). Close connections and frees resources.

                 1, drm2.lookupReplicants(SERVICEB).size());


         // simulate a split of the partition
         log.info("DRMTestCase.testIsMasterReplica() - stopping GossipRouter");
         router.clear();   // temporary workaround for JGRP-1232
         router.stop();
         sleepThread(15000);
         log.info("router stopped, routing table = " + router.dumpRoutingTable() + ", partition1 view=" + partition1.getCurrentView().toString());
         assertTrue("router is stopped", !router.isStarted());
         assertTrue("router is NOT running", !router.isRunning());

View Full Code Here

         if (partition1Started)
            partition1.stop();
         if (partition2Started)
            partition2.stop();
         if (router != null)
            router.stop();
      }
   }
   
   /**
    * Tests that one thread blocking in DRM.notifyKeyListeners() does not

View Full Code Here

            channel.close();
            coordinator.close();
        }
        finally {
            if(router != null){
                router.stop();
                //release ports
                Util.sleep(1000);
            }
        }
    }

View Full Code Here

            channel.disconnect();
            assertNull(channel.getLocalAddress());
        }
        finally {
            if(router != null)
                router.stop();
        }
    }




    /**

View Full Code Here

            assertEquals(1, view.size());
            assertTrue(view.containsMember(channel.getLocalAddress()));
        }
        finally {
            if(router != null)
                router.stop();
        }
     }




    public void testConnectTwo_TUNNEL() throws Exception {

View Full Code Here

             channel.close();
             coordinator.close();
         }
         finally {
             if(router != null){
                 router.stop();
                 //release ports
                 Util.sleep(1000);
             }
         }
     }

View Full Code Here

             channel.close();
             coordinator.close();
         }
         finally {
             if(router != null){
                 router.stop();
                 //release ports
                 Util.sleep(1000);
             }
         }
     }

View Full Code Here

         assertEquals("Partition2 should contain one DRM replicant for serviceB; ", 
                 1, drm2.lookupReplicants(SERVICEB).size());


         // simulate a split of the partition
         log.info("DRMTestCase.testIsMasterReplica() - stopping GossipRouter");
         router.stop();
         sleepThread(15000);
         
         // confirm that each partition contains one node   
         assertEquals("Partition1 should contain one node after split; ", 
                 1, partition1.getCurrentView().size());

View Full Code Here

         if (partition1Started)
            partition1.stop();
         if (partition2Started)
            partition2.stop();
         if (router != null)
            router.stop();
      }
   }
   
   /**
    * Tests that one thread blocking in DRM.notifyKeyListeners() does not

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.