| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/containers/container.adaptors/priority.queue/priqueue.cons/ |
| move_noexcept.pass.cpp | 10 // <queue>
18 #include <queue>
|
| /device/lge/mako/camera/QCamera/stack/mm-camera-interface/src/ |
| mm_camera_data.c | 49 int32_t mm_camera_queue_init(mm_camera_queue_t* queue)
51 pthread_mutex_init(&queue->lock, NULL);
52 cam_list_init(&queue->head.list);
53 queue->size = 0;
57 int32_t mm_camera_queue_enq(mm_camera_queue_t* queue, void* data)
69 pthread_mutex_lock(&queue->lock);
70 cam_list_add_tail_node(&node->list, &queue->head.list);
71 queue->size++;
72 pthread_mutex_unlock(&queue->lock);
78 void* mm_camera_queue_deq(mm_camera_queue_t* queue)
[all...] |
| /external/libnl/lib/netfilter/ |
| queue.c | 2 * lib/netfilter/queue.c Netfilter Queue
14 * @defgroup queue Queue
25 #include <netlink/netfilter/queue.h>
50 * @name Queue Commands
111 static int nfnl_queue_build_request(const struct nfnl_queue *queue,
116 if (!nfnl_queue_test_group(queue))
120 0, nfnl_queue_get_group(queue));
124 if (nfnl_queue_test_maxlen(queue) &
[all...] |
| /frameworks/base/native/android/ |
| sensor.cpp | 78 sp<SensorEventQueue> queue = local
80 if (queue != 0) {
81 ALooper_addFd(looper, queue->getFd(), ident, ALOOPER_EVENT_INPUT, callback, data);
82 queue->looper = looper;
83 queue->incStrong(manager);
85 return static_cast<ASensorEventQueue*>(queue.get());
91 sp<SensorEventQueue> queue = static_cast<SensorEventQueue*>(inQueue); local
92 ALooper_removeFd(queue->looper, queue->getFd());
93 queue->decStrong(manager)
[all...] |
| /art/runtime/mirror/ |
| reference-inl.h | 33 const Object* queue = GetFieldObject<mirror::Object>(QueueOffset()); local
35 return queue != nullptr && queue_next == nullptr;
|
| /external/chromium_org/mojo/public/cpp/bindings/lib/ |
| message_queue.h | 8 #include <queue>
17 // A queue for Message objects.
27 // to the message queue, resetting |message| in the process.
30 // Removes the next message from the queue, transferring ownership of its
34 // Removes the next message from the queue, discarding its data and handles.
39 std::queue<Message*> queue_;
|
| /external/chromium_org/v8/src/libplatform/ |
| task-queue.h | 8 #include <queue>
25 // Appends a task to the queue. The queue takes ownership of |task|.
29 // NULL if the queue is terminated.
32 // Terminate the queue.
38 std::queue<Task*> task_queue_;
|
| worker-thread.cc | 8 #include "src/libplatform/task-queue.h"
13 WorkerThread::WorkerThread(TaskQueue* queue)
14 : Thread("V8 WorkerThread"), queue_(queue) {
|
| /external/libcxx/test/containers/container.adaptors/queue/queue.cons/ |
| ctor_default.pass.cpp | 10 // <queue>
12 // queue();
14 #include <queue>
21 std::queue<int, std::vector<int, stack_allocator<int, 10> > > q;
|
| ctor_rcontainer.pass.cpp | 10 // <queue>
12 // explicit queue(container_type&& c);
14 #include <queue>
36 std::queue<MoveOnly> q(make<std::deque<MoveOnly> >(5));
|
| /external/libcxx/test/containers/container.adaptors/queue/queue.defn/ |
| emplace.pass.cpp | 10 // <queue>
14 #include <queue>
22 std::queue<Emplaceable> q;
|
| assign_move.pass.cpp | 10 // <queue>
12 // queue& operator=(queue&& q);
14 #include <queue>
36 std::queue<MoveOnly> q(make<std::deque<MoveOnly> >(5));
37 std::queue<MoveOnly> q2;
|
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/containers/container.adaptors/queue/queue.cons/ |
| ctor_default.pass.cpp | 10 // <queue>
12 // queue();
14 #include <queue>
21 std::queue<int, std::vector<int, stack_allocator<int, 10> > > q;
|
| ctor_rcontainer.pass.cpp | 10 // <queue>
12 // explicit queue(container_type&& c);
14 #include <queue>
36 std::queue<MoveOnly> q(make<std::deque<MoveOnly> >(5));
|
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/containers/container.adaptors/queue/queue.defn/ |
| emplace.pass.cpp | 10 // <queue>
14 #include <queue>
22 std::queue<Emplaceable> q;
|
| /external/smack/src/org/jivesoftware/smack/ |
| PacketWriter.java | 46 private final BlockingQueue<Packet> queue; field in class:PacketWriter
55 this.queue = new ArrayBlockingQueue<Packet>(500, true);
89 queue.put(packet);
95 synchronized (queue) {
96 queue.notifyAll();
124 synchronized (queue) {
125 queue.notifyAll();
141 * Returns the next available packet from the queue for writing.
148 while (!done && (packet = queue.poll()) == null) {
150 synchronized (queue) {
[all...] |
| /external/chromium_org/extensions/browser/ |
| lazy_background_task_queue_unittest.cc | 102 LazyBackgroundTaskQueue queue(profile_.get());
106 EXPECT_FALSE(queue.ShouldEnqueueTask(profile_.get(), no_background.get()));
110 EXPECT_TRUE(queue.ShouldEnqueueTask(profile_.get(), with_background.get()));
126 LazyBackgroundTaskQueue queue(profile_.get());
133 queue.AddPendingTask(profile_.get(),
137 EXPECT_EQ(1u, queue.extensions_with_pending_tasks());
142 queue.AddPendingTask(profile_.get(),
146 EXPECT_EQ(1u, queue.extensions_with_pending_tasks());
152 queue.AddPendingTask(profile_.get(),
156 EXPECT_EQ(2u, queue.extensions_with_pending_tasks())
[all...] |
| /frameworks/av/media/libstagefright/rtsp/ |
| AH263Assembler.cpp | 54 List<sp<ABuffer> > *queue = source->queue(); local
56 if (queue->empty()) {
61 List<sp<ABuffer> >::iterator it = queue->begin();
62 while (it != queue->end()) {
67 it = queue->erase(it);
70 if (queue->empty()) {
75 sp<ABuffer> buffer = *queue->begin();
99 queue->erase(queue->begin())
[all...] |
| ARawAudioAssembler.cpp | 55 List<sp<ABuffer> > *queue = source->queue(); local
57 if (queue->empty()) {
62 List<sp<ABuffer> >::iterator it = queue->begin();
63 while (it != queue->end()) {
68 it = queue->erase(it);
71 if (queue->empty()) {
76 sp<ABuffer> buffer = *queue->begin();
90 queue->erase(queue->begin())
[all...] |
| /external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/common/thread/ |
| messagepump_unittest.py | 53 queue = ThreadedMessageQueue()
55 pump = MessagePump(delegate, queue)
60 queue.post("Hello")
61 queue.post("There")
70 queue.post("More")
71 queue.post("Messages")
72 queue.stop()
|
| /developers/demos/MusicDemo/src/main/java/com/example/android/musicservicedemo/utils/ |
| QueueHelper.java | 31 * Utility class to help on queue related tasks.
45 LogHelper.e(TAG, "Could not build a playing queue for this mediaId: ", mediaId);
50 LogHelper.e(TAG, "Creating playing queue for musics of genre ", categoryValue);
52 List<MediaSession.QueueItem> queue = convertToQueue( local
55 return queue;
61 LogHelper.e(TAG, "Creating playing queue for musics from search ", query);
67 public static final int getMusicIndexOnQueue(Iterable<MediaSession.QueueItem> queue,
70 for (MediaSession.QueueItem item: queue) {
79 public static final int getMusicIndexOnQueue(Iterable<MediaSession.QueueItem> queue,
82 for (MediaSession.QueueItem item: queue) {
93 List<MediaSession.QueueItem> queue = new ArrayList<>(); local
[all...] |
| /external/chromium_org/base/ |
| pending_task.h | 8 #include <queue>
19 // for use by classes that queue and execute tasks.
48 // Wrapper around std::queue specialized for PendingTask which adds a Swap
50 class BASE_EXPORT TaskQueue : public std::queue<PendingTask> {
52 void Swap(TaskQueue* queue);
|
| /external/chromium_org/net/spdy/ |
| spdy_read_queue_unittest.cc | 20 const char kData[] = "SPDY read queue test data.\0Some more data.";
23 // Enqueues |data| onto |queue| in chunks of at most |max_buffer_size|
27 SpdyReadQueue* queue) {
30 size_t old_total_size = queue->GetTotalSize();
33 queue->Enqueue(
36 EXPECT_FALSE(queue->IsEmpty());
37 EXPECT_EQ(old_total_size + i, queue->GetTotalSize());
41 // Dequeues all bytes in |queue| in chunks of at most
43 std::string DrainToString(size_t max_buffer_size, SpdyReadQueue* queue) {
47 size_t padding = std::max(static_cast<size_t>(4096), queue->GetTotalSize())
[all...] |
| /external/chromium_org/third_party/WebKit/Tools/GardeningServer/scripts/ |
| model_unittests.js | 99 var queue = model.takeRebaselineQueue();
100 deepEqual(queue, []);
103 var queue = model.takeRebaselineQueue();
104 deepEqual(queue, ['failureInfo1', 'failureInfo2']);
105 var queue = model.takeRebaselineQueue();
106 deepEqual(queue, []);
110 var queue = model.takeExpectationUpdateQueue();
111 deepEqual(queue, []);
114 var queue = model.takeExpectationUpdateQueue();
115 deepEqual(queue, ['failureInfo1', 'failureInfo2'])
[all...] |
| /external/compiler-rt/test/tsan/ |
| static_init3.cc | 18 _Atomic(Cache*) queue;
22 __c11_atomic_store(&queue, c, 0);
29 c = __c11_atomic_load(&queue, 0);
|
