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

1234567891011>>

/freebsd-9.3-release/contrib/libstdc++/include/backward/
H A Dqueue.h32 #include <queue>
34 using std::queue;
/freebsd-9.3-release/contrib/ntp/lib/isc/include/isc/
H A Dqueue.h20 * 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 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-9.3-release/contrib/bind9/lib/isc/include/isc/
H A Dqueue.h20 * 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 DMakefile13 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 Dnfsrvcache.h39 #include <sys/queue.h>
/freebsd-9.3-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-9.3-release/sys/kern/
H A Dsubr_taskqueue.c91 _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 Dntp_prio_q.h4 * 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 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-9.3-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-9.3-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-9.3-release/usr.sbin/nscd/
H A Dsingletons.h37 int queue; member in struct:runtime_env
/freebsd-9.3-release/contrib/ntp/lib/isc/tests/
H A Dqueue_test.c28 #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 Dfmn.c41 /* 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 Dntp_prio_q.c3 * 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 Dcvmx-pko.c191 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 Dtaskqueue.h36 #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.h32 #include <sys/queue.h>
47 STAILQ_ENTRY(task) ta_link; /* (q) link for queue */
H A Dsleepqueue.h33 * 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 Dcred.h29 #include <sys/queue.h>
/freebsd-9.3-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-9.3-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-9.3-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

Completed in 203 milliseconds

1234567891011>>