| /system/bt/osi/include/ |
| D | fixed_queue.h | 26 struct fixed_queue_t;
27 typedef struct fixed_queue_t fixed_queue_t; typedef
31 typedef void (*fixed_queue_cb)(fixed_queue_t* queue, void* context);
37 fixed_queue_t* fixed_queue_new(size_t capacity);
44 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb);
49 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb);
53 bool fixed_queue_is_empty(fixed_queue_t* queue);
57 size_t fixed_queue_length(fixed_queue_t* queue);
61 size_t fixed_queue_capacity(fixed_queue_t* queue);
66 void fixed_queue_enqueue(fixed_queue_t* queue, void* data);
[all …]
|
| D | alarm.h | 25 typedef struct fixed_queue_t fixed_queue_t; typedef
|
| /system/bt/osi/src/ |
| D | fixed_queue.cc | 31 typedef struct fixed_queue_t { struct
41 } fixed_queue_t; argument
45 fixed_queue_t* fixed_queue_new(size_t capacity) { in fixed_queue_new()
46 fixed_queue_t* ret = in fixed_queue_new()
47 static_cast<fixed_queue_t*>(osi_calloc(sizeof(fixed_queue_t))); in fixed_queue_new()
68 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()
[all …]
|
| D | alarm.cc | 99 fixed_queue_t* queue; // The processing queue to add this alarm to
131 static fixed_queue_t* default_callback_queue;
138 fixed_queue_t* queue, bool for_msg_loop);
143 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
151 static void alarm_register_processing_queue(fixed_queue_t* queue,
226 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal()
546 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue()
603 static void alarm_queue_ready(fixed_queue_t* queue, UNUSED_ATTR void* context) { in alarm_queue_ready()
|
| D | thread.cc | 48 fixed_queue_t* work_queue;
246 fixed_queue_t* queue = (fixed_queue_t*)context; in work_queue_read_cb()
|
| /system/bt/test/stub/ |
| D | osi.cc | 304 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
308 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_try_enqueue()
312 fixed_queue_t* fixed_queue_new(size_t capacity) { in fixed_queue_new()
316 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd()
320 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) { in fixed_queue_get_enqueue_fd()
324 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list()
328 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
332 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
336 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue()
339 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
[all …]
|
| /system/bt/osi/test/ |
| D | fixed_queue_test.cc | 40 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()
83 fixed_queue_t* queue; in TEST_F()
125 fixed_queue_t* queue; in TEST_F()
147 fixed_queue_t* queue; in TEST_F()
169 fixed_queue_t* queue; in TEST_F()
197 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
234 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
264 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
295 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
[all …]
|
| /system/bt/osi/test/fuzzers/fixed_queue/ |
| D | fuzz_fixed_queue.cc | 32 void fqCb(fixed_queue_t* queue, void* data) { in fqCb()
73 void callArbitraryFunction(fixed_queue_t* fixed_queue, in callArbitraryFunction()
218 fixed_queue_t* fixed_queue = fixed_queue_new(start_capacity); in LLVMFuzzerTestOneInput()
|
| /system/bt/stack/rfcomm/ |
| D | port_int.h | 47 fixed_queue_t* queue; /* Queue of buffers waiting to be sent */
82 fixed_queue_t* cmd_q = nullptr; /* Queue for command messages on this mux */
|
| /system/bt/stack/l2cap/ |
| D | l2c_int.h | 243 fixed_queue_t*
245 fixed_queue_t* srej_rcv_hold_q; /* Buffers rcvd but held pending SREJ rsp */
246 fixed_queue_t* retrans_q; /* Buffers being retransmitted */
327 fixed_queue_t* xmit_hold_q; /* Transmit data hold queue */
515 fixed_queue_t* le_sec_pending_q; /* LE coc channels waiting for security check
|
| D | l2c_fcr.cc | 613 fixed_queue_t* temp_q = p_ccb->fcrb.srej_rcv_hold_q; in l2c_fcr_proc_pdu()
|
| /system/bt/common/benchmark/ |
| D | thread_performance_benchmark.cc | 40 auto queue = static_cast<fixed_queue_t*>(context); in pthread_callback_batch()
51 void callback_sequential_queue(fixed_queue_t* queue, void* context) { in callback_sequential_queue()
57 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
81 fixed_queue_t* bt_msg_queue_ = nullptr;
|
| /system/bt/btif/include/ |
| D | btif_hh.h | 92 fixed_queue_t* get_rpt_id_queue;
|
| /system/bt/stack/avrc/ |
| D | avrc_int.h | 137 fixed_queue_t*
|
| /system/bt/stack/btm/ |
| D | btm_int_types.h | 288 fixed_queue_t* page_queue{nullptr};
297 fixed_queue_t* sec_pending_q{nullptr}; /* pending sequrity requests in
|
| /system/bt/bta/pan/ |
| D | bta_pan_int.h | 118 fixed_queue_t*
|
| /system/bt/stack/gatt/ |
| D | gatt_int.h | 223 fixed_queue_t* multi_rsp_q;
307 fixed_queue_t* pending_ind_q;
389 fixed_queue_t* sign_op_queue;
398 fixed_queue_t* srv_chg_clt_q; /* service change clients queue */
|
| /system/bt/common/test/ |
| D | thread_performance_test.cc | 41 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
64 fixed_queue_t* bt_msg_queue_ = nullptr;
|
| /system/bt/stack/bnep/ |
| D | bnep_int.h | 110 fixed_queue_t* xmit_q;
|
| /system/bt/stack/avct/ |
| D | avct_int.h | 82 fixed_queue_t* tx_q; /* Transmit data buffer queue */
|
| /system/bt/stack/gap/ |
| D | gap_conn.cc | 58 fixed_queue_t* tx_queue; /* Queue of buffers waiting to be sent */
59 fixed_queue_t* rx_queue; /* Queue of buffers waiting to be read */
|
| /system/bt/stack/avdt/ |
| D | avdt_int.h | 611 fixed_queue_t* cmd_q; // Queue for outgoing command messages
612 fixed_queue_t* rsp_q; // Queue for outgoing response and reject messages
|
| /system/bt/bta/dm/ |
| D | bta_dm_int.h | 367 fixed_queue_t* pending_discovery_queue;
|
| /system/bt/btif/src/ |
| D | btif_a2dp_sink.cc | 114 fixed_queue_t* rx_audio_queue;
|
| D | btif_a2dp_source.cc | 217 fixed_queue_t* tx_audio_queue;
|