Replaces print with self.logger, adds stop() for eval client

software/coordinator2.py

@@ -214,7 +214,7 @@ class PRREvalClient(Thread):
         elif topic[0] == "hotplug" and len(topic) == 4:
             unpacked_msg = str(msg.payload)[2:][:-1]
             node_id = topic[2]
-            print("{}: {}".format(node_id, unpacked_msg))
+            self.logger.debug("{}: {}".format(node_id, unpacked_msg))
         else:
             print( "[on_message] {} {}".format(msg.payload, msg.topic) )
 
@@ -259,13 +259,25 @@ class PRREvalClient(Thread):
                     sleep( 5.0 )
 
     def run(self):
-        while True:
+        self.running = True
+        while self.running:
             try:
                 self.eval()
             except KeyboardInterrupt:
                 self.logger.debug("Stopped")
+                self.running = False
                 break
 
+    def stop(self):
+        if self.running:
+            self.logger.info("stop()")
+            self.running = False
+            return True
+        else:
+            self.logger.warn("Unable to stop: not alive")
+            return False
+
+
     def set_angle(self, angle):
         self.logger.debug("ANGLE={}".format( angle ))
         # {'module': ['SerialStepperMotorModule']}
@@ -295,10 +307,10 @@ class PRREvalClient(Thread):
                 if handle_serial_rx( data_dict ):
                     return True
                 else:
-                    logger.debug("[{}] {}".format( data_dict['src']['id'][0], data_dict['line'] ) )
+                    self.logger.debug("[{}] {}".format( data_dict['src']['id'][0], data_dict['line'] ) )
                     return True
           
-        logger.debug( data_dict )
+        self.logger.debug( data_dict )
 
 if __name__ == '__main__':
     coloredlogs.install(fmt='%(asctime)s %(name)s %(levelname)s %(message)s', level=0)