Lines Matching refs:WorkGrp
129 static WORKGRP volatile WorkGrp[MAXWORKGROUPS + 1]; /* work groups */ variable
1232 WorkGrp[wgrp].wg_restart = reason;
1266 if (WorkGrp[i].wg_restart >= 0) in restart_marked_work_groups()
1271 i, WorkGrp[i].wg_restart); in restart_marked_work_groups()
1307 WorkGrp[wgrp].wg_restart = -1;
1308 if (WorkGrp[wgrp].wg_restartcnt < MAX_PERSIST_RESTART)
1311 WorkGrp[wgrp].wg_restartcnt++;
1358 cgrp = endgrp = WorkGrp[wgrp].wg_curqgrp;
1367 qgrp = WorkGrp[wgrp].wg_qgs[cgrp]->qg_index;
1404 INCR_MOD(cgrp, WorkGrp[wgrp].wg_numqgrp);
1526 (WorkGrp[0].wg_qgs[0]->qg_numqueues > 1 || NumWorkGroups > 1 ||
1527 WorkGrp[0].wg_numqgrp > 1))
1569 WorkGrp[curnum].wg_maxact,
1571 CurRunners + WorkGrp[curnum].wg_maxact >
1576 CurRunners + WorkGrp[curnum].wg_maxact > MaxQueueChildren)
1595 CurRunners += WorkGrp[curnum].wg_maxact;
1619 CurRunners -= WorkGrp[curnum].wg_maxact;
1621 WorkGrp[curnum].wg_maxact);
1991 WorkGrp[wgrp].wg_lowqintvl > 0 &&
2037 WorkGrp[wgrp].wg_maxact,
2122 endgrp = WorkGrp[wgrp].wg_curqgrp; /* to not spin endlessly */
2139 qgrp = WorkGrp[wgrp].wg_qgs[WorkGrp[wgrp].wg_curqgrp]->qg_index;
2140 WorkGrp[wgrp].wg_curqgrp++; /* advance */
2141 WorkGrp[wgrp].wg_curqgrp %= WorkGrp[wgrp].wg_numqgrp; /* wrap */
2146 if (endgrp == WorkGrp[wgrp].wg_curqgrp)
2161 WorkGrp[wgrp].wg_curqgrp, WorkGrp[wgrp].wg_numqgrp);
2370 if (endgrp != WorkGrp[wgrp].wg_curqgrp)
2431 if (njobs == 0 && WorkGrp[wgrp].wg_lowqintvl < MIN_SLEEP_TIME)
2433 else if (WorkGrp[wgrp].wg_lowqintvl <= 0)
2436 sleep(WorkGrp[wgrp].wg_lowqintvl);
7903 WorkGrp[0].wg_numqgrp = 1; in makeworkgroups()
7904 WorkGrp[0].wg_qgs = (QUEUEGRP **) xalloc(sizeof(QUEUEGRP *)); in makeworkgroups()
7905 WorkGrp[0].wg_qgs[0] = Queue[0]; in makeworkgroups()
7908 WorkGrp[0].wg_runners = MaxQueueChildren; in makeworkgroups()
7910 WorkGrp[0].wg_runners = Queue[0]->qg_numqueues; in makeworkgroups()
7918 WorkGrp[0].wg_maxact = Queue[0]->qg_maxqrun; in makeworkgroups()
7919 WorkGrp[0].wg_lowqintvl = Queue[0]->qg_queueintvl; in makeworkgroups()
7981 if (WorkGrp[j].wg_qgs == NULL) in makeworkgroups()
7982 WorkGrp[j].wg_qgs = (QUEUEGRP **)sm_malloc(sizeof(QUEUEGRP *) * in makeworkgroups()
7983 (WorkGrp[j].wg_numqgrp + 1)); in makeworkgroups()
7985 WorkGrp[j].wg_qgs = (QUEUEGRP **)sm_realloc(WorkGrp[j].wg_qgs, in makeworkgroups()
7987 (WorkGrp[j].wg_numqgrp + 1)); in makeworkgroups()
7988 if (WorkGrp[j].wg_qgs == NULL) in makeworkgroups()
7992 (WorkGrp[j].wg_numqgrp + 1))); in makeworkgroups()
7995 WorkGrp[j].wg_qgs[WorkGrp[j].wg_numqgrp] = Queue[h]; in makeworkgroups()
7996 WorkGrp[j].wg_numqgrp++; in makeworkgroups()
7997 WorkGrp[j].wg_runners += Queue[h]->qg_maxqrun; in makeworkgroups()
8000 if (WorkGrp[j].wg_maxact == 0) in makeworkgroups()
8006 WorkGrp[j].wg_maxact = Queue[h]->qg_maxqrun; in makeworkgroups()
8017 WorkGrp[j].wg_lowqintvl < Queue[h]->qg_queueintvl) in makeworkgroups()
8018 WorkGrp[j].wg_lowqintvl = Queue[h]->qg_queueintvl; in makeworkgroups()
8026 for (j = 0; j < WorkGrp[i].wg_numqgrp; j++) in makeworkgroups()
8029 WorkGrp[i].wg_qgs[j]->qg_name); in makeworkgroups()
8033 (int) WorkGrp[i].wg_lowqintvl); in makeworkgroups()