| /src/usr.sbin/lpr/common_source/ |
| lp.h | 93 struct queue { struct
112 int getq(struct queue *(*[]));
113 void freeq(struct queue **, u_int);
|
| displayq.c | 58 * Routines to display the state of the queue.
91 * Display the current state of the queue. Format = 1 if long format.
96 struct queue *q;
99 struct queue **queue; local in function:displayq
109 * Print out local queue
116 if ((nitems = getq(&queue)) < 0)
140 printf("Warning: %s queue is turned off\n", printer);
203 q = queue[i];
207 freeq(queue, nitems)
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/vmwgfx/ |
| ttm_lock.h | 68 * @queue: Queue for processes waiting for lock change-of-status.
76 drm_waitqueue_t queue; member in struct:ttm_lock
|
| /src/sys/dev/raidframe/ |
| rf_sstf.h | 35 RF_DiskQueueData_t *queue; member in struct:RF_SstfQ_s
|
| rf_diskqueue.h | 41 #include <sys/queue.h>
55 /* the data held by a disk queue entry */
70 RF_Etimer_t qtime; /* perf mon only - time request is in queue */
73 RF_DiskQueue_t *queue; /* the disk queue to which this req is member in struct:RF_DiskQueueData_s
78 /* TAILQ bits for a queue for completed I/O requests */
84 /* note: "Create" returns type-specific queue header pointer cast to (void *) */
88 * one call per queue in
100 const RF_DiskQueueSW_t *qPtr; /* access point to queue functions */
101 void *qHdr; /* queue header, of whatever type *
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/i915/gt/ |
| intel_reset_types.h | 55 drm_waitqueue_t queue; member in struct:intel_reset
|
| /src/bin/stty/ |
| stty.h | 43 int queue; /* queue size */ member in struct:info
|
| /src/sys/external/bsd/drm2/dist/drm/amd/amdkfd/ |
| kfd_kernel_queue.h | 35 * queue ring buffer where the calling function can write its packet. It is
40 * kq_submit_packet: Update the write pointer and doorbell of a kernel queue.
59 struct queue *queue; member in struct:kernel_queue
|
| /src/sys/external/bsd/drm2/dist/include/drm/ |
| drm_vblank.h | 109 * @queue: Wait queue for vblank waiters.
111 drm_waitqueue_t queue; member in struct:drm_vblank_crtc
|
| /src/lib/libpthread/ |
| pthread_rwlock.c | 205 * can adjust the waiter bits and sleep queue.
327 * can adjust the waiter bits and sleep queue.
579 pthread_queue_t *queue; local in function:pthread__rwlock_early
582 if ((queue = self->pt_sleepobj) == NULL) {
586 PTQ_REMOVE(queue, self, pt_sleep);
|
| /src/libexec/atrun/ |
| atrun.c | 156 int queue; local in function:run_file
323 queue = *filename;
325 if (queue > 'b')
326 nice(queue - 'b');
376 * they should be executed and or deleted. The queue is coded into
392 char queue; local in function:main
482 if (sscanf(dirent->d_name, "%c%5x%8lx", &queue, &jobno,
489 if (isupper((unsigned char)queue) &&
499 if (islower((unsigned char)queue))
|
| /src/sys/altq/ |
| altq_wfq.h | 61 int bytes; /* bytes in this queue */
77 int qlimit; /* queue size in bytes */
105 int bytes; /* bytes in this queue */
121 wfq *queue; /* pointer to queue list */ member in struct:wfqstate
|
| altq_wfq.c | 87 /* global value : pointer to wfq queue list */
117 wfq *queue; local in function:wfq_ifattach
138 queue = malloc(sizeof(wfq) * DEFAULT_QSIZE, M_DEVBUF, M_WAITOK|M_ZERO);
139 if (queue == NULL) {
150 new_wfqp->queue = queue;
154 for (i = 0; i < new_wfqp->nums; i++, queue++) {
155 queue->next = queue->prev = NULL;
156 queue->head = queue->tail = NULL
254 wfq *queue; local in function:wfq_ifenqueue
418 wfq *queue, *max_queue = NULL; local in function:wfq_maxqueue
438 wfq *queue; local in function:wfq_ifdequeue
517 wfq *queue; local in function:wfq_setweight
541 wfq *queue; local in function:wfq_getstats
566 wfq *queue; local in function:wfq_config
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/amd/amdgpu/ |
| amdgpu_gfx.c | 44 int pipe, int queue)
51 bit += queue;
57 int *mec, int *pipe, int *queue)
59 *queue = bit % adev->gfx.mec.num_queue_per_pipe;
68 int mec, int pipe, int queue)
70 return test_bit(amdgpu_gfx_mec_queue_to_bit(adev, mec, pipe, queue),
75 int me, int pipe, int queue)
82 bit += queue;
88 int *me, int *pipe, int *queue)
90 *queue = bit % adev->gfx.me.num_queue_per_pipe
202 int i, queue, pipe, mec; local in function:amdgpu_gfx_compute_queue_acquire
240 int i, queue, me; local in function:amdgpu_gfx_graphics_queue_acquire
264 int mec, pipe, queue; local in function:amdgpu_gfx_kiq_acquire
[all...] |
| /src/sys/external/bsd/vchiq/dist/interface/vchiq_arm/ |
| vchiq_shim.c | 47 VCHIU_QUEUE_T queue; member in struct:__anonf97ee0e70108
109 if (vchiu_queue_is_empty(&service->queue))
112 header = vchiu_queue_peek(&service->queue);
137 header = vchiu_queue_pop(&service->queue);
154 * Description: Thin wrapper to queue a message onto a connection
334 if (vchiu_queue_is_empty(&service->queue))
337 header = vchiu_queue_pop(&service->queue);
359 * Description: Thin wrapper to queue a message onto a connection
443 if (vchiu_queue_is_empty(&service->queue))
446 header = vchiu_queue_pop(&service->queue);
[all...] |
| /src/usr.bin/at/ |
| at.c | 4 * at.c : Put file into atrun queue
88 unsigned char atqueue = 0; /* which queue to examine for jobs (atq) */
167 writefile(time_t runtimer, unsigned char queue)
236 "%c%5x%8lx", queue, jobno, (unsigned long) (runtimer/60));
423 * List all a user's jobs in the queue, by looping through
432 unsigned char queue; local in function:list_jobs
460 if (sscanf(dirent->d_name, "%c%5x%8lx", &queue, &jobno, &ctm) != 3)
463 if (atqueue && queue != atqueue)
481 7, "Queue",
490 queue,
507 unsigned char queue; local in function:process_jobs
585 unsigned char queue = DEFAULT_AT_QUEUE; local in function:main
[all...] |
| /src/usr.sbin/lpr/lpc/ |
| cmds.c | 80 static int touch(struct queue *);
285 struct dirent **queue; local in function:cleanpr
299 nitems = scandir(SD, &queue, doselect, sortq);
309 cp = queue[i]->d_name;
313 cp1 = queue[i + 1]->d_name;
694 * Print the status of each queue listed or all the queues.
725 * Print the status of the printer queue.
853 struct queue **queue; variable in typeref:struct:queue **
858 * Put the specified jobs at the top of printer queue
[all...] |
| /src/sys/kern/ |
| kern_rwlock.c | 287 int queue; local in function:rw_vector_enter
320 queue = TS_READER_Q;
326 queue = TS_WRITER_Q;
378 * can adjust the waiter bits and sleep queue.
402 turnstile_block(ts, queue, rw, &rw_syncobj);
483 * on the sleep queue. Once we have that, we can adjust the
631 * on the sleep queue. Once we have that, we can adjust the
|
| /src/sys/fs/udf/ |
| udf_strat_direct.c | 251 int what, class __diagused, queue; local in function:udf_queue_buf_direct
258 queue = UDF_SHED_READING;
261 queue = UDF_SHED_SEQWRITING;
263 queue = UDF_SHED_WRITING;
265 queue = UDF_SHED_WRITING;
267 queue = UDF_SHED_WRITING;
279 if (queue == UDF_SHED_READING) {
289 if (queue == UDF_SHED_WRITING) {
303 KASSERT(queue == UDF_SHED_SEQWRITING);
311 * this queue. Note that a buffer can get multiple extents allocated
[all...] |
| udf_strat_sequential.c | 266 int queue; local in function:udf_queuebuf_seq
274 queue = UDF_SHED_READING;
277 queue = UDF_SHED_SEQWRITING;
279 queue = UDF_SHED_WRITING;
284 bufq_put(priv->queues[queue], nestbuf);
285 vfs_timestamp(&priv->last_queued[queue]);
375 udf_issue_buf(struct udf_mount *ump, int queue, struct buf *buf)
390 if (queue == UDF_SHED_READING) {
399 if (queue == UDF_SHED_WRITING) {
411 KASSERT(queue == UDF_SHED_SEQWRITING)
[all...] |
| /src/sys/external/bsd/compiler_rt/dist/lib/tsan/rtl/ |
| tsan_libdispatch_mac.cc | 38 dispatch_queue_t queue; member in struct:__tsan::__anonb0bb39d30108
90 dispatch_queue_t queue,
96 new_context->queue = queue;
118 dispatch_queue_t q = context->queue;
133 dispatch_queue_t q = context->queue;
237 dispatch_queue_t queue, dispatch_block_t block) {
238 SCOPED_TSAN_INTERCEPTOR(dispatch_after, when, queue, block);
243 AllocContext(thr, pc, queue, heap_block, &invoke_and_release_block);
246 REAL(dispatch_after_f)(when, queue, new_context, dispatch_callback_wrap)
[all...] |
| /src/sys/external/bsd/drm2/dist/drm/via/ |
| via_dmablit.c | 547 via_dmablit_active(drm_via_blitq_t *blitq, int engine, uint32_t handle, drm_waitqueue_t **queue)
549 via_dmablit_active(drm_via_blitq_t *blitq, int engine, uint32_t handle, wait_queue_head_t **queue)
569 if (queue && active) {
573 *queue = blitq->blit_queue + slot;
594 drm_waitqueue_t *queue; local in function:via_dmablit_sync
596 wait_queue_head_t *queue; local in function:via_dmablit_sync
602 if (via_dmablit_active(blitq, engine, handle, &queue)) {
603 DRM_SPIN_WAIT_ON(ret, queue, &blitq->blit_lock, 3*HZ,
608 if (via_dmablit_active(blitq, engine, handle, &queue)) {
609 VIA_WAIT_ON(ret, *queue, 3 * HZ
[all...] |
| /src/usr.sbin/rpc.pcnfsd/ |
| pcnfsd_print.c | 99 pr_queue queue = NULL; variable in typeref:typename:pr_queue
608 * build_pr_queue: used to show the print queue.
611 * existing queue.
649 if (queue) {
650 free_pr_queue_item(queue);
651 queue = NULL;
663 msg_out("rpc.pcnfsd: unable to popen() lpstat queue query");
703 queue = curr;
729 if (queue) {
730 free_pr_queue_item(queue);
[all...] |
| /src/dist/pf/sbin/pfctl/ |
| pfctl_optimize.c | 812 TAILQ_HEAD( , pf_opt_rule) queue;
846 TAILQ_INIT(&queue);
849 TAILQ_INSERT_TAIL(&queue, por1, por_entry);
852 while ((por1 = TAILQ_FIRST(&queue)) != NULL) {
853 TAILQ_REMOVE(&queue, por1, por_entry);
879 struct pf_opt_queue queue; local in function:load_feedback_profile
884 TAILQ_INIT(&queue);
914 TAILQ_INSERT_TAIL(&queue, por, por_entry);
922 if (construct_superblocks(pf, &queue, &prof_superblocks))
|
| /src/sys/arch/playstation2/playstation2/ |
| sifbios.c | 183 /* queue DMA request to SIFBIOS. returns queue identifier. */
412 sifrpc_establish(struct sifrpc_server_system *queue, void (*end_func)(void *),
416 struct sifrpc_server_system *queue; member in struct:sifrpc_establish::__anonee80bffa0908
420 queue: queue,
429 sifrpc_register_service(struct sifrpc_server_system *queue,
449 receive_queue: queue,
456 sifrpc_unregister_service(struct sifrpc_server_system *queue,
464 receive_queue: queue,
[all...] |
