Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/NVIDIA/DALI
/ _put_msgs
Function
_put_msgs
dali/test/python/test_external_source_parallel_shared_batch.py:108–113 ·
view source on GitHub ↗
(queue, msgs, one_by_one)
Source
from the content-addressed store, hash-verified
106
107
108
def
_put_msgs(queue, msgs, one_by_one):
109
if
not one_by_one:
110
queue.put(msgs)
111
else
:
112
for
msg in msgs:
113
queue.put([msg])
114
115
116
def
test_queue_full_assertion():
Callers
2
_test_queue_recv
Function · 0.85
_test_queue_large
Function · 0.85
Calls
1
put
Method · 0.45
Tested by
no test coverage detected