163164165166167168169170171172173
// now fix the node connection gateway.start(); TestUtil.waitUntilNumberOfLiveNode(_protocol, 1); // cleanup node.shutdown(); master.shutdown(); zkGatewayClient.close(); gateway.stop(); }
155156157158159160161162163164165
return _startedNodes; } public Node shutdownNode(int i) { Node node = _nodes.remove(i); node.shutdown(); return node; } public Node restartNode(int i) { Node shutdownNode = getNode(i);