Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 452) sorted by relevance

12345678910>>...19

/external/chromium/base/synchronization/
Dcondition_variable_unittest.cc194 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F() local
201 base::AutoLock auto_lock(*queue.lock()); in TEST_F()
202 while (!queue.EveryIdWasAllocated()) in TEST_F()
203 queue.all_threads_have_ids()->Wait(); in TEST_F()
208 queue.SpinUntilAllThreadsAreWaiting(); in TEST_F()
212 base::AutoLock auto_lock(*queue.lock()); in TEST_F()
213 EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments()); in TEST_F()
214 EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks()); in TEST_F()
215 EXPECT_EQ(0, queue.task_count()); in TEST_F()
216 EXPECT_EQ(0, queue.GetMaxCompletionsByWorkerThread()); in TEST_F()
[all …]
/external/antlr/antlr-3.4/runtime/ObjC/Framework/test/runtime/misc/
DANTLRFastQueueTest.m18 ANTLRFastQueue *queue = [[ANTLRFastQueue newANTLRFastQueue] retain];
19 STAssertNotNil(queue, @"Queue was not created and was nil");
20 [queue release];
25 ANTLRFastQueue *queue = [[ANTLRFastQueue newANTLRFastQueue] retain];
26 STAssertNotNil(queue, @"Queue was not created and was nil");
27 [queue addObject:@"My String"];
28 …STAssertTrue([[queue objectAtIndex:0] isKindOfClass:[NSString class]], @"First object is not a NSS…
29 STAssertEquals([queue objectAtIndex:0], @"My String", @"Object at index zero is invalid");
30 STAssertTrue([queue size] == 1, @"Queue is the wrong size: %d", [queue size]);
31 [queue release];
[all …]
/external/dropbear/
Dqueue.c29 void initqueue(struct Queue* queue) { in initqueue() argument
31 queue->head = NULL; in initqueue()
32 queue->tail = NULL; in initqueue()
33 queue->count = 0; in initqueue()
36 int isempty(struct Queue* queue) { in isempty() argument
38 return (queue->head == NULL); in isempty()
41 void* dequeue(struct Queue* queue) { in dequeue() argument
45 dropbear_assert(!isempty(queue)); in dequeue()
47 ret = queue->head->item; in dequeue()
48 oldhead = queue->head; in dequeue()
[all …]
/external/apache-harmony/luni/src/test/api/common/org/apache/harmony/luni/tests/java/util/
DAbstractQueueTest.java29 private MockAbstractQueue<Object> queue; field in AbstractQueueTest
111 queue.add(null); in test_addLE_null()
125 queue.add(o); in test_addLE_Full()
129 queue.add(o); in test_addLE_Full()
143 queue.add(o); in test_addLE()
146 queue.add(I); in test_addLE()
147 assertTrue(queue.contains(I)); in test_addLE()
148 Iterator iter = queue.iterator(); in test_addLE()
160 queue.addAll(null); in test_addAllLE_null()
173 queue.addAll(list); in test_addAllLE_with_null()
[all …]
DPriorityQueueTest.java194 PriorityQueue<Object> queue = new PriorityQueue<Object>(); in test_Constructor() local
195 assertNotNull(queue); in test_Constructor()
196 assertEquals(0, queue.size()); in test_Constructor()
197 assertNull(queue.comparator()); in test_Constructor()
204 PriorityQueue<Object> queue = new PriorityQueue<Object>(100); in test_ConstructorI() local
205 assertNotNull(queue); in test_ConstructorI()
206 assertEquals(0, queue.size()); in test_ConstructorI()
207 assertNull(queue.comparator()); in test_ConstructorI()
214 PriorityQueue<Object> queue = new PriorityQueue<Object>(100, in test_ConstructorILjava_util_Comparator() local
216 assertNotNull(queue); in test_ConstructorILjava_util_Comparator()
[all …]
/external/webkit/Tools/Scripts/webkitpy/tool/commands/
Dqueues_unittest.py63 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._options = Mock()
86 queue._options.iterations = 3
87 self.assertTrue(queue.should_continue_work_queue())
88 self.assertTrue(queue.should_continue_work_queue())
[all …]
Dqueuestest.py40 def __init__(self, name, queue, wakeup_event): argument
67 …def assert_queue_outputs(self, queue, args=None, work_item=None, expected_stdout=None, expected_st… argument
86 queue.execute(options, args, tool, engine=MockQueueEngine)
88 …self.assert_outputs(queue.queue_log_path, "queue_log_path", [], expected_stdout, expected_stderr, …
89 …self.assert_outputs(queue.work_item_log_path, "work_item_log_path", [work_item], expected_stdout, …
90 …self.assert_outputs(queue.begin_work_queue, "begin_work_queue", [], expected_stdout, expected_stde…
91 …self.assert_outputs(queue.should_continue_work_queue, "should_continue_work_queue", [], expected_s…
92 …self.assert_outputs(queue.next_work_item, "next_work_item", [], expected_stdout, expected_stderr, …
93 …self.assert_outputs(queue.should_proceed_with_work_item, "should_proceed_with_work_item", [work_it…
94 …self.assert_outputs(queue.process_work_item, "process_work_item", [work_item], expected_stdout, ex…
[all …]
Dearlywarningsystem_unittest.py45 queue = TestEWS()
46 queue.bind_to_tool(MockTool(log_executive=True))
47 queue._options = MockOptions(port=None)
49 OutputCapture().assert_outputs(self, queue._can_build, [], expected_stderr=expected_stderr)
54 queue.run_webkit_patch = mock_run_webkit_patch
56 OutputCapture().assert_outputs(self, queue._can_build, [], expected_stderr=expected_stderr)
60 queue = AbstractReviewQueue()
61 queue.bind_to_tool(MockTool())
66 queue.review_patch = mock_review_patch
67 mock_patch = queue._tool.bugs.fetch_attachment(197)
[all …]
/external/webkit/PerformanceTests/SunSpider/tests/v8-v6/
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);
55 queue = new Packet(null, ID_DEVICE_B, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
[all …]
/external/webkit/PerformanceTests/SunSpider/tests/v8-v4/
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);
55 queue = new Packet(null, ID_DEVICE_B, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
[all …]
/external/v8/benchmarks/
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);
60 queue = new Packet(null, ID_DEVICE_B, KIND_DEVICE);
61 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
62 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
[all …]
/external/webkit/PerformanceTests/SunSpider/tests/v8-v5/
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);
55 queue = new Packet(null, ID_DEVICE_B, KIND_DEVICE);
56 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
57 queue = new Packet(queue, ID_DEVICE_B, KIND_DEVICE);
[all …]
/external/webkit/Tools/QueueStatusServer/handlers/
Dqueuestatus.py40 def _rows_for_work_items(self, queue): argument
41 queued_items = queue.work_items()
42 active_items = queue.active_work_items()
60 def _fetch_statuses(self, queue, bot_id): argument
62 statuses.filter("queue_name =", queue.name())
67 def _fetch_last_message_matching(self, queue, bot_id, message): argument
69 statuses.filter("queue_name =", queue.name())
75 def _fetch_trailing_days_pass_count(self, queue, bot_id, days): argument
77 statuses.filter("queue_name =", queue.name())
85 def _page_title(self, queue, bot_id): argument
[all …]
Dstatusbubble.py40 _queues_to_display = [queue for queue in Queue.all() if queue.is_ews()]
42 def _build_bubble(self, queue, attachment): argument
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]
/external/chromium/base/
Dtask_queue_unittest.cc41 TaskQueuerTask(TaskQueue* queue, Task* task_to_queue) in TaskQueuerTask() argument
42 : queue_(queue), in TaskQueuerTask()
60 TaskQueue queue; in TEST() local
61 EXPECT_TRUE(queue.IsEmpty()); in TEST()
63 queue.Run(); in TEST()
64 EXPECT_TRUE(queue.IsEmpty()); in TEST()
68 TaskQueue queue; in TEST() local
72 queue.Push(new TrackCallsTask(&ran_task1, &deleted_task1)); in TEST()
76 queue.Push(new TrackCallsTask(&ran_task2, &deleted_task2)); in TEST()
78 queue.Run(); in TEST()
[all …]
/external/webkit/Source/WebKit2/Platform/win/
DWorkQueueWin.cpp32 inline WorkQueue::WorkItemWin::WorkItemWin(PassOwnPtr<WorkItem> item, WorkQueue* queue) in WorkItemWin() argument
34 , m_queue(queue) in WorkItemWin()
38 …WorkQueue::WorkItemWin> WorkQueue::WorkItemWin::create(PassOwnPtr<WorkItem> item, WorkQueue* queue) in create() argument
40 return adoptRef(new WorkItemWin(item, queue)); in create()
47 …rkQueue::HandleWorkItem::HandleWorkItem(HANDLE handle, PassOwnPtr<WorkItem> item, WorkQueue* queue) in HandleWorkItem() argument
48 : WorkItemWin(item, queue) in HandleWorkItem()
55 …:HandleWorkItem::createByAdoptingHandle(HANDLE handle, PassOwnPtr<WorkItem> item, WorkQueue* queue) in createByAdoptingHandle() argument
57 return adoptRef(new HandleWorkItem(handle, item, queue)); in createByAdoptingHandle()
71 WorkQueue* queue = item->queue(); in handleCallback() local
74 MutexLocker lock(queue->m_workItemQueueLock); in handleCallback()
[all …]
/external/webkit/Tools/Scripts/webkitpy/common/thread/
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.take_all()
/external/chromium/chrome/browser/net/
Dpredictor_unittest.cc496 Predictor::HostNameQueue queue; in TEST_F() local
501 EXPECT_TRUE(queue.IsEmpty()); in TEST_F()
502 queue.Push(first, UrlInfo::LEARNED_REFERAL_MOTIVATED); in TEST_F()
503 EXPECT_FALSE(queue.IsEmpty()); in TEST_F()
504 queue.Push(second, UrlInfo::MOUSE_OVER_MOTIVATED); in TEST_F()
505 EXPECT_FALSE(queue.IsEmpty()); in TEST_F()
506 EXPECT_EQ(queue.Pop(), first); in TEST_F()
507 EXPECT_FALSE(queue.IsEmpty()); in TEST_F()
508 EXPECT_EQ(queue.Pop(), second); in TEST_F()
509 EXPECT_TRUE(queue.IsEmpty()); in TEST_F()
[all …]
/external/chromium/base/threading/
Dthread_collision_warner_unittest.cc151 explicit QueueUser(NonThreadSafeQueue& queue) in TEST() argument
152 : queue_(queue) {} in TEST()
165 NonThreadSafeQueue queue(local_reporter); in TEST() local
167 QueueUser queue_user_a(queue); in TEST()
168 QueueUser queue_user_b(queue); in TEST()
209 explicit QueueUser(NonThreadSafeQueue& queue) in TEST() argument
210 : queue_(queue) {} in TEST()
223 NonThreadSafeQueue queue(local_reporter); in TEST() local
225 QueueUser queue_user_a(queue); in TEST()
226 QueueUser queue_user_b(queue); in TEST()
[all …]
/external/guava/guava-tests/test/com/google/common/collect/
DMinMaxPriorityQueueTest.java52 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_simple() local
54 assertEquals(11, queue.capacity()); in testCreation_simple()
55 checkUnbounded(queue); in testCreation_simple()
56 checkNatural(queue); in testCreation_simple()
60 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_comparator() local
63 assertEquals(11, queue.capacity()); in testCreation_comparator()
64 checkUnbounded(queue); in testCreation_comparator()
65 assertSame(SOME_COMPARATOR, queue.comparator()); in testCreation_comparator()
69 MinMaxPriorityQueue<Integer> queue = MinMaxPriorityQueue in testCreation_expectedSize() local
72 assertEquals(8, queue.capacity()); in testCreation_expectedSize()
[all …]
/external/javassist/src/main/javassist/bytecode/analysis/
DAnalyzer.java133 IntQueue queue = new IntQueue(); in analyze() local
141 queue.add(iter.next()); in analyze()
142 while (!queue.isEmpty()) { in analyze()
143 analyzeNextEntry(method, iter, queue, executor); in analyze()
168 IntQueue queue, Executor executor) throws BadBytecode { in analyzeNextEntry() argument
169 int pos = queue.take(); in analyzeNextEntry()
185 mergeTableSwitch(queue, pos, iter, frame); in analyzeNextEntry()
187 mergeLookupSwitch(queue, pos, iter, frame); in analyzeNextEntry()
189 mergeRet(queue, iter, pos, frame, subroutine); in analyzeNextEntry()
195 mergeJsr(queue, frames[pos], subroutines[target], pos, lookAhead(iter, pos)); in analyzeNextEntry()
[all …]
/external/openfst/src/include/fst/script/
Dshortest-path.h72 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
75 queue, ArcFilter(), opts.nshortest, opts.unique, in ShortestPath()
79 delete queue; in ShortestPath() local
84 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
87 queue, ArcFilter(), opts.nshortest, opts.unique, in ShortestPath()
91 delete queue; in ShortestPath() local
96 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
99 queue, ArcFilter(), opts.nshortest, opts.unique, in ShortestPath()
103 delete queue; in ShortestPath() local
108 Queue *queue = QueueConstructor<Queue, Arc, in ShortestPath() local
[all …]
/external/compiler-rt/lib/asan/tests/
Dasan_mac_test.mm85 dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
90 dispatch_async(queue, block);
96 dispatch_queue_t queue = dispatch_get_global_queue(2, 0);
101 dispatch_sync(queue, block);
109 dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
113 dispatch_async(queue, block_alloc);
115 dispatch_async(queue, block_crash);
122 dispatch_queue_t queue[4];
123 queue[0] = dispatch_get_global_queue(2, 0);
124 queue[1] = dispatch_get_global_queue(0, 0);
[all …]
/external/guava/guava/src/com/google/common/collect/
DQueues.java80 ConcurrentLinkedQueue<E> queue = new ConcurrentLinkedQueue<E>(); in newConcurrentLinkedQueue() local
81 Iterables.addAll(queue, elements); in newConcurrentLinkedQueue()
82 return queue; in newConcurrentLinkedQueue()
119 LinkedBlockingQueue<E> queue = new LinkedBlockingQueue<E>(); in newLinkedBlockingQueue() local
120 Iterables.addAll(queue, elements); in newLinkedBlockingQueue()
121 return queue; in newLinkedBlockingQueue()
148 PriorityBlockingQueue<E> queue = new PriorityBlockingQueue<E>(); in newPriorityBlockingQueue() local
149 Iterables.addAll(queue, elements); in newPriorityBlockingQueue()
150 return queue; in newPriorityBlockingQueue()
174 PriorityQueue<E> queue = new PriorityQueue<E>(); in newPriorityQueue() local
[all …]
/external/libppp/src/
Dlink.c97 struct mqueue *queue, *highest; in link_SequenceQueue() local
102 for (queue = l->Queue; queue < highest; queue++) in link_SequenceQueue()
103 while (queue->len) in link_SequenceQueue()
104 m_enqueue(highest, m_dequeue(queue)); in link_SequenceQueue()
110 struct mqueue *queue, *highest; in link_DeleteQueue() local
113 for (queue = l->Queue; queue <= highest; queue++) in link_DeleteQueue()
114 while (queue->top) in link_DeleteQueue()
115 m_freem(m_dequeue(queue)); in link_DeleteQueue()
153 struct mqueue *queue, *highest; in link_PendingLowPriorityData() local
170 for (queue = l->Queue; queue < highest; queue++) { in link_PendingLowPriorityData()
[all …]

12345678910>>...19