Context Navigation

source: trunk/third/sendmail/src/daemon.c @ 12554

Visit:

Revision 12554, 44.9 KB checked in by danw, 26 years ago (diff)
This commit was generated by cvs2svn to compensate for changes in r12553, which included commits to RCS files with non-trunk default branches.

Line
1	/*
2	* Copyright (c) 1998 Sendmail, Inc. All rights reserved.
3	* Copyright (c) 1983, 1995-1997 Eric P. Allman. All rights reserved.
4	* Copyright (c) 1988, 1993
5	* The Regents of the University of California. All rights reserved.
6	*
7	* By using this file, you agree to the terms and conditions set
8	* forth in the LICENSE file which can be found at the top level of
9	* the sendmail distribution.
10	*
11	*/
12
13	#include <errno.h>
14	#include "sendmail.h"
15
16	#ifndef lint
17	#ifdef DAEMON
18	static char sccsid[] = "@(#)daemon.c 8.236 (Berkeley) 1/25/1999 (with daemon mode)";
19	#else
20	static char sccsid[] = "@(#)daemon.c 8.236 (Berkeley) 1/25/1999 (without daemon mode)";
21	#endif
22	#endif /* not lint */
23
24	#if defined(SOCK_STREAM) \|\| defined(__GNU_LIBRARY__)
25	# define USE_SOCK_STREAM 1
26	#endif
27
28	#if DAEMON \|\| defined(USE_SOCK_STREAM)
29	# include <arpa/inet.h>
30	# if NAMED_BIND
31	# include <resolv.h>
32	# ifndef NO_DATA
33	# define NO_DATA NO_ADDRESS
34	# endif
35	# endif
36	#endif
37
38	#if DAEMON
39
40	# include <sys/time.h>
41
42	# if IP_SRCROUTE
43	# include <netinet/in_systm.h>
44	# include <netinet/ip.h>
45	# include <netinet/ip_var.h>
46	# endif
47
48	/*
49	** DAEMON.C -- routines to use when running as a daemon.
50	**
51	** This entire file is highly dependent on the 4.2 BSD
52	** interprocess communication primitives. No attempt has
53	** been made to make this file portable to Version 7,
54	** Version 6, MPX files, etc. If you should try such a
55	** thing yourself, I recommend chucking the entire file
56	** and starting from scratch. Basic semantics are:
57	**
58	** getrequests(e)
59	** Opens a port and initiates a connection.
60	** Returns in a child. Must set InChannel and
61	** OutChannel appropriately.
62	** clrdaemon()
63	** Close any open files associated with getting
64	** the connection; this is used when running the queue,
65	** etc., to avoid having extra file descriptors during
66	** the queue run and to avoid confusing the network
67	** code (if it cares).
68	** makeconnection(host, port, outfile, infile, e)
69	** Make a connection to the named host on the given
70	** port. Set outfile and infile to the files
71	** appropriate for communication. Returns zero on
72	** success, else an exit status describing the
73	** error.
74	** host_map_lookup(map, hbuf, avp, pstat)
75	** Convert the entry in hbuf into a canonical form.
76	*/
77	/*
78	** GETREQUESTS -- open mail IPC port and get requests.
79	**
80	** Parameters:
81	** e -- the current envelope.
82	**
83	** Returns:
84	** none.
85	**
86	** Side Effects:
87	** Waits until some interesting activity occurs. When
88	** it does, a child is created to process it, and the
89	** parent waits for completion. Return from this
90	** routine is always in the child. The file pointers
91	** "InChannel" and "OutChannel" should be set to point
92	** to the communication channel.
93	*/
94
95	int DaemonSocket = -1; /* fd describing socket */
96	SOCKADDR DaemonAddr; /* socket for incoming */
97	int ListenQueueSize = 10; /* size of listen queue */
98	int TcpRcvBufferSize = 0; /* size of TCP receive buffer */
99	int TcpSndBufferSize = 0; /* size of TCP send buffer */
100
101	void
102	getrequests(e)
103	ENVELOPE *e;
104	{
105	int t;
106	time_t refuse_connections_until = 0;
107	bool firsttime = TRUE;
108	FILE *pidf;
109	int sff;
110	int socksize;
111	u_short port;
112	#if XDEBUG
113	bool j_has_dot;
114	#endif
115	char status[MAXLINE];
116	extern void reapchild __P((int));
117	#ifdef NETUNIX
118	extern int ControlSocket;
119	#endif
120	extern int opendaemonsocket __P((bool));
121	extern int opencontrolsocket __P((void));
122
123	/*
124	** Set up the address for the mailer.
125	*/
126
127	switch (DaemonAddr.sa.sa_family)
128	{
129	case AF_UNSPEC:
130	DaemonAddr.sa.sa_family = AF_INET;
131	/* fall through ... */
132
133	case AF_INET:
134	if (DaemonAddr.sin.sin_addr.s_addr == 0)
135	DaemonAddr.sin.sin_addr.s_addr = INADDR_ANY;
136	port = DaemonAddr.sin.sin_port;
137	break;
138
139	default:
140	/* unknown protocol */
141	port = 0;
142	break;
143	}
144	if (port == 0)
145	{
146	register struct servent *sp;
147
148	sp = getservbyname("smtp", "tcp");
149	if (sp == NULL)
150	{
151	syserr("554 service \"smtp\" unknown");
152	port = htons(25);
153	}
154	else
155	port = sp->s_port;
156	}
157
158	switch (DaemonAddr.sa.sa_family)
159	{
160	case AF_INET:
161	DaemonAddr.sin.sin_port = port;
162	break;
163
164	default:
165	/* unknown protocol */
166	break;
167	}
168
169	/*
170	** Try to actually open the connection.
171	*/
172
173	if (tTd(15, 1))
174	printf("getrequests: port 0x%x\n", port);
175
176	/* get a socket for the SMTP connection */
177	socksize = opendaemonsocket(TRUE);
178
179	if (opencontrolsocket() < 0)
180	sm_syslog(LOG_WARNING, NOQID,
181	"daemon could not open control socket %s: %s",
182	ControlSocketName, errstring(errno));
183
184	(void) setsignal(SIGCHLD, reapchild);
185
186	/* write the pid to the log file for posterity */
187	sff = SFF_NOLINK\|SFF_ROOTOK\|SFF_REGONLY\|SFF_CREAT;
188	if (TrustedUid != 0 && RealUid == TrustedUid)
189	sff \|= SFF_OPENASROOT;
190	pidf = safefopen(PidFile, O_WRONLY\|O_TRUNC, 0644, sff);
191	if (pidf == NULL)
192	{
193	sm_syslog(LOG_ERR, NOQID, "unable to write %s", PidFile);
194	}
195	else
196	{
197	extern char *CommandLineArgs;
198
199	/* write the process id on line 1 */
200	fprintf(pidf, "%ld\n", (long) getpid());
201
202	/* line 2 contains all command line flags */
203	fprintf(pidf, "%s\n", CommandLineArgs);
204
205	/* flush and close */
206	fclose(pidf);
207	}
208
209	#if XDEBUG
210	{
211	char jbuf[MAXHOSTNAMELEN];
212
213	expand("\201j", jbuf, sizeof jbuf, e);
214	j_has_dot = strchr(jbuf, '.') != NULL;
215	}
216	#endif
217
218	/* Add parent process as first item */
219	proc_list_add(getpid(), "Sendmail daemon");
220
221	if (tTd(15, 1))
222	printf("getrequests: %d\n", DaemonSocket);
223
224	for (;;)
225	{
226	register pid_t pid;
227	auto SOCKADDR_LEN_T lotherend;
228	bool timedout = FALSE;
229	bool control = FALSE;
230	int savederrno;
231	int pipefd[2];
232	extern bool refuseconnections __P((int));
233
234	/* see if we are rejecting connections */
235	(void) blocksignal(SIGALRM);
236	if (curtime() >= refuse_connections_until)
237	{
238	if (refuseconnections(ntohs(port)))
239	{
240	if (DaemonSocket >= 0)
241	{
242	/* close socket so peer fails quickly */
243	(void) close(DaemonSocket);
244	DaemonSocket = -1;
245	}
246
247	/* refuse connections for next 15 seconds */
248	refuse_connections_until = curtime() + 15;
249	}
250	else if (DaemonSocket < 0 \|\| firsttime)
251	{
252	/* arrange to (re)open the socket if needed */
253	(void) opendaemonsocket(FALSE);
254	firsttime = FALSE;
255	}
256	}
257
258	#if XDEBUG
259	/* check for disaster */
260	{
261	char jbuf[MAXHOSTNAMELEN];
262	extern void dumpstate __P((char *));
263
264	expand("\201j", jbuf, sizeof jbuf, e);
265	if (!wordinclass(jbuf, 'w'))
266	{
267	dumpstate("daemon lost $j");
268	sm_syslog(LOG_ALERT, NOQID,
269	"daemon process doesn't have $j in $=w; see syslog");
270	abort();
271	}
272	else if (j_has_dot && strchr(jbuf, '.') == NULL)
273	{
274	dumpstate("daemon $j lost dot");
275	sm_syslog(LOG_ALERT, NOQID,
276	"daemon process $j lost dot; see syslog");
277	abort();
278	}
279	}
280	#endif
281
282	#if 0
283	/*
284	** Andrew Sun <asun@ieps-sun.ml.com> claims that this will
285	** fix the SVr4 problem. But it seems to have gone away,
286	** so is it worth doing this?
287	*/
288
289	if (DaemonSocket >= 0 &&
290	SetNonBlocking(DaemonSocket, FALSE) < 0)
291	log an error here;
292	#endif
293	(void) releasesignal(SIGALRM);
294	for (;;)
295	{
296	int highest = -1;
297	fd_set readfds;
298	struct timeval timeout;
299
300	FD_ZERO(&readfds);
301
302	/* wait for a connection */
303	if (DaemonSocket >= 0)
304	{
305	sm_setproctitle(TRUE,
306	"accepting connections on port %d",
307	ntohs(port));
308	if (DaemonSocket > highest)
309	highest = DaemonSocket;
310	FD_SET(DaemonSocket, &readfds);
311	}
312	#ifdef NETUNIX
313	if (ControlSocket >= 0)
314	{
315	if (ControlSocket > highest)
316	highest = ControlSocket;
317	FD_SET(ControlSocket, &readfds);
318	}
319	#endif
320	if (DaemonSocket >= 0)
321	timeout.tv_sec = 60;
322	else
323	timeout.tv_sec = 5;
324	timeout.tv_usec = 0;
325
326	t = select(highest + 1, FDSET_CAST &readfds,
327	NULL, NULL, &timeout);
328
329	if (DoQueueRun)
330	(void) runqueue(TRUE, FALSE);
331	if (t <= 0)
332	{
333	timedout = TRUE;
334	break;
335	}
336
337	control = FALSE;
338	errno = 0;
339	if (DaemonSocket >= 0 &&
340	FD_ISSET(DaemonSocket, &readfds))
341	{
342	lotherend = socksize;
343	t = accept(DaemonSocket,
344	(struct sockaddr *)&RealHostAddr,
345	&lotherend);
346	}
347	#ifdef NETUNIX
348	else if (ControlSocket >= 0 &&
349	FD_ISSET(ControlSocket, &readfds))
350	{
351	struct sockaddr_un sa_un;
352
353	lotherend = sizeof sa_un;
354	t = accept(ControlSocket,
355	(struct sockaddr *)&sa_un,
356	&lotherend);
357	control = TRUE;
358	}
359	#endif
360	if (t >= 0 \|\| errno != EINTR)
361	break;
362	}
363	if (timedout)
364	{
365	timedout = FALSE;
366	continue;
367	}
368	if (control)
369	{
370	if (t >= 0)
371	{
372	extern void control_command __P((int, ENVELOPE *));
373
374	control_command(t, e);
375	}
376	else
377	syserr("getrequests: control accept");
378	continue;
379	}
380	savederrno = errno;
381	(void) blocksignal(SIGALRM);
382	if (t < 0)
383	{
384	errno = savederrno;
385	syserr("getrequests: accept");
386
387	/* arrange to re-open the socket next time around */
388	(void) close(DaemonSocket);
389	DaemonSocket = -1;
390	continue;
391	}
392
393	/*
394	** Create a subprocess to process the mail.
395	*/
396
397	if (tTd(15, 2))
398	printf("getrequests: forking (fd = %d)\n", t);
399
400	/*
401	** Create a pipe to keep the child from writing to the
402	** socket until after the parent has closed it. Otherwise
403	** the parent may hang if the child has closed it first.
404	*/
405
406	if (pipe(pipefd) < 0)
407	pipefd[0] = pipefd[1] = -1;
408
409	blocksignal(SIGCHLD);
410	pid = fork();
411	if (pid < 0)
412	{
413	syserr("daemon: cannot fork");
414	if (pipefd[0] != -1)
415	{
416	(void) close(pipefd[0]);
417	(void) close(pipefd[1]);
418	}
419	(void) releasesignal(SIGCHLD);
420	sleep(10);
421	(void) close(t);
422	continue;
423	}
424
425	if (pid == 0)
426	{
427	char *p;
428	extern SIGFUNC_DECL intsig __P((int));
429	FILE inchannel, outchannel;
430
431	/*
432	** CHILD -- return to caller.
433	** Collect verified idea of sending host.
434	** Verify calling user id if possible here.
435	*/
436
437	(void) releasesignal(SIGALRM);
438	(void) releasesignal(SIGCHLD);
439	(void) setsignal(SIGCHLD, SIG_DFL);
440	(void) setsignal(SIGHUP, intsig);
441	(void) close(DaemonSocket);
442	clrcontrol();
443	proc_list_clear();
444
445	/* Add parent process as first child item */
446	proc_list_add(getpid(), "daemon child");
447
448	/* don't schedule queue runs if we are told to ETRN */
449	QueueIntvl = 0;
450
451	sm_setproctitle(TRUE, "startup with %s",
452	anynet_ntoa(&RealHostAddr));
453
454	if (pipefd[0] != -1)
455	{
456	auto char c;
457
458	/*
459	** Wait for the parent to close the write end
460	** of the pipe, which we will see as an EOF.
461	** This guarantees that we won't write to the
462	** socket until after the parent has closed
463	** the pipe.
464	*/
465
466	/* close the write end of the pipe */
467	(void) close(pipefd[1]);
468
469	/* we shouldn't be interrupted, but ... */
470	while (read(pipefd[0], &c, 1) < 0 &&
471	errno == EINTR)
472	continue;
473	(void) close(pipefd[0]);
474	}
475
476	/* determine host name */
477	p = hostnamebyanyaddr(&RealHostAddr);
478	if (strlen(p) > (SIZE_T) MAXNAME)
479	p[MAXNAME] = '\0';
480	RealHostName = newstr(p);
481	sm_setproctitle(TRUE, "startup with %s", p);
482
483	if ((inchannel = fdopen(t, "r")) == NULL \|\|
484	(t = dup(t)) < 0 \|\|
485	(outchannel = fdopen(t, "w")) == NULL)
486	{
487	syserr("cannot open SMTP server channel, fd=%d", t);
488	finis(FALSE, EX_OK);
489	}
490
491	InChannel = inchannel;
492	OutChannel = outchannel;
493	DisConnected = FALSE;
494
495	#ifdef XLA
496	if (!xla_host_ok(RealHostName))
497	{
498	message("421 Too many SMTP sessions for this host");
499	finis(FALSE, EX_OK);
500	}
501	#endif
502	break;
503	}
504
505	/* parent -- keep track of children */
506	snprintf(status, sizeof status, "SMTP server child for %s",
507	anynet_ntoa(&RealHostAddr));
508	proc_list_add(pid, status);
509	(void) releasesignal(SIGCHLD);
510
511	/* close the read end of the synchronization pipe */
512	if (pipefd[0] != -1)
513	(void) close(pipefd[0]);
514
515	/* close the port so that others will hang (for a while) */
516	(void) close(t);
517
518	/* release the child by closing the read end of the sync pipe */
519	if (pipefd[1] != -1)
520	(void) close(pipefd[1]);
521	}
522	if (tTd(15, 2))
523	printf("getreq: returning\n");
524	return;
525	}
526	/*
527	** OPENDAEMONSOCKET -- open the SMTP socket
528	**
529	** Deals with setting all appropriate options. DaemonAddr must
530	** be set up in advance.
531	**
532	** Parameters:
533	** firsttime -- set if this is the initial open.
534	**
535	** Returns:
536	** Size in bytes of the daemon socket addr.
537	**
538	** Side Effects:
539	** Leaves DaemonSocket set to the open socket.
540	** Exits if the socket cannot be created.
541	*/
542
543	#define MAXOPENTRIES 10 /* maximum number of tries to open connection */
544
545	int
546	opendaemonsocket(firsttime)
547	bool firsttime;
548	{
549	int on = 1;
550	int socksize = 0;
551	int ntries = 0;
552	int saveerrno;
553
554	if (tTd(15, 2))
555	printf("opendaemonsocket()\n");
556
557	do
558	{
559	if (ntries > 0)
560	sleep(5);
561	if (firsttime \|\| DaemonSocket < 0)
562	{
563	DaemonSocket = socket(DaemonAddr.sa.sa_family, SOCK_STREAM, 0);
564	if (DaemonSocket < 0)
565	{
566	saveerrno = errno;
567	syserr("opendaemonsocket: can't create server SMTP socket");
568	severe:
569	if (LogLevel > 0)
570	sm_syslog(LOG_ALERT, NOQID,
571	"problem creating SMTP socket");
572	DaemonSocket = -1;
573	continue;
574	}
575
576	/* turn on network debugging? */
577	if (tTd(15, 101))
578	(void) setsockopt(DaemonSocket, SOL_SOCKET,
579	SO_DEBUG, (char *)&on,
580	sizeof on);
581
582	(void) setsockopt(DaemonSocket, SOL_SOCKET,
583	SO_REUSEADDR, (char *)&on, sizeof on);
584	(void) setsockopt(DaemonSocket, SOL_SOCKET,
585	SO_KEEPALIVE, (char *)&on, sizeof on);
586
587	#ifdef SO_RCVBUF
588	if (TcpRcvBufferSize > 0)
589	{
590	if (setsockopt(DaemonSocket, SOL_SOCKET,
591	SO_RCVBUF,
592	(char *) &TcpRcvBufferSize,
593	sizeof(TcpRcvBufferSize)) < 0)
594	syserr("opendaemonsocket: setsockopt(SO_RCVBUF)");
595	}
596	#endif
597
598	switch (DaemonAddr.sa.sa_family)
599	{
600	# if NETINET
601	case AF_INET:
602	socksize = sizeof DaemonAddr.sin;
603	break;
604	# endif
605
606	# if NETISO
607	case AF_ISO:
608	socksize = sizeof DaemonAddr.siso;
609	break;
610	# endif
611
612	default:
613	socksize = sizeof DaemonAddr;
614	break;
615	}
616
617	if (bind(DaemonSocket, &DaemonAddr.sa, socksize) < 0)
618	{
619	/* probably another daemon already */
620	saveerrno = errno;
621	syserr("opendaemonsocket: cannot bind");
622	(void) close(DaemonSocket);
623	goto severe;
624	}
625	}
626	if (!firsttime && listen(DaemonSocket, ListenQueueSize) < 0)
627	{
628	saveerrno = errno;
629	syserr("opendaemonsocket: cannot listen");
630	(void) close(DaemonSocket);
631	goto severe;
632	}
633	return socksize;
634	} while (ntries++ < MAXOPENTRIES && transienterror(saveerrno));
635	syserr("!opendaemonsocket: server SMTP socket wedged: exiting");
636	/NOTREACHED/
637	return -1; /* avoid compiler warning on IRIX */
638	}
639	/*
640	** CLRDAEMON -- reset the daemon connection
641	**
642	** Parameters:
643	** none.
644	**
645	** Returns:
646	** none.
647	**
648	** Side Effects:
649	** releases any resources used by the passive daemon.
650	*/
651
652	void
653	clrdaemon()
654	{
655	if (DaemonSocket >= 0)
656	(void) close(DaemonSocket);
657	DaemonSocket = -1;
658	}
659	/*
660	** SETDAEMONOPTIONS -- set options for running the daemon
661	**
662	** Parameters:
663	** p -- the options line.
664	**
665	** Returns:
666	** none.
667	*/
668
669	void
670	setdaemonoptions(p)
671	register char *p;
672	{
673	if (DaemonAddr.sa.sa_family == AF_UNSPEC)
674	DaemonAddr.sa.sa_family = AF_INET;
675
676	while (p != NULL)
677	{
678	register char *f;
679	register char *v;
680
681	while (isascii(p) && isspace(p))
682	p++;
683	if (*p == '\0')
684	break;
685	f = p;
686	p = strchr(p, ',');
687	if (p != NULL)
688	*p++ = '\0';
689	v = strchr(f, '=');
690	if (v == NULL)
691	continue;
692	while (isascii(++v) && isspace(v))
693	continue;
694	if (isascii(f) && islower(f))
695	f = toupper(f);
696
697	switch (*f)
698	{
699	case 'F': /* address family */
700	if (isascii(v) && isdigit(v))
701	DaemonAddr.sa.sa_family = atoi(v);
702	#if NETINET
703	else if (strcasecmp(v, "inet") == 0)
704	DaemonAddr.sa.sa_family = AF_INET;
705	#endif
706	#if NETISO
707	else if (strcasecmp(v, "iso") == 0)
708	DaemonAddr.sa.sa_family = AF_ISO;
709	#endif
710	#if NETNS
711	else if (strcasecmp(v, "ns") == 0)
712	DaemonAddr.sa.sa_family = AF_NS;
713	#endif
714	#if NETX25
715	else if (strcasecmp(v, "x.25") == 0)
716	DaemonAddr.sa.sa_family = AF_CCITT;
717	#endif
718	else
719	syserr("554 Unknown address family %s in Family=option", v);
720	break;
721
722	case 'A': /* address */
723	switch (DaemonAddr.sa.sa_family)
724	{
725	#if NETINET
726	case AF_INET:
727	if (isascii(v) && isdigit(v))
728	DaemonAddr.sin.sin_addr.s_addr = inet_addr(v);
729	else
730	{
731	register struct hostent *hp;
732
733	hp = sm_gethostbyname(v);
734	if (hp == NULL)
735	syserr("554 host \"%s\" unknown", v);
736	else
737	bcopy(hp->h_addr, &DaemonAddr.sin.sin_addr, INADDRSZ);
738	}
739	break;
740	#endif
741
742	default:
743	syserr("554 Address= option unsupported for family %d",
744	DaemonAddr.sa.sa_family);
745	break;
746	}
747	break;
748
749	case 'P': /* port */
750	switch (DaemonAddr.sa.sa_family)
751	{
752	#if NETISO
753	short port;
754	#endif
755
756	#if NETINET
757	case AF_INET:
758	if (isascii(v) && isdigit(v))
759	DaemonAddr.sin.sin_port = htons(atoi(v));
760	else
761	{
762	register struct servent *sp;
763
764	sp = getservbyname(v, "tcp");
765	if (sp == NULL)
766	syserr("554 service \"%s\" unknown", v);
767	else
768	DaemonAddr.sin.sin_port = sp->s_port;
769	}
770	break;
771	#endif
772
773	#if NETISO
774	case AF_ISO:
775	/* assume two byte transport selector */
776	if (isascii(v) && isdigit(v))
777	port = htons(atoi(v));
778	else
779	{
780	register struct servent *sp;
781
782	sp = getservbyname(v, "tcp");
783	if (sp == NULL)
784	syserr("554 service \"%s\" unknown", v);
785	else
786	port = sp->s_port;
787	}
788	bcopy((char *) &port, TSEL(&DaemonAddr.siso), 2);
789	break;
790	#endif
791
792	default:
793	syserr("554 Port= option unsupported for family %d",
794	DaemonAddr.sa.sa_family);
795	break;
796	}
797	break;
798
799	case 'L': /* listen queue size */
800	ListenQueueSize = atoi(v);
801	break;
802
803	case 'S': /* send buffer size */
804	TcpSndBufferSize = atoi(v);
805	break;
806
807	case 'R': /* receive buffer size */
808	TcpRcvBufferSize = atoi(v);
809	break;
810
811	default:
812	syserr("554 DaemonPortOptions parameter \"%s\" unknown", f);
813	}
814	}
815	}
816	/*
817	** MAKECONNECTION -- make a connection to an SMTP socket on another machine.
818	**
819	** Parameters:
820	** host -- the name of the host.
821	** port -- the port number to connect to.
822	** mci -- a pointer to the mail connection information
823	** structure to be filled in.
824	** e -- the current envelope.
825	**
826	** Returns:
827	** An exit code telling whether the connection could be
828	** made and if not why not.
829	**
830	** Side Effects:
831	** none.
832	*/
833
834	static jmp_buf CtxConnectTimeout;
835
836	static void
837	connecttimeout()
838	{
839	errno = ETIMEDOUT;
840	longjmp(CtxConnectTimeout, 1);
841	}
842
843	SOCKADDR CurHostAddr; /* address of current host */
844
845	int
846	makeconnection(host, port, mci, e)
847	char *host;
848	u_short port;
849	register MCI *mci;
850	ENVELOPE *e;
851	{
852	register volatile int addrno = 0;
853	register volatile int s;
854	register struct hostent volatile hp = (struct hostent )NULL;
855	SOCKADDR addr;
856	int sav_errno;
857	volatile int addrlen;
858	volatile bool firstconnect;
859	EVENT *volatile ev = NULL;
860
861	/*
862	** Set up the address for the mailer.
863	** Accept "[a.b.c.d]" syntax for host name.
864	*/
865
866	#if NAMED_BIND
867	h_errno = 0;
868	#endif
869	errno = 0;
870	bzero(&CurHostAddr, sizeof CurHostAddr);
871	SmtpPhase = mci->mci_phase = "initial connection";
872	CurHostName = host;
873
874	if (host[0] == '[')
875	{
876	#if NETINET
877	unsigned long hid = INADDR_NONE;
878	#endif
879	register char *p = strchr(host, ']');
880
881	if (p != NULL)
882	{
883	*p = '\0';
884	#if NETINET
885	hid = inet_addr(&host[1]);
886	if (hid == INADDR_NONE)
887	#endif
888	{
889	/* try it as a host name (avoid MX lookup) */
890	hp = sm_gethostbyname(&host[1]);
891	if (hp == NULL && p[-1] == '.')
892	{
893	#if NAMED_BIND
894	int oldopts = _res.options;
895
896	_res.options &= ~(RES_DEFNAMES\|RES_DNSRCH);
897	#endif
898	p[-1] = '\0';
899	hp = sm_gethostbyname(&host[1]);
900	p[-1] = '.';
901	#if NAMED_BIND
902	_res.options = oldopts;
903	#endif
904	}
905	*p = ']';
906	goto gothostent;
907	}
908	*p = ']';
909	}
910	if (p == NULL)
911	{
912	extern char MsgBuf[];
913
914	usrerr("553 Invalid numeric domain spec \"%s\"", host);
915	mci_setstat(mci, EX_NOHOST, "5.1.2", MsgBuf);
916	return EX_NOHOST;
917	}
918	#if NETINET
919	addr.sin.sin_family = AF_INET; /XXX/
920	addr.sin.sin_addr.s_addr = hid;
921	#endif
922	}
923	else
924	{
925	/* contortion to get around SGI cc complaints */
926	{
927	register char *p = &host[strlen(host) - 1];
928
929	hp = sm_gethostbyname(host);
930	if (hp == NULL && *p == '.')
931	{
932	#if NAMED_BIND
933	int oldopts = _res.options;
934
935	_res.options &= ~(RES_DEFNAMES\|RES_DNSRCH);
936	#endif
937	*p = '\0';
938	hp = sm_gethostbyname(host);
939	*p = '.';
940	#if NAMED_BIND
941	_res.options = oldopts;
942	#endif
943	}
944	}
945	gothostent:
946	if (hp == NULL)
947	{
948	#if NAMED_BIND
949	/* check for name server timeouts */
950	if (errno == ETIMEDOUT \|\| h_errno == TRY_AGAIN \|\|
951	(errno == ECONNREFUSED && UseNameServer))
952	{
953	mci_setstat(mci, EX_TEMPFAIL, "4.4.3", NULL);
954	return EX_TEMPFAIL;
955	}
956	#endif
957	mci_setstat(mci, EX_NOHOST, "5.1.2", NULL);
958	return (EX_NOHOST);
959	}
960	addr.sa.sa_family = hp->h_addrtype;
961	switch (hp->h_addrtype)
962	{
963	#if NETINET
964	case AF_INET:
965	bcopy(hp->h_addr,
966	&addr.sin.sin_addr,
967	INADDRSZ);
968	break;
969	#endif
970
971	default:
972	if (hp->h_length > sizeof addr.sa.sa_data)
973	{
974	syserr("makeconnection: long sa_data: family %d len %d",
975	hp->h_addrtype, hp->h_length);
976	mci_setstat(mci, EX_NOHOST, "5.1.2", NULL);
977	return EX_NOHOST;
978	}
979	bcopy(hp->h_addr,
980	addr.sa.sa_data,
981	hp->h_length);
982	break;
983	}
984	addrno = 1;
985	}
986
987	/*
988	** Determine the port number.
989	*/
990
991	if (port == 0)
992	{
993	register struct servent *sp = getservbyname("smtp", "tcp");
994
995	if (sp == NULL)
996	{
997	if (LogLevel > 2)
998	sm_syslog(LOG_ERR, NOQID,
999	"makeconnection: service \"smtp\" unknown");
1000	port = htons(25);
1001	}
1002	else
1003	port = sp->s_port;
1004	}
1005
1006	switch (addr.sa.sa_family)
1007	{
1008	#if NETINET
1009	case AF_INET:
1010	addr.sin.sin_port = port;
1011	addrlen = sizeof (struct sockaddr_in);
1012	break;
1013	#endif
1014
1015	#if NETISO
1016	case AF_ISO:
1017	/* assume two byte transport selector */
1018	bcopy((char ) &port, TSEL((struct sockaddr_iso ) &addr), 2);
1019	addrlen = sizeof (struct sockaddr_iso);
1020	break;
1021	#endif
1022
1023	default:
1024	syserr("Can't connect to address family %d", addr.sa.sa_family);
1025	mci_setstat(mci, EX_NOHOST, "5.1.2", NULL);
1026	return (EX_NOHOST);
1027	}
1028
1029	/*
1030	** Try to actually open the connection.
1031	*/
1032
1033	#ifdef XLA
1034	/* if too many connections, don't bother trying */
1035	if (!xla_noqueue_ok(host))
1036	return EX_TEMPFAIL;
1037	#endif
1038
1039	firstconnect = TRUE;
1040	for (;;)
1041	{
1042	if (tTd(16, 1))
1043	printf("makeconnection (%s [%s])\n",
1044	host, anynet_ntoa(&addr));
1045
1046	/* save for logging */
1047	CurHostAddr = addr;
1048
1049	if (bitnset(M_SECURE_PORT, mci->mci_mailer->m_flags))
1050	{
1051	int rport = IPPORT_RESERVED - 1;
1052
1053	s = rresvport(&rport);
1054	}
1055	else
1056	{
1057	s = socket(addr.sa.sa_family, SOCK_STREAM, 0);
1058	}
1059	if (s < 0)
1060	{
1061	sav_errno = errno;
1062	syserr("makeconnection: cannot create socket");
1063	#ifdef XLA
1064	xla_host_end(host);
1065	#endif
1066	mci_setstat(mci, EX_TEMPFAIL, "4.4.5", NULL);
1067	return EX_TEMPFAIL;
1068	}
1069
1070	#ifdef SO_SNDBUF
1071	if (TcpSndBufferSize > 0)
1072	{
1073	if (setsockopt(s, SOL_SOCKET, SO_SNDBUF,
1074	(char *) &TcpSndBufferSize,
1075	sizeof(TcpSndBufferSize)) < 0)
1076	syserr("makeconnection: setsockopt(SO_SNDBUF)");
1077	}
1078	#endif
1079
1080	if (tTd(16, 1))
1081	printf("makeconnection: fd=%d\n", s);
1082
1083	/* turn on network debugging? */
1084	if (tTd(16, 101))
1085	{
1086	int on = 1;
1087	(void) setsockopt(s, SOL_SOCKET, SO_DEBUG,
1088	(char *)&on, sizeof on);
1089	}
1090	if (e->e_xfp != NULL)
1091	(void) fflush(e->e_xfp); /* for debugging */
1092	errno = 0; /* for debugging */
1093
1094	/*
1095	** Linux seems to hang in connect for 90 minutes (!!!).
1096	** Time out the connect to avoid this problem.
1097	*/
1098
1099	if (setjmp(CtxConnectTimeout) == 0)
1100	{
1101	int i;
1102
1103	if (e->e_ntries <= 0 && TimeOuts.to_iconnect != 0)
1104	ev = setevent(TimeOuts.to_iconnect, connecttimeout, 0);
1105	else if (TimeOuts.to_connect != 0)
1106	ev = setevent(TimeOuts.to_connect, connecttimeout, 0);
1107	else
1108	ev = NULL;
1109
1110	#if _FFR_CONNECTONLYTO_OPTION
1111	/* for testing */
1112	if (ConnectOnlyTo != 0)
1113	addr.sin.sin_addr.s_addr = ConnectOnlyTo;
1114	#endif
1115	i = connect(s, (struct sockaddr *) &addr, addrlen);
1116	sav_errno = errno;
1117	if (ev != NULL)
1118	clrevent(ev);
1119	if (i >= 0)
1120	break;
1121	}
1122	else
1123	sav_errno = errno;
1124
1125	/* if running demand-dialed connection, try again */
1126	if (DialDelay > 0 && firstconnect)
1127	{
1128	if (tTd(16, 1))
1129	printf("Connect failed (%s); trying again...\n",
1130	errstring(sav_errno));
1131	firstconnect = FALSE;
1132	sleep(DialDelay);
1133	continue;
1134	}
1135
1136	/* couldn't connect.... figure out why */
1137	(void) close(s);
1138
1139	if (LogLevel >= 14)
1140	sm_syslog(LOG_INFO, e->e_id,
1141	"makeconnection (%s [%s]) failed: %s",
1142	host, anynet_ntoa(&addr),
1143	errstring(sav_errno));
1144
1145	if (hp != NULL && hp->h_addr_list[addrno] != NULL)
1146	{
1147	if (tTd(16, 1))
1148	printf("Connect failed (%s); trying new address....\n",
1149	errstring(sav_errno));
1150	switch (addr.sa.sa_family)
1151	{
1152	#if NETINET
1153	case AF_INET:
1154	bcopy(hp->h_addr_list[addrno++],
1155	&addr.sin.sin_addr,
1156	INADDRSZ);
1157	break;
1158	#endif
1159
1160	default:
1161	bcopy(hp->h_addr_list[addrno++],
1162	addr.sa.sa_data,
1163	hp->h_length);
1164	break;
1165	}
1166	continue;
1167	}
1168
1169	/* couldn't open connection */
1170	#ifdef XLA
1171	xla_host_end(host);
1172	#endif
1173	mci_setstat(mci, EX_TEMPFAIL, "4.4.1", NULL);
1174	return EX_TEMPFAIL;
1175	}
1176
1177	/* connection ok, put it into canonical form */
1178	if ((mci->mci_out = fdopen(s, "w")) == NULL \|\|
1179	(s = dup(s)) < 0 \|\|
1180	(mci->mci_in = fdopen(s, "r")) == NULL)
1181	{
1182	syserr("cannot open SMTP client channel, fd=%d", s);
1183	mci_setstat(mci, EX_TEMPFAIL, "4.4.5", NULL);
1184	return EX_TEMPFAIL;
1185	}
1186
1187	mci_setstat(mci, EX_OK, NULL, NULL);
1188	return (EX_OK);
1189	}
1190	/*
1191	** MYHOSTNAME -- return the name of this host.
1192	**
1193	** Parameters:
1194	** hostbuf -- a place to return the name of this host.
1195	** size -- the size of hostbuf.
1196	**
1197	** Returns:
1198	** A list of aliases for this host.
1199	**
1200	** Side Effects:
1201	** Adds numeric codes to $=w.
1202	*/
1203
1204	struct hostent *
1205	myhostname(hostbuf, size)
1206	char hostbuf[];
1207	int size;
1208	{
1209	register struct hostent *hp;
1210
1211	if (gethostname(hostbuf, size) < 0)
1212	{
1213	(void) strcpy(hostbuf, "localhost");
1214	}
1215	hp = sm_gethostbyname(hostbuf);
1216	if (hp == NULL)
1217	return NULL;
1218	if (strchr(hp->h_name, '.') != NULL \|\| strchr(hostbuf, '.') == NULL)
1219	{
1220	(void) strncpy(hostbuf, hp->h_name, size - 1);
1221	hostbuf[size - 1] = '\0';
1222	}
1223
1224	/*
1225	** If there is still no dot in the name, try looking for a
1226	** dotted alias.
1227	*/
1228
1229	if (strchr(hostbuf, '.') == NULL)
1230	{
1231	char **ha;
1232
1233	for (ha = hp->h_aliases; *ha != NULL; ha++)
1234	{
1235	if (strchr(*ha, '.') != NULL)
1236	{
1237	(void) strncpy(hostbuf, *ha, size - 1);
1238	hostbuf[size - 1] = '\0';
1239	break;
1240	}
1241	}
1242	}
1243
1244	/*
1245	** If _still_ no dot, wait for a while and try again -- it is
1246	** possible that some service is starting up. This can result
1247	** in excessive delays if the system is badly configured, but
1248	** there really isn't a way around that, particularly given that
1249	** the config file hasn't been read at this point.
1250	** All in all, a bit of a mess.
1251	*/
1252
1253	if (strchr(hostbuf, '.') == NULL &&
1254	!getcanonname(hostbuf, size, TRUE))
1255	{
1256	sm_syslog(LOG_CRIT, NOQID,
1257	"My unqualified host name (%s) unknown; sleeping for retry",
1258	hostbuf);
1259	message("My unqualified host name (%s) unknown; sleeping for retry",
1260	hostbuf);
1261	sleep(60);
1262	if (!getcanonname(hostbuf, size, TRUE))
1263	{
1264	sm_syslog(LOG_ALERT, NOQID,
1265	"unable to qualify my own domain name (%s) -- using short name",
1266	hostbuf);
1267	message("WARNING: unable to qualify my own domain name (%s) -- using short name",
1268	hostbuf);
1269	}
1270	}
1271	return (hp);
1272	}
1273	/*
1274	** ADDRCMP -- compare two host addresses
1275	**
1276	** Parameters:
1277	** hp -- hostent structure for the first address
1278	** ha -- actual first address
1279	** sa -- second address
1280	**
1281	** Returns:
1282	** 0 -- if ha and sa match
1283	** else -- they don't match
1284	*/
1285
1286	int
1287	addrcmp(hp, ha, sa)
1288	struct hostent *hp;
1289	char *ha;
1290	SOCKADDR *sa;
1291	{
1292	switch (sa->sa.sa_family)
1293	{
1294	case AF_INET:
1295	if (hp->h_addrtype == AF_INET)
1296	return bcmp(ha, (char *) &sa->sin.sin_addr, hp->h_length);
1297	break;
1298
1299	}
1300	return -1;
1301	}
1302	/*
1303	** GETAUTHINFO -- get the real host name asociated with a file descriptor
1304	**
1305	** Uses RFC1413 protocol to try to get info from the other end.
1306	**
1307	** Parameters:
1308	** fd -- the descriptor
1309	** may_be_forged -- an outage that is set to TRUE if the
1310	** forward lookup of RealHostName does not match
1311	** RealHostAddr; set to FALSE if they do match.
1312	**
1313	** Returns:
1314	** The user@host information associated with this descriptor.
1315	*/
1316
1317	static jmp_buf CtxAuthTimeout;
1318
1319	static void
1320	authtimeout()
1321	{
1322	longjmp(CtxAuthTimeout, 1);
1323	}
1324
1325	char *
1326	getauthinfo(fd, may_be_forged)
1327	int fd;
1328	bool *may_be_forged;
1329	{
1330	SOCKADDR_LEN_T falen;
1331	register char *volatile p = NULL;
1332	SOCKADDR la;
1333	SOCKADDR_LEN_T lalen;
1334	register struct servent *sp;
1335	volatile int s;
1336	int i = 0;
1337	EVENT *ev;
1338	int nleft;
1339	struct hostent *hp;
1340	char *ostype = NULL;
1341	char **ha;
1342	char ibuf[MAXNAME + 1];
1343	static char hbuf[MAXNAME * 2 + 11];
1344
1345	*may_be_forged = FALSE;
1346	falen = sizeof RealHostAddr;
1347	if (isatty(fd) \|\| (i = getpeername(fd, &RealHostAddr.sa, &falen)) < 0 \|\|
1348	falen <= 0 \|\| RealHostAddr.sa.sa_family == 0)
1349	{
1350	if (i < 0 && errno != ENOTSOCK)
1351	return NULL;
1352	(void) snprintf(hbuf, sizeof hbuf, "%s@localhost",
1353	RealUserName);
1354	if (tTd(9, 1))
1355	printf("getauthinfo: %s\n", hbuf);
1356	return hbuf;
1357	}
1358
1359	if (RealHostName == NULL)
1360	{
1361	/* translate that to a host name */
1362	RealHostName = newstr(hostnamebyanyaddr(&RealHostAddr));
1363	if (strlen(RealHostName) > MAXNAME)
1364	RealHostName[MAXNAME] = '\0';
1365	}
1366
1367	/* cross check RealHostName with forward DNS lookup */
1368	if (anynet_ntoa(&RealHostAddr)[0] == '[' \|\|
1369	RealHostName[0] == '[')
1370	{
1371	/*
1372	** address is not a socket or have an
1373	** IP address with no forward lookup
1374	*/
1375	*may_be_forged = FALSE;
1376	}
1377	else
1378	{
1379	/* try to match the reverse against the forward lookup */
1380	hp = sm_gethostbyname(RealHostName);
1381
1382	if (hp == NULL)
1383	*may_be_forged = TRUE;
1384	else
1385	{
1386	for (ha = hp->h_addr_list; *ha != NULL; ha++)
1387	if (addrcmp(hp, *ha, &RealHostAddr) == 0)
1388	break;
1389	may_be_forged = ha == NULL;
1390	}
1391	}
1392
1393	if (TimeOuts.to_ident == 0)
1394	goto noident;
1395
1396	lalen = sizeof la;
1397	if (RealHostAddr.sa.sa_family != AF_INET \|\|
1398	getsockname(fd, &la.sa, &lalen) < 0 \|\| lalen <= 0 \|\|
1399	la.sa.sa_family != AF_INET)
1400	{
1401	/* no ident info */
1402	goto noident;
1403	}
1404
1405	/* create ident query */
1406	(void) snprintf(ibuf, sizeof ibuf, "%d,%d\r\n",
1407	ntohs(RealHostAddr.sin.sin_port), ntohs(la.sin.sin_port));
1408
1409	/* create local address */
1410	la.sin.sin_port = 0;
1411
1412	/* create foreign address */
1413	sp = getservbyname("auth", "tcp");
1414	if (sp != NULL)
1415	RealHostAddr.sin.sin_port = sp->s_port;
1416	else
1417	RealHostAddr.sin.sin_port = htons(113);
1418
1419	s = -1;
1420	if (setjmp(CtxAuthTimeout) != 0)
1421	{
1422	if (s >= 0)
1423	(void) close(s);
1424	goto noident;
1425	}
1426
1427	/* put a timeout around the whole thing */
1428	ev = setevent(TimeOuts.to_ident, authtimeout, 0);
1429
1430	/* connect to foreign IDENT server using same address as SMTP socket */
1431	s = socket(AF_INET, SOCK_STREAM, 0);
1432	if (s < 0)
1433	{
1434	clrevent(ev);
1435	goto noident;
1436	}
1437	if (bind(s, &la.sa, sizeof la.sin) < 0 \|\|
1438	connect(s, &RealHostAddr.sa, sizeof RealHostAddr.sin) < 0)
1439	{
1440	goto closeident;
1441	}
1442
1443	if (tTd(9, 10))
1444	printf("getauthinfo: sent %s", ibuf);
1445
1446	/* send query */
1447	if (write(s, ibuf, strlen(ibuf)) < 0)
1448	goto closeident;
1449
1450	/* get result */
1451	p = &ibuf[0];
1452	nleft = sizeof ibuf - 1;
1453	while ((i = read(s, p, nleft)) > 0)
1454	{
1455	p += i;
1456	nleft -= i;
1457	*p = '\0';
1458	if (strchr(ibuf, '\n') != NULL)
1459	break;
1460	}
1461	(void) close(s);
1462	clrevent(ev);
1463	if (i < 0 \|\| p == &ibuf[0])
1464	goto noident;
1465
1466	if (--p == '\n' && --p == '\r')
1467	p--;
1468	*++p = '\0';
1469
1470	if (tTd(9, 3))
1471	printf("getauthinfo: got %s\n", ibuf);
1472
1473	/* parse result */
1474	p = strchr(ibuf, ':');
1475	if (p == NULL)
1476	{
1477	/* malformed response */
1478	goto noident;
1479	}
1480	while (isascii(++p) && isspace(p))
1481	continue;
1482	if (strncasecmp(p, "userid", 6) != 0)
1483	{
1484	/* presumably an error string */
1485	goto noident;
1486	}
1487	p += 6;
1488	while (isascii(p) && isspace(p))
1489	p++;
1490	if (*p++ != ':')
1491	{
1492	/* either useridxx or malformed response */
1493	goto noident;
1494	}
1495
1496	/* p now points to the OSTYPE field */
1497	while (isascii(p) && isspace(p))
1498	p++;
1499	ostype = p;
1500	p = strchr(p, ':');
1501	if (p == NULL)
1502	{
1503	/* malformed response */
1504	goto noident;
1505	}
1506	else
1507	{
1508	char *charset;
1509
1510	*p = '\0';
1511	charset = strchr(ostype, ',');
1512	if (charset != NULL)
1513	*charset = '\0';
1514	}
1515
1516	/* 1413 says don't do this -- but it's broken otherwise */
1517	while (isascii(++p) && isspace(p))
1518	continue;
1519
1520	/* p now points to the authenticated name -- copy carefully */
1521	if (strncasecmp(ostype, "other", 5) == 0 &&
1522	(ostype[5] == ' ' \|\| ostype[5] == '\0'))
1523	{
1524	snprintf(hbuf, sizeof hbuf, "IDENT:");
1525	cleanstrcpy(&hbuf[6], p, MAXNAME);
1526	}
1527	else
1528	cleanstrcpy(hbuf, p, MAXNAME);
1529	i = strlen(hbuf);
1530	snprintf(&hbuf[i], sizeof hbuf - i, "@%s",
1531	RealHostName == NULL ? "localhost" : RealHostName);
1532	goto postident;
1533
1534	closeident:
1535	(void) close(s);
1536	clrevent(ev);
1537
1538	noident:
1539	if (RealHostName == NULL)
1540	{
1541	if (tTd(9, 1))
1542	printf("getauthinfo: NULL\n");
1543	return NULL;
1544	}
1545	snprintf(hbuf, sizeof hbuf, "%s", RealHostName);
1546
1547	postident:
1548	#if IP_SRCROUTE
1549	# ifndef GET_IPOPT_DST
1550	# define GET_IPOPT_DST(dst) (dst)
1551	# endif
1552	/*
1553	** Extract IP source routing information.
1554	**
1555	** Format of output for a connection from site a through b
1556	** through c to d:
1557	** loose: @site-c@site-b:site-a
1558	** strict: !@site-c@site-b:site-a
1559	**
1560	** o - pointer within ipopt_list structure.
1561	** q - pointer within ls/ss rr route data
1562	** p - pointer to hbuf
1563	*/
1564
1565	if (RealHostAddr.sa.sa_family == AF_INET)
1566	{
1567	SOCKOPT_LEN_T ipoptlen;
1568	int j;
1569	u_char *q;
1570	u_char *o;
1571	int l;
1572	struct in_addr addr;
1573	struct ipoption ipopt;
1574
1575	ipoptlen = sizeof ipopt;
1576	if (getsockopt(fd, IPPROTO_IP, IP_OPTIONS,
1577	(char *) &ipopt, &ipoptlen) < 0)
1578	goto noipsr;
1579	if (ipoptlen == 0)
1580	goto noipsr;
1581	o = (u_char *) ipopt.ipopt_list;
1582	while (o != NULL && o < (u_char *) &ipopt + ipoptlen)
1583	{
1584	switch (*o)
1585	{
1586	case IPOPT_EOL:
1587	o = NULL;
1588	break;
1589
1590	case IPOPT_NOP:
1591	o++;
1592	break;
1593
1594	case IPOPT_SSRR:
1595	case IPOPT_LSRR:
1596	/*
1597	** Source routing.
1598	** o[0] is the option type (loose/strict).
1599	** o[1] is the length of this option,
1600	** including option type and
1601	** length.
1602	** o[2] is the pointer into the route
1603	** data.
1604	** o[3] begins the route data.
1605	*/
1606
1607	p = &hbuf[strlen(hbuf)];
1608	l = sizeof hbuf - (hbuf - p) - 6;
1609	snprintf(p, SPACELEFT(hbuf, p), " [%s@%.*s",
1610	*o == IPOPT_SSRR ? "!" : "",
1611	l > 240 ? 120 : l / 2,
1612	inet_ntoa(GET_IPOPT_DST(ipopt.ipopt_dst)));
1613	i = strlen(p);
1614	p += i;
1615	l -= strlen(p);
1616
1617	j = o[1] / sizeof(struct in_addr) - 1;
1618
1619	/* q skips length and router pointer to data */
1620	q = &o[3];
1621	for ( ; j >= 0; j--)
1622	{
1623	memcpy(&addr, q, sizeof(addr));
1624	snprintf(p, SPACELEFT(hbuf, p),
1625	"%c%.*s",
1626	j != 0 ? '@' : ':',
1627	l > 240 ? 120 :
1628	j == 0 ? l : l / 2,
1629	inet_ntoa(addr));
1630	i = strlen(p);
1631	p += i;
1632	l -= i + 1;
1633	q += sizeof(struct in_addr);
1634	}
1635	o += o[1];
1636	break;
1637
1638	default:
1639	/* Skip over option */
1640	o += o[1];
1641	break;
1642	}
1643	}
1644	snprintf(p, SPACELEFT(hbuf, p), "]");
1645	goto postipsr;
1646	}
1647
1648	noipsr:
1649	#endif
1650	if (RealHostName != NULL && RealHostName[0] != '[')
1651	{
1652	p = &hbuf[strlen(hbuf)];
1653	(void) snprintf(p, SPACELEFT(hbuf, p), " [%.100s]",
1654	anynet_ntoa(&RealHostAddr));
1655	}
1656	if (*may_be_forged)
1657	{
1658	p = &hbuf[strlen(hbuf)];
1659	(void) snprintf(p, SPACELEFT(hbuf, p), " (may be forged)");
1660	}
1661
1662	#if IP_SRCROUTE
1663	postipsr:
1664	#endif
1665	if (tTd(9, 1))
1666	printf("getauthinfo: %s\n", hbuf);
1667	return hbuf;
1668	}
1669	/*
1670	** HOST_MAP_LOOKUP -- turn a hostname into canonical form
1671	**
1672	** Parameters:
1673	** map -- a pointer to this map.
1674	** name -- the (presumably unqualified) hostname.
1675	** av -- unused -- for compatibility with other mapping
1676	** functions.
1677	** statp -- an exit status (out parameter) -- set to
1678	** EX_TEMPFAIL if the name server is unavailable.
1679	**
1680	** Returns:
1681	** The mapping, if found.
1682	** NULL if no mapping found.
1683	**
1684	** Side Effects:
1685	** Looks up the host specified in hbuf. If it is not
1686	** the canonical name for that host, return the canonical
1687	** name (unless MF_MATCHONLY is set, which will cause the
1688	** status only to be returned).
1689	*/
1690
1691	char *
1692	host_map_lookup(map, name, av, statp)
1693	MAP *map;
1694	char *name;
1695	char **av;
1696	int *statp;
1697	{
1698	register struct hostent *hp;
1699	struct in_addr in_addr;
1700	char *cp;
1701	register STAB *s;
1702	char hbuf[MAXNAME + 1];
1703
1704	/*
1705	** See if we have already looked up this name. If so, just
1706	** return it.
1707	*/
1708
1709	s = stab(name, ST_NAMECANON, ST_ENTER);
1710	if (bitset(NCF_VALID, s->s_namecanon.nc_flags))
1711	{
1712	if (tTd(9, 1))
1713	printf("host_map_lookup(%s) => CACHE %s\n",
1714	name,
1715	s->s_namecanon.nc_cname == NULL
1716	? "NULL"
1717	: s->s_namecanon.nc_cname);
1718	errno = s->s_namecanon.nc_errno;
1719	#if NAMED_BIND
1720	h_errno = s->s_namecanon.nc_herrno;
1721	#endif
1722	*statp = s->s_namecanon.nc_stat;
1723	if (*statp == EX_TEMPFAIL)
1724	{
1725	CurEnv->e_status = "4.4.3";
1726	message("851 %s: Name server timeout",
1727	shortenstring(name, 33));
1728	}
1729	if (*statp != EX_OK)
1730	return NULL;
1731	if (s->s_namecanon.nc_cname == NULL)
1732	{
1733	syserr("host_map_lookup(%s): bogus NULL cache entry, errno = %d, h_errno = %d",
1734	name,
1735	s->s_namecanon.nc_errno,
1736	s->s_namecanon.nc_herrno);
1737	return NULL;
1738	}
1739	if (bitset(MF_MATCHONLY, map->map_mflags))
1740	cp = map_rewrite(map, name, strlen(name), NULL);
1741	else
1742	cp = map_rewrite(map,
1743	s->s_namecanon.nc_cname,
1744	strlen(s->s_namecanon.nc_cname),
1745	av);
1746	return cp;
1747	}
1748
1749	/*
1750	** If we are running without a regular network connection (usually
1751	** dial-on-demand) and we are just queueing, we want to avoid DNS
1752	** lookups because those could try to connect to a server.
1753	*/
1754
1755	if (CurEnv->e_sendmode == SM_DEFER)
1756	{
1757	if (tTd(9, 1))
1758	printf("host_map_lookup(%s) => DEFERRED\n", name);
1759	*statp = EX_TEMPFAIL;
1760	return NULL;
1761	}
1762
1763	/*
1764	** If first character is a bracket, then it is an address
1765	** lookup. Address is copied into a temporary buffer to
1766	** strip the brackets and to preserve name if address is
1767	** unknown.
1768	*/
1769
1770	if (*name != '[')
1771	{
1772	if (tTd(9, 1))
1773	printf("host_map_lookup(%s) => ", name);
1774	s->s_namecanon.nc_flags \|= NCF_VALID; /* will be soon */
1775	snprintf(hbuf, sizeof hbuf, "%s", name);
1776	if (getcanonname(hbuf, sizeof hbuf - 1, !HasWildcardMX))
1777	{
1778	if (tTd(9, 1))
1779	printf("%s\n", hbuf);
1780	s->s_namecanon.nc_stat = EX_OK;
1781	s->s_namecanon.nc_cname = newstr(hbuf);
1782	if (bitset(MF_MATCHONLY, map->map_mflags))
1783	cp = map_rewrite(map, name, strlen(name), NULL);
1784	else
1785	cp = map_rewrite(map, hbuf, strlen(hbuf), av);
1786	return cp;
1787	}
1788	else
1789	{
1790	s->s_namecanon.nc_errno = errno;
1791	#if NAMED_BIND
1792	s->s_namecanon.nc_herrno = h_errno;
1793	if (tTd(9, 1))
1794	printf("FAIL (%d)\n", h_errno);
1795	switch (h_errno)
1796	{
1797	case TRY_AGAIN:
1798	if (UseNameServer)
1799	{
1800	CurEnv->e_status = "4.4.3";
1801	message("851 %s: Name server timeout",
1802	shortenstring(name, 33));
1803	}
1804	*statp = EX_TEMPFAIL;
1805	break;
1806
1807	case HOST_NOT_FOUND:
1808	case NO_DATA:
1809	*statp = EX_NOHOST;
1810	break;
1811
1812	case NO_RECOVERY:
1813	*statp = EX_SOFTWARE;
1814	break;
1815
1816	default:
1817	*statp = EX_UNAVAILABLE;
1818	break;
1819	}
1820	#else
1821	if (tTd(9, 1))
1822	printf("FAIL\n");
1823	*statp = EX_NOHOST;
1824	#endif
1825	s->s_namecanon.nc_stat = *statp;
1826	return NULL;
1827	}
1828	}
1829	if ((cp = strchr(name, ']')) == NULL)
1830	return (NULL);
1831	*cp = '\0';
1832	in_addr.s_addr = inet_addr(&name[1]);
1833	*cp = ']';
1834
1835	/* nope -- ask the name server */
1836	hp = sm_gethostbyaddr((char *)&in_addr, INADDRSZ, AF_INET);
1837	s->s_namecanon.nc_errno = errno;
1838	#if NAMED_BIND
1839	s->s_namecanon.nc_herrno = h_errno;
1840	#endif
1841	s->s_namecanon.nc_flags \|= NCF_VALID; /* will be soon */
1842	if (hp == NULL)
1843	{
1844	s->s_namecanon.nc_stat = *statp = EX_NOHOST;
1845	return (NULL);
1846	}
1847
1848	/* found a match -- copy out */
1849	hp->h_name = denlstring((char *) hp->h_name, TRUE, TRUE);
1850	s->s_namecanon.nc_stat = *statp = EX_OK;
1851	s->s_namecanon.nc_cname = newstr(hp->h_name);
1852	if (bitset(MF_MATCHONLY, map->map_mflags))
1853	cp = map_rewrite(map, name, strlen(name), NULL);
1854	else
1855	cp = map_rewrite(map, hp->h_name, strlen(hp->h_name), av);
1856	return cp;
1857	}
1858
1859	# else /* DAEMON */
1860	/* code for systems without sophisticated networking */
1861
1862	/*
1863	** MYHOSTNAME -- stub version for case of no daemon code.
1864	**
1865	** Can't convert to upper case here because might be a UUCP name.
1866	**
1867	** Mark, you can change this to be anything you want......
1868	*/
1869
1870	char **
1871	myhostname(hostbuf, size)
1872	char hostbuf[];
1873	int size;
1874	{
1875	register FILE *f;
1876
1877	hostbuf[0] = '\0';
1878	f = fopen("/usr/include/whoami", "r");
1879	if (f != NULL)
1880	{
1881	(void) fgets(hostbuf, size, f);
1882	fixcrlf(hostbuf, TRUE);
1883	(void) fclose(f);
1884	}
1885	return (NULL);
1886	}
1887	/*
1888	** GETAUTHINFO -- get the real host name asociated with a file descriptor
1889	**
1890	** Parameters:
1891	** fd -- the descriptor
1892	** may_be_forged -- an outage that is set to TRUE if the
1893	** forward lookup of RealHostName does not match
1894	** RealHostAddr; set to FALSE if they do match.
1895	**
1896	** Returns:
1897	** The host name associated with this descriptor, if it can
1898	** be determined.
1899	** NULL otherwise.
1900	**
1901	** Side Effects:
1902	** none
1903	*/
1904
1905	char *
1906	getauthinfo(fd, may_be_forged)
1907	int fd;
1908	bool *may_be_forged;
1909	{
1910	*may_be_forged = FALSE;
1911	return NULL;
1912	}
1913	/*
1914	** MAPHOSTNAME -- turn a hostname into canonical form
1915	**
1916	** Parameters:
1917	** map -- a pointer to the database map.
1918	** name -- a buffer containing a hostname.
1919	** avp -- a pointer to a (cf file defined) argument vector.
1920	** statp -- an exit status (out parameter).
1921	**
1922	** Returns:
1923	** mapped host name
1924	** FALSE otherwise.
1925	**
1926	** Side Effects:
1927	** Looks up the host specified in name. If it is not
1928	** the canonical name for that host, replace it with
1929	** the canonical name. If the name is unknown, or it
1930	** is already the canonical name, leave it unchanged.
1931	*/
1932
1933	/ARGSUSED/
1934	char *
1935	host_map_lookup(map, name, avp, statp)
1936	MAP *map;
1937	char *name;
1938	char **avp;
1939	char *statp;
1940	{
1941	register struct hostent *hp;
1942	char *cp;
1943
1944	hp = sm_gethostbyname(name);
1945	if (hp == NULL)
1946	{
1947	*statp = EX_NOHOST;
1948	return NULL;
1949	}
1950	if (bitset(MF_MATCHONLY, map->map_mflags))
1951	cp = map_rewrite(map, name, strlen(name), NULL);
1952	else
1953	cp = map_rewrite(map, hp->h_name, strlen(hp->h_name), avp);
1954	return cp;
1955	}
1956
1957	#endif /* DAEMON */
1958	/*
1959	** HOST_MAP_INIT -- initialize host class structures
1960	*/
1961
1962	bool
1963	host_map_init(map, args)
1964	MAP *map;
1965	char *args;
1966	{
1967	register char *p = args;
1968
1969	for (;;)
1970	{
1971	while (isascii(p) && isspace(p))
1972	p++;
1973	if (*p != '-')
1974	break;
1975	switch (*++p)
1976	{
1977	case 'a':
1978	map->map_app = ++p;
1979	break;
1980
1981	case 'T':
1982	map->map_tapp = ++p;
1983	break;
1984
1985	case 'm':
1986	map->map_mflags \|= MF_MATCHONLY;
1987	break;
1988
1989	case 't':
1990	map->map_mflags \|= MF_NODEFER;
1991	break;
1992	}
1993	while (p != '\0' && !(isascii(p) && isspace(*p)))
1994	p++;
1995	if (*p != '\0')
1996	*p++ = '\0';
1997	}
1998	if (map->map_app != NULL)
1999	map->map_app = newstr(map->map_app);
2000	if (map->map_tapp != NULL)
2001	map->map_tapp = newstr(map->map_tapp);
2002	return TRUE;
2003	}
2004	/*
2005	** ANYNET_NTOA -- convert a network address to printable form.
2006	**
2007	** Parameters:
2008	** sap -- a pointer to a sockaddr structure.
2009	**
2010	** Returns:
2011	** A printable version of that sockaddr.
2012	*/
2013
2014	#ifdef USE_SOCK_STREAM
2015
2016	#if NETLINK
2017	# include <net/if_dl.h>
2018	#endif
2019
2020	char *
2021	anynet_ntoa(sap)
2022	register SOCKADDR *sap;
2023	{
2024	register char *bp;
2025	register char *ap;
2026	int l;
2027	static char buf[100];
2028
2029	/* check for null/zero family */
2030	if (sap == NULL)
2031	return "NULLADDR";
2032	if (sap->sa.sa_family == 0)
2033	return "0";
2034
2035	switch (sap->sa.sa_family)
2036	{
2037	#if NETUNIX
2038	case AF_UNIX:
2039	if (sap->sunix.sun_path[0] != '\0')
2040	snprintf(buf, sizeof buf, "[UNIX: %.64s]",
2041	sap->sunix.sun_path);
2042	else
2043	snprintf(buf, sizeof buf, "[UNIX: localhost]");
2044	return buf;
2045	#endif
2046
2047	#if NETINET
2048	case AF_INET:
2049	return inet_ntoa(sap->sin.sin_addr);
2050	#endif
2051
2052	#if NETLINK
2053	case AF_LINK:
2054	snprintf(buf, sizeof buf, "[LINK: %s]",
2055	link_ntoa((struct sockaddr_dl *) &sap->sa));
2056	return buf;
2057	#endif
2058	default:
2059	/* this case is needed when nothing is #defined */
2060	/* in order to keep the switch syntactically correct */
2061	break;
2062	}
2063
2064	/* unknown family -- just dump bytes */
2065	(void) snprintf(buf, sizeof buf, "Family %d: ", sap->sa.sa_family);
2066	bp = &buf[strlen(buf)];
2067	ap = sap->sa.sa_data;
2068	for (l = sizeof sap->sa.sa_data; --l >= 0; )
2069	{
2070	(void) snprintf(bp, SPACELEFT(buf, bp), "%02x:", *ap++ & 0377);
2071	bp += 3;
2072	}
2073	*--bp = '\0';
2074	return buf;
2075	}
2076	/*
2077	** HOSTNAMEBYANYADDR -- return name of host based on address
2078	**
2079	** Parameters:
2080	** sap -- SOCKADDR pointer
2081	**
2082	** Returns:
2083	** text representation of host name.
2084	**
2085	** Side Effects:
2086	** none.
2087	*/
2088
2089	char *
2090	hostnamebyanyaddr(sap)
2091	register SOCKADDR *sap;
2092	{
2093	register struct hostent *hp;
2094	int saveretry;
2095
2096	#if NAMED_BIND
2097	/* shorten name server timeout to avoid higher level timeouts */
2098	saveretry = _res.retry;
2099	_res.retry = 3;
2100	#endif /* NAMED_BIND */
2101
2102	switch (sap->sa.sa_family)
2103	{
2104	#if NETINET
2105	case AF_INET:
2106	hp = sm_gethostbyaddr((char *) &sap->sin.sin_addr,
2107	INADDRSZ,
2108	AF_INET);
2109	break;
2110	#endif
2111
2112	#if NETISO
2113	case AF_ISO:
2114	hp = sm_gethostbyaddr((char *) &sap->siso.siso_addr,
2115	sizeof sap->siso.siso_addr,
2116	AF_ISO);
2117	break;
2118	#endif
2119
2120	#if NETUNIX
2121	case AF_UNIX:
2122	hp = NULL;
2123	break;
2124	#endif
2125
2126	default:
2127	hp = sm_gethostbyaddr(sap->sa.sa_data,
2128	sizeof sap->sa.sa_data,
2129	sap->sa.sa_family);
2130	break;
2131	}
2132
2133	#if NAMED_BIND
2134	_res.retry = saveretry;
2135	#endif /* NAMED_BIND */
2136
2137	if (hp != NULL && hp->h_name[0] != '[' &&
2138	inet_addr(hp->h_name) == INADDR_NONE)
2139	return denlstring((char *) hp->h_name, TRUE, TRUE);
2140	#if NETUNIX
2141	else if (sap->sa.sa_family == AF_UNIX && sap->sunix.sun_path[0] == '\0')
2142	return "localhost";
2143	#endif
2144	else
2145	{
2146	/* produce a dotted quad */
2147	static char buf[203];
2148
2149	(void) snprintf(buf, sizeof buf, "[%.200s]", anynet_ntoa(sap));
2150	return buf;
2151	}
2152	}
2153
2154	#endif /* SOCK_STREAM */

Note: See TracBrowser for help on using the repository browser.

Download in other formats: