Cross Reference: /illumos-gate/usr/src/cmd/sendmail/src/queue.c

Lines Matching defs:WorkGrp
121 static WORKGRP	volatile WorkGrp[MAXWORKGROUPS + 1];	/* work groups */
1178 	WorkGrp[wgrp].wg_restart = reason;
1212 		if (WorkGrp[i].wg_restart >= 0)
1217 					  i, WorkGrp[i].wg_restart);
1253 	WorkGrp[wgrp].wg_restart = -1;
1254 	if (WorkGrp[wgrp].wg_restartcnt < MAX_PERSIST_RESTART)
1257 		WorkGrp[wgrp].wg_restartcnt++;
1304 	cgrp = endgrp = WorkGrp[wgrp].wg_curqgrp;
1313 		qgrp = WorkGrp[wgrp].wg_qgs[cgrp]->qg_index;
1349 		INCR_MOD(cgrp, WorkGrp[wgrp].wg_numqgrp);
1471 	    (WorkGrp[0].wg_qgs[0]->qg_numqueues > 1 || NumWorkGroups > 1 ||
1472 	     WorkGrp[0].wg_numqgrp > 1))
1511 				"rq: curnum=%d, MaxQueueChildren=%d, CurRunners=%d, WorkGrp[curnum].wg_maxact=%d",
1513 				WorkGrp[curnum].wg_maxact);
1516 		    CurRunners + WorkGrp[curnum].wg_maxact > MaxQueueChildren)
1533 		CurRunners += WorkGrp[curnum].wg_maxact;
1553 			CurRunners -= WorkGrp[curnum].wg_maxact;
1912 	    WorkGrp[wgrp].wg_lowqintvl > 0 &&
1958 				      WorkGrp[wgrp].wg_maxact,
2042 	endgrp = WorkGrp[wgrp].wg_curqgrp; /* to not spin endlessly */
2059 		qgrp = WorkGrp[wgrp].wg_qgs[WorkGrp[wgrp].wg_curqgrp]->qg_index;
2060 		WorkGrp[wgrp].wg_curqgrp++; /* advance */
2061 		WorkGrp[wgrp].wg_curqgrp %= WorkGrp[wgrp].wg_numqgrp; /* wrap */
2066 		if (endgrp == WorkGrp[wgrp].wg_curqgrp)
2081 			WorkGrp[wgrp].wg_curqgrp, WorkGrp[wgrp].wg_numqgrp);
2292 	if (endgrp != WorkGrp[wgrp].wg_curqgrp)
2353 		if (njobs == 0 && WorkGrp[wgrp].wg_lowqintvl < MIN_SLEEP_TIME)
2355 		else if (WorkGrp[wgrp].wg_lowqintvl <= 0)
2358 			sleep(WorkGrp[wgrp].wg_lowqintvl);
7616 **		Sets up WorkGrp structure.
7640 		WorkGrp[0].wg_numqgrp = 1;
7641 		WorkGrp[0].wg_qgs = (QUEUEGRP **) xalloc(sizeof(QUEUEGRP *));
7642 		WorkGrp[0].wg_qgs[0] = Queue[0];
7645 			WorkGrp[0].wg_runners = MaxQueueChildren;
7647 			WorkGrp[0].wg_runners = Queue[0]->qg_numqueues;
7655 		WorkGrp[0].wg_maxact = Queue[0]->qg_maxqrun;
7656 		WorkGrp[0].wg_lowqintvl = Queue[0]->qg_queueintvl;
7707 		if (WorkGrp[j].wg_qgs == NULL)
7708 			WorkGrp[j].wg_qgs = (QUEUEGRP **)sm_malloc(sizeof(QUEUEGRP *) *
7709 							(WorkGrp[j].wg_numqgrp + 1));
7711 			WorkGrp[j].wg_qgs = (QUEUEGRP **)sm_realloc(WorkGrp[j].wg_qgs,
7713 							(WorkGrp[j].wg_numqgrp + 1));
7714 		if (WorkGrp[j].wg_qgs == NULL)
7718 				      (WorkGrp[j].wg_numqgrp + 1)));
7722 		WorkGrp[j].wg_qgs[WorkGrp[j].wg_numqgrp] = Queue[h];
7723 		WorkGrp[j].wg_numqgrp++;
7724 		WorkGrp[j].wg_runners += Queue[h]->qg_maxqrun;
7727 		if (WorkGrp[j].wg_maxact == 0)
7733 			WorkGrp[j].wg_maxact = Queue[h]->qg_maxqrun;
7744 		    WorkGrp[j].wg_lowqintvl < Queue[h]->qg_queueintvl)
7745 			WorkGrp[j].wg_lowqintvl = Queue[h]->qg_queueintvl;
7753 			for (j = 0; j < WorkGrp[i].wg_numqgrp; j++)
7756 					WorkGrp[i].wg_qgs[j]->qg_name);