Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 17 of 17) 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 …]
Ddata_dispatcher.cc72 fixed_queue_t* queue) { in data_dispatcher_register()
82 fixed_queue_t* queue) { in data_dispatcher_register_default()
93 fixed_queue_t* queue; in data_dispatcher_dispatch() local
Dalarm.cc84 fixed_queue_t* queue; // The processing queue to add this alarm to member
194 alarm_callback_t cb, void* data, fixed_queue_t* queue) { in alarm_set_on_queue()
202 fixed_queue_t* queue) { in alarm_set_internal()
512 void alarm_register_processing_queue(fixed_queue_t* queue, thread_t* thread) { in alarm_register_processing_queue()
520 void alarm_unregister_processing_queue(fixed_queue_t* queue) { in alarm_unregister_processing_queue()
538 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 …]
Dleaky_bonded_queue_test.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
Dalarm_test.cc294 fixed_queue_t* queue = fixed_queue_new(SIZE_MAX); in TEST_F() local
330 fixed_queue_t* queue = fixed_queue_new(SIZE_MAX); in TEST_F() local
389 fixed_queue_t* queue = fixed_queue_new(SIZE_MAX); in TEST_F() local
/system/bt/stack/btu/
Dbtu_task.cc99 void btu_hci_msg_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in btu_hci_msg_ready()
104 void btu_bta_msg_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in btu_bta_msg_ready()
/system/extras/simpleperf/
Dcallchain.h88 std::queue<std::vector<std::unique_ptr<NodeT>>*> queue; in SortByPeriod() local
/system/core/storaged/include/
Dstoraged.h97 uint32_t queue; // I/Os in queue member
173 stream_stats queue; // I/Os in queue member
/system/libfmq/tests/
Dmsgq_test_client.cpp140 MessageQueueUnsync* queue = nullptr; in TEST_F() local
184 MessageQueueUnsync* queue = nullptr; in TEST_F() local
/system/bt/btif/src/
Dbtif_a2dp_sink.cc217 static void btif_a2dp_sink_command_ready(fixed_queue_t* queue, in btif_a2dp_sink_command_ready()
Dbtif_a2dp_source.cc343 static void btif_a2dp_source_command_ready(fixed_queue_t* queue, in btif_a2dp_source_command_ready()
/system/bt/hci/src/
Dhci_layer.cc301 static void set_data_queue(fixed_queue_t* queue) { upwards_data_queue = queue; } in set_data_queue()
/system/bt/stack/rfcomm/
Dport_int.h57 fixed_queue_t* queue; /* Queue of buffers waiting to be sent */ member
/system/bt/stack/test/
Dble_advertiser_test.cc62 alarm_callback_t cb, void* data, fixed_queue_t* queue) { in alarm_set_on_queue()
/system/bt/stack/btm/
Dbtm_ble_multi_adv.cc121 base::Closure user_task, fixed_queue_t* queue) { in alarm_set_closure_on_queue()