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.37 (Berkeley) 03/06/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 			switch (saveerrno)
975 			{
976 			  case EIO:
977 			  case EAGAIN:
978 			  case ENOMEM:
979 # ifdef EPROCLIM
980 			  case EPROCLIM:
981 # endif
982 # ifdef ETIMEDOUT
983 			  case ETIMEDOUT:
984 # endif
985 				_exit(EX_TEMPFAIL);
986 			}
987 			_exit(EX_UNAVAILABLE);
988 		}
989 
990 		/*
991 		**  Set up return value.
992 		*/
993 
994 		mci = (MCI *) xalloc(sizeof *mci);
995 		bzero((char *) mci, sizeof *mci);
996 		mci->mci_mailer = m;
997 		mci->mci_state = clever ? MCIS_OPENING : MCIS_OPEN;
998 		mci->mci_pid = pid;
999 		(void) close(mpvect[0]);
1000 		mci->mci_out = fdopen(mpvect[1], "w");
1001 		if (clever)
1002 		{
1003 			(void) close(rpvect[1]);
1004 			mci->mci_in = fdopen(rpvect[0], "r");
1005 		}
1006 		else
1007 		{
1008 			mci->mci_flags |= MCIF_TEMP;
1009 			mci->mci_in = NULL;
1010 		}
1011 	}
1012 
1013 	/*
1014 	**  If we are in SMTP opening state, send initial protocol.
1015 	*/
1016 
1017 	if (clever && mci->mci_state != MCIS_CLOSED)
1018 	{
1019 		smtpinit(m, mci, e);
1020 	}
1021 	if (tTd(11, 1))
1022 	{
1023 		printf("openmailer: ");
1024 		mci_dump(mci);
1025 	}
1026 
1027 	return mci;
1028 }
1029 /*
1030 **  GIVERESPONSE -- Interpret an error response from a mailer
1031 **
1032 **	Parameters:
1033 **		stat -- the status code from the mailer (high byte
1034 **			only; core dumps must have been taken care of
1035 **			already).
1036 **		m -- the mailer info for this mailer.
1037 **		mci -- the mailer connection info -- can be NULL if the
1038 **			response is given before the connection is made.
1039 **		e -- the current envelope.
1040 **
1041 **	Returns:
1042 **		none.
1043 **
1044 **	Side Effects:
1045 **		Errors may be incremented.
1046 **		ExitStat may be set.
1047 */
1048 
1049 giveresponse(stat, m, mci, e)
1050 	int stat;
1051 	register MAILER *m;
1052 	register MCI *mci;
1053 	ENVELOPE *e;
1054 {
1055 	register char *statmsg;
1056 	extern char *SysExMsg[];
1057 	register int i;
1058 	extern int N_SysEx;
1059 #ifdef NAMED_BIND
1060 	extern int h_errno;
1061 #endif
1062 	char buf[MAXLINE];
1063 
1064 	/*
1065 	**  Compute status message from code.
1066 	*/
1067 
1068 	i = stat - EX__BASE;
1069 	if (stat == 0)
1070 		statmsg = "250 Sent";
1071 	else if (i < 0 || i > N_SysEx)
1072 	{
1073 		(void) sprintf(buf, "554 unknown mailer error %d", stat);
1074 		stat = EX_UNAVAILABLE;
1075 		statmsg = buf;
1076 	}
1077 	else if (stat == EX_TEMPFAIL)
1078 	{
1079 		(void) strcpy(buf, SysExMsg[i]);
1080 #ifdef NAMED_BIND
1081 		if (h_errno == TRY_AGAIN)
1082 		{
1083 			extern char *errstring();
1084 
1085 			statmsg = errstring(h_errno+MAX_ERRNO);
1086 		}
1087 		else
1088 #endif
1089 		{
1090 			if (errno != 0)
1091 			{
1092 				extern char *errstring();
1093 
1094 				statmsg = errstring(errno);
1095 			}
1096 			else
1097 			{
1098 #ifdef SMTP
1099 				extern char SmtpError[];
1100 
1101 				statmsg = SmtpError;
1102 #else /* SMTP */
1103 				statmsg = NULL;
1104 #endif /* SMTP */
1105 			}
1106 		}
1107 		if (statmsg != NULL && statmsg[0] != '\0')
1108 		{
1109 			(void) strcat(buf, ": ");
1110 			(void) strcat(buf, statmsg);
1111 		}
1112 		statmsg = buf;
1113 	}
1114 	else
1115 	{
1116 		statmsg = SysExMsg[i];
1117 	}
1118 
1119 	/*
1120 	**  Print the message as appropriate
1121 	*/
1122 
1123 	if (stat == EX_OK || stat == EX_TEMPFAIL)
1124 		message(&statmsg[4]);
1125 	else
1126 	{
1127 		Errors++;
1128 		usrerr(statmsg);
1129 	}
1130 
1131 	/*
1132 	**  Final cleanup.
1133 	**	Log a record of the transaction.  Compute the new
1134 	**	ExitStat -- if we already had an error, stick with
1135 	**	that.
1136 	*/
1137 
1138 	if (LogLevel > ((stat == EX_TEMPFAIL) ? 8 : (stat == EX_OK) ? 7 : 6))
1139 		logdelivery(m, mci, &statmsg[4], e);
1140 
1141 	if (stat != EX_TEMPFAIL)
1142 		setstat(stat);
1143 	if (stat != EX_OK)
1144 	{
1145 		if (e->e_message != NULL)
1146 			free(e->e_message);
1147 		e->e_message = newstr(&statmsg[4]);
1148 	}
1149 	errno = 0;
1150 #ifdef NAMED_BIND
1151 	h_errno = 0;
1152 #endif
1153 }
1154 /*
1155 **  LOGDELIVERY -- log the delivery in the system log
1156 **
1157 **	Parameters:
1158 **		m -- the mailer info.  Can be NULL for initial queue.
1159 **		mci -- the mailer connection info -- can be NULL if the
1160 **			log is occuring when no connection is active.
1161 **		stat -- the message to print for the status.
1162 **		e -- the current envelope.
1163 **
1164 **	Returns:
1165 **		none
1166 **
1167 **	Side Effects:
1168 **		none
1169 */
1170 
1171 logdelivery(m, mci, stat, e)
1172 	MAILER *m;
1173 	register MCI *mci;
1174 	char *stat;
1175 	register ENVELOPE *e;
1176 {
1177 # ifdef LOG
1178 	char *curhost;
1179 	char *mname;
1180 	char *relay;
1181 	char *hostdetail;
1182 	char buf[512];
1183 	extern char *pintvl();
1184 	extern char *macvalue();
1185 
1186 	if (mci != NULL && mci->mci_host != NULL)
1187 		curhost = mci->mci_host;
1188 	else
1189 		curhost = CurHostName;
1190 
1191 	if (curhost == NULL || curhost[0] == '/')
1192 	{
1193 		hostdetail = macvalue('h', e);
1194 		if (hostdetail == NULL || hostdetail[0] == '\0')
1195 			hostdetail = "local";
1196 	}
1197 	else
1198 	{
1199 # ifdef DAEMON
1200 		extern struct sockaddr_in CurHostAddr;
1201 		extern char *inet_ntoa();
1202 
1203 		hostdetail = inet_ntoa(CurHostAddr.sin_addr);
1204 # else
1205 		hostdetail = "?";
1206 # endif
1207 	}
1208 
1209 	if (m != NULL)
1210 		mname = m->m_name;
1211 	else
1212 		mname = "(unknown)";
1213 
1214 	(void) sprintf(buf, "delay=%s, mailer=%s, relay=%s (%s)",
1215 	       pintvl(curtime() - e->e_ctime, TRUE),
1216 	       mname, curhost, hostdetail);
1217 
1218 	syslog(LOG_INFO, "%s: to=%s, %s, stat=%s",
1219 	       e->e_id, e->e_to, buf, stat);
1220 # endif /* LOG */
1221 }
1222 /*
1223 **  PUTFROMLINE -- output a UNIX-style from line (or whatever)
1224 **
1225 **	This can be made an arbitrary message separator by changing $l
1226 **
1227 **	One of the ugliest hacks seen by human eyes is contained herein:
1228 **	UUCP wants those stupid "remote from <host>" lines.  Why oh why
1229 **	does a well-meaning programmer such as myself have to deal with
1230 **	this kind of antique garbage????
1231 **
1232 **	Parameters:
1233 **		fp -- the file to output to.
1234 **		m -- the mailer describing this entry.
1235 **
1236 **	Returns:
1237 **		none
1238 **
1239 **	Side Effects:
1240 **		outputs some text to fp.
1241 */
1242 
1243 putfromline(fp, m, e)
1244 	register FILE *fp;
1245 	register MAILER *m;
1246 	ENVELOPE *e;
1247 {
1248 	char *template = "\201l\n";
1249 	char buf[MAXLINE];
1250 
1251 	if (bitnset(M_NHDR, m->m_flags))
1252 		return;
1253 
1254 # ifdef UGLYUUCP
1255 	if (bitnset(M_UGLYUUCP, m->m_flags))
1256 	{
1257 		char *bang;
1258 		char xbuf[MAXLINE];
1259 
1260 		expand("\201<", buf, &buf[sizeof buf - 1], e);
1261 		bang = strchr(buf, '!');
1262 		if (bang == NULL)
1263 			syserr("554 No ! in UUCP! (%s)", buf);
1264 		else
1265 		{
1266 			*bang++ = '\0';
1267 			(void) sprintf(xbuf, "From %s  \201d remote from %s\n", bang, buf);
1268 			template = xbuf;
1269 		}
1270 	}
1271 # endif /* UGLYUUCP */
1272 	expand(template, buf, &buf[sizeof buf - 1], e);
1273 	putline(buf, fp, m);
1274 }
1275 /*
1276 **  PUTBODY -- put the body of a message.
1277 **
1278 **	Parameters:
1279 **		fp -- file to output onto.
1280 **		m -- a mailer descriptor to control output format.
1281 **		e -- the envelope to put out.
1282 **
1283 **	Returns:
1284 **		none.
1285 **
1286 **	Side Effects:
1287 **		The message is written onto fp.
1288 */
1289 
1290 putbody(fp, m, e)
1291 	FILE *fp;
1292 	MAILER *m;
1293 	register ENVELOPE *e;
1294 {
1295 	char buf[MAXLINE];
1296 
1297 	/*
1298 	**  Output the body of the message
1299 	*/
1300 
1301 	if (e->e_dfp == NULL)
1302 	{
1303 		if (e->e_df != NULL)
1304 		{
1305 			e->e_dfp = fopen(e->e_df, "r");
1306 			if (e->e_dfp == NULL)
1307 				syserr("putbody: Cannot open %s for %s from %s",
1308 				e->e_df, e->e_to, e->e_from);
1309 		}
1310 		else
1311 			putline("<<< No Message Collected >>>", fp, m);
1312 	}
1313 	if (e->e_dfp != NULL)
1314 	{
1315 		rewind(e->e_dfp);
1316 		while (!ferror(fp) && fgets(buf, sizeof buf, e->e_dfp) != NULL)
1317 		{
1318 			if (buf[0] == 'F' && bitnset(M_ESCFROM, m->m_flags) &&
1319 			    strncmp(buf, "From ", 5) == 0)
1320 				(void) putc('>', fp);
1321 			putline(buf, fp, m);
1322 		}
1323 
1324 		if (ferror(e->e_dfp))
1325 		{
1326 			syserr("putbody: read error");
1327 			ExitStat = EX_IOERR;
1328 		}
1329 	}
1330 
1331 	(void) fflush(fp);
1332 	if (ferror(fp) && errno != EPIPE)
1333 	{
1334 		syserr("putbody: write error");
1335 		ExitStat = EX_IOERR;
1336 	}
1337 	errno = 0;
1338 }
1339 /*
1340 **  PARENTBODY -- put the body of the parent of a message.
1341 **
1342 **	Parameters:
1343 **		fp -- file to output onto.
1344 **		m -- a mailer descriptor to control output format.
1345 **		e -- the envelope whose parent to put out.
1346 **
1347 **	Returns:
1348 **		none.
1349 **
1350 **	Side Effects:
1351 **		The message is written onto fp.
1352 */
1353 
1354 parentbody(fp, m, e)
1355 	FILE *fp;
1356 	MAILER *m;
1357 	register ENVELOPE *e;
1358 {
1359 	putbody(fp, m, e->e_parent);
1360 }
1361 /*
1362 **  MAILFILE -- Send a message to a file.
1363 **
1364 **	If the file has the setuid/setgid bits set, but NO execute
1365 **	bits, sendmail will try to become the owner of that file
1366 **	rather than the real user.  Obviously, this only works if
1367 **	sendmail runs as root.
1368 **
1369 **	This could be done as a subordinate mailer, except that it
1370 **	is used implicitly to save messages in ~/dead.letter.  We
1371 **	view this as being sufficiently important as to include it
1372 **	here.  For example, if the system is dying, we shouldn't have
1373 **	to create another process plus some pipes to save the message.
1374 **
1375 **	Parameters:
1376 **		filename -- the name of the file to send to.
1377 **		ctladdr -- the controlling address header -- includes
1378 **			the userid/groupid to be when sending.
1379 **
1380 **	Returns:
1381 **		The exit code associated with the operation.
1382 **
1383 **	Side Effects:
1384 **		none.
1385 */
1386 
1387 mailfile(filename, ctladdr, e)
1388 	char *filename;
1389 	ADDRESS *ctladdr;
1390 	register ENVELOPE *e;
1391 {
1392 	register FILE *f;
1393 	register int pid;
1394 	int mode;
1395 
1396 	/*
1397 	**  Fork so we can change permissions here.
1398 	**	Note that we MUST use fork, not vfork, because of
1399 	**	the complications of calling subroutines, etc.
1400 	*/
1401 
1402 	DOFORK(fork);
1403 
1404 	if (pid < 0)
1405 		return (EX_OSERR);
1406 	else if (pid == 0)
1407 	{
1408 		/* child -- actually write to file */
1409 		struct stat stb;
1410 
1411 		(void) signal(SIGINT, SIG_DFL);
1412 		(void) signal(SIGHUP, SIG_DFL);
1413 		(void) signal(SIGTERM, SIG_DFL);
1414 		(void) umask(OldUmask);
1415 
1416 		if (stat(filename, &stb) < 0)
1417 			stb.st_mode = 0666;
1418 		mode = stb.st_mode;
1419 
1420 		/* limit the errors to those actually caused in the child */
1421 		errno = 0;
1422 		ExitStat = EX_OK;
1423 
1424 		if (bitset(0111, stb.st_mode))
1425 			exit(EX_CANTCREAT);
1426 		if (ctladdr == NULL)
1427 			ctladdr = &e->e_from;
1428 		else
1429 		{
1430 			/* ignore setuid and setgid bits */
1431 			mode &= ~(S_ISGID|S_ISUID);
1432 		}
1433 
1434 		/* we have to open the dfile BEFORE setuid */
1435 		if (e->e_dfp == NULL && e->e_df != NULL)
1436 		{
1437 			e->e_dfp = fopen(e->e_df, "r");
1438 			if (e->e_dfp == NULL)
1439 			{
1440 				syserr("mailfile: Cannot open %s for %s from %s",
1441 					e->e_df, e->e_to, e->e_from);
1442 			}
1443 		}
1444 
1445 		if (!bitset(S_ISGID, mode) || setgid(stb.st_gid) < 0)
1446 		{
1447 			if (ctladdr->q_uid == 0)
1448 			{
1449 				(void) setgid(DefGid);
1450 				(void) initgroups(DefUser, DefGid);
1451 			}
1452 			else
1453 			{
1454 				(void) setgid(ctladdr->q_gid);
1455 				(void) initgroups(ctladdr->q_ruser ?
1456 					ctladdr->q_ruser : ctladdr->q_user,
1457 					ctladdr->q_gid);
1458 			}
1459 		}
1460 		if (!bitset(S_ISUID, mode) || setuid(stb.st_uid) < 0)
1461 		{
1462 			if (ctladdr->q_uid == 0)
1463 				(void) setuid(DefUid);
1464 			else
1465 				(void) setuid(ctladdr->q_uid);
1466 		}
1467 		FileName = filename;
1468 		LineNumber = 0;
1469 		f = dfopen(filename, "a");
1470 		if (f == NULL)
1471 		{
1472 			message("554 cannot open");
1473 			exit(EX_CANTCREAT);
1474 		}
1475 
1476 		putfromline(f, ProgMailer, e);
1477 		(*e->e_puthdr)(f, ProgMailer, e);
1478 		putline("\n", f, ProgMailer);
1479 		(*e->e_putbody)(f, ProgMailer, e);
1480 		putline("\n", f, ProgMailer);
1481 		if (ferror(f))
1482 		{
1483 			message("451 I/O error");
1484 			setstat(EX_IOERR);
1485 		}
1486 		(void) fclose(f);
1487 		(void) fflush(stdout);
1488 
1489 		/* reset ISUID & ISGID bits for paranoid systems */
1490 		(void) chmod(filename, (int) stb.st_mode);
1491 		exit(ExitStat);
1492 		/*NOTREACHED*/
1493 	}
1494 	else
1495 	{
1496 		/* parent -- wait for exit status */
1497 		int st;
1498 
1499 		st = waitfor(pid);
1500 		if ((st & 0377) != 0)
1501 			return (EX_UNAVAILABLE);
1502 		else
1503 			return ((st >> 8) & 0377);
1504 		/*NOTREACHED*/
1505 	}
1506 }
1507 /*
1508 **  SENDALL -- actually send all the messages.
1509 **
1510 **	Parameters:
1511 **		e -- the envelope to send.
1512 **		mode -- the delivery mode to use.  If SM_DEFAULT, use
1513 **			the current SendMode.
1514 **
1515 **	Returns:
1516 **		none.
1517 **
1518 **	Side Effects:
1519 **		Scans the send lists and sends everything it finds.
1520 **		Delivers any appropriate error messages.
1521 **		If we are running in a non-interactive mode, takes the
1522 **			appropriate action.
1523 */
1524 
1525 sendall(e, mode)
1526 	ENVELOPE *e;
1527 	char mode;
1528 {
1529 	register ADDRESS *q;
1530 	bool oldverbose;
1531 	int pid;
1532 	char *owner;
1533 	int otherowners;
1534 	ENVELOPE *splitenv = NULL;
1535 # ifdef LOCKF
1536 	struct flock lfd;
1537 # endif
1538 
1539 	/* determine actual delivery mode */
1540 	if (mode == SM_DEFAULT)
1541 	{
1542 		extern bool shouldqueue();
1543 
1544 		mode = SendMode;
1545 		if (mode != SM_VERIFY &&
1546 		    shouldqueue(e->e_msgpriority, e->e_ctime))
1547 			mode = SM_QUEUE;
1548 	}
1549 
1550 	if (tTd(13, 1))
1551 	{
1552 		printf("\nSENDALL: mode %c, sendqueue:\n", mode);
1553 		printaddr(e->e_sendqueue, TRUE);
1554 	}
1555 
1556 	/*
1557 	**  Do any preprocessing necessary for the mode we are running.
1558 	**	Check to make sure the hop count is reasonable.
1559 	**	Delete sends to the sender in mailing lists.
1560 	*/
1561 
1562 	CurEnv = e;
1563 
1564 	if (e->e_hopcount > MaxHopCount)
1565 	{
1566 		errno = 0;
1567 		syserr("554 too many hops %d (%d max): from %s, to %s",
1568 			e->e_hopcount, MaxHopCount, e->e_from.q_paddr,
1569 			e->e_sendqueue->q_paddr);
1570 		return;
1571 	}
1572 
1573 	if (!MeToo)
1574 	{
1575 		extern ADDRESS *recipient();
1576 
1577 		e->e_from.q_flags |= QDONTSEND;
1578 		if (tTd(13, 5))
1579 		{
1580 			printf("sendall: QDONTSEND ");
1581 			printaddr(&e->e_from, FALSE);
1582 		}
1583 		(void) recipient(&e->e_from, &e->e_sendqueue, e);
1584 	}
1585 
1586 	/*
1587 	**  Handle alias owners.
1588 	**
1589 	**	We scan up the q_alias chain looking for owners.
1590 	**	We discard owners that are the same as the return path.
1591 	*/
1592 
1593 	for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1594 	{
1595 		register struct address *a;
1596 
1597 		for (a = q; a != NULL && a->q_owner == NULL; a = a->q_alias)
1598 			continue;
1599 		if (a != NULL)
1600 			q->q_owner = a->q_owner;
1601 
1602 		if (q->q_owner != NULL && !bitset(QDONTSEND, q->q_flags) &&
1603 		    strcmp(q->q_owner, e->e_returnpath) == 0)
1604 			q->q_owner = NULL;
1605 	}
1606 
1607 	owner = "";
1608 	otherowners = 1;
1609 	while (owner != NULL && otherowners > 0)
1610 	{
1611 		owner = NULL;
1612 		otherowners = 0;
1613 
1614 		for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1615 		{
1616 			if (bitset(QDONTSEND, q->q_flags))
1617 				continue;
1618 
1619 			if (q->q_owner != NULL)
1620 			{
1621 				if (owner == NULL)
1622 					owner = q->q_owner;
1623 				else if (owner != q->q_owner)
1624 				{
1625 					if (strcmp(owner, q->q_owner) == 0)
1626 					{
1627 						/* make future comparisons cheap */
1628 						q->q_owner = owner;
1629 					}
1630 					else
1631 					{
1632 						otherowners++;
1633 					}
1634 					owner = q->q_owner;
1635 				}
1636 			}
1637 			else
1638 			{
1639 				otherowners++;
1640 			}
1641 		}
1642 
1643 		if (owner != NULL && otherowners > 0)
1644 		{
1645 			register ENVELOPE *ee;
1646 			extern HDR *copyheader();
1647 			extern ADDRESS *copyqueue();
1648 
1649 			ee = (ENVELOPE *) xalloc(sizeof(ENVELOPE));
1650 			STRUCTCOPY(*e, *ee);
1651 			ee->e_id = NULL;
1652 			ee->e_parent = e;
1653 			ee->e_header = copyheader(e->e_header);
1654 			ee->e_sendqueue = copyqueue(e->e_sendqueue);
1655 			ee->e_errorqueue = copyqueue(e->e_errorqueue);
1656 			ee->e_flags = e->e_flags & ~(EF_INQUEUE|EF_CLRQUEUE);
1657 			ee->e_returnpath = owner;
1658 			ee->e_putbody = parentbody;
1659 			ee->e_sibling = splitenv;
1660 			splitenv = ee;
1661 
1662 			for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1663 				if (q->q_owner == owner)
1664 					q->q_flags |= QDONTSEND;
1665 			for (q = ee->e_sendqueue; q != NULL; q = q->q_next)
1666 				if (q->q_owner != owner)
1667 					q->q_flags |= QDONTSEND;
1668 
1669 			if (e->e_df != NULL && mode != SM_VERIFY)
1670 			{
1671 				ee->e_dfp = NULL;
1672 				ee->e_df = newstr(queuename(ee, 'd'));
1673 				if (link(e->e_df, ee->e_df) < 0)
1674 				{
1675 					syserr("sendall: link(%s, %s)",
1676 						e->e_df, ee->e_df);
1677 				}
1678 			}
1679 		}
1680 	}
1681 
1682 	if (owner != NULL)
1683 		e->e_returnpath = owner;
1684 
1685 # ifdef QUEUE
1686 	if ((mode == SM_QUEUE || mode == SM_FORK ||
1687 	     (mode != SM_VERIFY && SuperSafe)) &&
1688 	    !bitset(EF_INQUEUE, e->e_flags))
1689 		queueup(e, TRUE, mode == SM_QUEUE);
1690 #endif /* QUEUE */
1691 
1692 	if (splitenv != NULL)
1693 	{
1694 		if (tTd(13, 1))
1695 		{
1696 			printf("\nsendall: Split queue; remaining queue:\n");
1697 			printaddr(e->e_sendqueue, TRUE);
1698 		}
1699 
1700 		while (splitenv != NULL)
1701 		{
1702 			sendall(splitenv, mode);
1703 			splitenv = splitenv->e_sibling;
1704 		}
1705 
1706 		CurEnv = e;
1707 	}
1708 
1709 	oldverbose = Verbose;
1710 	switch (mode)
1711 	{
1712 	  case SM_VERIFY:
1713 		Verbose = TRUE;
1714 		break;
1715 
1716 	  case SM_QUEUE:
1717   queueonly:
1718 		e->e_flags |= EF_INQUEUE|EF_KEEPQUEUE;
1719 		return;
1720 
1721 	  case SM_FORK:
1722 		if (e->e_xfp != NULL)
1723 			(void) fflush(e->e_xfp);
1724 
1725 # ifdef LOCKF
1726 		/*
1727 		**  Since lockf has the interesting semantic that the
1728 		**  lock is lost when we fork, we have to risk losing
1729 		**  the lock here by closing before the fork, and then
1730 		**  trying to get it back in the child.
1731 		*/
1732 
1733 		if (e->e_lockfp != NULL)
1734 		{
1735 			(void) fclose(e->e_lockfp);
1736 			e->e_lockfp = NULL;
1737 		}
1738 # endif /* LOCKF */
1739 
1740 		pid = fork();
1741 		if (pid < 0)
1742 		{
1743 			goto queueonly;
1744 		}
1745 		else if (pid > 0)
1746 		{
1747 			/* be sure we leave the temp files to our child */
1748 			e->e_id = e->e_df = NULL;
1749 # ifndef LOCKF
1750 			if (e->e_lockfp != NULL)
1751 			{
1752 				(void) fclose(e->e_lockfp);
1753 				e->e_lockfp = NULL;
1754 			}
1755 # endif
1756 
1757 			/* close any random open files in the envelope */
1758 			if (e->e_dfp != NULL)
1759 			{
1760 				(void) fclose(e->e_dfp);
1761 				e->e_dfp = NULL;
1762 			}
1763 			if (e->e_xfp != NULL)
1764 			{
1765 				(void) fclose(e->e_xfp);
1766 				e->e_xfp = NULL;
1767 			}
1768 			return;
1769 		}
1770 
1771 		/* double fork to avoid zombies */
1772 		if (fork() > 0)
1773 			exit(EX_OK);
1774 
1775 		/* be sure we are immune from the terminal */
1776 		disconnect(FALSE);
1777 
1778 # ifdef LOCKF
1779 		/*
1780 		**  Now try to get our lock back.
1781 		*/
1782 
1783 		lfd.l_type = F_WRLCK;
1784 		lfd.l_whence = lfd.l_start = lfd.l_len = 0;
1785 		e->e_lockfp = fopen(queuename(e, 'q'), "r+");
1786 		if (e->e_lockfp == NULL ||
1787 		    fcntl(fileno(e->e_lockfp), F_SETLK, &lfd) < 0)
1788 		{
1789 			/* oops....  lost it */
1790 # ifdef LOG
1791 			if (LogLevel > 29)
1792 				syslog(LOG_NOTICE, "%s: lost lock: %m",
1793 					e->e_id);
1794 # endif /* LOG */
1795 			exit(EX_OK);
1796 		}
1797 # endif /* LOCKF */
1798 
1799 		/*
1800 		**  Close any cached connections.
1801 		**
1802 		**	We don't send the QUIT protocol because the parent
1803 		**	still knows about the connection.
1804 		**
1805 		**	This should only happen when delivering an error
1806 		**	message.
1807 		*/
1808 
1809 		mci_flush(FALSE, NULL);
1810 
1811 		break;
1812 	}
1813 
1814 	/*
1815 	**  Run through the list and send everything.
1816 	*/
1817 
1818 	e->e_nsent = 0;
1819 	for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1820 	{
1821 		if (mode == SM_VERIFY)
1822 		{
1823 			e->e_to = q->q_paddr;
1824 			if (!bitset(QDONTSEND|QBADADDR, q->q_flags))
1825 				message("deliverable");
1826 		}
1827 		else if (!bitset(QDONTSEND, q->q_flags))
1828 		{
1829 # ifdef QUEUE
1830 			/*
1831 			**  Checkpoint the send list every few addresses
1832 			*/
1833 
1834 			if (e->e_nsent >= CheckpointInterval)
1835 			{
1836 				queueup(e, TRUE, FALSE);
1837 				e->e_nsent = 0;
1838 			}
1839 # endif /* QUEUE */
1840 			(void) deliver(e, q);
1841 		}
1842 	}
1843 	Verbose = oldverbose;
1844 
1845 	/*
1846 	**  Now run through and check for errors.
1847 	*/
1848 
1849 	if (mode == SM_VERIFY)
1850 		return;
1851 
1852 	for (q = e->e_sendqueue; q != NULL; q = q->q_next)
1853 	{
1854 		if (tTd(13, 3))
1855 		{
1856 			printf("Checking ");
1857 			printaddr(q, FALSE);
1858 		}
1859 
1860 		/* only send errors if the message failed */
1861 		if (!bitset(QBADADDR, q->q_flags))
1862 			continue;
1863 
1864 		if (q->q_owner == NULL && strcmp(e->e_from.q_paddr, "<>") != 0)
1865 			(void) sendtolist(e->e_from.q_paddr, NULL,
1866 					  &e->e_errorqueue, e);
1867 	}
1868 
1869 	if (mode == SM_FORK)
1870 		finis();
1871 }
1872 /*
1873 **  HOSTSIGNATURE -- return the "signature" for a host.
1874 **
1875 **	The signature describes how we are going to send this -- it
1876 **	can be just the hostname (for non-Internet hosts) or can be
1877 **	an ordered list of MX hosts.
1878 **
1879 **	Parameters:
1880 **		m -- the mailer describing this host.
1881 **		host -- the host name.
1882 **		e -- the current envelope.
1883 **
1884 **	Returns:
1885 **		The signature for this host.
1886 **
1887 **	Side Effects:
1888 **		Can tweak the symbol table.
1889 */
1890 
1891 char *
1892 hostsignature(m, host, e)
1893 	register MAILER *m;
1894 	char *host;
1895 	ENVELOPE *e;
1896 {
1897 	register char *p;
1898 	register STAB *s;
1899 	int i;
1900 	int len;
1901 #ifdef NAMED_BIND
1902 	int nmx;
1903 	auto int rcode;
1904 	char *mxhosts[MAXMXHOSTS + 1];
1905 	static char myhostbuf[MAXNAME];
1906 #endif
1907 
1908 	/*
1909 	**  Check to see if this uses IPC -- if not, it can't have MX records.
1910 	*/
1911 
1912 	p = m->m_mailer;
1913 	if (strcmp(p, "[IPC]") != 0 && strcmp(p, "[TCP]") != 0)
1914 	{
1915 		/* just an ordinary mailer */
1916 		return host;
1917 	}
1918 
1919 	/*
1920 	**  If it is a numeric address, just return it.
1921 	*/
1922 
1923 	if (host[0] == '[')
1924 		return host;
1925 
1926 	/*
1927 	**  Look it up in the symbol table.
1928 	*/
1929 
1930 	s = stab(host, ST_HOSTSIG, ST_ENTER);
1931 	if (s->s_hostsig != NULL)
1932 		return s->s_hostsig;
1933 
1934 	/*
1935 	**  Not already there -- create a signature.
1936 	*/
1937 
1938 #ifdef NAMED_BIND
1939 	if (myhostbuf[0] == '\0')
1940 		expand("\201j", myhostbuf, &myhostbuf[sizeof myhostbuf - 1], e);
1941 
1942 	nmx = getmxrr(host, mxhosts, myhostbuf, &rcode);
1943 	if (nmx <= 0)
1944 	{
1945 		register MCI *mci;
1946 		extern int errno;
1947 		extern MCI *mci_get();
1948 
1949 		/* update the connection info for this host */
1950 		mci = mci_get(host, m);
1951 		mci->mci_exitstat = rcode;
1952 		mci->mci_errno = errno;
1953 
1954 		/* and return the original host name as the signature */
1955 		s->s_hostsig = host;
1956 		return host;
1957 	}
1958 
1959 	len = 0;
1960 	for (i = 0; i < nmx; i++)
1961 	{
1962 		len += strlen(mxhosts[i]) + 1;
1963 	}
1964 	s->s_hostsig = p = xalloc(len);
1965 	for (i = 0; i < nmx; i++)
1966 	{
1967 		if (i != 0)
1968 			*p++ = ':';
1969 		strcpy(p, mxhosts[i]);
1970 		p += strlen(p);
1971 	}
1972 	makelower(s->s_hostsig);
1973 #else
1974 	/* not using BIND -- the signature is just the host name */
1975 	s->s_hostsig = host;
1976 #endif
1977 	if (tTd(17, 1))
1978 		printf("hostsignature(%s) = %s\n", host, s->s_hostsig);
1979 	return s->s_hostsig;
1980 }
1981