1 /*
2  * Copyright (c) 1983 Eric P. Allman
3  * Copyright (c) 1988 Regents of the University of California.
4  * All rights reserved.
5  *
6  * %sccs.include.redist.c%
7  */
8 
9 #ifndef lint
10 static char sccsid[] = "@(#)deliver.c	6.40 (Berkeley) 03/07/93";
11 #endif /* not lint */
12 
13 #include "sendmail.h"
14 #include <signal.h>
15 #include <sys/stat.h>
16 #include <netdb.h>
17 #include <fcntl.h>
18 #include <errno.h>
19 #ifdef NAMED_BIND
20 #include <arpa/nameser.h>
21 #include <resolv.h>
22 #endif
23 
24 /*
25 **  DELIVER -- Deliver a message to a list of addresses.
26 **
27 **	This routine delivers to everyone on the same host as the
28 **	user on the head of the list.  It is clever about mailers
29 **	that don't handle multiple users.  It is NOT guaranteed
30 **	that it will deliver to all these addresses however -- so
31 **	deliver should be called once for each address on the
32 **	list.
33 **
34 **	Parameters:
35 **		e -- the envelope to deliver.
36 **		firstto -- head of the address list to deliver to.
37 **
38 **	Returns:
39 **		zero -- successfully delivered.
40 **		else -- some failure, see ExitStat for more info.
41 **
42 **	Side Effects:
43 **		The standard input is passed off to someone.
44 */
45 
46 deliver(e, firstto)
47 	register ENVELOPE *e;
48 	ADDRESS *firstto;
49 {
50 	char *host;			/* host being sent to */
51 	char *user;			/* user being sent to */
52 	char **pvp;
53 	register char **mvp;
54 	register char *p;
55 	register MAILER *m;		/* mailer for this recipient */
56 	ADDRESS *ctladdr;
57 	register MCI *mci;
58 	register ADDRESS *to = firstto;
59 	bool clever = FALSE;		/* running user smtp to this mailer */
60 	ADDRESS *tochain = NULL;	/* chain of users in this mailer call */
61 	int rcode;			/* response code */
62 	char *from;			/* pointer to from person */
63 	char *firstsig;			/* signature of firstto */
64 	char *pv[MAXPV+1];
65 	char tobuf[MAXLINE-50];		/* text line of to people */
66 	char buf[MAXNAME];
67 	char tfrombuf[MAXNAME];		/* translated from person */
68 	char rpathbuf[MAXNAME];		/* translated return path */
69 	extern int checkcompat();
70 	extern ADDRESS *getctladdr();
71 	extern char *remotename();
72 	extern MCI *openmailer();
73 	extern char *hostsignature();
74 
75 	errno = 0;
76 	if (bitset(QDONTSEND|QQUEUEUP, to->q_flags))
77 		return (0);
78 
79 #ifdef NAMED_BIND
80 	/* unless interactive, try twice, over a minute */
81 	if (OpMode == MD_DAEMON || OpMode == MD_SMTP) {
82 		_res.retrans = 30;
83 		_res.retry = 2;
84 	}
85 #endif
86 
87 	m = to->q_mailer;
88 	host = to->q_host;
89 
90 	if (tTd(10, 1))
91 		printf("\n--deliver, mailer=%d, host=`%s', first user=`%s'\n",
92 			m->m_mno, host, to->q_user);
93 
94 	/*
95 	**  If this mailer is expensive, and if we don't want to make
96 	**  connections now, just mark these addresses and return.
97 	**	This is useful if we want to batch connections to
98 	**	reduce load.  This will cause the messages to be
99 	**	queued up, and a daemon will come along to send the
100 	**	messages later.
101 	**		This should be on a per-mailer basis.
102 	*/
103 
104 	if (NoConnect && !QueueRun && bitnset(M_EXPENSIVE, m->m_flags) &&
105 	    !Verbose)
106 	{
107 		for (; to != NULL; to = to->q_next)
108 		{
109 			if (bitset(QDONTSEND|QQUEUEUP, to->q_flags) ||
110 			    to->q_mailer != m)
111 				continue;
112 			to->q_flags |= QQUEUEUP|QDONTSEND;
113 			e->e_to = to->q_paddr;
114 			message("queued");
115 			if (LogLevel > 8)
116 				logdelivery(m, NULL, "queued", e);
117 		}
118 		e->e_to = NULL;
119 		return (0);
120 	}
121 
122 	/*
123 	**  Do initial argv setup.
124 	**	Insert the mailer name.  Notice that $x expansion is
125 	**	NOT done on the mailer name.  Then, if the mailer has
126 	**	a picky -f flag, we insert it as appropriate.  This
127 	**	code does not check for 'pv' overflow; this places a
128 	**	manifest lower limit of 4 for MAXPV.
129 	**		The from address rewrite is expected to make
130 	**		the address relative to the other end.
131 	*/
132 
133 	/* rewrite from address, using rewriting rules */
134 	(void) strcpy(rpathbuf, remotename(e->e_returnpath, m, TRUE, FALSE,
135 					   TRUE, FALSE, e));
136 	if (e->e_returnpath == e->e_sender)
137 	{
138 		from = rpathbuf;
139 	}
140 	else
141 	{
142 		(void) strcpy(tfrombuf, remotename(e->e_sender, m, TRUE, FALSE,
143 						   TRUE, FALSE, e));
144 		from = tfrombuf;
145 	}
146 
147 	define('f', e->e_returnpath, e);	/* raw return path */
148 	define('<', rpathbuf, e);		/* translated return path */
149 	define('g', from, e);			/* translated sender */
150 	define('h', host, e);			/* to host */
151 	Errors = 0;
152 	pvp = pv;
153 	*pvp++ = m->m_argv[0];
154 
155 	/* insert -f or -r flag as appropriate */
156 	if (FromFlag && (bitnset(M_FOPT, m->m_flags) || bitnset(M_ROPT, m->m_flags)))
157 	{
158 		if (bitnset(M_FOPT, m->m_flags))
159 			*pvp++ = "-f";
160 		else
161 			*pvp++ = "-r";
162 		*pvp++ = newstr(rpathbuf);
163 	}
164 
165 	/*
166 	**  Append the other fixed parts of the argv.  These run
167 	**  up to the first entry containing "$u".  There can only
168 	**  be one of these, and there are only a few more slots
169 	**  in the pv after it.
170 	*/
171 
172 	for (mvp = m->m_argv; (p = *++mvp) != NULL; )
173 	{
174 		/* can't use strchr here because of sign extension problems */
175 		while (*p != '\0')
176 		{
177 			if ((*p++ & 0377) == MACROEXPAND)
178 			{
179 				if (*p == 'u')
180 					break;
181 			}
182 		}
183 
184 		if (*p != '\0')
185 			break;
186 
187 		/* this entry is safe -- go ahead and process it */
188 		expand(*mvp, buf, &buf[sizeof buf - 1], e);
189 		*pvp++ = newstr(buf);
190 		if (pvp >= &pv[MAXPV - 3])
191 		{
192 			syserr("554 Too many parameters to %s before $u", pv[0]);
193 			return (-1);
194 		}
195 	}
196 
197 	/*
198 	**  If we have no substitution for the user name in the argument
199 	**  list, we know that we must supply the names otherwise -- and
200 	**  SMTP is the answer!!
201 	*/
202 
203 	if (*mvp == NULL)
204 	{
205 		/* running SMTP */
206 # ifdef SMTP
207 		clever = TRUE;
208 		*pvp = NULL;
209 # else /* SMTP */
210 		/* oops!  we don't implement SMTP */
211 		syserr("554 SMTP style mailer");
212 		return (EX_SOFTWARE);
213 # endif /* SMTP */
214 	}
215 
216 	/*
217 	**  At this point *mvp points to the argument with $u.  We
218 	**  run through our address list and append all the addresses
219 	**  we can.  If we run out of space, do not fret!  We can
220 	**  always send another copy later.
221 	*/
222 
223 	tobuf[0] = '\0';
224 	e->e_to = tobuf;
225 	ctladdr = NULL;
226 	firstsig = hostsignature(firstto->q_mailer, firstto->q_host, e);
227 	for (; to != NULL; to = to->q_next)
228 	{
229 		/* avoid sending multiple recipients to dumb mailers */
230 		if (tobuf[0] != '\0' && !bitnset(M_MUSER, m->m_flags))
231 			break;
232 
233 		/* if already sent or not for this host, don't send */
234 		if (bitset(QDONTSEND|QQUEUEUP, to->q_flags) ||
235 		    to->q_mailer != firstto->q_mailer ||
236 		    strcmp(hostsignature(to->q_mailer, to->q_host, e), firstsig) != 0)
237 			continue;
238 
239 		/* avoid overflowing tobuf */
240 		if (sizeof tobuf < (strlen(to->q_paddr) + strlen(tobuf) + 2))
241 			break;
242 
243 		if (tTd(10, 1))
244 		{
245 			printf("\nsend to ");
246 			printaddr(to, FALSE);
247 		}
248 
249 		/* compute effective uid/gid when sending */
250 		if (to->q_mailer == ProgMailer)
251 			ctladdr = getctladdr(to);
252 
253 		user = to->q_user;
254 		e->e_to = to->q_paddr;
255 		to->q_flags |= QDONTSEND;
256 		if (tTd(10, 5))
257 		{
258 			printf("deliver: QDONTSEND ");
259 			printaddr(to, FALSE);
260 		}
261 
262 		/*
263 		**  Check to see that these people are allowed to
264 		**  talk to each other.
265 		*/
266 
267 		if (m->m_maxsize != 0 && e->e_msgsize > m->m_maxsize)
268 		{
269 			NoReturn = TRUE;
270 			usrerr("552 Message is too large; %ld bytes max", m->m_maxsize);
271 			giveresponse(EX_UNAVAILABLE, m, NULL, e);
272 			continue;
273 		}
274 		rcode = checkcompat(to, e);
275 		if (rcode != EX_OK)
276 		{
277 			giveresponse(rcode, m, NULL, e);
278 			continue;
279 		}
280 
281 		/*
282 		**  Strip quote bits from names if the mailer is dumb
283 		**	about them.
284 		*/
285 
286 		if (bitnset(M_STRIPQ, m->m_flags))
287 		{
288 			stripquotes(user);
289 			stripquotes(host);
290 		}
291 
292 		/* hack attack -- delivermail compatibility */
293 		if (m == ProgMailer && *user == '|')
294 			user++;
295 
296 		/*
297 		**  If an error message has already been given, don't
298 		**	bother to send to this address.
299 		**
300 		**	>>>>>>>>>> This clause assumes that the local mailer
301 		**	>> NOTE >> cannot do any further aliasing; that
302 		**	>>>>>>>>>> function is subsumed by sendmail.
303 		*/
304 
305 		if (bitset(QBADADDR|QQUEUEUP, to->q_flags))
306 			continue;
307 
308 		/* save statistics.... */
309 		markstats(e, to);
310 
311 		/*
312 		**  See if this user name is "special".
313 		**	If the user name has a slash in it, assume that this
314 		**	is a file -- send it off without further ado.  Note
315 		**	that this type of addresses is not processed along
316 		**	with the others, so we fudge on the To person.
317 		*/
318 
319 		if (m == FileMailer)
320 		{
321 			rcode = mailfile(user, getctladdr(to), e);
322 			giveresponse(rcode, m, NULL, e);
323 			if (rcode == EX_OK)
324 				to->q_flags |= QSENT;
325 			continue;
326 		}
327 
328 		/*
329 		**  Address is verified -- add this user to mailer
330 		**  argv, and add it to the print list of recipients.
331 		*/
332 
333 		/* link together the chain of recipients */
334 		to->q_tchain = tochain;
335 		tochain = to;
336 
337 		/* create list of users for error messages */
338 		(void) strcat(tobuf, ",");
339 		(void) strcat(tobuf, to->q_paddr);
340 		define('u', user, e);		/* to user */
341 		define('z', to->q_home, e);	/* user's home */
342 
343 		/*
344 		**  Expand out this user into argument list.
345 		*/
346 
347 		if (!clever)
348 		{
349 			expand(*mvp, buf, &buf[sizeof buf - 1], e);
350 			*pvp++ = newstr(buf);
351 			if (pvp >= &pv[MAXPV - 2])
352 			{
353 				/* allow some space for trailing parms */
354 				break;
355 			}
356 		}
357 	}
358 
359 	/* see if any addresses still exist */
360 	if (tobuf[0] == '\0')
361 	{
362 		define('g', (char *) NULL, e);
363 		define('<', (char *) NULL, e);
364 		return (0);
365 	}
366 
367 	/* print out messages as full list */
368 	e->e_to = tobuf + 1;
369 
370 	/*
371 	**  Fill out any parameters after the $u parameter.
372 	*/
373 
374 	while (!clever && *++mvp != NULL)
375 	{
376 		expand(*mvp, buf, &buf[sizeof buf - 1], e);
377 		*pvp++ = newstr(buf);
378 		if (pvp >= &pv[MAXPV])
379 			syserr("554 deliver: pv overflow after $u for %s", pv[0]);
380 	}
381 	*pvp++ = NULL;
382 
383 	/*
384 	**  Call the mailer.
385 	**	The argument vector gets built, pipes
386 	**	are created as necessary, and we fork & exec as
387 	**	appropriate.
388 	**	If we are running SMTP, we just need to clean up.
389 	*/
390 
391 	if (ctladdr == NULL && m != ProgMailer)
392 		ctladdr = &e->e_from;
393 #ifdef NAMED_BIND
394 	if (ConfigLevel < 2)
395 		_res.options &= ~(RES_DEFNAMES | RES_DNSRCH);	/* XXX */
396 #endif
397 	mci = openmailer(m, pv, ctladdr, clever, e);
398 	if (mci == NULL)
399 	{
400 		/* catastrophic error */
401 		rcode = EX_OSERR;
402 		goto give_up;
403 	}
404 	else if (mci->mci_state != MCIS_OPEN)
405 	{
406 		/* couldn't open the mailer */
407 		rcode = mci->mci_exitstat;
408 		errno = mci->mci_errno;
409 		if (rcode == EX_OK)
410 		{
411 			/* shouldn't happen */
412 			syserr("554 deliver: rcode=%d, mci_state=%d, sig=%s",
413 				rcode, mci->mci_state, firstsig);
414 			rcode = EX_SOFTWARE;
415 		}
416 	}
417 	else if (!clever)
418 	{
419 		/*
420 		**  Format and send message.
421 		*/
422 
423 		putfromline(mci->mci_out, m, e);
424 		(*e->e_puthdr)(mci->mci_out, m, e);
425 		putline("\n", mci->mci_out, m);
426 		(*e->e_putbody)(mci->mci_out, m, e);
427 
428 		/* get the exit status */
429 		rcode = endmailer(mci, pv[0]);
430 	}
431 	else
432 #ifdef SMTP
433 	{
434 		/*
435 		**  Send the MAIL FROM: protocol
436 		*/
437 
438 		rcode = smtpmailfrom(m, mci, e);
439 		if (rcode == EX_OK)
440 		{
441 			register char *t = tobuf;
442 			register int i;
443 
444 			/* send the recipient list */
445 			tobuf[0] = '\0';
446 			for (to = tochain; to != NULL; to = to->q_tchain)
447 			{
448 				e->e_to = to->q_paddr;
449 				if ((i = smtprcpt(to, m, mci, e)) != EX_OK)
450 				{
451 					markfailure(e, to, i);
452 					giveresponse(i, m, mci, e);
453 				}
454 				else
455 				{
456 					*t++ = ',';
457 					for (p = to->q_paddr; *p; *t++ = *p++)
458 						continue;
459 				}
460 			}
461 
462 			/* now send the data */
463 			if (tobuf[0] == '\0')
464 			{
465 				e->e_to = NULL;
466 				if (bitset(MCIF_CACHED, mci->mci_flags))
467 					smtprset(m, mci, e);
468 			}
469 			else
470 			{
471 				e->e_to = tobuf + 1;
472 				rcode = smtpdata(m, mci, e);
473 			}
474 
475 			/* now close the connection */
476 			if (!bitset(MCIF_CACHED, mci->mci_flags))
477 				smtpquit(m, mci, e);
478 		}
479 	}
480 #else /* not SMTP */
481 	{
482 		syserr("554 deliver: need SMTP compiled to use clever mailer");
483 		rcode = EX_CONFIG;
484 		goto give_up;
485 	}
486 #endif /* SMTP */
487 #ifdef NAMED_BIND
488 	if (ConfigLevel < 2)
489 		_res.options |= RES_DEFNAMES | RES_DNSRCH;	/* XXX */
490 #endif
491 
492 	/* arrange a return receipt if requested */
493 	if (e->e_receiptto != NULL && bitnset(M_LOCALMAILER, m->m_flags))
494 	{
495 		e->e_flags |= EF_SENDRECEIPT;
496 		/* do we want to send back more info? */
497 	}
498 
499 	/*
500 	**  Do final status disposal.
501 	**	We check for something in tobuf for the SMTP case.
502 	**	If we got a temporary failure, arrange to queue the
503 	**		addressees.
504 	*/
505 
506   give_up:
507 	if (tobuf[0] != '\0')
508 		giveresponse(rcode, m, mci, e);
509 	for (to = tochain; to != NULL; to = to->q_tchain)
510 	{
511 		if (rcode != EX_OK)
512 			markfailure(e, to, rcode);
513 		else
514 		{
515 			to->q_flags |= QSENT;
516 			e->e_nsent++;
517 		}
518 	}
519 
520 	/*
521 	**  Restore state and return.
522 	*/
523 
524 	errno = 0;
525 	define('g', (char *) NULL, e);
526 	define('<', (char *) NULL, e);
527 	return (rcode);
528 }
529 /*
530 **  MARKFAILURE -- mark a failure on a specific address.
531 **
532 **	Parameters:
533 **		e -- the envelope we are sending.
534 **		q -- the address to mark.
535 **		rcode -- the code signifying the particular failure.
536 **
537 **	Returns:
538 **		none.
539 **
540 **	Side Effects:
541 **		marks the address (and possibly the envelope) with the
542 **			failure so that an error will be returned or
543 **			the message will be queued, as appropriate.
544 */
545 
546 markfailure(e, q, rcode)
547 	register ENVELOPE *e;
548 	register ADDRESS *q;
549 	int rcode;
550 {
551 	if (rcode == EX_OK)
552 		return;
553 	else if (rcode != EX_TEMPFAIL && rcode != EX_IOERR && rcode != EX_OSERR)
554 		q->q_flags |= QBADADDR;
555 	else if (curtime() > e->e_ctime + TimeOut)
556 	{
557 		extern char *pintvl();
558 		char buf[MAXLINE];
559 
560 		if (!bitset(EF_TIMEOUT, e->e_flags))
561 		{
562 			(void) sprintf(buf, "Cannot send message for %s",
563 				pintvl(TimeOut, FALSE));
564 			if (e->e_message != NULL)
565 				free(e->e_message);
566 			e->e_message = newstr(buf);
567 			message(buf);
568 		}
569 		q->q_flags |= QBADADDR;
570 		e->e_flags |= EF_TIMEOUT;
571 		fprintf(e->e_xfp, "421 %s... Message timed out\n", q->q_paddr);
572 	}
573 	else
574 		q->q_flags |= QQUEUEUP;
575 }
576 /*
577 **  DOFORK -- do a fork, retrying a couple of times on failure.
578 **
579 **	This MUST be a macro, since after a vfork we are running
580 **	two processes on the same stack!!!
581 **
582 **	Parameters:
583 **		none.
584 **
585 **	Returns:
586 **		From a macro???  You've got to be kidding!
587 **
588 **	Side Effects:
589 **		Modifies the ==> LOCAL <== variable 'pid', leaving:
590 **			pid of child in parent, zero in child.
591 **			-1 on unrecoverable error.
592 **
593 **	Notes:
594 **		I'm awfully sorry this looks so awful.  That's
595 **		vfork for you.....
596 */
597 
598 # define NFORKTRIES	5
599 
600 # ifndef FORK
601 # define FORK	fork
602 # endif
603 
604 # define DOFORK(fORKfN) \
605 {\
606 	register int i;\
607 \
608 	for (i = NFORKTRIES; --i >= 0; )\
609 	{\
610 		pid = fORKfN();\
611 		if (pid >= 0)\
612 			break;\
613 		if (i > 0)\
614 			sleep((unsigned) NFORKTRIES - i);\
615 	}\
616 }
617 /*
618 **  DOFORK -- simple fork interface to DOFORK.
619 **
620 **	Parameters:
621 **		none.
622 **
623 **	Returns:
624 **		pid of child in parent.
625 **		zero in child.
626 **		-1 on error.
627 **
628 **	Side Effects:
629 **		returns twice, once in parent and once in child.
630 */
631 
632 dofork()
633 {
634 	register int pid;
635 
636 	DOFORK(fork);
637 	return (pid);
638 }
639 /*
640 **  ENDMAILER -- Wait for mailer to terminate.
641 **
642 **	We should never get fatal errors (e.g., segmentation
643 **	violation), so we report those specially.  For other
644 **	errors, we choose a status message (into statmsg),
645 **	and if it represents an error, we print it.
646 **
647 **	Parameters:
648 **		pid -- pid of mailer.
649 **		name -- name of mailer (for error messages).
650 **
651 **	Returns:
652 **		exit code of mailer.
653 **
654 **	Side Effects:
655 **		none.
656 */
657 
658 endmailer(mci, name)
659 	register MCI *mci;
660 	char *name;
661 {
662 	int st;
663 
664 	/* close any connections */
665 	if (mci->mci_in != NULL)
666 		(void) fclose(mci->mci_in);
667 	if (mci->mci_out != NULL)
668 		(void) fclose(mci->mci_out);
669 	mci->mci_in = mci->mci_out = NULL;
670 	mci->mci_state = MCIS_CLOSED;
671 
672 	/* in the IPC case there is nothing to wait for */
673 	if (mci->mci_pid == 0)
674 		return (EX_OK);
675 
676 	/* wait for the mailer process to die and collect status */
677 	st = waitfor(mci->mci_pid);
678 	if (st == -1)
679 	{
680 		syserr("endmailer %s: wait", name);
681 		return (EX_SOFTWARE);
682 	}
683 
684 	/* see if it died a horrid death */
685 	if ((st & 0377) != 0)
686 	{
687 		syserr("mailer %s died with signal %o", name, st);
688 		ExitStat = EX_TEMPFAIL;
689 		return (EX_TEMPFAIL);
690 	}
691 
692 	/* normal death -- return status */
693 	st = (st >> 8) & 0377;
694 	return (st);
695 }
696 /*
697 **  OPENMAILER -- open connection to mailer.
698 **
699 **	Parameters:
700 **		m -- mailer descriptor.
701 **		pvp -- parameter vector to pass to mailer.
702 **		ctladdr -- controlling address for user.
703 **		clever -- create a full duplex connection.
704 **
705 **	Returns:
706 **		The mail connection info struct for this connection.
707 **		NULL on failure.
708 **
709 **	Side Effects:
710 **		creates a mailer in a subprocess.
711 */
712 
713 MCI *
714 openmailer(m, pvp, ctladdr, clever, e)
715 	MAILER *m;
716 	char **pvp;
717 	ADDRESS *ctladdr;
718 	bool clever;
719 	ENVELOPE *e;
720 {
721 	int pid;
722 	register MCI *mci;
723 	int mpvect[2];
724 	int rpvect[2];
725 	extern FILE *fdopen();
726 
727 	if (tTd(11, 1))
728 	{
729 		printf("openmailer:");
730 		printav(pvp);
731 	}
732 	errno = 0;
733 
734 	CurHostName = m->m_mailer;
735 
736 	/*
737 	**  Deal with the special case of mail handled through an IPC
738 	**  connection.
739 	**	In this case we don't actually fork.  We must be
740 	**	running SMTP for this to work.  We will return a
741 	**	zero pid to indicate that we are running IPC.
742 	**  We also handle a debug version that just talks to stdin/out.
743 	*/
744 
745 	/* check for Local Person Communication -- not for mortals!!! */
746 	if (strcmp(m->m_mailer, "[LPC]") == 0)
747 	{
748 		mci = (MCI *) xalloc(sizeof *mci);
749 		bzero((char *) mci, sizeof *mci);
750 		mci->mci_in = stdin;
751 		mci->mci_out = stdout;
752 		mci->mci_state = clever ? MCIS_OPENING : MCIS_OPEN;
753 		mci->mci_mailer = m;
754 	}
755 	else if (strcmp(m->m_mailer, "[IPC]") == 0 ||
756 		 strcmp(m->m_mailer, "[TCP]") == 0)
757 	{
758 #ifdef DAEMON
759 		register int i;
760 		register u_short port;
761 		char *curhost;
762 		extern MCI *mci_get();
763 		extern char *hostsignature();
764 
765 		CurHostName = pvp[1];
766 		curhost = hostsignature(m, pvp[1], e);
767 
768 		if (curhost == NULL || curhost[0] == '\0')
769 		{
770 			syserr("null signature");
771 			return NULL;
772 		}
773 
774 		if (!clever)
775 		{
776 			syserr("554 non-clever IPC");
777 			return NULL;
778 		}
779 		if (pvp[2] != NULL)
780 			port = atoi(pvp[2]);
781 		else
782 			port = 0;
783 		while (*curhost != '\0')
784 		{
785 			register char *p;
786 			char hostbuf[MAXNAME];
787 
788 			/* pull the next host from the signature */
789 			p = strchr(curhost, ':');
790 			if (p == NULL)
791 				p = &curhost[strlen(curhost)];
792 			strncpy(hostbuf, curhost, p - curhost);
793 			hostbuf[p - curhost] = '\0';
794 			if (*p != '\0')
795 				p++;
796 			curhost = p;
797 
798 			/* see if we already know that this host is fried */
799 			CurHostName = hostbuf;
800 			mci = mci_get(hostbuf, m);
801 			if (mci->mci_state != MCIS_CLOSED)
802 			{
803 				if (tTd(11, 1))
804 				{
805 					printf("openmailer: ");
806 					mci_dump(mci);
807 				}
808 				CurHostName = mci->mci_host;
809 				return mci;
810 			}
811 			mci->mci_mailer = m;
812 			if (mci->mci_exitstat != EX_OK)
813 				continue;
814 
815 			/* try the connection */
816 			setproctitle("%s %s: %s", e->e_id, hostbuf, "user open");
817 			message("Connecting to %s (%s)...",
818 				hostbuf, m->m_name);
819 			i = makeconnection(hostbuf, port, mci,
820 				bitnset(M_SECURE_PORT, m->m_flags));
821 			mci->mci_exitstat = i;
822 			mci->mci_errno = errno;
823 			if (i == EX_OK)
824 			{
825 				mci->mci_state = MCIS_OPENING;
826 				mci_cache(mci);
827 				break;
828 			}
829 			else if (tTd(11, 1))
830 				printf("openmailer: makeconnection => stat=%d, errno=%d\n",
831 					i, errno);
832 
833 
834 			/* enter status of this host */
835 			setstat(i);
836 		}
837 		mci->mci_pid = 0;
838 #else /* no DAEMON */
839 		syserr("554 openmailer: no IPC");
840 		if (tTd(11, 1))
841 			printf("openmailer: NULL\n");
842 		return NULL;
843 #endif /* DAEMON */
844 	}
845 	else
846 	{
847 		/* create a pipe to shove the mail through */
848 		if (pipe(mpvect) < 0)
849 		{
850 			syserr("openmailer: pipe (to mailer)");
851 			if (tTd(11, 1))
852 				printf("openmailer: NULL\n");
853 			return NULL;
854 		}
855 
856 		/* if this mailer speaks smtp, create a return pipe */
857 		if (clever && pipe(rpvect) < 0)
858 		{
859 			syserr("openmailer: pipe (from mailer)");
860 			(void) close(mpvect[0]);
861 			(void) close(mpvect[1]);
862 			if (tTd(11, 1))
863 				printf("openmailer: NULL\n");
864 			return NULL;
865 		}
866 
867 		/*
868 		**  Actually fork the mailer process.
869 		**	DOFORK is clever about retrying.
870 		**
871 		**	Dispose of SIGCHLD signal catchers that may be laying
872 		**	around so that endmail will get it.
873 		*/
874 
875 		if (e->e_xfp != NULL)
876 			(void) fflush(e->e_xfp);		/* for debugging */
877 		(void) fflush(stdout);
878 # ifdef SIGCHLD
879 		(void) signal(SIGCHLD, SIG_DFL);
880 # endif /* SIGCHLD */
881 		DOFORK(FORK);
882 		/* pid is set by DOFORK */
883 		if (pid < 0)
884 		{
885 			/* failure */
886 			syserr("openmailer: cannot fork");
887 			(void) close(mpvect[0]);
888 			(void) close(mpvect[1]);
889 			if (clever)
890 			{
891 				(void) close(rpvect[0]);
892 				(void) close(rpvect[1]);
893 			}
894 			if (tTd(11, 1))
895 				printf("openmailer: NULL\n");
896 			return NULL;
897 		}
898 		else if (pid == 0)
899 		{
900 			int i;
901 			int saveerrno;
902 			char *env[2];
903 			extern int DtableSize;
904 
905 			/* child -- set up input & exec mailer */
906 			/* make diagnostic output be standard output */
907 			(void) signal(SIGINT, SIG_IGN);
908 			(void) signal(SIGHUP, SIG_IGN);
909 			(void) signal(SIGTERM, SIG_DFL);
910 
911 			/* close any other cached connections */
912 			mci_flush(FALSE, mci);
913 
914 			/* arrange to filter std & diag output of command */
915 			if (clever)
916 			{
917 				(void) close(rpvect[0]);
918 				(void) close(1);
919 				(void) dup(rpvect[1]);
920 				(void) close(rpvect[1]);
921 			}
922 			else if (OpMode == MD_SMTP || HoldErrs)
923 			{
924 				/* put mailer output in transcript */
925 				(void) close(1);
926 				(void) dup(fileno(e->e_xfp));
927 			}
928 			(void) close(2);
929 			(void) dup(1);
930 
931 			/* arrange to get standard input */
932 			(void) close(mpvect[1]);
933 			(void) close(0);
934 			if (dup(mpvect[0]) < 0)
935 			{
936 				syserr("Cannot dup to zero!");
937 				_exit(EX_OSERR);
938 			}
939 			(void) close(mpvect[0]);
940 			if (!bitnset(M_RESTR, m->m_flags))
941 			{
942 				if (ctladdr == NULL || ctladdr->q_uid == 0)
943 				{
944 					(void) setgid(DefGid);
945 					(void) initgroups(DefUser, DefGid);
946 					(void) setuid(DefUid);
947 				}
948 				else
949 				{
950 					(void) setgid(ctladdr->q_gid);
951 					(void) initgroups(ctladdr->q_ruser?
952 						ctladdr->q_ruser: ctladdr->q_user,
953 						ctladdr->q_gid);
954 					(void) setuid(ctladdr->q_uid);
955 				}
956 			}
957 
958 			/* arrange for all the files to be closed */
959 			for (i = 3; i < DtableSize; i++)
960 			{
961 				register int j;
962 				if ((j = fcntl(i, F_GETFD, 0)) != -1)
963 					(void)fcntl(i, F_SETFD, j|1);
964 			}
965 
966 			/* try to execute the mailer */
967 			env[0] = "AGENT=sendmail";
968 			env[1] = NULL;
969 			execve(m->m_mailer, pvp, env);
970 			saveerrno = errno;
971 			syserr("Cannot exec %s", m->m_mailer);
972 			if (m == LocalMailer)
973 				_exit(EX_TEMPFAIL);
974 			if (transienterror(saveerrno))
975 				_exit(EX_TEMPFAIL);
976 			_exit(EX_UNAVAILABLE);
977 		}
978 
979 		/*
980 		**  Set up return value.
981 		*/
982 
983 		mci = (MCI *) xalloc(sizeof *mci);
984 		bzero((char *) mci, sizeof *mci);
985 		mci->mci_mailer = m;
986 		mci->mci_state = clever ? MCIS_OPENING : MCIS_OPEN;
987 		mci->mci_pid = pid;
988 		(void) close(mpvect[0]);
989 		mci->mci_out = fdopen(mpvect[1], "w");
990 		if (clever)
991 		{
992 			(void) close(rpvect[1]);
993 			mci->mci_in = fdopen(rpvect[0], "r");
994 		}
995 		else
996 		{
997 			mci->mci_flags |= MCIF_TEMP;
998 			mci->mci_in = NULL;
999 		}
1000 	}
1001 
1002 	/*
1003 	**  If we are in SMTP opening state, send initial protocol.
1004 	*/
1005 
1006 	if (clever && mci->mci_state != MCIS_CLOSED)
1007 	{
1008 		smtpinit(m, mci, e);
1009 	}
1010 	if (tTd(11, 1))
1011 	{
1012 		printf("openmailer: ");
1013 		mci_dump(mci);
1014 	}
1015 
1016 	return mci;
1017 }
1018 /*
1019 **  GIVERESPONSE -- Interpret an error response from a mailer
1020 **
1021 **	Parameters:
1022 **		stat -- the status code from the mailer (high byte
1023 **			only; core dumps must have been taken care of
1024 **			already).
1025 **		m -- the mailer info for this mailer.
1026 **		mci -- the mailer connection info -- can be NULL if the
1027 **			response is given before the connection is made.
1028 **		e -- the current envelope.
1029 **
1030 **	Returns:
1031 **		none.
1032 **
1033 **	Side Effects:
1034 **		Errors may be incremented.
1035 **		ExitStat may be set.
1036 */
1037 
1038 giveresponse(stat, m, mci, e)
1039 	int stat;
1040 	register MAILER *m;
1041 	register MCI *mci;
1042 	ENVELOPE *e;
1043 {
1044 	register char *statmsg;
1045 	extern char *SysExMsg[];
1046 	register int i;
1047 	extern int N_SysEx;
1048 #ifdef NAMED_BIND
1049 	extern int h_errno;
1050 #endif
1051 	char buf[MAXLINE];
1052 
1053 	/*
1054 	**  Compute status message from code.
1055 	*/
1056 
1057 	i = stat - EX__BASE;
1058 	if (stat == 0)
1059 		statmsg = "250 Sent";
1060 	else if (i < 0 || i > N_SysEx)
1061 	{
1062 		(void) sprintf(buf, "554 unknown mailer error %d", stat);
1063 		stat = EX_UNAVAILABLE;
1064 		statmsg = buf;
1065 	}
1066 	else if (stat == EX_TEMPFAIL)
1067 	{
1068 		(void) strcpy(buf, SysExMsg[i]);
1069 #ifdef NAMED_BIND
1070 		if (h_errno == TRY_AGAIN)
1071 		{
1072 			extern char *errstring();
1073 
1074 			statmsg = errstring(h_errno+MAX_ERRNO);
1075 		}
1076 		else
1077 #endif
1078 		{
1079 			if (errno != 0)
1080 			{
1081 				extern char *errstring();
1082 
1083 				statmsg = errstring(errno);
1084 			}
1085 			else
1086 			{
1087 #ifdef SMTP
1088 				extern char SmtpError[];
1089 
1090 				statmsg = SmtpError;
1091 #else /* SMTP */
1092 				statmsg = NULL;
1093 #endif /* SMTP */
1094 			}
1095 		}
1096 		if (statmsg != NULL && statmsg[0] != '\0')
1097 		{
1098 			(void) strcat(buf, ": ");
1099 			(void) strcat(buf, statmsg);
1100 		}
1101 		statmsg = buf;
1102 	}
1103 	else
1104 	{
1105 		statmsg = SysExMsg[i];
1106 	}
1107 
1108 	/*
1109 	**  Print the message as appropriate
1110 	*/
1111 
1112 	if (stat == EX_OK || stat == EX_TEMPFAIL)
1113 		message(&statmsg[4], errstring(errno));
1114 	else
1115 	{
1116 		Errors++;
1117 		usrerr(statmsg, errstring(errno));
1118 	}
1119 
1120 	/*
1121 	**  Final cleanup.
1122 	**	Log a record of the transaction.  Compute the new
1123 	**	ExitStat -- if we already had an error, stick with
1124 	**	that.
1125 	*/
1126 
1127 	if (LogLevel > ((stat == EX_TEMPFAIL) ? 8 : (stat == EX_OK) ? 7 : 6))
1128 		logdelivery(m, mci, &statmsg[4], e);
1129 
1130 	if (stat != EX_TEMPFAIL)
1131 		setstat(stat);
1132 	if (stat != EX_OK)
1133 	{
1134 		if (e->e_message != NULL)
1135 			free(e->e_message);
1136 		e->e_message = newstr(&statmsg[4]);
1137 	}
1138 	errno = 0;
1139 #ifdef NAMED_BIND
1140 	h_errno = 0;
1141 #endif
1142 }
1143 /*
1144 **  LOGDELIVERY -- log the delivery in the system log
1145 **
1146 **	Parameters:
1147 **		m -- the mailer info.  Can be NULL for initial queue.
1148 **		mci -- the mailer connection info -- can be NULL if the
1149 **			log is occuring when no connection is active.
1150 **		stat -- the message to print for the status.
1151 **		e -- the current envelope.
1152 **
1153 **	Returns:
1154 **		none
1155 **
1156 **	Side Effects:
1157 **		none
1158 */
1159 
1160 logdelivery(m, mci, stat, e)
1161 	MAILER *m;
1162 	register MCI *mci;
1163 	char *stat;
1164 	register ENVELOPE *e;
1165 {
1166 # ifdef LOG
1167 	char *curhost;
1168 	char buf[512];
1169 	extern char *pintvl();
1170 	extern char *macvalue();
1171 
1172 	(void) sprintf(buf, "delay=%s", pintvl(curtime() - e->e_ctime, TRUE));
1173 
1174 	if (m != NULL)
1175 	{
1176 		(void) strcat(buf, ", mailer=");
1177 		(void) strcat(buf, m->m_name);
1178 	}
1179 
1180 	if (mci != NULL && mci->mci_host != NULL)
1181 	{
1182 # ifdef DAEMON
1183 		extern struct sockaddr_in CurHostAddr;
1184 		extern char *inet_ntoa();
1185 # endif
1186 
1187 		(void) strcat(buf, ", relay=");
1188 		(void) strcat(buf, mci->mci_host);
1189 
1190 # ifdef DAEMON
1191 		(void) strcat(buf, " (");
1192 		(void) strcat(buf, inet_ntoa(CurHostAddr.sin_addr));
1193 		(void) strcat(buf, ")");
1194 # endif
1195 	}
1196 	else
1197 	{
1198 		char *p = macvalue('h', e);
1199 
1200 		if (p != NULL && p[0] != '\0')
1201 		{
1202 			(void) strcat(buf, ", relay=");
1203 			(void) strcat(buf, p);
1204 		}
1205 	}
1206 
1207 	syslog(LOG_INFO, "%s: to=%s, %s, stat=%s",
1208 	       e->e_id, e->e_to, buf, stat);
1209 # endif /* LOG */
1210 }
1211 /*
1212 **  PUTFROMLINE -- output a UNIX-style from line (or whatever)
1213 **
1214 **	This can be made an arbitrary message separator by changing $l
1215 **
1216 **	One of the ugliest hacks seen by human eyes is contained herein:
1217 **	UUCP wants those stupid "remote from <host>" lines.  Why oh why
1218 **	does a well-meaning programmer such as myself have to deal with
1219 **	this kind of antique garbage????
1220 **
1221 **	Parameters:
1222 **		fp -- the file to output to.
1223 **		m -- the mailer describing this entry.
1224 **
1225 **	Returns:
1226 **		none
1227 **
1228 **	Side Effects:
1229 **		outputs some text to fp.
1230 */
1231 
1232 putfromline(fp, m, e)
1233 	register FILE *fp;
1234 	register MAILER *m;
1235 	ENVELOPE *e;
1236 {
1237 	char *template = "\201l\n";
1238 	char buf[MAXLINE];
1239 
1240 	if (bitnset(M_NHDR, m->m_flags))
1241 		return;
1242 
1243 # ifdef UGLYUUCP
1244 	if (bitnset(M_UGLYUUCP, m->m_flags))
1245 	{
1246 		char *bang;
1247 		char xbuf[MAXLINE];
1248 
1249 		expand("\201<", buf, &buf[sizeof buf - 1], e);
1250 		bang = strchr(buf, '!');
1251 		if (bang == NULL)
1252 			syserr("554 No ! in UUCP! (%s)", buf);
1253 		else
1254 		{
1255 			*bang++ = '\0';
1256 			(void) sprintf(xbuf, "From %s  \201d remote from %s\n", bang, buf);
1257 			template = xbuf;
1258 		}
1259 	}
1260 # endif /* UGLYUUCP */
1261 	expand(template, buf, &buf[sizeof buf - 1], e);
1262 	putline(buf, fp, m);
1263 }
1264 /*
1265 **  PUTBODY -- put the body of a message.
1266 **
1267 **	Parameters:
1268 **		fp -- file to output onto.
1269 **		m -- a mailer descriptor to control output format.
1270 **		e -- the envelope to put out.
1271 **
1272 **	Returns:
1273 **		none.
1274 **
1275 **	Side Effects:
1276 **		The message is written onto fp.
1277 */
1278 
1279 putbody(fp, m, e)
1280 	FILE *fp;
1281 	MAILER *m;
1282 	register ENVELOPE *e;
1283 {
1284 	char buf[MAXLINE];
1285 
1286 	/*
1287 	**  Output the body of the message
1288 	*/
1289 
1290 	if (e->e_dfp == NULL)
1291 	{
1292 		if (e->e_df != NULL)
1293 		{
1294 			e->e_dfp = fopen(e->e_df, "r");
1295 			if (e->e_dfp == NULL)
1296 				syserr("putbody: Cannot open %s for %s from %s",
1297 				e->e_df, e->e_to, e->e_from);
1298 		}
1299 		else
1300 			putline("<<< No Message Collected >>>", fp, m);
1301 	}
1302 	if (e->e_dfp != NULL)
1303 	{
1304 		rewind(e->e_dfp);
1305 		while (!ferror(fp) && fgets(buf, sizeof buf, e->e_dfp) != NULL)
1306 		{
1307 			if (buf[0] == 'F' && bitnset(M_ESCFROM, m->m_flags) &&
1308 			    strncmp(buf, "From ", 5) == 0)
1309 				(void) putc('>', fp);
1310 			putline(buf, fp, m);
1311 		}
1312 
1313 		if (ferror(e->e_dfp))
1314 		{
1315 			syserr("putbody: read error");
1316 			ExitStat = EX_IOERR;
1317 		}
1318 	}
1319 
1320 	(void) fflush(fp);
1321 	if (ferror(fp) && errno != EPIPE)
1322 	{
1323 		syserr("putbody: write error");
1324 		ExitStat = EX_IOERR;
1325 	}
1326 	errno = 0;
1327 }
1328 /*
1329 **  PARENTBODY -- put the body of the parent of a message.
1330 **
1331 **	Parameters:
1332 **		fp -- file to output onto.
1333 **		m -- a mailer descriptor to control output format.
1334 **		e -- the envelope whose parent to put out.
1335 **
1336 **	Returns:
1337 **		none.
1338 **
1339 **	Side Effects:
1340 **		The message is written onto fp.
1341 */
1342 
1343 parentbody(fp, m, e)
1344 	FILE *fp;
1345 	MAILER *m;
1346 	register ENVELOPE *e;
1347 {
1348 	putbody(fp, m, e->e_parent);
1349 }
1350 /*
1351 **  MAILFILE -- Send a message to a file.
1352 **
1353 **	If the file has the setuid/setgid bits set, but NO execute
1354 **	bits, sendmail will try to become the owner of that file
1355 **	rather than the real user.  Obviously, this only works if
1356 **	sendmail runs as root.
1357 **
1358 **	This could be done as a subordinate mailer, except that it
1359 **	is used implicitly to save messages in ~/dead.letter.  We
1360 **	view this as being sufficiently important as to include it
1361 **	here.  For example, if the system is dying, we shouldn't have
1362 **	to create another process plus some pipes to save the message.
1363 **
1364 **	Parameters:
1365 **		filename -- the name of the file to send to.
1366 **		ctladdr -- the controlling address header -- includes
1367 **			the userid/groupid to be when sending.
1368 **
1369 **	Returns:
1370 **		The exit code associated with the operation.
1371 **
1372 **	Side Effects:
1373 **		none.
1374 */
1375 
1376 mailfile(filename, ctladdr, e)
1377 	char *filename;
1378 	ADDRESS *ctladdr;
1379 	register ENVELOPE *e;
1380 {
1381 	register FILE *f;
1382 	register int pid;
1383 	int mode;
1384 
1385 	/*
1386 	**  Fork so we can change permissions here.
1387 	**	Note that we MUST use fork, not vfork, because of
1388 	**	the complications of calling subroutines, etc.
1389 	*/
1390 
1391 	DOFORK(fork);
1392 
1393 	if (pid < 0)
1394 		return (EX_OSERR);
1395 	else if (pid == 0)
1396 	{
1397 		/* child -- actually write to file */
1398 		struct stat stb;
1399 
1400 		(void) signal(SIGINT, SIG_DFL);
1401 		(void) signal(SIGHUP, SIG_DFL);
1402 		(void) signal(SIGTERM, SIG_DFL);
1403 		(void) umask(OldUmask);
1404 
1405 		if (stat(filename, &stb) < 0)
1406 			stb.st_mode = 0666;
1407 		mode = stb.st_mode;
1408 
1409 		/* limit the errors to those actually caused in the child */
1410 		errno = 0;
1411 		ExitStat = EX_OK;
1412 
1413 		if (bitset(0111, stb.st_mode))
1414 			exit(EX_CANTCREAT);
1415 		if (ctladdr == NULL)
1416 			ctladdr = &e->e_from;
1417 		else
1418 		{
1419 			/* ignore setuid and setgid bits */
1420 			mode &= ~(S_ISGID|S_ISUID);
1421 		}
1422 
1423 		/* we have to open the dfile BEFORE setuid */
1424 		if (e->e_dfp == NULL && e->e_df != NULL)
1425 		{
1426 			e->e_dfp = fopen(e->e_df, "r");
1427 			if (e->e_dfp == NULL)
1428 			{
1429 				syserr("mailfile: Cannot open %s for %s from %s",
1430 					e->e_df, e->e_to, e->e_from);
1431 			}
1432 		}
1433 
1434 		if (!bitset(S_ISGID, mode) || setgid(stb.st_gid) < 0)
1435 		{
1436 			if (ctladdr->q_uid == 0)
1437 			{
1438 				(void) setgid(DefGid);
1439 				(void) initgroups(DefUser, DefGid);
1440 			}
1441 			else
1442 			{
1443 				(void) setgid(ctladdr->q_gid);
1444 				(void) initgroups(ctladdr->q_ruser ?
1445 					ctladdr->q_ruser : ctladdr->q_user,
1446 					ctladdr->q_gid);
1447 			}
1448 		}
1449 		if (!bitset(S_ISUID, mode) || setuid(stb.st_uid) < 0)
1450 		{
1451 			if (ctladdr->q_uid == 0)
1452 				(void) setuid(DefUid);
1453 			else
1454 				(void) setuid(ctladdr->q_uid);
1455 		}
1456 		FileName = filename;
1457 		LineNumber = 0;
1458 		f = dfopen(filename, "a");
1459 		if (f == NULL)
1460 		{
1461 			message("554 cannot open");
1462 			exit(EX_CANTCREAT);
1463 		}
1464 
1465 		putfromline(f, ProgMailer, e);
1466 		(*e->e_puthdr)(f, ProgMailer, e);
1467 		putline("\n", f, ProgMailer);
1468 		(*e->e_putbody)(f, ProgMailer, e);
1469 		putline("\n", f, ProgMailer);
1470 		if (ferror(f))
1471 		{
1472 			message("451 I/O error");
1473 			setstat(EX_IOERR);
1474 		}
1475 		(void) fclose(f);
1476 		(void) fflush(stdout);
1477 
1478 		/* reset ISUID & ISGID bits for paranoid systems */
1479 		(void) chmod(filename, (int) stb.st_mode);
1480 		exit(ExitStat);
1481 		/*NOTREACHED*/
1482 	}
1483 	else
1484 	{
1485 		/* parent -- wait for exit status */
1486 		int st;
1487 
1488 		st = waitfor(pid);
1489 		if ((st & 0377) != 0)
1490 			return (EX_UNAVAILABLE);
1491 		else
1492 			return ((st >> 8) & 0377);
1493 		/*NOTREACHED*/
1494 	}
1495 }
1496 /*
1497 **  SENDALL -- actually send all the messages.
1498 **
1499 **	Parameters:
1500 **		e -- the envelope to send.
1501 **		mode -- the delivery mode to use.  If SM_DEFAULT, use
1502 **			the current SendMode.
1503 **
1504 **	Returns:
1505 **		none.
1506 **
1507 **	Side Effects:
1508 **		Scans the send lists and sends everything it finds.
1509 **		Delivers any appropriate error messages.
1510 **		If we are running in a non-interactive mode, takes the
1511 **			appropriate action.
1512 */
1513 
1514 sendall(e, mode)
1515 	ENVELOPE *e;
1516 	char mode;
1517 {
1518 	register ADDRESS *q;
1519 	bool oldverbose;
1520 	int pid;
1521 	char *owner;
1522 	int otherowners;
1523 	ENVELOPE *splitenv = NULL;
1524 # ifdef LOCKF
1525 	struct flock lfd;
1526 # endif
1527 
1528 	/* determine actual delivery mode */
1529 	if (mode == SM_DEFAULT)
1530 	{
1531 		extern bool shouldqueue();
1532 
1533 		mode = SendMode;
1534 		if (mode != SM_VERIFY &&
1535 		    shouldqueue(e->e_msgpriority, e->e_ctime))
1536 			mode = SM_QUEUE;
1537 	}
1538 
1539 	if (tTd(13, 1))
1540 	{
1541 		printf("\nSENDALL: mode %c, sendqueue:\n", mode);
1542 		printaddr(e->e_sendqueue, TRUE);
1543 	}
1544 
1545 	/*
1546 	**  Do any preprocessing necessary for the mode we are running.
1547 	**	Check to make sure the hop count is reasonable.
1548 	**	Delete sends to the sender in mailing lists.
1549 	*/
1550 
1551 	CurEnv = e;
1552 
1553 	if (e->e_hopcount > MaxHopCount)
1554 	{
1555 		errno = 0;
1556 		syserr("554 too many hops %d (%d max): from %s, to %s",
1557 			e->e_hopcount, MaxHopCount, e->e_from.q_paddr,
1558 			e->e_sendqueue->q_paddr);
1559 		return;
1560 	}
1561 
1562 	if (!MeToo)
1563 	{
1564 		extern ADDRESS *recipient();
1565 
1566 		e->e_from.q_flags |= QDONTSEND;
1567 		if (tTd(13, 5))
1568 		{
1569 			printf("sendall: QDONTSEND ");
1570 			printaddr(&e->e_from, FALSE);
1571 		}
1572 		(void) recipient(&e->e_from, &e->e_sendqueue, e);
1573 	}
1574 
1575 	/*
1576 	**  Handle alias owners.
1577 	**
1578 	**	We scan up the q_alias chain looking for owners.
1579 	**	We discard owners that are the same as the return path.
1580 	*/
1581 
1582 	for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1583 	{
1584 		register struct address *a;
1585 
1586 		for (a = q; a != NULL && a->q_owner == NULL; a = a->q_alias)
1587 			continue;
1588 		if (a != NULL)
1589 			q->q_owner = a->q_owner;
1590 
1591 		if (q->q_owner != NULL && !bitset(QDONTSEND, q->q_flags) &&
1592 		    strcmp(q->q_owner, e->e_returnpath) == 0)
1593 			q->q_owner = NULL;
1594 	}
1595 
1596 	owner = "";
1597 	otherowners = 1;
1598 	while (owner != NULL && otherowners > 0)
1599 	{
1600 		owner = NULL;
1601 		otherowners = 0;
1602 
1603 		for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1604 		{
1605 			if (bitset(QDONTSEND, q->q_flags))
1606 				continue;
1607 
1608 			if (q->q_owner != NULL)
1609 			{
1610 				if (owner == NULL)
1611 					owner = q->q_owner;
1612 				else if (owner != q->q_owner)
1613 				{
1614 					if (strcmp(owner, q->q_owner) == 0)
1615 					{
1616 						/* make future comparisons cheap */
1617 						q->q_owner = owner;
1618 					}
1619 					else
1620 					{
1621 						otherowners++;
1622 					}
1623 					owner = q->q_owner;
1624 				}
1625 			}
1626 			else
1627 			{
1628 				otherowners++;
1629 			}
1630 		}
1631 
1632 		if (owner != NULL && otherowners > 0)
1633 		{
1634 			register ENVELOPE *ee;
1635 			extern HDR *copyheader();
1636 			extern ADDRESS *copyqueue();
1637 
1638 			ee = (ENVELOPE *) xalloc(sizeof(ENVELOPE));
1639 			STRUCTCOPY(*e, *ee);
1640 			ee->e_id = NULL;
1641 			ee->e_parent = e;
1642 			ee->e_header = copyheader(e->e_header);
1643 			ee->e_sendqueue = copyqueue(e->e_sendqueue);
1644 			ee->e_errorqueue = copyqueue(e->e_errorqueue);
1645 			ee->e_flags = e->e_flags & ~(EF_INQUEUE|EF_CLRQUEUE);
1646 			ee->e_returnpath = owner;
1647 			ee->e_putbody = parentbody;
1648 			ee->e_sibling = splitenv;
1649 			splitenv = ee;
1650 
1651 			for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1652 				if (q->q_owner == owner)
1653 					q->q_flags |= QDONTSEND;
1654 			for (q = ee->e_sendqueue; q != NULL; q = q->q_next)
1655 				if (q->q_owner != owner)
1656 					q->q_flags |= QDONTSEND;
1657 
1658 			if (e->e_df != NULL && mode != SM_VERIFY)
1659 			{
1660 				ee->e_dfp = NULL;
1661 				ee->e_df = newstr(queuename(ee, 'd'));
1662 				if (link(e->e_df, ee->e_df) < 0)
1663 				{
1664 					syserr("sendall: link(%s, %s)",
1665 						e->e_df, ee->e_df);
1666 				}
1667 			}
1668 		}
1669 	}
1670 
1671 	if (owner != NULL)
1672 		e->e_returnpath = owner;
1673 
1674 # ifdef QUEUE
1675 	if ((mode == SM_QUEUE || mode == SM_FORK ||
1676 	     (mode != SM_VERIFY && SuperSafe)) &&
1677 	    !bitset(EF_INQUEUE, e->e_flags))
1678 		queueup(e, TRUE, mode == SM_QUEUE);
1679 #endif /* QUEUE */
1680 
1681 	if (splitenv != NULL)
1682 	{
1683 		if (tTd(13, 1))
1684 		{
1685 			printf("\nsendall: Split queue; remaining queue:\n");
1686 			printaddr(e->e_sendqueue, TRUE);
1687 		}
1688 
1689 		while (splitenv != NULL)
1690 		{
1691 			sendall(splitenv, mode);
1692 			splitenv = splitenv->e_sibling;
1693 		}
1694 
1695 		CurEnv = e;
1696 	}
1697 
1698 	oldverbose = Verbose;
1699 	switch (mode)
1700 	{
1701 	  case SM_VERIFY:
1702 		Verbose = TRUE;
1703 		break;
1704 
1705 	  case SM_QUEUE:
1706   queueonly:
1707 		e->e_flags |= EF_INQUEUE|EF_KEEPQUEUE;
1708 		return;
1709 
1710 	  case SM_FORK:
1711 		if (e->e_xfp != NULL)
1712 			(void) fflush(e->e_xfp);
1713 
1714 # ifdef LOCKF
1715 		/*
1716 		**  Since lockf has the interesting semantic that the
1717 		**  lock is lost when we fork, we have to risk losing
1718 		**  the lock here by closing before the fork, and then
1719 		**  trying to get it back in the child.
1720 		*/
1721 
1722 		if (e->e_lockfp != NULL)
1723 		{
1724 			(void) fclose(e->e_lockfp);
1725 			e->e_lockfp = NULL;
1726 		}
1727 # endif /* LOCKF */
1728 
1729 		pid = fork();
1730 		if (pid < 0)
1731 		{
1732 			goto queueonly;
1733 		}
1734 		else if (pid > 0)
1735 		{
1736 			/* be sure we leave the temp files to our child */
1737 			e->e_id = e->e_df = NULL;
1738 # ifndef LOCKF
1739 			if (e->e_lockfp != NULL)
1740 			{
1741 				(void) fclose(e->e_lockfp);
1742 				e->e_lockfp = NULL;
1743 			}
1744 # endif
1745 
1746 			/* close any random open files in the envelope */
1747 			if (e->e_dfp != NULL)
1748 			{
1749 				(void) fclose(e->e_dfp);
1750 				e->e_dfp = NULL;
1751 			}
1752 			if (e->e_xfp != NULL)
1753 			{
1754 				(void) fclose(e->e_xfp);
1755 				e->e_xfp = NULL;
1756 			}
1757 			return;
1758 		}
1759 
1760 		/* double fork to avoid zombies */
1761 		if (fork() > 0)
1762 			exit(EX_OK);
1763 
1764 		/* be sure we are immune from the terminal */
1765 		disconnect(FALSE);
1766 
1767 # ifdef LOCKF
1768 		/*
1769 		**  Now try to get our lock back.
1770 		*/
1771 
1772 		lfd.l_type = F_WRLCK;
1773 		lfd.l_whence = lfd.l_start = lfd.l_len = 0;
1774 		e->e_lockfp = fopen(queuename(e, 'q'), "r+");
1775 		if (e->e_lockfp == NULL ||
1776 		    fcntl(fileno(e->e_lockfp), F_SETLK, &lfd) < 0)
1777 		{
1778 			/* oops....  lost it */
1779 # ifdef LOG
1780 			if (LogLevel > 29)
1781 				syslog(LOG_NOTICE, "%s: lost lock: %m",
1782 					e->e_id);
1783 # endif /* LOG */
1784 			exit(EX_OK);
1785 		}
1786 # endif /* LOCKF */
1787 
1788 		/*
1789 		**  Close any cached connections.
1790 		**
1791 		**	We don't send the QUIT protocol because the parent
1792 		**	still knows about the connection.
1793 		**
1794 		**	This should only happen when delivering an error
1795 		**	message.
1796 		*/
1797 
1798 		mci_flush(FALSE, NULL);
1799 
1800 		break;
1801 	}
1802 
1803 	/*
1804 	**  Run through the list and send everything.
1805 	*/
1806 
1807 	e->e_nsent = 0;
1808 	for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1809 	{
1810 		if (mode == SM_VERIFY)
1811 		{
1812 			e->e_to = q->q_paddr;
1813 			if (!bitset(QDONTSEND|QBADADDR, q->q_flags))
1814 				message("deliverable");
1815 		}
1816 		else if (!bitset(QDONTSEND, q->q_flags))
1817 		{
1818 # ifdef QUEUE
1819 			/*
1820 			**  Checkpoint the send list every few addresses
1821 			*/
1822 
1823 			if (e->e_nsent >= CheckpointInterval)
1824 			{
1825 				queueup(e, TRUE, FALSE);
1826 				e->e_nsent = 0;
1827 			}
1828 # endif /* QUEUE */
1829 			(void) deliver(e, q);
1830 		}
1831 	}
1832 	Verbose = oldverbose;
1833 
1834 	/*
1835 	**  Now run through and check for errors.
1836 	*/
1837 
1838 	if (mode == SM_VERIFY)
1839 		return;
1840 
1841 	for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1842 	{
1843 		if (tTd(13, 3))
1844 		{
1845 			printf("Checking ");
1846 			printaddr(q, FALSE);
1847 		}
1848 
1849 		/* only send errors if the message failed */
1850 		if (!bitset(QBADADDR, q->q_flags))
1851 			continue;
1852 
1853 		if (q->q_owner == NULL && strcmp(e->e_from.q_paddr, "<>") != 0)
1854 			(void) sendtolist(e->e_from.q_paddr, NULL,
1855 					  &e->e_errorqueue, e);
1856 	}
1857 
1858 	if (mode == SM_FORK)
1859 		finis();
1860 }
1861 /*
1862 **  HOSTSIGNATURE -- return the "signature" for a host.
1863 **
1864 **	The signature describes how we are going to send this -- it
1865 **	can be just the hostname (for non-Internet hosts) or can be
1866 **	an ordered list of MX hosts.
1867 **
1868 **	Parameters:
1869 **		m -- the mailer describing this host.
1870 **		host -- the host name.
1871 **		e -- the current envelope.
1872 **
1873 **	Returns:
1874 **		The signature for this host.
1875 **
1876 **	Side Effects:
1877 **		Can tweak the symbol table.
1878 */
1879 
1880 char *
1881 hostsignature(m, host, e)
1882 	register MAILER *m;
1883 	char *host;
1884 	ENVELOPE *e;
1885 {
1886 	register char *p;
1887 	register STAB *s;
1888 	int i;
1889 	int len;
1890 #ifdef NAMED_BIND
1891 	int nmx;
1892 	auto int rcode;
1893 	char *mxhosts[MAXMXHOSTS + 1];
1894 	static char myhostbuf[MAXNAME];
1895 #endif
1896 
1897 	/*
1898 	**  Check to see if this uses IPC -- if not, it can't have MX records.
1899 	*/
1900 
1901 	p = m->m_mailer;
1902 	if (strcmp(p, "[IPC]") != 0 && strcmp(p, "[TCP]") != 0)
1903 	{
1904 		/* just an ordinary mailer */
1905 		return host;
1906 	}
1907 
1908 	/*
1909 	**  If it is a numeric address, just return it.
1910 	*/
1911 
1912 	if (host[0] == '[')
1913 		return host;
1914 
1915 	/*
1916 	**  Look it up in the symbol table.
1917 	*/
1918 
1919 	s = stab(host, ST_HOSTSIG, ST_ENTER);
1920 	if (s->s_hostsig != NULL)
1921 		return s->s_hostsig;
1922 
1923 	/*
1924 	**  Not already there -- create a signature.
1925 	*/
1926 
1927 #ifdef NAMED_BIND
1928 	if (myhostbuf[0] == '\0')
1929 		expand("\201j", myhostbuf, &myhostbuf[sizeof myhostbuf - 1], e);
1930 
1931 	nmx = getmxrr(host, mxhosts, myhostbuf, &rcode);
1932 	if (nmx <= 0)
1933 	{
1934 		register MCI *mci;
1935 		extern int errno;
1936 		extern MCI *mci_get();
1937 
1938 		/* update the connection info for this host */
1939 		mci = mci_get(host, m);
1940 		mci->mci_exitstat = rcode;
1941 		mci->mci_errno = errno;
1942 
1943 		/* and return the original host name as the signature */
1944 		s->s_hostsig = host;
1945 		return host;
1946 	}
1947 
1948 	len = 0;
1949 	for (i = 0; i < nmx; i++)
1950 	{
1951 		len += strlen(mxhosts[i]) + 1;
1952 	}
1953 	s->s_hostsig = p = xalloc(len);
1954 	for (i = 0; i < nmx; i++)
1955 	{
1956 		if (i != 0)
1957 			*p++ = ':';
1958 		strcpy(p, mxhosts[i]);
1959 		p += strlen(p);
1960 	}
1961 	makelower(s->s_hostsig);
1962 #else
1963 	/* not using BIND -- the signature is just the host name */
1964 	s->s_hostsig = host;
1965 #endif
1966 	if (tTd(17, 1))
1967 		printf("hostsignature(%s) = %s\n", host, s->s_hostsig);
1968 	return s->s_hostsig;
1969 }
1970