Home
last modified time | relevance | path

Searched defs:Queue (Results 1 – 25 of 181) sorted by relevance

12345678

/external/cronet/third_party/abseil-cpp/absl/strings/internal/
Dcordz_handle.h84 struct Queue { struct
85 constexpr explicit Queue(absl::ConstInitType) in Queue() argument
111 ABSL_CONST_INIT static Queue global_queue_; argument
/external/abseil-cpp/absl/strings/internal/
Dcordz_handle.h84 struct Queue { struct
85 constexpr explicit Queue(absl::ConstInitType) in Queue() argument
111 ABSL_CONST_INIT static Queue global_queue_; argument
/external/webrtc/third_party/abseil-cpp/absl/strings/internal/
Dcordz_handle.h84 struct Queue { struct
85 constexpr explicit Queue(absl::ConstInitType) in Queue() argument
111 ABSL_CONST_INIT static Queue global_queue_; argument
/external/tensorflow/third_party/absl/abseil-cpp/absl/strings/internal/
Dcordz_handle.h84 struct Queue { struct
85 constexpr explicit Queue(absl::ConstInitType) in Queue() argument
111 ABSL_CONST_INIT static Queue global_queue_; argument
/external/licenseclassifier/stringclassifier/internal/pq/
Dpriority.go38 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) {
/external/rust/crates/futures-channel/src/mpsc/
Dqueue.rs72 pub(super) struct Queue<T> { struct
77 unsafe impl<T: Send> Send for Queue<T> {} argument
78 unsafe impl<T: Send> Sync for Queue<T> {} implementation
86 impl<T> Queue<T> { impl
163 impl<T> Drop for Queue<T> { implementation
/external/rust/crates/crossbeam-epoch/src/sync/
Dqueue.rs22 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> { implementation
204 impl<T> Drop for Queue<T> { implementation
224 struct Queue<T> { struct
225 queue: super::Queue<T>,
228 impl<T> Queue<T> { implementation
/external/crosvm/devices/src/virtio/
Dqueue.rs299 pub struct Queue { struct
301 activated: bool,
304 max_size: u16,
309 size: u16,
312 ready: bool,
315 vector: u16,
318 desc_table: GuestAddress,
321 avail_ring: GuestAddress,
324 used_ring: GuestAddress,
326 pub next_avail: Wrapping<u16>,
[all …]
Dvirtio_pci_common_config.rs48 queues: &mut [Queue], in read()
76 queues: &mut [Queue], in write()
136 fn write_common_config_word(&mut self, offset: u64, value: u16, queues: &mut [Queue]) { in write_common_config_word()
170 queues: &mut [Queue], in write_common_config_dword()
217 fn write_common_config_qword(&mut self, offset: u64, value: u64, queues: &mut [Queue]) { in write_common_config_qword()
228 fn with_queue<U, F>(&self, queues: &[Queue], f: F) -> Option<U> in with_queue()
235 fn with_queue_mut<F: FnOnce(&mut Queue)>(&self, queues: &mut [Queue], f: F) { in with_queue_mut()
269 _queues: Vec<(Queue, Event)>, in activate()
Dballoon.rs348 mut queue: Queue, in handle_queue()
399 mut queue: Queue, in handle_reporting_queue()
444 mut queue: Queue, in handle_stats_queue()
558 mut queue: Queue, in handle_events_queue()
584 mut queue: Queue, in handle_wss_queue()
673 mut queue: Queue, in handle_wss_data_queue()
737 queue: &mut Queue,
758 queue: &mut Queue, in send_initial_wss_config()
876 inflate_queue: (Queue, Event), in run_worker()
877 deflate_queue: (Queue, Event), in run_worker()
[all …]
/external/deqp/external/vulkancts/modules/vulkan/sparse_resources/
DvktSparseResourcesBase.hpp42 struct Queue struct
44 vk::VkQueue queueHandle;
45 deUint32 queueFamilyIndex;
46 deUint32 queueIndex;
/external/angle/third_party/abseil-cpp/absl/strings/internal/
Dcordz_handle.cc27 struct Queue { struct
30 absl::Mutex mutex;
31 std::atomic<CordzHandle*> dq_tail ABSL_GUARDED_BY(mutex){nullptr}; in ABSL_GUARDED_BY()
41 bool IsEmpty() const ABSL_NO_THREAD_SAFETY_ANALYSIS { in IsEmpty()
/external/rust/crates/vulkano/src/command_buffer/
Dtraits.rs52 queue: &Queue, in lock_submit()
83 queue: Arc<Queue>, in execute()
118 queue: Arc<Queue>, in execute_after()
148 queue: &Queue, in check_buffer_access()
156 queue: &Queue, in check_image_access()
174 queue: &Queue, in lock_submit()
189 queue: &Queue, in check_buffer_access()
200 queue: &Queue, in check_image_access()
402 fn queue(&self) -> Option<Arc<Queue>> { in queue()
411 queue: &Queue, in check_buffer_access()
[all …]
/external/perfetto/src/trace_processor/sorter/
Dtrace_sorter.h253 struct Queue { struct
254 void Append(int64_t ts, in Append()
291 base::CircularQueue<TimestampedEvent> events_; argument
300 inline Queue* GetQueue(size_t index) { in GetQueue() argument
/external/crosvm/devices/src/virtio/vsock/sys/windows/
Dvsock.rs193 mut queues: Vec<(Queue, Event)>, in activate()
328 recv_queue: Arc<Mutex<Queue>>, in process_rx_queue()
515 mut queue: Queue, in process_tx_queue()
776 send_queue: &Arc<Mutex<Queue>>, in process_tx_packets()
846 send_queue: &Arc<Mutex<Queue>>, in process_tx_packets_for_port()
871 send_queue: &Arc<Mutex<Queue>>, in handle_tx_packet()
1038 send_queue: &Arc<Mutex<Queue>>, in send_vsock_credit_update()
1080 send_queue: &Arc<Mutex<Queue>>, in send_vsock_reset()
1118 queue: &mut Queue, in get_next_writer()
1139 queue: &mut Queue, in write_bytes_to_queue()
[all …]
/external/cronet/third_party/boringssl/src/third_party/googletest/samples/
Dsample3-inl.h42 class Queue; variable
48 friend class Queue<E>; variable
76 Queue() : head_(nullptr), last_(nullptr), size_(0) {} in Queue() function
/external/cronet/third_party/googletest/src/googletest/samples/
Dsample3-inl.h41 class Queue; variable
47 friend class Queue<E>; variable
75 Queue() : head_(nullptr), last_(nullptr), size_(0) {} in Queue() function
/external/rust/crates/quiche/deps/boringssl/src/third_party/googletest/samples/
Dsample3-inl.h42 class Queue; variable
48 friend class Queue<E>; variable
76 Queue() : head_(nullptr), last_(nullptr), size_(0) {} in Queue() function
/external/googletest/googletest/samples/
Dsample3-inl.h42 class Queue; variable
48 friend class Queue<E>; variable
76 Queue() : head_(nullptr), last_(nullptr), size_(0) {} in Queue() function
/external/rust/crates/vulkano/src/device/
Dmod.rs725 fn next(&mut self) -> Option<Arc<Queue>> { in next()
865 pub struct Queue { struct
866 queue: Mutex<ash::vk::Queue>, argument
872 impl Queue { argument
916 impl PartialEq for Queue { implementation
922 impl Eq for Queue {} implementation
924 unsafe impl DeviceOwned for Queue { implementation
930 unsafe impl SynchronizedVulkanObject for Queue { implementation
934 fn internal_object_guard(&self) -> MutexGuard<ash::vk::Queue> { in internal_object_guard()
/external/rust/crates/vulkano/src/sync/future/
Dmod.rs102 fn queue(&self) -> Option<Arc<Queue>>; in queue()
120 queue: &Queue, in check_buffer_access()
142 queue: &Queue, in check_image_access()
162 queue: Arc<Queue>, in then_execute()
258 queue: Arc<Queue>, in then_swapchain_present()
274 queue: Arc<Queue>, in then_swapchain_present_incremental()
326 fn queue(&self) -> Option<Arc<Queue>> { in queue()
335 queue: &Queue, in check_buffer_access()
346 queue: &Queue, in check_image_access()
Dnow.rs59 fn queue(&self) -> Option<Arc<Queue>> { in queue()
68 _: &Queue, in check_buffer_access()
79 _: &Queue, in check_image_access()
Dfence_signal.rs375 fn queue(&self) -> Option<Arc<Queue>> { in queue()
389 queue: &Queue, in check_buffer_access()
405 queue: &Queue, in check_image_access()
492 fn queue(&self) -> Option<Arc<Queue>> { in queue()
501 queue: &Queue, in check_buffer_access()
512 queue: &Queue, in check_image_access()
Dsemaphore_signal.rs143 fn queue(&self) -> Option<Arc<Queue>> { in queue()
152 queue: &Queue, in check_buffer_access()
165 queue: &Queue, in check_image_access()
/external/crosvm/devices/src/virtio/snd/vios_backend/
Dworker.rs53 control_queue: Arc<Mutex<Queue>>, in try_new()
55 event_queue: Queue, in try_new()
57 tx_queue: Arc<Mutex<Queue>>, in try_new()
59 rx_queue: Arc<Mutex<Queue>>, in try_new()
543 tx_queue: Arc<Mutex<Queue>>, in io_loop()
545 rx_queue: Arc<Mutex<Queue>>, in io_loop()
614 queue: &Arc<Mutex<Queue>>, in lock_pop_unlock()

12345678