| /external/pigweed/pw_containers/ |
| D | inline_queue_test.cc | 35 InlineQueue<int, 3> queue; in TEST() local 43 InlineQueue<int>& queue(sized_queue); in TEST() local 50 InlineQueue<CopyOnly, 4> queue(4, CopyOnly(123)); in TEST() local 61 InlineQueue<CopyOnly, 4> queue(4, CopyOnly(123)); in TEST() local 72 InlineQueue<CopyOnly, 4> queue(3, CopyOnly(123)); in TEST() local 83 InlineQueue<MoveOnly, 4> queue; in TEST() local 98 InlineQueue<MoveOnly, 4> queue; in TEST() local 113 InlineQueue<MoveOnly, 4> queue; in TEST() local 129 InlineQueue<Counter, 0> queue; in TEST() local 140 InlineQueue<Counter, 3> queue; in TEST() local [all …]
|
| D | inline_var_len_entry_queue.c | 23 static uint32_t BufferSize(const uint32_t* queue) { return queue[0]; } in BufferSize() 24 static uint32_t Capacity(const uint32_t* queue) { in Capacity() 29 #define HEAD(queue) queue[1] argument 30 #define TAIL(queue) queue[2] argument 33 static uint8_t* WritableData(uint32_t* queue) { return (uint8_t*)&queue[3]; } in WritableData() 34 static const uint8_t* Data(const uint32_t* queue) { in Data() 38 static uint32_t WrapIndex(pw_InlineVarLenEntryQueue_ConstHandle queue, in WrapIndex() 52 static EntrySize ReadEntrySize(pw_InlineVarLenEntryQueue_ConstHandle queue, in ReadEntrySize() 68 static uint32_t EncodePrefix(pw_InlineVarLenEntryQueue_ConstHandle queue, in EncodePrefix() 83 pw_InlineVarLenEntryQueue_ConstHandle queue, uint32_t offset) { in ReadEncodedEntrySize() [all …]
|
| /external/rust/crates/tokio-util/tests/ |
| D | time_delay_queue.rs | 29 let mut queue = task::spawn(DelayQueue::new()); in single_immediate_delay() localVariable 45 let mut queue = task::spawn(DelayQueue::new()); in multi_immediate_delays() localVariable 74 let mut queue = task::spawn(DelayQueue::new()); in single_short_delay() localVariable 101 let mut queue = task::spawn(DelayQueue::new()); in multi_delay_at_start() localVariable 141 let mut queue = task::spawn(DelayQueue::new()); in insert_in_past_fires_immediately() localVariable 156 let mut queue = task::spawn(DelayQueue::new()); in remove_entry() localVariable 175 let mut queue = task::spawn(DelayQueue::new()); in reset_entry() localVariable 209 let mut queue = task::spawn(DelayQueue::new()); in reset_much_later() localVariable 231 let mut queue = task::spawn(DelayQueue::new()); in reset_twice() localVariable 265 let mut queue = task::spawn(DelayQueue::new()); in repeatedly_reset_entry_inserted_as_expired() localVariable [all …]
|
| /external/exoplayer/tree_15dc86382f17a24a3e881e52e31a810c1ea44b49/library/core/src/test/java/com/google/android/exoplayer2/mediacodec/ |
| D | IntArrayQueueTest.java | 32 IntArrayQueue queue = new IntArrayQueue(); in add_willDoubleCapacity() local 45 IntArrayQueue queue = new IntArrayQueue(); in isEmpty_returnsTrueAfterConstruction() local 52 IntArrayQueue queue = new IntArrayQueue(); in isEmpty_returnsFalseAfterAddition() local 60 IntArrayQueue queue = new IntArrayQueue(); in isEmpty_returnsFalseAfterRemoval() local 69 IntArrayQueue queue = new IntArrayQueue(); in remove_onEmptyQueue_throwsException() local 81 IntArrayQueue queue = new IntArrayQueue(); in remove_returnsCorrectItem() local 90 IntArrayQueue queue = new IntArrayQueue(); in remove_untilIsEmpty() local 107 IntArrayQueue queue = new IntArrayQueue(); in remove_withResize_returnsCorrectItem() local 128 IntArrayQueue queue = new IntArrayQueue(); in clear_resetsQueue() local
|
| /external/exoplayer/tree_8e57d3715f9092d5ec54ebe2e538f34bfcc34479/library/core/src/test/java/com/google/android/exoplayer2/mediacodec/ |
| D | IntArrayQueueTest.java | 32 IntArrayQueue queue = new IntArrayQueue(); in add_willDoubleCapacity() local 45 IntArrayQueue queue = new IntArrayQueue(); in isEmpty_returnsTrueAfterConstruction() local 52 IntArrayQueue queue = new IntArrayQueue(); in isEmpty_returnsFalseAfterAddition() local 60 IntArrayQueue queue = new IntArrayQueue(); in isEmpty_returnsFalseAfterRemoval() local 69 IntArrayQueue queue = new IntArrayQueue(); in remove_onEmptyQueue_throwsException() local 81 IntArrayQueue queue = new IntArrayQueue(); in remove_returnsCorrectItem() local 90 IntArrayQueue queue = new IntArrayQueue(); in remove_untilIsEmpty() local 107 IntArrayQueue queue = new IntArrayQueue(); in remove_withResize_returnsCorrectItem() local 128 IntArrayQueue queue = new IntArrayQueue(); in clear_resetsQueue() local
|
| /external/guava/android/guava-tests/test/com/google/common/collect/ |
| D | EvictingQueueTest.java | 45 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local 73 EvictingQueue<String> queue = EvictingQueue.create(0); in testRemainingCapacity_maxSize0() local 78 EvictingQueue<String> queue = EvictingQueue.create(1); in testRemainingCapacity_maxSize1() local 85 EvictingQueue<String> queue = EvictingQueue.create(3); in testRemainingCapacity_maxSize3() local 96 EvictingQueue<String> queue = EvictingQueue.create(1); in testEvictingAfterOne() local 118 EvictingQueue<String> queue = EvictingQueue.create(3); in testEvictingAfterThree() local 142 EvictingQueue<String> queue = EvictingQueue.create(3); in testAddAll() local 181 EvictingQueue<String> queue = EvictingQueue.create(3); in testAddAll_largeList() local 195 EvictingQueue<String> queue = EvictingQueue.create(5); in testNullPointerExceptions() local
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| D | EvictingQueueTest.java | 45 EvictingQueue<String> queue = EvictingQueue.create(0); in testCreateWithZeroSize() local 73 EvictingQueue<String> queue = EvictingQueue.create(0); in testRemainingCapacity_maxSize0() local 78 EvictingQueue<String> queue = EvictingQueue.create(1); in testRemainingCapacity_maxSize1() local 85 EvictingQueue<String> queue = EvictingQueue.create(3); in testRemainingCapacity_maxSize3() local 96 EvictingQueue<String> queue = EvictingQueue.create(1); in testEvictingAfterOne() local 118 EvictingQueue<String> queue = EvictingQueue.create(3); in testEvictingAfterThree() local 142 EvictingQueue<String> queue = EvictingQueue.create(3); in testAddAll() local 181 EvictingQueue<String> queue = EvictingQueue.create(3); in testAddAll_largeList() local 195 EvictingQueue<String> queue = EvictingQueue.create(5); in testNullPointerExceptions() local
|
| /external/OpenCL-CTS/test_conformance/printf/ |
| D | test_printf.cpp | 402 static int doTest(cl_command_queue queue, cl_context context, const unsigned int testId, const unsi… in doTest() 595 int test_int_0(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_0() 599 int test_int_1(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_1() 603 int test_int_2(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_2() 607 int test_int_3(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_3() 611 int test_int_4(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_4() 615 int test_int_5(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_5() 619 int test_int_6(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_6() 623 int test_int_7(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_7() 627 int test_int_8(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) in test_int_8() [all …]
|
| /external/libnl/lib/netfilter/ |
| D | queue_obj.c | 40 struct nfnl_queue *queue = (struct nfnl_queue *) a; in nfnl_queue_dump() local 90 void nfnl_queue_get(struct nfnl_queue *queue) in nfnl_queue_get() 95 void nfnl_queue_put(struct nfnl_queue *queue) in nfnl_queue_put() 107 void nfnl_queue_set_group(struct nfnl_queue *queue, uint16_t group) in nfnl_queue_set_group() 113 int nfnl_queue_test_group(const struct nfnl_queue *queue) in nfnl_queue_test_group() 118 uint16_t nfnl_queue_get_group(const struct nfnl_queue *queue) in nfnl_queue_get_group() 123 void nfnl_queue_set_maxlen(struct nfnl_queue *queue, uint32_t maxlen) in nfnl_queue_set_maxlen() 129 int nfnl_queue_test_maxlen(const struct nfnl_queue *queue) in nfnl_queue_test_maxlen() 134 uint32_t nfnl_queue_get_maxlen(const struct nfnl_queue *queue) in nfnl_queue_get_maxlen() 139 void nfnl_queue_set_copy_mode(struct nfnl_queue *queue, enum nfnl_queue_copy_mode mode) in nfnl_queue_set_copy_mode() [all …]
|
| /external/OpenCL-CTS/test_conformance/integer_ops/ |
| D | test_int_basic_ops.cpp | 361 cl_command_queue queue, int num_elements, in globalThreadDataNew() 419 cl_command_queue queue; in test_integer_ops_do_thread() local 474 test_integer_ops_threaded(cl_device_id deviceID, cl_context context, cl_command_queue queue, int nu… in test_integer_ops_threaded() 559 cl_command_queue queue, int num_elements, in test_integer_ops() 812 int run_specific_test(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_el… in run_specific_test() 824 int run_multiple_tests(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_e… in run_multiple_tests() 851 int run_test_math(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elemen… in run_test_math() 857 int run_test_logic(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_eleme… in run_test_logic() 863 int run_test_shift(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_eleme… in run_test_shift() 869 int run_test_compare(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_ele… in run_test_compare() [all …]
|
| /external/OpenCL-CTS/test_conformance/events/ |
| D | action_classes.cpp | 132 cl_command_queue queue) in Setup() 177 cl_int NDRangeKernelAction::Execute(cl_command_queue queue, cl_uint numWaits, in Execute() 192 cl_command_queue queue) in Setup() 228 cl_command_queue queue) in Setup() 233 cl_int ReadBufferAction::Execute(cl_command_queue queue, cl_uint numWaits, in Execute() 244 cl_command_queue queue) in Setup() 249 cl_int WriteBufferAction::Execute(cl_command_queue queue, cl_uint numWaits, in Execute() 266 cl_command_queue queue) in Setup() 271 cl_int MapBufferAction::Execute(cl_command_queue queue, cl_uint numWaits, in Execute() 284 cl_command_queue queue) in Setup() [all …]
|
| /external/sdv/vsomeip/third_party/boost/thread/test/ |
| D | test_9192.cpp | 17 struct queue struct 19 void put( const item& item ) in put() 43 //Mutex to protect access to the queue argument 46 //Condition to wait when the queue is empty argument 49 //Condition to wait when the queue is full argument 50 boost::condition_variable cond_full; 75 // shm.truncate(sizeof(queue)); in printThread() argument
|
| /external/webrtc/modules/pacing/ |
| D | prioritized_packet_queue_unittest.cc | 43 PrioritizedPacketQueue queue(now); in TEST() local 64 PrioritizedPacketQueue queue(now); in TEST() local 100 PrioritizedPacketQueue queue(/*creation_time=*/Timestamp::Zero()); in TEST() local 113 PrioritizedPacketQueue queue(/*creation_time=*/Timestamp::Zero()); in TEST() local 126 PrioritizedPacketQueue queue(/*creation_time=*/Timestamp::Zero()); in TEST() local 143 PrioritizedPacketQueue queue(/*creation_time=*/Timestamp::Zero()); in TEST() local 166 PrioritizedPacketQueue queue(/*creation_time=*/Timestamp::Zero()); in TEST() local 192 PrioritizedPacketQueue queue(/*creation_time=*/Timestamp::Zero()); in TEST() local 218 PrioritizedPacketQueue queue(/*creation_time=*/Timestamp::Zero()); in TEST() local 255 PrioritizedPacketQueue queue(now); in TEST() local
|
| /external/sdv/vsomeip/third_party/boost/numeric/ublas/include/boost/numeric/ublas/opencl/ |
| D | elementwise.hpp | 26 O op, compute::command_queue& queue) in element_wise() 47 compute::command_queue &queue) in element_wise() 60 compute::command_queue &queue) in element_wise() 72 compute::command_queue& queue) in element_wise() 92 compute::command_queue &queue) in element_wise() 105 compute::command_queue &queue) in element_wise() 116 compute::command_queue &queue) in element_add() 125 compute::command_queue &queue) in element_add() 133 compute::command_queue &queue) in element_add() 142 compute::command_queue& queue) in element_add() [all …]
|
| /external/cronet/base/task/sequence_manager/ |
| D | task_queue_selector.cc | 47 void TaskQueueSelector::AddQueue(internal::TaskQueueImpl* queue, in AddQueue() 54 void TaskQueueSelector::RemoveQueue(internal::TaskQueueImpl* queue) { in RemoveQueue() 61 void TaskQueueSelector::EnableQueue(internal::TaskQueueImpl* queue) { in EnableQueue() 69 void TaskQueueSelector::DisableQueue(internal::TaskQueueImpl* queue) { in DisableQueue() 75 void TaskQueueSelector::SetQueuePriority(internal::TaskQueueImpl* queue, in SetQueuePriority() 90 void TaskQueueSelector::AddQueueImpl(internal::TaskQueueImpl* queue, in AddQueueImpl() 102 void TaskQueueSelector::ChangeSetIndex(internal::TaskQueueImpl* queue, in ChangeSetIndex() 116 void TaskQueueSelector::RemoveQueueImpl(internal::TaskQueueImpl* queue) { in RemoveQueueImpl() 197 WorkQueue* queue = in SelectWorkQueueToService() local 207 WorkQueue* queue = in SelectWorkQueueToService() local
|
| /external/mesa3d/src/gallium/drivers/virgl/ |
| D | virgl_transfer_queue.c | 140 virgl_transfer_queue_find_overlap(const struct virgl_transfer_queue *queue, in virgl_transfer_queue_find_overlap() 162 static void remove_transfer(struct virgl_transfer_queue *queue, in remove_transfer() 169 static void replace_unmapped_transfer(struct virgl_transfer_queue *queue, in replace_unmapped_transfer() 182 static void transfer_put(struct virgl_transfer_queue *queue, in transfer_put() 195 static void transfer_write(struct virgl_transfer_queue *queue, in transfer_write() 208 static void compare_and_perform_action(struct virgl_transfer_queue *queue, in compare_and_perform_action() 226 static void perform_action(struct virgl_transfer_queue *queue, in perform_action() 241 static void add_internal(struct virgl_transfer_queue *queue, in add_internal() 264 void virgl_transfer_queue_init(struct virgl_transfer_queue *queue, in virgl_transfer_queue_init() 282 void virgl_transfer_queue_fini(struct virgl_transfer_queue *queue) in virgl_transfer_queue_fini() [all …]
|
| /external/zstd/contrib/pzstd/utils/test/ |
| D | WorkQueueTest.cpp | 23 WorkQueue<int>* queue; member 38 WorkQueue<int> queue; in TEST() local 65 WorkQueue<int> queue; in TEST() local 93 WorkQueue<int> queue; in TEST() local 116 WorkQueue<int> queue; in TEST() local 151 WorkQueue<int> queue(1); in TEST() local 164 WorkQueue<int> queue(1); in TEST() local 181 WorkQueue<int> queue(2); in TEST() local 202 WorkQueue<int> queue(10); in TEST() local 243 WorkQueue<std::unique_ptr<int>> queue; in TEST() local [all …]
|
| /external/mesa3d/src/imagination/vulkan/ |
| D | pvr_queue.c | 61 struct pvr_queue *queue, in pvr_queue_init() 169 static void pvr_queue_finish(struct pvr_queue *queue) in pvr_queue_finish() 198 struct pvr_queue *queue, in pvr_update_job_syncs() 217 struct pvr_queue *queue, in pvr_process_graphics_cmd() 319 struct pvr_queue *queue, in pvr_process_compute_cmd() 349 struct pvr_queue *queue, in pvr_process_transfer_cmds() 380 struct pvr_queue *queue, in pvr_process_occlusion_query_cmd() 417 struct pvr_queue *queue, in pvr_process_event_cmd_barrier() 492 struct pvr_queue *queue, in pvr_process_event_cmd_set_or_reset() 551 struct pvr_queue *queue, in pvr_process_event_cmd_set() [all …]
|
| /external/OpenCL-CTS/test_conformance/images/kernel_read_write/ |
| D | main.cpp | 138 static int doTest( cl_device_id device, cl_context context, cl_command_queue queue, cl_mem_object_t… in doTest() 265 int test_1D(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_1D() 269 int test_2D(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_2D() 273 int test_3D(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_3D() 277 int test_1Darray(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_1Darray() 281 int test_2Darray(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_2Darray() 288 cl_command_queue queue, in test_cl_image_requirements_size_ext_negative() 295 cl_command_queue queue, in test_cl_image_requirements_size_ext_consistency() 302 cl_command_queue queue, in test_clGetImageRequirementsInfoEXT_negative() 309 cl_command_queue queue, in test_cl_image_requirements_max_val_ext_negative() [all …]
|
| /external/webrtc/test/pc/e2e/analyzer/video/ |
| D | multi_reader_queue_test.cc | 20 MultiReaderQueue<int> queue = MultiReaderQueue<int>(/*readers_count=*/10); in TEST() local 31 MultiReaderQueue<int> queue = MultiReaderQueue<int>(/*readers_count=*/10); in TEST() local 43 MultiReaderQueue<int> queue = MultiReaderQueue<int>(/*readers_count=*/10); in TEST() local 61 MultiReaderQueue<int> queue = MultiReaderQueue<int>(/*readers_count=*/1); in TEST() local 74 MultiReaderQueue<size_t> queue = in TEST() local 88 MultiReaderQueue<size_t> queue = in TEST() local 115 MultiReaderQueue<size_t> queue = in TEST() local 136 MultiReaderQueue<size_t> queue = in TEST() local 157 MultiReaderQueue<size_t> queue = in TEST() local 178 MultiReaderQueue<size_t> queue = in TEST() local [all …]
|
| /external/OpenCL-CTS/test_conformance/images/clCopyImage/ |
| D | main.cpp | 36 int test_1D(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_1D() 40 int test_2D(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_2D() 44 int test_3D(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_3D() 48 int test_1Darray(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_1Darray() 52 int test_2Darray(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_2Darray() 56 int test_2Dto3D(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_2Dto3D() 60 int test_3Dto2D(cl_device_id device, cl_context context, cl_command_queue queue, int num_elements) in test_3Dto2D() 64 int test_2Darrayto2D(cl_device_id device, cl_context context, cl_command_queue queue, int num_eleme… in test_2Darrayto2D() 68 int test_2Dto2Darray(cl_device_id device, cl_context context, cl_command_queue queue, int num_eleme… in test_2Dto2Darray() 72 int test_2Darrayto3D(cl_device_id device, cl_context context, cl_command_queue queue, int num_eleme… in test_2Darrayto3D() [all …]
|
| /external/webrtc/rtc_base/ |
| D | swap_queue_unittest.cc | 47 SwapQueue<std::vector<int>> queue(2, i); in TEST() local 60 SwapQueue<int> queue(2); in TEST() local 82 SwapQueue<int> queue(2); in TEST() local 91 SwapQueue<int> queue(2); in TEST() local 115 queue(2, template_element); in TEST() local 127 SwapQueue<std::vector<int>, LengthVerifierFunctor> queue(2, template_element, in TEST() local 141 SwapQueue<int, decltype(minus_2_verifier)> queue(2, minus_2_verifier); in TEST() local 154 queue(2, template_element); in TEST() local 163 queue(2, template_element); in TEST() local 178 SwapQueue<std::vector<int16_t>> queue(kQueueSize, in TEST() local [all …]
|
| /external/OpenCL-CTS/test_conformance/select/ |
| D | test_select.cpp | 313 static int doTest(cl_command_queue queue, cl_context context, Type stype, Type cmptype, cl_device_i… in doTest() 481 int test_select_uchar_uchar(cl_device_id deviceID, cl_context context, cl_command_queue queue, int … in test_select_uchar_uchar() 485 int test_select_uchar_char(cl_device_id deviceID, cl_context context, cl_command_queue queue, int n… in test_select_uchar_char() 489 int test_select_char_uchar(cl_device_id deviceID, cl_context context, cl_command_queue queue, int n… in test_select_char_uchar() 493 int test_select_char_char(cl_device_id deviceID, cl_context context, cl_command_queue queue, int nu… in test_select_char_char() 497 int test_select_ushort_ushort(cl_device_id deviceID, cl_context context, cl_command_queue queue, in… in test_select_ushort_ushort() 501 int test_select_ushort_short(cl_device_id deviceID, cl_context context, cl_command_queue queue, int… in test_select_ushort_short() 505 int test_select_short_ushort(cl_device_id deviceID, cl_context context, cl_command_queue queue, int… in test_select_short_ushort() 509 int test_select_short_short(cl_device_id deviceID, cl_context context, cl_command_queue queue, int … in test_select_short_short() 514 cl_command_queue queue, int num_elements) in test_select_half_ushort() [all …]
|
| /external/OpenCL-CTS/test_conformance/generic_address_space/ |
| D | basic_tests.cpp | 34 …int ExecuteSubcase(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elem… in ExecuteSubcase() 81 … int Execute(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_elements) { in Execute() 97 int test_function_get_fence(cl_device_id deviceID, cl_context context, cl_command_queue queue, int … in test_function_get_fence() 145 …tion_to_address_space(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_e… in test_function_to_address_space() 193 int test_variable_get_fence(cl_device_id deviceID, cl_context context, cl_command_queue queue, int … in test_variable_get_fence() 226 …able_to_address_space(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_e… in test_variable_to_address_space() 259 int test_casting(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_element… in test_casting() 348 int test_conditional_casting(cl_device_id deviceID, cl_context context, cl_command_queue queue, int… in test_conditional_casting() 379 int test_chain_casting(cl_device_id deviceID, cl_context context, cl_command_queue queue, int num_e… in test_chain_casting() 410 int test_ternary_operator_casting(cl_device_id deviceID, cl_context context, cl_command_queue queue… in test_ternary_operator_casting() [all …]
|
| /external/rust/crates/futures/tests/ |
| D | ready_queue.rs | 14 let mut queue = FuturesUnordered::new(); in basic_usage() localVariable 42 let mut queue = FuturesUnordered::new(); in resolving_errors() localVariable 70 let queue = FuturesUnordered::new(); in dropping_ready_queue() localVariable 101 let mut queue = FuturesUnordered::new(); in stress() localVariable 140 let mut queue = FuturesUnordered::new(); in panicking_future_dropped() localVariable
|