/external/stlport/test/unit/ |
H A D | queue_header_test.cpp | 8 #include <queue>
|
/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)
|
H A D | releasepatch.py | 43 # 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 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...] |
H A D | queuestest.py | 40 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 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...] |
/external/compiler-rt/lib/tsan/output_tests/ |
H A D | static_init3.cc | 17 _Atomic(Cache*) queue; 21 __c11_atomic_store(&queue, c, 0); 28 c = __c11_atomic_load(&queue, 0);
|