Skip to content
Snippets Groups Projects
Commit f796258c authored by Torben Petersen's avatar Torben Petersen
Browse files

Fixed logging of received lines to files

parent 7bfbf716
No related branches found
No related tags found
No related merge requests found
......@@ -350,18 +350,21 @@ class PRREvalClient(Thread):
line_bytes, = struct.unpack("{}s".format(length), msg.payload[12:])
line = line_bytes.decode("utf-8")
node_id = topic[2]
#get the logger for this node
node_serial_id = topic[2]
node_code_id = self.get_code_id(userdata, node_serial_id)
file_logger = self.registered_nodes[node_code_id][1]
self.log_mutex.acquire()
self.logger.info("{:0<20},{},{}".format(ts, node_id, line))
self.log_mutex.acquire()
file_logger.info("{:0<20},{},{}".format(ts, node_serial_id, line))
self.log_mutex.release()
#write it to the DB!
if userdata == self.chamber_one_logger_pi:
handle_serial_rx(node_id, ts, line, self.chamber_one_temp)
handle_serial_rx(node_serial_id, ts, line, self.chamber_one_temp)
elif userdata == self.chamber_two_logger_pi:
handle_serial_rx(node_id, ts, line, self.chamber_two_temp)
handle_serial_rx(node_serial_id, ts, line, self.chamber_two_temp)
else:
self.logger.warning("Got node message from unknown source!")
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment