1343 	int qgrp, cgrp, endgrp;  local
1367 		qgrp = WorkGrp[wgrp].wg_qgs[cgrp]->qg_index;
1368 		if (Queue[qgrp]->qg_queueintvl > 0)
1369 			qintvl = Queue[qgrp]->qg_queueintvl;
1375 		lastsched = Queue[qgrp]->qg_nextrun;
1377 		if ((runall || Queue[qgrp]->qg_nextrun <= now) && qintvl > 0)
1393 				Queue[qgrp]->qg_nextrun += qintvl;
1399 				wgrp, cgrp, qgrp,
1400 				(long) Queue[qgrp]->qg_queueintvl,
1402 				(long) Queue[qgrp]->qg_nextrun, sched);
1430 	int qgrp;  in checkqueuerunner()  local
1435 	for (qgrp = 0; qgrp < NumQueue && Queue[qgrp] != NULL; qgrp++)  in checkqueuerunner()
1439 		if (Queue[qgrp]->qg_queueintvl > 0)  in checkqueuerunner()
1440 			qintvl = Queue[qgrp]->qg_queueintvl;  in checkqueuerunner()
1445 		if (Queue[qgrp]->qg_nextrun <= now - qintvl)  in checkqueuerunner()
1452 					qgrp,  in checkqueuerunner()
1453 					arpadate(ctime(&Queue[qgrp]->qg_nextrun)),  in checkqueuerunner()
1957 	int qgrp, endgrp, h, i;  local
2139 		qgrp = WorkGrp[wgrp].wg_qgs[WorkGrp[wgrp].wg_curqgrp]->qg_index;
2143 		    (Queue[qgrp]->qg_nextrun <= now &&
2144 		     Queue[qgrp]->qg_nextrun != (time_t) -1))
2155 	qdir = Queue[qgrp]->qg_curnum; /* round-robin init of queue position */
2160 			wgrp, qgrp, qdir, qid_printqueue(qgrp, qdir),
2166 	if (Queue[qgrp]->qg_nice > 0)
2167 		(void) nice(Queue[qgrp]->qg_nice);
2172 			qid_printqueue(qgrp, qdir));
2177 			  qid_printqueue(qgrp, qdir), (int) CurrentPid,
2186 	for (i = 0; i < Queue[qgrp]->qg_numqueues; i++)
2188 		(void) gatherq(qgrp, qdir, false, &full, &more, &h);
2191 			QSHM_ENTRIES(Queue[qgrp]->qg_qpaths[qdir].qp_idx) = h;
2198 			qdir %= Queue[qgrp]->qg_numqueues;
2207 	njobs = sortq(Queue[qgrp]->qg_maxlist);
2208 	Queue[qgrp]->qg_curnum = qdir; /* update */
2210 	if (!Verbose && bitnset(QD_FORK, Queue[qgrp]->qg_flags))
2226 		maxrunners = Queue[qgrp]->qg_maxqrun;
2353 	else if (Queue[qgrp]->qg_maxqrun > 0 || bitset(RWG_FORCE, flags))
2383 				qid_printqueue(qgrp, qdir));
2554 gatherq(qgrp, qdir, doall, full, more, pnentries)  in gatherq()  argument
2555 	int qgrp;  in gatherq()
2578 			Queue[qgrp]->qg_qpaths[qdir].qp_name,
2580 				Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
2632 			qid_printqueue(qgrp, qdir));
2702 					  qid_printqueue(qgrp, qdir),
2710 			grow_wlist(qgrp, qdir);
2723 					  qid_printqueue(qgrp, qdir),
2738 				       qid_printqueue(qgrp, qdir), d->d_name);
2752 			w->w_qgrp = qgrp;
2777 		w->w_qgrp = qgrp;
3236 grow_wlist(qgrp, qdir)  in grow_wlist()  argument
3237 	int qgrp;  in grow_wlist()
3262 					  qid_printqueue(qgrp, qdir),
3270 				  qid_printqueue(qgrp, qdir), newsize);
3638 dowork(qgrp, qdir, id, forkflag, requeueflag, e)  in dowork()  argument
3639 	int qgrp;  in dowork()
3650 		sm_dprintf("dowork(%s/%s), forkflag=%d\n", qid_printqueue(qgrp, qdir), id, forkflag);
3745 		e->e_qgrp = qgrp;
3791 				qid_printqueue(qgrp, qdir), id, forkflag,
4304 				int qgrp, qdir;  local
4311 				for (qgrp = 0;
4312 				     qgrp < NumQueue && Queue[qgrp] != NULL;
4313 				     ++qgrp)
4316 					     qdir < Queue[qgrp]->qg_numqueues;
4320 							   Queue[qgrp]->qg_qpaths[qdir].qp_name)
4323 							e->e_dfqgrp = qgrp;
4922 print_single_queue(qgrp, qdir)  in print_single_queue()  argument
4923 	int qgrp;  in print_single_queue()
4941 			Queue[qgrp]->qg_qpaths[qdir].qp_name,
4943 				Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4946 			Queue[qgrp]->qg_qpaths[qdir].qp_name,
4948 				Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
4967 				qid_printqueue(qgrp, qdir));
4992 	nrequests = gatherq(qgrp, qdir, true, NULL, NULL, NULL);
4993 	(void) sortq(Queue[qgrp]->qg_maxlist);
5003 				     qid_printqueue(qgrp, qdir));
5010 			     qid_printqueue(qgrp, qdir),
5075 			e.e_qgrp = qgrp;
5848 qid_printqueue(qgrp, qdir)  in qid_printqueue()  argument
5849 	int qgrp;  in qid_printqueue()
5856 		return Queue[qgrp]->qg_qdir;
5858 	if (strcmp(Queue[qgrp]->qg_qpaths[qdir].qp_name, ".") == 0)
5861 		subdir = Queue[qgrp]->qg_qpaths[qdir].qp_name;
5864 			Queue[qgrp]->qg_qdir,
5868 				Queue[qgrp]->qg_qpaths[qdir].qp_subdirs)
8165 split_env(e, sendqueue, qgrp, qdir)  in split_env()  argument
8168 	int qgrp;
8192 	ee->e_qgrp = ee->e_dfqgrp = qgrp;
8749 quarantine_queue_item(qgrp, qdir, e, reason)  in quarantine_queue_item()  argument
8750 	int qgrp;  in quarantine_queue_item()
9112 	int qgrp;  local
9124 	for (qgrp = 0; qgrp < NumQueue && Queue[qgrp] != NULL; qgrp++)
9128 		if (qgrplimit != NOQGRP && qgrplimit != qgrp)
9131 		for (qdir = 0; qdir < Queue[qgrp]->qg_numqueues; qdir++)
9139 			nrequests = gatherq(qgrp, qdir, true, NULL, NULL, NULL);
9148 							     qid_printqueue(qgrp, qdir));
9157 						     qid_printqueue(qgrp, qdir));
9170 				e.e_qgrp = qgrp;
9179 				else if (quarantine_queue_item(qgrp, qdir,