| /external/rust/crates/vmm_vhost/src/vhost_kern/ |
| D | mod.rs | 50 let queue_size = config_data.queue_size; in is_valid() localVariable
51 if queue_size > config_data.queue_max_size in is_valid()
52 || queue_size == 0 in is_valid()
53 || (queue_size & (queue_size - 1)) != 0 in is_valid()
59 let desc_table_size = 16 * u64::from(queue_size) as GuestUsize; in is_valid()
60 let avail_ring_size = 6 + 2 * u64::from(queue_size) as GuestUsize; in is_valid()
61 let used_ring_size = 6 + 8 * u64::from(queue_size) as GuestUsize; in is_valid()
|
| D | vsock.rs | 107 queue_size: 32, in test_vsock_is_valid()
116 config.queue_size = 0; in test_vsock_is_valid()
118 config.queue_size = 31; in test_vsock_is_valid()
120 config.queue_size = 33; in test_vsock_is_valid()
167 queue_size: 32, in test_vsock_ioctls()
|
| /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 | 247 int32 queue_size = queues_[0].size(); in TryDequeue()
248 if (closed_ && queue_size == 0) { in TryDequeue()
252 queue_size, ")")); in TryDequeue()
255 if (!closed_) queue_size -= min_after_dequeue_; in TryDequeue()
256 if (queue_size > 0) { in TryDequeue()
340 int32 queue_size = queues_[0].size(); in TryDequeueMany()
341 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
366 queue_size = queues_[0].size(); in TryDequeueMany()
368 attempt->elements_requested = queue_size; in TryDequeueMany()
381 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/crosvm/devices/src/virtio/ |
| D | queue.rs | 61 queue_size: u16, field
85 queue_size: u16, in checked_new()
89 if index >= queue_size { in checked_new()
103 queue_size, in checked_new()
104 ttl: queue_size, in checked_new()
128 } else if self.has_next() && self.next >= self.queue_size { in is_valid()
167 self.queue_size, in next_descriptor()
277 let queue_size = self.actual_size() as usize; in is_valid() localVariable
279 let desc_table_size = 16 * queue_size; in is_valid()
281 let avail_ring_size = 6 + 2 * queue_size; in is_valid()
[all …]
|
| /external/crosvm/fuzz/ |
| D | virtqueue_fuzzer.rs | 79 let queue_size = q.size as usize; localVariable
80 let mut buf = vec![0u8; queue_size * size_of::<virtq_desc>()];
87 let avail_size = 4 + (queue_size * 2) + 2;
94 let used_size = 4 + (queue_size * size_of::<virtq_used_elem>()) + 2;
|
| /external/libgav1/libgav1/src/ |
| D | residual_buffer_pool.h | 40 int queue_size) { in Create() argument
45 !buffer->transform_parameters_.Init(queue_size) || in Create()
46 !buffer->partition_tree_order_.Init(queue_size)) { in Create()
|
| 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()
|
| /external/webrtc/modules/pacing/ |
| D | task_queue_paced_sender.h | 112 queue_size(DataSize::Zero()), in Stats()
115 DataSize queue_size; member
|
| D | task_queue_paced_sender.cc | 179 return GetStats().queue_size; in QueueSizeData()
264 new_stats.queue_size = pacing_controller_.QueueSizeData(); in MaybeUpdateStats()
|
| /external/libkmsxx/kms++util/src/ |
| D | videodevice.cpp | 178 static void v4l2_request_bufs(int fd, uint32_t queue_size, uint32_t buf_type) in v4l2_request_bufs() argument
183 v4lreqbuf.count = queue_size; in v4l2_request_bufs()
186 ASSERT(v4lreqbuf.count == queue_size); in v4l2_request_bufs()
508 void VideoStreamer::set_queue_size(uint32_t queue_size) in set_queue_size() argument
510 v4l2_request_bufs(m_fd, queue_size, get_buf_type(m_type)); in set_queue_size()
511 m_fbs.resize(queue_size); in set_queue_size()
|
| /external/arm-trusted-firmware/plat/nvidia/tegra/drivers/bpmp_ipc/ |
| D | ivc.c | 557 size_t tegra_ivc_total_queue_size(size_t queue_size) in tegra_ivc_total_queue_size() argument
559 if ((queue_size & (IVC_ALIGN - 1U)) != 0U) { in tegra_ivc_total_queue_size()
561 (int32_t)queue_size, IVC_ALIGN); in tegra_ivc_total_queue_size()
564 return queue_size + sizeof(struct ivc_channel_header); in tegra_ivc_total_queue_size()
|
| D | ivc.h | 36 size_t tegra_ivc_total_queue_size(size_t queue_size);
|
| /external/crosvm/devices/src/virtio/vhost/user/ |
| D | handler.rs | 64 pub fn queue_sizes(&mut self, queue_size: u16, default_queues_num: usize) -> Result<Vec<u16>> { in queue_sizes()
73 Ok(vec![queue_size; queues_num]) in queue_sizes()
155 queue_size: queue.actual_size(), in activate_vring()
|
| /external/webrtc/call/ |
| D | simulated_network.cc | 33 DataSize queue_size) { in DropDequeuedPacket() argument
42 if (queue_size < kMaxPacketSize || queuing_time < kDelayThreshold) { in DropDequeuedPacket()
72 if (queue_size - packet_size < kMaxPacketSize) in DropDequeuedPacket()
|
| D | simulated_network.h | 43 DataSize queue_size);
|
| /external/rust/crates/rayon-core/src/ |
| D | log.rs | 410 for ((i, state), queue_size) in (0..).zip(&self.thread_states).zip(&self.local_queue_size) { in dump()
413 if *queue_size > 0 { in dump()
414 write!(w, ",{:03},", queue_size)?; in dump()
|
| /external/tensorflow/tensorflow/core/kernels/data/experimental/ |
| D | matching_files_dataset_op.cc | 256 int64 queue_size; in RestoreInternal() local
258 reader->ReadScalar(full_name("queue_size"), &queue_size)); in RestoreInternal()
259 for (int i = 0; i < queue_size; i++) { in RestoreInternal()
|
| /external/arm-trusted-firmware/plat/marvell/armada/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/rust/crates/vmm_vhost/src/ |
| D | backend.rs | 28 pub queue_size: u16, field
461 queue_size: 0x2000, in test_vring_backend_mut()
483 queue_size: 0x2000, in test_vring_config_data()
|
| /external/kernel-headers/original/uapi/linux/ |
| D | virtio_pci.h | 157 __le16 queue_size; /* read-write, power of 2. */ member
|
| /external/libkmsxx/kms++util/inc/kms++util/ |
| D | videodevice.h | 76 void set_queue_size(uint32_t queue_size);
|