| /external/rust/crates/rayon/src/collections/ |
| D | vec_deque.rs | 5 use std::collections::VecDeque;
21 impl<T: Send> IntoParallelIterator for VecDeque<T> { implementation
51 impl<'a, T: Sync> IntoParallelIterator for &'a VecDeque<T> { implementation
74 impl<'a, T: Send> IntoParallelIterator for &'a mut VecDeque<T> { implementation
95 deque: &'a mut VecDeque<T>,
100 impl<'a, T: Send> ParallelDrainRange<usize> for &'a mut VecDeque<T> { implementation
|
| /external/crosvm/cros_async/src/ |
| D | queue.rs | 5 use std::collections::VecDeque;
13 runnables: Mutex<VecDeque<Runnable>>,
20 runnables: Mutex::new(VecDeque::new()), in new()
|
| /external/rust/crates/plotters/src/drawing/backend_impl/ |
| D | mocked.rs | 9 use std::collections::VecDeque;
30 check_draw_pixel: VecDeque<Box<dyn FnMut(RGBAColor, BackendCoord)>>,
31 check_draw_line: VecDeque<Box<dyn FnMut(RGBAColor, u32, BackendCoord, BackendCoord)>>,
32 check_draw_rect: VecDeque<Box<dyn FnMut(RGBAColor, u32, bool, BackendCoord, BackendCoord)>>,
33 check_draw_path: VecDeque<Box<dyn FnMut(RGBAColor, u32, Vec<BackendCoord>)>>,
34 check_draw_circle: VecDeque<Box<dyn FnMut(RGBAColor, u32, bool, BackendCoord, u32)>>,
35 check_draw_text: VecDeque<Box<dyn FnMut(RGBAColor, &str, f64, BackendCoord, &str)>>,
36 check_fill_polygon: VecDeque<Box<dyn FnMut(RGBAColor, Vec<BackendCoord>)>>,
|
| /external/rust/crates/itertools/src/ |
| D | peek_nth.rs | 3 use alloc::collections::VecDeque;
13 buf: VecDeque<I::Item>,
29 buf: VecDeque::new(), in peek_nth()
|
| D | tee.rs | 4 use alloc::collections::VecDeque;
10 backlog: VecDeque<A>,
31 let buffer = TeeBuffer{backlog: VecDeque::new(), iter, owner: false}; in new()
|
| D | multipeek_impl.rs | 2 use alloc::collections::VecDeque;
12 buf: VecDeque<I::Item>,
23 buf: VecDeque::new(), in multipeek()
|
| /external/rust/crates/quiche/src/ |
| D | dgram.rs | 30 use std::collections::VecDeque;
35 queue: VecDeque<Vec<u8>>,
43 queue: VecDeque::with_capacity(queue_max_len), in new()
|
| /external/rust/crates/tokio/tests/support/ |
| D | mock_pool.rs | 4 use std::collections::VecDeque;
11 static QUEUE: RefCell<VecDeque<Box<dyn FnOnce() + Send>>> = RefCell::new(VecDeque::new())
|
| D | mock_file.rs | 3 use std::collections::VecDeque;
21 calls: VecDeque<Call>,
140 calls: VecDeque::new(), in mock()
|
| /external/rust/crates/bytes/src/buf/ |
| D | vec_deque.rs | 1 use alloc::collections::VecDeque;
5 impl Buf for VecDeque<u8> { implementation
|
| /external/rust/crates/bytes/tests/ |
| D | test_buf.rs | 61 use std::collections::VecDeque; in test_vec_deque()
63 let mut buffer: VecDeque<u8> = VecDeque::new(); in test_vec_deque()
|
| /external/crosvm/devices/src/virtio/video/ |
| D | worker.rs | 7 use std::collections::VecDeque;
40 responses: &mut VecDeque<WritableResp>, in write_responses()
87 let mut responses: VecDeque<WritableResp> = Default::default(); in write_event_responses()
153 ) -> Result<VecDeque<WritableResp>> { in handle_command_desc()
154 let mut responses: VecDeque<WritableResp> = Default::default(); in handle_command_desc()
|
| /external/rust/crates/futures-util/benches/ |
| D | futures_unordered.rs | 11 use std::collections::VecDeque;
19 let mut txs = VecDeque::with_capacity(NUM); in oneshots()
|
| /external/rust/crates/tokio/src/task/ |
| D | local.rs | 7 use std::collections::VecDeque;
239 queue: VecDeque<task::Notified<Arc<Shared>>>,
245 queue: Mutex<VecDeque<task::Notified<Arc<Shared>>>>,
331 queue: VecDeque::with_capacity(INITIAL_CAPACITY), in new()
334 queue: Mutex::new(VecDeque::with_capacity(INITIAL_CAPACITY)), in new()
|
| /external/rust/crates/futures-util/src/sink/ |
| D | buffer.rs | 7 use alloc::collections::VecDeque;
16 buf: VecDeque<Item>,
27 buf: VecDeque::with_capacity(capacity), in new()
|
| /external/rust/crates/grpcio/src/ |
| D | cq.rs | 4 use std::collections::VecDeque;
145 pending_work: UnsafeCell<VecDeque<UnfinishedWork>>,
157 pending_work: UnsafeCell::new(VecDeque::with_capacity(QUEUE_CAPACITY)), in new()
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | task.rs | 5 use std::collections::VecDeque;
56 queue: VecDeque::new(), in with()
74 queue: VecDeque<task::Notified<Runtime>>,
|
| /external/rust/crates/tokio/src/runtime/ |
| D | basic_scheduler.rs | 11 use std::collections::VecDeque;
66 queue: VecDeque<task::Notified<Arc<Shared>>>,
88 queue: Mutex<VecDeque<Entry>>,
127 queue: Mutex::new(VecDeque::with_capacity(INITIAL_CAPACITY)), in new()
136 queue: VecDeque::with_capacity(INITIAL_CAPACITY), in new()
|
| /external/crosvm/gpu_display/src/ |
| D | event_device.rs | 8 use std::collections::VecDeque;
43 event_buffer: VecDeque<u8>,
|
| /external/rust/crates/tokio-test/src/ |
| D | io.rs | 27 use std::collections::VecDeque;
54 actions: VecDeque<Action>,
69 actions: VecDeque<Action>,
187 fn new(actions: VecDeque<Action>) -> (Inner, Handle) { in new()
|
| /external/rust/crates/rayon/src/iter/ |
| D | extend.rs | 7 use std::collections::{BinaryHeap, VecDeque};
322 fn deque_reserve<T, U>(deque: &mut VecDeque<T>, list: &LinkedList<Vec<U>>) { in deque_reserve()
327 impl<T> ParallelExtend<T> for VecDeque<T> implementation
340 impl<'a, T> ParallelExtend<&'a T> for VecDeque<T> implementation
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 14 use std::collections::{HashMap, VecDeque};
55 queue: VecDeque<Task>,
112 queue: VecDeque::new(), in new()
|
| /external/rust/crates/bindgen/src/ir/ |
| D | traversal.rs | 5 use std::collections::{BTreeMap, VecDeque};
328 impl TraversalQueue for VecDeque<ItemId> { implementation
494 VecDeque<ItemId>,
|
| /external/rust/crates/rayon-core/src/ |
| D | log.rs | 22 use std::collections::VecDeque;
216 let mut events: VecDeque<Event> = VecDeque::with_capacity(capacity); in tail_logger_thread()
|
| /external/crosvm/devices/src/virtio/input/ |
| D | event_source.rs | 12 use std::collections::VecDeque;
46 queue: VecDeque<virtio_input_event>,
124 queue: VecDeque::new(), in new()
|