Searched refs:queue (Results 1 - 25 of 31) sorted by relevance

12

/system/bt/osi/include/
H A Dfixed_queue.h31 typedef void (*fixed_queue_cb)(fixed_queue_t *queue, void *context);
33 // Creates a new fixed queue with the given |capacity|. If more elements than
34 // |capacity| are added to the queue, the caller is blocked until space is
35 // made available in the queue. Returns NULL on failure. The caller must free
36 // the returned queue with |fixed_queue_free|.
39 // Freeing a queue that is currently in use (i.e. has waiters
41 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb);
43 // Returns a value indicating whether the given |queue| is empty. If |queue|
45 bool fixed_queue_is_empty(fixed_queue_t *queue);
[all...]
H A Ddata_dispatcher.h40 // Registers |type| and |queue| with the data dispatcher so that data
41 // sent under |type| ends up in |queue|. If |type| is already registered,
42 // it is replaced. If |queue| is NULL, the existing registration is
44 void data_dispatcher_register(data_dispatcher_t *dispatcher, data_dispatcher_type_t type, fixed_queue_t *queue);
46 // Registers a default queue to send data to when there is not a specific
47 // type/queue relationship registered. If a default queue is already registered,
48 // it is replaced. If |queue| is NULL, the existing registration is
50 void data_dispatcher_register_default(data_dispatcher_t *dispatcher, fixed_queue_t *queue);
52 // Dispatches |data| to the queue registere
[all...]
H A Dalarm.h78 // specific |queue|. This function is same as |alarm_set| except
80 // context of the thread responsible for processing |queue|.
82 // among alarms that are scheduled on the same queue. |queue|
86 fixed_queue_t *queue);
99 // Registers |queue| for processing alarm callbacks on |thread|.
100 // |queue| may not be NULL. |thread| may not be NULL.
101 void alarm_register_processing_queue(fixed_queue_t *queue, thread_t *thread);
103 // Unregisters |queue| for processing alarm callbacks on whichever thread
104 // it is registered with. All alarms currently set for execution on |queue|
[all...]
/system/bt/osi/src/
H A Dfixed_queue.c69 void fixed_queue_free(fixed_queue_t *queue, fixed_queue_free_cb free_cb) { argument
70 if (!queue)
73 fixed_queue_unregister_dequeue(queue);
76 for (const list_node_t *node = list_begin(queue->list); node != list_end(queue->list); node = list_next(node))
79 list_free(queue->list);
80 semaphore_free(queue->enqueue_sem);
81 semaphore_free(queue->dequeue_sem);
82 pthread_mutex_destroy(&queue->lock);
83 osi_free(queue);
86 fixed_queue_is_empty(fixed_queue_t *queue) argument
97 fixed_queue_length(fixed_queue_t *queue) argument
108 fixed_queue_capacity(fixed_queue_t *queue) argument
114 fixed_queue_enqueue(fixed_queue_t *queue, void *data) argument
127 fixed_queue_dequeue(fixed_queue_t *queue) argument
142 fixed_queue_try_enqueue(fixed_queue_t *queue, void *data) argument
157 fixed_queue_try_dequeue(fixed_queue_t *queue) argument
174 fixed_queue_try_peek_first(fixed_queue_t *queue) argument
185 fixed_queue_try_peek_last(fixed_queue_t *queue) argument
196 fixed_queue_try_remove_from_queue(fixed_queue_t *queue, void *data) argument
216 fixed_queue_get_list(fixed_queue_t *queue) argument
225 fixed_queue_get_dequeue_fd(const fixed_queue_t *queue) argument
230 fixed_queue_get_enqueue_fd(const fixed_queue_t *queue) argument
235 fixed_queue_register_dequeue(fixed_queue_t *queue, reactor_t *reactor, fixed_queue_cb ready_cb, void *context) argument
254 fixed_queue_unregister_dequeue(fixed_queue_t *queue) argument
266 fixed_queue_t *queue = context; local
[all...]
H A Ddata_dispatcher.c36 fixed_queue_t *default_queue; // We don't own this queue
72 void data_dispatcher_register(data_dispatcher_t *dispatcher, data_dispatcher_type_t type, fixed_queue_t *queue) { argument
76 if (queue)
77 hash_map_set(dispatcher->dispatch_table, (void *)type, queue);
80 void data_dispatcher_register_default(data_dispatcher_t *dispatcher, fixed_queue_t *queue) { argument
83 dispatcher->default_queue = queue;
90 fixed_queue_t *queue = hash_map_get(dispatcher->dispatch_table, (void *)type); local
91 if (!queue)
92 queue = dispatcher->default_queue;
94 if (queue)
[all...]
H A Dalarm.c85 fixed_queue_t *queue; // The processing queue to add this alarm to member in struct:alarm_t
119 // Default alarm callback thread and queue
128 fixed_queue_t *queue);
133 static void alarm_queue_ready(fixed_queue_t *queue, void *context);
231 fixed_queue_t *queue) {
232 assert(queue != NULL);
233 alarm_set_internal(alarm, interval_ms, cb, data, queue);
239 fixed_queue_t *queue) {
248 alarm->queue
229 alarm_set_on_queue(alarm_t *alarm, period_ms_t interval_ms, alarm_callback_t cb, void *data, fixed_queue_t *queue) argument
237 alarm_set_internal(alarm_t *alarm, period_ms_t period, alarm_callback_t cb, void *data, fixed_queue_t *queue) argument
557 alarm_register_processing_queue(fixed_queue_t *queue, thread_t *thread) argument
565 alarm_unregister_processing_queue(fixed_queue_t *queue) argument
585 alarm_queue_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) argument
[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.
222 LOG_DEBUG(LOG_TAG, "%s growing event queue on shutdown.", __func__);
231 fixed_queue_t *queue = (fixed_queue_t *)context; local
232 work_item_t *item = fixed_queue_dequeue(queue);
/system/bt/osi/test/
H A Dfixed_queue_test.cpp40 // Function for performing dequeue operations from the queue when is ready
42 fixed_queue_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) argument
44 void *msg = fixed_queue_try_dequeue(queue);
52 fixed_queue_t *queue; local
54 // Test a corner case: queue of size 0
55 queue = fixed_queue_new(0);
56 EXPECT_TRUE(queue != NULL);
57 fixed_queue_free(queue, NULL);
59 // Test a corner case: queue of size 1
60 queue
80 fixed_queue_t *queue; local
102 fixed_queue_t *queue; local
124 fixed_queue_t *queue; local
152 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); local
189 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); local
219 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); local
250 fixed_queue_t *queue = fixed_queue_new(TEST_QUEUE_SIZE); local
[all...]
H A Dalarm_test.cpp303 // separate queue.
306 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX); local
309 alarm_register_processing_queue(queue, thread);
319 alarm_set_on_queue(alarms[i], 100, ordered_cb, INT_TO_PTR(i), queue);
334 alarm_unregister_processing_queue(queue);
335 fixed_queue_free(queue, NULL);
339 // Test whether unregistering a processing queue cancels all timers using
340 // that queue.
343 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX); local
347 alarm_register_processing_queue(queue, threa
401 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX); local
[all...]
/system/connectivity/shill/init/
H A Dnetfilter-queue.conf17 description "Run the netfilter-queue-helper multicast firewall extension"
25 EXEC_NAME="/usr/sbin/netfilter-queue-helper"
32 --input-queue=${NETFILTER_INPUT_NFQUEUE} \
33 --output-queue=${NETFILTER_OUTPUT_NFQUEUE}
/system/core/toolbox/upstream-netbsd/usr.bin/grep/
H A Dqueue.c1 /* $NetBSD: queue.c,v 1.5 2011/08/31 16:24:57 plunky Exp $ */
2 /* $FreeBSD: head/usr.bin/grep/queue.c 211496 2010-08-19 09:28:59Z des $ */
30 * A really poor man's queue. It does only what it has to and gets out of
31 * Dodge. It is used in place of <sys/queue.h> to get a better performance.
39 __RCSID("$NetBSD: queue.c,v 1.5 2011/08/31 16:24:57 plunky Exp $");
42 #include <sys/queue.h>
54 static STAILQ_HEAD(, qentry) queue = STAILQ_HEAD_INITIALIZER(queue);
72 STAILQ_INSERT_TAIL(&queue, item, list);
86 item = STAILQ_FIRST(&queue);
[all...]
/system/extras/simpleperf/
H A Dcallchain.cpp21 #include <queue>
118 std::queue<std::vector<std::unique_ptr<CallChainNode>>*> queue; local
119 queue.push(&children);
120 while (!queue.empty()) {
121 std::vector<std::unique_ptr<CallChainNode>>* v = queue.front();
122 queue.pop();
125 queue.push(&node->children);
/system/bt/stack/btu/
H A Dbtu_task.c91 // Communication queue between btu_task and bta.
94 // Communication queue between btu_task and hci.
97 // General timer queue.
107 void btu_hci_msg_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { argument
108 BT_HDR *p_msg = (BT_HDR *)fixed_queue_dequeue(queue);
112 void btu_bta_msg_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { argument
113 BT_HDR *p_msg = (BT_HDR *)fixed_queue_dequeue(queue);
/system/core/fastboot/
H A Dsocket_mock.h33 #include <queue>
96 std::queue<Event> events_;
/system/bt/stack/rfcomm/
H A Dport_utils.c133 p_port->tx.queue = fixed_queue_new(SIZE_MAX);
134 p_port->rx.queue = fixed_queue_new(SIZE_MAX);
218 while ((p_buf = (BT_HDR *)fixed_queue_try_dequeue(p_port->rx.queue)) != NULL)
222 while ((p_buf = (BT_HDR *)fixed_queue_try_dequeue(p_port->tx.queue)) != NULL)
242 fixed_queue_free(p_port->tx.queue, NULL);
243 p_port->tx.queue = NULL;
244 fixed_queue_free(p_port->rx.queue, NULL);
245 p_port->rx.queue = NULL;
428 || (fixed_queue_length(p_port->tx.queue) > PORT_TX_BUF_HIGH_WM);
543 /* if queue coun
[all...]
H A Dport_api.c75 "TX queue disabled",
640 ** Description This function return number of buffers on the rx queue.
643 ** p_rx_queue_count - Pointer to return queue count in.
672 RFCOMM_TRACE_API ("PORT_GetRxQueueCnt() p_rx_queue_count:%d, p_port->rx.queue.count = %d",
1162 count = fixed_queue_length(p_port->rx.queue);
1164 while ((p_buf = (BT_HDR *)fixed_queue_try_dequeue(p_port->rx.queue)) != NULL)
1180 while ((p_buf = (BT_HDR *)fixed_queue_try_dequeue(p_port->tx.queue)) != NULL)
1242 if (fixed_queue_is_empty(p_port->rx.queue))
1249 p_buf = (BT_HDR *)fixed_queue_try_peek_first(p_port->rx.queue);
1285 osi_free(fixed_queue_try_dequeue(p_port->rx.queue));
[all...]
H A Dport_int.h58 fixed_queue_t *queue; /* Queue of buffers waiting to be sent */ member in struct:__anon1251
61 UINT32 queue_size; /* Number of data bytes in the queue */
203 UINT16 rx_buf_critical; /* port receive queue critical watermark level */
/system/core/init/
H A Daction.h21 #include <queue>
112 std::queue<std::unique_ptr<Trigger>> trigger_queue_;
113 std::queue<const Action*> current_executing_actions_;
/system/bt/hci/include/
H A Dhci_layer.h86 // Set the queue to receive ACL data in
87 void (*set_data_queue)(fixed_queue_t *queue);
/system/bt/hci/src/
H A Dhci_layer.c154 static void event_command_ready(fixed_queue_t *queue, void *context);
155 static void event_packet_ready(fixed_queue_t *queue, void *context);
210 LOG_ERROR(LOG_TAG, "%s unable to create pending command queue.", __func__);
216 LOG_ERROR(LOG_TAG, "%s unable to create pending packet queue.", __func__);
350 static void set_data_queue(fixed_queue_t *queue) { argument
351 upwards_data_queue = queue;
474 static void event_command_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { argument
476 waiting_command_t *wait_entry = fixed_queue_dequeue(queue);
493 static void event_packet_ready(fixed_queue_t *queue, UNUSED_ATTR void *context) { argument
494 // The queue ma
[all...]
/system/connectivity/shill/net/
H A Dnetlink_manager.h73 #include <queue>
432 // the first element in this queue will contain the netlink dump request
434 std::queue<NetlinkPendingMessage> pending_messages_;
/system/core/adb/
H A Dfdevent_test.cpp22 #include <queue>
70 std::queue<char> queue_;
/system/extras/libpagemap/include/pagemap/
H A Dpagemap.h24 #include <sys/queue.h>
/system/core/toolbox/
H A DAndroid.mk111 upstream-netbsd/usr.bin/grep/queue.c \
/system/extras/tests/ext4/
H A Dandroid_emmc_perf_tests.sh242 ORIG_READAHEAD=`adb shell cat /sys/block/$MMCDEV/queue/read_ahead_kb | tr -d "\r"`
243 adb shell "echo 4 > /sys/block/$MMCDEV/queue/read_ahead_kb"
252 adb shell "echo $ORIG_READAHEAD > /sys/block/$MMCDEV/queue/read_ahead_kb"

Completed in 656 milliseconds

12