fixes non-windows compatible socket options

Author: anathan

p1_runner/data_source.py

@@ -1,6 +1,7 @@
 import select
 import socket
 import time
+import platform
 from abc import ABC, abstractmethod
 from socket import SocketType
 from threading import Event, Lock
@@ -145,8 +146,10 @@ def __init__(
             # The socket buffer can be made large enough that we don't need a reader thread.
             self.socket_in.setsockopt(socket.SOL_SOCKET, socket.SO_SNDBUF, MAX_DATA_BUFFER_SIZE)
             self.socket_in.setblocking(False)
-            enable_socket_timestamping(self.socket_in, enable_sw_timestamp=True,
-                                       enable_hw_timestamp=False)  # type: ignore
+            #  This is not supported in windows
+            if platform.system() != "Windows":
+                enable_socket_timestamping(self.socket_in, enable_sw_timestamp=True,
+                                        enable_hw_timestamp=False)  # type: ignore
 
         self.rx_log = rx_log
 
@@ -160,8 +163,12 @@ def read(self, size: int, timeout=RESPONSE_TIMEOUT, return_any: bool = False) ->
         while len(all_data) < size and remaining >= 0:
             ready = select.select([self.socket_in], [], [], remaining)
             if ready[0]:
-                data, ancdata, _, _ = self.socket_in.recvmsg(size - len(all_data), 1024)
-                kernel_ts, _, _ = parse_timestamps_from_ancdata(ancdata)
+                kernel_ts = None
+                if hasattr(self.socket_in, "recvmsg"):
+                    data, ancdata, _, _ = self.socket_in.recvmsg(size - len(all_data), 1024)
+                    kernel_ts, _, _ = parse_timestamps_from_ancdata(ancdata)
+                else:
+                    data = self.socket_in.recv(size - len(all_data))                        
                 if kernel_ts:
                     self.last_rx_data_posix_timestamp_sec = kernel_ts