| /aosp_15_r20/system/chre/util/tests/ |
| H A D | array_queue_test.cc | 26 using chre::ArrayQueue;
63 ArrayQueue<int, 4> q; in TEST()
69 ArrayQueue<int, 3> q; in TEST()
77 ArrayQueue<int, 3> q; in TEST()
123 ArrayQueue<int, 2> q; in TEST()
134 ArrayQueue<int, 2> q; in TEST()
146 ArrayQueue<int, 2> q; in TEST()
156 ArrayQueue<int, 2> q; in TEST()
167 ArrayQueue<int, 4> q; in TEST()
173 ArrayQueue<int, 4> q; in TEST()
[all …]
|
| H A D | atomic_spsc_queue_test.cc | 25 using chre::ArrayQueue;
381 void PrintTo(const ArrayQueue<HistoryEntry, kHistorySize> &history, in PrintTo()
404 ArrayQueue<HistoryEntry, kHistorySize> history; in TEST()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-queue/tests/ |
| D | array_queue.rs | 3 use crossbeam_queue::ArrayQueue;
9 let q = ArrayQueue::new(1); in smoke()
22 let q = ArrayQueue::<i32>::new(i); in capacity()
30 let _ = ArrayQueue::<i32>::new(0); in zero_capacity()
35 let q = ArrayQueue::new(2); in len_empty_full()
72 let q = ArrayQueue::new(CAP); in len()
131 let q = ArrayQueue::new(3); in spsc()
163 let q = ArrayQueue::<usize>::new(3); in spsc_ring_buffer()
204 let q = ArrayQueue::<usize>::new(3); in mpmc()
244 let q = ArrayQueue::<usize>::new(3); in mpmc_ring_buffer()
[all …]
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-queue/src/ |
| D | array_queue.rs | 50 pub struct ArrayQueue<T> { struct
77 unsafe impl<T: Send> Sync for ArrayQueue<T> {} implementation
78 unsafe impl<T: Send> Send for ArrayQueue<T> {} implementation
80 impl<T> UnwindSafe for ArrayQueue<T> {} implementation
81 impl<T> RefUnwindSafe for ArrayQueue<T> {} implementation
83 impl<T> ArrayQueue<T> { impl
97 pub fn new(cap: usize) -> ArrayQueue<T> { in new()
120 ArrayQueue { in new()
448 impl<T> Drop for ArrayQueue<T> { implementation
487 impl<T> fmt::Debug for ArrayQueue<T> { implementation
[all …]
|
| D | lib.rs | 32 pub use crate::{array_queue::ArrayQueue, seg_queue::SegQueue};
|
| /aosp_15_r20/external/rust/android-crates-io/crates/crossbeam-queue/ |
| D | CHANGELOG.md | 8 - Implement `UnwindSafe` and `RefUnwindSafe` for `ArrayQueue` and `SegQueue`. (#1053)
9 - Optimize `Drop` implementation of `ArrayQueue`. (#1057)
33 - Add `ArrayQueue::force_push`. (#789)
37 - Implement `IntoIterator` for `ArrayQueue` and `SegQueue`. (#772)
41 - Fix stacked borrows violation in `ArrayQueue` when `-Zmiri-tag-raw-pointers` is enabled. (#763)
84 - Initial version with `ArrayQueue` and `SegQueue`.
|
| D | README.md | 17 * [`ArrayQueue`], a bounded MPMC queue that allocates a fixed-capacity buffer on construction.
23 [`ArrayQueue`]: https://docs.rs/crossbeam-queue/*/crossbeam_queue/struct.ArrayQueue.html
|
| /aosp_15_r20/external/rust/android-crates-io/crates/vulkano/src/command_buffer/ |
| D | allocator.rs | 27 use crossbeam_queue::ArrayQueue;
234 let reserve = Arc::new(ArrayQueue::new(MAX_POOLS)); in allocate()
305 reserve: Arc<ArrayQueue<PoolInner>>,
332 reserve: Arc<ArrayQueue<PoolInner>>,
340 primary_pool: Option<ArrayQueue<CommandPoolAlloc>>,
342 secondary_pool: Option<ArrayQueue<CommandPoolAlloc>>,
353 reserve: Arc<ArrayQueue<PoolInner>>, in new()
371 let pool = ArrayQueue::new(create_info.primary_buffer_count); in new()
387 let pool = ArrayQueue::new(create_info.secondary_buffer_count); in new()
|
| /aosp_15_r20/system/chre/host/hal_generic/aidl/ |
| H A D | event_logger.h | 82 ::chre::ArrayQueue<NanoappLoad, kMaxNanoappEvents> mNanoappLoads;
83 ::chre::ArrayQueue<NanoappUnload, kMaxNanoappEvents> mNanoappUnloads;
84 ::chre::ArrayQueue<int64_t, kMaxRestartEvents> mContextHubRestarts;
85 ::chre::ArrayQueue<NanoappMessage, kMaxMessageEvents> mMsgToNanoapp;
86 ::chre::ArrayQueue<NanoappMessage, kMaxMessageEvents> mMsgFromNanoapp;
|
| /aosp_15_r20/frameworks/base/libs/hwui/thread/ |
| H A D | CommonPool.h | 35 class ArrayQueue {
36 PREVENT_COPY_AND_ASSIGN(ArrayQueue);
40 ArrayQueue() = default;
41 ~ArrayQueue() = default;
126 ArrayQueue<Task, QUEUE_SIZE> mWorkQueue;
|
| /aosp_15_r20/external/rust/android-crates-io/crates/vulkano/src/descriptor_set/ |
| D | allocator.rs | 32 use crossbeam_queue::ArrayQueue;
255 reserve: ArrayQueue<UnsafeDescriptorSet>,
280 let reserve = ArrayQueue::new(set_count); in new()
316 reserve: Arc<ArrayQueue<DescriptorPool>>,
325 let reserve = Arc::new(ArrayQueue::new(MAX_POOLS)); in new()
388 reserve: Arc<ArrayQueue<DescriptorPool>>,
394 reserve: Arc<ArrayQueue<DescriptorPool>>, in new()
|
| /aosp_15_r20/system/chre/core/include/chre/core/ |
| H A D | wifi_request_manager.h | 382 ArrayQueue<PendingScanMonitorRequest, kMaxScanMonitorStateTransitions>
388 ArrayQueue<PendingScanRequest, kMaxPendingScanRequest> mPendingScanRequests;
416 ArrayQueue<PendingRangingRequest, kMaxPendingRangingRequests>
420 ArrayQueue<PendingNanSubscribeRequest, kMaxPendingNanSubscriptionRequests>
425 ArrayQueue<WifiScanRequestLog, kNumWifiRequestLogs> mWifiScanRequestLogs;
|
| H A D | ble_request_manager.h | 274 ArrayQueue<FlushRequest, kMaxFlushRequests> mFlushRequestQueue;
289 ArrayQueue<BleReadRssiRequest, kMaxPendingRssiRequests> mPendingRssiRequests;
320 ArrayQueue<BleRequestLog, kNumBleRequestLogs> mBleRequestLogs;
|
| H A D | gnss_manager.h | 204 ArrayQueue<StateTransition, kMaxGnssStateTransitions> mStateTransitions;
208 ArrayQueue<SessionRequestLog, kNumSessionRequestLogs> mSessionRequestLogs;
|
| H A D | event_ref_queue.h | 64 ArrayQueue<Event *, kMaxPendingEvents> mQueue;
|
| H A D | sensor_request_manager.h | 342 ArrayQueue<SensorRequestLog, kMaxSensorRequestLogs> mSensorRequestLogs;
|
| /aosp_15_r20/frameworks/native/libs/debugstore/rust/src/ |
| H A D | storage.rs | 17 use crossbeam_queue::ArrayQueue;
21 insertion_buffer: ArrayQueue<T>,
27 Self { insertion_buffer: ArrayQueue::new(N) } in new()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/vulkano/src/buffer/ |
| D | allocator.rs | 27 use crossbeam_queue::ArrayQueue;
286 reserve: Option<Arc<ArrayQueue<Arc<Buffer>>>>,
339 self.reserve = Some(Arc::new(ArrayQueue::new(MAX_ARENAS))); in next_arena()
381 reserve: Arc<ArrayQueue<Arc<Buffer>>>,
|
| /aosp_15_r20/system/chre/util/include/chre/util/system/ |
| H A D | fixed_size_blocking_queue.h | 116 ElementType, ArrayQueue<ElementType, kSize>> {
|
| H A D | transaction_manager.h | 182 ArrayQueue<Transaction, kMaxTransactions> mTransactions;
|
| /aosp_15_r20/system/chre/util/include/chre/util/ |
| H A D | array_queue.h | 340 class ArrayQueue
|
| /aosp_15_r20/external/rust/android-crates-io/crates/vulkano/src/memory/allocator/ |
| D | suballocator.rs | 27 use crossbeam_queue::ArrayQueue;
2088 free_list: ArrayQueue<DeviceSize>,
2113 let free_list = ArrayQueue::new(block_count as usize); in new()
2677 let allocs = ArrayQueue::new((ALLOCATIONS_PER_THREAD * THREADS) as usize); in free_list_allocator_capacity()
|
| /aosp_15_r20/system/chre/doc/ |
| H A D | nanoapp_developer_guide.md | 126 * `chre::ArrayQueue`: can be used as a circular buffer
|
| /aosp_15_r20/external/kotlinc/lib/ |
| HD | kotlinx-coroutines-core-jvm.jar | META-INF/
META-INF/MANIFEST.MF
kotlinx/
kotlinx/coroutines/
kotlinx/ ... |
| /aosp_15_r20/prebuilts/jdk/jdk8/darwin-x86/lib/ |
| D | ct.sym | META-INF/
META-INF/MANIFEST.MF
META-INF/sym/rt. ... |