/external/chromium_org/media/base/ |
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.Clear() 56 DecoderBufferQueue queue; local 85 DecoderBufferQueue queue; local 121 DecoderBufferQueue queue; local 146 DecoderBufferQueue queue; local [all...] |
/external/chromium_org/chrome/browser/chromeos/drive/ |
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.PopForRun(LOW_PRIORITY, &id)) [all...] |
/external/chromium_org/third_party/WebKit/Source/wtf/ |
DoubleBufferedDequeTest.cpp | 16 DoubleBufferedDeque<int> queue; local 18 EXPECT_TRUE(queue.isEmpty()); 19 queue.append(1); 20 EXPECT_FALSE(queue.isEmpty()); 25 DoubleBufferedDeque<int> queue; local 26 queue.append(1); 28 queue.swapBuffers(); 29 EXPECT_TRUE(queue.isEmpty()); 34 DoubleBufferedDeque<int> queue; local 35 queue.append(1) [all...] |
/external/chromium_org/third_party/webrtc/base/ |
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(2) [all...] |
/external/bluetooth/bluedroid/osi/include/ |
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, void *data) [all...] |
/device/moto/shamu/camera/QCamera2/stack/mm-camera-test/src/ |
mm_qcamera_queue.c | 33 int mm_camera_queue_init(mm_camera_queue_t *queue, 37 if ( NULL == queue ) { 41 pthread_mutex_init(&queue->m_lock, NULL); 42 cam_list_init(&queue->m_head.list); 43 queue->m_size = 0; 44 queue->m_dataFn = data_rel_fn; 45 queue->m_userData = user_data; 50 int mm_qcamera_queue_release(mm_camera_queue_t *queue) 52 if ( NULL == queue ) { 56 mm_qcamera_queue_flush(queue); [all...] |
/external/chromium_org/third_party/mesa/src/src/gallium/drivers/llvmpipe/ |
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/ |
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/libcxx/test/containers/container.adaptors/queue/queue.cons/ |
default_noexcept.pass.cpp | 10 // <queue> 12 // queue() 17 #include <queue> 26 typedef std::queue<MoveOnly> C;
|
dtor_noexcept.pass.cpp | 10 // <queue> 12 // ~queue() // implied noexcept; 14 #include <queue> 23 typedef std::queue<MoveOnly> C;
|
move_assign_noexcept.pass.cpp | 10 // <queue> 12 // queue& operator=(queue&& c) 17 #include <queue> 26 typedef std::queue<MoveOnly> C;
|
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/ |
size.pass.cpp | 10 // <queue> 14 #include <queue> 19 std::queue<int> q;
|
/device/asus/flo/camera/QCamera2/stack/common/ |
cam_queue.h | 43 static inline int32_t cam_queue_init(cam_queue_t *queue) 45 pthread_mutex_init(&queue->lock, NULL); 46 cam_list_init(&queue->head.list); 47 queue->size = 0; 51 static inline int32_t cam_queue_enq(cam_queue_t *queue, void *data) 62 pthread_mutex_lock(&queue->lock); 63 cam_list_add_tail_node(&node->list, &queue->head.list); 64 queue->size++; 65 pthread_mutex_unlock(&queue->lock); 70 static inline void *cam_queue_deq(cam_queue_t *queue) [all...] |
/device/lge/hammerhead/camera/QCamera2/stack/common/ |
cam_queue.h | 43 static inline int32_t cam_queue_init(cam_queue_t *queue) 45 pthread_mutex_init(&queue->lock, NULL); 46 cam_list_init(&queue->head.list); 47 queue->size = 0; 51 static inline int32_t cam_queue_enq(cam_queue_t *queue, void *data) 62 pthread_mutex_lock(&queue->lock); 63 cam_list_add_tail_node(&node->list, &queue->head.list); 64 queue->size++; 65 pthread_mutex_unlock(&queue->lock); 70 static inline void *cam_queue_deq(cam_queue_t *queue) [all...] |
/device/moto/shamu/camera/QCamera2/stack/common/ |
cam_queue.h | 43 static inline int32_t cam_queue_init(cam_queue_t *queue) 45 pthread_mutex_init(&queue->lock, NULL); 46 cam_list_init(&queue->head.list); 47 queue->size = 0; 51 static inline int32_t cam_queue_enq(cam_queue_t *queue, void *data) 62 pthread_mutex_lock(&queue->lock); 63 cam_list_add_tail_node(&node->list, &queue->head.list); 64 queue->size++; 65 pthread_mutex_unlock(&queue->lock); 70 static inline void *cam_queue_deq(cam_queue_t *queue) [all...] |
/external/bluetooth/bluedroid/osi/src/ |
fixed_queue.c | 69 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) { 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, void *data) [all...] |
/device/asus/flo/camera/QCamera2/stack/mm-jpeg-interface/src/ |
mm_jpeg_queue.c | 34 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue) 36 pthread_mutex_init(&queue->lock, NULL); 37 cam_list_init(&queue->head.list); 38 queue->size = 0; 42 int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue, void* data) 54 pthread_mutex_lock(&queue->lock); 55 cam_list_add_tail_node(&node->list, &queue->head.list); 56 queue->size++; 57 pthread_mutex_unlock(&queue->lock); 63 void* mm_jpeg_queue_deq(mm_jpeg_queue_t* queue) [all...] |
/device/lge/hammerhead/camera/QCamera2/stack/mm-jpeg-interface/src/ |
mm_jpeg_queue.c | 34 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue) 36 pthread_mutex_init(&queue->lock, NULL); 37 cam_list_init(&queue->head.list); 38 queue->size = 0; 42 int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue, void* data) 54 pthread_mutex_lock(&queue->lock); 55 cam_list_add_tail_node(&node->list, &queue->head.list); 56 queue->size++; 57 pthread_mutex_unlock(&queue->lock); 63 void* mm_jpeg_queue_deq(mm_jpeg_queue_t* queue) [all...] |
/device/moto/shamu/camera/QCamera/stack/mm-jpeg-interface/src/ |
mm_jpeg_queue.c | 34 int32_t mm_jpeg_queue_init(mm_jpeg_queue_t* queue) 36 pthread_mutex_init(&queue->lock, NULL); 37 cam_list_init(&queue->head.list); 38 queue->size = 0; 42 int32_t mm_jpeg_queue_enq(mm_jpeg_queue_t* queue, void* data) 54 pthread_mutex_lock(&queue->lock); 55 cam_list_add_tail_node(&node->list, &queue->head.list); 56 queue->size++; 57 pthread_mutex_unlock(&queue->lock); 64 void* mm_jpeg_queue_peek(mm_jpeg_queue_t* queue) [all...] |
/external/chromium_org/v8/src/libplatform/ |
task-queue-unittest.cc | 7 #include "src/libplatform/task-queue.h" 26 explicit TaskQueueThread(TaskQueue* queue) 27 : Thread(Options("libplatform TaskQueueThread")), queue_(queue) {} 39 TaskQueue queue; local 41 queue.Append(&task); 42 EXPECT_EQ(&task, queue.GetNext()); 43 queue.Terminate(); 44 EXPECT_THAT(queue.GetNext(), IsNull()); 49 TaskQueue queue; local 50 TaskQueueThread thread1(&queue); [all...] |
/external/libnl/lib/netfilter/ |
queue_obj.c | 2 * lib/netfilter/queue_obj.c Netfilter Queue 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 [all...] |
/external/guava/guava/src/com/google/common/base/ |
FinalizablePhantomReference.java | 38 * @param queue that should finalize the referent 40 protected FinalizablePhantomReference(T referent, FinalizableReferenceQueue queue) { 41 super(referent, queue.queue); 42 queue.cleanUp();
|
FinalizableSoftReference.java | 36 * @param queue that should finalize the referent 38 protected FinalizableSoftReference(T referent, FinalizableReferenceQueue queue) { 39 super(referent, queue.queue); 40 queue.cleanUp();
|
FinalizableWeakReference.java | 36 * @param queue that should finalize the referent 38 protected FinalizableWeakReference(T referent, FinalizableReferenceQueue queue) { 39 super(referent, queue.queue); 40 queue.cleanUp();
|