Loading...
tools/lldbmacros/usertaskdebugging/interface.py xnu-12377.101.15 /dev/null
--- xnu/xnu-12377.101.15/tools/lldbmacros/usertaskdebugging/interface.py
+++ /dev/null
@@ -1,63 +0,0 @@
-import logging
-import socket
-import select
-
-class Interface(object):
-    """Basic communication interface."""
-    def __init__(self, host_cfg, portnum):
-        super().__init__()
-        self.host_cfg = host_cfg
-        self.portnum = portnum
-        self.pkt_size = 8192
-        self.socket = None
-        self.isblocking = True
-        logging.debug("created  %s" % str(self))
-
-    def connect(self):
-        self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
-        self.socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-        self.socket.bind((self.host_cfg, self.portnum))
-        logging.debug("Initializing network interface for communication host: %s:%d", self.host_cfg, self.portnum)
-        self.socket.listen(5)
-        num_retries = 3
-        while num_retries > 0:
-            ra,wa,ea = select.select([self.socket], [], [], 30)
-            if not ra:
-                num_retries -= 1
-                logging.warning("timeout: select returned empty list. retrying..")
-                continue
-            self.connection, addr = self.socket.accept()
-            logging.info("Connected to client from %s" % str(addr))
-            return True
-        logging.error("Failed to connect. Exiting after multiple attempts.")
-        return False
-
-    def read(self):
-        if self.isblocking:
-            #BUG TODO make this unblocking soon
-            #logging.warn("blocking read bug")
-            self.connection.settimeout(15)
-            self.isblocking = False
-        r_bytes = bytes()
-        try:
-            r_bytes = self.connection.recv(self.pkt_size)
-        except Exception as e:
-            #logging.debug("Found exception in recv. %s " % (str(e)))
-            pass
-
-        return r_bytes
-    
-    def write(self, str):
-        if not self.isblocking:
-            self.connection.setblocking(1)
-            self.isblocking = True
-        return self.connection.send(str.encode())
-
-    def close(self):
-        if self.connection:
-            logging.debug('closing connection.')
-            self.connection.close()
-        return self.socket
-
-    def __str__(self):
-        return "interface: %s %d" % (self.host_cfg, self.portnum)