Lines Matching refs:qgrp
51 /* Naming convention: qgrp: index of queue group, qg: QUEUEGROUP */
1308 int qgrp, cgrp, endgrp;
1332 qgrp = WorkGrp[wgrp].wg_qgs[cgrp]->qg_index;
1333 if (Queue[qgrp]->qg_queueintvl > 0)
1334 qintvl = Queue[qgrp]->qg_queueintvl;
1340 lastsched = Queue[qgrp]->qg_nextrun;
1342 if ((runall || Queue[qgrp]->qg_nextrun <= now) && qintvl > 0)
1358 Queue[qgrp]->qg_nextrun += qintvl;
1363 "sqr: wgrp=%d, cgrp=%d, qgrp=%d, intvl=%ld, QI=%ld, runall=%d, lastrun=%ld, nextrun=%ld, sched=%d",
1364 wgrp, cgrp, qgrp,
1365 (long) Queue[qgrp]->qg_queueintvl,
1367 (long) Queue[qgrp]->qg_nextrun, sched);
1395 int qgrp;
1400 for (qgrp = 0; qgrp < NumQueue && Queue[qgrp] != NULL; qgrp++)
1404 if (Queue[qgrp]->qg_queueintvl > 0)
1405 qintvl = Queue[qgrp]->qg_queueintvl;
1410 if (Queue[qgrp]->qg_nextrun <= now - qintvl)
1417 qgrp,
1418 arpadate(ctime(&Queue[qgrp]->qg_nextrun)),
1919 int qgrp, endgrp, h, i;
2101 qgrp = WorkGrp[wgrp].wg_qgs[WorkGrp[wgrp].wg_curqgrp]->qg_index;
2105 (Queue[qgrp]->qg_nextrun <= now &&
2106 Queue[qgrp]->qg_nextrun != (time_t) -1))
2117 qdir = Queue[qgrp]->qg_curnum; /* round-robin init of queue position */
2121 "rwg: wgrp=%d, qgrp=%d, qdir=%d, name=%s, curqgrp=%d, numgrps=%d",
2122 wgrp, qgrp, qdir, qid_printqueue(qgrp, qdir),
2128 if (Queue[qgrp]->qg_nice > 0)
2129 (void) nice(Queue[qgrp]->qg_nice);
2134 qid_printqueue(qgrp, qdir));
2139 qid_printqueue(qgrp, qdir), (int) CurrentPid,
2149 for (i = 0; i < Queue[qgrp]->qg_numqueues; i++)
2151 (void) gatherq(qgrp, qdir, false, &full, &more, &h);
2154 QSHM_ENTRIES(Queue[qgrp]->qg_qpaths[qdir].qp_idx) = h;
2161 qdir %= Queue[qgrp]->qg_numqueues;
2170 njobs = sortq(Queue[qgrp]->qg_maxlist);
2171 Queue[qgrp]->qg_curnum = qdir; /* update */
2174 if (!Verbose && bitnset(QD_FORK, Queue[qgrp]->qg_flags))
2190 maxrunners = Queue[qgrp]->qg_maxqrun;
2318 else if (Queue[qgrp]->qg_maxqrun > 0 || bitset(RWG_FORCE, flags))
2347 qid_printqueue(qgrp, qdir));
2486 ** qgrp -- the index of the queue group.
2518 gatherq(qgrp, qdir, doall, full, more, pnentries)
2519 int qgrp;
2542 Queue[qgrp]->qg_qpaths[qdir].qp_name,
2544 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
2596 qid_printqueue(qgrp, qdir));
2666 qid_printqueue(qgrp, qdir),
2674 grow_wlist(qgrp, qdir);
2687 qid_printqueue(qgrp, qdir),
2702 qid_printqueue(qgrp, qdir), d->d_name);
2716 w->w_qgrp = qgrp;
2741 w->w_qgrp = qgrp;
3183 ** qgrp -- the index for the queue group.
3196 grow_wlist(qgrp, qdir)
3197 int qgrp;
3222 qid_printqueue(qgrp, qdir),
3230 qid_printqueue(qgrp, qdir), newsize);
3569 ** qgrp -- the index of the queue group for the job.
3587 dowork(qgrp, qdir, id, forkflag, requeueflag, e)
3588 int qgrp;
3599 sm_dprintf("dowork(%s/%s)\n", qid_printqueue(qgrp, qdir), id);
3693 e->e_qgrp = qgrp;
4246 int qgrp, qdir;
4253 for (qgrp = 0;
4254 qgrp < NumQueue && Queue[qgrp] != NULL;
4255 ++qgrp)
4258 qdir < Queue[qgrp]->qg_numqueues;
4262 Queue[qgrp]->qg_qpaths[qdir].qp_name)
4265 e->e_dfqgrp = qgrp;
4479 /* make sure we keep the current qgrp */
4846 ** qgrp -- the index of the queue group.
4857 print_single_queue(qgrp, qdir)
4858 int qgrp;
4876 Queue[qgrp]->qg_qpaths[qdir].qp_name,
4878 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4881 Queue[qgrp]->qg_qpaths[qdir].qp_name,
4883 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4902 qid_printqueue(qgrp, qdir));
4927 nrequests = gatherq(qgrp, qdir, true, NULL, NULL, NULL);
4928 (void) sortq(Queue[qgrp]->qg_maxlist);
4938 qid_printqueue(qgrp, qdir));
4945 qid_printqueue(qgrp, qdir),
5007 e.e_qgrp = qgrp;
5774 ** qgrp -- index in queue group.
5782 qid_printqueue(qgrp, qdir)
5783 int qgrp;
5790 return Queue[qgrp]->qg_qdir;
5792 if (strcmp(Queue[qgrp]->qg_qpaths[qdir].qp_name, ".") == 0)
5795 subdir = Queue[qgrp]->qg_qpaths[qdir].qp_name;
5798 Queue[qgrp]->qg_qdir,
5802 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
5919 ** e->qgrp = NOQGRP, e->e_qdir = NOQDIR
8091 ** qgrp -- index of queue group.
8102 split_env(e, sendqueue, qgrp, qdir)
8105 int qgrp;
8129 ee->e_qgrp = ee->e_dfqgrp = qgrp;
8673 ** qgrp -- queue group for the item
8686 quarantine_queue_item(qgrp, qdir, e, reason)
8687 int qgrp;
9050 int qgrp;
9062 for (qgrp = 0; qgrp < NumQueue && Queue[qgrp] != NULL; qgrp++)
9066 if (qgrplimit != NOQGRP && qgrplimit != qgrp)
9069 for (qdir = 0; qdir < Queue[qgrp]->qg_numqueues; qdir++)
9077 nrequests = gatherq(qgrp, qdir, true, NULL, NULL, NULL);
9086 qid_printqueue(qgrp, qdir));
9095 qid_printqueue(qgrp, qdir));
9108 e.e_qgrp = qgrp;
9117 else if (quarantine_queue_item(qgrp, qdir,