diff --git a/software/coordinator2.py b/software/coordinator2.py index 14a0a13ed5a7d1d2f1f96062cdfd7717f8e189fc..543bb7e76b0f4fae2d480df0ad2d4b179cbc1c1d 100644 --- a/software/coordinator2.py +++ b/software/coordinator2.py @@ -180,7 +180,7 @@ class PRREvalClient(Thread): self.client.on_disconnect = self.on_disconnect self.client.loop_start() - self.server = "pc13" + self.server = "pi-a279" self.HUB_DISCOVERY_TOPIC = "hotplug/{}/discovery".format(self.server) self.HUB_DISCOVERY_ANSWER_TOPIC = "hotplug/{}/discovery/answer".format(self.server) @@ -207,10 +207,10 @@ class PRREvalClient(Thread): self.logger.debug("Got nodes: {}".format(all_nodes)) for node in all_nodes: if node not in self.my_nodes and node is not '': - self.logger.debug("Subscribing!") self.my_nodes.append(node) - rx_topic = "hotplug/pc13/{}/rx".format(node) + rx_topic = "hotplug/{}/{}/rx".format(self.server, node) self.client.subscribe(rx_topic, qos=2) + self.logger.debug("Subscribing to {}!".format(rx_topic)) print("My Nodes: {}".format(self.my_nodes)) elif topic[0] == "hotplug" and len(topic) == 4: unpacked_msg = str(msg.payload)[2:][:-1]