/external/stlport/test/unit/ |
H A D | queue_header_test.cpp | 8 #include <queue>
|
/external/chromium_org/media/base/ |
H A D | decoder_buffer_queue_unittest.cc | 36 DecoderBufferQueue queue; local 37 EXPECT_TRUE(queue.IsEmpty()); 39 queue.Push(CreateBuffer(0)); 40 EXPECT_FALSE(queue.IsEmpty()); 44 DecoderBufferQueue queue; local 45 queue.Push(CreateBuffer(0)); 46 queue.Push(CreateBuffer(1)); 47 EXPECT_FALSE(queue.IsEmpty()); 48 EXPECT_EQ(1, queue.Duration().InSeconds()); 50 queue 56 DecoderBufferQueue queue; local 85 DecoderBufferQueue queue; local 121 DecoderBufferQueue queue; local 146 DecoderBufferQueue queue; local [all...] |
/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/third_party/webrtc/base/ |
H A D | atomicops_unittest.cc | 30 rtc::FixedSizeLockFreeQueue<int> queue; local 31 EXPECT_EQ(0u, queue.capacity()); 32 EXPECT_EQ(0u, queue.Size()); 33 EXPECT_FALSE(queue.PushBack(1)); 35 EXPECT_FALSE(queue.PopFront(&val)); 39 rtc::FixedSizeLockFreeQueue<int> queue(5); 40 EXPECT_EQ(5u, queue.capacity()); 41 EXPECT_EQ(0u, queue.Size()); 43 EXPECT_FALSE(queue.PopFront(&val)); 47 rtc::FixedSizeLockFreeQueue<int> queue( [all...] |
/external/bluetooth/bluedroid/osi/include/ |
H A D | fixed_queue.h | 28 // Creates a new fixed queue with the given |capacity|. If more elements than 29 // |capacity| are added to the queue, the caller is blocked until space is 30 // made available in the queue. Returns NULL on failure. The caller must free 31 // the returned queue with |fixed_queue_free|. 34 // Freeing a queue that is currently in use (i.e. has waiters 36 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb); 38 // Enqueues the given |data| into the |queue|. The caller will be blocked 39 // if nore more space is available in the queue. Neither |queue| nor |data| 41 void fixed_queue_enqueue(fixed_queue_t *queue, voi [all...] |
/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);
|
/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);
|
/external/chromium_org/chrome/browser/sync_file_system/drive_backend_v1/ |
H A D | origin_operation_queue_unittest.cc | 15 OriginOperationQueue* queue) { 16 ASSERT_FALSE(queue->empty()); 18 op = queue->Pop(); 28 OriginOperationQueue queue; local 30 queue.Push(origin1, OriginOperation::REGISTERING); 31 queue.Push(origin2, OriginOperation::DISABLING); 32 queue.Push(origin1, OriginOperation::UNINSTALLING); 34 ASSERT_EQ(3U, queue.size()); 35 ASSERT_TRUE(queue.HasPendingOperation(origin1)); 36 ASSERT_TRUE(queue 13 PopAndVerify(const GURL& expected_origin, OriginOperation::Type expected_type, OriginOperationQueue* queue) argument [all...] |
/external/chromium_org/v8/test/cctest/ |
H A D | test-libplatform-worker-thread.cc | 30 #include "src/libplatform/task-queue.h" 39 TaskQueue queue; local 47 WorkerThread* thread1 = new WorkerThread(&queue); 48 WorkerThread* thread2 = new WorkerThread(&queue); 52 queue.Append(task1); 53 queue.Append(task2); 54 queue.Append(task3); 55 queue.Append(task4); 58 queue.Terminate();
|
/external/libcxx/test/containers/container.adaptors/queue/queue.cons/ |
H A D | default_noexcept.pass.cpp | 10 // <queue> 12 // queue() 17 #include <queue> 26 typedef std::queue<MoveOnly> C;
|
H A D | dtor_noexcept.pass.cpp | 10 // <queue> 12 // ~queue() // implied noexcept; 14 #include <queue> 23 typedef std::queue<MoveOnly> C;
|
H A D | move_assign_noexcept.pass.cpp | 10 // <queue> 12 // queue& operator=(queue&& c) 17 #include <queue> 26 typedef std::queue<MoveOnly> C;
|
H A D | move_noexcept.pass.cpp | 10 // <queue> 12 // queue(queue&&) 17 #include <queue> 26 typedef std::queue<MoveOnly> C;
|
/external/libcxx/test/containers/container.adaptors/queue/queue.defn/ |
H A D | size.pass.cpp | 10 // <queue> 14 #include <queue> 19 std::queue<int> q;
|
H A D | swap.pass.cpp | 10 // <queue> 12 // void swap(queue& q); 14 #include <queue> 29 std::queue<int> q1 = make<std::queue<int> >(5); 30 std::queue<int> q2 = make<std::queue<int> >(10); 31 std::queue<int> q1_save = q1; 32 std::queue<int> q2_save = q2;
|
/external/bluetooth/bluedroid/osi/src/ |
H A D | fixed_queue.c | 69 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) { argument 70 if (!queue) 74 for (const list_node_t *node = list_begin(queue->list); node != list_end(queue->list); node = list_next(node)) 77 list_free(queue->list); 78 semaphore_free(queue->enqueue_sem); 79 semaphore_free(queue->dequeue_sem); 80 pthread_mutex_destroy(&queue->lock); 81 free(queue); 84 void fixed_queue_enqueue(fixed_queue_t *queue, voi argument 97 fixed_queue_dequeue(fixed_queue_t *queue) argument 112 fixed_queue_try_enqueue(fixed_queue_t *queue, void *data) argument 127 fixed_queue_try_dequeue(fixed_queue_t *queue) argument 143 fixed_queue_get_dequeue_fd(const fixed_queue_t *queue) argument 148 fixed_queue_get_enqueue_fd(const fixed_queue_t *queue) argument [all...] |
/external/libnl/lib/netfilter/ |
H A D | queue_obj.c | 14 * @defgroup queue Queue 21 #include <netlink/netfilter/queue.h> 33 struct nfnl_queue *queue = (struct nfnl_queue *) a; local 38 if (queue->ce_mask & QUEUE_ATTR_GROUP) 39 nl_dump(p, "group=%u ", queue->queue_group); 41 if (queue->ce_mask & QUEUE_ATTR_MAXLEN) 42 nl_dump(p, "maxlen=%u ", queue->queue_maxlen); 44 if (queue->ce_mask & QUEUE_ATTR_COPY_MODE) 46 nfnl_queue_copy_mode2str(queue->queue_copy_mode, 49 if (queue 83 nfnl_queue_get(struct nfnl_queue *queue) argument 88 nfnl_queue_put(struct nfnl_queue *queue) argument 100 nfnl_queue_set_group(struct nfnl_queue *queue, uint16_t group) argument 106 nfnl_queue_test_group(const struct nfnl_queue *queue) argument 111 nfnl_queue_get_group(const struct nfnl_queue *queue) argument 116 nfnl_queue_set_maxlen(struct nfnl_queue *queue, uint32_t maxlen) argument 122 nfnl_queue_test_maxlen(const struct nfnl_queue *queue) argument 127 nfnl_queue_get_maxlen(const struct nfnl_queue *queue) argument 132 nfnl_queue_set_copy_mode(struct nfnl_queue *queue, enum nfnl_queue_copy_mode mode) argument 138 nfnl_queue_test_copy_mode(const struct nfnl_queue *queue) argument 143 nfnl_queue_get_copy_mode(const struct nfnl_queue *queue) argument 148 nfnl_queue_set_copy_range(struct nfnl_queue *queue, uint32_t copy_range) argument 154 nfnl_queue_test_copy_range(const struct nfnl_queue *queue) argument 159 nfnl_queue_get_copy_range(const struct nfnl_queue *queue) 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/libcxx/test/containers/container.adaptors/queue/ |
H A D | version.pass.cpp | 10 // <queue> 12 #include <queue>
|
/external/libcxx/test/containers/container.adaptors/queue/queue.ops/ |
H A D | eq.pass.cpp | 10 // <queue> 13 // bool operator==(const queue<T, Container>& x,const queue<T, Container>& y); 16 // bool operator!=(const queue<T, Container>& x,const queue<T, Container>& y); 18 #include <queue> 33 std::queue<int> q1 = make<std::queue<int> >(5); 34 std::queue<int> q2 = make<std::queue<in [all...] |
/external/libcxx/test/containers/container.adaptors/queue/queue.special/ |
H A D | swap.pass.cpp | 10 // <queue> 13 // void swap(queue<T, Container>& x, queue<T, Container>& y); 15 #include <queue> 30 std::queue<int> q1 = make<std::queue<int> >(5); 31 std::queue<int> q2 = make<std::queue<int> >(10); 32 std::queue<int> q1_save = q1; 33 std::queue<in [all...] |
/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...] |