/system/core/adb/ |
H A D | adb_utils.h | 59 // 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 D | thread_performance_test.cc | 25 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 D | fixed_queue_test.cc | 39 // 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 D | leaky_bonded_queue_test.cc | 54 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 D | fixed_queue.cc | 68 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 D | thread.cc | 131 // 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 D | alarm.cc | 102 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 D | callchain.h | 25 #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 D | avrcp_service.cc | 341 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 D | storaged_diskstats.h | 39 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 D | msgq_test_client.cpp | 119 * 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 D | tombstoned.cpp | 100 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 D | btif_a2dp_sink.cc | 41 * 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 D | device.cc | 1090 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 D | port_int.h | 57 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 */
|