Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 16 of 16) sorted by relevance

/system/bt/osi/src/
Dfixed_queue.cc68 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
85 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
96 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
103 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
110 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
116 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue()
130 void* fixed_queue_dequeue(fixed_queue_t* queue) { in fixed_queue_dequeue()
147 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_try_enqueue()
162 void* fixed_queue_try_dequeue(fixed_queue_t* queue) { in fixed_queue_try_dequeue()
179 void* fixed_queue_try_peek_first(fixed_queue_t* queue) { in fixed_queue_try_peek_first()
[all …]
Dalarm.cc101 fixed_queue_t* queue; // The processing queue to add this alarm to member
227 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal()
551 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue()
608 static void alarm_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in alarm_queue_ready()
Dthread.cc249 fixed_queue_t* queue = (fixed_queue_t*)context; in work_queue_read_cb() local
/system/bt/osi/test/
Dfixed_queue_test.cc40 static void fixed_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in fixed_queue_ready()
55 fixed_queue_t* queue; in TEST_F() local
83 fixed_queue_t* queue; in TEST_F() local
125 fixed_queue_t* queue; in TEST_F() local
147 fixed_queue_t* queue; in TEST_F() local
169 fixed_queue_t* queue; in TEST_F() local
197 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
234 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
264 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
295 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F() local
[all …]
/system/bt/common/
Dleaky_bonded_queue_unittest.cc54 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(3); in TEST() local
90 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
124 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
164 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
193 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
218 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
227 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(1); in TEST() local
237 LeakyBondedQueue<MockItem>* queue = new LeakyBondedQueue<MockItem>(2); in TEST() local
/system/core/adb/
Dadb_utils.h68 std::vector<T> queue; variable
/system/core/storaged/include/
Dstoraged_diskstats.h110 uint32_t queue; // I/Os in queue member
158 stream_stats queue; // I/Os in queue member
/system/bt/common/benchmark/
Dthread_performance_benchmark.cc39 auto queue = static_cast<fixed_queue_t*>(context); in pthread_callback_batch() local
50 void callback_sequential_queue(fixed_queue_t* queue, void* context) { in callback_sequential_queue()
56 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
/system/core/init/
Dmount_handler.cpp83 auto queue = "/sys/block/" + value + "/queue"; in SetMountProperty() local
/system/core/debuggerd/tombstoned/
Dtombstoned.cpp102 static CrashQueue queue("/data/tombstones", "tombstone_" /* file_name_prefix */, in for_tombstones() local
109 static CrashQueue queue("/data/anr", "trace_" /* file_name_prefix */, in for_anrs() local
/system/extras/simpleperf/
Dcallchain.h91 std::queue<std::vector<std::unique_ptr<NodeT>>*> queue; in SortByPeriod() local
/system/bt/common/test/
Dthread_performance_test.cc40 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
/system/libfmq/tests/
Dmsgq_test_client.cpp150 MessageQueueUnsync* queue = nullptr; in TEST_F() local
198 MessageQueueUnsync* queue = nullptr; in TEST_F() local
/system/bt/stack/rfcomm/
Dport_int.h57 fixed_queue_t* queue; /* Queue of buffers waiting to be sent */ member
/system/bt/btif/avrcp/
Davrcp_service.cc345 bool queue) { in SendMediaUpdate()
/system/bt/profile/avrcp/
Ddevice.cc1261 void Device::SendMediaUpdate(bool metadata, bool play_status, bool queue) { in SendMediaUpdate()