| /aosp_15_r20/external/rust/crates/v4l2r/lib/src/device/ |
| D | queue.rs | 68 pub struct Queue<D, S> struct
73 inner: QueueBase, argument
78 /// Methods of `Queue` that are available no matter the state. argument
79 impl<D, S> Queue<D, S> impl
213 impl<D: Direction> Queue<D, QueueInit> { impl
308 impl Queue<Output, QueueInit> { impl
326 impl Queue<Capture, QueueInit> { impl
355 impl<D: Direction, P: BufferHandles> Queue<D, BuffersAllocated<P>> { impl
422 impl<'a, D: Direction, P: BufferHandles + 'a> AllocatedQueue<'a, D> implementation
467 impl<D: Direction, P: BufferHandles> Stream for Queue<D, BuffersAllocated<P>> { implementation
[all …]
|
| /aosp_15_r20/external/mesa3d/src/gallium/frontends/rusticl/core/ |
| H A D | queue.rs | 84 pub struct Queue { struct
90 state: Mutex<QueueState>, argument
94 impl_cl_type_trait!(cl_command_queue, Queue, CL_INVALID_COMMAND_QUEUE); argument
103 impl Queue { implementation
109 ) -> CLResult<Arc<Queue>> { in new()
258 impl Drop for Queue { implementation
|
| H A D | memory.rs | 157 pub fn sync_unmap(&self, q: &Queue, ctx: &PipeContext, ptr: MutMemoryPtr) -> CLResult<()> { in sync_unmap()
785 q: &Queue, in copy_rect()
824 q: &Queue, in copy_to_buffer()
853 q: &Queue, in copy_to_image()
912 q: &Queue, in fill()
949 q: &Queue, in read()
970 q: &Queue, in read_rect()
1003 pub fn sync_map(&self, q: &Queue, ctx: &PipeContext, ptr: MutMemoryPtr) -> CLResult<()> { in sync_map()
1017 pub fn sync_unmap(&self, q: &Queue, ctx: &PipeContext, ptr: MutMemoryPtr) -> CLResult<()> { in sync_unmap()
1044 q: &Queue, in tx()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-epoch/src/sync/ |
| D | queue.rs | 22 pub(crate) struct Queue<T> { struct
40 unsafe impl<T: Send> Sync for Queue<T> {} implementation
41 unsafe impl<T: Send> Send for Queue<T> {} implementation
43 impl<T> Queue<T> { impl
203 impl<T> Drop for Queue<T> { implementation
223 struct Queue<T> { struct
224 queue: super::Queue<T>,
227 impl<T> Queue<T> { impl
|
| /aosp_15_r20/external/licenseclassifier/stringclassifier/internal/pq/ |
| H A D | priority.go | 38 type Queue struct { struct
39 heap pqHeap
43 func (pq *Queue) Len() int {
48 func (pq *Queue) Push(x interface{}) {
54 func (pq *Queue) Min() interface{} {
60 func (pq *Queue) Pop() interface{} {
65 func (pq *Queue) Fix(index int) {
70 func (pq *Queue) Remove(index int) {
|
| /aosp_15_r20/external/rust/android-crates-io/crates/futures-channel/src/mpsc/ |
| D | queue.rs | 73 pub(super) struct Queue<T> { struct
78 unsafe impl<T: Send> Send for Queue<T> {} argument
79 unsafe impl<T: Send> Sync for Queue<T> {} implementation
87 impl<T> Queue<T> { implementation
166 impl<T> Drop for Queue<T> { implementation
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/vsock/sys/windows/ |
| H A D | vsock.rs | 272 mut queues: BTreeMap<usize, Queue>, in activate() argument
291 fn virtio_sleep(&mut self) -> anyhow::Result<Option<BTreeMap<usize, Queue>>> { in virtio_sleep() argument
310 queues_state: Option<(GuestMemory, Interrupt, BTreeMap<usize, Queue>)>, in virtio_wake() argument
465 recv_queue: Arc<RwLock<Queue>>, in process_rx_queue()
673 mut queue: Queue, in process_tx_queue()
677 ) -> Result<Queue> { in process_tx_queue()
955 send_queue: &Arc<RwLock<Queue>>, in process_tx_packets()
1041 send_queue: &Arc<RwLock<Queue>>, in process_tx_packets_for_port()
1066 send_queue: &Arc<RwLock<Queue>>, in handle_tx_packet()
1249 send_queue: &Arc<RwLock<Queue>>, in send_vsock_credit_update()
[all …]
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/ |
| H A D | balloon.rs | 347 mut queue: Queue, in handle_queue()
399 mut queue: Queue, in handle_reporting_queue()
448 mut queue: Queue, in handle_stats_queue()
455 ) -> Queue { in handle_stats_queue()
539 mut queue: Queue, in handle_ws_op_queue()
544 ) -> Result<Queue> { in handle_ws_op_queue()
635 mut queue: Queue, in handle_ws_data_queue()
641 ) -> Result<Queue> { in handle_ws_data_queue()
792 fn new(inflate: Queue, deflate: Queue) -> Self { in new()
815 fn new(inflate: Queue, deflate: Queue) -> Self { in new()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/virtio-queue/src/ |
| D | queue.rs | 80 pub struct Queue { struct
82 max_size: u16,
85 next_avail: Wrapping<u16>,
88 next_used: Wrapping<u16>,
113 impl Queue { implementation
274 impl<'a> QueueGuard<'a> for Queue { implementation
278 impl QueueT for Queue { implementation
608 impl QueueOwnedT for Queue { implementation
|
| /aosp_15_r20/external/webrtc/third_party/abseil-cpp/absl/strings/internal/ |
| H A D | cordz_handle.h | 84 struct Queue { struct
85 constexpr explicit Queue(absl::ConstInitType) in Queue() argument
111 ABSL_CONST_INIT static Queue global_queue_; argument
|
| /aosp_15_r20/external/private-join-and-compute/third_party/abseil-cpp-20230125.2/absl/strings/internal/ |
| H A D | cordz_handle.h | 84 struct Queue { struct
85 constexpr explicit Queue(absl::ConstInitType) in Queue() argument
111 ABSL_CONST_INIT static Queue global_queue_; argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/internal/ |
| D | cordz_handle.h | 84 struct Queue { struct
85 constexpr explicit Queue(absl::ConstInitType) in Queue() argument
111 ABSL_CONST_INIT static Queue global_queue_; argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/vulkano/src/device/ |
| D | queue.rs | 48 pub struct Queue { struct
49 handle: ash::vk::Queue, argument
54 state: Mutex<QueueState>, argument
57 impl Queue { argument
62 handle: ash::vk::Queue, in from_handle()
104 impl Drop for Queue { implementation
112 unsafe impl VulkanObject for Queue { implementation
121 unsafe impl DeviceOwned for Queue { implementation
128 impl PartialEq for Queue { implementation
137 impl Eq for Queue {} implementation
[all …]
|
| /aosp_15_r20/prebuilts/go/linux-x86/src/cmd/go/internal/par/ |
| D | queue.go | 11 type Queue struct { struct
12 maxActive int
13 st chan queueState
42 func (q *Queue) Add(f func()) {
76 func (q *Queue) Idle() <-chan struct{} {
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/vhost/user/device/ |
| H A D | net.rs | 49 mut queue: Queue, in run_tx_queue()
53 ) -> Queue { in run_tx_queue()
76 mut queue: Queue, in run_ctrl_queue()
82 ) -> Queue { in run_ctrl_queue()
176 queue: virtio::Queue, in start_queue()
182 fn stop_queue(&mut self, idx: usize) -> anyhow::Result<virtio::Queue> { in stop_queue()
|
| /aosp_15_r20/external/executorch/backends/vulkan/runtime/vk_api/ |
| H A D | Adapter.h | 67 struct Queue { struct
70 VkQueueFlags capabilities; argument
71 VkQueue handle; argument
80 // Queue Management argument
|
| /aosp_15_r20/external/pytorch/aten/src/ATen/native/vulkan/api/ |
| H A D | Adapter.h | 99 struct Queue { struct
102 VkQueueFlags capabilities; argument
103 VkQueue handle; argument
112 // Queue Management argument
|
| /aosp_15_r20/external/rust/android-crates-io/crates/vulkano/src/sync/future/ |
| D | mod.rs | 187 fn queue(&self) -> Option<Arc<Queue>>; in queue()
203 queue: &Queue, in check_buffer_access()
223 queue: &Queue, in check_image_access()
253 queue: Arc<Queue>, in then_execute()
350 queue: Arc<Queue>, in then_swapchain_present()
429 fn queue(&self) -> Option<Arc<Queue>> { in queue()
438 queue: &Queue, in check_buffer_access()
449 queue: &Queue, in check_image_access()
|
| /aosp_15_r20/external/perfetto/src/trace_processor/sorter/ |
| H A D | trace_sorter.h | 440 struct Queue { struct
441 void Append(int64_t ts, in Append()
480 base::CircularQueue<TimestampedEvent> events_; argument
489 Queue* GetQueue(size_t index, argument
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/snd/vios_backend/ |
| H A D | worker.rs | 51 control_queue: Arc<Mutex<Queue>>, in try_new()
52 event_queue: Queue, in try_new()
53 tx_queue: Arc<Mutex<Queue>>, in try_new()
54 rx_queue: Arc<Mutex<Queue>>, in try_new()
515 tx_queue: Arc<Mutex<Queue>>, in io_loop()
516 rx_queue: Arc<Mutex<Queue>>, in io_loop()
|
| /aosp_15_r20/external/crosvm/devices/src/virtio/snd/common_backend/ |
| H A D | mod.rs | 447 queues: BTreeMap<usize, Queue>, in activate() argument
488 fn virtio_sleep(&mut self) -> anyhow::Result<Option<BTreeMap<usize, Queue>>> { in virtio_sleep() argument
502 device_state: Option<(GuestMemory, Interrupt, BTreeMap<usize, Queue>)>, in virtio_wake() argument
572 queues: BTreeMap<usize, Queue>, in run_worker() argument
748 ctrl_queue: Rc<AsyncRwLock<Queue>>, in run_worker_once()
750 tx_queue: Rc<AsyncRwLock<Queue>>, in run_worker_once()
754 rx_queue: Rc<AsyncRwLock<Queue>>, in run_worker_once()
867 tx_queue: &Rc<AsyncRwLock<Queue>>, in reset_streams()
869 rx_queue: &Rc<AsyncRwLock<Queue>>, in reset_streams()
|
| /aosp_15_r20/external/swiftshader/third_party/llvm-16.0/llvm/lib/Support/ |
| H A D | OptimizedStructLayout.cpp | 276 for (auto &Queue : FlexibleFieldsByAlignment) { in performOptimizedStructLayout() local
295 auto spliceFromQueue = [&](AlignmentQueue *Queue, Field *Last, Field *Cur) { in performOptimizedStructLayout()
349 auto tryAddFillerFromQueue = [&](AlignmentQueue *Queue, uint64_t StartOffset, in performOptimizedStructLayout()
350 std::optional<uint64_t> EndOffset) -> bool { in performOptimizedStructLayout()
396 for (auto Queue = FirstQueueToSearch; Queue != QueueE; ++Queue) { in performOptimizedStructLayout() local
|
| /aosp_15_r20/frameworks/av/media/codec2/sfplugin/ |
| H A D | C2NodeImpl.cpp | 174 struct Queue { struct in android::C2NodeImpl::QueueThread
175 Queue(const std::shared_ptr<Codec2Client::Component> &comp) in Queue() function
180 std::weak_ptr<Codec2Client::Component> component;
181 std::list<WorkFence> workList;
182 nsecs_t lastQueuedTimestampNs;
|
| /aosp_15_r20/external/deqp/external/vulkancts/modules/vulkan/sparse_resources/ |
| H A D | vktSparseResourcesBase.hpp | 42 struct Queue struct
44 vk::VkQueue queueHandle;
45 uint32_t queueFamilyIndex;
46 uint32_t queueIndex;
|
| /aosp_15_r20/external/angle/third_party/abseil-cpp/absl/strings/internal/ |
| H A D | cordz_handle.cc | 28 struct Queue { struct
31 absl::Mutex mutex;
32 std::atomic<CordzHandle*> dq_tail ABSL_GUARDED_BY(mutex){nullptr}; in ABSL_GUARDED_BY()
42 bool IsEmpty() const ABSL_NO_THREAD_SAFETY_ANALYSIS { in IsEmpty()
|