/freebsd-9.3-release/contrib/libstdc++/include/backward/ |
H A D | queue.h | 32 #include <queue> 34 using std::queue;
|
/freebsd-9.3-release/contrib/ntp/lib/isc/include/isc/ |
H A D | queue.h | 20 * This is a generic implementation of a two-lock concurrent queue. 21 * There are built-in mutex locks for the head and tail of the queue, 51 #define ISC_QUEUE_INIT(queue, link) \ 53 isc_mutex_init(&(queue).headlock); \ 54 isc_mutex_init(&(queue).taillock); \ 55 (queue).head = (void *) &((queue).headnode); \ 56 (queue).tail = (void *) &((queue).headnode); \ 57 ISC_QLINK_INIT((queue) [all...] |
/freebsd-9.3-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-9.3-release/contrib/bind9/lib/isc/include/isc/ |
H A D | queue.h | 20 * This is a generic implementation of a two-lock concurrent queue. 21 * There are built-in mutex locks for the head and tail of the queue, 54 #define ISC_QUEUE_INIT(queue, link) \ 56 (void) isc_mutex_init(&(queue).taillock); \ 57 (void) isc_mutex_init(&(queue).headlock); \ 58 (queue).tail = (queue).head = NULL; \ 61 #define ISC_QUEUE_EMPTY(queue) ISC_TF((queue).head == NULL) 63 #define ISC_QUEUE_DESTROY(queue) \ [all...] |
/freebsd-9.3-release/share/man/man3/ |
H A D | Makefile | 13 queue.3 \ 43 MLINKS+= queue.3 LIST_EMPTY.3 \ 44 queue.3 LIST_ENTRY.3 \ 45 queue.3 LIST_FIRST.3 \ 46 queue.3 LIST_FOREACH.3 \ 47 queue.3 LIST_FOREACH_SAFE.3 \ 48 queue.3 LIST_HEAD.3 \ 49 queue.3 LIST_HEAD_INITIALIZER.3 \ 50 queue.3 LIST_INIT.3 \ 51 queue [all...] |
/freebsd-9.3-release/sys/nfsserver/ |
H A D | nfsrvcache.h | 39 #include <sys/queue.h>
|
/freebsd-9.3-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-9.3-release/sys/kern/ |
H A D | subr_taskqueue.c | 91 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, argument 96 callout_init_mtx(&timeout_task->c, &queue->tq_mutex, 0); 97 timeout_task->q = queue; 115 struct taskqueue *queue; local 117 queue = malloc(sizeof(struct taskqueue), M_TASKQUEUE, mflags | M_ZERO); 118 if (!queue) 121 STAILQ_INIT(&queue->tq_queue); 122 TAILQ_INIT(&queue->tq_active); 123 queue->tq_enqueue = enqueue; 124 queue 154 taskqueue_free(struct taskqueue *queue) argument 168 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) argument 210 taskqueue_enqueue(struct taskqueue *queue, struct task *task) argument 224 struct taskqueue *queue; local 236 taskqueue_enqueue_timeout(struct taskqueue *queue, struct timeout_task *timeout_task, int ticks) argument 268 taskqueue_drain_running(struct taskqueue *queue) argument 277 taskqueue_block(struct taskqueue *queue) argument 286 taskqueue_unblock(struct taskqueue *queue) argument 299 taskqueue_run_locked(struct taskqueue *queue) argument 333 taskqueue_run(struct taskqueue *queue) argument 342 task_is_running(struct taskqueue *queue, struct task *task) argument 355 taskqueue_cancel_locked(struct taskqueue *queue, struct task *task, u_int *pendp) argument 368 taskqueue_cancel(struct taskqueue *queue, struct task *task, u_int *pendp) argument 380 taskqueue_cancel_timeout(struct taskqueue *queue, struct timeout_task *timeout_task, u_int *pendp) argument 401 taskqueue_drain(struct taskqueue *queue, struct task *task) argument 414 taskqueue_drain_all(struct taskqueue *queue) argument 433 taskqueue_drain_timeout(struct taskqueue *queue, struct timeout_task *timeout_task) argument 580 taskqueue_enqueue_fast(struct taskqueue *queue, struct task *task) argument 604 taskqueue_member(struct taskqueue *queue, struct thread *td) argument [all...] |
/freebsd-9.3-release/contrib/ntp/include/ |
H A D | ntp_prio_q.h | 4 * priority queue implementation used by the discrete event simulator. 17 /* Structures for storing a priority queue 35 } queue; typedef in typeref:struct:Queue 41 /* Define a function to create a FIFO queue */ 44 void destroy_queue(queue *my_queue); 47 int empty(queue *my_queue); 48 void *queue_head(queue *my_queue); 49 queue *enqueue(queue *my_queue, void *my_node); 50 void append_queue(queue *q [all...] |
/freebsd-9.3-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-9.3-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-9.3-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-9.3-release/usr.sbin/nscd/ |
H A D | singletons.h | 37 int queue; member in struct:runtime_env
|
/freebsd-9.3-release/contrib/ntp/lib/isc/tests/ |
H A D | queue_test.c | 28 #include <isc/queue.h> 52 atf_tc_set_md_var(tc, "descr", "Check queue validity"); 56 item_queue_t queue; local 62 ISC_QUEUE_INIT(queue, qlink); 73 ATF_CHECK(ISC_QUEUE_EMPTY(queue)); 75 ISC_QUEUE_POP(queue, qlink, p); 79 ISC_QUEUE_PUSH(queue, &one, qlink); 82 ATF_CHECK(! ISC_QUEUE_EMPTY(queue)); 84 ISC_QUEUE_POP(queue, qlink, p); 87 ATF_CHECK(ISC_QUEUE_EMPTY(queue)); [all...] |
/freebsd-9.3-release/sys/mips/nlm/hal/ |
H A D | fmn.c | 41 /* XLP can take upto 16K of FMN messages per hardware queue, as spill. 44 * chip configuration. Hence for now, we will setup the per queue spill 84 * entries of the same output queue are placed in successive banks. 86 * output queue over as many different banks as possible so that they 94 * Each output queue can be sized from 32-entry to 1024-entry in 97 * to the output queue. 112 * Output queue pointer information: 153 /* Configure 32 as onchip queue depth */ 163 /* configure credits for src cpu0, on this queue */ 168 /* configure credits for src cpu1, on this queue */ 346 int queue; local 465 int queue; local 560 int queue; local [all...] |
/freebsd-9.3-release/contrib/ntp/ntpd/ |
H A D | ntp_prio_q.c | 3 * This file contains the priority queue implementation used by the 20 * Define a priority queue in which the relative priority of the elements 24 queue *debug_create_priority_queue( 32 queue *my_queue; 35 my_queue = emalloc(sizeof(queue)); 38 my_queue = debug_erealloc(NULL, sizeof(queue), sourcefile, line_num); 48 /* Define a function to "destroy" a priority queue, freeing-up 53 queue *my_queue 58 /* Empty out the queue elements if they are not already empty */ 65 /* Now free the queue */ [all...] |
/freebsd-9.3-release/sys/contrib/octeon-sdk/ |
H A D | cvmx-pko.c | 191 int queue; local 195 for (queue=0; queue<CVMX_PKO_MAX_OUTPUT_QUEUES; queue++) 201 config.s.queue = queue & 0x7f; 208 config1.s.qid7 = queue >> 7; 212 cvmx_cmd_queue_shutdown(CVMX_CMD_QUEUE_PKO(queue)); 222 * @param base_queue First queue number to associate with this port. 224 * @param priority Array of priority levels for each queue 238 uint64_t queue; local [all...] |
/freebsd-9.3-release/sys/sys/ |
H A D | taskqueue.h | 36 #include <sys/queue.h> 54 * queue to arrange to run itself later (e.g., by scheduling a software 64 int taskqueue_enqueue(struct taskqueue *queue, struct task *task); 65 int taskqueue_enqueue_timeout(struct taskqueue *queue, 67 int taskqueue_cancel(struct taskqueue *queue, struct task *task, 69 int taskqueue_cancel_timeout(struct taskqueue *queue, 71 void taskqueue_drain(struct taskqueue *queue, struct task *task); 72 void taskqueue_drain_timeout(struct taskqueue *queue, 74 void taskqueue_drain_all(struct taskqueue *queue); 75 void taskqueue_free(struct taskqueue *queue); [all...] |
H A D | _task.h | 32 #include <sys/queue.h> 47 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
|
H A D | sleepqueue.h | 33 * Sleep queue interface. Sleep/wakeup, condition variables, and sx 34 * locks use a sleep queue for the queue of threads blocked on a sleep 37 * A thread calls sleepq_lock() to lock the sleep queue chain associated 39 * add themself onto a sleep queue and call one of the sleepq_wait() 42 * queue chain lock. If the thread also needs to remove itself from a queue 56 * A thread is normally resumed from a sleep queue by either the 62 * be removed from a specified sleep queue using the sleepq_remove() 63 * function. Note that the sleep queue chai [all...] |
/freebsd-9.3-release/lib/libgssapi/ |
H A D | cred.h | 29 #include <sys/queue.h>
|
/freebsd-9.3-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-9.3-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-9.3-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
|