STAR
Cal STAR — firmware, DAQ server, and engine design
Loading...
Searching...
No Matches
combined_fsw_gui.UDPReceiver Class Reference
Inheritance diagram for combined_fsw_gui.UDPReceiver:
[legend]
Collaboration diagram for combined_fsw_gui.UDPReceiver:
[legend]

Public Member Functions

 __init__ (self, int port=DEFAULT_RECEIVE_PORT, str bind_address=DEFAULT_BIND_ADDRESS)
 stop (self)
Dict get_stats (self)
 run (self)
Optional[Tuple[int, int, int]] parse_packet_header (self, bytes data)
Optional[Tuple[dict, List[dict]]] parse_sensor_data_packet (self, bytes data)

Public Attributes

 port = port
 bind_address = bind_address
 sock = None
int total_packets = 0
int total_bytes = 0
 start_time = None

Static Public Attributes

 sensor_data_received
 status_update = QtCore.pyqtSignal(str)
 packet_received = QtCore.pyqtSignal(int, int)

Protected Attributes

bool _stop = False

Detailed Description

Thread that receives UDP packets and emits decoded sensor data

Definition at line 328 of file combined_fsw_gui.py.

Constructor & Destructor Documentation

◆ __init__()

combined_fsw_gui.UDPReceiver.__init__ ( self,
int port = DEFAULT_RECEIVE_PORT,
str bind_address = DEFAULT_BIND_ADDRESS )

Definition at line 337 of file combined_fsw_gui.py.

References __init__().

Referenced by __init__().

Member Function Documentation

◆ get_stats()

Dict combined_fsw_gui.UDPReceiver.get_stats ( self) 
Get current statistics

Definition at line 358 of file combined_fsw_gui.py.

References autonomous_calibration_engine.AutonomousCalibrationEngine.start_time, calibration_robustness.HealthMonitor.start_time, start_time, combined_gui.UDPReceiver.start_time, lc_calibration_gui.UDPReceiver.start_time, pt_multi_gui.UDPReceiver.start_time, PWMState.start_time, sense_testing_gui.UDPReceiver.start_time, time.time(), total_bytes, combined_gui.UDPReceiver.total_bytes, lc_calibration_gui.UDPReceiver.total_bytes, pt_multi_gui.UDPReceiver.total_bytes, sense_testing_gui.UDPReceiver.total_bytes, total_packets, combined_gui.UDPReceiver.total_packets, lc_calibration_gui.UDPReceiver.total_packets, pt_multi_gui.UDPReceiver.total_packets, and sense_testing_gui.UDPReceiver.total_packets.

◆ parse_packet_header()

Optional[Tuple[int, int, int]] combined_fsw_gui.UDPReceiver.parse_packet_header ( self,
bytes data ) 
Parse the packet header

Definition at line 432 of file combined_fsw_gui.py.

Referenced by run().

◆ parse_sensor_data_packet()

Optional[Tuple[dict, List[dict]]] combined_fsw_gui.UDPReceiver.parse_sensor_data_packet ( self,
bytes data ) 
Parse sensor data packet

Definition at line 444 of file combined_fsw_gui.py.

Referenced by run().

◆ run()

combined_fsw_gui.UDPReceiver.run ( self) 
Main receiver loop

Definition at line 384 of file combined_fsw_gui.py.

References actuator_testing_gui.SensorReceiver._stop, calibration_orchestrator.UDPSensorReceiver._stop, _stop, combined_gui.UDPReceiver._stop, gui.Reader._stop, lc_calibration_gui.UDPReceiver._stop, pt_multi_gui.UDPReceiver._stop, robust_pt_calibration_gui.SerialReader._stop, sense_testing_gui.UDPReceiver._stop, solenoid_characterization_gui.UDPReceiver._stop, actuator_testing_gui.SensorReceiver.bind_address, bind_address, combined_gui.SensorPlotWidget.bind_address, combined_gui.UDPReceiver.bind_address, fsw::config::ActuatorServiceConfig.bind_address, fsw::control::ControllerService::PWMConfig.bind_address, lc_calibration_gui.LCPlotWindow.bind_address, lc_calibration_gui.UDPReceiver.bind_address, pt_multi_gui.PTPlotWindow.bind_address, pt_multi_gui.UDPReceiver.bind_address, sense_testing_gui.UDPReceiver.bind_address, solenoid_characterization_gui.SolenoidCharacterizationWindow.bind_address, solenoid_characterization_gui.UDPReceiver.bind_address, emit(), packet_received, combined_gui.UDPReceiver.packet_received, parse_packet_header(), parse_sensor_data_packet(), actuator_testing_gui.SensorReceiver.port, calibration_orchestrator.UDPSensorReceiver.port, calibration_server.ElodinWriter.port, port, combined_gui.UDPReceiver.port, emmc_log_t.port, FakeDb.port, FakeDbRefuseFirst.port, feedtwin.comps.manifold.ManifoldBranch.port, fsw::config::ActuatorServiceConfig.port, fsw::config::ControllerServiceConfig.port, fsw::config::DatabaseConfig.port, fsw::config::DiscoveredBoard.port, gui.Reader.port, idle_t.port, imu_calibration_gui.IMUCalibrationGUI.port, imu_calibration_gui.UDPReceiver.port, lc_calibration_gui.LCPlotWindow.port, lc_calibration_gui.UDPReceiver.port, pt_multi_gui.PTPlotWindow.port, pt_multi_gui.UDPReceiver.port, robust_pt_calibration_gui.SerialReader.port, self_test_t.port, sense_testing_gui.UDPReceiver.port, solenoid_characterization_gui.UDPReceiver.port, StarOTA::Config.port, t7_integration.FakeElodin.port, actuator_testing_gui.SensorReceiver.sensor_data_received, sensor_data_received, combined_gui.UDPReceiver.sensor_data_received, lc_calibration_gui.UDPReceiver.sensor_data_received, pt_multi_gui.UDPReceiver.sensor_data_received, sense_testing_gui.UDPReceiver.sensor_data_received, solenoid_characterization_gui.UDPReceiver.sensor_data_received, actuator_testing_gui.SensorReceiver.sock, ball_valve_gui.BallValveGui.sock, board_simulator.SimulatedBoard.sock, calibration_server.ElodinWriter.sock, sock, combined_gui.UDPReceiver.sock, imu_calibration_gui.UDPReceiver.sock, lc_calibration_gui.UDPReceiver.sock, pt_multi_gui.UDPReceiver.sock, sense_testing_gui.UDPReceiver.sock, solenoid_characterization_gui.UDPReceiver.sock, autonomous_calibration_engine.AutonomousCalibrationEngine.start_time, calibration_robustness.HealthMonitor.start_time, start_time, combined_gui.UDPReceiver.start_time, lc_calibration_gui.UDPReceiver.start_time, pt_multi_gui.UDPReceiver.start_time, PWMState.start_time, sense_testing_gui.UDPReceiver.start_time, actuator_testing_gui.SensorReceiver.status_update, status_update, combined_gui.UDPReceiver.status_update, lc_calibration_gui.UDPReceiver.status_update, pt_multi_gui.UDPReceiver.status_update, sense_testing_gui.UDPReceiver.status_update, solenoid_characterization_gui.UDPReceiver.status_update, time.time(), total_bytes, combined_gui.UDPReceiver.total_bytes, lc_calibration_gui.UDPReceiver.total_bytes, pt_multi_gui.UDPReceiver.total_bytes, sense_testing_gui.UDPReceiver.total_bytes, total_packets, combined_gui.UDPReceiver.total_packets, lc_calibration_gui.UDPReceiver.total_packets, pt_multi_gui.UDPReceiver.total_packets, and sense_testing_gui.UDPReceiver.total_packets.

◆ stop()

combined_fsw_gui.UDPReceiver.stop ( self) 
Stop the receiver thread

Definition at line 349 of file combined_fsw_gui.py.

References actuator_testing_gui.SensorReceiver._stop, calibration_orchestrator.UDPSensorReceiver._stop, _stop, combined_gui.UDPReceiver._stop, gui.Reader._stop, lc_calibration_gui.UDPReceiver._stop, pt_multi_gui.UDPReceiver._stop, robust_pt_calibration_gui.SerialReader._stop, sense_testing_gui.UDPReceiver._stop, solenoid_characterization_gui.UDPReceiver._stop, actuator_testing_gui.SensorReceiver.sock, ball_valve_gui.BallValveGui.sock, board_simulator.SimulatedBoard.sock, calibration_server.ElodinWriter.sock, sock, combined_gui.UDPReceiver.sock, imu_calibration_gui.UDPReceiver.sock, lc_calibration_gui.UDPReceiver.sock, pt_multi_gui.UDPReceiver.sock, sense_testing_gui.UDPReceiver.sock, and solenoid_characterization_gui.UDPReceiver.sock.

Member Data Documentation

◆ _stop

bool combined_fsw_gui.UDPReceiver._stop = False
protected

Definition at line 343 of file combined_fsw_gui.py.

Referenced by run(), and stop().

◆ bind_address

combined_fsw_gui.UDPReceiver.bind_address = bind_address

Definition at line 342 of file combined_fsw_gui.py.

Referenced by run().

◆ packet_received

combined_fsw_gui.UDPReceiver.packet_received = QtCore.pyqtSignal(int, int)
static

Definition at line 335 of file combined_fsw_gui.py.

Referenced by run().

◆ port

combined_fsw_gui.UDPReceiver.port = port

Definition at line 341 of file combined_fsw_gui.py.

Referenced by run().

◆ sensor_data_received

combined_fsw_gui.UDPReceiver.sensor_data_received
static
Initial value:
= QtCore.pyqtSignal(
dict, list, str
)

Definition at line 331 of file combined_fsw_gui.py.

Referenced by run().

◆ sock

combined_fsw_gui.UDPReceiver.sock = None

Definition at line 344 of file combined_fsw_gui.py.

Referenced by run(), and stop().

◆ start_time

combined_fsw_gui.UDPReceiver.start_time = None

Definition at line 347 of file combined_fsw_gui.py.

Referenced by get_stats(), and run().

◆ status_update

combined_fsw_gui.UDPReceiver.status_update = QtCore.pyqtSignal(str)
static

Definition at line 334 of file combined_fsw_gui.py.

Referenced by run().

◆ total_bytes

combined_fsw_gui.UDPReceiver.total_bytes = 0

Definition at line 346 of file combined_fsw_gui.py.

Referenced by get_stats(), and run().

◆ total_packets

combined_fsw_gui.UDPReceiver.total_packets = 0

Definition at line 345 of file combined_fsw_gui.py.

Referenced by get_stats(), and run().

The documentation for this class was generated from the following file: