cereal.messaging package
Subpackages
- cereal.messaging.tests package
- Submodules
- cereal.messaging.tests.test_fake module
TestEvents
TestFakeSockets
TestFakeSockets_0
TestFakeSockets_0.prefix
TestFakeSockets_0.setUp()
TestFakeSockets_0.tearDown()
TestFakeSockets_0.test_event_handle_init()
TestFakeSockets_0.test_managed_socket_state()
TestFakeSockets_0.test_non_managed_socket_state()
TestFakeSockets_0.test_sockets_enable_disable()
TestFakeSockets_0.test_synced_pub_sub()
TestFakeSockets_1_test
TestFakeSockets_1_test.prefix
TestFakeSockets_1_test.setUp()
TestFakeSockets_1_test.tearDown()
TestFakeSockets_1_test.test_event_handle_init()
TestFakeSockets_1_test.test_managed_socket_state()
TestFakeSockets_1_test.test_non_managed_socket_state()
TestFakeSockets_1_test.test_sockets_enable_disable()
TestFakeSockets_1_test.test_synced_pub_sub()
- cereal.messaging.tests.test_messaging module
TestMessaging
TestMessaging.setUp()
TestMessaging.test_drain_sock
TestMessaging.test_drain_sock_0()
TestMessaging.test_drain_sock_1()
TestMessaging.test_new_message
TestMessaging.test_new_message_00_roadCameraState()
TestMessaging.test_new_message_01_gpsNMEA()
TestMessaging.test_new_message_02_can()
TestMessaging.test_new_message_03_deviceState()
TestMessaging.test_new_message_04_controlsState()
TestMessaging.test_new_message_05_radarState()
TestMessaging.test_new_message_06_roadEncodeIdx()
TestMessaging.test_new_message_07_liveTracks()
TestMessaging.test_new_message_08_sendcan()
TestMessaging.test_new_message_09_logMessage()
TestMessaging.test_new_message_10_liveCalibration()
TestMessaging.test_new_message_11_androidLog()
TestMessaging.test_new_message_12_gpsLocation()
TestMessaging.test_new_message_13_carState()
TestMessaging.test_new_message_14_carControl()
TestMessaging.test_new_message_15_longitudinalPlan()
TestMessaging.test_new_message_16_qcomGnss()
TestMessaging.test_new_message_17_procLog()
TestMessaging.test_new_message_18_ubloxGnss()
TestMessaging.test_new_message_19_clocks()
TestMessaging.test_new_message_20_ubloxRaw()
TestMessaging.test_new_message_21_gpsLocationExternal()
TestMessaging.test_new_message_22_testJoystick()
TestMessaging.test_new_message_23_liveParameters()
TestMessaging.test_new_message_24_cameraOdometry()
TestMessaging.test_new_message_25_thumbnail()
TestMessaging.test_new_message_26_onroadEvents()
TestMessaging.test_new_message_27_carParams()
TestMessaging.test_new_message_28_driverCameraState()
TestMessaging.test_new_message_29_driverMonitoringState()
TestMessaging.test_new_message_30_liveLocationKalman()
TestMessaging.test_new_message_31_wideRoadCameraState()
TestMessaging.test_new_message_32_modelV2()
TestMessaging.test_new_message_33_driverEncodeIdx()
TestMessaging.test_new_message_34_wideRoadEncodeIdx()
TestMessaging.test_new_message_35_managerState()
TestMessaging.test_new_message_36_uploaderState()
TestMessaging.test_new_message_37_peripheralState()
TestMessaging.test_new_message_38_pandaStates()
TestMessaging.test_new_message_39_navInstruction()
TestMessaging.test_new_message_40_navRoute()
TestMessaging.test_new_message_41_navThumbnail()
TestMessaging.test_new_message_42_errorLogMessage()
TestMessaging.test_new_message_43_roadEncodeData()
TestMessaging.test_new_message_44_driverEncodeData()
TestMessaging.test_new_message_45_wideRoadEncodeData()
TestMessaging.test_new_message_46_qRoadEncodeData()
TestMessaging.test_new_message_47_qRoadEncodeIdx()
TestMessaging.test_new_message_48_gnssMeasurements()
TestMessaging.test_new_message_49_driverStateV2()
TestMessaging.test_new_message_50_userFlag()
TestMessaging.test_new_message_51_liveTorqueParameters()
TestMessaging.test_new_message_52_magnetometer()
TestMessaging.test_new_message_53_lightSensor()
TestMessaging.test_new_message_54_temperatureSensor()
TestMessaging.test_new_message_55_accelerometer()
TestMessaging.test_new_message_56_gyroscope()
TestMessaging.test_new_message_57_gyroscope2()
TestMessaging.test_new_message_58_accelerometer2()
TestMessaging.test_new_message_59_uiDebug()
TestMessaging.test_new_message_60_microphone()
TestMessaging.test_new_message_61_navModel()
TestMessaging.test_new_message_62_mapRenderState()
TestMessaging.test_new_message_63_uiPlan()
TestMessaging.test_new_message_64_livestreamRoadEncodeIdx()
TestMessaging.test_new_message_65_livestreamWideRoadEncodeIdx()
TestMessaging.test_new_message_66_livestreamDriverEncodeIdx()
TestMessaging.test_new_message_67_livestreamRoadEncodeData()
TestMessaging.test_new_message_68_livestreamWideRoadEncodeData()
TestMessaging.test_new_message_69_livestreamDriverEncodeData()
TestMessaging.test_new_message_70_temperatureSensor2()
TestMessaging.test_new_message_71_customReservedRawData0()
TestMessaging.test_new_message_72_customReservedRawData1()
TestMessaging.test_new_message_73_customReservedRawData2()
TestMessaging.test_new_message_74_carOutput()
TestMessaging.test_pub_sock
TestMessaging.test_pub_sock_00_roadCameraState()
TestMessaging.test_pub_sock_01_gpsNMEA()
TestMessaging.test_pub_sock_02_can()
TestMessaging.test_pub_sock_03_deviceState()
TestMessaging.test_pub_sock_04_controlsState()
TestMessaging.test_pub_sock_05_radarState()
TestMessaging.test_pub_sock_06_roadEncodeIdx()
TestMessaging.test_pub_sock_07_liveTracks()
TestMessaging.test_pub_sock_08_sendcan()
TestMessaging.test_pub_sock_09_logMessage()
TestMessaging.test_pub_sock_10_liveCalibration()
TestMessaging.test_pub_sock_11_androidLog()
TestMessaging.test_pub_sock_12_gpsLocation()
TestMessaging.test_pub_sock_13_carState()
TestMessaging.test_pub_sock_14_carControl()
TestMessaging.test_pub_sock_15_longitudinalPlan()
TestMessaging.test_pub_sock_16_qcomGnss()
TestMessaging.test_pub_sock_17_procLog()
TestMessaging.test_pub_sock_18_ubloxGnss()
TestMessaging.test_pub_sock_19_clocks()
TestMessaging.test_pub_sock_20_ubloxRaw()
TestMessaging.test_pub_sock_21_gpsLocationExternal()
TestMessaging.test_pub_sock_22_testJoystick()
TestMessaging.test_pub_sock_23_liveParameters()
TestMessaging.test_pub_sock_24_cameraOdometry()
TestMessaging.test_pub_sock_25_thumbnail()
TestMessaging.test_pub_sock_26_onroadEvents()
TestMessaging.test_pub_sock_27_carParams()
TestMessaging.test_pub_sock_28_driverCameraState()
TestMessaging.test_pub_sock_29_driverMonitoringState()
TestMessaging.test_pub_sock_30_liveLocationKalman()
TestMessaging.test_pub_sock_31_wideRoadCameraState()
TestMessaging.test_pub_sock_32_modelV2()
TestMessaging.test_pub_sock_33_driverEncodeIdx()
TestMessaging.test_pub_sock_34_wideRoadEncodeIdx()
TestMessaging.test_pub_sock_35_managerState()
TestMessaging.test_pub_sock_36_uploaderState()
TestMessaging.test_pub_sock_37_peripheralState()
TestMessaging.test_pub_sock_38_pandaStates()
TestMessaging.test_pub_sock_39_navInstruction()
TestMessaging.test_pub_sock_40_navRoute()
TestMessaging.test_pub_sock_41_navThumbnail()
TestMessaging.test_pub_sock_42_errorLogMessage()
TestMessaging.test_pub_sock_43_roadEncodeData()
TestMessaging.test_pub_sock_44_driverEncodeData()
TestMessaging.test_pub_sock_45_wideRoadEncodeData()
TestMessaging.test_pub_sock_46_qRoadEncodeData()
TestMessaging.test_pub_sock_47_qRoadEncodeIdx()
TestMessaging.test_pub_sock_48_gnssMeasurements()
TestMessaging.test_pub_sock_49_driverStateV2()
TestMessaging.test_pub_sock_50_userFlag()
TestMessaging.test_pub_sock_51_liveTorqueParameters()
TestMessaging.test_pub_sock_52_magnetometer()
TestMessaging.test_pub_sock_53_lightSensor()
TestMessaging.test_pub_sock_54_temperatureSensor()
TestMessaging.test_pub_sock_55_accelerometer()
TestMessaging.test_pub_sock_56_gyroscope()
TestMessaging.test_pub_sock_57_gyroscope2()
TestMessaging.test_pub_sock_58_accelerometer2()
TestMessaging.test_pub_sock_59_uiDebug()
TestMessaging.test_pub_sock_60_microphone()
TestMessaging.test_pub_sock_61_navModel()
TestMessaging.test_pub_sock_62_mapRenderState()
TestMessaging.test_pub_sock_63_uiPlan()
TestMessaging.test_pub_sock_64_livestreamRoadEncodeIdx()
TestMessaging.test_pub_sock_65_livestreamWideRoadEncodeIdx()
TestMessaging.test_pub_sock_66_livestreamDriverEncodeIdx()
TestMessaging.test_pub_sock_67_livestreamRoadEncodeData()
TestMessaging.test_pub_sock_68_livestreamWideRoadEncodeData()
TestMessaging.test_pub_sock_69_livestreamDriverEncodeData()
TestMessaging.test_pub_sock_70_temperatureSensor2()
TestMessaging.test_pub_sock_71_customReservedRawData0()
TestMessaging.test_pub_sock_72_customReservedRawData1()
TestMessaging.test_pub_sock_73_customReservedRawData2()
TestMessaging.test_pub_sock_74_carOutput()
TestMessaging.test_recv_one()
TestMessaging.test_recv_one_or_none()
TestMessaging.test_recv_one_retry()
TestMessaging.test_recv_sock()
TestMessaging.test_sub_sock
TestMessaging.test_sub_sock_00_roadCameraState()
TestMessaging.test_sub_sock_01_gpsNMEA()
TestMessaging.test_sub_sock_02_can()
TestMessaging.test_sub_sock_03_deviceState()
TestMessaging.test_sub_sock_04_controlsState()
TestMessaging.test_sub_sock_05_radarState()
TestMessaging.test_sub_sock_06_roadEncodeIdx()
TestMessaging.test_sub_sock_07_liveTracks()
TestMessaging.test_sub_sock_08_sendcan()
TestMessaging.test_sub_sock_09_logMessage()
TestMessaging.test_sub_sock_10_liveCalibration()
TestMessaging.test_sub_sock_11_androidLog()
TestMessaging.test_sub_sock_12_gpsLocation()
TestMessaging.test_sub_sock_13_carState()
TestMessaging.test_sub_sock_14_carControl()
TestMessaging.test_sub_sock_15_longitudinalPlan()
TestMessaging.test_sub_sock_16_qcomGnss()
TestMessaging.test_sub_sock_17_procLog()
TestMessaging.test_sub_sock_18_ubloxGnss()
TestMessaging.test_sub_sock_19_clocks()
TestMessaging.test_sub_sock_20_ubloxRaw()
TestMessaging.test_sub_sock_21_gpsLocationExternal()
TestMessaging.test_sub_sock_22_testJoystick()
TestMessaging.test_sub_sock_23_liveParameters()
TestMessaging.test_sub_sock_24_cameraOdometry()
TestMessaging.test_sub_sock_25_thumbnail()
TestMessaging.test_sub_sock_26_onroadEvents()
TestMessaging.test_sub_sock_27_carParams()
TestMessaging.test_sub_sock_28_driverCameraState()
TestMessaging.test_sub_sock_29_driverMonitoringState()
TestMessaging.test_sub_sock_30_liveLocationKalman()
TestMessaging.test_sub_sock_31_wideRoadCameraState()
TestMessaging.test_sub_sock_32_modelV2()
TestMessaging.test_sub_sock_33_driverEncodeIdx()
TestMessaging.test_sub_sock_34_wideRoadEncodeIdx()
TestMessaging.test_sub_sock_35_managerState()
TestMessaging.test_sub_sock_36_uploaderState()
TestMessaging.test_sub_sock_37_peripheralState()
TestMessaging.test_sub_sock_38_pandaStates()
TestMessaging.test_sub_sock_39_navInstruction()
TestMessaging.test_sub_sock_40_navRoute()
TestMessaging.test_sub_sock_41_navThumbnail()
TestMessaging.test_sub_sock_42_errorLogMessage()
TestMessaging.test_sub_sock_43_roadEncodeData()
TestMessaging.test_sub_sock_44_driverEncodeData()
TestMessaging.test_sub_sock_45_wideRoadEncodeData()
TestMessaging.test_sub_sock_46_qRoadEncodeData()
TestMessaging.test_sub_sock_47_qRoadEncodeIdx()
TestMessaging.test_sub_sock_48_gnssMeasurements()
TestMessaging.test_sub_sock_49_driverStateV2()
TestMessaging.test_sub_sock_50_userFlag()
TestMessaging.test_sub_sock_51_liveTorqueParameters()
TestMessaging.test_sub_sock_52_magnetometer()
TestMessaging.test_sub_sock_53_lightSensor()
TestMessaging.test_sub_sock_54_temperatureSensor()
TestMessaging.test_sub_sock_55_accelerometer()
TestMessaging.test_sub_sock_56_gyroscope()
TestMessaging.test_sub_sock_57_gyroscope2()
TestMessaging.test_sub_sock_58_accelerometer2()
TestMessaging.test_sub_sock_59_uiDebug()
TestMessaging.test_sub_sock_60_microphone()
TestMessaging.test_sub_sock_61_navModel()
TestMessaging.test_sub_sock_62_mapRenderState()
TestMessaging.test_sub_sock_63_uiPlan()
TestMessaging.test_sub_sock_64_livestreamRoadEncodeIdx()
TestMessaging.test_sub_sock_65_livestreamWideRoadEncodeIdx()
TestMessaging.test_sub_sock_66_livestreamDriverEncodeIdx()
TestMessaging.test_sub_sock_67_livestreamRoadEncodeData()
TestMessaging.test_sub_sock_68_livestreamWideRoadEncodeData()
TestMessaging.test_sub_sock_69_livestreamDriverEncodeData()
TestMessaging.test_sub_sock_70_temperatureSensor2()
TestMessaging.test_sub_sock_71_customReservedRawData0()
TestMessaging.test_sub_sock_72_customReservedRawData1()
TestMessaging.test_sub_sock_73_customReservedRawData2()
TestMessaging.test_sub_sock_74_carOutput()
TestPubSubSockets
assert_carstate()
delayed_send()
random_bytes()
random_carstate()
random_sock()
random_socks()
zmq_expected_failure()
zmq_sleep()
- cereal.messaging.tests.test_poller module
- cereal.messaging.tests.test_pub_sub_master module
TestPubMaster
TestSubMaster
TestSubMaster.setUp()
TestSubMaster.test_alive()
TestSubMaster.test_avg_frequency_checks()
TestSubMaster.test_conflate()
TestSubMaster.test_getitem()
TestSubMaster.test_ignore_alive()
TestSubMaster.test_init()
TestSubMaster.test_init_state()
TestSubMaster.test_update()
TestSubMaster.test_update_timeout()
TestSubMaster.test_valid()
- cereal.messaging.tests.test_services module
TestServices
TestServices.test_generated_header()
TestServices.test_no_duplicate_port()
TestServices.test_services
TestServices.test_services_00_gyroscope()
TestServices.test_services_01_gyroscope2()
TestServices.test_services_02_accelerometer()
TestServices.test_services_03_accelerometer2()
TestServices.test_services_04_magnetometer()
TestServices.test_services_05_lightSensor()
TestServices.test_services_06_temperatureSensor()
TestServices.test_services_07_temperatureSensor2()
TestServices.test_services_08_gpsNMEA()
TestServices.test_services_09_deviceState()
TestServices.test_services_10_can()
TestServices.test_services_11_controlsState()
TestServices.test_services_12_pandaStates()
TestServices.test_services_13_peripheralState()
TestServices.test_services_14_radarState()
TestServices.test_services_15_roadEncodeIdx()
TestServices.test_services_16_liveTracks()
TestServices.test_services_17_sendcan()
TestServices.test_services_18_logMessage()
TestServices.test_services_19_errorLogMessage()
TestServices.test_services_20_liveCalibration()
TestServices.test_services_21_liveTorqueParameters()
TestServices.test_services_22_androidLog()
TestServices.test_services_23_carState()
TestServices.test_services_24_carControl()
TestServices.test_services_25_carOutput()
TestServices.test_services_26_longitudinalPlan()
TestServices.test_services_27_procLog()
TestServices.test_services_28_gpsLocationExternal()
TestServices.test_services_29_gpsLocation()
TestServices.test_services_30_ubloxGnss()
TestServices.test_services_31_qcomGnss()
TestServices.test_services_32_gnssMeasurements()
TestServices.test_services_33_clocks()
TestServices.test_services_34_ubloxRaw()
TestServices.test_services_35_liveLocationKalman()
TestServices.test_services_36_liveParameters()
TestServices.test_services_37_cameraOdometry()
TestServices.test_services_38_thumbnail()
TestServices.test_services_39_onroadEvents()
TestServices.test_services_40_carParams()
TestServices.test_services_41_roadCameraState()
TestServices.test_services_42_driverCameraState()
TestServices.test_services_43_driverEncodeIdx()
TestServices.test_services_44_driverStateV2()
TestServices.test_services_45_driverMonitoringState()
TestServices.test_services_46_wideRoadEncodeIdx()
TestServices.test_services_47_wideRoadCameraState()
TestServices.test_services_48_modelV2()
TestServices.test_services_49_managerState()
TestServices.test_services_50_uploaderState()
TestServices.test_services_51_navInstruction()
TestServices.test_services_52_navRoute()
TestServices.test_services_53_navThumbnail()
TestServices.test_services_54_navModel()
TestServices.test_services_55_mapRenderState()
TestServices.test_services_56_uiPlan()
TestServices.test_services_57_qRoadEncodeIdx()
TestServices.test_services_58_userFlag()
TestServices.test_services_59_microphone()
TestServices.test_services_60_uiDebug()
TestServices.test_services_61_testJoystick()
TestServices.test_services_62_roadEncodeData()
TestServices.test_services_63_driverEncodeData()
TestServices.test_services_64_wideRoadEncodeData()
TestServices.test_services_65_qRoadEncodeData()
TestServices.test_services_66_livestreamWideRoadEncodeIdx()
TestServices.test_services_67_livestreamRoadEncodeIdx()
TestServices.test_services_68_livestreamDriverEncodeIdx()
TestServices.test_services_69_livestreamWideRoadEncodeData()
TestServices.test_services_70_livestreamRoadEncodeData()
TestServices.test_services_71_livestreamDriverEncodeData()
TestServices.test_services_72_customReservedRawData0()
TestServices.test_services_73_customReservedRawData1()
TestServices.test_services_74_customReservedRawData2()
- Module contents
Submodules
cereal.messaging.demo module
cereal.messaging.messaging_pyx module
- class cereal.messaging.messaging_pyx.Event
Bases:
object
- clear()
- fd
- peek()
- ptr
- set()
- wait(timeout=-1)
- exception cereal.messaging.messaging_pyx.MessagingError(endpoint=None)
Bases:
Exception
- exception cereal.messaging.messaging_pyx.MultiplePublishersError(endpoint=None)
Bases:
MessagingError
- class cereal.messaging.messaging_pyx.PubSocket
Bases:
object
- all_readers_updated()
- connect(context, endpoint)
- send(data)
- class cereal.messaging.messaging_pyx.SocketEventHandle
Bases:
object
- enabled
- recv_called_event
- recv_ready_event
- class cereal.messaging.messaging_pyx.SubSocket
Bases:
object
- connect(context, endpoint, address=b'127.0.0.1', conflate=False)
- receive(non_blocking=False)
- setTimeout(timeout)
- cereal.messaging.messaging_pyx.delete_fake_prefix()
- cereal.messaging.messaging_pyx.get_fake_prefix()
- cereal.messaging.messaging_pyx.set_fake_prefix(prefix)
- cereal.messaging.messaging_pyx.toggle_fake_events(enabled)
- cereal.messaging.messaging_pyx.wait_for_one_event(events, timeout=-1)
cereal.messaging.stress module
Module contents
- class cereal.messaging.SubMaster(services: List[str], poll: str | None = None, ignore_alive: List[str] | None = None, ignore_avg_freq: List[str] | None = None, ignore_valid: List[str] | None = None, addr: str = '127.0.0.1', frequency: float | None = None)[source]
Bases:
object
- cereal.messaging.drain_sock(sock: SubSocket, wait_for_one: bool = False) List[_DynamicStructReader] [source]
Receive all message currently available on the queue
- cereal.messaging.drain_sock_raw(sock: SubSocket, wait_for_one: bool = False) List[bytes] [source]
Receive all message currently available on the queue
- cereal.messaging.fake_event_handle(endpoint: str, identifier: str | None = None, override: bool = True, enable: bool = False) SocketEventHandle [source]
- cereal.messaging.new_message(service: str | None, size: int | None = None, **kwargs) _DynamicStructBuilder [source]
- cereal.messaging.recv_one_retry(sock: SubSocket) _DynamicStructReader [source]
Keep receiving until we get a message