Searched refs:queue (Results 1 - 25 of 404) sorted by relevance

1234567891011>>

/external/stlport/test/unit/
H A Dqueue_header_test.cpp8 #include <queue>
/external/dropbear/
H A Dqueue.c27 #include "queue.h"
29 void initqueue(struct Queue* queue) { argument
31 queue->head = NULL;
32 queue->tail = NULL;
33 queue->count = 0;
36 int isempty(struct Queue* queue) { argument
38 return (queue->head == NULL);
41 void* dequeue(struct Queue* queue) { argument
45 dropbear_assert(!isempty(queue));
47 ret = queue
63 examine(struct Queue* queue) argument
69 enqueue(struct Queue* queue, void* item) argument
[all...]
H A Dqueue.h43 void initqueue(struct Queue* queue);
44 int isempty(struct Queue* queue);
45 void* dequeue(struct Queue* queue);
46 void *examine(struct Queue* queue);
47 void enqueue(struct Queue* queue, void* item);
/external/guava/guava/src/com/google/common/base/
H A DFinalizablePhantomReference.java38 * @param queue that should finalize the referent
40 protected FinalizablePhantomReference(T referent, FinalizableReferenceQueue queue) { argument
41 super(referent, queue.queue);
42 queue.cleanUp();
H A DFinalizableSoftReference.java36 * @param queue that should finalize the referent
38 protected FinalizableSoftReference(T referent, FinalizableReferenceQueue queue) { argument
39 super(referent, queue.queue);
40 queue.cleanUp();
H A DFinalizableWeakReference.java36 * @param queue that should finalize the referent
38 protected FinalizableWeakReference(T referent, FinalizableReferenceQueue queue) { argument
39 super(referent, queue.queue);
40 queue.cleanUp();
/external/webkit/Tools/QueueStatusServer/model/
H A Dqueuepropertymixin.py36 def _queue_setter(self, queue):
37 self.queue_name = queue.name() if queue else None
39 queue = property(_queue_getter, _queue_setter) variable in class:QueuePropertyMixin
/external/webkit/Tools/Scripts/webkitpy/common/thread/
H A Dthreadedmessagequeue_unittest.py36 queue = ThreadedMessageQueue()
37 queue.post("Hello")
38 queue.post("There")
39 (messages, is_running) = queue.take_all()
42 (messages, is_running) = queue.take_all()
45 queue.post("More")
46 queue.stop()
47 queue.post("Messages")
48 (messages, is_running) = queue.take_all()
51 (messages, is_running) = queue
[all...]
H A Dmessagepump_unittest.py53 queue = ThreadedMessageQueue()
55 pump = MessagePump(delegate, queue)
60 queue.post("Hello")
61 queue.post("There")
70 queue.post("More")
71 queue.post("Messages")
72 queue.stop()
/external/chromium/base/synchronization/
H A Dcondition_variable_unittest.cc194 WorkQueue queue(kThreadCount); // Start the threads.
201 base::AutoLock auto_lock(*queue.lock());
202 while (!queue.EveryIdWasAllocated())
203 queue.all_threads_have_ids()->Wait();
208 queue.SpinUntilAllThreadsAreWaiting();
212 base::AutoLock auto_lock(*queue.lock());
213 EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments());
214 EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks());
215 EXPECT_EQ(0, queue.task_count());
216 EXPECT_EQ(0, queue
[all...]
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/util/
H A DAbstractQueueTest.java29 private MockAbstractQueue<Object> queue; field in class:AbstractQueueTest
111 queue.add(null);
125 queue.add(o);
129 queue.add(o);
143 queue.add(o);
146 queue.add(I);
147 assertTrue(queue.contains(I));
148 Iterator iter = queue.iterator();
160 queue.addAll(null);
173 queue
[all...]
/external/webkit/Tools/QueueStatusServer/handlers/
H A Dstatusbubble.py40 _queues_to_display = [queue for queue in Queue.all() if queue.is_ews()]
42 def _build_bubble(self, queue, attachment):
43 queue_status = attachment.status_for_queue(queue)
45 "name": queue.short_name().lower(),
47 "queue_position": attachment.position_in_queue(queue),
55 bubbles = [self._build_bubble(queue, attachment) for queue in self._queues_to_display]
H A Dqueuestatus.py40 def _rows_for_work_items(self, queue):
41 queued_items = queue.work_items()
42 active_items = queue.active_work_items()
60 def _fetch_statuses(self, queue, bot_id):
62 statuses.filter("queue_name =", queue.name())
67 def _fetch_last_message_matching(self, queue, bot_id, message):
69 statuses.filter("queue_name =", queue.name())
75 def _fetch_trailing_days_pass_count(self, queue, bot_id, days):
77 statuses.filter("queue_name =", queue.name())
85 def _page_title(self, queue, bot_i
[all...]
H A Ddashboard.py41 _header_names = [queue.short_name() for queue in _ordered_queues]
43 def _build_bubble(self, attachment, queue):
44 queue_status = attachment.status_for_queue(queue)
55 "bubbles": [self._build_bubble(attachment, queue) for queue in self._ordered_queues],
H A Dsubmittoews.py41 def _should_add_to_ews_queue(self, queue, attachment):
42 # This assert() is here to make sure we're not submitting to the commit-queue.
43 # The commit-queue clients check each patch anyway, but there is not sense
44 # in adding things to the commit-queue when they won't be processed by it.
45 assert(queue.is_ews())
46 latest_status = attachment.status_for_queue(queue)
50 # This allows us to restart the EWS feeder queue, without all r? patches
57 for queue in Queue.all_ews(): # all_ews() currently includes the style-queue
58 if self._should_add_to_ews_queue(queue, attachmen
[all...]
H A Dstatusbubble_unittest.py40 def status_for_queue(self, queue):
43 def position_in_queue(self, queue):
50 queue = Queue("mac-ews")
52 bubble_dict = bubble._build_bubble(queue, attachment)
H A Dreleasepatch.py43 # FIXME: This queue lookup should be shared between handlers.
44 queue = Queue.queue_with_name(queue_name)
45 if not queue:
51 last_status = attachment.status_for_queue(queue)
56 # Only remove it from the queue if the last message is not a retry request.
57 # Allow removing it from the queue even if there is no last_status for easier testing.
59 queue.work_items().remove_work_item(attachment_id)
62 queue.active_work_items().expire_item(attachment_id)
/external/webkit/Tools/Scripts/webkitpy/tool/commands/
H A Dqueues_unittest.py47 name = "test-queue"
51 name = "test-review-queue"
60 self.assertEquals(TestQueue()._log_directory(), os.path.join("..", "test-queue-logs"))
63 queue = TestQueue()
67 queue.bind_to_tool(tool)
68 queue._options = Mock()
69 queue._options.port = port
71 queue.run_webkit_patch(run_args)
84 queue = TestQueue()
85 queue
[all...]
H A Dqueuestest.py40 def __init__(self, name, queue, wakeup_event):
67 def assert_queue_outputs(self, queue, args=None, work_item=None, expected_stdout=None, expected_stderr=None, expected_exceptions=None, options=None, tool=None):
70 # This is a hack to make it easy for callers to not have to setup a custom MockFileSystem just to test the commit-queue
86 queue.execute(options, args, tool, engine=MockQueueEngine)
88 self.assert_outputs(queue.queue_log_path, "queue_log_path", [], expected_stdout, expected_stderr, expected_exceptions)
89 self.assert_outputs(queue.work_item_log_path, "work_item_log_path", [work_item], expected_stdout, expected_stderr, expected_exceptions)
90 self.assert_outputs(queue.begin_work_queue, "begin_work_queue", [], expected_stdout, expected_stderr, expected_exceptions)
91 self.assert_outputs(queue.should_continue_work_queue, "should_continue_work_queue", [], expected_stdout, expected_stderr, expected_exceptions)
92 self.assert_outputs(queue.next_work_item, "next_work_item", [], expected_stdout, expected_stderr, expected_exceptions)
93 self.assert_outputs(queue
[all...]
/external/chromium/base/
H A Dtask_queue_unittest.cc38 // Adds a given task to the queue when run.
41 TaskQueuerTask(TaskQueue* queue, Task* task_to_queue) argument
42 : queue_(queue),
60 TaskQueue queue; local
61 EXPECT_TRUE(queue.IsEmpty());
63 queue.Run();
64 EXPECT_TRUE(queue.IsEmpty());
68 TaskQueue queue; local
72 queue.Push(new TrackCallsTask(&ran_task1, &deleted_task1));
76 queue
88 TaskQueue queue; local
[all...]
/external/v8/benchmarks/
H A Drichards.js51 var queue = new Packet(null, ID_WORKER, KIND_WORK);
52 queue = new Packet(queue, ID_WORKER, KIND_WORK);
53 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
55 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
58 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
[all...]
/external/webkit/PerformanceTests/SunSpider/tests/v8-v4/
H A Dv8-richards.js46 var queue = new Packet(null, ID_WORKER, KIND_WORK);
47 queue = new Packet(queue, ID_WORKER, KIND_WORK);
48 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
50 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
51 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
52 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
53 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
[all...]
/external/webkit/PerformanceTests/SunSpider/tests/v8-v5/
H A Dv8-richards.js46 var queue = new Packet(null, ID_WORKER, KIND_WORK);
47 queue = new Packet(queue, ID_WORKER, KIND_WORK);
48 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
50 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
51 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
52 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
53 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
[all...]
/external/webkit/PerformanceTests/SunSpider/tests/v8-v6/
H A Dv8-richards.js46 var queue = new Packet(null, ID_WORKER, KIND_WORK);
47 queue = new Packet(queue, ID_WORKER, KIND_WORK);
48 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
50 queue = new Packet(null, ID_DEVICE_A, KIND_DEVICE);
51 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
52 queue = new Packet(queue, ID_DEVICE_A, KIND_DEVICE);
53 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
[all...]
/external/compiler-rt/lib/tsan/output_tests/
H A Dstatic_init3.cc17 _Atomic(Cache*) queue;
21 __c11_atomic_store(&queue, c, 0);
28 c = __c11_atomic_load(&queue, 0);

Completed in 315 milliseconds

1234567891011>>