Home
last modified time | relevance | path

Searched defs:queue (Results 1 – 25 of 191) sorted by relevance

12345678

/NextBSD/sys/contrib/vchiq/interface/vchiq_arm/
HDvchiq_util.c41 int vchiu_queue_init(VCHIU_QUEUE_T *queue, int size) in vchiu_queue_init()
61 void vchiu_queue_delete(VCHIU_QUEUE_T *queue) in vchiu_queue_delete()
67 int vchiu_queue_is_empty(VCHIU_QUEUE_T *queue) in vchiu_queue_is_empty()
72 int vchiu_queue_is_full(VCHIU_QUEUE_T *queue) in vchiu_queue_is_full()
77 void vchiu_queue_push(VCHIU_QUEUE_T *queue, VCHIQ_HEADER_T *header) in vchiu_queue_push()
107 VCHIQ_HEADER_T *vchiu_queue_peek(VCHIU_QUEUE_T *queue) in vchiu_queue_peek()
126 VCHIQ_HEADER_T *vchiu_queue_pop(VCHIU_QUEUE_T *queue) in vchiu_queue_pop()
/NextBSD/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
106 apr_queue_t *queue; in apr_queue_create() local
148 APU_DECLARE(apr_status_t) apr_queue_push(apr_queue_t *queue, void *data) in apr_queue_push()
211 APU_DECLARE(apr_status_t) apr_queue_trypush(apr_queue_t *queue, void *data) in apr_queue_trypush()
251 APU_DECLARE(unsigned int) apr_queue_size(apr_queue_t *queue) { in apr_queue_size()
261 APU_DECLARE(apr_status_t) apr_queue_pop(apr_queue_t *queue, void **data) in apr_queue_pop()
325 APU_DECLARE(apr_status_t) apr_queue_trypop(apr_queue_t *queue, void **data) in apr_queue_trypop()
362 APU_DECLARE(apr_status_t) apr_queue_interrupt_all(apr_queue_t *queue) in apr_queue_interrupt_all()
[all …]
/NextBSD/sys/sys/mach/ipc/
HDipc_thread.h103 #define ipc_thread_queue_init(queue) \ argument
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
132 #define ipc_thread_enqueue_macro(queue, thread) \ argument
HDipc_kmsg.h222 #define ipc_kmsg_queue_init(queue) \ argument
227 #define ipc_kmsg_queue_empty(queue) ((queue)->ikmq_base == IKM_NULL) argument
243 #define ipc_kmsg_queue_first(queue) ((queue)->ikmq_base) argument
250 #define ipc_kmsg_rmqueue_first_macro(queue, kmsg) \ argument
272 #define ipc_kmsg_enqueue_macro(queue, kmsg) \ argument
/NextBSD/sys/dev/vxge/vxgehal/
HDvxge-queue.c59 __queue_consume(vxge_queue_t *queue, in __queue_consume()
170 vxge_queue_t *queue = (vxge_queue_t *) queueh; in vxge_queue_produce() local
303 vxge_queue_t *queue; in vxge_queue_create() local
363 vxge_queue_t *queue = (vxge_queue_t *) queueh; in vxge_queue_destroy() local
405 vxge_queue_t *queue = (vxge_queue_t *) queueh; in vxge_io_queue_grow() local
500 vxge_queue_t *queue = (vxge_queue_t *) queueh; in vxge_queue_consume() local
540 vxge_queue_t *queue = (vxge_queue_t *) queueh; in vxge_queue_flush() local
579 vxge_queue_t *queue = (vxge_queue_t *) queueh; in vxge_queue_get_reset_critical() local
/NextBSD/sys/compat/mach/ipc/
HDipc_thread.c88 ipc_thread_queue_t queue, in ipc_thread_enqueue()
102 ipc_thread_queue_t queue) in ipc_thread_dequeue()
122 ipc_thread_queue_t queue, in ipc_thread_rmqueue()
155 ipc_thread_queue_t queue, in ipc_thread_inqueue()
/NextBSD/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()
147 xge_queue_t *queue = (xge_queue_t *)queueh; in xge_queue_produce() local
264 xge_queue_t *queue; in xge_queue_create() local
301 xge_queue_t *queue = (xge_queue_t *)queueh; in xge_queue_destroy() local
328 xge_queue_t *queue = (xge_queue_t *)queueh; in __io_queue_grow() local
399 xge_queue_t *queue = (xge_queue_t *)queueh; in xge_queue_consume() local
447 xge_queue_t* queue = (xge_queue_t*)qh; in __queue_get_reset_critical() local
/NextBSD/contrib/ntp/lib/isc/include/isc/
HDqueue.h51 #define ISC_QUEUE_INIT(queue, link) \ argument
60 #define ISC_QUEUE_EMPTY(queue) ISC_TF((queue).head == (queue).tail) argument
62 #define ISC_QUEUE_DESTROY(queue) \ argument
69 #define ISC_QUEUE_PUSH(queue, elt, link) \ argument
80 #define ISC_QUEUE_POP(queue, link, ret) \ argument
/NextBSD/sys/kern/
HDsubr_taskqueue.c104 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init()
129 struct taskqueue *queue; in _taskqueue_create() local
168 taskqueue_set_callback(struct taskqueue *queue, in taskqueue_set_callback()
198 taskqueue_free(struct taskqueue *queue) in taskqueue_free()
213 taskqueue_enqueue_locked(struct taskqueue *queue, struct task *task) in taskqueue_enqueue_locked()
261 taskqueue_enqueue(struct taskqueue *queue, struct task *task) in taskqueue_enqueue()
275 struct taskqueue *queue; in taskqueue_timeout_func() local
288 taskqueue_enqueue_timeout(struct taskqueue *queue, in taskqueue_enqueue_timeout()
331 taskqueue_drain_tq_queue(struct taskqueue *queue) in taskqueue_drain_tq_queue()
364 taskqueue_drain_tq_active(struct taskqueue *queue) in taskqueue_drain_tq_active()
[all …]
HDsubr_turnstile.c292 int queue; in turnstile_adjust_thread() local
674 turnstile_wait(struct turnstile *ts, struct thread *owner, int queue) in turnstile_wait()
764 turnstile_signal(struct turnstile *ts, int queue) in turnstile_signal()
815 turnstile_broadcast(struct turnstile *ts, int queue) in turnstile_broadcast()
997 turnstile_head(struct turnstile *ts, int queue) in turnstile_head()
1012 turnstile_empty(struct turnstile *ts, int queue) in turnstile_empty()
1034 print_queue(struct threadqueue *queue, const char *header, const char *prefix) in print_queue()
/NextBSD/contrib/dma/
HDdma.c97 set_from(struct queue *queue, const char *osender) in set_from()
156 do_alias(struct queue *queue, const char *addr) in do_alias()
176 add_recp(struct queue *queue, const char *str, int expand) in add_recp()
243 go_background(struct queue *queue) in go_background()
375 run_queue(struct queue *queue) in run_queue()
388 show_queue(struct queue *queue) in show_queue()
424 struct queue queue; in main() local
HDspool.c72 newspoolf(struct queue *queue) in newspoolf()
154 readqueuef(struct queue *queue, char *queuefn) in readqueuef()
232 linkspool(struct queue *queue) in linkspool()
279 load_queue(struct queue *queue) in load_queue()
385 dropspool(struct queue *queue, struct qitem *keep) in dropspool()
HDdma.h121 struct queue { struct
122 struct queueh queue; argument
123 char *id;
124 FILE *mailf;
125 char *tmpf;
126 const char *sender;
/NextBSD/contrib/subversion/subversion/libsvn_subr/
HDsorts.c404 heap_is_less(svn_priority_queue__t *queue, in heap_is_less() argument
420 heap_swap(svn_priority_queue__t *queue, in heap_swap()
440 heap_bubble_down(svn_priority_queue__t *queue, in heap_bubble_down()
454 heap_bubble_up(svn_priority_queue__t *queue, in heap_bubble_up()
481 svn_priority_queue__t *queue = apr_pcalloc(elements->pool, sizeof(*queue)); in svn_priority_queue__create() local
492 svn_priority_queue__size(svn_priority_queue__t *queue) in svn_priority_queue__size()
498 svn_priority_queue__peek(svn_priority_queue__t *queue) in svn_priority_queue__peek()
504 svn_priority_queue__update(svn_priority_queue__t *queue) in svn_priority_queue__update()
510 svn_priority_queue__pop(svn_priority_queue__t *queue) in svn_priority_queue__pop()
524 svn_priority_queue__push(svn_priority_queue__t *queue, in svn_priority_queue__push()
/NextBSD/sys/cam/
HDcam_queue.c98 camq_free(struct camq *queue) in camq_free()
107 camq_fini(struct camq *queue) in camq_fini()
120 camq_resize(struct camq *queue, int new_size) in camq_resize()
155 camq_insert(struct camq *queue, cam_pinfo *new_entry) in camq_insert()
175 camq_remove(struct camq *queue, int index) in camq_remove()
199 camq_change_priority(struct camq *queue, int index, u_int32_t new_priority) in camq_change_priority()
HDcam_queue.h61 struct camq queue; member
198 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
220 struct camq *queue = &ccbq->queue; in cam_ccbq_remove_ccb() local
/NextBSD/sys/contrib/octeon-sdk/
HDcvmx-zip.c96 int cvmx_zip_queue_initialize(int queue, int zcoremask) in cvmx_zip_queue_initialize()
183 int cvmx_zip_queue_shutdown(int queue) in cvmx_zip_queue_shutdown()
225 int cvmx_zip_queue_submit(cvmx_zip_command_t *command, int queue) in cvmx_zip_queue_submit()
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()
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()
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()
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()
734 static inline void cvmx_pko_doorbell_pkoid(uint64_t pko_port, uint64_t queue, uint64_t len) in cvmx_pko_doorbell_pkoid()
763 static inline cvmx_pko_status_t cvmx_pko_send_packet_finish_pkoid(int pko_port, uint64_t queue, in cvmx_pko_send_packet_finish_pkoid()
805 …atic inline cvmx_pko_status_t cvmx_pko_send_packet_finish3_pkoid(uint64_t pko_port, uint64_t queue, in cvmx_pko_send_packet_finish3_pkoid()
/NextBSD/sys/netinet/
HDtcp_pcap.c260 tcp_pcap_add(struct tcphdr *th, struct mbuf *m, struct mbufq *queue) in tcp_pcap_add()
415 tcp_pcap_drain(struct mbufq *queue) in tcp_pcap_drain()
430 tcp_pcap_set_sock_max(struct mbufq *queue, int newval) in tcp_pcap_set_sock_max()
438 tcp_pcap_get_sock_max(struct mbufq *queue) in tcp_pcap_get_sock_max()
/NextBSD/tools/tools/net80211/w00t/expand/
HDexpand.c51 struct queue { struct
57 struct queue *next; argument
/NextBSD/usr.sbin/notifyd/
HDtimer.c275 timer_oneshot(time_t when, dispatch_queue_t queue) in timer_oneshot()
323 timer_clock(time_t first, time_t freq_sec, time_t end, dispatch_queue_t queue) in timer_clock()
380 timer_calendar(time_t first, time_t freq_mth, time_t end, int day, dispatch_queue_t queue) in timer_calendar()
435 …h, uint32_t end_day, uint32_t end_hour, uint32_t end_min, uint32_t end_sec, dispatch_queue_t queue) in timer_calendar_long()
/NextBSD/tools/tools/net80211/w00t/redir/
HDredir.c52 struct queue { struct
59 struct queue *next; argument
/NextBSD/lib/libdispatch/src/
HDdata.c83 dispatch_queue_t queue, dispatch_block_t destructor) in _dispatch_data_destroy_buffer()
105 dispatch_queue_t queue, dispatch_block_t destructor) in _dispatch_data_init()
137 dispatch_data_create(const void* buffer, size_t size, dispatch_queue_t queue, in dispatch_data_create()
176 dispatch_data_create_f(const void *buffer, size_t size, dispatch_queue_t queue, in dispatch_data_create_f()
/NextBSD/usr.bin/at/
HDat.c205 writefile(time_t runtimer, char queue) in writefile()
465 char queue; in list_jobs() local
541 char queue; in process_jobs() local
733 char queue = DEFAULT_AT_QUEUE; in main() local
/NextBSD/usr.sbin/nscd/
HDsingletons.h37 int queue; member

12345678