Lines Matching refs:qdir

1955 	int njobs, qdir;  local
2155 qdir = Queue[qgrp]->qg_curnum; /* round-robin init of queue position */
2160 wgrp, qgrp, qdir, qid_printqueue(qgrp, qdir),
2172 qid_printqueue(qgrp, qdir));
2177 qid_printqueue(qgrp, qdir), (int) CurrentPid,
2188 (void) gatherq(qgrp, qdir, false, &full, &more, &h);
2191 QSHM_ENTRIES(Queue[qgrp]->qg_qpaths[qdir].qp_idx) = h;
2197 qdir++;
2198 qdir %= Queue[qgrp]->qg_numqueues;
2208 Queue[qgrp]->qg_curnum = qdir; /* update */
2383 qid_printqueue(qgrp, qdir));
2554 gatherq(qgrp, qdir, doall, full, more, pnentries) in gatherq() argument
2556 int qdir;
2574 if (qdir == NOQDIR)
2578 Queue[qgrp]->qg_qpaths[qdir].qp_name,
2580 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
2632 qid_printqueue(qgrp, qdir));
2702 qid_printqueue(qgrp, qdir),
2710 grow_wlist(qgrp, qdir);
2723 qid_printqueue(qgrp, qdir),
2738 qid_printqueue(qgrp, qdir), d->d_name);
2753 w->w_qdir = qdir;
2778 w->w_qdir = qdir;
3236 grow_wlist(qgrp, qdir) in grow_wlist() argument
3238 int qdir;
3262 qid_printqueue(qgrp, qdir),
3270 qid_printqueue(qgrp, qdir), newsize);
3638 dowork(qgrp, qdir, id, forkflag, requeueflag, e) in dowork() argument
3640 int qdir;
3650 sm_dprintf("dowork(%s/%s), forkflag=%d\n", qid_printqueue(qgrp, qdir), id, forkflag);
3746 e->e_qdir = qdir;
3791 qid_printqueue(qgrp, qdir), id, forkflag,
4304 int qgrp, qdir; local
4315 for (qdir = 0;
4316 qdir < Queue[qgrp]->qg_numqueues;
4317 ++qdir)
4320 Queue[qgrp]->qg_qpaths[qdir].qp_name)
4324 e->e_dfqdir = qdir;
4922 print_single_queue(qgrp, qdir) in print_single_queue() argument
4924 int qdir;
4933 if (qdir == NOQDIR)
4941 Queue[qgrp]->qg_qpaths[qdir].qp_name,
4943 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4946 Queue[qgrp]->qg_qpaths[qdir].qp_name,
4948 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4967 qid_printqueue(qgrp, qdir));
4992 nrequests = gatherq(qgrp, qdir, true, NULL, NULL, NULL);
5003 qid_printqueue(qgrp, qdir));
5010 qid_printqueue(qgrp, qdir),
5076 e.e_qdir = qdir;
5848 qid_printqueue(qgrp, qdir) in qid_printqueue() argument
5850 int qdir;
5855 if (qdir == NOQDIR)
5858 if (strcmp(Queue[qgrp]->qg_qpaths[qdir].qp_name, ".") == 0)
5861 subdir = Queue[qgrp]->qg_qpaths[qdir].qp_name;
5868 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
5900 int qdir; local
5906 qdir = 0;
5908 qdir = get_rand_mod(qg->qg_numqueues);
5915 return qdir;
5922 i = qdir;
5959 } while (i != qdir);
8165 split_env(e, sendqueue, qgrp, qdir) in split_env() argument
8169 int qdir;
8193 ee->e_qdir = ee->e_dfqdir = qdir;
8749 quarantine_queue_item(qgrp, qdir, e, reason) in quarantine_queue_item() argument
8751 int qdir;
9126 int qdir; local
9131 for (qdir = 0; qdir < Queue[qgrp]->qg_numqueues; qdir++)
9139 nrequests = gatherq(qgrp, qdir, true, NULL, NULL, NULL);
9148 qid_printqueue(qgrp, qdir));
9157 qid_printqueue(qgrp, qdir));
9171 e.e_qdir = qdir;
9179 else if (quarantine_queue_item(qgrp, qdir,