List of syncStop() Examples

Examples of syncStop()

Examples of org.apache.helix.integration.manager.MockParticipantManager.syncStop()

      // NodeOpArg arg = new NodeOpArg(result._manager, result._thread);
      // TestCommand command = new TestCommand(CommandType.STOP, new TestTrigger(beginTime), arg);
      // List<TestCommand> commandList = new ArrayList<TestCommand>();
      // commandList.add(command);
      // TestExecutor.executeTestAsync(commandList, ZK_ADDR);
      participant.syncStop();
    }
  }


  public static void setIdealState(String uniqClusterName, long beginTime, int percentage)
      throws Exception {

View Full Code Here

Examples of org.apache.helix.integration.manager.MockParticipantManager.syncStop()

    // clean up
    for (ClusterDistributedController controller : distControllers.values()) {
      controller.syncStop();
    }
    for (MockParticipantManager participant : participants.values()) {
      participant.syncStop();
    }
  }


  private Map<String, String> rebalanceCmd(int replicas, String prefix, String tag) {
    Map<String, String> parameters = new HashMap<String, String>();

View Full Code Here

Examples of org.apache.helix.manager.zk.MockController.syncStop()

    // check state models have been dropped also
    Assert.assertTrue(fty.getPartitionSet().isEmpty(),
        "All state-models should be dropped, but was " + fty.getPartitionSet());


    // cleanup
    controller.syncStop();
    for (int i = 0; i < n; i++) {
      participants[i].syncStop();
    }


    System.out.println("END " + clusterName + " at " + new Date(System.currentTimeMillis()));

View Full Code Here

Examples of org.apache.helix.manager.zk.MockMultiClusterController.syncStop()

    numberOfListeners = ZkTestHelper.numberOfListeners(_zkaddr, msgPath);
    // System.out.println("numberOfListeners(" + msgPath + "): " + numberOfListeners);
    Assert.assertEquals(numberOfListeners, 2); // 1 of participant, and 1 of controller


    // clean up
    multiClusterController.syncStop();
    for (int i = 0; i < nodeNr; i++) {
      participants[i].syncStop();
    }


    System.out.println("END " + clusterName + " at " + new Date(System.currentTimeMillis()));

View Full Code Here

Examples of org.apache.helix.manager.zk.MockParticipant.syncStop()

        break;
    }
    Assert.assertTrue(null != manager.getHelixDataAccessor().getProperty(
        accessor.keyBuilder().liveInstance(instance2)));


    newParticipant.syncStop();
  }
}

View Full Code Here

Examples of org.apache.helix.mock.controller.ClusterController.syncStop()


  // clean up
  // wait for all zk callbacks done
  Thread.sleep(1000);
  // adminThread.stop();
  controller.syncStop();
  for (int i = 0; i < 5; i++) {
      participants[i].syncStop();
  }


  System.out.println("END " + clusterName + " at "

View Full Code Here

Examples of org.apache.helix.mock.controller.ClusterController.syncStop()

    
    // clean up
    // wait for all zk callbacks done
    Thread.sleep(1000);
//    adminThread.stop();
    controller.syncStop();
    for (int i = 0; i < 5; i++)
    {
      participants[i].syncStop();
    }

View Full Code Here

Examples of org.apache.helix.mock.controller.ClusterController.syncStop()

    
    // clean up
    // wait for all zk callbacks done
    Thread.sleep(1000);
//    adminThread.stop();
    controller.syncStop();
    for (int i = 0; i < 5; i++)
    {
      participants[i].syncStop();
    }

View Full Code Here

Examples of org.apache.helix.mock.controller.ClusterController.syncStop()

      Assert.assertEquals(record.getId(), "mockAlerts4");
    }


    // clean up
    Thread.sleep(1000);
    controller.syncStop();
    for (int i = 0; i < 5; i++)
    {
      participants[i].syncStop();
    }

View Full Code Here

Examples of org.apache.helix.mock.controller.ClusterController.syncStop()

    {
      participants[i].syncStop();
    }


    Thread.sleep(2000);
    controller.syncStop();


    System.out.println("END " + clusterName + " at "
        + new Date(System.currentTimeMillis()));
  }
}

View Full Code Here

0 1 2 3 4 5

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.