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

1234567891011>>

/external/stlport/test/unit/
H A Dqueue_header_test.cpp8 #include <queue>
/external/bluetooth/glib/glib/
H A Dgqueue.c4 * GQueue: Double ended queue implementation, piggy backed on GList.
47 * @queue: a #GQueue.
50 * @queue was created with g_queue_new(). If queue elements contain
54 g_queue_free (GQueue *queue) argument
56 g_return_if_fail (queue != NULL);
58 g_list_free (queue->head);
59 g_slice_free (GQueue, queue);
64 * @queue: an uninitialized #GQueue
74 g_queue_init (GQueue *queue) argument
92 g_queue_clear(GQueue *queue) argument
109 g_queue_is_empty(GQueue *queue) argument
127 g_queue_get_length(GQueue *queue) argument
143 g_queue_reverse(GQueue *queue) argument
164 g_queue_copy(GQueue *queue) argument
191 g_queue_foreach(GQueue *queue, GFunc func, gpointer user_data) argument
221 g_queue_find(GQueue *queue, gconstpointer data) argument
247 g_queue_find_custom(GQueue *queue, gconstpointer data, GCompareFunc func) argument
271 g_queue_sort(GQueue *queue, GCompareDataFunc compare_func, gpointer user_data) argument
290 g_queue_push_head(GQueue *queue, gpointer data) argument
314 g_queue_push_nth(GQueue *queue, gpointer data, gint n) argument
338 g_queue_push_head_link(GQueue *queue, GList *link) argument
363 g_queue_push_tail(GQueue *queue, gpointer data) argument
385 g_queue_push_tail_link(GQueue *queue, GList *link) argument
415 g_queue_push_nth_link(GQueue *queue, gint n, GList *link_) argument
463 g_queue_pop_head(GQueue *queue) argument
496 g_queue_pop_head_link(GQueue *queue) argument
531 g_queue_peek_head_link(GQueue *queue) argument
549 g_queue_peek_tail_link(GQueue *queue) argument
566 g_queue_pop_tail(GQueue *queue) argument
601 g_queue_pop_nth(GQueue *queue, guint n) argument
630 g_queue_pop_tail_link(GQueue *queue) argument
666 g_queue_pop_nth_link(GQueue *queue, guint n) argument
695 g_queue_peek_nth_link(GQueue *queue, guint n) argument
737 g_queue_link_index(GQueue *queue, GList *link_) argument
758 g_queue_unlink(GQueue *queue, GList *link_) argument
783 g_queue_delete_link(GQueue *queue, GList *link_) argument
803 g_queue_peek_head(GQueue *queue) argument
820 g_queue_peek_tail(GQueue *queue) argument
840 g_queue_peek_nth(GQueue *queue, guint n) argument
867 g_queue_index(GQueue *queue, gconstpointer data) argument
885 g_queue_remove(GQueue *queue, gconstpointer data) argument
908 g_queue_remove_all(GQueue *queue, gconstpointer data) argument
940 g_queue_insert_before(GQueue *queue, GList *sibling, gpointer data) argument
964 g_queue_insert_after(GQueue *queue, GList *sibling, gpointer data) argument
993 g_queue_insert_sorted(GQueue *queue, gpointer data, GCompareDataFunc func, gpointer user_data) argument
[all...]
H A Dgqueue.h52 void g_queue_free (GQueue *queue);
53 void g_queue_init (GQueue *queue);
54 void g_queue_clear (GQueue *queue);
55 gboolean g_queue_is_empty (GQueue *queue);
56 guint g_queue_get_length (GQueue *queue);
57 void g_queue_reverse (GQueue *queue);
58 GQueue * g_queue_copy (GQueue *queue);
59 void g_queue_foreach (GQueue *queue,
62 GList * g_queue_find (GQueue *queue,
64 GList * g_queue_find_custom (GQueue *queue,
[all...]
H A Dgasyncqueue.h47 /* Lock and unlock a GAsyncQueue. All functions lock the queue for
49 * thus you lock the queue, call the *_unlocked functions and unlock it again.
51 void g_async_queue_lock (GAsyncQueue *queue);
52 void g_async_queue_unlock (GAsyncQueue *queue);
55 GAsyncQueue* g_async_queue_ref (GAsyncQueue *queue);
56 void g_async_queue_unref (GAsyncQueue *queue);
60 void g_async_queue_ref_unlocked (GAsyncQueue *queue);
61 void g_async_queue_unref_and_unlock (GAsyncQueue *queue);
64 /* Push data into the async queue. Must not be NULL. */
65 void g_async_queue_push (GAsyncQueue *queue,
[all...]
/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)
/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...]
/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...]

Completed in 815 milliseconds

1234567891011>>