/external/stlport/test/unit/ |
H A D | queue_header_test.cpp | 8 #include <queue>
|
/external/chromium_org/chrome/browser/chromeos/drive/ |
H A D | job_queue_unittest.cc | 16 // 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 D | atomicops_unittest.cc | 47 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 D | decoder_buffer_queue_unittest.cc | 29 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 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/chromium_org/third_party/mesa/src/src/gallium/drivers/llvmpipe/ |
H A D | lp_scene_queue.h | 42 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 D | lp_scene_queue.c | 30 * 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 D | lp_scene_queue.h | 42 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 D | lp_scene_queue.c | 30 * 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 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/chromium_org/third_party/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...] |
/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/smack/src/org/jivesoftware/smackx/workgroup/agent/ |
H A D | QueueUsersListener.java | 30 * 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 D | condition_variable_unittest.cc | 202 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 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/chromium_org/cc/test/ |
H A D | fake_scrollbar_layer.cc | 31 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 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/chromium_org/third_party/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/chromium_org/third_party/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/chromium_org/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/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...] |