Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 460) sorted by relevance

12345678910>>...19

/trueos/contrib/apr-util/misc/
HDapr_queue.c73 #define apr_queue_full(queue) ((queue)->nelts == (queue)->bounds) argument
79 #define apr_queue_empty(queue) ((queue)->nelts == 0) argument
87 apr_queue_t *queue = data; in queue_destroy() local
91 apr_thread_cond_destroy(queue->not_empty); in queue_destroy()
92 apr_thread_cond_destroy(queue->not_full); in queue_destroy()
93 apr_thread_mutex_destroy(queue->one_big_mutex); in queue_destroy()
106 apr_queue_t *queue; in apr_queue_create() local
107 queue = apr_palloc(a, sizeof(apr_queue_t)); in apr_queue_create()
108 *q = queue; in apr_queue_create()
111 rv = apr_thread_mutex_create(&queue->one_big_mutex, in apr_queue_create()
[all …]
/trueos/sys/dev/nxge/xgehal/
HDxge-queue.c52 __queue_consume(xge_queue_t *queue, int data_max_size, xge_queue_item_t *item) in __queue_consume() argument
57 if (xge_list_is_empty(&queue->list_head)) in __queue_consume()
60 elem = (xge_queue_item_t *)queue->list_head.next; in __queue_consume()
66 if (queue->head_ptr == elem) { in __queue_consume()
67 queue->head_ptr = (char *)queue->head_ptr + real_size; in __queue_consume()
73 (u64)(ulong_t)queue->start_ptr, in __queue_consume()
74 (u64)(ulong_t)queue->head_ptr, in __queue_consume()
75 (u64)(ulong_t)queue->tail_ptr, in __queue_consume()
76 (u64)(ulong_t)queue->end_ptr, in __queue_consume()
79 } else if ((char *)queue->tail_ptr - real_size == (char*)elem) { in __queue_consume()
[all …]
HDxgehal-ring.c250 xge_hal_ring_queue_t *queue; in __hal_ring_open() local
258 queue = &ring->config->queue[attr->post_qid]; in __hal_ring_open()
259 ring->indicate_max_pkts = queue->indicate_max_pkts; in __hal_ring_open()
260 ring->buffer_mode = queue->buffer_mode; in __hal_ring_open()
262 xge_assert(queue->configured); in __hal_ring_open()
275 ring->rxd_size = XGE_HAL_RING_RXD_SIZEOF(queue->buffer_mode); in __hal_ring_open()
281 ring->rxds_per_block = XGE_HAL_RING_RXDS_PER_BLOCK(queue->buffer_mode); in __hal_ring_open()
287 sizeof(void*) * queue->max * ring->rxds_per_block); in __hal_ring_open()
299 queue->initial, queue->max, in __hal_ring_open()
311 queue->initial * ring->rxds_per_block, in __hal_ring_open()
[all …]
/trueos/sys/dev/vxge/vxgehal/
HDvxge-queue.c59 __queue_consume(vxge_queue_t *queue, in __queue_consume() argument
67 vxge_assert(queue != NULL); in __queue_consume()
69 hldev = (__hal_device_t *) queue->hldev; in __queue_consume()
76 (ptr_t) queue, data_max_size, (ptr_t) item); in __queue_consume()
78 if (vxge_list_is_empty(&queue->list_head)) { in __queue_consume()
84 elem = (vxge_queue_item_t *) queue->list_head.next; in __queue_consume()
93 if (queue->head_ptr == elem) { in __queue_consume()
94 queue->head_ptr = (char *) queue->head_ptr + real_size; in __queue_consume()
99 elem->event_type, (ptr_t) queue->start_ptr, in __queue_consume()
100 (ptr_t) queue->head_ptr, (ptr_t) queue->tail_ptr, in __queue_consume()
[all …]
/trueos/sys/kern/
HDsubr_taskqueue.c98 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init() argument
103 callout_init_mtx(&timeout_task->c, &queue->tq_mutex, in _timeout_task_init()
105 timeout_task->q = queue; in _timeout_task_init()
123 struct taskqueue *queue; in _taskqueue_create() local
125 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO); in _taskqueue_create()
126 if (!queue) in _taskqueue_create()
129 STAILQ_INIT(&queue->tq_queue); in _taskqueue_create()
130 TAILQ_INIT(&queue->tq_active); in _taskqueue_create()
131 queue->tq_enqueue = enqueue; in _taskqueue_create()
132 queue->tq_context = context; in _taskqueue_create()
[all …]
/trueos/share/man/man3/
HDMakefile15 queue.3 \
67 MLINKS+= queue.3 LIST_EMPTY.3 \
68 queue.3 LIST_ENTRY.3 \
69 queue.3 LIST_FIRST.3 \
70 queue.3 LIST_FOREACH.3 \
71 queue.3 LIST_FOREACH_SAFE.3 \
72 queue.3 LIST_HEAD.3 \
73 queue.3 LIST_HEAD_INITIALIZER.3 \
74 queue.3 LIST_INIT.3 \
75 queue.3 LIST_INSERT_AFTER.3 \
[all …]
/trueos/sys/cam/
HDcam_queue.c98 camq_free(struct camq *queue) in camq_free() argument
100 if (queue != NULL) { in camq_free()
101 camq_fini(queue); in camq_free()
102 free(queue, M_CAMQ); in camq_free()
107 camq_fini(struct camq *queue) in camq_fini() argument
109 if (queue->queue_array != NULL) { in camq_fini()
114 queue->queue_array++; in camq_fini()
115 free(queue->queue_array, M_CAMQ); in camq_fini()
120 camq_resize(struct camq *queue, int new_size) in camq_resize() argument
124 KASSERT(new_size >= queue->entries, ("camq_resize: " in camq_resize()
[all …]
HDcam_queue.h61 struct camq queue; member
110 u_int32_t camq_resize(struct camq *queue, int new_size);
122 void camq_free(struct camq *queue);
127 void camq_fini(struct camq *queue);
133 void camq_insert(struct camq *queue, cam_pinfo *new_entry);
139 cam_pinfo *camq_remove(struct camq *queue, int index);
153 void camq_change_priority(struct camq *queue, int index,
172 cam_ccbq_send_ccb(struct cam_ccbq *queue, union ccb *send_ccb);
184 return (ccbq->queue.entries + ccbq->queue_extra_entries); in cam_ccbq_pending_ccb_count()
198 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
[all …]
/trueos/sys/contrib/octeon-sdk/
HDcvmx-pko.c287 int queue, base_queue, num_queues; in __cvmx_pko_iport_config() local
309 for (queue = 0; queue < num_queues; queue++) in __cvmx_pko_iport_config()
312 priorities[queue] == CVMX_PKO_QUEUE_STATIC_PRIORITY) in __cvmx_pko_iport_config()
313 static_priority_base = queue; in __cvmx_pko_iport_config()
317 priorities[queue] != CVMX_PKO_QUEUE_STATIC_PRIORITY && in __cvmx_pko_iport_config()
318 queue) in __cvmx_pko_iport_config()
319 static_priority_end = queue - 1; in __cvmx_pko_iport_config()
322 queue == num_queues - 1) in __cvmx_pko_iport_config()
323 static_priority_end = queue; /* all queues are static priority */ in __cvmx_pko_iport_config()
331 (int)queue > static_priority_end && in __cvmx_pko_iport_config()
[all …]
HDcvmx-zip.c96 int cvmx_zip_queue_initialize(int queue, int zcoremask) in cvmx_zip_queue_initialize() argument
110 result = cvmx_cmd_queue_initialize(CVMX_CMD_QUEUE_ZIP_QUE(queue), 0, in cvmx_zip_queue_initialize()
122 zip_que_buf.s.ptr = cvmx_ptr_to_phys(cvmx_cmd_queue_buffer(CVMX_CMD_QUEUE_ZIP_QUE(queue)))>>7; in cvmx_zip_queue_initialize()
123 cvmx_write_csr(CVMX_ZIP_QUEX_BUF(queue), zip_que_buf.u64); in cvmx_zip_queue_initialize()
126 que_map.u64 = cvmx_read_csr(CVMX_ZIP_QUEX_MAP(queue)); in cvmx_zip_queue_initialize()
128 cvmx_write_csr(CVMX_ZIP_QUEX_MAP(queue), que_map.u64); in cvmx_zip_queue_initialize()
132 que_ena.s.ena |= (1<<queue); in cvmx_zip_queue_initialize()
139 if (queue) in cvmx_zip_queue_initialize()
146 cvmx_read_csr(CVMX_ZIP_QUEX_BUF(queue)); in cvmx_zip_queue_initialize()
183 int cvmx_zip_queue_shutdown(int queue) in cvmx_zip_queue_shutdown() argument
[all …]
HDcvmx-pko.h179 …uint64_t queue : 9; /**< The output queue to send the packet to (0-127 are leg… member
283 static inline void cvmx_pko_doorbell(uint64_t ipd_port, uint64_t queue, uint64_t len) in cvmx_pko_doorbell() argument
297 ptr.s.queue = queue; in cvmx_pko_doorbell()
338 static inline void cvmx_pko_send_packet_prepare(uint64_t port, uint64_t queue, cvmx_pko_lock_t use_… in cvmx_pko_send_packet_prepare() argument
347 …AG_SW_SHIFT | CVMX_TAG_SUBGROUP_PKO << CVMX_TAG_SUBGROUP_SHIFT | (CVMX_TAG_SUBGROUP_MASK & queue); in cvmx_pko_send_packet_prepare()
374 static inline cvmx_pko_status_t cvmx_pko_send_packet_finish(uint64_t ipd_port, uint64_t queue, in cvmx_pko_send_packet_finish() argument
381 result = cvmx_cmd_queue_write2(CVMX_CMD_QUEUE_PKO(queue), in cvmx_pko_send_packet_finish()
387 cvmx_pko_doorbell(ipd_port, queue, 2); in cvmx_pko_send_packet_finish()
422 static inline cvmx_pko_status_t cvmx_pko_send_packet_finish3(uint64_t ipd_port, uint64_t queue, in cvmx_pko_send_packet_finish3() argument
429 result = cvmx_cmd_queue_write3(CVMX_CMD_QUEUE_PKO(queue), in cvmx_pko_send_packet_finish3()
[all …]
/trueos/share/examples/pf/
HDfaq-example310 # enable queueing on the external interface to queue packets going out
12 # each queue can be controlled. the max outgoing bandwidth is 1.5Mbps.
14 altq on fxp0 cbq bandwidth 1.5Mb queue { std_ext, www_ext, boss_ext }
17 # std_ext - the standard queue. also the default queue for
19 # www_ext - container queue for WWW server queues. limit to
25 queue std_ext bandwidth 500Kb cbq(default borrow)
26 queue www_ext bandwidth 500Kb { www_ext_http, www_ext_misc }
27 queue www_ext_http bandwidth 50% priority 3 cbq(red borrow)
28 queue www_ext_misc bandwidth 50% priority 1 cbq(borrow)
29 queue boss_ext bandwidth 500Kb priority 3 cbq(borrow)
[all …]
HDfaq-example213 # ACK queue.
15 altq on fxp0 priq bandwidth 610Kb queue { std_out, ssh_im_out, dns_out, \
19 # std_out - the standard queue. any filter rule below that does not
20 # explicitly specify a queue will have its traffic added
21 # to this queue.
26 queue std_out priq(default)
27 queue ssh_im_out priority 4 priq(red)
28 queue dns_out priority 5
29 queue tcp_ack_out priority 6
35 altq on dc0 cbq bandwidth 2Mb queue { std_in, ssh_im_in, dns_in, bob_in }
[all …]
HDqueue23 # advanced queue example.
10 altq on $ext_if cbq bandwidth 5Mb queue { std, http, mail, ssh }
12 queue std bandwidth 10% cbq(default)
13 queue http bandwidth 60% priority 2 cbq(borrow red) { employees, developers }
14 queue developers bandwidth 75% cbq(borrow)
15 queue employees bandwidth 15%
16 queue mail bandwidth 10% priority 0 cbq(borrow ecn)
17 queue ssh bandwidth 20% cbq(borrow) { ssh_interactive, ssh_bulk }
18 queue ssh_interactive bandwidth 25% priority 7
19 queue ssh_bulk bandwidth 75% priority 0
[all …]
HDqueue17 queue { deflt, http, ssh, mail, rsets }
8 queue deflt bandwidth 10% priority 0 cbq(default ecn)
9 queue http bandwidth 1.5Mb priority 3 { http_vhosts, http_cust1 }
10 queue http_vhosts bandwidth 40% cbq(borrow red)
11 queue http_cust1 bandwidth 0.5Mb
12 queue mail bandwidth 10% priority 1
13 queue ssh bandwidth 100Kb priority 7 cbq(borrow)
14 queue rsets bandwidth 7500b priority 0 cbq(red)
16 block return in on $ext_if inet all queue rsets
17 pass in on $ext_if inet proto tcp from any to any port 80 queue http
[all …]
HDqueue411 # whenever there is no backlogged sibling queue but when a queue gets
12 # backlogged, it is guaranteed that the queue gets its linkshare.
14 altq on dc0 bandwidth 16Mb hfsc queue { eng law art }
15 queue eng bandwidth 10Mb { cs ee ie }
16 queue cs hfsc( default linkshare 50% )
17 queue ee hfsc( linkshare 30% )
18 queue ie hfsc( linkshare 20% )
19 queue law bandwidth 3Mb
20 queue art bandwidth 3Mb
/trueos/sys/sys/mach/ipc/
HDipc_thread.h103 #define ipc_thread_queue_init(queue) \ argument
105 (queue)->ithq_base = ITH_NULL; \
108 #define ipc_thread_queue_empty(queue) ((queue)->ithq_base == ITH_NULL) argument
110 #define ipc_thread_queue_first(queue) ((queue)->ithq_base) argument
112 #define ipc_thread_rmqueue_first_macro(queue, thread) \ argument
116 assert((queue)->ithq_base == (thread)); \
121 (queue)->ithq_base = ITH_NULL; \
125 (queue)->ithq_base = _next; \
132 #define ipc_thread_enqueue_macro(queue, thread) \ argument
134 register ipc_thread_t _first = (queue)->ithq_base; \
[all …]
HDipc_kmsg.h222 #define ipc_kmsg_queue_init(queue) \ argument
224 (queue)->ikmq_base = IKM_NULL; \
227 #define ipc_kmsg_queue_empty(queue) ((queue)->ikmq_base == IKM_NULL) argument
231 ipc_kmsg_queue_t queue,
236 ipc_kmsg_queue_t queue);
240 ipc_kmsg_queue_t queue,
243 #define ipc_kmsg_queue_first(queue) ((queue)->ikmq_base) argument
247 ipc_kmsg_queue_t queue,
250 #define ipc_kmsg_rmqueue_first_macro(queue, kmsg) \ argument
254 assert((queue)->ikmq_base == (kmsg)); \
[all …]
/trueos/sys/compat/mach/ipc/
HDipc_thread.c88 ipc_thread_queue_t queue, in ipc_thread_enqueue() argument
91 ipc_thread_enqueue_macro(queue, thread); in ipc_thread_enqueue()
102 ipc_thread_queue_t queue) in ipc_thread_dequeue() argument
106 first = ipc_thread_queue_first(queue); in ipc_thread_dequeue()
109 ipc_thread_rmqueue_first_macro(queue, first); in ipc_thread_dequeue()
122 ipc_thread_queue_t queue, in ipc_thread_rmqueue() argument
127 assert(queue->ithq_base != ITH_NULL); in ipc_thread_rmqueue()
134 assert(queue->ithq_base == thread); in ipc_thread_rmqueue()
136 queue->ithq_base = ITH_NULL; in ipc_thread_rmqueue()
138 if (queue->ithq_base == thread) in ipc_thread_rmqueue()
[all …]
/trueos/contrib/libc++/include/
Dqueue2 //===--------------------------- queue ------------------------------------===//
15 queue synopsis
21 class queue
34 queue() = default;
35 ~queue() = default;
37 queue(const queue& q) = default;
38 queue(queue&& q) = default;
40 queue& operator=(const queue& q) = default;
41 queue& operator=(queue&& q) = default;
43 explicit queue(const container_type& c);
[all …]
/trueos/sys/sys/
HDtaskqueue.h74 int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
75 int taskqueue_enqueue_timeout(struct taskqueue *queue,
77 int taskqueue_cancel(struct taskqueue *queue, struct task *task,
79 int taskqueue_cancel_timeout(struct taskqueue *queue,
81 void taskqueue_drain(struct taskqueue *queue, struct task *task);
82 void taskqueue_drain_timeout(struct taskqueue *queue,
84 void taskqueue_drain_all(struct taskqueue *queue);
85 void taskqueue_free(struct taskqueue *queue);
86 void taskqueue_run(struct taskqueue *queue);
87 void taskqueue_block(struct taskqueue *queue);
[all …]
/trueos/contrib/libstdc++/include/bits/
Dstl_queue.h95 class queue in _GLIBCXX_BEGIN_NAMESPACE()
106 operator==(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_BEGIN_NAMESPACE()
110 operator<(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_BEGIN_NAMESPACE()
135 queue(const _Sequence& __c = _Sequence()) : c(__c) {} in _GLIBCXX_BEGIN_NAMESPACE()
239 operator==(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
257 operator<(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
263 operator!=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
269 operator>(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
275 operator<=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
281 operator>=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
/trueos/lib/libdispatch/dispatch/
HDqueue.h103 dispatch_async(dispatch_queue_t queue, dispatch_block_t block);
133 dispatch_async_f(dispatch_queue_t queue,
171 dispatch_sync(dispatch_queue_t queue, dispatch_block_t block);
199 dispatch_sync_f(dispatch_queue_t queue,
232 dispatch_apply(size_t iterations, dispatch_queue_t queue,
265 dispatch_apply_f(size_t iterations, dispatch_queue_t queue,
575 dispatch_queue_get_label(dispatch_queue_t queue);
614 dispatch_queue_get_qos_class(dispatch_queue_t queue,
673 dispatch_set_target_queue(dispatch_object_t object, dispatch_queue_t queue);
720 dispatch_queue_t queue,
[all …]
/trueos/contrib/libyaml/src/
HDyaml_private.h436 #define QUEUE_INIT(context,queue,size) \ argument
437 (((queue).start = yaml_malloc((size)*sizeof(*(queue).start))) ? \
438 ((queue).head = (queue).tail = (queue).start, \
439 (queue).end = (queue).start+(size), \
444 #define QUEUE_DEL(context,queue) \ argument
445 (yaml_free((queue).start), \
446 (queue).start = (queue).head = (queue).tail = (queue).end = 0)
448 #define QUEUE_EMPTY(context,queue) \ argument
449 ((queue).head == (queue).tail)
451 #define ENQUEUE(context,queue,value) \ argument
[all …]
/trueos/contrib/apr-util/include/
HDapr_queue.h55 APU_DECLARE(apr_status_t) apr_queue_create(apr_queue_t **queue,
68 APU_DECLARE(apr_status_t) apr_queue_push(apr_queue_t *queue, void *data);
79 APU_DECLARE(apr_status_t) apr_queue_pop(apr_queue_t *queue, void **data);
91 APU_DECLARE(apr_status_t) apr_queue_trypush(apr_queue_t *queue, void *data);
103 APU_DECLARE(apr_status_t) apr_queue_trypop(apr_queue_t *queue, void **data);
113 APU_DECLARE(unsigned int) apr_queue_size(apr_queue_t *queue);
120 APU_DECLARE(apr_status_t) apr_queue_interrupt_all(apr_queue_t *queue);
128 APU_DECLARE(apr_status_t) apr_queue_term(apr_queue_t *queue);

12345678910>>...19