@Test(timeout = 30000) public void testRejoinSingleNode() throws IOException, InterruptedException { useFastFailureDetectionTimeouts(); final Endpoint seedEndpoint = Utils.hostFromParts("127.0.0.1", basePort); final Endpoint leavingEndpoint = Utils.hostFromParts("127.0.0.1", basePort + 1); createCluster(10, seedEndpoint); for (int i = 0; i < 2; i++) { final Cluster cluster = instances.remove(leavingEndpoint); cluster.shutdown(); waitAndVerifyAgreement(9, 20, 500); extendCluster(leavingEndpoint, seedEndpoint); waitAndVerifyAgreement(10, 20, 500); } }
public void shutdown() { LOG.debug("Shutting down RpcServer and MembershipService"); rpcServer.shutdown(); membershipService.shutdown(); sharedResources.shutdown(); this.hasShutdown = true; }
Cluster { public void shutdown() { LOG.debug("Shutting down RpcServer and MembershipService"); rpcServer.shutdown(); membershipService.shutdown(); sharedResources.shutdown(); this.hasShutdown = true; } }
Cluster { public void shutdown() { LOG.debug("Shutting down RpcServer and MembershipService"); rpcServer.shutdown(); membershipService.shutdown(); sharedResources.shutdown(); this.hasShutdown = true; } private  Cluster(final IMessagingServer rpcServer,
                    final MembershipService membershipService,
                    final SharedResources sharedResources,
                    final Endpoint listenAddress); }
Cluster { public void shutdown() { LOG.debug("Shutting down RpcServer and MembershipService"); rpcServer.shutdown(); membershipService.shutdown(); sharedResources.shutdown(); this.hasShutdown = true; } private  Cluster(final IMessagingServer rpcServer,
                    final MembershipService membershipService,
                    final SharedResources sharedResources,
                    final Endpoint listenAddress); List<Endpoint> getMemberlist(); int getMembershipSize(); Map<Endpoint, Metadata> getClusterMetadata(); void registerSubscription(final ClusterEvents event,
                                     final BiConsumer<Long, List<NodeStatusChange>> callback); void leaveGracefully(); void shutdown(); @Override String toString(); }
Cluster { public void shutdown() { LOG.debug("Shutting down RpcServer and MembershipService"); rpcServer.shutdown(); membershipService.shutdown(); sharedResources.shutdown(); this.hasShutdown = true; } private  Cluster(final IMessagingServer rpcServer,
                    final MembershipService membershipService,
                    final SharedResources sharedResources,
                    final Endpoint listenAddress); List<Endpoint> getMemberlist(); int getMembershipSize(); Map<Endpoint, Metadata> getClusterMetadata(); void registerSubscription(final ClusterEvents event,
                                     final BiConsumer<Long, List<NodeStatusChange>> callback); void leaveGracefully(); void shutdown(); @Override String toString();  }