MCPcopy Create free account

hub / github.com/commaai/msgq / functions

Functions153 in github.com/commaai/msgq

⨍ Functions 153◇ Types & classes 44
↓ 23 callersFunctionmsgq_msg_close
msgq/msgq.cc:63
↓ 22 callersFunctionmsgq_new_queue
msgq/msgq.cc:84
↓ 14 callersFunctionmsgq_init_subscriber
msgq/msgq.cc:184
↓ 14 callersFunctionmsgq_msg_send
msgq/msgq.cc:234
↓ 13 callersFunctionmsgq_msg_recv
msgq/msgq.cc:348
↓ 13 callersMethodreceive
msgq/impl_msgq.cc:61
↓ 11 callersFunctioncleanup_test_queue
msgq/msgq_tests.cc:4
↓ 11 callersMethodconnect
Connect is not thread safe. Do not use the buffers while calling connect
msgq/visionipc/visionipc_client.cc:38
↓ 11 callersMethodsend
msgq/visionipc/visionipc_server.cc:167
↓ 10 callersFunctionmsgq_init_publisher
msgq/msgq.cc:157
↓ 9 callersFunctionmsgq_msg_init_size
msgq/msgq.cc:46
↓ 9 callersFunctionthrow_errno
msgq/event.cc:22
↓ 8 callersMethodpeek
msgq/event.cc:212
↓ 8 callersMethodset
msgq/event.cc:173
↓ 7 callersFunctionipc_sendrecv_with_fds
msgq/visionipc/visionipc.cc:60
↓ 6 callersMethodsend
msgq/impl_msgq.cc:130
↓ 6 callersMethodsetup_vipc
(self, name, *stream_types, num_buffers=1, width=100, height=100, conflate=False)
msgq/visionipc/tests/test_visionipc.py:19
↓ 6 callersMethodwait
msgq/event.cc:203
↓ 5 callersFunctionion_fd
msgq/visionipc/visionbuf_ion.cc:40
↓ 5 callersFunctionmsgq_reset_reader
msgq/msgq.cc:72
↓ 5 callersMethodrecv
msgq/visionipc/visionipc_client.cc:85
↓ 4 callersMethodclear
msgq/event.cc:186
↓ 4 callersMethodconnect
msgq/impl_msgq.cc:38
↓ 4 callersFunctionmsgq_msg_init_data
msgq/msgq.cc:54
↓ 4 callersMethodregisterSocket
msgq/impl_fake.cc:4
↓ 3 callersMethodfree
msgq/visionipc/visionbuf.cc:65
↓ 3 callersFunctionget_ipc_path
msgq/visionipc/visionipc_server.cc:21
↓ 3 callersFunctionipc_connect
msgq/visionipc/visionipc.cc:20
↓ 3 callersFunctionpoll_events
poll() that retries on EINTR with a monotonic deadline so signal storms don't extend the effective timeout.
msgq/event.cc:35
↓ 3 callersFunctionrandom_sock
()
msgq/tests/test_messaging.py:8
↓ 2 callersFunctionconnect_to_vipc_server
msgq/visionipc/visionipc_client.cc:14
↓ 2 callersFunctionevent_state_shm_mmap
msgq/event.cc:69
↓ 2 callersMethodgetData
msgq/ipc.h:34
↓ 2 callersMethodgetSize
msgq/ipc.h:33
↓ 2 callersFunctionget_endpoint_name
msgq/visionipc/visionipc_server.cc:17
↓ 2 callersMethodinit_yuv
msgq/visionipc/visionbuf.cc:51
↓ 2 callersFunctionmessaging_use_fake
msgq/ipc.cc:9
↓ 2 callersFunctionmsgq_close_queue
msgq/msgq.cc:150
↓ 2 callersFunctionmsgq_get_uid
msgq/msgq.cc:32
↓ 2 callersFunctionmsgq_msg_ready
msgq/msgq.cc:319
↓ 2 callersFunctionmsgq_poll
msgq/msgq.cc:437
↓ 2 callersMethodpoll
msgq/impl_fake.cc:8
↓ 2 callersFunctionrandom_bytes
(length=1000)
msgq/tests/test_messaging.py:11
↓ 2 callersMethodsync
msgq/visionipc/visionbuf.cc:61
↓ 2 callersFunctionthread_signal
msgq/msgq.cc:172
↓ 2 callersMethodtoggle_fake_events
msgq/event.cc:151
↓ 1 callersMethodallocate
msgq/visionipc/visionbuf.cc:36
↓ 1 callersMethodclose
msgq/impl_msgq.cc:27
↓ 1 callersMethodcreate_buffers
msgq/visionipc/visionipc_server.cc:37
↓ 1 callersFunctioncreate_builder
(env)
site_scons/site_tools/cython.py:39
↓ 1 callersFunctionevent_shm_name
macOS limits shm_open names to ~31 chars, so hash the (prefix, identifier, endpoint) tuple into a fixed-length name.
msgq/event.cc:52
↓ 1 callersMethodfd
msgq/event.cc:223
↓ 1 callersMethodgetQueue
msgq/impl_msgq.h:18
↓ 1 callersMethodimport
msgq/visionipc/visionbuf.cc:43
↓ 1 callersFunctionipc_bind
msgq/visionipc/visionipc.cc:39
↓ 1 callersMethodis_connected
msgq/visionipc/visionipc_client.h:26
↓ 1 callersMethodis_valid
msgq/event.cc:219
↓ 1 callersFunctionmalloc_with_fd
msgq/visionipc/visionbuf.cc:14
↓ 1 callersFunctionmsgq_all_readers_updated
msgq/msgq.cc:496
↓ 1 callersFunctionopen_event_fifo
msgq/event.cc:26
↓ 1 callersMethodsetTimeout
msgq/impl_msgq.cc:96
↓ 1 callersMethodset_fake_prefix
msgq/event.cc:158
↓ 1 callersMethodstart_listener
msgq/visionipc/visionipc_server.cc:68
↓ 1 callersMethodtakeOwnership
msgq/impl_msgq.cc:22
MethodEvent
msgq/event.cc:171
MethodFakeSubSocket
msgq/impl_fake.h:32
MethodIonFileHandle
msgq/visionipc/visionbuf_ion.cc:30
MethodSocketEventHandle
msgq/event.cc:96
MethodVisionIpcClient
msgq/visionipc/visionipc_client.cc:29
MethodVisionIpcServer
msgq/visionipc/visionipc_server.cc:29
Methodall_readers_updated
msgq/impl_msgq.cc:138
Methodallocate
msgq/visionipc/visionbuf_ion.cc:45
Methodconnect
msgq/impl_fake.h:42
Methodcreate
msgq/ipc.cc:14
Methodcreate_buffers_with_sizes
msgq/visionipc/visionipc_server.cc:48
Functioncython_suffix_emitter
(env, source)
site_scons/site_tools/cython.py:53
Functiondaemon_repub_process_run
()
msgq/tests/test_fake.py:15
Functiondrain_sock_raw
Receive all message currently available on the queue
msgq/__init__.py:60
Methodensure_fifos_open
msgq/impl_fake.h:23
Functionexists
(env)
site_scons/site_tools/cython.py:71
Functionfake_event_handle
(endpoint: str, identifier: Optional[Union[str, bytes]] = None, override: bool = True, enable: bool = False)
msgq/__init__.py:34
Methodfake_prefix
msgq/event.cc:166
Methodfree
msgq/visionipc/visionbuf_ion.cc:123
Functiongenerate
(env)
site_scons/site_tools/cython.py:56
MethodgetAvailableStreams
msgq/visionipc/visionipc_client.cc:128
Methodget_buffer
msgq/visionipc/visionipc_server.cc:154
Methodget_frame_id
msgq/visionipc/visionbuf_ion.cc:134
Methodget_frame_id
msgq/visionipc/visionbuf.cc:73
Methodimport
msgq/visionipc/visionbuf_ion.cc:75
Methodinit
msgq/impl_msgq.cc:11
Methodinit_yuv
msgq/visionipc/visionbuf_ion.cc:92
Methodis_enabled
msgq/event.cc:135
Methodlistener
msgq/visionipc/visionipc_server.cc:73
Functionmsgq_wait_for_subscriber
msgq/msgq.cc:78
Methodpoll
msgq/impl_msgq.cc:158
Functionpoller
()
msgq/tests/test_poller.py:7
Functionpub_sock
(endpoint: str, segment_size: int = 0)
msgq/__init__.py:42
Functionpyx_scan
(node, env, path, arg=None)
site_scons/site_tools/cython.py:11
Methodreceive
msgq/impl_fake.h:55
Methodrecv_called
msgq/event.cc:143
next →1–100 of 153, ranked by callers