| /external/bluetooth/bluedroid/osi/src/ |
| thread.c | 39 fixed_queue_t *work_queue; member in struct:thread_t
70 ret->work_queue = fixed_queue_new(WORK_QUEUE_CAPACITY);
71 if (!ret->work_queue)
91 fixed_queue_free(ret->work_queue, free);
104 fixed_queue_free(thread->work_queue, free);
126 fixed_queue_enqueue(thread->work_queue, item);
159 work_queue_object.context = thread->work_queue;
160 work_queue_object.fd = fixed_queue_get_dequeue_fd(thread->work_queue);
171 work_item_t *item = fixed_queue_try_dequeue(thread->work_queue);
175 item = fixed_queue_try_dequeue(thread->work_queue);
[all...] |
| /external/chromium_org/v8/tools/testrunner/local/ |
| pool.py | 27 def Worker(fn, work_queue, done_queue, done):
32 for args in iter(work_queue.get, "STOP"):
59 # Invariant: count >= #work_queue + #done_queue. It is greater when a
60 # worker takes an item from the work_queue and before the result is
65 # work_queue.
67 self.work_queue = Queue()
81 self.work_queue,
106 self.work_queue.put(gen.next())
118 self.work_queue.put(args)
133 self.work_queue.put("STOP"
[all...] |
| /external/chromium_org/base/message_loop/ |
| incoming_task_queue.cc | 53 int IncomingTaskQueue::ReloadWorkQueue(TaskQueue* work_queue) {
55 DCHECK(work_queue->empty());
60 incoming_queue_.Swap(work_queue);
|
| incoming_task_queue.h | 48 // Loads tasks from the |incoming_queue_| into |*work_queue|. Must be called
51 int ReloadWorkQueue(TaskQueue* work_queue);
|
| /external/chromium_org/remoting/base/ |
| plugin_thread_task_runner.cc | 178 base::TaskQueue work_queue; local
181 incoming_queue_.Swap(&work_queue);
184 while (!work_queue.empty()) {
185 base::PendingTask pending_task = work_queue.front();
186 work_queue.pop();
|
| /external/chromium_org/tools/gn/ |
| header_checker.cc | 471 // work_queue maintains a queue of targets which need to be considered as
475 // the first time, it is added to work_queue and a "breadcrumb" is added,
483 std::queue<ChainLink> work_queue; local
484 work_queue.push(ChainLink(search_from, true));
487 while (!work_queue.empty()) {
488 ChainLink cur_link = work_queue.front();
490 work_queue.pop();
509 work_queue.push(ChainLink(public_deps[i].ptr, true));
522 work_queue.push(ChainLink(private_deps[i].ptr, false));
|
| /external/chromium_org/third_party/android_crazy_linker/src/src/ |
| crazy_linker_library_list.cpp | 90 Vector<LibraryView*> work_queue;
93 work_queue.PushBack(from);
95 while (!work_queue.IsEmpty()) {
96 LibraryView* lib = work_queue.PopFirst();
116 work_queue.PushBack(dependency);
|
| /ndk/sources/android/crazy_linker/src/ |
| crazy_linker_library_list.cpp | 88 Vector<LibraryView*> work_queue;
91 work_queue.PushBack(from);
93 while (!work_queue.IsEmpty()) {
94 LibraryView* lib = work_queue.PopFirst();
114 work_queue.PushBack(dependency);
|
| /external/llvm/utils/ |
| llvm-compilers-check | 255 def __init__(self, work_queue, jobs,
259 self.work_queue = work_queue
274 source, build = self.work_queue.get()
279 self.work_queue.task_done()
595 work_queue = queue.Queue()
611 builder = Builder(work_queue, jobs,
619 work_queue.put((source, build))
621 work_queue.join()
|
