Searched defs:queue (Results 1 - 7 of 7) sorted by relevance

/system/bt/osi/src/
H A Ddata_dispatcher.c35 fixed_queue_t *default_queue; // We don't own this queue
78 void data_dispatcher_register(data_dispatcher_t *dispatcher, data_dispatcher_type_t type, fixed_queue_t *queue) { argument
82 if (queue)
83 hash_map_set(dispatcher->dispatch_table, (void *)type, queue);
86 void data_dispatcher_register_default(data_dispatcher_t *dispatcher, fixed_queue_t *queue) { argument
89 dispatcher->default_queue = queue;
96 fixed_queue_t *queue = hash_map_get(dispatcher->dispatch_table, (void *)type); local
97 if (!queue)
98 queue = dispatcher->default_queue;
100 if (queue)
[all...]
H A Dfixed_queue.c71 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) { argument
72 if (!queue)
75 fixed_queue_unregister_dequeue(queue);
78 for (const list_node_t *node = list_begin(queue->list); node != list_end(queue->list); node = list_next(node))
81 list_free(queue->list);
82 semaphore_free(queue->enqueue_sem);
83 semaphore_free(queue->dequeue_sem);
84 pthread_mutex_destroy(&queue->lock);
85 osi_free(queue);
88 fixed_queue_is_empty(fixed_queue_t *queue) argument
98 fixed_queue_capacity(fixed_queue_t *queue) argument
104 fixed_queue_enqueue(fixed_queue_t *queue, void *data) argument
117 fixed_queue_dequeue(fixed_queue_t *queue) argument
132 fixed_queue_try_enqueue(fixed_queue_t *queue, void *data) argument
147 fixed_queue_try_dequeue(fixed_queue_t *queue) argument
163 fixed_queue_try_peek(fixed_queue_t *queue) argument
174 fixed_queue_get_dequeue_fd(const fixed_queue_t *queue) argument
179 fixed_queue_get_enqueue_fd(const fixed_queue_t *queue) argument
184 fixed_queue_register_dequeue(fixed_queue_t *queue, reactor_t *reactor, fixed_queue_cb ready_cb, void *context) argument
203 fixed_queue_unregister_dequeue(fixed_queue_t *queue) argument
215 fixed_queue_t *queue = context; local
[all...]
H A Dthread.c136 // of queue space, we should abort this operation, otherwise we'll
139 // Queue item is freed either when the queue itself is destroyed
140 // or when the item is removed from the queue for dispatch.
210 LOG_DEBUG("%s growing event queue on shutdown.", __func__);
218 fixed_queue_t *queue = (fixed_queue_t *)context; local
219 work_item_t *item = fixed_queue_dequeue(queue);
/system/bt/stack/btu/
H A Dbtu_task.c94 // Communication queue between btu_task and bta.
97 // Communication queue between btu_task and hci.
100 // General timer queue.
105 // Oneshot timer queue.
110 // l2cap timer queue.
128 void btu_hci_msg_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { argument
129 BT_HDR *p_msg = (BT_HDR *)fixed_queue_dequeue(queue);
133 void btu_general_alarm_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { argument
134 TIMER_LIST_ENT *p_tle = (TIMER_LIST_ENT *)fixed_queue_dequeue(queue);
138 void btu_oneshot_alarm_ready(fixed_queue_t *queue, UNUSED_ATT argument
164 btu_l2cap_alarm_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) argument
169 btu_bta_msg_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) argument
174 btu_bta_alarm_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) argument
[all...]
/system/bt/hci/src/
H A Dhci_layer.c155 static void event_command_ready(fixed_queue_t *queue, void *context);
156 static void event_packet_ready(fixed_queue_t *queue, void *context);
208 LOG_ERROR("%s unable to create pending command queue.", __func__);
214 LOG_ERROR("%s unable to create pending packet queue.", __func__);
339 static void set_data_queue(fixed_queue_t *queue) { argument
340 upwards_data_queue = queue;
454 static void event_command_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { argument
456 waiting_command_t *wait_entry = fixed_queue_dequeue(queue);
473 static void event_packet_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { argument
474 // The queue ma
[all...]
/system/bt/stack/rfcomm/
H A Dport_int.h56 BUFFER_Q queue; /* Queue of buffers waiting to be sent */ member in struct:__anon1245
59 UINT32 queue_size; /* Number of data bytes in the queue */
203 UINT16 rx_buf_critical; /* port receive queue critical watermark level */
/system/bt/btif/src/
H A Dbtif_media_task.c179 /* The typical runlevel of the tx queue size is ~1 buffer
283 static void btif_media_thread_handle_cmd(fixed_queue_t *queue, void *context);
333 APPL_TRACE_DEBUG("[%s] ts %08llu, diff : %08llu, queue sz %d", comment, now_us, now_us - prev_us,
1251 static void btif_media_thread_handle_cmd(fixed_queue_t *queue, UNUSED_ATTR void *context) argument
1253 BT_HDR *p_msg = (BT_HDR *)fixed_queue_dequeue(queue);
2281 ** Returns size of the queue
2614 // Check for TX queue overflow
2621 APPL_TRACE_WARNING("%s() - TX queue buffer count %d/%d", __func__,

Completed in 70 milliseconds