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

1234567891011>>

/external/stlport/test/unit/
H A Dqueue_header_test.cpp8 #include <queue>
/external/chromium_org/chrome/browser/chromeos/drive/
H A Djob_queue_unittest.cc16 // Create a queue. Number of jobs are initially zero.
17 JobQueue queue(kNumMaxConcurrentJobs, kNumPriorityLevels);
18 EXPECT_EQ(0U, queue.GetNumberOfJobs());
21 queue.Push(101, LOW_PRIORITY);
22 queue.Push(102, HIGH_PRIORITY);
23 queue.Push(103, LOW_PRIORITY);
24 queue.Push(104, HIGH_PRIORITY);
28 EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id));
30 EXPECT_TRUE(queue.PopForRun(LOW_PRIORITY, &id));
34 EXPECT_TRUE(queue
[all...]
/external/chromium_org/third_party/libjingle/source/talk/base/
H A Datomicops_unittest.cc47 talk_base::FixedSizeLockFreeQueue<int> queue; local
48 EXPECT_EQ(0u, queue.capacity());
49 EXPECT_EQ(0u, queue.Size());
50 EXPECT_FALSE(queue.PushBack(1));
52 EXPECT_FALSE(queue.PopFront(&val));
56 talk_base::FixedSizeLockFreeQueue<int> queue(5);
57 EXPECT_EQ(5u, queue.capacity());
58 EXPECT_EQ(0u, queue.Size());
60 EXPECT_FALSE(queue.PopFront(&val));
64 talk_base::FixedSizeLockFreeQueue<int> queue(
[all...]
/external/chromium_org/media/base/
H A Ddecoder_buffer_queue_unittest.cc29 DecoderBufferQueue queue; local
30 EXPECT_TRUE(queue.IsEmpty());
32 queue.Push(CreateBuffer(0));
33 EXPECT_FALSE(queue.IsEmpty());
37 DecoderBufferQueue queue; local
38 queue.Push(CreateBuffer(0));
39 queue.Push(CreateBuffer(1));
40 EXPECT_FALSE(queue.IsEmpty());
41 EXPECT_EQ(1, queue.Duration().InSeconds());
43 queue
49 DecoderBufferQueue queue; local
78 DecoderBufferQueue queue; local
114 DecoderBufferQueue queue; local
[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/chromium_org/third_party/mesa/src/src/gallium/drivers/llvmpipe/
H A Dlp_scene_queue.h42 lp_scene_queue_destroy(struct lp_scene_queue *queue);
45 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait);
48 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene);
H A Dlp_scene_queue.c30 * Scene queue. We'll use two queues. One contains "full" scenes which
49 * A queue of scenes
58 /** Allocate a new scene queue */
62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); local
63 if (queue == NULL)
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE *
68 if (queue->ring == NULL)
71 return queue;
74 FREE(queue);
79 /** Delete a scene queue */
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) argument
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) argument
110 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene) argument
[all...]
/external/mesa3d/src/gallium/drivers/llvmpipe/
H A Dlp_scene_queue.h42 lp_scene_queue_destroy(struct lp_scene_queue *queue);
45 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait);
48 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene);
H A Dlp_scene_queue.c30 * Scene queue. We'll use two queues. One contains "full" scenes which
49 * A queue of scenes
58 /** Allocate a new scene queue */
62 struct lp_scene_queue *queue = CALLOC_STRUCT(lp_scene_queue); local
63 if (queue == NULL)
66 queue->ring = util_ringbuffer_create( MAX_SCENE_QUEUE *
68 if (queue->ring == NULL)
71 return queue;
74 FREE(queue);
79 /** Delete a scene queue */
81 lp_scene_queue_destroy(struct lp_scene_queue *queue) argument
90 lp_scene_dequeue(struct lp_scene_queue *queue, boolean wait) argument
110 lp_scene_enqueue(struct lp_scene_queue *queue, struct lp_scene *scene) argument
[all...]
/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/chromium_org/third_party/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...]
/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/smack/src/org/jivesoftware/smackx/workgroup/agent/
H A DQueueUsersListener.java30 * The status of the queue was updated.
32 * @param queue the workgroup queue.
33 * @param status the status of queue.
35 public void statusUpdated(WorkgroupQueue queue, WorkgroupQueue.Status status); argument
38 * The average wait time of the queue was updated.
40 * @param queue the workgroup queue.
41 * @param averageWaitTime the average wait time of the queue.
43 public void averageWaitTimeUpdated(WorkgroupQueue queue, in argument
51 oldestEntryUpdated(WorkgroupQueue queue, Date oldestEntry) argument
59 usersUpdated(WorkgroupQueue queue, Set<QueueUser> users) argument
[all...]
/external/chromium_org/base/synchronization/
H A Dcondition_variable_unittest.cc202 WorkQueue queue(kThreadCount); // Start the threads.
209 base::AutoLock auto_lock(*queue.lock());
210 while (!queue.EveryIdWasAllocated())
211 queue.all_threads_have_ids()->Wait();
216 queue.SpinUntilAllThreadsAreWaiting();
220 base::AutoLock auto_lock(*queue.lock());
221 EXPECT_EQ(0, queue.GetNumThreadsTakingAssignments());
222 EXPECT_EQ(0, queue.GetNumThreadsCompletingTasks());
223 EXPECT_EQ(0, queue.task_count());
224 EXPECT_EQ(0, 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/chromium_org/cc/test/
H A Dfake_scrollbar_layer.cc31 bool FakeScrollbarLayer::Update(ResourceUpdateQueue* queue, argument
33 size_t full = queue->FullUploadSize();
34 size_t partial = queue->PartialUploadSize();
35 bool updated = ScrollbarLayer::Update(queue, occlusion);
37 last_update_full_upload_size_ = queue->FullUploadSize() - full;
38 last_update_partial_upload_size_ = queue->PartialUploadSize() - partial;
/external/chromium_org/third_party/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/chromium_org/third_party/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/chromium_org/third_party/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...]
/external/chromium_org/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/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...]

Completed in 2638 milliseconds

1234567891011>>