Home
last modified time | relevance | path

Searched refs:queue_size (Results 1 – 25 of 26) sorted by relevance

12

/external/crosvm/devices/src/virtio/
Dqueue.rs52 queue_size: u16, field
76 queue_size: u16, in checked_new()
79 if index >= queue_size { in checked_new()
98 queue_size, in checked_new()
99 ttl: queue_size, in checked_new()
122 } else if self.has_next() && self.next >= self.queue_size { in is_valid()
156 DescriptorChain::checked_new(self.mem, self.desc_table, self.queue_size, self.next).map( in next_descriptor()
234 let queue_size = self.actual_size() as usize; in is_valid() localVariable
236 let desc_table_size = 16 * queue_size; in is_valid()
238 let avail_ring_size = 6 + 2 * queue_size; in is_valid()
[all …]
/external/tensorflow/tensorflow/core/kernels/
Dfifo_queue.cc168 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()
Drandom_shuffle_queue_op.cc246 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 …]
Dpadding_fifo_queue.cc102 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/crosvm/vhost/src/
Dlib.rs183 queue_size: u16, in is_valid()
188 let desc_table_size = 16 * queue_size as usize; in is_valid()
189 let avail_ring_size = 6 + 2 * queue_size as usize; in is_valid()
190 let used_ring_size = 6 + 8 * queue_size as usize; in is_valid()
191 if queue_size > queue_max_size || queue_size == 0 || (queue_size & (queue_size - 1)) != 0 { in is_valid()
227 queue_size: u16, in set_vring_addr()
237 if !self.is_valid(queue_max_size, queue_size, desc_addr, used_addr, avail_addr) { in set_vring_addr()
/external/libgav1/libgav1/src/
Dresidual_buffer_pool.cc97 const int queue_size = kMaxQueueSize[static_cast<int>(use_128x128_superblock)] in Reset() local
99 if (buffer_size == buffer_size_ && queue_size == queue_size_) { in Reset()
104 queue_size_ = queue_size; in Reset()
Dresidual_buffer_pool.h102 int queue_size) { in Create() argument
107 !buffer->transform_parameters_.Init(queue_size)) { in Create()
/external/tensorflow/tensorflow/core/common_runtime/gpu/
Dgpu_event_mgr_test.cc56 size_t queue_size() { in queue_size() function in tensorflow::TEST_EventMgrHelper
72 while (queue_size() > 0) { in PollEvents()
120 EXPECT_EQ(0, th.queue_size()); in TEST()
137 EXPECT_EQ(0, th.queue_size()); in TEST()
146 EXPECT_EQ(i + 1, th.queue_size()); in TEST()
150 EXPECT_EQ(0, th.queue_size()); in TEST()
157 EXPECT_EQ(i + 1, th.queue_size()); in TEST()
161 EXPECT_EQ(0, th.queue_size()); in TEST()
250 EXPECT_EQ(0, th.queue_size()); in TEST()
259 EXPECT_EQ(1 + i, th.queue_size()); in TEST()
/external/libkmsxx/kms++util/src/
Dvideodevice.cpp156 static void v4l2_request_bufs(int fd, uint32_t queue_size, uint32_t buf_type) in v4l2_request_bufs() argument
161 v4lreqbuf.count = queue_size; in v4l2_request_bufs()
164 ASSERT(v4lreqbuf.count == queue_size); in v4l2_request_bufs()
484 void VideoStreamer::set_queue_size(uint32_t queue_size) in set_queue_size() argument
486 v4l2_request_bufs(m_fd, queue_size, get_buf_type(m_type)); in set_queue_size()
487 m_fbs.resize(queue_size); in set_queue_size()
/external/arm-trusted-firmware/plat/nvidia/tegra/common/drivers/bpmp_ipc/
Divc.c556 size_t tegra_ivc_total_queue_size(size_t queue_size) in tegra_ivc_total_queue_size() argument
558 if ((queue_size & (IVC_ALIGN - 1U)) != 0U) { in tegra_ivc_total_queue_size()
560 (int32_t)queue_size, IVC_ALIGN); in tegra_ivc_total_queue_size()
563 return queue_size + sizeof(struct ivc_channel_header); in tegra_ivc_total_queue_size()
Divc.h37 size_t tegra_ivc_total_queue_size(size_t queue_size);
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Dmatching_files_dataset_op.cc249 int64 queue_size; in RestoreInternal() local
251 reader->ReadScalar(full_name("queue_size"), &queue_size)); in RestoreInternal()
252 for (int i = 0; i < queue_size; i++) { in RestoreInternal()
/external/arm-trusted-firmware/plat/marvell/common/mss/
Dmss_ipc_drv.h55 unsigned int queue_size; member
Dmss_ipc_drv.c41 mv_pm_ipc_queue_size = ipc_control->queue_size; in mv_pm_ipc_init()
/external/kernel-headers/original/uapi/linux/
Dvirtio_pci.h148 __le16 queue_size; /* read-write, power of 2. */ member
/external/u-boot/drivers/virtio/
Dvirtio_pci.h122 __le16 queue_size; /* read-write, power of 2 */ member
Dvirtio_pci_modern.c273 num = ioread16(&cfg->queue_size); in virtio_pci_setup_vq()
290 iowrite16(virtqueue_get_vring_size(vq), &cfg->queue_size); in virtio_pci_setup_vq()
/external/tensorflow/tensorflow/core/distributed_runtime/eager/
Dremote_execute_node.cc37 ops.reserve(request_->queue_size()); in RunAsync()
/external/libkmsxx/kms++util/inc/kms++util/
Dvideodevice.h76 void set_queue_size(uint32_t queue_size);
/external/webrtc/webrtc/video/
Dvideo_loopback.cc111 DEFINE_int32(queue_size, 0, "Size of the bottleneck link queue in packets.");
Dscreenshare_loopback.cc109 DEFINE_int32(queue_size, 0, "Size of the bottleneck link queue in packets.");
/external/python/cpython3/Lib/concurrent/futures/
Dprocess.py554 queue_size = self._max_workers + EXTRA_QUEUED_CALLS
556 max_size=queue_size, ctx=self._mp_context,
/external/python/cpython3/Lib/test/test_asyncio/
Dtest_queues.py298 queue_size = 1
302 q = asyncio.Queue(queue_size, loop=self.loop)
/external/kernel-headers/original/uapi/sound/
Dasound.h758 unsigned int queue_size; /* total size of queue (32-1024) */ member
/external/tensorflow/tensorflow/python/kernel_tests/random/
Drandom_shuffle_queue_test.py1049 queue_size = self.evaluate(size_t)
1050 if queue_size == 4:

12