Searched defs:queue (Results 1 - 15 of 15) sorted by relevance

/system/core/adb/
H A Dadb_utils.h59 // A thread-safe blocking queue.
64 std::vector<T> queue; member in class:BlockingQueue
70 queue.push_back(t);
81 cv.wait(lock, [this]() { return !queue.empty(); });
82 popped = std::move(queue);
83 queue.clear();
/system/bt/test/suite/core/
H A Dthread_performance_test.cc25 void callback(fixed_queue_t* queue, void* data) { argument
26 if (queue != nullptr) {
27 fixed_queue_dequeue(queue);
102 thread = thread_new("queue performance test thread");
/system/bt/osi/test/
H A Dfixed_queue_test.cc39 // Function for performing dequeue operations from the queue when is ready
40 static void fixed_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { argument
41 void* msg = fixed_queue_try_dequeue(queue);
55 fixed_queue_t* queue; local
57 // Test a corner case: queue of size 0
58 queue = fixed_queue_new(0);
59 EXPECT_TRUE(queue != NULL);
60 fixed_queue_free(queue, NULL);
62 // Test a corner case: queue of size 1
63 queue
83 fixed_queue_t* queue; local
125 fixed_queue_t* queue; local
147 fixed_queue_t* queue; local
169 fixed_queue_t* queue; local
197 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); local
234 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); local
264 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); local
295 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); local
[all...]
H A Dleaky_bonded_queue_test.cc54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); local
55 EXPECT_EQ(queue->Capacity(), static_cast<size_t>(3));
56 EXPECT_EQ(queue->Length(), static_cast<size_t>(0));
57 queue->Enqueue(item1);
58 EXPECT_EQ(queue->Length(), static_cast<size_t>(1));
59 queue->Enqueue(item2);
60 EXPECT_EQ(queue->Length(), static_cast<size_t>(2));
61 queue->Enqueue(item3);
62 EXPECT_EQ(queue->Length(), static_cast<size_t>(3));
64 queue
90 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
124 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
164 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
193 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
218 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
227 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(1); local
237 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); local
[all...]
/system/bt/osi/src/
H A Dfixed_queue.cc68 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { argument
69 if (!queue) return;
71 fixed_queue_unregister_dequeue(queue);
74 for (const list_node_t* node = list_begin(queue->list);
75 node != list_end(queue->list); node = list_next(node))
78 list_free(queue->list);
79 semaphore_free(queue->enqueue_sem);
80 semaphore_free(queue->dequeue_sem);
81 delete queue->mutex;
82 osi_free(queue);
85 fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) argument
96 fixed_queue_is_empty(fixed_queue_t* queue) argument
103 fixed_queue_length(fixed_queue_t* queue) argument
110 fixed_queue_capacity(fixed_queue_t* queue) argument
116 fixed_queue_enqueue(fixed_queue_t* queue, void* data) argument
130 fixed_queue_dequeue(fixed_queue_t* queue) argument
147 fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) argument
162 fixed_queue_try_dequeue(fixed_queue_t* queue) argument
179 fixed_queue_try_peek_first(fixed_queue_t* queue) argument
186 fixed_queue_try_peek_last(fixed_queue_t* queue) argument
193 fixed_queue_try_remove_from_queue(fixed_queue_t* queue, void* data) argument
213 fixed_queue_get_list(fixed_queue_t* queue) argument
222 fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) argument
227 fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) argument
232 fixed_queue_register_dequeue(fixed_queue_t* queue, reactor_t* reactor, fixed_queue_cb ready_cb, void* context) argument
248 fixed_queue_unregister_dequeue(fixed_queue_t* queue) argument
260 fixed_queue_t* queue = static_cast<fixed_queue_t*>(context); local
[all...]
H A Dthread.cc131 // of queue space, we should abort this operation, otherwise we'll
134 // Queue item is freed either when the queue itself is destroyed
135 // or when the item is removed from the queue for dispatch.
239 LOG_DEBUG(LOG_TAG, "%s growing event queue on shutdown.", __func__);
249 fixed_queue_t* queue = (fixed_queue_t*)context; local
250 work_item_t* item = static_cast<work_item_t*>(fixed_queue_dequeue(queue));
H A Dalarm.cc102 fixed_queue_t* queue; // The processing queue to add this alarm to member in struct:alarm_t
138 // Default alarm callback thread and queue
147 fixed_queue_t* queue, bool for_msg_loop);
152 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
158 // Registers |queue| for processing alarm callbacks on |thread|.
159 // |queue| may not be NULL. |thread| may not be NULL.
160 static void alarm_register_processing_queue(fixed_queue_t* queue,
232 fixed_queue_t* queue, bool for_msg_loop) {
241 alarm->queue
230 alarm_set_internal(alarm_t* alarm, period_ms_t period, alarm_callback_t cb, void* data, fixed_queue_t* queue, bool for_msg_loop) argument
549 alarm_register_processing_queue(fixed_queue_t* queue, thread_t* thread) argument
598 alarm_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) argument
[all...]
/system/extras/simpleperf/
H A Dcallchain.h25 #include <queue>
91 std::queue<std::vector<std::unique_ptr<NodeT>>*> queue; local
92 queue.push(&children);
93 while (!queue.empty()) {
94 std::vector<std::unique_ptr<NodeT>>* v = queue.front();
95 queue.pop();
99 queue.push(&node->children);
/system/bt/btif/avrcp/
H A Davrcp_service.cc341 bool queue) {
345 << " queue=" << queue; local
352 track_changed, play_state, queue));
340 SendMediaUpdate(bool track_changed, bool play_state, bool queue) argument
/system/core/storaged/include/
H A Dstoraged_diskstats.h39 uint64_t read_merges; // number of read I/Os merged with in-queue I/Os
43 uint64_t write_merges; // number of write I/Os merged with in-queue I/Os
110 uint32_t queue; // I/Os in queue member in struct:disk_perf
113 write_perf == 0 && write_ios == 0 && queue == 0;
152 std::queue<struct disk_perf> mBuffer;
158 stream_stats queue; // I/Os in queue member in struct:disk_stats_monitor::__anon1840
/system/libfmq/tests/
H A Dmsgq_test_client.cpp119 * Utility function to verify data read from the fast message queue.
148 MessageQueueUnsync* queue = nullptr; local
149 getQueue(&queue, &testService, true /* setupQueue */);
152 ASSERT_NE(queue, nullptr);
153 ASSERT_TRUE(queue->isValid());
155 size_t numMessagesMax = queue->getQuantumCount();
168 ASSERT_FALSE(queue->read(&readData[0], numMessagesMax));
180 ASSERT_TRUE(queue->read(&readData[0], dataLen));
183 delete queue;
196 MessageQueueUnsync* queue local
[all...]
/system/core/debuggerd/tombstoned/
H A Dtombstoned.cpp100 static CrashQueue queue("/data/tombstones", "tombstone_" /* file_name_prefix */,
103 return &queue;
107 static CrashQueue queue("/data/anr", "trace_" /* file_name_prefix */,
110 return &queue;
389 CrashQueue* queue = CrashQueue::for_crash(crash); local
393 queue->maybe_dequeue_crashes(perform_request);
/system/bt/btif/src/
H A Dbtif_a2dp_sink.cc41 * The receiving queue buffer size.
102 static void btif_a2dp_sink_command_ready(fixed_queue_t* queue, void* context);
309 static void btif_a2dp_sink_command_ready(fixed_queue_t* queue, argument
311 BT_HDR* p_msg = (BT_HDR*)fixed_queue_dequeue(queue);
466 APPL_TRACE_DEBUG("%s: empty queue", __func__);
488 APPL_TRACE_DEBUG("%s: number of packets in queue %zu", __func__,
582 /* Allocate and queue this buffer */
/system/bt/profile/avrcp/
H A Ddevice.cc1090 void Device::SendMediaUpdate(bool metadata, bool play_status, bool queue) { argument
1093 << " : play_status= " << play_status << " : queue=" << queue; local
1095 if (queue) {
/system/bt/stack/rfcomm/
H A Dport_int.h57 fixed_queue_t* queue; /* Queue of buffers waiting to be sent */ member in struct:__anon1308
60 uint32_t queue_size; /* Number of data bytes in the queue */
202 uint16_t rx_buf_critical; /* port receive queue critical watermark level */

Completed in 247 milliseconds