/external/crosvm/devices/src/virtio/ |
D | queue.rs | 52 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/ |
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/crosvm/vhost/src/ |
D | lib.rs | 183 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/ |
D | residual_buffer_pool.cc | 97 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()
|
D | residual_buffer_pool.h | 102 int queue_size) { in Create() argument 107 !buffer->transform_parameters_.Init(queue_size)) { in Create()
|
/external/tensorflow/tensorflow/core/common_runtime/gpu/ |
D | gpu_event_mgr_test.cc | 56 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/ |
D | videodevice.cpp | 156 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/ |
D | ivc.c | 556 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()
|
D | ivc.h | 37 size_t tegra_ivc_total_queue_size(size_t queue_size);
|
/external/tensorflow/tensorflow/core/kernels/data/experimental/ |
D | matching_files_dataset_op.cc | 249 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/ |
D | mss_ipc_drv.h | 55 unsigned int queue_size; member
|
D | mss_ipc_drv.c | 41 mv_pm_ipc_queue_size = ipc_control->queue_size; in mv_pm_ipc_init()
|
/external/kernel-headers/original/uapi/linux/ |
D | virtio_pci.h | 148 __le16 queue_size; /* read-write, power of 2. */ member
|
/external/u-boot/drivers/virtio/ |
D | virtio_pci.h | 122 __le16 queue_size; /* read-write, power of 2 */ member
|
D | virtio_pci_modern.c | 273 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/ |
D | remote_execute_node.cc | 37 ops.reserve(request_->queue_size()); in RunAsync()
|
/external/libkmsxx/kms++util/inc/kms++util/ |
D | videodevice.h | 76 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 | 554 queue_size = self._max_workers + EXTRA_QUEUED_CALLS 556 max_size=queue_size, ctx=self._mp_context,
|
/external/python/cpython3/Lib/test/test_asyncio/ |
D | test_queues.py | 298 queue_size = 1 302 q = asyncio.Queue(queue_size, loop=self.loop)
|
/external/kernel-headers/original/uapi/sound/ |
D | asound.h | 758 unsigned int queue_size; /* total size of queue (32-1024) */ member
|
/external/tensorflow/tensorflow/python/kernel_tests/random/ |
D | random_shuffle_queue_test.py | 1049 queue_size = self.evaluate(size_t) 1050 if queue_size == 4:
|