test

socs/testing/device_emulator.py

@@ -10,6 +10,7 @@
 
 import pytest
 import serial
+from serial.serialutil import SerialException
 
 
 def create_device_emulator(responses, relay_type, port=9001, encoding='utf-8',
@@ -190,7 +191,13 @@ def _read_serial(self):
 
         while self._read:
             if self.ser.in_waiting > 0:
-                msg = self.ser.readline()
+                try:
+                    msg = self.ser.readline()
+                except SerialException as e:
+                    self.logger.error(f"Serial error: {e}")
+                    self.ser.close()
+                    return
+
                 if self.encoding:
                     msg = msg.strip().decode(self.encoding)
                 self.logger.debug(f"msg='{msg}'")
@@ -327,10 +334,10 @@ def create_tcp_relay(self, port):
         """
         self._type = 'tcp'
         self._sock_bound = False
-        self._bkg_read = threading.Thread(name='background',
+        bkg_read = threading.Thread(name='background',
                                           target=self._read_socket,
                                           kwargs={'port': port})
-        self._bkg_read.start()
+        bkg_read.start()
 
         # wait for socket to bind properly before returning
         while not self._sock_bound:

socs/testing/hwp_emulator.py

@@ -248,7 +248,7 @@ def __init__(
         self.run_enc_thread = False
 
         if self.enc_port == 0:
-            self._enc_port = _find_open_port()
+            self.enc_port = _find_open_port()
 
         self.logger = _create_logger("HWP", log_level=log_level)
 
@@ -321,6 +321,7 @@ def encoder_thread_func(self):
                     [header, clock, clock_overflow, edge_count]
                 ).tobytes()
                 sock.sendto(byte_data, addr)
+
                 time.sleep(ENC_COUNTER_LEN / (2 * self.state.cur_freq * NUM_SLITS))
         self.logger.info("Stopping encoder thread")