kafka_dae_control.threads.hardware_polling_thread

Thread for polling the hardware and sending updates to the worker thread’s queue.

Members

hardware_poll_thread

Thread for polling the hardware and sending updates to the worker thread's queue.

kafka_dae_control.threads.hardware_polling_thread.hardware_poll_thread(config: ControlConfig, queue: Queue[SetIPEvent | BeginEvent | EndEvent | TitleUpdateEvent | UsersUpdateEvent | HardwareUpdateEvent | BlocksUpdateEvent], sock: socket, sock_lock: RLock) → Never

Thread for polling the hardware and sending updates to the worker thread’s queue.

Parameters:

• config – the program’s configuration

• queue – the worker thread queue to add updates to after polling hardware

• sock – the socket instance

• sock_lock – the lock to use when using the socket instance