cereal.messaging package

Subpackages

Submodules

cereal.messaging.demo module

cereal.messaging.messaging_pyx module

class cereal.messaging.messaging_pyx.Context

Bases: object

term()
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.Poller

Bases: object

poll(timeout)
registerSocket(socket)
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.PubMaster(services: List[str])[source]

Bases: object

all_readers_updated(s: str) bool[source]
send(s: str, dat: bytes | _DynamicStructBuilder) None[source]
wait_for_readers_to_update(s: str, timeout: int, dt: float = 0.05) bool[source]
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

all_alive(service_list: List[str] | None = None) bool[source]
all_checks(service_list: List[str] | None = None) bool[source]
all_freq_ok(service_list: List[str] | None = None) bool[source]
all_valid(service_list: List[str] | None = None) bool[source]
update(timeout: int = 100) None[source]
update_msgs(cur_time: float, msgs: List[_DynamicStructReader]) None[source]
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.log_from_bytes(dat: bytes) _DynamicStructReader[source]
cereal.messaging.new_message(service: str | None, size: int | None = None, **kwargs) _DynamicStructBuilder[source]
cereal.messaging.pub_sock(endpoint: str) PubSocket[source]
cereal.messaging.recv_one(sock: SubSocket) _DynamicStructReader | None[source]
cereal.messaging.recv_one_or_none(sock: SubSocket) _DynamicStructReader | None[source]
cereal.messaging.recv_one_retry(sock: SubSocket) _DynamicStructReader[source]

Keep receiving until we get a message

cereal.messaging.recv_sock(sock: SubSocket, wait: bool = False) _DynamicStructReader | None[source]

Same as drain sock, but only returns latest message. Consider using conflate instead.

cereal.messaging.sub_sock(endpoint: str, poller: Poller | None = None, addr: str = '127.0.0.1', conflate: bool = False, timeout: int | None = None) SubSocket[source]