| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| D | gpu_event_mgr_test.cc | 39 size_t queue_size() { in queue_size() function in tensorflow::TEST_EventMgrHelper
55 while (queue_size() > 0) { in PollEvents()
103 EXPECT_EQ(0, th.queue_size()); in TEST()
120 EXPECT_EQ(0, th.queue_size()); in TEST()
129 EXPECT_EQ(i + 1, th.queue_size()); in TEST()
133 EXPECT_EQ(0, th.queue_size()); in TEST()
140 EXPECT_EQ(i + 1, th.queue_size()); in TEST()
144 EXPECT_EQ(0, th.queue_size()); in TEST()
233 EXPECT_EQ(0, th.queue_size()); in TEST()
242 EXPECT_EQ(1 + i, th.queue_size()); in TEST()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | fifo_queue.cc | 168 const int64 queue_size = queues_[0].size(); in TryDequeue()
169 if (closed_ && queue_size == 0) { in TryDequeue()
173 queue_size, ")")); in TryDequeue()
176 if (queue_size > 0) { in TryDequeue()
260 int64 queue_size = queues_[0].size(); in TryDequeueMany()
262 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
288 queue_size = queues_[0].size(); in TryDequeueMany()
290 attempt->elements_requested = queue_size; in TryDequeueMany()
303 queue_size, ")")); in TryDequeueMany()
310 for (; queue_size > 0; --queue_size) { in TryDequeueMany()
|
| D | random_shuffle_queue_op.cc | 246 int32 queue_size = queues_[0].size(); in TryDequeue()
247 if (closed_ && queue_size == 0) { in TryDequeue()
251 queue_size, ")")); in TryDequeue()
254 if (!closed_) queue_size -= min_after_dequeue_; in TryDequeue()
255 if (queue_size > 0) { in TryDequeue()
339 int32 queue_size = queues_[0].size(); in TryDequeueMany()
340 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
365 queue_size = queues_[0].size(); in TryDequeueMany()
367 attempt->elements_requested = queue_size; in TryDequeueMany()
380 queue_size, ")")); in TryDequeueMany()
[all …]
|
| D | padding_fifo_queue.cc | 102 int32 queue_size = queues_[0].size(); in TryDequeueMany()
103 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
126 queue_size = queues_[0].size(); in TryDequeueMany()
128 attempt->elements_requested = queue_size; in TryDequeueMany()
141 queue_size, ")")); in TryDequeueMany()
148 for (; queue_size > 0; --queue_size) { in TryDequeueMany()
|
| /external/libkmsxx/kms++util/src/ |
| D | videodevice.cpp | 99 static void v4l2_request_bufs(int fd, uint32_t queue_size, uint32_t buf_type) in v4l2_request_bufs() argument
104 v4lreqbuf.count = queue_size; in v4l2_request_bufs()
107 ASSERT(v4lreqbuf.count == queue_size); in v4l2_request_bufs()
417 void VideoStreamer::set_queue_size(uint32_t queue_size) in set_queue_size() argument
419 v4l2_request_bufs(m_fd, queue_size, get_buf_type(m_type)); in set_queue_size()
420 m_fbs.resize(queue_size); in set_queue_size()
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | matching_files_dataset_op.cc | 242 int64 queue_size; in RestoreInternal() local
244 reader->ReadScalar(full_name("queue_size"), &queue_size)); in RestoreInternal()
245 for (int i = 0; i < queue_size; i++) { in RestoreInternal()
|
| /external/kernel-headers/original/uapi/linux/ |
| D | virtio_pci.h | 148 __le16 queue_size; /* read-write, power of 2. */ member
|
| /external/libkmsxx/kms++util/inc/kms++util/ |
| D | videodevice.h | 74 void set_queue_size(uint32_t queue_size);
|
| /external/webrtc/webrtc/video/ |
| D | video_loopback.cc | 111 DEFINE_int32(queue_size, 0, "Size of the bottleneck link queue in packets.");
|
| D | screenshare_loopback.cc | 109 DEFINE_int32(queue_size, 0, "Size of the bottleneck link queue in packets.");
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | process.py | 539 queue_size = self._max_workers + EXTRA_QUEUED_CALLS
541 max_size=queue_size, ctx=self._mp_context,
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_queues.py | 277 queue_size = 1
279 q = asyncio.Queue(queue_size, loop=self.loop)
|
| /external/kernel-headers/original/uapi/sound/ |
| D | asound.h | 757 unsigned int queue_size; /* total size of queue (32-1024) */ member
|
| /external/tensorflow/tensorflow/python/kernel_tests/random/ |
| D | random_shuffle_queue_test.py | 1045 queue_size = self.evaluate(size_t)
1046 if queue_size == 4:
|
| /external/tensorflow/tensorflow/python/ops/ |
| D | data_flow_ops.py | 611 return gen_data_flow_ops.queue_size(self._queue_ref, name=name)
|