Package net.sf.katta.node

Examples of net.sf.katta.node.Node.start()

146
147
148
149
150
151
152
153
154
155
156
    gateway.start();
    final ZkClient zkGatewayClient = ZkKattaUtil.startZkClient(gatewayConf, 30000);
    InteractionProtocol gatewayProtocol = new InteractionProtocol(zkGatewayClient, gatewayConf);
    FileUtil.deleteFolder(new NodeConfiguration().getShardFolder());
    final Node node = new Node(gatewayProtocol, new LuceneServer());
    node.start();

    // check node-master link
    master.start();
    TestUtil.waitUntilLeaveSafeMode(master);
    TestUtil.waitUntilNumberOfLiveNode(_protocol, 1);
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
  public Node startAdditionalNode() throws Exception {
    NodeConfiguration nodeConfiguration = new NodeConfiguration();
    nodeConfiguration.setStartPort(_nodeStartPort + _startedNodes);
    Node node = new Node(_protocol, nodeConfiguration, _contentServerClass.newInstance());
    _nodes.add(node);
    node.start();
    _startedNodes++;
    return node;
  }

  public Master startSecondaryMaster() throws KattaException {
View Full Code Here
165
166
167
168
169
170
171
172
173
174
175
    Node shutdownNode = getNode(i);
    NodeConfiguration nodeConfiguration = new NodeConfiguration();
    nodeConfiguration.setStartPort(shutdownNode.getRPCServerPort());
    shutdownNode(i);
    Node node = new Node(_protocol, nodeConfiguration, shutdownNode.getContext().getContentServer());
    node.start();
    _nodes.add(i, node);
    return node;
  }

  public Node shutdownNodeRpc(int i) {
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.