Searched refs:local_queue_one (Results 1 – 1 of 1) sorted by relevance
1021 let local_queue_one = Arc::new(LocalQueue::new()); in ut_inner_buffer_steal_into_multi_threaded_complex() localVariable1022 let local_queue_one_clone = local_queue_one.clone(); in ut_inner_buffer_steal_into_multi_threaded_complex()1056 assert_eq!(local_queue_one.len(), (LOCAL_QUEUE_CAP / 4 - 1) as u16); in ut_inner_buffer_steal_into_multi_threaded_complex()