| /packages/modules/Bluetooth/system/test/mock/ |
| D | mock_osi_fixed_queue.h | 46 std::function<size_t(fixed_queue_t* queue)> body{
47 [this](fixed_queue_t* /* queue */) { return return_value; }};
48 size_t operator()(fixed_queue_t* queue) { return body(queue); }; in operator()
57 std::function<void*(fixed_queue_t* queue)> body{
58 [this](fixed_queue_t* /* queue */) { return return_value; }};
59 void* operator()(fixed_queue_t* queue) { return body(queue); }; in operator()
67 std::function<void(fixed_queue_t* queue, void* data)> body{
68 [](fixed_queue_t* /* queue */, void* /* data */) {}};
69 void operator()(fixed_queue_t* queue, void* data) { body(queue, data); }; in operator()
77 std::function<void(fixed_queue_t* queue, fixed_queue_free_cb free_cb)> body{
[all …]
|
| D | mock_osi_fixed_queue.cc | 59 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
63 void* fixed_queue_dequeue(fixed_queue_t* queue) { in fixed_queue_dequeue()
67 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue()
71 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
75 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
79 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd()
83 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) { in fixed_queue_get_enqueue_fd()
87 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list()
91 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
95 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
[all …]
|
| /packages/modules/Bluetooth/system/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
|
| /packages/modules/Bluetooth/system/osi/src/ |
| D | fixed_queue.cc | 34 typedef struct fixed_queue_t { struct
44 } fixed_queue_t; argument
48 fixed_queue_t* fixed_queue_new(size_t capacity) { in fixed_queue_new()
49 fixed_queue_t* ret = in fixed_queue_new()
50 static_cast<fixed_queue_t*>(osi_calloc(sizeof(fixed_queue_t))); in fixed_queue_new()
71 void fixed_queue_free(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_free()
88 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
99 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
106 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
113 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
[all …]
|
| D | alarm.cc | 94 fixed_queue_t* queue; // The processing queue to add this alarm to
126 static fixed_queue_t* default_callback_queue;
133 fixed_queue_t* queue, bool for_msg_loop);
138 static void alarm_queue_ready(fixed_queue_t* queue, void* context);
146 static void alarm_register_processing_queue(fixed_queue_t* queue,
222 fixed_queue_t* queue, bool for_msg_loop) { in alarm_set_internal()
539 static void alarm_register_processing_queue(fixed_queue_t* queue, in alarm_register_processing_queue()
595 static void alarm_queue_ready(fixed_queue_t* queue, void* /* context */) { in alarm_queue_ready()
|
| D | thread.cc | 50 fixed_queue_t* work_queue;
247 fixed_queue_t* queue = (fixed_queue_t*)context; in work_queue_read_cb()
|
| /packages/modules/Bluetooth/system/test/fake/ |
| D | fake_osi.cc | 61 struct fixed_queue_t { struct
65 fixed_queue_t(size_t capacity) { in fixed_queue_t() argument
259 return new fixed_queue_t(capacity); in FakeOsi()
262 [](fixed_queue_t* q, fixed_queue_free_cb cb) { in FakeOsi()
277 [](fixed_queue_t* q, fixed_queue_free_cb free_cb) { in FakeOsi()
284 test::mock::osi_fixed_queue::fixed_queue_enqueue.body = [](fixed_queue_t* q, in FakeOsi()
288 test::mock::osi_fixed_queue::fixed_queue_dequeue.body = [](fixed_queue_t* q) { in FakeOsi()
297 test::mock::osi_fixed_queue::fixed_queue_length.body = [](fixed_queue_t* q) { in FakeOsi()
302 [](fixed_queue_t* q) { in FakeOsi()
307 [](fixed_queue_t* q) { return q ? q->capacity_ : 0; }; in FakeOsi()
[all …]
|
| /packages/modules/Bluetooth/system/test/stub/ |
| D | osi.cc | 277 bool fixed_queue_is_empty(fixed_queue_t* queue) { in fixed_queue_is_empty()
281 bool fixed_queue_try_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_try_enqueue()
285 fixed_queue_t* fixed_queue_new(size_t capacity) { in fixed_queue_new()
289 int fixed_queue_get_dequeue_fd(const fixed_queue_t* queue) { in fixed_queue_get_dequeue_fd()
293 int fixed_queue_get_enqueue_fd(const fixed_queue_t* queue) { in fixed_queue_get_enqueue_fd()
297 list_t* fixed_queue_get_list(fixed_queue_t* queue) { in fixed_queue_get_list()
301 size_t fixed_queue_capacity(fixed_queue_t* queue) { in fixed_queue_capacity()
305 size_t fixed_queue_length(fixed_queue_t* queue) { in fixed_queue_length()
309 void fixed_queue_enqueue(fixed_queue_t* queue, void* data) { in fixed_queue_enqueue()
312 void fixed_queue_flush(fixed_queue_t* queue, fixed_queue_free_cb free_cb) { in fixed_queue_flush()
[all …]
|
| /packages/modules/Bluetooth/system/osi/test/ |
| D | fixed_queue_test.cc | 38 static void fixed_queue_ready(fixed_queue_t* queue, void* /* context */) { in fixed_queue_ready()
53 fixed_queue_t* queue; in TEST_F()
81 fixed_queue_t* queue; in TEST_F()
123 fixed_queue_t* queue; in TEST_F()
145 fixed_queue_t* queue; in TEST_F()
167 fixed_queue_t* queue; in TEST_F()
195 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
232 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
262 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
293 fixed_queue_t* queue = fixed_queue_new(TEST_QUEUE_SIZE); in TEST_F()
[all …]
|
| /packages/modules/Bluetooth/system/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()
|
| /packages/modules/Bluetooth/system/btif/include/ |
| D | btif_hh.h | 95 fixed_queue_t* get_rpt_id_queue;
97 fixed_queue_t* set_rpt_id_queue;
|
| /packages/modules/Bluetooth/system/stack/rfcomm/ |
| D | port_int.h | 51 fixed_queue_t* queue; /* Queue of buffers waiting to be sent */
86 fixed_queue_t* cmd_q = nullptr; /* Queue for command messages on this mux */
|
| /packages/modules/Bluetooth/system/common/benchmark/ |
| D | thread_performance_benchmark.cc | 42 auto queue = static_cast<fixed_queue_t*>(context); in pthread_callback_batch()
54 void callback_sequential_queue(fixed_queue_t* queue, void* context) { in callback_sequential_queue()
61 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
86 fixed_queue_t* bt_msg_queue_ = nullptr;
|
| /packages/modules/Bluetooth/system/stack/l2cap/ |
| D | l2c_int.h | 240 fixed_queue_t*
242 fixed_queue_t* srej_rcv_hold_q; /* Buffers rcvd but held pending SREJ rsp */
243 fixed_queue_t* retrans_q; /* Buffers being retransmitted */
320 fixed_queue_t* xmit_hold_q; /* Transmit data hold queue */
524 fixed_queue_t* le_sec_pending_q; /* LE coc channels waiting for security check
|
| /packages/modules/Bluetooth/system/stack/gatt/ |
| D | gatt_int.h | 227 fixed_queue_t* multi_rsp_q;
314 fixed_queue_t* pending_ind_q;
407 fixed_queue_t* sign_op_queue;
416 fixed_queue_t* srv_chg_clt_q; /* service change clients queue */
|
| /packages/modules/Bluetooth/system/stack/btm/ |
| D | btm_sec_cb.h | 76 fixed_queue_t* sec_pending_q{nullptr}; /* pending sequrity requests in
|
| D | btm_int_types.h | 152 fixed_queue_t* sec_pending_q{nullptr}; /* pending sequrity requests in
|
| /packages/modules/Bluetooth/system/stack/avrc/ |
| D | avrc_int.h | 138 fixed_queue_t*
|
| /packages/modules/Bluetooth/system/common/test/ |
| D | thread_performance_test.cc | 42 void callback_batch(fixed_queue_t* queue, void* data) { in callback_batch()
65 fixed_queue_t* bt_msg_queue_ = nullptr;
|
| /packages/modules/Bluetooth/system/bta/pan/ |
| D | bta_pan_int.h | 132 fixed_queue_t*
|
| /packages/modules/Bluetooth/system/stack/bnep/ |
| D | bnep_int.h | 112 fixed_queue_t* xmit_q;
|
| /packages/modules/Bluetooth/system/stack/gap/ |
| D | gap_conn.cc | 64 fixed_queue_t* tx_queue; /* Queue of buffers waiting to be sent */
65 fixed_queue_t* rx_queue; /* Queue of buffers waiting to be read */
|
| /packages/modules/Bluetooth/system/stack/avct/ |
| D | avct_int.h | 83 fixed_queue_t* tx_q; /* Transmit data buffer queue */
|
| /packages/modules/Bluetooth/system/stack/avdt/ |
| D | avdt_int.h | 612 fixed_queue_t* cmd_q; // Queue for outgoing command messages
613 fixed_queue_t* rsp_q; // Queue for outgoing response and reject messages
|