Home
last modified time | relevance | path

Searched refs:fixed_queue_t (Results 1 – 24 of 24) sorted by relevance

/system/bt/osi/include/
Dfixed_queue.h26 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 …]
Dalarm.h25 typedef struct fixed_queue_t fixed_queue_t; typedef
/system/bt/osi/src/
Dfixed_queue.cc31 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 …]
Dalarm.cc101 fixed_queue_t* queue; // The processing queue to add this alarm to
133 static fixed_queue_t* default_callback_queue;
140 fixed_queue_t* queue, bool for_msg_loop);
145 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
153 static void alarm_register_processing_queue(fixed_queue_t* queue,
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.cc48 fixed_queue_t* work_queue;
249 fixed_queue_t* queue = (fixed_queue_t*)context; in work_queue_read_cb()
/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()
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/stack/rfcomm/
Dport_int.h57 fixed_queue_t* queue; /* Queue of buffers waiting to be sent */
92 fixed_queue_t* cmd_q; /* Queue for command messages on this mux */
/system/bt/btif/include/
Dbtif_hh.h71 fixed_queue_t* get_rpt_id_queue;
/system/bt/common/benchmark/
Dthread_performance_benchmark.cc39 auto queue = static_cast<fixed_queue_t*>(context); in pthread_callback_batch()
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()
80 fixed_queue_t* bt_msg_queue_ = nullptr;
/system/bt/stack/l2cap/
Dl2c_int.h206 fixed_queue_t*
208 fixed_queue_t* srej_rcv_hold_q; /* Buffers rcvd but held pending SREJ rsp */
209 fixed_queue_t* retrans_q; /* Buffers being retransmitted */
312 fixed_queue_t* xmit_hold_q; /* Transmit data hold queue */
433 fixed_queue_t* le_sec_pending_q; /* LE coc channels waiting for security check
Dl2c_fcr.cc757 fixed_queue_t* temp_q = p_ccb->fcrb.srej_rcv_hold_q; in l2c_fcr_proc_pdu()
/system/bt/stack/avrc/
Davrc_int.h137 fixed_queue_t*
/system/bt/stack/gatt/
Dgatt_int.h221 fixed_queue_t* multi_rsp_q;
285 fixed_queue_t* pending_ind_q;
356 fixed_queue_t* sign_op_queue;
365 fixed_queue_t* srv_chg_clt_q; /* service change clients queue */
/system/bt/bta/pan/
Dbta_pan_int.h119 fixed_queue_t*
/system/bt/common/test/
Dthread_performance_test.cc40 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
63 fixed_queue_t* bt_msg_queue_ = nullptr;
/system/bt/stack/bnep/
Dbnep_int.h131 fixed_queue_t* xmit_q;
/system/bt/stack/btm/
Dbtm_int_types.h828 fixed_queue_t* page_queue;
831 fixed_queue_t* sec_pending_q; /* pending sequrity requests in
Dbtm_sec.cc2665 fixed_queue_t* bq = btm_cb.sec_pending_q; in btm_sec_check_pending_reqs()
/system/bt/stack/avct/
Davct_int.h84 fixed_queue_t* tx_q; /* Transmit data buffer queue */
/system/bt/stack/gap/
Dgap_conn.cc61 fixed_queue_t* tx_queue; /* Queue of buffers waiting to be sent */
62 fixed_queue_t* rx_queue; /* Queue of buffers waiting to be read */
/system/bt/stack/avdt/
Davdt_int.h616 fixed_queue_t* cmd_q; // Queue for outgoing command messages
617 fixed_queue_t* rsp_q; // Queue for outgoing response and reject messages
/system/bt/btif/src/
Dbtif_a2dp_sink.cc112 fixed_queue_t* rx_audio_queue;
Dbtif_core.cc147 extern fixed_queue_t* btu_hci_msg_queue;
Dbtif_a2dp_source.cc214 fixed_queue_t* tx_audio_queue;