Compare commits
2 Commits
061b0e504e
...
7bf0f39d39
| Author | SHA1 | Date | |
|---|---|---|---|
| 7bf0f39d39 | |||
| 3d1bd08f72 |
@ -121,7 +121,7 @@ class ServiceExplorationModule():
|
|||||||
self.node_manager = node_manager
|
self.node_manager = node_manager
|
||||||
|
|
||||||
def listen(self):
|
def listen(self):
|
||||||
self.sock.bind((self.host, self.port))
|
self.sock.bind(('0.0.0.0', self.port))
|
||||||
print(f"Exploration Server(UDP) listening on {self.host}:{self.port}...")
|
print(f"Exploration Server(UDP) listening on {self.host}:{self.port}...")
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
|
|||||||
@ -67,7 +67,7 @@ class NodeManager():
|
|||||||
info = self.cluster_communication_module.cluster_info()
|
info = self.cluster_communication_module.cluster_info()
|
||||||
print(f"\nThere are {len(info)+1} nodes in this cluster.")
|
print(f"\nThere are {len(info)+1} nodes in this cluster.")
|
||||||
print("Cluster Info:")
|
print("Cluster Info:")
|
||||||
print(f" {self.service_exploration_module.IP}(local) -> {self.GPU} * {self.GPU_num}")
|
print(f" {self.service_exploration_module.host}(local) -> {self.GPU} * {self.GPU_num}")
|
||||||
for host in info:
|
for host in info:
|
||||||
print(f" {host['host']} -> {host['GPU']} * {host['GPU_num']}")
|
print(f" {host['host']} -> {host['GPU']} * {host['GPU_num']}")
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user