Examples of relocate()


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

  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

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

      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

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

      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

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

  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

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

    {
  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

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

  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

Examples of com.vmware.vim.binding.vim.VirtualMachine.relocate()

      relocSpec.setDisk(diskList.toArray(new RelocateSpec.DiskLocator[diskList.size()]));
      VcTask task = VcContext.getTaskMgr().execute(new IVcTaskBody() {
         public VcTask body() throws Exception {
            VirtualMachine vm = getManagedObject();
            return new VcTask(TaskType.RelocateVm,
                  vm.relocate(relocSpec, VirtualMachine.MovePriority.defaultPriority), callback);
         }
      });
      return task;
   }
View Full Code Here

Examples of javafx.scene.control.Label.relocate()

    socket.setId(String.valueOf(0));
    socket.setStroke(Paint.valueOf("black"));

    final Label connectionLabel = new Label("S");
    connectionLabel.setStyle("-fx-background-color:rgb(255, 255, 255); -fx-border-color:rgba(0, 0, 0, 0.5); ");
    connectionLabel.relocate(socket.getCenterX() + 5, socket.getCenterY() - 10);
    connectionLabel.setVisible(false);

    /*
     * Mouse event handlers on sockets
     *
 
View Full Code Here

Examples of javafx.scene.control.Label.relocate()

      s.addEventFilter(MouseEvent.MOUSE_ENTERED, new EventHandler<MouseEvent>() {
        @Override
        public void handle(MouseEvent event) {
          // user is hovering over connection socket
          connectionNumber.setText("C: " + s.getId());
          connectionNumber.relocate(s.getCenterX() + 5, s.getCenterY() - 10);
          connectionNumber.setVisible(true);
        }
      });

      s.addEventFilter(MouseEvent.MOUSE_EXITED, new EventHandler<MouseEvent>() {
View Full Code Here

Examples of javafx.scene.control.Label.relocate()

        label.setTextOverrun(OverrunStyle.LEADING_ELLIPSIS);
        //force size
        label.setMinWidth(labelWidth);
        label.setPrefWidth(labelWidth);
        label.setMaxWidth(labelWidth);
        label.relocate(labelX, 0);

        if (labelX == 0) { // first label has no border
            label.setStyle("-fx-border-width: 0 0 0 0 ; -fx-border-color:black;");
        } else // subsequent labels have border on left to create dividers
            label.setStyle("-fx-border-width: 0 0 0 1; -fx-border-color:black;");
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.