sendmail/src/queue.c

73 static WORK	*WorkQ;		/* queue of things to be done */
1615 **  SKIP_DOMAINS -- Skip 'skip' number of domains in the WorkQ.
1622 **		skip -- number of domains in WorkQ to skip.
1628 **		may change WorkQ
1637 	for (n = 0, seqjump = 0; n < skip && WorkQ != NULL; seqjump++)
1639 		if (WorkQ->w_next != NULL)
1641 			if (WorkQ->w_host != NULL &&
1642 			    WorkQ->w_next->w_host != NULL)
1644 				if (sm_strcasecmp(WorkQ->w_host,
1645 						WorkQ->w_next->w_host) != 0)
1650 				if ((WorkQ->w_host != NULL &&
1651 				     WorkQ->w_next->w_host == NULL) ||
1652 				    (WorkQ->w_host == NULL &&
1653 				     WorkQ->w_next->w_host != NULL))
1657 		WorkQ = WorkQ->w_next;
1675 **		sequenceno -- 'th process to run WorkQ.
1678 **		njobs -- number of jobs in WorkQ.
1712 	while (WorkQ != NULL)
1737 		w = WorkQ; /* assign current work item */
1740 		**  Set the head of the WorkQ to the next work item.
1742 		**  runners working on WorkQ together) since each runner
1754 			if (WorkQ->w_next != NULL)
1756 				if (WorkQ->w_host != NULL &&
1757 				    WorkQ->w_next->w_host != NULL)
1759 					if (sm_strcasecmp(WorkQ->w_host,
1760 							WorkQ->w_next->w_host)
1764 						WorkQ = WorkQ->w_next;
1768 					if ((WorkQ->w_host != NULL &&
1769 					     WorkQ->w_next->w_host == NULL) ||
1770 					    (WorkQ->w_host == NULL &&
1771 					     WorkQ->w_next->w_host != NULL))
1774 						WorkQ = WorkQ->w_next;
1778 				WorkQ = WorkQ->w_next;
1783 			for (n = 0; n < skip && WorkQ != NULL; n++)
1784 				WorkQ = WorkQ->w_next;
2180 		**  For this WorkQ we want to fork off N children (maxrunners)
2181 		**  at this point. Each child has a copy of WorkQ. Each child
2234 					WorkQ = WorkQ->w_next;
2241 				if (WorkQ == NULL)
2258 				**  copy of WorkQ at its current position.
2403 		**  Get the LA outside the WorkQ loop if necessary.
2968 **	First the old WorkQ is cleared away. Then the WorkList is sorted
2971 **	WorkList to WorkQ. The lower count of 'max' or MaxListCount items
2975 **		max -- maximum number of items to be placed in WorkQ
2978 **		the number of items in WorkQ
2981 **		WorkQ gets released and filled with new work. WorkList
2991 	int wc = WorkListCount;		/* trim size for WorkQ */
2993 	if (WorkQ != NULL)
2997 		/* Clear out old WorkQ. */
2998 		for (w = WorkQ; w != NULL; w = nw)
3006 		WorkQ = NULL;
3146 		w->w_next = WorkQ;
3147 		WorkQ = w;
3166 		for (w = WorkQ; w != NULL; w = w->w_next)
3177 	return wc; /* return number of WorkQ items */
4956 	for (w = WorkQ; w != NULL; w = w->w_next)