def processor()

in usb_monitor_pkg/usb_monitor_pkg/usb_monitor_node.py [0:0]

• 14 lines of code
• 9 McCabe index (conditional complexity)

    def processor(self):
        """Main daemon thread that is checking for USB connection and processing its contents.
        """
        while not self.stop_queue.isSet():
            device = self.queue.get()
            if device is None:
                continue

            # Look for block devices.
            if device.subsystem != "block":
                continue

            # Look for partition/disk devices.
            if device.device_type not in ("partition", "disk"):
                continue

            # Look for SCSI disk devices (0-15).
            if device["MAJOR"] != "8":
                continue

            self.get_logger().info(f"Detected file system {device.device_node}")
            self.process(device.device_node)
            self.get_logger().info(f"After processing : {device.device_node}")