Package com.sun.sgs.test.impl.service.session.TestClientSessionServiceImplv4

Examples of com.sun.sgs.test.impl.service.session.TestClientSessionServiceImplv4.DummyClient.relocate()

123
124
125
126
127
128
129
130
131
132
133
  String newNodeHost = "new";
  DummyClient client = createClientToRelocate(newNodeHost);
  try {
      SgsTestNode newNode = additionalNodes.get(newNodeHost);
      int objectCount = getObjectCount();
      client.relocate(newNode.getAppPort(), false, false);
      waitForExpectedObjectCount(
    objectCount - MANAGED_OBJECTS_PER_SESSION);
      checkBindings(0);
      client.assertDisconnectedCallbackInvoked(false);
  } finally {
View Full Code Here
185
186
187
188
189
190
191
192
193
194
195
  SgsTestNode node2 = additionalNodes.get(host2);
  SgsTestNode node3 = additionalNodes.get(host3);
  identityAssigner.moveIdentity("foo", node2.getNodeId(),
       node3.getNodeId());
  int objectCount = getObjectCount();
  client.relocate(node2.getAppPort(), true, false);
  waitForExpectedObjectCount(
      objectCount - MANAGED_OBJECTS_PER_SESSION);
  checkBindings(0);
  client.assertDisconnectedCallbackInvoked(false);
    }
View Full Code Here
252
253
254
255
256
257
258
259
260
261
262
      SgsTestNode newNode = additionalNodes.get(newNodeHost);
      client.waitForRelocationNotification(newNode.getAppPort());
      client.validateMessageSequence(
    client.sessionListenerReceivedMessages, numMessages, 0);
      assertTrue(client.clientReceivedMessages.isEmpty());
      client.relocate(newNode.getAppPort(), true, true);
      client.waitForClientToReceiveExpectedMessages(numMessages);
      client.validateMessageSequence(
    client.clientReceivedMessages, numMessages, 0);
      assertTrue(client.sessionListenerReceivedMessages.isEmpty());
  } finally {
View Full Code Here
281
282
283
284
285
286
287
288
289
290
291
      client.waitForRelocationNotification(newNode.getAppPort());
      // Make sure that all messages received after the suspend was
      // completed have been dropped.
      assertTrue(client.sessionListenerReceivedMessages.isEmpty());
      assertTrue(client.clientReceivedMessages.isEmpty());
      client.relocate(newNode.getAppPort(), true, true);
      assertTrue(client.sessionListenerReceivedMessages.isEmpty());
      assertTrue(client.clientReceivedMessages.isEmpty());
  } finally {
      client.disconnect();
  }
View Full Code Here
61
62
63
64
65
66
67
68
69
70
71
  String newNodeHost = "newNode";
  DummyClient client = createClientToRelocate(newNodeHost);
  int objectCount = getObjectCount();
  try {
      SgsTestNode newNode = additionalNodes.get(newNodeHost);
      client.relocate(newNode.getAppPort(), true, true);
      // need to wait here to get the true object count to make sure
      // that objects and bindings aren't cleaned up.
      Thread.sleep(WAIT_TIME);
      assertEquals(objectCount, getObjectCount());
      checkBindings(1);
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
    {
  String newNodeHost = "newNode";
  DummyClient client = createClientToRelocate(newNodeHost);
  try {
      SgsTestNode newNode = additionalNodes.get(newNodeHost);
      client.relocate(newNode.getAppPort(), true, true);
      sendMessagesFromNodeToClient(serverNode, client, 4, 0);
      sendMessagesFromNodeToClient(newNode, client, 4, 10);
  } finally {
      client.disconnect();
  }
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
  try {
      SgsTestNode newNode = additionalNodes.get(newNodeHost);
      int objectCount = getObjectCount();
      sendMessagesFromNode(serverNode, client, 4, 0);
      sendMessagesFromNode(newNode, client, 4, 10);
      client.relocate(newNode.getAppPort(), true, true);
      synchronized (client.clientReceivedMessages) {
    client.waitForClientToReceiveExpectedMessages(4);
    client.validateMessageSequence(
        client.clientReceivedMessages, 4, 0);
    client.clientReceivedMessages.clear();
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.