| /tools/netsim/src/util/ |
| D | blocking_queue.h | 42 std::queue<T> queue; variable
70 this->queue.push(value); in Push()
83 this->queue.push(std::move(value)); in Push()
98 [=] { return this->stopped || !this->queue.empty(); }); in WaitAndPop()
100 value = this->queue.front(); in WaitAndPop()
101 this->queue.pop(); in WaitAndPop()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/io/ |
| D | Pipe.kt | 33 private val queue = ArrayBlockingQueue<Packet<T>>(capacity) constant
41 queue.put(Packet(data)) in add()
47 queue.put(Packet(null)) in close()
53 val packet = queue.take() in next()
|
| /tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/ |
| D | event_dispatcher.py | 18 import queue
117 q = queue.Queue()
217 except queue.Empty:
221 raise queue.Empty(msg)
265 except queue.Empty:
281 raise queue.Empty(msg)
321 raise queue.Empty(msg)
337 except queue.Empty:
352 self._event_dict[event_name] = queue.Queue()
441 except (queue.Empty, KeyError):
[all …]
|
| /tools/test/connectivity/acts_tests/tests/google/wifi/aware/stress/ |
| D | InfraAssociationStressTest.py | 17 import queue
58 except queue.Empty:
90 q = queue.Queue()
103 except queue.Empty:
146 except queue.Empty:
|
| D | DiscoveryStressTest.py | 17 import queue
100 except queue.Empty:
|
| D | DataPathStressTest.py | 17 import queue
150 except queue.Empty:
182 except queue.Empty:
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/car/ |
| D | tel_telecom_utils.py | 21 import queue
53 except queue.Empty:
101 except queue.Empty:
140 except queue.Empty:
182 except queue.Empty:
220 except queue.Empty:
281 except queue.Empty:
|
| D | car_telecom_utils.py | 29 import queue
66 except queue.Empty:
129 except queue.Empty:
167 except queue.Empty:
262 except queue.Empty:
305 except queue.Empty:
359 except queue.Empty:
403 except queue.Empty:
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/bt/ |
| D | AvrcpBaseTest.py | 19 import queue
104 except queue.Empty as e:
113 except queue.Empty as e:
122 except queue.Empty as e:
132 except queue.Empty as e:
|
| D | bt_contacts_utils.py | 29 import queue
328 except queue.Empty:
343 except queue.Empty:
360 except queue.Empty:
|
| /tools/tradefederation/core/src/com/android/tradefed/util/sl4a/ |
| D | Sl4aEventDispatcher.java | 83 LinkedList<EventSl4aObject> queue = new LinkedList<>(); in internalPolling() local
84 queue.add(event); in internalPolling()
85 mEventQueue.put(event.getName(), queue); in internalPolling() local
|
| /tools/test/connectivity/acts_tests/tests/google/bt/performance/ |
| D | BtInterferenceDynamicTest.py | 282 queue = Queue()
284 args=(self.audio_params['duration'], queue))
301 audio_captured = queue.get()
339 queue = Queue()
341 args=(self.audio_params['duration'], queue))
360 audio_captured = queue.get()
|
| D | BtInterferenceStaticTest.py | 109 queue = Queue()
111 args=(self.audio_params['duration'], queue))
126 audio_captured = queue.get()
|
| /tools/test/connectivity/acts_tests/tests/google/bt/car_bt/ |
| D | BtCarMapMceTest.py | 21 import queue
74 except queue.Empty:
91 except queue.Empty:
99 except queue.Empty:
|
| /tools/test/connectivity/acts_tests/tests/google/wifi/ |
| D | WifiScannerBssidTest.py | 18 import queue
144 except queue.Empty as error:
196 except queue.Empty as error:
254 except queue.Empty as error:
391 except queue.Empty as error:
428 except queue.Empty as error:
|
| D | WifiScannerScanTest.py | 18 import queue
247 except queue.Empty as error:
296 except queue.Empty as error:
351 except queue.Empty as error:
412 except queue.Empty as error:
495 except queue.Empty as error:
516 except queue.Empty as error:
534 except queue.Empty as error:
911 except queue.Empty as error:
1053 except queue.Empty as error:
|
| D | WifiServiceApiTest.py | 17 import queue
120 except queue.Empty:
|
| /tools/tradefederation/core/javatests/com/android/tradefed/util/ |
| D | ConditionPriorityBlockingQueueTest.java | 290 final ConditionPriorityBlockingQueue<Integer> queue = in testModificationOnIterating() local
293 queue.add(i); in testModificationOnIterating()
300 for (@SuppressWarnings("unused") Integer i : queue) { in testModificationOnIterating()
311 queue.add(i); in testModificationOnIterating()
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/wifi/rtt/ |
| D | rtt_test_utils.py | 18 import queue
51 except queue.Empty:
72 except queue.Empty:
468 except queue.Empty:
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/net/ |
| D | socket_test_utils.py | 16 import queue
201 sq = queue.Queue()
202 cq = queue.Queue()
|
| /tools/test/connectivity/acts_tests/tests/google/wifi/rtt/stress/ |
| D | StressRangeAwareTest.py | 17 import queue
77 except queue.Empty:
|
| /tools/test/connectivity/acts_tests/tests/google/wifi/aware/performance/ |
| D | LatencyTest.py | 17 import queue
130 except queue.Empty:
217 except queue.Empty:
297 except queue.Empty:
312 except queue.Empty:
415 except queue.Empty:
530 except queue.Empty:
|
| /tools/metalava/metalava-model/src/main/java/com/android/tools/metalava/model/ |
| D | MethodItem.kt | 504 val queue = mutableListOf(superInterface) in <lambda>() constant
505 while (queue.isNotEmpty()) { in <lambda>()
506 val s = queue.removeFirst() in <lambda>()
508 queue.addAll( in <lambda>()
|
| /tools/test/connectivity/acts/framework/acts/controllers/monsoon_lib/sampling/engine/ |
| D | assembly_line.py | 17 import queue
216 def __init__(self, queue_generator=queue.Queue):
|
| /tools/test/connectivity/acts_tests/tests/google/wifi/aware/functional/ |
| D | MatchFilterTest.py | 19 import queue
115 except queue.Empty:
|