Home
last modified time | relevance | path

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

123

/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);
41 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb);
45 bool fixed_queue_is_empty(fixed_queue_t *queue);
49 size_t fixed_queue_length(fixed_queue_t *queue);
53 size_t fixed_queue_capacity(fixed_queue_t *queue);
58 void fixed_queue_enqueue(fixed_queue_t *queue, void *data);
63 void *fixed_queue_dequeue(fixed_queue_t *queue);
[all …]
Dalarm.h25 typedef struct fixed_queue_t fixed_queue_t; typedef
86 fixed_queue_t *queue);
101 void alarm_register_processing_queue(fixed_queue_t *queue, thread_t *thread);
106 void alarm_unregister_processing_queue(fixed_queue_t *queue);
Ddata_dispatcher.h44 …patcher_register(data_dispatcher_t *dispatcher, data_dispatcher_type_t type, fixed_queue_t *queue);
50 void data_dispatcher_register_default(data_dispatcher_t *dispatcher, fixed_queue_t *queue);
/system/bt/osi/src/
Dfixed_queue.c30 typedef struct fixed_queue_t { struct
40 } fixed_queue_t; argument
44 fixed_queue_t *fixed_queue_new(size_t capacity) { in fixed_queue_new()
45 fixed_queue_t *ret = osi_calloc(sizeof(fixed_queue_t)); in fixed_queue_new()
69 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
86 bool fixed_queue_is_empty(fixed_queue_t *queue) { in fixed_queue_is_empty()
97 size_t fixed_queue_length(fixed_queue_t *queue) { in fixed_queue_length()
108 size_t fixed_queue_capacity(fixed_queue_t *queue) { in fixed_queue_capacity()
114 void fixed_queue_enqueue(fixed_queue_t *queue, void *data) { in fixed_queue_enqueue()
127 void *fixed_queue_dequeue(fixed_queue_t *queue) { in fixed_queue_dequeue()
[all …]
Ddata_dispatcher.c36 fixed_queue_t *default_queue; // We don't own this queue
72 …atcher_register(data_dispatcher_t *dispatcher, data_dispatcher_type_t type, fixed_queue_t *queue) { in data_dispatcher_register()
80 void data_dispatcher_register_default(data_dispatcher_t *dispatcher, fixed_queue_t *queue) { in data_dispatcher_register_default()
90 fixed_queue_t *queue = hash_map_get(dispatcher->dispatch_table, (void *)type); in data_dispatcher_dispatch()
Dalarm.c85 fixed_queue_t *queue; // The processing queue to add this alarm to
121 static fixed_queue_t *default_callback_queue;
128 fixed_queue_t *queue);
133 static void alarm_queue_ready(fixed_queue_t *queue, void *context);
231 fixed_queue_t *queue) { in alarm_set_on_queue()
239 fixed_queue_t *queue) { in alarm_set_internal()
557 void alarm_register_processing_queue(fixed_queue_t *queue, thread_t *thread) { in alarm_register_processing_queue()
565 void alarm_unregister_processing_queue(fixed_queue_t *queue) { in alarm_unregister_processing_queue()
585 static void alarm_queue_ready(fixed_queue_t *queue, in alarm_queue_ready()
Dthread.c45 fixed_queue_t *work_queue;
231 fixed_queue_t *queue = (fixed_queue_t *)context; in work_queue_read_cb()
Deager_reader.c50 fixed_queue_t *buffers;
/system/bt/osi/test/
Ddata_dispatcher_test.cpp41 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
61 fixed_queue_t *dummy_queue0 = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
62 fixed_queue_t *dummy_queue1 = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
86 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
87 fixed_queue_t *default_queue = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
111 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
134 fixed_queue_t *dummy_queue0 = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
135 fixed_queue_t *dummy_queue1 = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
162 fixed_queue_t *dummy_queue = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
163 fixed_queue_t *dummy_queue_reregistered = fixed_queue_new(DUMMY_QUEUE_SIZE); in TEST_F()
[all …]
Dfixed_queue_test.cpp42 fixed_queue_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) in fixed_queue_ready()
52 fixed_queue_t *queue; in TEST_F()
80 fixed_queue_t *queue; in TEST_F()
102 fixed_queue_t *queue; in TEST_F()
124 fixed_queue_t *queue; in TEST_F()
152 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
189 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
219 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
250 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
285 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
Dalarm_test.cpp306 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX); in TEST_F()
343 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX); in TEST_F()
401 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX); in TEST_F()
/system/bt/stack/btu/
Dbtu_task.c92 extern fixed_queue_t *btu_bta_msg_queue;
95 extern fixed_queue_t *btu_hci_msg_queue;
98 extern fixed_queue_t *btu_general_alarm_queue;
100 extern fixed_queue_t *event_queue;
101 extern fixed_queue_t *btif_msg_queue;
107 void btu_hci_msg_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { in btu_hci_msg_ready()
112 void btu_bta_msg_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { in btu_bta_msg_ready()
Dbtu_init.c51 extern fixed_queue_t *btif_msg_queue;
54 fixed_queue_t *btu_bta_msg_queue;
57 extern fixed_queue_t *btu_hci_msg_queue;
60 fixed_queue_t *btu_general_alarm_queue;
/system/bt/stack/gap/
Dgap_int.h78 fixed_queue_t *tx_queue; /* Queue of buffers waiting to be sent */
79 fixed_queue_t *rx_queue; /* Queue of buffers waiting to be read */
133 fixed_queue_t *pending_req_q;
/system/bt/hci/src/
Dhci_layer.c129 static fixed_queue_t *command_queue;
130 static fixed_queue_t *packet_queue;
139 static fixed_queue_t *upwards_data_queue;
154 static void event_command_ready(fixed_queue_t *queue, void *context);
155 static void event_packet_ready(fixed_queue_t *queue, void *context);
350 static void set_data_queue(fixed_queue_t *queue) { in set_data_queue()
474 static void event_command_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { in event_command_ready()
493 static void event_packet_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { in event_packet_ready()
/system/bt/stack/l2cap/
Dl2c_int.h185 fixed_queue_t *waiting_for_ack_q; /* Buffers sent and waiting for peer to ack */
186 fixed_queue_t *srej_rcv_hold_q; /* Buffers rcvd but held pending SREJ rsp */
187 fixed_queue_t *retrans_q; /* Buffers being retransmitted */
311 fixed_queue_t *xmit_hold_q; /* Transmit data hold queue */
413 fixed_queue_t *ucd_out_sec_pending_q; /* Security pending outgoing UCD packet */
414 fixed_queue_t *ucd_in_sec_pending_q; /* Security pending incoming UCD packet */
431 …fixed_queue_t *le_sec_pending_q; /* LE coc channels waiting for security check completi…
/system/bt/stack/gatt/
Dgatt_int.h220 fixed_queue_t *svc_buffer; /* buffer queue used for service database */
287 fixed_queue_t *multi_rsp_q;
351 fixed_queue_t *pending_enc_clcb; /* pending encryption channel q */
369 fixed_queue_t *pending_ind_q;
468 fixed_queue_t *sign_op_queue;
479 fixed_queue_t *srv_chg_clt_q; /* service change clients queue */
480 fixed_queue_t *pending_new_srv_start_q; /* pending new service start queue */
/system/bt/stack/rfcomm/
Dport_int.h58 fixed_queue_t *queue; /* Queue of buffers waiting to be sent */
96 fixed_queue_t *cmd_q; /* Queue for command messages on this mux */
/system/bt/hci/include/
Dhci_layer.h87 void (*set_data_queue)(fixed_queue_t *queue);
/system/bt/main/
Dbte_main.c89 fixed_queue_t *btu_hci_msg_queue;
/system/bt/bta/sys/
Dbta_sys_main.c54 fixed_queue_t *btu_bta_alarm_queue;
63 extern fixed_queue_t *btu_bta_msg_queue;
/system/bt/bta/pan/
Dbta_pan_int.h142 … fixed_queue_t *data_queue; /* Queue of buffers waiting to be passed to application */
/system/bt/stack/avdt/
Davdt_int.h434 fixed_queue_t *cmd_q; /* Queue for outgoing command messages */
435 fixed_queue_t *rsp_q; /* Queue for outgoing response and reject messages */
505 fixed_queue_t *frag_q; /* Queue for outgoing media fragments */
/system/bt/stack/bnep/
Dbnep_int.h137 fixed_queue_t *xmit_q;
/system/bt/stack/avct/
Davct_int.h85 fixed_queue_t *tx_q; /* Transmit data buffer queue */

123