Searched refs:local_queue_two (Results 1 – 1 of 1) sorted by relevance
1024 let local_queue_two = Arc::new(LocalQueue::new()); in ut_inner_buffer_steal_into_multi_threaded_complex() localVariable1025 let local_queue_two_clone = local_queue_two.clone(); in ut_inner_buffer_steal_into_multi_threaded_complex()1055 assert_eq!(local_queue_two.len(), (LOCAL_QUEUE_CAP / 2 - 1) as u16); in ut_inner_buffer_steal_into_multi_threaded_complex()