Advertisement
Guest User

Untitled

a guest
May 22nd, 2017
57
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.98 KB | None | 0 0
  1. List<DiscoveryNode> discoNodes = newArrayList();
  2. Map<String, ? extends ComputeMetadata> nodes = computeService.context().getComputeService().getNodes();
  3. for (Map.Entry<String, ? extends ComputeMetadata> node : nodes.entrySet()) {
  4. NodeMetadata nodeMetadata = computeService.context().getComputeService().getNodeMetadata(node.getValue());
  5. if (nodeMetadata.getState() == NodeState.PENDING || nodeMetadata.getState() == NodeState.RUNNING) {
  6. logger.debug("Adding {}/{}", nodeMetadata.getName(), nodeMetadata.getPrivateAddresses());
  7. for (InetAddress inetAddress : nodeMetadata.getPrivateAddresses()) {
  8. for (int port : new PortsRange(ports).ports()) {
  9. discoNodes.add(new DiscoveryNode("#cloud-" + inetAddress.getHostAddress() + "-" + port, new InetSocketTransportAddress(new InetSocketAddress(inetAddress, port))));
  10. }
  11. }
  12. }
  13. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement