Lines Matching defs:qdir
1876 int njobs, qdir;
2075 qdir = Queue[qgrp]->qg_curnum; /* round-robin init of queue position */
2079 "rwg: wgrp=%d, qgrp=%d, qdir=%d, name=%s, curqgrp=%d, numgrps=%d",
2080 wgrp, qgrp, qdir, qid_printqueue(qgrp, qdir),
2092 qid_printqueue(qgrp, qdir));
2097 qid_printqueue(qgrp, qdir), (int) CurrentPid,
2109 (void) gatherq(qgrp, qdir, false, &full, &more, &h);
2112 QSHM_ENTRIES(Queue[qgrp]->qg_qpaths[qdir].qp_idx) = h;
2118 qdir++;
2119 qdir %= Queue[qgrp]->qg_numqueues;
2129 Queue[qgrp]->qg_curnum = qdir; /* update */
2305 qid_printqueue(qgrp, qdir));
2445 ** qdir -- the index of the queue directory.
2476 gatherq(qgrp, qdir, doall, full, more, pnentries)
2478 int qdir;
2496 if (qdir == NOQDIR)
2500 Queue[qgrp]->qg_qpaths[qdir].qp_name,
2502 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
2554 qid_printqueue(qgrp, qdir));
2624 qid_printqueue(qgrp, qdir),
2632 grow_wlist(qgrp, qdir);
2645 qid_printqueue(qgrp, qdir),
2660 qid_printqueue(qgrp, qdir), d->d_name);
2675 w->w_qdir = qdir;
2700 w->w_qdir = qdir;
3144 ** qdir -- the index for the queue directory.
3156 grow_wlist(qgrp, qdir)
3158 int qdir;
3182 qid_printqueue(qgrp, qdir),
3190 qid_printqueue(qgrp, qdir), newsize);
3530 ** qdir -- the index of the queue directory for the job.
3547 dowork(qgrp, qdir, id, forkflag, requeueflag, e)
3549 int qdir;
3559 sm_dprintf("dowork(%s/%s)\n", qid_printqueue(qgrp, qdir), id);
3654 e->e_qdir = qdir;
4204 int qgrp, qdir;
4215 for (qdir = 0;
4216 qdir < Queue[qgrp]->qg_numqueues;
4217 ++qdir)
4220 Queue[qgrp]->qg_qpaths[qdir].qp_name)
4224 e->e_dfqdir = qdir;
4777 ** qdir -- the queue directory.
4787 print_single_queue(qgrp, qdir)
4789 int qdir;
4798 if (qdir == NOQDIR)
4806 Queue[qgrp]->qg_qpaths[qdir].qp_name,
4808 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4811 Queue[qgrp]->qg_qpaths[qdir].qp_name,
4813 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4832 qid_printqueue(qgrp, qdir));
4857 nrequests = gatherq(qgrp, qdir, true, NULL, NULL, NULL);
4868 qid_printqueue(qgrp, qdir));
4875 qid_printqueue(qgrp, qdir),
4938 e.e_qdir = qdir;
5695 ** qdir -- the short version of the queue directory
5702 qid_printqueue(qgrp, qdir)
5704 int qdir;
5709 if (qdir == NOQDIR)
5712 if (strcmp(Queue[qgrp]->qg_qpaths[qdir].qp_name, ".") == 0)
5715 subdir = Queue[qgrp]->qg_qpaths[qdir].qp_name;
5722 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
5754 int qdir;
5760 qdir = 0;
5762 qdir = get_rand_mod(qg->qg_numqueues);
5769 return qdir;
5776 i = qdir;
5813 } while (i != qdir);
6313 ** cut off qdir
7879 ** qdir -- queue directory.
7889 split_env(e, sendqueue, qgrp, qdir)
7893 int qdir;
7917 ee->e_qdir = ee->e_dfqdir = qdir;
8461 ** qdir -- queue directory in the given queue group
8473 quarantine_queue_item(qgrp, qdir, e, reason)
8475 int qdir;
8851 int qdir;
8856 for (qdir = 0; qdir < Queue[qgrp]->qg_numqueues; qdir++)
8864 nrequests = gatherq(qgrp, qdir, true, NULL, NULL, NULL);
8873 qid_printqueue(qgrp, qdir));
8882 qid_printqueue(qgrp, qdir));
8896 e.e_qdir = qdir;
8904 else if (quarantine_queue_item(qgrp, qdir,