Lines Matching refs:WorkGrp

121 static WORKGRP	volatile WorkGrp[MAXWORKGROUPS + 1];	/* work groups */  variable
1176 WorkGrp[wgrp].wg_restart = reason;
1210 if (WorkGrp[i].wg_restart >= 0) in restart_marked_work_groups()
1215 i, WorkGrp[i].wg_restart); in restart_marked_work_groups()
1251 WorkGrp[wgrp].wg_restart = -1;
1252 if (WorkGrp[wgrp].wg_restartcnt < MAX_PERSIST_RESTART)
1255 WorkGrp[wgrp].wg_restartcnt++;
1302 cgrp = endgrp = WorkGrp[wgrp].wg_curqgrp;
1311 qgrp = WorkGrp[wgrp].wg_qgs[cgrp]->qg_index;
1347 INCR_MOD(cgrp, WorkGrp[wgrp].wg_numqgrp);
1469 (WorkGrp[0].wg_qgs[0]->qg_numqueues > 1 || NumWorkGroups > 1 ||
1470 WorkGrp[0].wg_numqgrp > 1))
1512 WorkGrp[curnum].wg_maxact);
1515 CurRunners + WorkGrp[curnum].wg_maxact > MaxQueueChildren)
1534 CurRunners += WorkGrp[curnum].wg_maxact;
1558 CurRunners -= WorkGrp[curnum].wg_maxact;
1560 WorkGrp[curnum].wg_maxact);
1921 WorkGrp[wgrp].wg_lowqintvl > 0 &&
1967 WorkGrp[wgrp].wg_maxact,
2052 endgrp = WorkGrp[wgrp].wg_curqgrp; /* to not spin endlessly */
2069 qgrp = WorkGrp[wgrp].wg_qgs[WorkGrp[wgrp].wg_curqgrp]->qg_index;
2070 WorkGrp[wgrp].wg_curqgrp++; /* advance */
2071 WorkGrp[wgrp].wg_curqgrp %= WorkGrp[wgrp].wg_numqgrp; /* wrap */
2076 if (endgrp == WorkGrp[wgrp].wg_curqgrp)
2091 WorkGrp[wgrp].wg_curqgrp, WorkGrp[wgrp].wg_numqgrp);
2302 if (endgrp != WorkGrp[wgrp].wg_curqgrp)
2363 if (njobs == 0 && WorkGrp[wgrp].wg_lowqintvl < MIN_SLEEP_TIME)
2365 else if (WorkGrp[wgrp].wg_lowqintvl <= 0)
2368 sleep(WorkGrp[wgrp].wg_lowqintvl);
7664 WorkGrp[0].wg_numqgrp = 1; in makeworkgroups()
7665 WorkGrp[0].wg_qgs = (QUEUEGRP **) xalloc(sizeof(QUEUEGRP *)); in makeworkgroups()
7666 WorkGrp[0].wg_qgs[0] = Queue[0]; in makeworkgroups()
7669 WorkGrp[0].wg_runners = MaxQueueChildren; in makeworkgroups()
7671 WorkGrp[0].wg_runners = Queue[0]->qg_numqueues; in makeworkgroups()
7679 WorkGrp[0].wg_maxact = Queue[0]->qg_maxqrun; in makeworkgroups()
7680 WorkGrp[0].wg_lowqintvl = Queue[0]->qg_queueintvl; in makeworkgroups()
7734 if (WorkGrp[j].wg_qgs == NULL) in makeworkgroups()
7735 WorkGrp[j].wg_qgs = (QUEUEGRP **)sm_malloc(sizeof(QUEUEGRP *) * in makeworkgroups()
7736 (WorkGrp[j].wg_numqgrp + 1)); in makeworkgroups()
7738 WorkGrp[j].wg_qgs = (QUEUEGRP **)sm_realloc(WorkGrp[j].wg_qgs, in makeworkgroups()
7740 (WorkGrp[j].wg_numqgrp + 1)); in makeworkgroups()
7741 if (WorkGrp[j].wg_qgs == NULL) in makeworkgroups()
7745 (WorkGrp[j].wg_numqgrp + 1))); in makeworkgroups()
7749 WorkGrp[j].wg_qgs[WorkGrp[j].wg_numqgrp] = Queue[h]; in makeworkgroups()
7750 WorkGrp[j].wg_numqgrp++; in makeworkgroups()
7751 WorkGrp[j].wg_runners += Queue[h]->qg_maxqrun; in makeworkgroups()
7754 if (WorkGrp[j].wg_maxact == 0) in makeworkgroups()
7760 WorkGrp[j].wg_maxact = Queue[h]->qg_maxqrun; in makeworkgroups()
7771 WorkGrp[j].wg_lowqintvl < Queue[h]->qg_queueintvl) in makeworkgroups()
7772 WorkGrp[j].wg_lowqintvl = Queue[h]->qg_queueintvl; in makeworkgroups()
7780 for (j = 0; j < WorkGrp[i].wg_numqgrp; j++) in makeworkgroups()
7783 WorkGrp[i].wg_qgs[j]->qg_name); in makeworkgroups()