/external/stlport/test/unit/ |
H A D | queue_header_test.cpp | 8 #include <queue>
|
/external/bluetooth/glib/glib/ |
H A D | gqueue.c | 4 * 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 D | gqueue.h | 52 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 D | gasyncqueue.h | 47 /* 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 D | queue.c | 27 #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 D | queue.h | 43 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 D | FinalizablePhantomReference.java | 38 * @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 D | FinalizableSoftReference.java | 36 * @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 D | FinalizableWeakReference.java | 36 * @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 D | queuepropertymixin.py | 36 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 D | threadedmessagequeue_unittest.py | 36 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 D | messagepump_unittest.py | 53 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 D | condition_variable_unittest.cc | 194 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 D | AbstractQueueTest.java | 29 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 D | statusbubble.py | 40 _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 D | queuestatus.py | 40 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 D | dashboard.py | 41 _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 D | submittoews.py | 41 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 D | statusbubble_unittest.py | 40 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 D | queues_unittest.py | 47 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 D | task_queue_unittest.cc | 38 // 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 D | richards.js | 51 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 D | v8-richards.js | 46 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 D | v8-richards.js | 46 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 D | v8-richards.js | 46 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...] |