/external/autotest/server/cros/ |
H A D | queue_barrier.py | 5 from multiprocessing import Queue, queues namespace 33 self.queue_master_ = Queue() 34 self.queue_slave_ = Queue()
|
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/sqs/ |
H A D | test_queue.py | 25 from boto.sqs.queue import Queue namespace 35 q = Queue( 44 q = Queue(
|
/external/google-breakpad/src/testing/gtest/samples/ |
H A D | sample3-inl.h | 40 // Queue is a simple queue implemented as a singled-linked list. 44 class Queue; 46 // QueueNode is a node in a Queue, which consists of an element of 50 friend class Queue<E>; 74 class Queue { class 77 Queue() : head_(NULL), last_(NULL), size_(0) {} function in class:Queue 80 ~Queue() { Clear(); } 153 Queue* Map(F function) const { 154 Queue* new_queue = new Queue(); [all...] |
/external/protobuf/gtest/samples/ |
H A D | sample3-inl.h | 40 // Queue is a simple queue implemented as a singled-linked list. 44 class Queue; 46 // QueueNode is a node in a Queue, which consists of an element of 50 friend class Queue<E>; 74 class Queue { class 78 Queue() : head_(NULL), last_(NULL), size_(0) {} function in class:Queue 81 ~Queue() { Clear(); } 154 Queue* Map(F function) const { 155 Queue* new_queue = new Queue(); [all...] |
/external/vulkan-validation-layers/tests/gtest-1.7.0/samples/ |
H A D | sample3-inl.h | 40 // Queue is a simple queue implemented as a singled-linked list. 44 class Queue; 46 // QueueNode is a node in a Queue, which consists of an element of 50 friend class Queue<E>; 74 class Queue { class 77 Queue() : head_(NULL), last_(NULL), size_(0) {} function in class:Queue 80 ~Queue() { Clear(); } 153 Queue* Map(F function) const { 154 Queue* new_queue = new Queue(); [all...] |
/external/autotest/scheduler/ |
H A D | drone_task_queue_unittest.py | 11 import Queue namespace 68 # Queue 2 calls against each drone, and confirm that the host's
|
H A D | thread_lib.py | 24 import Queue namespace 82 self.results_queue = Queue.Queue() 124 logging.info('(Task Queue) Waiting for %s', tname) 128 logging.info('(Task Queue) All threads have returned, clearing map.')
|
H A D | thread_lib_unittest.py | 11 import Queue namespace 108 sync_queue = Queue.Queue() 191 # Queue 2 calls against each drone, and confirm that the host's
|
/external/autotest/server/cros/ap_configurators/ |
H A D | ap_cartridge.py | 6 import Queue namespace 23 self.cartridge = Queue.Queue()
|
/external/autotest/server/ |
H A D | site_server_job_utils.py | 16 import logging, os, Queue namespace 188 except Queue.Empty:
|
/external/chromium-trace/catapult/devil/devil/android/perf/ |
H A D | surface_stats_collector.py | 5 import Queue namespace 39 self._data_queue = Queue.Queue()
|
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/boto/ |
H A D | requestlog.py | 4 import Queue namespace 17 self.request_log_queue = Queue.Queue(100)
|
H A D | compat.py | 54 from boto.vendored.six.moves.queue import Queue namespace
|
/external/chromium-trace/catapult/tracing/tracing/mre/ |
H A D | threaded_work_queue.py | 6 import Queue namespace 40 self._main_thread_tasks = Queue.Queue() 41 self._any_thread_tasks = Queue.Queue() 61 self._main_thread_tasks = Queue.Queue() 62 self._any_thread_tasks = Queue.Queue() 78 except Queue [all...] |
/external/llvm/include/llvm/CodeGen/ |
H A D | LatencyPriorityQueue.h | 37 /// Queue, the number of nodes that the node is the sole unscheduled 42 /// Queue - The queue. 43 std::vector<SUnit*> Queue; member in class:llvm::LatencyPriorityQueue 78 bool empty() const override { return Queue.empty(); }
|
/external/v8/tools/testrunner/network/ |
H A D | endpoint.py | 31 import Queue namespace
|
/external/deqp/external/vulkancts/modules/vulkan/sparse_resources/ |
H A D | vktSparseResourcesBase.hpp | 52 struct Queue struct in namespace:vkt::sparse 78 typedef std::map<vk::VkQueueFlags, std::vector<Queue> > QueuesMap; 84 const Queue& getQueue (const vk::VkQueueFlags queueFlags,
|
/external/v8/tools/testrunner/local/ |
H A D | pool.py | 6 from Queue import Empty 7 from multiprocessing import Event, Process, Queue namespace 89 self.work_queue = Queue() 90 self.done_queue = Queue()
|
/external/wpa_supplicant_8/wpa_supplicant/ |
H A D | eapol_test.py | 12 import Queue namespace 128 res[i] = Queue.Queue()
|
/external/autotest/client/bin/ |
H A D | prespawner.py | 43 from Queue import Queue namespace 51 self.prespawned = Queue(NUM_PRESPAWNED_PROCESSES)
|
/external/autotest/client/cros/cellular/mbim_compliance/ |
H A D | mbim_channel.py | 7 import Queue namespace 78 self._request_queue = multiprocessing.Queue() 79 self._response_queue = multiprocessing.Queue() 290 except Queue.Empty: 309 except Queue.Empty:
|
H A D | mbim_channel_endpoint.py | 6 import Queue namespace 117 except Queue.Full: 127 except Queue.Empty:
|
/external/autotest/site_utils/ |
H A D | metadata_reporter.py | 12 import Queue namespace 37 # Queue to buffer metadata to be reported. 38 metadata_queue = Queue.Queue(_MAX_METADATA_QUEUE_SIZE) 45 """Queue metadata to be uploaded in reporter thread. 48 becomes full. The call does not wait or raise Queue.Full exception, so 59 except Queue.Full:
|
/external/autotest/site_utils/tester_feedback/ |
H A D | request_multiplexer.py | 8 import Queue namespace 34 self._request_queue = multiprocessing.Queue() 44 except Queue.Empty:
|
/external/chromium-trace/catapult/third_party/gsutil/third_party/boto/tests/unit/glacier/ |
H A D | test_concurrent.py | 24 from boto.compat import Queue namespace 128 Queue(), Queue()) 139 job_queue = Queue() 140 result_queue = Queue() 158 job_queue = Queue() 159 result_queue = Queue()
|