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.h26 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.cc102 fixed_queue_t* queue; // The processing queue to add this alarm to
140 static fixed_queue_t* default_callback_queue;
147 fixed_queue_t* queue, bool for_msg_loop);
152 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
160 static void alarm_register_processing_queue(fixed_queue_t* queue,
233 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal()
552 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue()
604 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/test/suite/core/
Dthread_performance_test.cc25 void callback(fixed_queue_t* queue, void* data) { in callback()
50 fixed_queue_t* bt_msg_queue;
/system/bt/stack/btu/
Dbtu_init.cc43 extern fixed_queue_t* btu_hci_msg_queue;
/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/src/
Dbtif_a2dp_sink.cc78 fixed_queue_t* cmd_msg_queue;
79 fixed_queue_t* rx_audio_queue;
102 static void btif_a2dp_sink_command_ready(fixed_queue_t* queue, void* context);
256 fixed_queue_t* cmd_msg_queue; in btif_a2dp_sink_cleanup()
309 static void btif_a2dp_sink_command_ready(fixed_queue_t* queue, in btif_a2dp_sink_command_ready()
Dbtif_core.cc150 extern fixed_queue_t* btu_hci_msg_queue;
Dbtif_a2dp_source.cc287 fixed_queue_t* tx_audio_queue;
/system/bt/stack/l2cap/
Dl2c_int.h203 fixed_queue_t*
205 fixed_queue_t* srej_rcv_hold_q; /* Buffers rcvd but held pending SREJ rsp */
206 fixed_queue_t* retrans_q; /* Buffers being retransmitted */
308 fixed_queue_t* xmit_hold_q; /* Transmit data hold queue */
429 fixed_queue_t* le_sec_pending_q; /* LE coc channels waiting for security check
Dl2c_fcr.cc755 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;
361 fixed_queue_t* sign_op_queue;
370 fixed_queue_t* srv_chg_clt_q; /* service change clients queue */
/system/bt/bta/pan/
Dbta_pan_int.h119 fixed_queue_t*
/system/bt/stack/bnep/
Dbnep_int.h131 fixed_queue_t* xmit_q;
/system/bt/stack/btm/
Dbtm_ble_int_types.h297 fixed_queue_t* conn_pending_q;
Dbtm_int_types.h835 fixed_queue_t* page_queue;
838 fixed_queue_t* sec_pending_q; /* pending sequrity requests in
Dbtm_sec.cc2655 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