Examples of shutdownPeer()

Examples of com.linkedin.d2.quorum.ZKPeer.shutdownPeer()

64
65
66
67
68
69
70
71
72
73
74
  public void testD2ConfigWithZKQuorumV3DegraderDefaultPartitionFollowerPeerDown() throws Exception
  {
    setup();
    String connectionString = _quorum.getHosts();
    ZKPeer follower = _quorum.getQuorumFollower();
    follower.shutdownPeer();
    assertEquals(LoadBalancerClientCli.runDiscovery(connectionString, "/d2", D2_CONFIG_DEFAULT_PARTITION_DATA), 0);
  }

  public void testD2ConfigWithZKQuorumV3DegraderDefaultPartitionLeaderPeerDown() throws Exception
  {
View Full Code Here

Examples of com.linkedin.d2.quorum.ZKPeer.shutdownPeer()

73
74
75
76
77
78
79
80
81
82
83
  public void testD2ConfigWithZKQuorumV3DegraderDefaultPartitionLeaderPeerDown() throws Exception
  {
    setup();
    String connectionString = _quorum.getHosts();
    ZKPeer leader = _quorum.getQuorumLeader();
    leader.shutdownPeer();
    assertEquals(LoadBalancerClientCli.runDiscovery(connectionString, "/d2", D2_CONFIG_DEFAULT_PARTITION_DATA), 0);
  }

  public void testD2ConfigWithZKQuorumV3DegraderDefaultPartitionMultiplePeersDown() throws Exception
  {
View Full Code Here

Examples of com.linkedin.d2.quorum.ZKPeer.shutdownPeer()

107
108
109
110
111
112
113
114
115
116
117
  public void testD2ConfigWithZKQuorumV3DegraderCustomPartitionFollowerPeerDown() throws Exception
  {
    setup();
    String connectionString = _quorum.getHosts();
    ZKPeer follower = _quorum.getQuorumFollower();
    follower.shutdownPeer();
    assertEquals(LoadBalancerClientCli.runDiscovery(connectionString, "/d2", D2_CONFIG_DEFAULT_PARTITION_DATA), 0);
  }

  public void testD2ConfigWithZKQuorumV3DegraderCustomPartitionMultiplePeersDown() throws Exception
  {
View Full Code Here

Examples of com.linkedin.d2.quorum.ZKPeer.shutdownPeer()

129
130
131
132
133
134
135
136
137
138
139
  public void testD2ConfigWithZKQuorumV3DegraderCustomPartitionLeaderPeerDown() throws Exception
  {
    setup();
    String connectionString = _quorum.getHosts();
    ZKPeer leader = _quorum.getQuorumLeader();
    leader.shutdownPeer();
    assertEquals(LoadBalancerClientCli.runDiscovery(connectionString, "/d2", D2_CONFIG_DEFAULT_PARTITION_DATA), 0);
  }

  public void testD2ConfigWithZKQuorumV3DegraderDefaultPartitionInvalidHost() throws Exception
  {
View Full Code Here

Examples of com.linkedin.d2.quorum.ZKPeer.shutdownPeer()

112
113
114
115
116
117
118
119
120
121
122
  public void testD2WithQuorumFollowerPeerDown() throws Exception
  {
    setup();
    // Shutdown zk _quorum follower peer (non-leader member of a zk _quorum)
    ZKPeer follower = _quorum.getQuorumFollower();
    follower.shutdownPeer();
    // Assert requests are processed while follower goes down
    long start = System.currentTimeMillis();
    while (follower.getZKServer() != null && System.currentTimeMillis() < start + TIMEOUT)
    {
      assertQuorumProcessAllRequests(D2_CONFIG_DATA);
View Full Code Here

Examples of com.linkedin.d2.quorum.ZKPeer.shutdownPeer()

183
184
185
186
187
188
189
190
191
192
193
    // Shutdown zk _quorum leader peer
    ZKPeer peer = _quorum.getQuorumLeader();
    if (peer != null)
    {
      int peerId = peer.getId();
      peer.shutdownPeer();
      // Verify requests are processed while leader goes down
      long start = System.currentTimeMillis();
      while (_quorum.getQuorumLeader() != null && _quorum.getQuorumLeader().equals(peer) && System.currentTimeMillis() < (start + TIMEOUT))
      {
        assertQuorumProcessAllRequests(D2_CONFIG_DATA);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.