Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 105) sorted by relevance

12345

/tools/test/connectivity/acts/framework/acts/controllers/buds_lib/data_storage/bigquery/
Dbigquery_logger_queue.py27 self.queue = Queue(maxsize=size)
39 self.queue.put(((dataset_id, table_id), row))
51 num_entries_to_insert = self.queue.qsize()
54 if not self.queue.empty():
55 dataset_table_tuple, row_dict = self.queue.get()
63 self.queue.put(row_tuple)
66 return self.queue.get()
69 return self.queue.empty()
Dbigquery_buffer.py25 queue = None variable
78 global queue
79 queue = bq_utils.get_queue(
82 if queue:
86 queue.put(old_queue.get())
90 queue.set_flush_period(self.flush_period)
135 global queue
147 if queue:
150 queue.add_row(dataset_id, table_id, row_dict)
Dbigquery_scheduled_automatic_client.py25 def start_scheduled_automatic_logging(queue, project_id, credentials_path): argument
33 insert_iterator = queue.get_insert_iterator()
38 time.sleep(queue.get_flush_period())
44 queue = utils.get_queue(ip_address, port, authkey)
45 start_scheduled_automatic_logging(queue, project_id, credentials_path)
Dbigquery_logger_server.py25 queue = BigqueryLoggerQueue(size=int(queue_size))
26 BaseManager.register('get_queue', callable=lambda: queue)
/tools/test/connectivity/acts/framework/acts/controllers/sl4a_lib/
Devent_dispatcher.py18 import queue
113 q = queue.Queue()
213 except queue.Empty:
214 raise queue.Empty('Timeout after {}s waiting for event: {}'.format(
256 except queue.Empty:
267 raise queue.Empty(
306 raise queue.Empty('Timeout after {}s waiting for event: {}'.format(
323 except queue.Empty:
338 self._event_dict[event_name] = queue.Queue()
427 except (queue.Empty, KeyError):
[all …]
/tools/test/connectivity/acts/framework/acts/test_utils/car/
Dtel_telecom_utils.py21 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:
Dcar_telecom_utils.py29 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/google/wifi/aware/stress/
DInfraAssociationStressTest.py17 import queue
61 except queue.Empty:
93 q = queue.Queue()
106 except queue.Empty:
149 except queue.Empty:
DDataPathStressTest.py17 import queue
153 except queue.Empty:
185 except queue.Empty:
DMessagesStressTest.py17 import queue
112 except queue.Empty:
147 except queue.Empty:
DDiscoveryStressTest.py17 import queue
103 except queue.Empty:
/tools/test/connectivity/acts/tests/google/wifi/aware/performance/
DLatencyTest.py17 import queue
128 except queue.Empty:
214 except queue.Empty:
292 except queue.Empty:
307 except queue.Empty:
409 except queue.Empty:
516 except queue.Empty:
532 except queue.Empty:
551 except queue.Empty:
567 except queue.Empty:
[all …]
DThroughputTest.py19 import queue
181 q = queue.Queue()
364 q = queue.Queue()
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/io/
DPipe.kt33 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/test_utils/bt/
DAvrcpBaseTest.py19 import queue
103 except queue.Empty as e:
112 except queue.Empty as e:
121 except queue.Empty as e:
131 except queue.Empty as e:
Dbt_contacts_utils.py29 import queue
328 except queue.Empty:
343 except queue.Empty:
360 except queue.Empty:
/tools/test/connectivity/acts/tests/google/wifi/
DWifiScannerScanTest.py18 import queue
255 except queue.Empty as error:
304 except queue.Empty as error:
359 except queue.Empty as error:
420 except queue.Empty as error:
503 except queue.Empty as error:
524 except queue.Empty as error:
542 except queue.Empty as error:
819 except queue.Empty as error:
954 except queue.Empty as error:
[all …]
DWifiScannerBssidTest.py18 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:
DWifiNetworkRequestTest.py19 import queue
113 except queue.Empty:
436 except queue.Empty:
500 except queue.Empty:
/tools/test/connectivity/acts/tests/google/bt/car_bt/
DBtCarMapMceTest.py21 import queue
74 except queue.Empty:
91 except queue.Empty:
99 except queue.Empty:
/tools/tradefederation/core/tests/src/com/android/tradefed/util/
DConditionPriorityBlockingQueueTest.java284 final ConditionPriorityBlockingQueue<Integer> queue = in testModificationOnIterating() local
287 queue.add(i); in testModificationOnIterating()
294 for (@SuppressWarnings("unused") Integer i : queue) { in testModificationOnIterating()
305 queue.add(i); in testModificationOnIterating()
/tools/test/connectivity/acts/framework/acts/test_utils/wifi/rtt/
Drtt_test_utils.py18 import queue
51 except queue.Empty:
72 except queue.Empty:
462 except queue.Empty:
/tools/test/connectivity/acts/framework/acts/test_utils/wifi/aware/
Daware_test_utils.py19 import queue
63 except queue.Empty:
96 except queue.Empty:
118 except queue.Empty:
150 except queue.Empty:
168 except queue.Empty:
/tools/tradefederation/core/src/com/android/tradefed/util/sl4a/
DSl4aEventDispatcher.java83 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/framework/acts/test_utils/net/
Dsocket_test_utils.py16 import queue
209 sq = queue.Queue()
210 cq = queue.Queue()

12345