More cleanup

Author: mpurnell1

msgq/ipc.py

@@ -377,7 +377,6 @@ def recv_ready_event(self) -> 'Event':
     ptr = _lib.msgq_socket_event_handle_recv_ready(self.ptr)
     return Event(ptr=ptr)
 
-
 def toggle_fake_events(enabled: bool):
   assert _lib
   _lib.msgq_toggle_fake_events(enabled)
@@ -399,7 +398,6 @@ def wait_for_one_event(events: List[Event], timeout: Optional[int] = None) -> in
   return Event.wait_for_one(events, timeout)
 
 
-
 if _lib:
   context: Optional[Context] = Context()
 else:

msgq/visionipc/visionipc.py

@@ -227,7 +227,6 @@ def allocate(self, length: int):
       self.handle = alloc.handle
       self.mmap_len = alloc.len
 
-
       fd_data = ion_fd_data()
       fd_data.handle = self.handle
       if ctypes.pythonapi.ioctl(self.ion_fd, ION_IOC_SHARE, ctypes.byref(fd_data)) != 0:
@@ -237,11 +236,9 @@ def allocate(self, length: int):
       self._mmap = mmap.mmap(self.fd, self.mmap_len)
       self.addr = ctypes.addressof(ctypes.c_char.from_buffer(self._mmap))
 
-
       ctypes.memset(self.addr, 0, self.mmap_len)
       return
 
-
     base_dir = "/dev/shm" if platform.system() != "Darwin" else "/tmp"
     self.mmap_len = self.len + 8
     name = f"{base_dir}/visionbuf_{os.getpid()}_{id(self)}"
@@ -405,7 +402,6 @@ def create_buffers_with_sizes(self, stream: VisionStreamType, num_buffers: int,
       self.buffers[stream] = bufs
       self.cur_idx[stream] = 0
 
-
       ctx = msgq.Context()
       sock = msgq.PubSocket()
       sock.connect(ctx, get_endpoint_name(self.name, stream))
@@ -437,7 +433,6 @@ def send(
              ctypes.memmove(buf.addr, data.ctypes.data, min(data.nbytes, buf.len))
           extra_valid = True
 
-
       buf.sync(False)
 
       packet = VisionIpcPacket()
@@ -581,10 +576,8 @@ def connect(self, blocking: bool = True):
             s_sock = socket.socket(socket.AF_UNIX, sock_type)
             s_sock.connect(path)
 
-
             s_sock.send(struct.pack("i", int(self.stream)))
 
-
             iov, ancillary, flags, addr = s_sock.recvmsg(8192, 4096)
             s_sock.close()
 
@@ -600,7 +593,6 @@ def connect(self, blocking: bool = True):
                    continue
                 return False
 
-
             self.buffers = []
             for i in range(num_buffers):
                 width, height, stride, uv_offset, length = struct.unpack_from("QQQQQ", iov, i*40)
@@ -643,13 +635,11 @@ def recv(self, timeout_ms: int = 100) -> Optional[VisionBuf]:
       if not msg:
           return None
 
-
       if len(msg) < ctypes.sizeof(VisionIpcPacket):
           return None
 
       packet = VisionIpcPacket.from_buffer_copy(msg)
 
-
       self.frame_id = packet.extra.frame_id
       self.timestamp_sof = packet.extra.timestamp_sof
       self.timestamp_eof = packet.extra.timestamp_eof
@@ -670,7 +660,6 @@ def recv(self, timeout_ms: int = 100) -> Optional[VisionBuf]:
 
       return cast(VisionBuf, buf)
 
-
   @staticmethod
   def available_streams(name: str, blocking: bool = True) -> Set[VisionStreamType]:
       path = get_ipc_path(name)