/freebsd-10.0-release/contrib/apr-util/misc/ |
H A D | apr_queue.c | 48 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 D | queue.h | 32 #include <queue> 34 using std::queue;
|
/freebsd-10.0-release/sys/dev/nxge/xgehal/ |
H A D | xge-queue.c | 29 #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 D | apr_queue.h | 22 * @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 D | nfsrvcache.h | 39 #include <sys/queue.h>
|
/freebsd-10.0-release/sys/dev/vxge/vxgehal/ |
H A D | vxge-queue.c | 42 * 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 D | Makefile | 15 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 D | subr_taskqueue.c | 95 _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 D | cam_queue.c | 2 * 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 D | cam_queue.h | 2 * 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 D | dispqlen.d | 3 * 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 D | dispqlen.d | 3 * 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 D | singletons.h | 37 int queue; member in struct:runtime_env
|
/freebsd-10.0-release/sys/contrib/octeon-sdk/ |
H A D | cvmx-zip.c | 57 #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 D | cvmx-pko.c | 185 * 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 D | taskqueue.h | 36 #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.h | 32 #include <sys/queue.h> 47 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
|
/freebsd-10.0-release/lib/libgssapi/ |
H A D | cred.h | 29 #include <sys/queue.h>
|
/freebsd-10.0-release/tools/tools/aac/ |
H A D | aac_checkq.c | 44 * 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 D | mfi_checkq.c | 41 * 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 D | dequeue | 5 /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 D | fixwhite.c | 35 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 D | queue.c | 1 /* $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 D | subr_disk.c | 28 * 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 D | stl_queue.h | 83 * 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...] |