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

1234567891011>>

/freebsd-10.0-release/contrib/apr-util/misc/
H A Dapr_queue.c48 unsigned int bounds;/**< max size of queue */
73 #define apr_queue_full(queue) ((queue)->nelts == (queue)->bounds)
79 #define apr_queue_empty(queue) ((queue)->nelts == 0)
87 apr_queue_t *queue = data; local
91 apr_thread_cond_destroy(queue->not_empty);
92 apr_thread_cond_destroy(queue->not_full);
93 apr_thread_mutex_destroy(queue
106 apr_queue_t *queue; local
251 apr_queue_size(apr_queue_t *queue) argument
[all...]
/freebsd-10.0-release/contrib/libstdc++/include/backward/
H A Dqueue.h32 #include <queue>
34 using std::queue;
/freebsd-10.0-release/sys/dev/nxge/xgehal/
H A Dxge-queue.c29 #include <dev/nxge/include/xge-queue.h>
38 * user-defined portion of the queue item.
46 * __queue_consume - (Lockless) dequeue an item from the specified queue.
48 * @queue: Event queue.
52 __queue_consume(xge_queue_t *queue, int data_max_size, xge_queue_item_t *item) argument
57 if (xge_list_is_empty(&queue->list_head))
60 elem = (xge_queue_item_t *)queue->list_head.next;
66 if (queue->head_ptr == elem) {
67 queue
147 xge_queue_t *queue = (xge_queue_t *)queueh; local
264 xge_queue_t *queue; local
301 xge_queue_t *queue = (xge_queue_t *)queueh; local
328 xge_queue_t *queue = (xge_queue_t *)queueh; local
399 xge_queue_t *queue = (xge_queue_t *)queueh; local
447 xge_queue_t* queue = (xge_queue_t*)qh; local
[all...]
/freebsd-10.0-release/contrib/apr-util/include/
H A Dapr_queue.h22 * @brief Thread Safe FIFO bounded queue
23 * @note Since most implementations of the queue are backed by a condition
39 * @defgroup APR_Util_FIFO Thread Safe FIFO bounded queue
50 * create a FIFO queue
51 * @param queue The new queue
52 * @param queue_capacity maximum size of the queue
53 * @param a pool to allocate queue from
55 APU_DECLARE(apr_status_t) apr_queue_create(apr_queue_t **queue,
60 * push/add an object to the queue, blockin
113 APU_DECLARE(unsigned int) apr_queue_size(apr_queue_t *queue); variable
120 APU_DECLARE(apr_status_t) apr_queue_interrupt_all(apr_queue_t *queue); variable
128 APU_DECLARE(apr_status_t) apr_queue_term(apr_queue_t *queue); variable
[all...]
/freebsd-10.0-release/sys/nfsserver/
H A Dnfsrvcache.h39 #include <sys/queue.h>
/freebsd-10.0-release/sys/dev/vxge/vxgehal/
H A Dvxge-queue.c42 * user-defined portion of the queue item.
51 * __queue_consume - (Lockless) dequeue an item from the specified queue.
53 * @queue: Event queue.
59 __queue_consume(vxge_queue_t *queue, argument
67 vxge_assert(queue != NULL);
69 hldev = (__hal_device_t *) queue->hldev;
75 "queue = 0x"VXGE_OS_STXFMT", size = %d, item = 0x"VXGE_OS_STXFMT,
76 (ptr_t) queue, data_max_size, (ptr_t) item);
78 if (vxge_list_is_empty(&queue
170 vxge_queue_t *queue = (vxge_queue_t *) queueh; local
303 vxge_queue_t *queue; local
363 vxge_queue_t *queue = (vxge_queue_t *) queueh; local
405 vxge_queue_t *queue = (vxge_queue_t *) queueh; local
500 vxge_queue_t *queue = (vxge_queue_t *) queueh; local
540 vxge_queue_t *queue = (vxge_queue_t *) queueh; local
579 vxge_queue_t *queue = (vxge_queue_t *) queueh; local
[all...]
/freebsd-10.0-release/share/man/man3/
H A DMakefile15 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
[all...]
/freebsd-10.0-release/sys/kern/
H A Dsubr_taskqueue.c95 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, argument
100 callout_init_mtx(&timeout_task->c, &queue->tq_mutex, 0);
101 timeout_task->q = queue;
119 struct taskqueue *queue; local
121 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO);
122 if (!queue)
125 STAILQ_INIT(&queue->tq_queue);
126 TAILQ_INIT(&queue->tq_active);
127 queue->tq_enqueue = enqueue;
128 queue
145 taskqueue_set_callback(struct taskqueue *queue, enum taskqueue_callback_type cb_type, taskqueue_callback_fn callback, void *context) argument
175 taskqueue_free(struct taskqueue *queue) argument
189 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) argument
231 taskqueue_enqueue(struct taskqueue *queue, struct task *task) argument
245 struct taskqueue *queue; local
257 taskqueue_enqueue_timeout(struct taskqueue *queue, struct timeout_task *timeout_task, int ticks) argument
289 taskqueue_block(struct taskqueue *queue) argument
298 taskqueue_unblock(struct taskqueue *queue) argument
311 taskqueue_run_locked(struct taskqueue *queue) argument
343 taskqueue_run(struct taskqueue *queue) argument
352 task_is_running(struct taskqueue *queue, struct task *task) argument
365 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, u_int *pendp) argument
378 taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp) argument
392 taskqueue_cancel_timeout(struct taskqueue *queue, struct timeout_task *timeout_task, u_int *pendp) argument
413 taskqueue_drain(struct taskqueue *queue, struct task *task) argument
426 taskqueue_drain_timeout(struct taskqueue *queue, struct timeout_task *timeout_task) argument
595 taskqueue_enqueue_fast(struct taskqueue *queue, struct task *task) argument
619 taskqueue_member(struct taskqueue *queue, struct thread *td) argument
[all...]
/freebsd-10.0-release/sys/cam/
H A Dcam_queue.c2 * CAM request queue management functions.
43 static MALLOC_DEFINE(M_CAMQ, "CAM queue", "CAM queue buffers");
44 static MALLOC_DEFINE(M_CAMDEVQ, "CAM dev queue", "CAM dev queue buffers");
45 static MALLOC_DEFINE(M_CAMCCBQ, "CAM ccb queue", "CAM ccb queue buffers");
94 * obtained a camq structure. The XPT should ensure that the queue
98 camq_free(struct camq *queue) argument
100 if (queue !
107 camq_fini(struct camq *queue) argument
120 camq_resize(struct camq *queue, int new_size) argument
155 camq_insert(struct camq *queue, cam_pinfo *new_entry) argument
175 camq_remove(struct camq *queue, int index) argument
199 camq_change_priority(struct camq *queue, int index, u_int32_t new_priority) argument
[all...]
H A Dcam_queue.h2 * CAM request queue management definitions.
36 #include <sys/queue.h>
40 * This structure implements a heap based priority queue. The queue
59 struct camq queue; member in struct:cam_ccbq
106 * Resize a cam queue
108 u_int32_t camq_resize(struct camq *queue, int new_size);
120 void camq_free(struct camq *queue);
125 void camq_fini(struct camq *queue);
128 * cam_queue_insert: Given a CAM queue wit
196 struct camq *queue = &ccbq->queue; local
220 struct camq *queue = &ccbq->queue; local
[all...]
/freebsd-10.0-release/cddl/contrib/dtracetoolkit/Bin/
H A Ddispqlen.d3 * dispqlen.d - dispatcher queue length by CPU.
10 * NOTES: The dispatcher queue length is an indication of CPU saturation.
12 * utilised when the dispatcher queue reports a length of zero.
45 @queue[cpu] =
51 printa(" CPU %d%@d\n", @queue);
/freebsd-10.0-release/cddl/contrib/dtracetoolkit/Cpu/
H A Ddispqlen.d3 * dispqlen.d - dispatcher queue length by CPU.
10 * NOTES: The dispatcher queue length is an indication of CPU saturation.
12 * utilised when the dispatcher queue reports a length of zero.
45 @queue[cpu] =
51 printa(" CPU %d%@d\n", @queue);
/freebsd-10.0-release/usr.sbin/nscd/
H A Dsingletons.h37 int queue; member in struct:runtime_env
/freebsd-10.0-release/sys/contrib/octeon-sdk/
H A Dcvmx-zip.c57 #include "cvmx-cmd-queue.h"
91 * @param queue : ZIP instruction queue
92 * @param zcoremask : ZIP coremask to use for this queue
96 int cvmx_zip_queue_initialize(int queue, int zcoremask) argument
104 /* Previous Octeon models has only one instruction queue, call
110 result = cvmx_cmd_queue_initialize(CVMX_CMD_QUEUE_ZIP_QUE(queue), 0,
117 size configured for each instruction queue */
122 zip_que_buf.s.ptr = cvmx_ptr_to_phys(cvmx_cmd_queue_buffer(CVMX_CMD_QUEUE_ZIP_QUE(queue)))>>7;
123 cvmx_write_csr(CVMX_ZIP_QUEX_BUF(queue), zip_que_bu
183 cvmx_zip_queue_shutdown(int queue) argument
225 cvmx_zip_queue_submit(cvmx_zip_command_t *command, int queue) argument
[all...]
H A Dcvmx-pko.c185 * For a given PKO port number, return the base output queue
189 * @return Base output queue
247 cvmx_dprintf("pko_port %d (interface%d index%d) has %d queues (queue base = %d)\n",
287 int queue, base_queue, num_queues; local
301 * Give the user a chance to override the per queue priorities.
307 * static queue priority validation
309 for (queue = 0; queue < num_queues; queue++)
312 priorities[queue]
729 int queue; local
792 uint64_t queue; local
[all...]
/freebsd-10.0-release/sys/sys/
H A Dtaskqueue.h36 #include <sys/queue.h>
64 * queue to arrange to run itself later (e.g., by scheduling a software
74 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_free(struct taskqueue *queue);
85 void taskqueue_run(struct taskqueue *queue);
[all...]
H A D_task.h32 #include <sys/queue.h>
47 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
/freebsd-10.0-release/lib/libgssapi/
H A Dcred.h29 #include <sys/queue.h>
/freebsd-10.0-release/tools/tools/aac/
H A Daac_checkq.c44 * Simple program to print out the queue stats on the given queue index.
45 * See /sys/sys/aac_ioctl.h for the definitions of each queue index.
59 int fd, retval, queue; local
70 queue = atoi(argv[1]);
71 printf("Getting stats for queue %d\n", queue);
73 sr.as_item = queue;
/freebsd-10.0-release/tools/tools/mfi/
H A Dmfi_checkq.c41 * Simple program to print out the queue stats on the given queue index.
42 * See /sys/sys/mfi_ioctl.h for the definitions of each queue index.
56 int fd, retval, queue; local
67 queue = atoi(argv[1]);
68 printf("Getting stats for queue %d\n", queue);
70 sr.ms_item = queue;
/freebsd-10.0-release/usr.sbin/ctm/mkCTM/
H A Ddequeue5 /usr/sbin/ctm_dequeue -n 1 -l $L /home/ctm/queue/ctm-cvs-cur
6 /usr/sbin/ctm_dequeue -n 1 -l $L /home/ctm/queue/ctm-src-cur
/freebsd-10.0-release/tools/tools/fixwhite/
H A Dfixwhite.c35 static char *queue = NULL; variable
45 queue = realloc(queue, queuesize);
46 if (queue == NULL) {
51 queue[queuelen++] = c;
70 return (queuelen >= back && queue[queuelen - back] == c);
123 queue[queuelen++] = '\t';
127 if (fwrite(queue, 1, queuelen, stdout) != queuelen) {
/freebsd-10.0-release/usr.bin/grep/
H A Dqueue.c1 /* $NetBSD: queue.c,v 1.2 2011/02/16 01:31:33 joerg Exp $ */
31 * A really poor man's queue. It does only what it has to and gets out of
32 * Dodge. It is used in place of <sys/queue.h> to get a better performance.
39 #include <sys/queue.h>
51 static STAILQ_HEAD(, qentry) queue = STAILQ_HEAD_INITIALIZER(queue);
69 STAILQ_INSERT_TAIL(&queue, item, list);
80 item = STAILQ_FIRST(&queue);
84 STAILQ_REMOVE_HEAD(&queue, list);
/freebsd-10.0-release/sys/geom/sched/
H A Dsubr_disk.c28 * BIO queue implementation
47 * bioq_first() return the head of the queue, without removing;
49 * bioq_takefirst() return and remove the head of the queue,
66 * request is extracted from the queue. However, the current API
71 * --- Direct queue manipulation ---
86 * bioq_remove() remove a generic element from the queue, act as
87 * bioq_takefirst() if invoked on the head of the queue.
97 * at the head of the queue even after subsequent bioq_disksort().
99 * Note that when the direct queue manipulation functions are used,
100 * the queue ma
[all...]
/freebsd-10.0-release/contrib/libstdc++/include/bits/
H A Dstl_queue.h83 * wrapper is what enforces strict first-in-first-out %queue behavior.
92 * @c pop, which are standard %queue/FIFO operations.
95 class queue class
106 operator==(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&);
110 operator<(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&);
135 queue(const _Sequence& __c = _Sequence()) : c(__c) {} function in class:queue
138 * Returns true if the %queue is empty.
144 /** Returns the number of elements in the %queue
239 operator ==(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) argument
257 operator <(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) argument
263 operator !=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) argument
269 operator >(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) argument
275 operator <=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) argument
281 operator >=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) argument
[all...]

Completed in 195 milliseconds

1234567891011>>