@@ -36,12 +36,12 @@ def __init__(self, device: USBDevice, handle: USBDeviceHandle) -> None:
3636 self ._transfer_list = []
3737
3838
39- def set_input_interrupt (self , endpoint , size , callback ):
40- """Set up input transfer.
39+ def set_input_interrupt (self , endpoint : int , size : int , callback ) -> None :
40+ """Set up input transfer
4141
4242 callback(endpoint, data) is called repeadedly with every packed received.
4343 """
44- def callback_wrapper (transfer ):
44+ def callback_wrapper (transfer ) -> None :
4545 if (transfer .getStatus () != usb1 .TRANSFER_COMPLETED or
4646 transfer .getActualLength () != size ):
4747 return
@@ -98,16 +98,16 @@ def make_request(self, index, callback, data, size=64):
9898 """
9999 self ._rmsg .append ((
100100 (
101- 0x21 , # request_type
102- 0x09 , # request
103- 0x0300 , # value
104- index , data
105- ), index , size , callback
101+ 0x21 , # request_type
102+ 0x09 , # request
103+ 0x0300 , # value
104+ index , data ,
105+ ), index , size , callback ,
106106 ))
107107
108108
109109 def flush (self ):
110- """Flushes all prepared control messages to the device."""
110+ """Flush all prepared control messages to the device."""
111111 while len (self ._cmsg ):
112112 msg = self ._cmsg .pop ()
113113 self .handle .controlWrite (* msg )
@@ -116,10 +116,10 @@ def flush(self):
116116 msg , index , size , callback = self ._rmsg .pop ()
117117 self .handle .controlWrite (* msg )
118118 data = self .handle .controlRead (
119- 0xA1 , # request_type
120- 0x01 , # request
121- 0x0300 , # value
122- index , size
119+ 0xA1 , # request_type
120+ 0x01 , # request
121+ 0x0300 , # value
122+ index , size ,
123123 )
124124 callback (data )
125125
@@ -135,19 +135,18 @@ def force_restart(self):
135135
136136
137137 def claim (self , number ):
138- """
139- Helper method; Remembers list of claimed interfaces and allows to
140- unclaim them all at once using unclaim() method or automatically when
141- device is closed.
138+ """Remember list of claimed interfaces and allow to unclaim them all at once using unclaim() method
139+
140+ or automatically when device is closed.
142141 """
143142 self .handle .claimInterface (number )
144143 self ._claimed .append (number )
145144
146145
147- def claim_by (self , klass , subclass , protocol ):
148- """
149- Claims all interfaces with specified parameters.
150- Returns number of claimed interfaces
146+ def claim_by (self , klass , subclass , protocol ) -> int :
147+ """Claim all interfaces with specified parameters.
148+
149+ Return number of claimed interfaces
151150 """
152151 rv = 0
153152 for inter in self .device [0 ]:
@@ -197,7 +196,7 @@ def __init__(self):
197196 self ._started = False
198197 self ._retry_devices = []
199198 self ._retry_devices_timer = 0
200- self ._ctx = None # Set by start method
199+ self ._ctx = None # Set by start method
201200 self ._changed = 0
202201
203202
@@ -250,8 +249,8 @@ def handle_new_device(self, syspath: str, vendor: int, product: int) -> bool | N
250249 return
251250 if self .daemon :
252251 self .daemon .add_error (
253- "usb:%s:%s" % ( tp [0 ], tp [1 ]) ,
254- "Failed to open USB device: %s" % ( e ,)
252+ f "usb:{ tp [0 ]} : { tp [1 ]} " ,
253+ f "Failed to open USB device: { e } " ,
255254 )
256255 return
257256 else :
@@ -269,8 +268,8 @@ def handle_new_device(self, syspath: str, vendor: int, product: int) -> bool | N
269268 return False
270269 if self .daemon :
271270 self .daemon .add_error (
272- "usb:%s:%s" % ( tp [0 ], tp [1 ]) ,
273- "Failed to claim USB device: %s" % ( e ,)
271+ f "usb:{ tp [0 ]} : { tp [1 ]} " ,
272+ f "Failed to claim USB device: { e } " ,
274273 )
275274 self ._retry_devices .append ((syspath , tp ))
276275 device .close ()
@@ -279,14 +278,14 @@ def handle_new_device(self, syspath: str, vendor: int, product: int) -> bool | N
279278 self ._devices [device ] = handled_device
280279 self ._syspaths [syspath ] = device
281280 log .debug ("USB device added: %.4x:%.4x" , * tp )
282- self .daemon .remove_error ("usb:%s:%s" % ( tp [0 ], tp [1 ]) )
281+ self .daemon .remove_error (f "usb:{ tp [0 ]} : { tp [1 ]} " )
283282 return True
284283 log .warning ("Known USB device ignored: %.4x:%.4x" , * tp )
285284 device .close ()
286285 return False
287286
288287
289- def handle_removed_device (self , syspath : str , vendor : int , product : int ):
288+ def handle_removed_device (self , syspath : str , vendor : int , product : int ) -> None :
290289 if syspath in self ._syspaths :
291290 device = self ._syspaths [syspath ]
292291 handled_device = self ._devices [device ]
@@ -296,11 +295,11 @@ def handle_removed_device(self, syspath: str, vendor: int, product: int):
296295 try :
297296 device .close ()
298297 except usb1 .USBErrorNoDevice :
299- # Safe to ignore, happens when device is physiucally removed
298+ # Safe to ignore, happens when device is physically removed
300299 pass
301300
302301
303- def register_hotplug_device (self , callback , vendor_id : int , product_id : int , on_failure ):
302+ def register_hotplug_device (self , callback , vendor_id : int , product_id : int , on_failure ) -> None :
304303 self ._known_ids [vendor_id , product_id ] = callback
305304 if on_failure :
306305 self ._fail_cbs [vendor_id , product_id ] = on_failure
@@ -310,7 +309,7 @@ def register_hotplug_device(self, callback, vendor_id: int, product_id: int, on_
310309 log .debug ("Registered USB driver for %.4x:%.4x" , vendor_id , product_id )
311310
312311
313- def unregister_hotplug_device (self , callback , vendor_id , product_id ) :
312+ def unregister_hotplug_device (self , callback , vendor_id : int , product_id : int ) -> None :
314313 if self ._known_ids .get ((vendor_id , product_id )) == callback :
315314 del self ._known_ids [vendor_id , product_id ]
316315 if (vendor_id , product_id ) in self ._fail_cbs :
@@ -347,13 +346,13 @@ def init(daemon: SCCDaemon, config: dict) -> bool:
347346 daemon .add_mainloop (_usb .mainloop )
348347 return True
349348
350- def start (daemon : SCCDaemon ):
349+ def start (daemon : SCCDaemon ) -> None :
351350 _usb .start ()
352351
353352
354- def register_hotplug_device (callback , vendor_id : int , product_id : int , on_failure = None ):
353+ def register_hotplug_device (callback , vendor_id : int , product_id : int , on_failure = None ) -> None :
355354 _usb .register_hotplug_device (callback , vendor_id , product_id , on_failure )
356355
357356
358- def unregister_hotplug_device (callback , vendor_id : int , product_id : int ):
357+ def unregister_hotplug_device (callback , vendor_id : int , product_id : int ) -> None :
359358 _usb .unregister_hotplug_device (callback , vendor_id , product_id )
0 commit comments