Home
last modified time | relevance | path

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

123456

/netbsd/src/sys/external/bsd/vchiq/dist/interface/vchiq_arm/
Dvchiq_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()
/netbsd/src/external/ibm-public/postfix/dist/src/oqmgr/
Dqmgr_queue.c116 #define QMGR_ERROR_OR_RETRY_QUEUE(queue) \ argument
124 #define QMGR_LOG_WINDOW(queue) \ argument
134 QMGR_QUEUE *queue = (QMGR_QUEUE *) context; in qmgr_queue_resume() local
162 void qmgr_queue_suspend(QMGR_QUEUE *queue, int delay) in qmgr_queue_suspend()
186 QMGR_QUEUE *queue = (QMGR_QUEUE *) context; in qmgr_queue_unthrottle_wrapper() local
200 void qmgr_queue_unthrottle(QMGR_QUEUE *queue) in qmgr_queue_unthrottle()
280 void qmgr_queue_throttle(QMGR_QUEUE *queue, DSN *dsn) in qmgr_queue_throttle()
357 QMGR_QUEUE *queue; in qmgr_queue_select() local
376 void qmgr_queue_done(QMGR_QUEUE *queue) in qmgr_queue_done()
412 QMGR_QUEUE *queue; in qmgr_queue_create() local
Dqmgr_entry.c104 QMGR_ENTRY *qmgr_entry_select(QMGR_QUEUE *queue) in qmgr_entry_select()
172 void qmgr_entry_unselect(QMGR_QUEUE *queue, QMGR_ENTRY *entry) in qmgr_entry_unselect()
217 QMGR_QUEUE *queue = entry->queue; in qmgr_entry_done() local
306 QMGR_ENTRY *qmgr_entry_create(QMGR_QUEUE *queue, QMGR_MESSAGE *message) in qmgr_entry_create()
Dqmgr_enable.c81 QMGR_QUEUE *queue; in qmgr_enable_transport() local
100 void qmgr_enable_queue(QMGR_QUEUE *queue) in qmgr_enable_queue()
Dqmgr_defer.c87 QMGR_QUEUE *queue; in qmgr_defer_transport() local
105 void qmgr_defer_todo(QMGR_QUEUE *queue, DSN *dsn) in qmgr_defer_todo()
Dqmgr_deliver.c236 QMGR_QUEUE *queue = entry->queue; in qmgr_deliver_abort() local
249 QMGR_QUEUE *queue = entry->queue; in qmgr_deliver_update() local
383 QMGR_QUEUE *queue; in qmgr_deliver() local
Dqmgr_error.c90 QMGR_QUEUE *queue; in qmgr_error_queue() local
/netbsd/src/external/ibm-public/postfix/dist/src/qmgr/
Dqmgr_queue.c122 #define QMGR_ERROR_OR_RETRY_QUEUE(queue) \ argument
130 #define QMGR_LOG_WINDOW(queue) \ argument
140 QMGR_QUEUE *queue = (QMGR_QUEUE *) context; in qmgr_queue_resume() local
179 void qmgr_queue_suspend(QMGR_QUEUE *queue, int delay) in qmgr_queue_suspend()
203 QMGR_QUEUE *queue = (QMGR_QUEUE *) context; in qmgr_queue_unthrottle_wrapper() local
217 void qmgr_queue_unthrottle(QMGR_QUEUE *queue) in qmgr_queue_unthrottle()
297 void qmgr_queue_throttle(QMGR_QUEUE *queue, DSN *dsn) in qmgr_queue_throttle()
372 void qmgr_queue_done(QMGR_QUEUE *queue) in qmgr_queue_done()
408 QMGR_QUEUE *queue; in qmgr_queue_create() local
Dqmgr_peer.c80 QMGR_PEER *qmgr_peer_create(QMGR_JOB *job, QMGR_QUEUE *queue) in qmgr_peer_create()
100 QMGR_QUEUE *queue = peer->queue; in qmgr_peer_free() local
117 QMGR_PEER *qmgr_peer_find(QMGR_JOB *job, QMGR_QUEUE *queue) in qmgr_peer_find()
124 QMGR_PEER *qmgr_peer_obtain(QMGR_JOB *job, QMGR_QUEUE *queue) in qmgr_peer_obtain()
138 QMGR_QUEUE *queue; in qmgr_peer_select() local
Dqmgr_entry.c116 QMGR_QUEUE *queue; in qmgr_entry_select() local
187 QMGR_QUEUE *queue = entry->queue; in qmgr_entry_unselect() local
254 QMGR_QUEUE *queue = entry->queue; in qmgr_entry_done() local
365 QMGR_QUEUE *queue = peer->queue; in qmgr_entry_create() local
Dqmgr_enable.c81 QMGR_QUEUE *queue; in qmgr_enable_transport() local
100 void qmgr_enable_queue(QMGR_QUEUE *queue) in qmgr_enable_queue()
Dqmgr_defer.c92 QMGR_QUEUE *queue; in qmgr_defer_transport() local
110 void qmgr_defer_todo(QMGR_QUEUE *queue, DSN *dsn) in qmgr_defer_todo()
Dqmgr_deliver.c241 QMGR_QUEUE *queue = entry->queue; in qmgr_deliver_abort() local
254 QMGR_QUEUE *queue = entry->queue; in qmgr_deliver_update() local
Dqmgr_error.c90 QMGR_QUEUE *queue; in qmgr_error_queue() local
Dqmgr_scan.c178 QMGR_SCAN *qmgr_scan_create(const char *queue) in qmgr_scan_create()
/netbsd/src/sys/external/bsd/drm2/dist/drm/vmwgfx/
Dvmwgfx_marker.c42 void vmw_marker_queue_init(struct vmw_marker_queue *queue) in vmw_marker_queue_init()
50 void vmw_marker_queue_takedown(struct vmw_marker_queue *queue) in vmw_marker_queue_takedown()
60 int vmw_marker_push(struct vmw_marker_queue *queue, in vmw_marker_push()
77 int vmw_marker_pull(struct vmw_marker_queue *queue, in vmw_marker_pull()
111 static u64 vmw_fifo_lag(struct vmw_marker_queue *queue) in vmw_fifo_lag()
124 static bool vmw_lag_lt(struct vmw_marker_queue *queue, in vmw_lag_lt()
133 struct vmw_marker_queue *queue, uint32_t us) in vmw_wait_lag()
/netbsd/src/sys/external/bsd/drm2/dist/include/drm/
Dspsc_queue.h50 static inline void spsc_queue_init(struct spsc_queue *queue) in spsc_queue_init()
57 static inline struct spsc_node *spsc_queue_peek(struct spsc_queue *queue) in spsc_queue_peek()
62 static inline int spsc_queue_count(struct spsc_queue *queue) in spsc_queue_count()
67 static inline bool spsc_queue_push(struct spsc_queue *queue, struct spsc_node *node) in spsc_queue_push()
91 static inline struct spsc_node *spsc_queue_pop(struct spsc_queue *queue) in spsc_queue_pop()
/netbsd/src/usr.sbin/lpr/common_source/
Dlp.h93 struct queue { struct
112 int getq(struct queue *(*[])); argument
/netbsd/src/external/ibm-public/postfix/dist/src/global/
Dabounce.c327 const char *queue, const char *id, in abounce_connect()
397 void abounce_flush_verp(int flags, const char *queue, const char *id, in abounce_flush_verp()
411 void adefer_flush_verp(int flags, const char *queue, const char *id, in adefer_flush_verp()
425 void abounce_flush(int flags, const char *queue, const char *id, in abounce_flush()
438 void adefer_flush(int flags, const char *queue, const char *id, in adefer_flush()
451 void adefer_warn(int flags, const char *queue, const char *id, in adefer_warn()
463 void atrace_flush(int flags, const char *queue, const char *id, in atrace_flush()
Dbounce.c354 int bounce_flush(int flags, const char *queue, const char *id, in bounce_flush()
389 int bounce_flush_verp(int flags, const char *queue, const char *id, in bounce_flush_verp()
425 int bounce_one(int flags, const char *queue, const char *id, in bounce_one()
457 int bounce_one_intern(int flags, const char *queue, const char *id, in bounce_one_intern()
Ddefer.c307 int defer_flush(int flags, const char *queue, const char *id, in defer_flush()
335 int defer_warn(int flags, const char *queue, const char *id, in defer_warn()
359 int defer_one(int flags, const char *queue, const char *id, in defer_one()
/netbsd/src/sys/altq/
Daltq_wfq.c117 wfq *queue; in wfq_ifattach() local
254 wfq *queue; in wfq_ifenqueue() local
418 wfq *queue, *max_queue = NULL; in wfq_maxqueue() local
438 wfq *queue; in wfq_ifdequeue() local
517 wfq *queue; in wfq_setweight() local
541 wfq *queue; in wfq_getstats() local
566 wfq *queue; in wfq_config() local
/netbsd/src/external/gpl3/gdb/dist/sim/ppc/
Devents.c64 event_entry *queue; member
76 event_queue *queue = data; in sim_events_poll() local
101 event_queue_init(event_queue *queue) in event_queue_init()
146 event_queue_time(event_queue *queue) in event_queue_time()
/netbsd/src/usr.bin/at/
Dat.c167 writefile(time_t runtimer, unsigned char queue) in writefile()
432 unsigned char queue; in list_jobs() local
507 unsigned char queue; in process_jobs() local
585 unsigned char queue = DEFAULT_AT_QUEUE; in main() local
/netbsd/src/external/bsd/tmux/dist/
Dcmd-queue.c43 struct cmdq_list *queue; member
127 struct cmdq_list *queue; in cmdq_new() local
136 cmdq_free(struct cmdq_list *queue) in cmdq_free()
303 struct cmdq_list *queue = cmdq_get(c); in cmdq_append() local
328 struct cmdq_list *queue = after->queue; in cmdq_insert_after() local
732 struct cmdq_list *queue = cmdq_get(c); in cmdq_next() local
814 struct cmdq_list *queue = cmdq_get(c); in cmdq_running() local

123456