| /external/chromium_org/media/base/ |
| D | decoder_buffer_queue_unittest.cc | 29 DecoderBufferQueue queue; in TEST() local
30 EXPECT_TRUE(queue.IsEmpty()); in TEST()
32 queue.Push(CreateBuffer(0)); in TEST()
33 EXPECT_FALSE(queue.IsEmpty()); in TEST()
37 DecoderBufferQueue queue; in TEST() local
38 queue.Push(CreateBuffer(0)); in TEST()
39 queue.Push(CreateBuffer(1)); in TEST()
40 EXPECT_FALSE(queue.IsEmpty()); in TEST()
41 EXPECT_EQ(1, queue.Duration().InSeconds()); in TEST()
43 queue.Clear(); in TEST()
[all …]
|
| /external/chromium/base/synchronization/ |
| D | condition_variable_unittest.cc | 194 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/chromium_org/media/midi/ |
| D | midi_message_queue_unittest.cc | 31 void Add(MIDIMessageQueue* queue, const T(&array)[N]) { in Add() argument
32 queue->Add(array, N); in Add()
58 MIDIMessageQueue queue(false); in TEST() local
60 queue.Get(&message); in TEST()
65 MIDIMessageQueue queue(false); in TEST() local
66 Add(&queue, kGMOn); in TEST()
67 Add(&queue, kBrokenData1); in TEST()
68 Add(&queue, kNoteOnWithRunningStatus); in TEST()
69 Add(&queue, kBrokenData2); in TEST()
70 Add(&queue, kChannelPressureWithRunningStatus); in TEST()
[all …]
|
| /external/chromium_org/chrome/browser/chromeos/drive/ |
| D | job_queue_unittest.cc | 17 JobQueue queue(kNumMaxConcurrentJobs, kNumPriorityLevels); in TEST() local
18 EXPECT_EQ(0U, queue.GetNumberOfJobs()); in TEST()
21 queue.Push(101, LOW_PRIORITY); in TEST()
22 queue.Push(102, HIGH_PRIORITY); in TEST()
23 queue.Push(103, LOW_PRIORITY); in TEST()
24 queue.Push(104, HIGH_PRIORITY); in TEST()
28 EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); in TEST()
30 EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); in TEST()
34 EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id)); in TEST()
38 EXPECT_FALSE(queue.PopForRun(LOW_PRIORITY, &id)); in TEST()
[all …]
|
| /external/chromium_org/base/synchronization/ |
| D | condition_variable_unittest.cc | 255 WorkQueue queue(kThreadCount); // Start the threads. in TEST_F() local
262 base::AutoLock auto_lock(*queue.lock()); in TEST_F()
263 while (!queue.EveryIdWasAllocated()) in TEST_F()
264 queue.all_threads_have_ids()->Wait(); in TEST_F()
269 queue.SpinUntilAllThreadsAreWaiting(); in TEST_F()
273 base::AutoLock auto_lock(*queue.lock()); in TEST_F()
274 EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments()); in TEST_F()
275 EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks()); in TEST_F()
276 EXPECT_EQ(0, queue.task_count()); in TEST_F()
277 EXPECT_EQ(0, queue.GetMaxCompletionsByWorkerThread()); in TEST_F()
[all …]
|
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| D | atomicops_unittest.cc | 47 talk_base::FixedSizeLockFreeQueue<int> queue; in TEST() local
48 EXPECT_EQ(0u, queue.capacity()); in TEST()
49 EXPECT_EQ(0u, queue.Size()); in TEST()
50 EXPECT_FALSE(queue.PushBack(1)); in TEST()
52 EXPECT_FALSE(queue.PopFront(&val)); in TEST()
56 talk_base::FixedSizeLockFreeQueue<int> queue(5); in TEST() local
57 EXPECT_EQ(5u, queue.capacity()); in TEST()
58 EXPECT_EQ(0u, queue.Size()); in TEST()
60 EXPECT_FALSE(queue.PopFront(&val)); in TEST()
64 talk_base::FixedSizeLockFreeQueue<int> queue(2); in TEST() local
[all …]
|
| /external/antlr/antlr-3.4/runtime/ObjC/Framework/test/runtime/misc/ |
| D | ANTLRFastQueueTest.m | 18 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/ |
| D | queue.c | 29 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/ |
| D | AbstractQueueTest.java | 29 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 …]
|
| D | PriorityQueueTest.java | 194 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/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v4/ |
| 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);
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/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v6/ |
| 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);
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/ |
| 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);
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/chromium_org/v8/benchmarks/ |
| 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);
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/chromium_org/third_party/WebKit/PerformanceTests/SunSpider/tests/v8-v5/ |
| 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);
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/chromium_org/chrome/browser/sync_file_system/drive_backend_v1/ |
| D | origin_operation_queue_unittest.cc | 15 OriginOperationQueue* queue) { in PopAndVerify() argument
16 ASSERT_FALSE(queue->empty()); in PopAndVerify()
18 op = queue->Pop(); in PopAndVerify()
28 OriginOperationQueue queue; in TEST() local
30 queue.Push(origin1, OriginOperation::REGISTERING); in TEST()
31 queue.Push(origin2, OriginOperation::DISABLING); in TEST()
32 queue.Push(origin1, OriginOperation::UNINSTALLING); in TEST()
34 ASSERT_EQ(3U, queue.size()); in TEST()
35 ASSERT_TRUE(queue.HasPendingOperation(origin1)); in TEST()
36 ASSERT_TRUE(queue.HasPendingOperation(origin2)); in TEST()
[all …]
|
| /external/chromium_org/chrome/browser/extensions/api/identity/ |
| D | identity_mint_queue_unittest.cc | 34 IdentityMintRequestQueue queue; in TEST() local
40 queue.RequestStart(type, *key, &request1); in TEST()
41 queue.RequestComplete(type, *key, &request1); in TEST()
44 queue.RequestStart(type, *key, &request2); in TEST()
45 queue.RequestComplete(type, *key, &request2); in TEST()
51 IdentityMintRequestQueue queue; in TEST() local
56 queue.RequestStart(type, *key, &request1); in TEST()
57 queue.RequestComplete(type, *key, &request1); in TEST()
63 IdentityMintRequestQueue queue; in TEST() local
70 queue.RequestStart(type, *key, &request1); in TEST()
[all …]
|
| /external/chromium/base/ |
| D | task_queue_unittest.cc | 41 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/mesa3d/src/gallium/drivers/llvmpipe/ |
| D | lp_scene_queue.c | 62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); in lp_scene_queue_create() local
63 if (queue == NULL) in lp_scene_queue_create()
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE * in lp_scene_queue_create()
68 if (queue->ring == NULL) in lp_scene_queue_create()
71 return queue; in lp_scene_queue_create()
74 FREE(queue); in lp_scene_queue_create()
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy() argument
83 util_ringbuffer_destroy(queue->ring); in lp_scene_queue_destroy()
84 FREE(queue); in lp_scene_queue_destroy()
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue() argument
[all …]
|
| /external/chromium_org/third_party/mesa/src/src/gallium/drivers/llvmpipe/ |
| D | lp_scene_queue.c | 62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); in lp_scene_queue_create() local
63 if (queue == NULL) in lp_scene_queue_create()
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE * in lp_scene_queue_create()
68 if (queue->ring == NULL) in lp_scene_queue_create()
71 return queue; in lp_scene_queue_create()
74 FREE(queue); in lp_scene_queue_create()
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) in lp_scene_queue_destroy() argument
83 util_ringbuffer_destroy(queue->ring); in lp_scene_queue_destroy()
84 FREE(queue); in lp_scene_queue_destroy()
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) in lp_scene_dequeue() argument
[all …]
|
| /external/chromium_org/third_party/mesa/src/src/gallium/drivers/svga/ |
| D | svga_state_tss.c | 77 struct bind_queue queue; in update_tss_binding() local
79 queue.bind_count = 0; in update_tss_binding()
123 queue.bind[queue.bind_count].unit = i; in update_tss_binding()
124 queue.bind[queue.bind_count].view = view; in update_tss_binding()
125 queue.bind_count++; in update_tss_binding()
134 if (queue.bind_count) { in update_tss_binding()
139 queue.bind_count ) != PIPE_OK) in update_tss_binding()
142 for (i = 0; i < queue.bind_count; i++) { in update_tss_binding()
145 ts[i].stage = queue.bind[i].unit; in update_tss_binding()
148 if (queue.bind[i].view->v) { in update_tss_binding()
[all …]
|
| /external/mesa3d/src/gallium/drivers/svga/ |
| D | svga_state_tss.c | 77 struct bind_queue queue; in update_tss_binding() local
79 queue.bind_count = 0; in update_tss_binding()
123 queue.bind[queue.bind_count].unit = i; in update_tss_binding()
124 queue.bind[queue.bind_count].view = view; in update_tss_binding()
125 queue.bind_count++; in update_tss_binding()
134 if (queue.bind_count) { in update_tss_binding()
139 queue.bind_count ) != PIPE_OK) in update_tss_binding()
142 for (i = 0; i < queue.bind_count; i++) { in update_tss_binding()
145 ts[i].stage = queue.bind[i].unit; in update_tss_binding()
148 if (queue.bind[i].view->v) { in update_tss_binding()
[all …]
|
| /external/chromium_org/extensions/browser/ |
| D | lazy_background_task_queue_unittest.cc | 100 LazyBackgroundTaskQueue queue(profile_.get()); in TEST_F() local
104 EXPECT_FALSE(queue.ShouldEnqueueTask(profile_.get(), no_background.get())); in TEST_F()
108 EXPECT_TRUE(queue.ShouldEnqueueTask(profile_.get(), with_background.get())); in TEST_F()
124 LazyBackgroundTaskQueue queue(profile_.get()); in TEST_F() local
131 queue.AddPendingTask(profile_.get(), in TEST_F()
135 EXPECT_EQ(1u, queue.extensions_with_pending_tasks()); in TEST_F()
140 queue.AddPendingTask(profile_.get(), in TEST_F()
144 EXPECT_EQ(1u, queue.extensions_with_pending_tasks()); in TEST_F()
150 queue.AddPendingTask(profile_.get(), in TEST_F()
154 EXPECT_EQ(2u, queue.extensions_with_pending_tasks()); in TEST_F()
[all …]
|
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/common/thread/ |
| 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.take_all()
|
| /external/smack/src/org/jivesoftware/smack/ |
| D | PacketWriter.java | 46 private final BlockingQueue<Packet> queue; field in PacketWriter
55 this.queue = new ArrayBlockingQueue<Packet>(500, true); in PacketWriter()
89 queue.put(packet); in sendPacket()
95 synchronized (queue) { in sendPacket()
96 queue.notifyAll(); in sendPacket()
124 synchronized (queue) { in shutdown()
125 queue.notifyAll(); in shutdown()
148 while (!done && (packet = queue.poll()) == null) { in nextPacket()
150 synchronized (queue) { in nextPacket()
151 queue.wait(); in nextPacket()
[all …]
|