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.

poll_hardware

Poll the hardware and send updates to the worker thread's queue.
kafka_dae_control.threads.hardware_polling_thread.hardware_poll_thread(config: ControlConfig, queue: Queue[SetIPEvent | BeginEvent | EndEvent | HardwareUpdateEvent | BlocksUpdateEvent | FrameSyncSelectChangeEvent | CurrentPeriodSetEvent | NumberOfPeriodsSetEvent | PeriodModeSetEvent], sock: socket, sock_lock: RLock) → Never[source]

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

kafka_dae_control.threads.hardware_polling_thread.poll_hardware(config: ControlConfig, queue: Queue[Any], sock: socket, sock_lock: RLock) → bool[source]

Poll the hardware and send 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

Returns:

True if the hardware poll was successful, False otherwise