Lines Matching refs:Queue
625 Queue[e->e_dfqgrp]->qg_qpaths[e->e_dfqdir].qp_name);
1312 if (Queue[qgrp]->qg_queueintvl > 0)
1313 qintvl = Queue[qgrp]->qg_queueintvl;
1319 lastsched = Queue[qgrp]->qg_nextrun;
1321 if ((runall || Queue[qgrp]->qg_nextrun <= now) && qintvl > 0)
1337 Queue[qgrp]->qg_nextrun += qintvl;
1343 wgrp, cgrp, qgrp, Queue[qgrp]->qg_queueintvl,
1345 Queue[qgrp]->qg_nextrun, sched);
1378 for (qgrp = 0; qgrp < NumQueue && Queue[qgrp] != NULL; qgrp++) in checkqueuerunner()
1382 if (Queue[qgrp]->qg_queueintvl > 0) in checkqueuerunner()
1383 qintvl = Queue[qgrp]->qg_queueintvl; in checkqueuerunner()
1388 if (Queue[qgrp]->qg_nextrun <= now - qintvl) in checkqueuerunner()
1396 arpadate(ctime(&Queue[qgrp]->qg_nextrun)), in checkqueuerunner()
2073 (Queue[qgrp]->qg_nextrun <= now &&
2074 Queue[qgrp]->qg_nextrun != (time_t) -1))
2085 qdir = Queue[qgrp]->qg_curnum; /* round-robin init of queue position */
2096 if (Queue[qgrp]->qg_nice > 0)
2097 (void) nice(Queue[qgrp]->qg_nice);
2117 for (i = 0; i < Queue[qgrp]->qg_numqueues; i++)
2122 QSHM_ENTRIES(Queue[qgrp]->qg_qpaths[qdir].qp_idx) = h;
2129 qdir %= Queue[qgrp]->qg_numqueues;
2138 njobs = sortq(Queue[qgrp]->qg_maxlist);
2139 Queue[qgrp]->qg_curnum = qdir; /* update */
2142 if (!Verbose && bitnset(QD_FORK, Queue[qgrp]->qg_flags))
2158 maxrunners = Queue[qgrp]->qg_maxqrun;
2286 else if (Queue[qgrp]->qg_maxqrun > 0 || bitset(RWG_FORCE, flags))
2510 Queue[qgrp]->qg_qpaths[qdir].qp_name,
2512 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4222 qgrp < NumQueue && Queue[qgrp] != NULL;
4226 qdir < Queue[qgrp]->qg_numqueues;
4230 Queue[qgrp]->qg_qpaths[qdir].qp_name)
4695 for (i = 0; i < NumQueue && Queue[i] != NULL; i++)
4701 for (j = 0; j < Queue[i]->qg_numqueues; j++)
4708 n = QSHM_ENTRIES(Queue[i]->qg_qpaths[j].qp_idx);
4767 for (i = 0; i < NumQueue && Queue[i] != NULL; i++) in printqueue()
4772 for (j = 0; j < Queue[i]->qg_numqueues; j++) in printqueue()
4819 Queue[qgrp]->qg_qpaths[qdir].qp_name,
4821 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4824 Queue[qgrp]->qg_qpaths[qdir].qp_name,
4826 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4871 (void) sortq(Queue[qgrp]->qg_maxlist);
5244 if (Queue[e->e_xfqgrp]->qg_numqueues <= 1)
5249 Queue[e->e_xfqgrp]->qg_numqueues);
5284 if (bitset(QP_SUBDF, Queue[qg]->qg_qpaths[qd].qp_subdirs))
5293 if (bitset(QP_SUBQF, Queue[qg]->qg_qpaths[qd].qp_subdirs))
5298 if (bitset(QP_SUBXF, Queue[qg]->qg_qpaths[qd].qp_subdirs))
5309 Queue[qg]->qg_qpaths[qd].qp_name,
5709 Queue[e->e_qgrp]->qg_qpaths[e->e_qdir].qp_name,
5733 return Queue[qgrp]->qg_qdir;
5735 if (strcmp(Queue[qgrp]->qg_qpaths[qdir].qp_name, ".") == 0)
5738 subdir = Queue[qgrp]->qg_qpaths[qdir].qp_name;
5741 Queue[qgrp]->qg_qdir,
5745 Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
5917 e->e_qdir = pickqdir(Queue[e->e_qgrp], e->e_msgsize, e);
6457 for (i = 0; i < NumQueue && Queue[i] != NULL; i++)
6459 for (j = 0; j < Queue[i]->qg_numqueues; ++j)
6461 QPATHS *qp = &Queue[i]->qg_qpaths[j];
6727 idx = Queue[e->e_qgrp]->qg_qpaths[e->e_qdir].qp_idx;
6746 fidx = Queue[e->e_qgrp]->qg_qpaths[e->e_qdir].qp_fsysidx;
7128 for (i = 0; i < NumQueue && Queue[i] != NULL; i++)
7129 Queue[i]->qg_nextrun = now;
7181 for (i = 0; i < NumQueue && Queue[i] != NULL; i++)
7182 qn = multiqueue_cache(basedir, len, Queue[i], qn, &hashval);
7533 Queue[i] = s->s_quegrp = qg;
7650 if (NumQueue == 1 && strcmp(Queue[0]->qg_name, "mqueue") == 0) in makeworkgroups()
7666 WorkGrp[0].wg_qgs[0] = Queue[0]; in makeworkgroups()
7668 Queue[0]->qg_numqueues > MaxQueueChildren) in makeworkgroups()
7671 WorkGrp[0].wg_runners = Queue[0]->qg_numqueues; in makeworkgroups()
7673 Queue[0]->qg_wgrp = 0; in makeworkgroups()
7677 Queue[0]->qg_maxqrun > MaxQueueChildren) in makeworkgroups()
7678 Queue[0]->qg_maxqrun = MaxQueueChildren; in makeworkgroups()
7679 WorkGrp[0].wg_maxact = Queue[0]->qg_maxqrun; in makeworkgroups()
7680 WorkGrp[0].wg_lowqintvl = Queue[0]->qg_queueintvl; in makeworkgroups()
7686 si[i].sg_maxqrun = Queue[i]->qg_maxqrun; in makeworkgroups()
7749 WorkGrp[j].wg_qgs[WorkGrp[j].wg_numqgrp] = Queue[h]; in makeworkgroups()
7751 WorkGrp[j].wg_runners += Queue[h]->qg_maxqrun; in makeworkgroups()
7752 Queue[h]->qg_wgrp = j; in makeworkgroups()
7758 Queue[h]->qg_maxqrun > MaxQueueChildren) in makeworkgroups()
7759 Queue[h]->qg_maxqrun = MaxQueueChildren; in makeworkgroups()
7760 WorkGrp[j].wg_maxact = Queue[h]->qg_maxqrun; in makeworkgroups()
7770 if (Queue[h]->qg_queueintvl > 0 && in makeworkgroups()
7771 WorkGrp[j].wg_lowqintvl < Queue[h]->qg_queueintvl) in makeworkgroups()
7772 WorkGrp[j].wg_lowqintvl = Queue[h]->qg_queueintvl; in makeworkgroups()
7862 ofs = Queue[old->e_dfqgrp]->qg_qpaths[old->e_dfqdir].qp_fsysidx;
7863 nfs = Queue[new->e_dfqgrp]->qg_qpaths[new->e_dfqdir].qp_fsysidx;
8018 fs1 = Queue[(*pe1)->e_qgrp]->qg_qpaths[(*pe1)->e_qdir].qp_fsysidx;
8019 fs2 = Queue[(*pe2)->e_qgrp]->qg_qpaths[(*pe2)->e_qdir].qp_fsysidx;
8145 es->e_qdir = pickqdir(Queue[es->e_qgrp], es->e_msgsize, es);
8226 maxrcpt = Queue[e->e_qgrp]->qg_maxrcpt;
8876 for (qgrp = 0; qgrp < NumQueue && Queue[qgrp] != NULL; qgrp++)
8883 for (qdir = 0; qdir < Queue[qgrp]->qg_numqueues; qdir++)