xref: /freebsd/contrib/sendmail/src/mci.c (revision 7660b554bc59a07be0431c17e0e33815818baa69)
1c2aa98e2SPeter Wemm /*
2f9218d3dSGregory Neil Shapiro  * Copyright (c) 1998-2003 Sendmail, Inc. and its suppliers.
33299c2f1SGregory Neil Shapiro  *	All rights reserved.
4c2aa98e2SPeter Wemm  * Copyright (c) 1995-1997 Eric P. Allman.  All rights reserved.
5c2aa98e2SPeter Wemm  * Copyright (c) 1988, 1993
6c2aa98e2SPeter Wemm  *	The Regents of the University of California.  All rights reserved.
7c2aa98e2SPeter Wemm  *
8c2aa98e2SPeter Wemm  * By using this file, you agree to the terms and conditions set
9c2aa98e2SPeter Wemm  * forth in the LICENSE file which can be found at the top level of
10c2aa98e2SPeter Wemm  * the sendmail distribution.
11c2aa98e2SPeter Wemm  *
127660b554SGregory Neil Shapiro  * $FreeBSD$
13c2aa98e2SPeter Wemm  */
14c2aa98e2SPeter Wemm 
153299c2f1SGregory Neil Shapiro #include <sendmail.h>
163299c2f1SGregory Neil Shapiro 
177660b554SGregory Neil Shapiro SM_RCSID("@(#)$Id: mci.c,v 8.205.2.4 2003/03/31 17:35:27 ca Exp $")
183299c2f1SGregory Neil Shapiro 
193299c2f1SGregory Neil Shapiro #if NETINET || NETINET6
20c2aa98e2SPeter Wemm # include <arpa/inet.h>
213299c2f1SGregory Neil Shapiro #endif /* NETINET || NETINET6 */
223299c2f1SGregory Neil Shapiro 
23c2aa98e2SPeter Wemm #include <dirent.h>
24c2aa98e2SPeter Wemm 
253299c2f1SGregory Neil Shapiro static int	mci_generate_persistent_path __P((const char *, char *,
263299c2f1SGregory Neil Shapiro 						  int, bool));
273299c2f1SGregory Neil Shapiro static bool	mci_load_persistent __P((MCI *));
283299c2f1SGregory Neil Shapiro static void	mci_uncache __P((MCI **, bool));
293299c2f1SGregory Neil Shapiro static int	mci_lock_host_statfile __P((MCI *));
3012ed1c7cSGregory Neil Shapiro static int	mci_read_persistent __P((SM_FILE_T *, MCI *));
313299c2f1SGregory Neil Shapiro 
32c2aa98e2SPeter Wemm /*
33c2aa98e2SPeter Wemm **  Mail Connection Information (MCI) Caching Module.
34c2aa98e2SPeter Wemm **
35c2aa98e2SPeter Wemm **	There are actually two separate things cached.  The first is
36c2aa98e2SPeter Wemm **	the set of all open connections -- these are stored in a
37c2aa98e2SPeter Wemm **	(small) list.  The second is stored in the symbol table; it
38c2aa98e2SPeter Wemm **	has the overall status for all hosts, whether or not there
39c2aa98e2SPeter Wemm **	is a connection open currently.
40c2aa98e2SPeter Wemm **
41c2aa98e2SPeter Wemm **	There should never be too many connections open (since this
42c2aa98e2SPeter Wemm **	could flood the socket table), nor should a connection be
43c2aa98e2SPeter Wemm **	allowed to sit idly for too long.
44c2aa98e2SPeter Wemm **
45c2aa98e2SPeter Wemm **	MaxMciCache is the maximum number of open connections that
46c2aa98e2SPeter Wemm **	will be supported.
47c2aa98e2SPeter Wemm **
48c2aa98e2SPeter Wemm **	MciCacheTimeout is the time (in seconds) that a connection
49c2aa98e2SPeter Wemm **	is permitted to survive without activity.
50c2aa98e2SPeter Wemm **
51c2aa98e2SPeter Wemm **	We actually try any cached connections by sending a NOOP
52c2aa98e2SPeter Wemm **	before we use them; if the NOOP fails we close down the
53c2aa98e2SPeter Wemm **	connection and reopen it.  Note that this means that a
54c2aa98e2SPeter Wemm **	server SMTP that doesn't support NOOP will hose the
55c2aa98e2SPeter Wemm **	algorithm -- but that doesn't seem too likely.
56c2aa98e2SPeter Wemm **
57c2aa98e2SPeter Wemm **	The persistent MCI code is donated by Mark Lovell and Paul
58c2aa98e2SPeter Wemm **	Vixie.  It is based on the long term host status code in KJS
59c2aa98e2SPeter Wemm **	written by Paul but has been adapted by Mark to fit into the
60c2aa98e2SPeter Wemm **	MCI structure.
61c2aa98e2SPeter Wemm */
62c2aa98e2SPeter Wemm 
633299c2f1SGregory Neil Shapiro static MCI	**MciCache;		/* the open connection cache */
64c2aa98e2SPeter Wemm 
6512ed1c7cSGregory Neil Shapiro /*
66c2aa98e2SPeter Wemm **  MCI_CACHE -- enter a connection structure into the open connection cache
67c2aa98e2SPeter Wemm **
68c2aa98e2SPeter Wemm **	This may cause something else to be flushed.
69c2aa98e2SPeter Wemm **
70c2aa98e2SPeter Wemm **	Parameters:
71c2aa98e2SPeter Wemm **		mci -- the connection to cache.
72c2aa98e2SPeter Wemm **
73c2aa98e2SPeter Wemm **	Returns:
74c2aa98e2SPeter Wemm **		none.
75c2aa98e2SPeter Wemm */
76c2aa98e2SPeter Wemm 
77c2aa98e2SPeter Wemm void
78c2aa98e2SPeter Wemm mci_cache(mci)
79c2aa98e2SPeter Wemm 	register MCI *mci;
80c2aa98e2SPeter Wemm {
81c2aa98e2SPeter Wemm 	register MCI **mcislot;
82c2aa98e2SPeter Wemm 
83c2aa98e2SPeter Wemm 	/*
84c2aa98e2SPeter Wemm 	**  Find the best slot.  This may cause expired connections
85c2aa98e2SPeter Wemm 	**  to be closed.
86c2aa98e2SPeter Wemm 	*/
87c2aa98e2SPeter Wemm 
88c2aa98e2SPeter Wemm 	mcislot = mci_scan(mci);
89c2aa98e2SPeter Wemm 	if (mcislot == NULL)
90c2aa98e2SPeter Wemm 	{
91c2aa98e2SPeter Wemm 		/* we don't support caching */
92c2aa98e2SPeter Wemm 		return;
93c2aa98e2SPeter Wemm 	}
94c2aa98e2SPeter Wemm 
95c2aa98e2SPeter Wemm 	if (mci->mci_host == NULL)
96c2aa98e2SPeter Wemm 		return;
97c2aa98e2SPeter Wemm 
98c2aa98e2SPeter Wemm 	/* if this is already cached, we are done */
99c2aa98e2SPeter Wemm 	if (bitset(MCIF_CACHED, mci->mci_flags))
100c2aa98e2SPeter Wemm 		return;
101c2aa98e2SPeter Wemm 
102c2aa98e2SPeter Wemm 	/* otherwise we may have to clear the slot */
103c2aa98e2SPeter Wemm 	if (*mcislot != NULL)
10412ed1c7cSGregory Neil Shapiro 		mci_uncache(mcislot, true);
105c2aa98e2SPeter Wemm 
106c2aa98e2SPeter Wemm 	if (tTd(42, 5))
10712ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_cache: caching %p (%s) in slot %d\n",
10812ed1c7cSGregory Neil Shapiro 			   mci, mci->mci_host, (int) (mcislot - MciCache));
109c2aa98e2SPeter Wemm 	if (tTd(91, 100))
110c2aa98e2SPeter Wemm 		sm_syslog(LOG_DEBUG, CurEnv->e_id,
1113299c2f1SGregory Neil Shapiro 			  "mci_cache: caching %lx (%.100s) in slot %d",
11212ed1c7cSGregory Neil Shapiro 			  (unsigned long) mci, mci->mci_host,
11312ed1c7cSGregory Neil Shapiro 			  (int) (mcislot - MciCache));
114c2aa98e2SPeter Wemm 
115c2aa98e2SPeter Wemm 	*mcislot = mci;
116c2aa98e2SPeter Wemm 	mci->mci_flags |= MCIF_CACHED;
117c2aa98e2SPeter Wemm }
11812ed1c7cSGregory Neil Shapiro /*
119c2aa98e2SPeter Wemm **  MCI_SCAN -- scan the cache, flush junk, and return best slot
120c2aa98e2SPeter Wemm **
121c2aa98e2SPeter Wemm **	Parameters:
122c2aa98e2SPeter Wemm **		savemci -- never flush this one.  Can be null.
123c2aa98e2SPeter Wemm **
124c2aa98e2SPeter Wemm **	Returns:
125c2aa98e2SPeter Wemm **		The LRU (or empty) slot.
126c2aa98e2SPeter Wemm */
127c2aa98e2SPeter Wemm 
128c2aa98e2SPeter Wemm MCI **
129c2aa98e2SPeter Wemm mci_scan(savemci)
130c2aa98e2SPeter Wemm 	MCI *savemci;
131c2aa98e2SPeter Wemm {
132c2aa98e2SPeter Wemm 	time_t now;
133c2aa98e2SPeter Wemm 	register MCI **bestmci;
134c2aa98e2SPeter Wemm 	register MCI *mci;
135c2aa98e2SPeter Wemm 	register int i;
136c2aa98e2SPeter Wemm 
137c2aa98e2SPeter Wemm 	if (MaxMciCache <= 0)
138c2aa98e2SPeter Wemm 	{
139c2aa98e2SPeter Wemm 		/* we don't support caching */
140c2aa98e2SPeter Wemm 		return NULL;
141c2aa98e2SPeter Wemm 	}
142c2aa98e2SPeter Wemm 
143c2aa98e2SPeter Wemm 	if (MciCache == NULL)
144c2aa98e2SPeter Wemm 	{
145c2aa98e2SPeter Wemm 		/* first call */
14612ed1c7cSGregory Neil Shapiro 		MciCache = (MCI **) sm_pmalloc_x(MaxMciCache * sizeof *MciCache);
1473299c2f1SGregory Neil Shapiro 		memset((char *) MciCache, '\0', MaxMciCache * sizeof *MciCache);
1483299c2f1SGregory Neil Shapiro 		return &MciCache[0];
149c2aa98e2SPeter Wemm 	}
150c2aa98e2SPeter Wemm 
151c2aa98e2SPeter Wemm 	now = curtime();
152c2aa98e2SPeter Wemm 	bestmci = &MciCache[0];
153c2aa98e2SPeter Wemm 	for (i = 0; i < MaxMciCache; i++)
154c2aa98e2SPeter Wemm 	{
155c2aa98e2SPeter Wemm 		mci = MciCache[i];
156c2aa98e2SPeter Wemm 		if (mci == NULL || mci->mci_state == MCIS_CLOSED)
157c2aa98e2SPeter Wemm 		{
158c2aa98e2SPeter Wemm 			bestmci = &MciCache[i];
159c2aa98e2SPeter Wemm 			continue;
160c2aa98e2SPeter Wemm 		}
161320f00e7SGregory Neil Shapiro 		if ((mci->mci_lastuse + MciCacheTimeout <= now ||
1623299c2f1SGregory Neil Shapiro 		     (mci->mci_mailer != NULL &&
1633299c2f1SGregory Neil Shapiro 		      mci->mci_mailer->m_maxdeliveries > 0 &&
1643299c2f1SGregory Neil Shapiro 		      mci->mci_deliveries + 1 >= mci->mci_mailer->m_maxdeliveries))&&
1653299c2f1SGregory Neil Shapiro 		    mci != savemci)
166c2aa98e2SPeter Wemm 		{
1673299c2f1SGregory Neil Shapiro 			/* connection idle too long or too many deliveries */
168c2aa98e2SPeter Wemm 			bestmci = &MciCache[i];
1693299c2f1SGregory Neil Shapiro 
1703299c2f1SGregory Neil Shapiro 			/* close it */
17112ed1c7cSGregory Neil Shapiro 			mci_uncache(bestmci, true);
172c2aa98e2SPeter Wemm 			continue;
173c2aa98e2SPeter Wemm 		}
174c2aa98e2SPeter Wemm 		if (*bestmci == NULL)
175c2aa98e2SPeter Wemm 			continue;
176c2aa98e2SPeter Wemm 		if (mci->mci_lastuse < (*bestmci)->mci_lastuse)
177c2aa98e2SPeter Wemm 			bestmci = &MciCache[i];
178c2aa98e2SPeter Wemm 	}
179c2aa98e2SPeter Wemm 	return bestmci;
180c2aa98e2SPeter Wemm }
18112ed1c7cSGregory Neil Shapiro /*
182c2aa98e2SPeter Wemm **  MCI_UNCACHE -- remove a connection from a slot.
183c2aa98e2SPeter Wemm **
184c2aa98e2SPeter Wemm **	May close a connection.
185c2aa98e2SPeter Wemm **
186c2aa98e2SPeter Wemm **	Parameters:
187c2aa98e2SPeter Wemm **		mcislot -- the slot to empty.
18812ed1c7cSGregory Neil Shapiro **		doquit -- if true, send QUIT protocol on this connection.
18912ed1c7cSGregory Neil Shapiro **			  if false, we are assumed to be in a forked child;
190c2aa98e2SPeter Wemm **				all we want to do is close the file(s).
191c2aa98e2SPeter Wemm **
192c2aa98e2SPeter Wemm **	Returns:
193c2aa98e2SPeter Wemm **		none.
194c2aa98e2SPeter Wemm */
195c2aa98e2SPeter Wemm 
1963299c2f1SGregory Neil Shapiro static void
197c2aa98e2SPeter Wemm mci_uncache(mcislot, doquit)
198c2aa98e2SPeter Wemm 	register MCI **mcislot;
199c2aa98e2SPeter Wemm 	bool doquit;
200c2aa98e2SPeter Wemm {
201c2aa98e2SPeter Wemm 	register MCI *mci;
202c2aa98e2SPeter Wemm 	extern ENVELOPE BlankEnvelope;
203c2aa98e2SPeter Wemm 
204c2aa98e2SPeter Wemm 	mci = *mcislot;
205c2aa98e2SPeter Wemm 	if (mci == NULL)
206c2aa98e2SPeter Wemm 		return;
207c2aa98e2SPeter Wemm 	*mcislot = NULL;
208c2aa98e2SPeter Wemm 	if (mci->mci_host == NULL)
209c2aa98e2SPeter Wemm 		return;
210c2aa98e2SPeter Wemm 
211c2aa98e2SPeter Wemm 	mci_unlock_host(mci);
212c2aa98e2SPeter Wemm 
213c2aa98e2SPeter Wemm 	if (tTd(42, 5))
21412ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_uncache: uncaching %p (%s) from slot %d (%d)\n",
21512ed1c7cSGregory Neil Shapiro 			   mci, mci->mci_host, (int) (mcislot - MciCache),
21612ed1c7cSGregory Neil Shapiro 			   doquit);
217c2aa98e2SPeter Wemm 	if (tTd(91, 100))
218c2aa98e2SPeter Wemm 		sm_syslog(LOG_DEBUG, CurEnv->e_id,
2193299c2f1SGregory Neil Shapiro 			  "mci_uncache: uncaching %lx (%.100s) from slot %d (%d)",
22012ed1c7cSGregory Neil Shapiro 			  (unsigned long) mci, mci->mci_host,
22112ed1c7cSGregory Neil Shapiro 			  (int) (mcislot - MciCache), doquit);
222c2aa98e2SPeter Wemm 
2233299c2f1SGregory Neil Shapiro 	mci->mci_deliveries = 0;
224c2aa98e2SPeter Wemm 	if (doquit)
225c2aa98e2SPeter Wemm 	{
226c2aa98e2SPeter Wemm 		message("Closing connection to %s", mci->mci_host);
227c2aa98e2SPeter Wemm 
228c2aa98e2SPeter Wemm 		mci->mci_flags &= ~MCIF_CACHED;
229c2aa98e2SPeter Wemm 
230c2aa98e2SPeter Wemm 		/* only uses the envelope to flush the transcript file */
231c2aa98e2SPeter Wemm 		if (mci->mci_state != MCIS_CLOSED)
232c2aa98e2SPeter Wemm 			smtpquit(mci->mci_mailer, mci, &BlankEnvelope);
23312ed1c7cSGregory Neil Shapiro #if XLA
234c2aa98e2SPeter Wemm 		xla_host_end(mci->mci_host);
2353299c2f1SGregory Neil Shapiro #endif /* XLA */
236c2aa98e2SPeter Wemm 	}
237c2aa98e2SPeter Wemm 	else
238c2aa98e2SPeter Wemm 	{
239c2aa98e2SPeter Wemm 		if (mci->mci_in != NULL)
24012ed1c7cSGregory Neil Shapiro 			(void) sm_io_close(mci->mci_in, SM_TIME_DEFAULT);
241c2aa98e2SPeter Wemm 		if (mci->mci_out != NULL)
24212ed1c7cSGregory Neil Shapiro 			(void) sm_io_close(mci->mci_out, SM_TIME_DEFAULT);
243c2aa98e2SPeter Wemm 		mci->mci_in = mci->mci_out = NULL;
244c2aa98e2SPeter Wemm 		mci->mci_state = MCIS_CLOSED;
245c2aa98e2SPeter Wemm 		mci->mci_exitstat = EX_OK;
246c2aa98e2SPeter Wemm 		mci->mci_errno = 0;
247c2aa98e2SPeter Wemm 		mci->mci_flags = 0;
24812ed1c7cSGregory Neil Shapiro 
24912ed1c7cSGregory Neil Shapiro 		mci->mci_retryrcpt = false;
25012ed1c7cSGregory Neil Shapiro 		mci->mci_tolist = NULL;
25112ed1c7cSGregory Neil Shapiro #if PIPELINING
25212ed1c7cSGregory Neil Shapiro 		mci->mci_okrcpts = 0;
25312ed1c7cSGregory Neil Shapiro #endif /* PIPELINING */
25412ed1c7cSGregory Neil Shapiro 	}
25512ed1c7cSGregory Neil Shapiro 
25612ed1c7cSGregory Neil Shapiro 	SM_FREE_CLR(mci->mci_status);
25712ed1c7cSGregory Neil Shapiro 	SM_FREE_CLR(mci->mci_rstatus);
25812ed1c7cSGregory Neil Shapiro 	SM_FREE_CLR(mci->mci_heloname);
25912ed1c7cSGregory Neil Shapiro 	if (mci->mci_rpool != NULL)
26012ed1c7cSGregory Neil Shapiro 	{
26112ed1c7cSGregory Neil Shapiro 		sm_rpool_free(mci->mci_rpool);
26212ed1c7cSGregory Neil Shapiro 		mci->mci_macro.mac_rpool = NULL;
26312ed1c7cSGregory Neil Shapiro 		mci->mci_rpool = NULL;
264c2aa98e2SPeter Wemm 	}
265c2aa98e2SPeter Wemm }
26612ed1c7cSGregory Neil Shapiro /*
267c2aa98e2SPeter Wemm **  MCI_FLUSH -- flush the entire cache
268c2aa98e2SPeter Wemm **
269c2aa98e2SPeter Wemm **	Parameters:
27012ed1c7cSGregory Neil Shapiro **		doquit -- if true, send QUIT protocol.
27112ed1c7cSGregory Neil Shapiro **			  if false, just close the connection.
272c2aa98e2SPeter Wemm **		allbut -- but leave this one open.
273c2aa98e2SPeter Wemm **
274c2aa98e2SPeter Wemm **	Returns:
275c2aa98e2SPeter Wemm **		none.
276c2aa98e2SPeter Wemm */
277c2aa98e2SPeter Wemm 
278c2aa98e2SPeter Wemm void
279c2aa98e2SPeter Wemm mci_flush(doquit, allbut)
280c2aa98e2SPeter Wemm 	bool doquit;
281c2aa98e2SPeter Wemm 	MCI *allbut;
282c2aa98e2SPeter Wemm {
283c2aa98e2SPeter Wemm 	register int i;
284c2aa98e2SPeter Wemm 
285c2aa98e2SPeter Wemm 	if (MciCache == NULL)
286c2aa98e2SPeter Wemm 		return;
287c2aa98e2SPeter Wemm 
288c2aa98e2SPeter Wemm 	for (i = 0; i < MaxMciCache; i++)
289c46d91b7SGregory Neil Shapiro 	{
290c2aa98e2SPeter Wemm 		if (allbut != MciCache[i])
291c2aa98e2SPeter Wemm 			mci_uncache(&MciCache[i], doquit);
292c2aa98e2SPeter Wemm 	}
293c46d91b7SGregory Neil Shapiro }
29412ed1c7cSGregory Neil Shapiro /*
295c2aa98e2SPeter Wemm **  MCI_GET -- get information about a particular host
29612ed1c7cSGregory Neil Shapiro **
29712ed1c7cSGregory Neil Shapiro **	Parameters:
29812ed1c7cSGregory Neil Shapiro **		host -- host to look for.
29912ed1c7cSGregory Neil Shapiro **		m -- mailer.
30012ed1c7cSGregory Neil Shapiro **
30112ed1c7cSGregory Neil Shapiro **	Returns:
30212ed1c7cSGregory Neil Shapiro **		mci for this host (might be new).
303c2aa98e2SPeter Wemm */
304c2aa98e2SPeter Wemm 
305c2aa98e2SPeter Wemm MCI *
306c2aa98e2SPeter Wemm mci_get(host, m)
307c2aa98e2SPeter Wemm 	char *host;
308c2aa98e2SPeter Wemm 	MAILER *m;
309c2aa98e2SPeter Wemm {
310c2aa98e2SPeter Wemm 	register MCI *mci;
311c2aa98e2SPeter Wemm 	register STAB *s;
312c2aa98e2SPeter Wemm 	extern SOCKADDR CurHostAddr;
313c2aa98e2SPeter Wemm 
314c2aa98e2SPeter Wemm 	/* clear CurHostAddr so we don't get a bogus address with this name */
3153299c2f1SGregory Neil Shapiro 	memset(&CurHostAddr, '\0', sizeof CurHostAddr);
316c2aa98e2SPeter Wemm 
317c2aa98e2SPeter Wemm 	/* clear out any expired connections */
318c2aa98e2SPeter Wemm 	(void) mci_scan(NULL);
319c2aa98e2SPeter Wemm 
320c2aa98e2SPeter Wemm 	if (m->m_mno < 0)
321c46d91b7SGregory Neil Shapiro 		syserr("!negative mno %d (%s)", m->m_mno, m->m_name);
3223299c2f1SGregory Neil Shapiro 
323c2aa98e2SPeter Wemm 	s = stab(host, ST_MCI + m->m_mno, ST_ENTER);
324c2aa98e2SPeter Wemm 	mci = &s->s_mci;
325c2aa98e2SPeter Wemm 
32612ed1c7cSGregory Neil Shapiro 	/* initialize per-message data */
32712ed1c7cSGregory Neil Shapiro 	mci->mci_retryrcpt = false;
32812ed1c7cSGregory Neil Shapiro 	mci->mci_tolist = NULL;
32912ed1c7cSGregory Neil Shapiro #if PIPELINING
33012ed1c7cSGregory Neil Shapiro 	mci->mci_okrcpts = 0;
33112ed1c7cSGregory Neil Shapiro #endif /* PIPELINING */
33212ed1c7cSGregory Neil Shapiro 
33312ed1c7cSGregory Neil Shapiro 	if (mci->mci_rpool == NULL)
33412ed1c7cSGregory Neil Shapiro 		mci->mci_rpool = sm_rpool_new_x(NULL);
33512ed1c7cSGregory Neil Shapiro 
33612ed1c7cSGregory Neil Shapiro 	if (mci->mci_macro.mac_rpool == NULL)
33712ed1c7cSGregory Neil Shapiro 		mci->mci_macro.mac_rpool = mci->mci_rpool;
33812ed1c7cSGregory Neil Shapiro 
3393299c2f1SGregory Neil Shapiro 	/*
34012ed1c7cSGregory Neil Shapiro 	**  We don't need to load the persistent data if we have data
3413299c2f1SGregory Neil Shapiro 	**  already loaded in the cache.
3423299c2f1SGregory Neil Shapiro 	*/
3433299c2f1SGregory Neil Shapiro 
3443299c2f1SGregory Neil Shapiro 	if (mci->mci_host == NULL &&
3453299c2f1SGregory Neil Shapiro 	    (mci->mci_host = s->s_name) != NULL &&
3463299c2f1SGregory Neil Shapiro 	    !mci_load_persistent(mci))
347c2aa98e2SPeter Wemm 	{
348c2aa98e2SPeter Wemm 		if (tTd(42, 2))
34912ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_get(%s %s): lock failed\n",
3503299c2f1SGregory Neil Shapiro 				host, m->m_name);
351c2aa98e2SPeter Wemm 		mci->mci_exitstat = EX_TEMPFAIL;
352c2aa98e2SPeter Wemm 		mci->mci_state = MCIS_CLOSED;
353c2aa98e2SPeter Wemm 		mci->mci_statfile = NULL;
354c2aa98e2SPeter Wemm 		return mci;
355c2aa98e2SPeter Wemm 	}
356c2aa98e2SPeter Wemm 
357c2aa98e2SPeter Wemm 	if (tTd(42, 2))
358c2aa98e2SPeter Wemm 	{
35912ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_get(%s %s): mci_state=%d, _flags=%lx, _exitstat=%d, _errno=%d\n",
360c2aa98e2SPeter Wemm 			host, m->m_name, mci->mci_state, mci->mci_flags,
361c2aa98e2SPeter Wemm 			mci->mci_exitstat, mci->mci_errno);
362c2aa98e2SPeter Wemm 	}
363c2aa98e2SPeter Wemm 
364c2aa98e2SPeter Wemm 	if (mci->mci_state == MCIS_OPEN)
365c2aa98e2SPeter Wemm 	{
366c2aa98e2SPeter Wemm 		/* poke the connection to see if it's still alive */
367c2aa98e2SPeter Wemm 		(void) smtpprobe(mci);
368c2aa98e2SPeter Wemm 
369c2aa98e2SPeter Wemm 		/* reset the stored state in the event of a timeout */
370c2aa98e2SPeter Wemm 		if (mci->mci_state != MCIS_OPEN)
371c2aa98e2SPeter Wemm 		{
372c2aa98e2SPeter Wemm 			mci->mci_errno = 0;
373c2aa98e2SPeter Wemm 			mci->mci_exitstat = EX_OK;
374c2aa98e2SPeter Wemm 			mci->mci_state = MCIS_CLOSED;
375c2aa98e2SPeter Wemm 		}
376c2aa98e2SPeter Wemm 		else
377c2aa98e2SPeter Wemm 		{
37812ed1c7cSGregory Neil Shapiro 			/* get peer host address */
379c2aa98e2SPeter Wemm 			/* (this should really be in the mci struct) */
380c2aa98e2SPeter Wemm 			SOCKADDR_LEN_T socklen = sizeof CurHostAddr;
381c2aa98e2SPeter Wemm 
38212ed1c7cSGregory Neil Shapiro 			(void) getpeername(sm_io_getinfo(mci->mci_in,
38312ed1c7cSGregory Neil Shapiro 							 SM_IO_WHAT_FD, NULL),
384c2aa98e2SPeter Wemm 				(struct sockaddr *) &CurHostAddr, &socklen);
385c2aa98e2SPeter Wemm 		}
386c2aa98e2SPeter Wemm 	}
387c2aa98e2SPeter Wemm 	if (mci->mci_state == MCIS_CLOSED)
388c2aa98e2SPeter Wemm 	{
389c2aa98e2SPeter Wemm 		time_t now = curtime();
390c2aa98e2SPeter Wemm 
391c2aa98e2SPeter Wemm 		/* if this info is stale, ignore it */
392320f00e7SGregory Neil Shapiro 		if (mci->mci_lastuse + MciInfoTimeout <= now)
393c2aa98e2SPeter Wemm 		{
394c2aa98e2SPeter Wemm 			mci->mci_lastuse = now;
395c2aa98e2SPeter Wemm 			mci->mci_errno = 0;
396c2aa98e2SPeter Wemm 			mci->mci_exitstat = EX_OK;
397c2aa98e2SPeter Wemm 		}
398c2aa98e2SPeter Wemm 	}
399c2aa98e2SPeter Wemm 
400c2aa98e2SPeter Wemm 	return mci;
401c2aa98e2SPeter Wemm }
40212ed1c7cSGregory Neil Shapiro /*
40312ed1c7cSGregory Neil Shapiro **  MCI_NEW -- allocate new MCI structure
40412ed1c7cSGregory Neil Shapiro **
40512ed1c7cSGregory Neil Shapiro **	Parameters:
40612ed1c7cSGregory Neil Shapiro **		rpool -- if non-NULL: allocate from that rpool.
40712ed1c7cSGregory Neil Shapiro **
40812ed1c7cSGregory Neil Shapiro **	Returns:
40912ed1c7cSGregory Neil Shapiro **		mci (new).
41012ed1c7cSGregory Neil Shapiro */
41112ed1c7cSGregory Neil Shapiro 
41212ed1c7cSGregory Neil Shapiro MCI *
41312ed1c7cSGregory Neil Shapiro mci_new(rpool)
41412ed1c7cSGregory Neil Shapiro 	SM_RPOOL_T *rpool;
41512ed1c7cSGregory Neil Shapiro {
41612ed1c7cSGregory Neil Shapiro 	register MCI *mci;
41712ed1c7cSGregory Neil Shapiro 
41812ed1c7cSGregory Neil Shapiro 	if (rpool == NULL)
41912ed1c7cSGregory Neil Shapiro 		mci = (MCI *) sm_malloc_x(sizeof *mci);
42012ed1c7cSGregory Neil Shapiro 	else
42112ed1c7cSGregory Neil Shapiro 		mci = (MCI *) sm_rpool_malloc_x(rpool, sizeof *mci);
42212ed1c7cSGregory Neil Shapiro 	memset((char *) mci, '\0', sizeof *mci);
42312ed1c7cSGregory Neil Shapiro 	mci->mci_rpool = sm_rpool_new_x(NULL);
42412ed1c7cSGregory Neil Shapiro 	mci->mci_macro.mac_rpool = mci->mci_rpool;
42512ed1c7cSGregory Neil Shapiro 	return mci;
42612ed1c7cSGregory Neil Shapiro }
42712ed1c7cSGregory Neil Shapiro /*
4283299c2f1SGregory Neil Shapiro **  MCI_MATCH -- check connection cache for a particular host
42912ed1c7cSGregory Neil Shapiro **
43012ed1c7cSGregory Neil Shapiro **	Parameters:
43112ed1c7cSGregory Neil Shapiro **		host -- host to look for.
43212ed1c7cSGregory Neil Shapiro **		m -- mailer.
43312ed1c7cSGregory Neil Shapiro **
43412ed1c7cSGregory Neil Shapiro **	Returns:
43512ed1c7cSGregory Neil Shapiro **		true iff open connection exists.
4363299c2f1SGregory Neil Shapiro */
4373299c2f1SGregory Neil Shapiro 
4383299c2f1SGregory Neil Shapiro bool
4393299c2f1SGregory Neil Shapiro mci_match(host, m)
4403299c2f1SGregory Neil Shapiro 	char *host;
4413299c2f1SGregory Neil Shapiro 	MAILER *m;
4423299c2f1SGregory Neil Shapiro {
4433299c2f1SGregory Neil Shapiro 	register MCI *mci;
4443299c2f1SGregory Neil Shapiro 	register STAB *s;
4453299c2f1SGregory Neil Shapiro 
446c46d91b7SGregory Neil Shapiro 	if (m->m_mno < 0 || m->m_mno > MAXMAILERS)
44712ed1c7cSGregory Neil Shapiro 		return false;
4483299c2f1SGregory Neil Shapiro 	s = stab(host, ST_MCI + m->m_mno, ST_FIND);
4493299c2f1SGregory Neil Shapiro 	if (s == NULL)
45012ed1c7cSGregory Neil Shapiro 		return false;
4513299c2f1SGregory Neil Shapiro 
4523299c2f1SGregory Neil Shapiro 	mci = &s->s_mci;
45312ed1c7cSGregory Neil Shapiro 	return mci->mci_state == MCIS_OPEN;
4543299c2f1SGregory Neil Shapiro }
45512ed1c7cSGregory Neil Shapiro /*
456c2aa98e2SPeter Wemm **  MCI_SETSTAT -- set status codes in MCI structure.
457c2aa98e2SPeter Wemm **
458c2aa98e2SPeter Wemm **	Parameters:
459c2aa98e2SPeter Wemm **		mci -- the MCI structure to set.
460c2aa98e2SPeter Wemm **		xstat -- the exit status code.
461c2aa98e2SPeter Wemm **		dstat -- the DSN status code.
462c2aa98e2SPeter Wemm **		rstat -- the SMTP status code.
463c2aa98e2SPeter Wemm **
464c2aa98e2SPeter Wemm **	Returns:
465c2aa98e2SPeter Wemm **		none.
466c2aa98e2SPeter Wemm */
467c2aa98e2SPeter Wemm 
468c2aa98e2SPeter Wemm void
469c2aa98e2SPeter Wemm mci_setstat(mci, xstat, dstat, rstat)
470c2aa98e2SPeter Wemm 	MCI *mci;
471c2aa98e2SPeter Wemm 	int xstat;
472c2aa98e2SPeter Wemm 	char *dstat;
473c2aa98e2SPeter Wemm 	char *rstat;
474c2aa98e2SPeter Wemm {
475c2aa98e2SPeter Wemm 	/* protocol errors should never be interpreted as sticky */
476c2aa98e2SPeter Wemm 	if (xstat != EX_NOTSTICKY && xstat != EX_PROTOCOL)
477c2aa98e2SPeter Wemm 		mci->mci_exitstat = xstat;
478c2aa98e2SPeter Wemm 
47912ed1c7cSGregory Neil Shapiro 	SM_FREE_CLR(mci->mci_status);
48012ed1c7cSGregory Neil Shapiro 	if (dstat != NULL)
48112ed1c7cSGregory Neil Shapiro 		mci->mci_status = sm_strdup_x(dstat);
48212ed1c7cSGregory Neil Shapiro 
48312ed1c7cSGregory Neil Shapiro 	SM_FREE_CLR(mci->mci_rstatus);
484c2aa98e2SPeter Wemm 	if (rstat != NULL)
48512ed1c7cSGregory Neil Shapiro 		mci->mci_rstatus = sm_strdup_x(rstat);
486c2aa98e2SPeter Wemm }
48712ed1c7cSGregory Neil Shapiro /*
488c2aa98e2SPeter Wemm **  MCI_DUMP -- dump the contents of an MCI structure.
489c2aa98e2SPeter Wemm **
490c2aa98e2SPeter Wemm **	Parameters:
491c2aa98e2SPeter Wemm **		mci -- the MCI structure to dump.
492c2aa98e2SPeter Wemm **
493c2aa98e2SPeter Wemm **	Returns:
494c2aa98e2SPeter Wemm **		none.
495c2aa98e2SPeter Wemm **
496c2aa98e2SPeter Wemm **	Side Effects:
497c2aa98e2SPeter Wemm **		none.
498c2aa98e2SPeter Wemm */
499c2aa98e2SPeter Wemm 
500c2aa98e2SPeter Wemm struct mcifbits
501c2aa98e2SPeter Wemm {
502c2aa98e2SPeter Wemm 	int	mcif_bit;	/* flag bit */
503c2aa98e2SPeter Wemm 	char	*mcif_name;	/* flag name */
504c2aa98e2SPeter Wemm };
5053299c2f1SGregory Neil Shapiro static struct mcifbits	MciFlags[] =
506c2aa98e2SPeter Wemm {
507c2aa98e2SPeter Wemm 	{ MCIF_VALID,		"VALID"		},
508c2aa98e2SPeter Wemm 	{ MCIF_CACHED,		"CACHED"	},
509c2aa98e2SPeter Wemm 	{ MCIF_ESMTP,		"ESMTP"		},
510c2aa98e2SPeter Wemm 	{ MCIF_EXPN,		"EXPN"		},
511c2aa98e2SPeter Wemm 	{ MCIF_SIZE,		"SIZE"		},
512c2aa98e2SPeter Wemm 	{ MCIF_8BITMIME,	"8BITMIME"	},
513c2aa98e2SPeter Wemm 	{ MCIF_7BIT,		"7BIT"		},
514c2aa98e2SPeter Wemm 	{ MCIF_INHEADER,	"INHEADER"	},
515c2aa98e2SPeter Wemm 	{ MCIF_CVT8TO7,		"CVT8TO7"	},
516c2aa98e2SPeter Wemm 	{ MCIF_DSN,		"DSN"		},
517c2aa98e2SPeter Wemm 	{ MCIF_8BITOK,		"8BITOK"	},
518c2aa98e2SPeter Wemm 	{ MCIF_CVT7TO8,		"CVT7TO8"	},
519c2aa98e2SPeter Wemm 	{ MCIF_INMIME,		"INMIME"	},
52012ed1c7cSGregory Neil Shapiro 	{ MCIF_AUTH,		"AUTH"		},
52112ed1c7cSGregory Neil Shapiro 	{ MCIF_AUTHACT,		"AUTHACT"	},
52212ed1c7cSGregory Neil Shapiro 	{ MCIF_ENHSTAT,		"ENHSTAT"	},
52312ed1c7cSGregory Neil Shapiro 	{ MCIF_PIPELINED,	"PIPELINED"	},
52412ed1c7cSGregory Neil Shapiro #if STARTTLS
52512ed1c7cSGregory Neil Shapiro 	{ MCIF_TLS,		"TLS"		},
52612ed1c7cSGregory Neil Shapiro 	{ MCIF_TLSACT,		"TLSACT"	},
52712ed1c7cSGregory Neil Shapiro #endif /* STARTTLS */
52812ed1c7cSGregory Neil Shapiro 	{ MCIF_DLVR_BY,		"DLVR_BY"	},
529c2aa98e2SPeter Wemm 	{ 0,			NULL		}
530c2aa98e2SPeter Wemm };
531c2aa98e2SPeter Wemm 
532c2aa98e2SPeter Wemm void
533c2aa98e2SPeter Wemm mci_dump(mci, logit)
534c2aa98e2SPeter Wemm 	register MCI *mci;
535c2aa98e2SPeter Wemm 	bool logit;
536c2aa98e2SPeter Wemm {
537c2aa98e2SPeter Wemm 	register char *p;
538c2aa98e2SPeter Wemm 	char *sep;
539c2aa98e2SPeter Wemm 	char buf[4000];
540c2aa98e2SPeter Wemm 
541c2aa98e2SPeter Wemm 	sep = logit ? " " : "\n\t";
542c2aa98e2SPeter Wemm 	p = buf;
54312ed1c7cSGregory Neil Shapiro 	(void) sm_snprintf(p, SPACELEFT(buf, p), "MCI@%p: ", mci);
544c2aa98e2SPeter Wemm 	p += strlen(p);
545c2aa98e2SPeter Wemm 	if (mci == NULL)
546c2aa98e2SPeter Wemm 	{
54712ed1c7cSGregory Neil Shapiro 		(void) sm_snprintf(p, SPACELEFT(buf, p), "NULL");
548c2aa98e2SPeter Wemm 		goto printit;
549c2aa98e2SPeter Wemm 	}
55012ed1c7cSGregory Neil Shapiro 	(void) sm_snprintf(p, SPACELEFT(buf, p), "flags=%lx", mci->mci_flags);
551c2aa98e2SPeter Wemm 	p += strlen(p);
5527660b554SGregory Neil Shapiro 
5537660b554SGregory Neil Shapiro 	/*
5547660b554SGregory Neil Shapiro 	**  The following check is just for paranoia.  It protects the
5557660b554SGregory Neil Shapiro 	**  assignment in the if() clause. If there's not some minimum
5567660b554SGregory Neil Shapiro 	**  amount of space we can stop right now. The check will not
5577660b554SGregory Neil Shapiro 	**  trigger as long as sizeof(buf)=4000.
5587660b554SGregory Neil Shapiro 	*/
5597660b554SGregory Neil Shapiro 
5607660b554SGregory Neil Shapiro 	if (p >= buf + sizeof(buf) - 4)
5617660b554SGregory Neil Shapiro 		goto printit;
562c2aa98e2SPeter Wemm 	if (mci->mci_flags != 0)
563c2aa98e2SPeter Wemm 	{
564c2aa98e2SPeter Wemm 		struct mcifbits *f;
565c2aa98e2SPeter Wemm 
5667660b554SGregory Neil Shapiro 		*p++ = '<';	/* protected above */
567c2aa98e2SPeter Wemm 		for (f = MciFlags; f->mcif_bit != 0; f++)
568c2aa98e2SPeter Wemm 		{
569c2aa98e2SPeter Wemm 			if (!bitset(f->mcif_bit, mci->mci_flags))
570c2aa98e2SPeter Wemm 				continue;
57112ed1c7cSGregory Neil Shapiro 			(void) sm_strlcpyn(p, SPACELEFT(buf, p), 2,
57212ed1c7cSGregory Neil Shapiro 					   f->mcif_name, ",");
573c2aa98e2SPeter Wemm 			p += strlen(p);
574c2aa98e2SPeter Wemm 		}
575c2aa98e2SPeter Wemm 		p[-1] = '>';
576c2aa98e2SPeter Wemm 	}
57712ed1c7cSGregory Neil Shapiro 
57812ed1c7cSGregory Neil Shapiro 	/* Note: sm_snprintf() takes care of NULL arguments for %s */
57912ed1c7cSGregory Neil Shapiro 	(void) sm_snprintf(p, SPACELEFT(buf, p),
580c2aa98e2SPeter Wemm 		",%serrno=%d, herrno=%d, exitstat=%d, state=%d, pid=%d,%s",
581c2aa98e2SPeter Wemm 		sep, mci->mci_errno, mci->mci_herrno,
5823299c2f1SGregory Neil Shapiro 		mci->mci_exitstat, mci->mci_state, (int) mci->mci_pid, sep);
583c2aa98e2SPeter Wemm 	p += strlen(p);
58412ed1c7cSGregory Neil Shapiro 	(void) sm_snprintf(p, SPACELEFT(buf, p),
585c2aa98e2SPeter Wemm 		"maxsize=%ld, phase=%s, mailer=%s,%s",
58612ed1c7cSGregory Neil Shapiro 		mci->mci_maxsize, mci->mci_phase,
587c2aa98e2SPeter Wemm 		mci->mci_mailer == NULL ? "NULL" : mci->mci_mailer->m_name,
588c2aa98e2SPeter Wemm 		sep);
589c2aa98e2SPeter Wemm 	p += strlen(p);
59012ed1c7cSGregory Neil Shapiro 	(void) sm_snprintf(p, SPACELEFT(buf, p),
591c2aa98e2SPeter Wemm 		"status=%s, rstatus=%s,%s",
59212ed1c7cSGregory Neil Shapiro 		mci->mci_status, mci->mci_rstatus, sep);
593c2aa98e2SPeter Wemm 	p += strlen(p);
59412ed1c7cSGregory Neil Shapiro 	(void) sm_snprintf(p, SPACELEFT(buf, p),
595c2aa98e2SPeter Wemm 		"host=%s, lastuse=%s",
59612ed1c7cSGregory Neil Shapiro 		mci->mci_host, ctime(&mci->mci_lastuse));
597c2aa98e2SPeter Wemm printit:
598c2aa98e2SPeter Wemm 	if (logit)
599c2aa98e2SPeter Wemm 		sm_syslog(LOG_DEBUG, CurEnv->e_id, "%.1000s", buf);
600c2aa98e2SPeter Wemm 	else
60112ed1c7cSGregory Neil Shapiro 		(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT, "%s\n", buf);
602c2aa98e2SPeter Wemm }
60312ed1c7cSGregory Neil Shapiro /*
604c2aa98e2SPeter Wemm **  MCI_DUMP_ALL -- print the entire MCI cache
605c2aa98e2SPeter Wemm **
606c2aa98e2SPeter Wemm **	Parameters:
607c2aa98e2SPeter Wemm **		logit -- if set, log the result instead of printing
608c2aa98e2SPeter Wemm **			to stdout.
609c2aa98e2SPeter Wemm **
610c2aa98e2SPeter Wemm **	Returns:
611c2aa98e2SPeter Wemm **		none.
612c2aa98e2SPeter Wemm */
613c2aa98e2SPeter Wemm 
614c2aa98e2SPeter Wemm void
615c2aa98e2SPeter Wemm mci_dump_all(logit)
616c2aa98e2SPeter Wemm 	bool logit;
617c2aa98e2SPeter Wemm {
618c2aa98e2SPeter Wemm 	register int i;
619c2aa98e2SPeter Wemm 
620c2aa98e2SPeter Wemm 	if (MciCache == NULL)
621c2aa98e2SPeter Wemm 		return;
622c2aa98e2SPeter Wemm 
623c2aa98e2SPeter Wemm 	for (i = 0; i < MaxMciCache; i++)
624c2aa98e2SPeter Wemm 		mci_dump(MciCache[i], logit);
625c2aa98e2SPeter Wemm }
62612ed1c7cSGregory Neil Shapiro /*
627c2aa98e2SPeter Wemm **  MCI_LOCK_HOST -- Lock host while sending.
628c2aa98e2SPeter Wemm **
629c2aa98e2SPeter Wemm **	If we are contacting a host, we'll need to
630c2aa98e2SPeter Wemm **	update the status information in the host status
631c2aa98e2SPeter Wemm **	file, and if we want to do that, we ought to have
632c2aa98e2SPeter Wemm **	locked it. This has the (according to some)
633c2aa98e2SPeter Wemm **	desirable effect of serializing connectivity with
63412ed1c7cSGregory Neil Shapiro **	remote hosts -- i.e.: one connection to a given
635c2aa98e2SPeter Wemm **	host at a time.
636c2aa98e2SPeter Wemm **
637c2aa98e2SPeter Wemm **	Parameters:
638c2aa98e2SPeter Wemm **		mci -- containing the host we want to lock.
639c2aa98e2SPeter Wemm **
640c2aa98e2SPeter Wemm **	Returns:
641c2aa98e2SPeter Wemm **		EX_OK	    -- got the lock.
642c2aa98e2SPeter Wemm **		EX_TEMPFAIL -- didn't get the lock.
643c2aa98e2SPeter Wemm */
644c2aa98e2SPeter Wemm 
645c2aa98e2SPeter Wemm int
646c2aa98e2SPeter Wemm mci_lock_host(mci)
647c2aa98e2SPeter Wemm 	MCI *mci;
648c2aa98e2SPeter Wemm {
649c2aa98e2SPeter Wemm 	if (mci == NULL)
650c2aa98e2SPeter Wemm 	{
651c2aa98e2SPeter Wemm 		if (tTd(56, 1))
65212ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_lock_host: NULL mci\n");
653c2aa98e2SPeter Wemm 		return EX_OK;
654c2aa98e2SPeter Wemm 	}
655c2aa98e2SPeter Wemm 
656c2aa98e2SPeter Wemm 	if (!SingleThreadDelivery)
657c2aa98e2SPeter Wemm 		return EX_OK;
658c2aa98e2SPeter Wemm 
659c2aa98e2SPeter Wemm 	return mci_lock_host_statfile(mci);
660c2aa98e2SPeter Wemm }
661c2aa98e2SPeter Wemm 
6623299c2f1SGregory Neil Shapiro static int
663c2aa98e2SPeter Wemm mci_lock_host_statfile(mci)
664c2aa98e2SPeter Wemm 	MCI *mci;
665c2aa98e2SPeter Wemm {
6663299c2f1SGregory Neil Shapiro 	int save_errno = errno;
667c2aa98e2SPeter Wemm 	int retVal = EX_OK;
66888ad41d4SGregory Neil Shapiro 	char fname[MAXPATHLEN];
669c2aa98e2SPeter Wemm 
670c2aa98e2SPeter Wemm 	if (HostStatDir == NULL || mci->mci_host == NULL)
671c2aa98e2SPeter Wemm 		return EX_OK;
672c2aa98e2SPeter Wemm 
673c2aa98e2SPeter Wemm 	if (tTd(56, 2))
67412ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_lock_host: attempting to lock %s\n",
675c2aa98e2SPeter Wemm 			   mci->mci_host);
676c2aa98e2SPeter Wemm 
67712ed1c7cSGregory Neil Shapiro 	if (mci_generate_persistent_path(mci->mci_host, fname, sizeof fname,
67812ed1c7cSGregory Neil Shapiro 					 true) < 0)
679c2aa98e2SPeter Wemm 	{
680c2aa98e2SPeter Wemm 		/* of course this should never happen */
681c2aa98e2SPeter Wemm 		if (tTd(56, 2))
68212ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_lock_host: Failed to generate host path for %s\n",
683c2aa98e2SPeter Wemm 				   mci->mci_host);
684c2aa98e2SPeter Wemm 
685c2aa98e2SPeter Wemm 		retVal = EX_TEMPFAIL;
686c2aa98e2SPeter Wemm 		goto cleanup;
687c2aa98e2SPeter Wemm 	}
688c2aa98e2SPeter Wemm 
689c2aa98e2SPeter Wemm 	mci->mci_statfile = safefopen(fname, O_RDWR, FileMode,
690c2aa98e2SPeter Wemm 				      SFF_NOLOCK|SFF_NOLINK|SFF_OPENASROOT|SFF_REGONLY|SFF_SAFEDIRPATH|SFF_CREAT);
691c2aa98e2SPeter Wemm 
692c2aa98e2SPeter Wemm 	if (mci->mci_statfile == NULL)
693c2aa98e2SPeter Wemm 	{
69412ed1c7cSGregory Neil Shapiro 		syserr("mci_lock_host: cannot create host lock file %s", fname);
695c2aa98e2SPeter Wemm 		goto cleanup;
696c2aa98e2SPeter Wemm 	}
697c2aa98e2SPeter Wemm 
69812ed1c7cSGregory Neil Shapiro 	if (!lockfile(sm_io_getinfo(mci->mci_statfile, SM_IO_WHAT_FD, NULL),
69912ed1c7cSGregory Neil Shapiro 		      fname, "", LOCK_EX|LOCK_NB))
700c2aa98e2SPeter Wemm 	{
701c2aa98e2SPeter Wemm 		if (tTd(56, 2))
70212ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_lock_host: couldn't get lock on %s\n",
703c2aa98e2SPeter Wemm 				fname);
70412ed1c7cSGregory Neil Shapiro 		(void) sm_io_close(mci->mci_statfile, SM_TIME_DEFAULT);
705c2aa98e2SPeter Wemm 		mci->mci_statfile = NULL;
706c2aa98e2SPeter Wemm 		retVal = EX_TEMPFAIL;
707c2aa98e2SPeter Wemm 		goto cleanup;
708c2aa98e2SPeter Wemm 	}
709c2aa98e2SPeter Wemm 
710c2aa98e2SPeter Wemm 	if (tTd(56, 12) && mci->mci_statfile != NULL)
71112ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_lock_host: Sanity check -- lock is good\n");
712c2aa98e2SPeter Wemm 
713c2aa98e2SPeter Wemm cleanup:
7143299c2f1SGregory Neil Shapiro 	errno = save_errno;
715c2aa98e2SPeter Wemm 	return retVal;
716c2aa98e2SPeter Wemm }
71712ed1c7cSGregory Neil Shapiro /*
718c2aa98e2SPeter Wemm **  MCI_UNLOCK_HOST -- unlock host
719c2aa98e2SPeter Wemm **
720c2aa98e2SPeter Wemm **	Clean up the lock on a host, close the file, let
721c2aa98e2SPeter Wemm **	someone else use it.
722c2aa98e2SPeter Wemm **
723c2aa98e2SPeter Wemm **	Parameters:
724c2aa98e2SPeter Wemm **		mci -- us.
725c2aa98e2SPeter Wemm **
726c2aa98e2SPeter Wemm **	Returns:
727c2aa98e2SPeter Wemm **		nothing.
728c2aa98e2SPeter Wemm */
729c2aa98e2SPeter Wemm 
730c2aa98e2SPeter Wemm void
731c2aa98e2SPeter Wemm mci_unlock_host(mci)
732c2aa98e2SPeter Wemm 	MCI *mci;
733c2aa98e2SPeter Wemm {
7343299c2f1SGregory Neil Shapiro 	int save_errno = errno;
735c2aa98e2SPeter Wemm 
736c2aa98e2SPeter Wemm 	if (mci == NULL)
737c2aa98e2SPeter Wemm 	{
738c2aa98e2SPeter Wemm 		if (tTd(56, 1))
73912ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_unlock_host: NULL mci\n");
740c2aa98e2SPeter Wemm 		return;
741c2aa98e2SPeter Wemm 	}
742c2aa98e2SPeter Wemm 
743c2aa98e2SPeter Wemm 	if (HostStatDir == NULL || mci->mci_host == NULL)
744c2aa98e2SPeter Wemm 		return;
745c2aa98e2SPeter Wemm 
746c2aa98e2SPeter Wemm 	if (!SingleThreadDelivery && mci_lock_host_statfile(mci) == EX_TEMPFAIL)
747c2aa98e2SPeter Wemm 	{
748c2aa98e2SPeter Wemm 		if (tTd(56, 1))
74912ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_unlock_host: stat file already locked\n");
750c2aa98e2SPeter Wemm 	}
751c2aa98e2SPeter Wemm 	else
752c2aa98e2SPeter Wemm 	{
753c2aa98e2SPeter Wemm 		if (tTd(56, 2))
75412ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_unlock_host: store prior to unlock\n");
755c2aa98e2SPeter Wemm 		mci_store_persistent(mci);
756c2aa98e2SPeter Wemm 	}
757c2aa98e2SPeter Wemm 
758c2aa98e2SPeter Wemm 	if (mci->mci_statfile != NULL)
759c2aa98e2SPeter Wemm 	{
76012ed1c7cSGregory Neil Shapiro 		(void) sm_io_close(mci->mci_statfile, SM_TIME_DEFAULT);
761c2aa98e2SPeter Wemm 		mci->mci_statfile = NULL;
762c2aa98e2SPeter Wemm 	}
763c2aa98e2SPeter Wemm 
7643299c2f1SGregory Neil Shapiro 	errno = save_errno;
765c2aa98e2SPeter Wemm }
76612ed1c7cSGregory Neil Shapiro /*
767c2aa98e2SPeter Wemm **  MCI_LOAD_PERSISTENT -- load persistent host info
768c2aa98e2SPeter Wemm **
769c2aa98e2SPeter Wemm **	Load information about host that is kept
770c2aa98e2SPeter Wemm **	in common for all running sendmails.
771c2aa98e2SPeter Wemm **
772c2aa98e2SPeter Wemm **	Parameters:
77312ed1c7cSGregory Neil Shapiro **		mci -- the host/connection to load persistent info for.
774c2aa98e2SPeter Wemm **
775c2aa98e2SPeter Wemm **	Returns:
77612ed1c7cSGregory Neil Shapiro **		true -- lock was successful
77712ed1c7cSGregory Neil Shapiro **		false -- lock failed
778c2aa98e2SPeter Wemm */
779c2aa98e2SPeter Wemm 
7803299c2f1SGregory Neil Shapiro static bool
781c2aa98e2SPeter Wemm mci_load_persistent(mci)
782c2aa98e2SPeter Wemm 	MCI *mci;
783c2aa98e2SPeter Wemm {
7843299c2f1SGregory Neil Shapiro 	int save_errno = errno;
78512ed1c7cSGregory Neil Shapiro 	bool locked = true;
78612ed1c7cSGregory Neil Shapiro 	SM_FILE_T *fp;
78788ad41d4SGregory Neil Shapiro 	char fname[MAXPATHLEN];
788c2aa98e2SPeter Wemm 
789c2aa98e2SPeter Wemm 	if (mci == NULL)
790c2aa98e2SPeter Wemm 	{
791c2aa98e2SPeter Wemm 		if (tTd(56, 1))
79212ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_load_persistent: NULL mci\n");
79312ed1c7cSGregory Neil Shapiro 		return true;
794c2aa98e2SPeter Wemm 	}
795c2aa98e2SPeter Wemm 
796c2aa98e2SPeter Wemm 	if (IgnoreHostStatus || HostStatDir == NULL || mci->mci_host == NULL)
79712ed1c7cSGregory Neil Shapiro 		return true;
798c2aa98e2SPeter Wemm 
799c2aa98e2SPeter Wemm 	/* Already have the persistent information in memory */
800c2aa98e2SPeter Wemm 	if (SingleThreadDelivery && mci->mci_statfile != NULL)
80112ed1c7cSGregory Neil Shapiro 		return true;
802c2aa98e2SPeter Wemm 
803c2aa98e2SPeter Wemm 	if (tTd(56, 1))
80412ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_load_persistent: Attempting to load persistent information for %s\n",
805c2aa98e2SPeter Wemm 			   mci->mci_host);
806c2aa98e2SPeter Wemm 
80712ed1c7cSGregory Neil Shapiro 	if (mci_generate_persistent_path(mci->mci_host, fname, sizeof fname,
80812ed1c7cSGregory Neil Shapiro 					 false) < 0)
809c2aa98e2SPeter Wemm 	{
810c2aa98e2SPeter Wemm 		/* Not much we can do if the file isn't there... */
811c2aa98e2SPeter Wemm 		if (tTd(56, 1))
81212ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_load_persistent: Couldn't generate host path\n");
813c2aa98e2SPeter Wemm 		goto cleanup;
814c2aa98e2SPeter Wemm 	}
815c2aa98e2SPeter Wemm 
816c2aa98e2SPeter Wemm 	fp = safefopen(fname, O_RDONLY, FileMode,
817c2aa98e2SPeter Wemm 		       SFF_NOLOCK|SFF_NOLINK|SFF_OPENASROOT|SFF_REGONLY|SFF_SAFEDIRPATH);
818c2aa98e2SPeter Wemm 	if (fp == NULL)
819c2aa98e2SPeter Wemm 	{
820c2aa98e2SPeter Wemm 		/* I can't think of any reason this should ever happen */
821c2aa98e2SPeter Wemm 		if (tTd(56, 1))
82212ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_load_persistent: open(%s): %s\n",
82312ed1c7cSGregory Neil Shapiro 				fname, sm_errstring(errno));
824c2aa98e2SPeter Wemm 		goto cleanup;
825c2aa98e2SPeter Wemm 	}
826c2aa98e2SPeter Wemm 
827c2aa98e2SPeter Wemm 	FileName = fname;
82812ed1c7cSGregory Neil Shapiro 	locked = lockfile(sm_io_getinfo(fp, SM_IO_WHAT_FD, NULL), fname, "",
82912ed1c7cSGregory Neil Shapiro 			  LOCK_SH|LOCK_NB);
830c2aa98e2SPeter Wemm 	if (locked)
8313299c2f1SGregory Neil Shapiro 	{
8323299c2f1SGregory Neil Shapiro 		(void) mci_read_persistent(fp, mci);
83312ed1c7cSGregory Neil Shapiro 		(void) lockfile(sm_io_getinfo(fp, SM_IO_WHAT_FD, NULL), fname,
83412ed1c7cSGregory Neil Shapiro 				"", LOCK_UN);
8353299c2f1SGregory Neil Shapiro 	}
8363299c2f1SGregory Neil Shapiro 	FileName = NULL;
83712ed1c7cSGregory Neil Shapiro 	(void) sm_io_close(fp, SM_TIME_DEFAULT);
838c2aa98e2SPeter Wemm 
839c2aa98e2SPeter Wemm cleanup:
8403299c2f1SGregory Neil Shapiro 	errno = save_errno;
841c2aa98e2SPeter Wemm 	return locked;
842c2aa98e2SPeter Wemm }
84312ed1c7cSGregory Neil Shapiro /*
844c2aa98e2SPeter Wemm **  MCI_READ_PERSISTENT -- read persistent host status file
845c2aa98e2SPeter Wemm **
846c2aa98e2SPeter Wemm **	Parameters:
847c2aa98e2SPeter Wemm **		fp -- the file pointer to read.
848c2aa98e2SPeter Wemm **		mci -- the pointer to fill in.
849c2aa98e2SPeter Wemm **
850c2aa98e2SPeter Wemm **	Returns:
851c2aa98e2SPeter Wemm **		-1 -- if the file was corrupt.
852c2aa98e2SPeter Wemm **		0 -- otherwise.
853c2aa98e2SPeter Wemm **
854c2aa98e2SPeter Wemm **	Warning:
855c2aa98e2SPeter Wemm **		This code makes the assumption that this data
856c2aa98e2SPeter Wemm **		will be read in an atomic fashion, and that the data
857c2aa98e2SPeter Wemm **		was written in an atomic fashion.  Any other functioning
858c2aa98e2SPeter Wemm **		may lead to some form of insanity.  This should be
859c2aa98e2SPeter Wemm **		perfectly safe due to underlying stdio buffering.
860c2aa98e2SPeter Wemm */
861c2aa98e2SPeter Wemm 
8623299c2f1SGregory Neil Shapiro static int
863c2aa98e2SPeter Wemm mci_read_persistent(fp, mci)
86412ed1c7cSGregory Neil Shapiro 	SM_FILE_T *fp;
865c2aa98e2SPeter Wemm 	register MCI *mci;
866c2aa98e2SPeter Wemm {
867c2aa98e2SPeter Wemm 	int ver;
868c2aa98e2SPeter Wemm 	register char *p;
869c2aa98e2SPeter Wemm 	int saveLineNumber = LineNumber;
870c2aa98e2SPeter Wemm 	char buf[MAXLINE];
871c2aa98e2SPeter Wemm 
872c2aa98e2SPeter Wemm 	if (fp == NULL)
873c2aa98e2SPeter Wemm 		syserr("mci_read_persistent: NULL fp");
874c2aa98e2SPeter Wemm 	if (mci == NULL)
875c2aa98e2SPeter Wemm 		syserr("mci_read_persistent: NULL mci");
876c2aa98e2SPeter Wemm 	if (tTd(56, 93))
877c2aa98e2SPeter Wemm 	{
87812ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_read_persistent: fp=%lx, mci=",
87912ed1c7cSGregory Neil Shapiro 			   (unsigned long) fp);
880c2aa98e2SPeter Wemm 	}
881c2aa98e2SPeter Wemm 
88212ed1c7cSGregory Neil Shapiro 	SM_FREE_CLR(mci->mci_status);
88312ed1c7cSGregory Neil Shapiro 	SM_FREE_CLR(mci->mci_rstatus);
884c2aa98e2SPeter Wemm 
88512ed1c7cSGregory Neil Shapiro 	sm_io_rewind(fp, SM_TIME_DEFAULT);
886c2aa98e2SPeter Wemm 	ver = -1;
887c2aa98e2SPeter Wemm 	LineNumber = 0;
88812ed1c7cSGregory Neil Shapiro 	while (sm_io_fgets(fp, SM_TIME_DEFAULT, buf, sizeof buf) != NULL)
889c2aa98e2SPeter Wemm 	{
890c2aa98e2SPeter Wemm 		LineNumber++;
891c2aa98e2SPeter Wemm 		p = strchr(buf, '\n');
892c2aa98e2SPeter Wemm 		if (p != NULL)
893c2aa98e2SPeter Wemm 			*p = '\0';
894c2aa98e2SPeter Wemm 		switch (buf[0])
895c2aa98e2SPeter Wemm 		{
896c2aa98e2SPeter Wemm 		  case 'V':		/* version stamp */
897c2aa98e2SPeter Wemm 			ver = atoi(&buf[1]);
898c2aa98e2SPeter Wemm 			if (ver < 0 || ver > 0)
899c2aa98e2SPeter Wemm 				syserr("Unknown host status version %d: %d max",
900c2aa98e2SPeter Wemm 					ver, 0);
901c2aa98e2SPeter Wemm 			break;
902c2aa98e2SPeter Wemm 
903c2aa98e2SPeter Wemm 		  case 'E':		/* UNIX error number */
904c2aa98e2SPeter Wemm 			mci->mci_errno = atoi(&buf[1]);
905c2aa98e2SPeter Wemm 			break;
906c2aa98e2SPeter Wemm 
907c2aa98e2SPeter Wemm 		  case 'H':		/* DNS error number */
908c2aa98e2SPeter Wemm 			mci->mci_herrno = atoi(&buf[1]);
909c2aa98e2SPeter Wemm 			break;
910c2aa98e2SPeter Wemm 
911c2aa98e2SPeter Wemm 		  case 'S':		/* UNIX exit status */
912c2aa98e2SPeter Wemm 			mci->mci_exitstat = atoi(&buf[1]);
913c2aa98e2SPeter Wemm 			break;
914c2aa98e2SPeter Wemm 
915c2aa98e2SPeter Wemm 		  case 'D':		/* DSN status */
916c2aa98e2SPeter Wemm 			mci->mci_status = newstr(&buf[1]);
917c2aa98e2SPeter Wemm 			break;
918c2aa98e2SPeter Wemm 
919c2aa98e2SPeter Wemm 		  case 'R':		/* SMTP status */
920c2aa98e2SPeter Wemm 			mci->mci_rstatus = newstr(&buf[1]);
921c2aa98e2SPeter Wemm 			break;
922c2aa98e2SPeter Wemm 
923c2aa98e2SPeter Wemm 		  case 'U':		/* last usage time */
924c2aa98e2SPeter Wemm 			mci->mci_lastuse = atol(&buf[1]);
925c2aa98e2SPeter Wemm 			break;
926c2aa98e2SPeter Wemm 
927c2aa98e2SPeter Wemm 		  case '.':		/* end of file */
92812ed1c7cSGregory Neil Shapiro 			if (tTd(56, 93))
92912ed1c7cSGregory Neil Shapiro 				mci_dump(mci, false);
930c2aa98e2SPeter Wemm 			return 0;
931c2aa98e2SPeter Wemm 
932c2aa98e2SPeter Wemm 		  default:
933c2aa98e2SPeter Wemm 			sm_syslog(LOG_CRIT, NOQID,
934c2aa98e2SPeter Wemm 				  "%s: line %d: Unknown host status line \"%s\"",
935c2aa98e2SPeter Wemm 				  FileName == NULL ? mci->mci_host : FileName,
936c2aa98e2SPeter Wemm 				  LineNumber, buf);
937c2aa98e2SPeter Wemm 			LineNumber = saveLineNumber;
938c2aa98e2SPeter Wemm 			return -1;
939c2aa98e2SPeter Wemm 		}
940c2aa98e2SPeter Wemm 	}
941c2aa98e2SPeter Wemm 	LineNumber = saveLineNumber;
94212ed1c7cSGregory Neil Shapiro 	if (tTd(56, 93))
94312ed1c7cSGregory Neil Shapiro 		sm_dprintf("incomplete (missing dot for EOF)\n");
944c2aa98e2SPeter Wemm 	if (ver < 0)
945c2aa98e2SPeter Wemm 		return -1;
946c2aa98e2SPeter Wemm 	return 0;
947c2aa98e2SPeter Wemm }
94812ed1c7cSGregory Neil Shapiro /*
949c2aa98e2SPeter Wemm **  MCI_STORE_PERSISTENT -- Store persistent MCI information
950c2aa98e2SPeter Wemm **
951c2aa98e2SPeter Wemm **	Store information about host that is kept
952c2aa98e2SPeter Wemm **	in common for all running sendmails.
953c2aa98e2SPeter Wemm **
954c2aa98e2SPeter Wemm **	Parameters:
955c2aa98e2SPeter Wemm **		mci -- the host/connection to store persistent info for.
956c2aa98e2SPeter Wemm **
957c2aa98e2SPeter Wemm **	Returns:
958c2aa98e2SPeter Wemm **		none.
959c2aa98e2SPeter Wemm */
960c2aa98e2SPeter Wemm 
961c2aa98e2SPeter Wemm void
962c2aa98e2SPeter Wemm mci_store_persistent(mci)
963c2aa98e2SPeter Wemm 	MCI *mci;
964c2aa98e2SPeter Wemm {
9653299c2f1SGregory Neil Shapiro 	int save_errno = errno;
966c2aa98e2SPeter Wemm 
967c2aa98e2SPeter Wemm 	if (mci == NULL)
968c2aa98e2SPeter Wemm 	{
969c2aa98e2SPeter Wemm 		if (tTd(56, 1))
97012ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_store_persistent: NULL mci\n");
971c2aa98e2SPeter Wemm 		return;
972c2aa98e2SPeter Wemm 	}
973c2aa98e2SPeter Wemm 
974c2aa98e2SPeter Wemm 	if (HostStatDir == NULL || mci->mci_host == NULL)
975c2aa98e2SPeter Wemm 		return;
976c2aa98e2SPeter Wemm 
977c2aa98e2SPeter Wemm 	if (tTd(56, 1))
97812ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_store_persistent: Storing information for %s\n",
979c2aa98e2SPeter Wemm 			   mci->mci_host);
980c2aa98e2SPeter Wemm 
981c2aa98e2SPeter Wemm 	if (mci->mci_statfile == NULL)
982c2aa98e2SPeter Wemm 	{
983c2aa98e2SPeter Wemm 		if (tTd(56, 1))
98412ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_store_persistent: no statfile\n");
985c2aa98e2SPeter Wemm 		return;
986c2aa98e2SPeter Wemm 	}
987c2aa98e2SPeter Wemm 
98812ed1c7cSGregory Neil Shapiro 	sm_io_rewind(mci->mci_statfile, SM_TIME_DEFAULT);
989c2aa98e2SPeter Wemm #if !NOFTRUNCATE
99012ed1c7cSGregory Neil Shapiro 	(void) ftruncate(sm_io_getinfo(mci->mci_statfile, SM_IO_WHAT_FD, NULL),
99112ed1c7cSGregory Neil Shapiro 			 (off_t) 0);
9923299c2f1SGregory Neil Shapiro #endif /* !NOFTRUNCATE */
993c2aa98e2SPeter Wemm 
99412ed1c7cSGregory Neil Shapiro 	(void) sm_io_fprintf(mci->mci_statfile, SM_TIME_DEFAULT, "V0\n");
99512ed1c7cSGregory Neil Shapiro 	(void) sm_io_fprintf(mci->mci_statfile, SM_TIME_DEFAULT, "E%d\n",
99612ed1c7cSGregory Neil Shapiro 			     mci->mci_errno);
99712ed1c7cSGregory Neil Shapiro 	(void) sm_io_fprintf(mci->mci_statfile, SM_TIME_DEFAULT, "H%d\n",
99812ed1c7cSGregory Neil Shapiro 			     mci->mci_herrno);
99912ed1c7cSGregory Neil Shapiro 	(void) sm_io_fprintf(mci->mci_statfile, SM_TIME_DEFAULT, "S%d\n",
100012ed1c7cSGregory Neil Shapiro 			     mci->mci_exitstat);
1001c2aa98e2SPeter Wemm 	if (mci->mci_status != NULL)
100212ed1c7cSGregory Neil Shapiro 		(void) sm_io_fprintf(mci->mci_statfile, SM_TIME_DEFAULT,
100312ed1c7cSGregory Neil Shapiro 				     "D%.80s\n",
100412ed1c7cSGregory Neil Shapiro 				     denlstring(mci->mci_status, true, false));
1005c2aa98e2SPeter Wemm 	if (mci->mci_rstatus != NULL)
100612ed1c7cSGregory Neil Shapiro 		(void) sm_io_fprintf(mci->mci_statfile, SM_TIME_DEFAULT,
100712ed1c7cSGregory Neil Shapiro 				     "R%.80s\n",
100812ed1c7cSGregory Neil Shapiro 				     denlstring(mci->mci_rstatus, true, false));
100912ed1c7cSGregory Neil Shapiro 	(void) sm_io_fprintf(mci->mci_statfile, SM_TIME_DEFAULT, "U%ld\n",
101012ed1c7cSGregory Neil Shapiro 			     (long)(mci->mci_lastuse));
101112ed1c7cSGregory Neil Shapiro 	(void) sm_io_fprintf(mci->mci_statfile, SM_TIME_DEFAULT, ".\n");
1012c2aa98e2SPeter Wemm 
101312ed1c7cSGregory Neil Shapiro 	(void) sm_io_flush(mci->mci_statfile, SM_TIME_DEFAULT);
1014c2aa98e2SPeter Wemm 
10153299c2f1SGregory Neil Shapiro 	errno = save_errno;
1016c2aa98e2SPeter Wemm 	return;
1017c2aa98e2SPeter Wemm }
101812ed1c7cSGregory Neil Shapiro /*
1019c2aa98e2SPeter Wemm **  MCI_TRAVERSE_PERSISTENT -- walk persistent status tree
1020c2aa98e2SPeter Wemm **
1021c2aa98e2SPeter Wemm **	Recursively find all the mci host files in `pathname'.  Default to
1022c2aa98e2SPeter Wemm **		main host status directory if no path is provided.
1023c2aa98e2SPeter Wemm **	Call (*action)(pathname, host) for each file found.
1024c2aa98e2SPeter Wemm **
1025c2aa98e2SPeter Wemm **	Note: all information is collected in a list before it is processed.
1026c2aa98e2SPeter Wemm **	This may not be the best way to do it, but it seems safest, since
1027c2aa98e2SPeter Wemm **	the file system would be touched while we are attempting to traverse
1028c2aa98e2SPeter Wemm **	the directory tree otherwise (during purges).
1029c2aa98e2SPeter Wemm **
1030c2aa98e2SPeter Wemm **	Parameters:
1031c2aa98e2SPeter Wemm **		action -- function to call on each node.  If returns < 0,
1032c2aa98e2SPeter Wemm **			return immediately.
1033c2aa98e2SPeter Wemm **		pathname -- root of tree.  If null, use main host status
1034c2aa98e2SPeter Wemm **			directory.
1035c2aa98e2SPeter Wemm **
1036c2aa98e2SPeter Wemm **	Returns:
1037c2aa98e2SPeter Wemm **		< 0 -- if any action routine returns a negative value, that
1038c2aa98e2SPeter Wemm **			value is returned.
1039c2aa98e2SPeter Wemm **		0 -- if we successfully went to completion.
10403299c2f1SGregory Neil Shapiro **		> 0 -- return status from action()
1041c2aa98e2SPeter Wemm */
1042c2aa98e2SPeter Wemm 
1043c2aa98e2SPeter Wemm int
1044c2aa98e2SPeter Wemm mci_traverse_persistent(action, pathname)
1045c2aa98e2SPeter Wemm 	int (*action)();
1046c2aa98e2SPeter Wemm 	char *pathname;
1047c2aa98e2SPeter Wemm {
1048c2aa98e2SPeter Wemm 	struct stat statbuf;
1049c2aa98e2SPeter Wemm 	DIR *d;
1050c2aa98e2SPeter Wemm 	int ret;
1051c2aa98e2SPeter Wemm 
1052c2aa98e2SPeter Wemm 	if (pathname == NULL)
1053c2aa98e2SPeter Wemm 		pathname = HostStatDir;
1054c2aa98e2SPeter Wemm 	if (pathname == NULL)
1055c2aa98e2SPeter Wemm 		return -1;
1056c2aa98e2SPeter Wemm 
1057c2aa98e2SPeter Wemm 	if (tTd(56, 1))
105812ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_traverse: pathname is %s\n", pathname);
1059c2aa98e2SPeter Wemm 
1060c2aa98e2SPeter Wemm 	ret = stat(pathname, &statbuf);
1061c2aa98e2SPeter Wemm 	if (ret < 0)
1062c2aa98e2SPeter Wemm 	{
1063c2aa98e2SPeter Wemm 		if (tTd(56, 2))
106412ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_traverse: Failed to stat %s: %s\n",
106512ed1c7cSGregory Neil Shapiro 				pathname, sm_errstring(errno));
1066c2aa98e2SPeter Wemm 		return ret;
1067c2aa98e2SPeter Wemm 	}
1068c2aa98e2SPeter Wemm 	if (S_ISDIR(statbuf.st_mode))
1069c2aa98e2SPeter Wemm 	{
10703299c2f1SGregory Neil Shapiro 		bool leftone, removedone;
107112ed1c7cSGregory Neil Shapiro 		size_t len;
107212ed1c7cSGregory Neil Shapiro 		char *newptr;
107312ed1c7cSGregory Neil Shapiro 		struct dirent *e;
107488ad41d4SGregory Neil Shapiro 		char newpath[MAXPATHLEN];
1075c2aa98e2SPeter Wemm 
1076c2aa98e2SPeter Wemm 		if ((d = opendir(pathname)) == NULL)
1077c2aa98e2SPeter Wemm 		{
1078c2aa98e2SPeter Wemm 			if (tTd(56, 2))
107912ed1c7cSGregory Neil Shapiro 				sm_dprintf("mci_traverse: opendir %s: %s\n",
108012ed1c7cSGregory Neil Shapiro 					pathname, sm_errstring(errno));
1081c2aa98e2SPeter Wemm 			return -1;
1082c2aa98e2SPeter Wemm 		}
108312ed1c7cSGregory Neil Shapiro 		len = sizeof(newpath) - MAXNAMLEN - 3;
108412ed1c7cSGregory Neil Shapiro 		if (sm_strlcpy(newpath, pathname, len) >= len)
1085c2aa98e2SPeter Wemm 		{
1086c2aa98e2SPeter Wemm 			if (tTd(56, 2))
108712ed1c7cSGregory Neil Shapiro 				sm_dprintf("mci_traverse: path \"%s\" too long",
1088c2aa98e2SPeter Wemm 					pathname);
1089c2aa98e2SPeter Wemm 			return -1;
1090c2aa98e2SPeter Wemm 		}
1091c2aa98e2SPeter Wemm 		newptr = newpath + strlen(newpath);
1092c2aa98e2SPeter Wemm 		*newptr++ = '/';
1093c2aa98e2SPeter Wemm 
10943299c2f1SGregory Neil Shapiro 		/*
10953299c2f1SGregory Neil Shapiro 		**  repeat until no file has been removed
10963299c2f1SGregory Neil Shapiro 		**  this may become ugly when several files "expire"
10973299c2f1SGregory Neil Shapiro 		**  during these loops, but it's better than doing
10983299c2f1SGregory Neil Shapiro 		**  a rewinddir() inside the inner loop
10993299c2f1SGregory Neil Shapiro 		*/
110012ed1c7cSGregory Neil Shapiro 
11013299c2f1SGregory Neil Shapiro 		do
11023299c2f1SGregory Neil Shapiro 		{
110312ed1c7cSGregory Neil Shapiro 			leftone = removedone = false;
1104c2aa98e2SPeter Wemm 			while ((e = readdir(d)) != NULL)
1105c2aa98e2SPeter Wemm 			{
1106c2aa98e2SPeter Wemm 				if (e->d_name[0] == '.')
1107c2aa98e2SPeter Wemm 					continue;
1108c2aa98e2SPeter Wemm 
110912ed1c7cSGregory Neil Shapiro 				(void) sm_strlcpy(newptr, e->d_name,
11103299c2f1SGregory Neil Shapiro 					       sizeof newpath -
11113299c2f1SGregory Neil Shapiro 					       (newptr - newpath));
1112c2aa98e2SPeter Wemm 
1113c0c4794dSGregory Neil Shapiro 				if (StopRequest)
1114c0c4794dSGregory Neil Shapiro 					stop_sendmail();
1115c2aa98e2SPeter Wemm 				ret = mci_traverse_persistent(action, newpath);
1116c2aa98e2SPeter Wemm 				if (ret < 0)
1117c2aa98e2SPeter Wemm 					break;
11183299c2f1SGregory Neil Shapiro 				if (ret == 1)
111912ed1c7cSGregory Neil Shapiro 					leftone = true;
11203299c2f1SGregory Neil Shapiro 				if (!removedone && ret == 0 &&
11213299c2f1SGregory Neil Shapiro 				    action == mci_purge_persistent)
112212ed1c7cSGregory Neil Shapiro 					removedone = true;
11233299c2f1SGregory Neil Shapiro 			}
11243299c2f1SGregory Neil Shapiro 			if (ret < 0)
11253299c2f1SGregory Neil Shapiro 				break;
112612ed1c7cSGregory Neil Shapiro 
1127c2aa98e2SPeter Wemm 			/*
1128c2aa98e2SPeter Wemm 			**  The following appears to be
1129c2aa98e2SPeter Wemm 			**  necessary during purges, since
1130c2aa98e2SPeter Wemm 			**  we modify the directory structure
1131c2aa98e2SPeter Wemm 			*/
113212ed1c7cSGregory Neil Shapiro 
11333299c2f1SGregory Neil Shapiro 			if (removedone)
1134c2aa98e2SPeter Wemm 				rewinddir(d);
11353299c2f1SGregory Neil Shapiro 			if (tTd(56, 40))
113612ed1c7cSGregory Neil Shapiro 				sm_dprintf("mci_traverse: path %s: ret %d removed %d left %d\n",
11373299c2f1SGregory Neil Shapiro 					pathname, ret, removedone, leftone);
11383299c2f1SGregory Neil Shapiro 		} while (removedone);
1139c2aa98e2SPeter Wemm 
1140c2aa98e2SPeter Wemm 		/* purge (or whatever) the directory proper */
11413299c2f1SGregory Neil Shapiro 		if (!leftone)
11423299c2f1SGregory Neil Shapiro 		{
1143c2aa98e2SPeter Wemm 			*--newptr = '\0';
1144c2aa98e2SPeter Wemm 			ret = (*action)(newpath, NULL);
11453299c2f1SGregory Neil Shapiro 		}
11463299c2f1SGregory Neil Shapiro 		(void) closedir(d);
1147c2aa98e2SPeter Wemm 	}
1148c2aa98e2SPeter Wemm 	else if (S_ISREG(statbuf.st_mode))
1149c2aa98e2SPeter Wemm 	{
1150c2aa98e2SPeter Wemm 		char *end = pathname + strlen(pathname) - 1;
1151c2aa98e2SPeter Wemm 		char *start;
1152c2aa98e2SPeter Wemm 		char *scan;
1153c2aa98e2SPeter Wemm 		char host[MAXHOSTNAMELEN];
1154c2aa98e2SPeter Wemm 		char *hostptr = host;
1155c2aa98e2SPeter Wemm 
1156c2aa98e2SPeter Wemm 		/*
1157c2aa98e2SPeter Wemm 		**  Reconstruct the host name from the path to the
1158c2aa98e2SPeter Wemm 		**  persistent information.
1159c2aa98e2SPeter Wemm 		*/
1160c2aa98e2SPeter Wemm 
1161c2aa98e2SPeter Wemm 		do
1162c2aa98e2SPeter Wemm 		{
1163c2aa98e2SPeter Wemm 			if (hostptr != host)
1164c2aa98e2SPeter Wemm 				*(hostptr++) = '.';
1165c2aa98e2SPeter Wemm 			start = end;
11667660b554SGregory Neil Shapiro 			while (start > pathname && *(start - 1) != '/')
1167c2aa98e2SPeter Wemm 				start--;
1168c2aa98e2SPeter Wemm 
1169c2aa98e2SPeter Wemm 			if (*end == '.')
1170c2aa98e2SPeter Wemm 				end--;
1171c2aa98e2SPeter Wemm 
1172c2aa98e2SPeter Wemm 			for (scan = start; scan <= end; scan++)
1173c2aa98e2SPeter Wemm 				*(hostptr++) = *scan;
1174c2aa98e2SPeter Wemm 
1175c2aa98e2SPeter Wemm 			end = start - 2;
11767660b554SGregory Neil Shapiro 		} while (end > pathname && *end == '.');
1177c2aa98e2SPeter Wemm 
1178c2aa98e2SPeter Wemm 		*hostptr = '\0';
1179c2aa98e2SPeter Wemm 
1180c2aa98e2SPeter Wemm 		/*
1181c2aa98e2SPeter Wemm 		**  Do something with the file containing the persistent
1182c2aa98e2SPeter Wemm 		**  information.
1183c2aa98e2SPeter Wemm 		*/
118412ed1c7cSGregory Neil Shapiro 
1185c2aa98e2SPeter Wemm 		ret = (*action)(pathname, host);
1186c2aa98e2SPeter Wemm 	}
1187c2aa98e2SPeter Wemm 
1188c2aa98e2SPeter Wemm 	return ret;
1189c2aa98e2SPeter Wemm }
119012ed1c7cSGregory Neil Shapiro /*
11913299c2f1SGregory Neil Shapiro **  MCI_PRINT_PERSISTENT -- print persistent info
1192c2aa98e2SPeter Wemm **
1193c2aa98e2SPeter Wemm **	Dump the persistent information in the file 'pathname'
1194c2aa98e2SPeter Wemm **
1195c2aa98e2SPeter Wemm **	Parameters:
1196c2aa98e2SPeter Wemm **		pathname -- the pathname to the status file.
1197c2aa98e2SPeter Wemm **		hostname -- the corresponding host name.
1198c2aa98e2SPeter Wemm **
1199c2aa98e2SPeter Wemm **	Returns:
1200c2aa98e2SPeter Wemm **		0
1201c2aa98e2SPeter Wemm */
1202c2aa98e2SPeter Wemm 
1203c2aa98e2SPeter Wemm int
1204c2aa98e2SPeter Wemm mci_print_persistent(pathname, hostname)
1205c2aa98e2SPeter Wemm 	char *pathname;
1206c2aa98e2SPeter Wemm 	char *hostname;
1207c2aa98e2SPeter Wemm {
120812ed1c7cSGregory Neil Shapiro 	static bool initflag = false;
120912ed1c7cSGregory Neil Shapiro 	SM_FILE_T *fp;
1210c2aa98e2SPeter Wemm 	int width = Verbose ? 78 : 25;
1211c2aa98e2SPeter Wemm 	bool locked;
1212c2aa98e2SPeter Wemm 	MCI mcib;
1213c2aa98e2SPeter Wemm 
1214c2aa98e2SPeter Wemm 	/* skip directories */
1215c2aa98e2SPeter Wemm 	if (hostname == NULL)
1216c2aa98e2SPeter Wemm 		return 0;
1217c2aa98e2SPeter Wemm 
1218c0c4794dSGregory Neil Shapiro 	if (StopRequest)
1219c0c4794dSGregory Neil Shapiro 		stop_sendmail();
1220c0c4794dSGregory Neil Shapiro 
1221c2aa98e2SPeter Wemm 	if (!initflag)
1222c2aa98e2SPeter Wemm 	{
122312ed1c7cSGregory Neil Shapiro 		initflag = true;
122412ed1c7cSGregory Neil Shapiro 		(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT,
122512ed1c7cSGregory Neil Shapiro 				     " -------------- Hostname --------------- How long ago ---------Results---------\n");
1226c2aa98e2SPeter Wemm 	}
1227c2aa98e2SPeter Wemm 
122812ed1c7cSGregory Neil Shapiro 	fp = safefopen(pathname, O_RDONLY, FileMode,
1229c2aa98e2SPeter Wemm 		       SFF_NOLOCK|SFF_NOLINK|SFF_OPENASROOT|SFF_REGONLY|SFF_SAFEDIRPATH);
1230c2aa98e2SPeter Wemm 
1231c2aa98e2SPeter Wemm 	if (fp == NULL)
1232c2aa98e2SPeter Wemm 	{
1233c2aa98e2SPeter Wemm 		if (tTd(56, 1))
123412ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_print_persistent: cannot open %s: %s\n",
123512ed1c7cSGregory Neil Shapiro 				pathname, sm_errstring(errno));
1236c2aa98e2SPeter Wemm 		return 0;
1237c2aa98e2SPeter Wemm 	}
1238c2aa98e2SPeter Wemm 
1239c2aa98e2SPeter Wemm 	FileName = pathname;
12403299c2f1SGregory Neil Shapiro 	memset(&mcib, '\0', sizeof mcib);
1241c2aa98e2SPeter Wemm 	if (mci_read_persistent(fp, &mcib) < 0)
1242c2aa98e2SPeter Wemm 	{
1243c2aa98e2SPeter Wemm 		syserr("%s: could not read status file", pathname);
124412ed1c7cSGregory Neil Shapiro 		(void) sm_io_close(fp, SM_TIME_DEFAULT);
1245c2aa98e2SPeter Wemm 		FileName = NULL;
1246c2aa98e2SPeter Wemm 		return 0;
1247c2aa98e2SPeter Wemm 	}
1248c2aa98e2SPeter Wemm 
124912ed1c7cSGregory Neil Shapiro 	locked = !lockfile(sm_io_getinfo(fp, SM_IO_WHAT_FD, NULL), pathname,
125012ed1c7cSGregory Neil Shapiro 			   "", LOCK_SH|LOCK_NB);
125112ed1c7cSGregory Neil Shapiro 	(void) sm_io_close(fp, SM_TIME_DEFAULT);
1252c2aa98e2SPeter Wemm 	FileName = NULL;
1253c2aa98e2SPeter Wemm 
125412ed1c7cSGregory Neil Shapiro 	(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT, "%c%-39s %12s ",
1255c2aa98e2SPeter Wemm 			     locked ? '*' : ' ', hostname,
125612ed1c7cSGregory Neil Shapiro 			     pintvl(curtime() - mcib.mci_lastuse, true));
1257c2aa98e2SPeter Wemm 	if (mcib.mci_rstatus != NULL)
125812ed1c7cSGregory Neil Shapiro 		(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT, "%.*s\n", width,
125912ed1c7cSGregory Neil Shapiro 				     mcib.mci_rstatus);
1260c2aa98e2SPeter Wemm 	else if (mcib.mci_exitstat == EX_TEMPFAIL && mcib.mci_errno != 0)
126112ed1c7cSGregory Neil Shapiro 		(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT,
126212ed1c7cSGregory Neil Shapiro 				     "Deferred: %.*s\n", width - 10,
126312ed1c7cSGregory Neil Shapiro 				     sm_errstring(mcib.mci_errno));
1264c2aa98e2SPeter Wemm 	else if (mcib.mci_exitstat != 0)
1265c2aa98e2SPeter Wemm 	{
126612ed1c7cSGregory Neil Shapiro 		char *exmsg = sm_sysexmsg(mcib.mci_exitstat);
1267c2aa98e2SPeter Wemm 
126812ed1c7cSGregory Neil Shapiro 		if (exmsg == NULL)
1269c2aa98e2SPeter Wemm 		{
1270c2aa98e2SPeter Wemm 			char buf[80];
1271c2aa98e2SPeter Wemm 
127212ed1c7cSGregory Neil Shapiro 			(void) sm_snprintf(buf, sizeof buf,
127312ed1c7cSGregory Neil Shapiro 				"Unknown mailer error %d",
1274c2aa98e2SPeter Wemm 				mcib.mci_exitstat);
127512ed1c7cSGregory Neil Shapiro 			(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT, "%.*s\n",
127612ed1c7cSGregory Neil Shapiro 					     width, buf);
1277c2aa98e2SPeter Wemm 		}
1278c2aa98e2SPeter Wemm 		else
127912ed1c7cSGregory Neil Shapiro 			(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT, "%.*s\n",
128012ed1c7cSGregory Neil Shapiro 					     width, &exmsg[5]);
1281c2aa98e2SPeter Wemm 	}
1282c2aa98e2SPeter Wemm 	else if (mcib.mci_errno == 0)
128312ed1c7cSGregory Neil Shapiro 		(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT, "OK\n");
1284c2aa98e2SPeter Wemm 	else
128512ed1c7cSGregory Neil Shapiro 		(void) sm_io_fprintf(smioout, SM_TIME_DEFAULT, "OK: %.*s\n",
128612ed1c7cSGregory Neil Shapiro 				     width - 4, sm_errstring(mcib.mci_errno));
1287c2aa98e2SPeter Wemm 
1288c2aa98e2SPeter Wemm 	return 0;
1289c2aa98e2SPeter Wemm }
129012ed1c7cSGregory Neil Shapiro /*
1291c2aa98e2SPeter Wemm **  MCI_PURGE_PERSISTENT -- Remove a persistence status file.
1292c2aa98e2SPeter Wemm **
1293c2aa98e2SPeter Wemm **	Parameters:
1294c2aa98e2SPeter Wemm **		pathname -- path to the status file.
1295c2aa98e2SPeter Wemm **		hostname -- name of host corresponding to that file.
1296c2aa98e2SPeter Wemm **			NULL if this is a directory (domain).
1297c2aa98e2SPeter Wemm **
1298c2aa98e2SPeter Wemm **	Returns:
12993299c2f1SGregory Neil Shapiro **		0 -- ok
13003299c2f1SGregory Neil Shapiro **		1 -- file not deleted (too young, incorrect format)
13013299c2f1SGregory Neil Shapiro **		< 0 -- some error occurred
1302c2aa98e2SPeter Wemm */
1303c2aa98e2SPeter Wemm 
1304c2aa98e2SPeter Wemm int
1305c2aa98e2SPeter Wemm mci_purge_persistent(pathname, hostname)
1306c2aa98e2SPeter Wemm 	char *pathname;
1307c2aa98e2SPeter Wemm 	char *hostname;
1308c2aa98e2SPeter Wemm {
13093299c2f1SGregory Neil Shapiro 	struct stat statbuf;
1310c2aa98e2SPeter Wemm 	char *end = pathname + strlen(pathname) - 1;
13113299c2f1SGregory Neil Shapiro 	int ret;
1312c2aa98e2SPeter Wemm 
1313c2aa98e2SPeter Wemm 	if (tTd(56, 1))
131412ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_purge_persistent: purging %s\n", pathname);
1315c2aa98e2SPeter Wemm 
13163299c2f1SGregory Neil Shapiro 	ret = stat(pathname, &statbuf);
13173299c2f1SGregory Neil Shapiro 	if (ret < 0)
13183299c2f1SGregory Neil Shapiro 	{
13193299c2f1SGregory Neil Shapiro 		if (tTd(56, 2))
132012ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_purge_persistent: Failed to stat %s: %s\n",
132112ed1c7cSGregory Neil Shapiro 				pathname, sm_errstring(errno));
13223299c2f1SGregory Neil Shapiro 		return ret;
13233299c2f1SGregory Neil Shapiro 	}
1324320f00e7SGregory Neil Shapiro 	if (curtime() - statbuf.st_mtime <= MciInfoTimeout)
13253299c2f1SGregory Neil Shapiro 		return 1;
1326c2aa98e2SPeter Wemm 	if (hostname != NULL)
1327c2aa98e2SPeter Wemm 	{
1328c2aa98e2SPeter Wemm 		/* remove the file */
132912ed1c7cSGregory Neil Shapiro 		ret = unlink(pathname);
133012ed1c7cSGregory Neil Shapiro 		if (ret < 0)
1331c2aa98e2SPeter Wemm 		{
133212ed1c7cSGregory Neil Shapiro 			if (LogLevel > 8)
133312ed1c7cSGregory Neil Shapiro 				sm_syslog(LOG_ERR, NOQID,
133412ed1c7cSGregory Neil Shapiro 					  "mci_purge_persistent: failed to unlink %s: %s",
133512ed1c7cSGregory Neil Shapiro 					  pathname, sm_errstring(errno));
1336c2aa98e2SPeter Wemm 			if (tTd(56, 2))
133712ed1c7cSGregory Neil Shapiro 				sm_dprintf("mci_purge_persistent: failed to unlink %s: %s\n",
133812ed1c7cSGregory Neil Shapiro 					pathname, sm_errstring(errno));
133912ed1c7cSGregory Neil Shapiro 			return ret;
1340c2aa98e2SPeter Wemm 		}
1341c2aa98e2SPeter Wemm 	}
1342c2aa98e2SPeter Wemm 	else
1343c2aa98e2SPeter Wemm 	{
1344c2aa98e2SPeter Wemm 		/* remove the directory */
1345c2aa98e2SPeter Wemm 		if (*end != '.')
13463299c2f1SGregory Neil Shapiro 			return 1;
1347c2aa98e2SPeter Wemm 
1348c2aa98e2SPeter Wemm 		if (tTd(56, 1))
134912ed1c7cSGregory Neil Shapiro 			sm_dprintf("mci_purge_persistent: dpurge %s\n", pathname);
1350c2aa98e2SPeter Wemm 
135112ed1c7cSGregory Neil Shapiro 		ret = rmdir(pathname);
135212ed1c7cSGregory Neil Shapiro 		if (ret < 0)
1353c2aa98e2SPeter Wemm 		{
1354c2aa98e2SPeter Wemm 			if (tTd(56, 2))
135512ed1c7cSGregory Neil Shapiro 				sm_dprintf("mci_purge_persistent: rmdir %s: %s\n",
135612ed1c7cSGregory Neil Shapiro 					pathname, sm_errstring(errno));
135712ed1c7cSGregory Neil Shapiro 			return ret;
1358c2aa98e2SPeter Wemm 		}
1359c2aa98e2SPeter Wemm 	}
1360c2aa98e2SPeter Wemm 
1361c2aa98e2SPeter Wemm 	return 0;
1362c2aa98e2SPeter Wemm }
136312ed1c7cSGregory Neil Shapiro /*
1364c2aa98e2SPeter Wemm **  MCI_GENERATE_PERSISTENT_PATH -- generate path from hostname
1365c2aa98e2SPeter Wemm **
13667660b554SGregory Neil Shapiro **	Given `host', convert from a.b.c to $HostStatDir/c./b./a,
1367c2aa98e2SPeter Wemm **	putting the result into `path'.  if `createflag' is set, intervening
1368c2aa98e2SPeter Wemm **	directories will be created as needed.
1369c2aa98e2SPeter Wemm **
1370c2aa98e2SPeter Wemm **	Parameters:
1371c2aa98e2SPeter Wemm **		host -- host name to convert from.
1372c2aa98e2SPeter Wemm **		path -- place to store result.
1373c2aa98e2SPeter Wemm **		pathlen -- length of path buffer.
1374c2aa98e2SPeter Wemm **		createflag -- if set, create intervening directories as
1375c2aa98e2SPeter Wemm **			needed.
1376c2aa98e2SPeter Wemm **
1377c2aa98e2SPeter Wemm **	Returns:
1378c2aa98e2SPeter Wemm **		0 -- success
1379c2aa98e2SPeter Wemm **		-1 -- failure
1380c2aa98e2SPeter Wemm */
1381c2aa98e2SPeter Wemm 
13823299c2f1SGregory Neil Shapiro static int
1383c2aa98e2SPeter Wemm mci_generate_persistent_path(host, path, pathlen, createflag)
1384c2aa98e2SPeter Wemm 	const char *host;
1385c2aa98e2SPeter Wemm 	char *path;
1386c2aa98e2SPeter Wemm 	int pathlen;
1387c2aa98e2SPeter Wemm 	bool createflag;
1388c2aa98e2SPeter Wemm {
1389c2aa98e2SPeter Wemm 	char *elem, *p, *x, ch;
1390c2aa98e2SPeter Wemm 	int ret = 0;
1391c2aa98e2SPeter Wemm 	int len;
1392c2aa98e2SPeter Wemm 	char t_host[MAXHOSTNAMELEN];
13933299c2f1SGregory Neil Shapiro #if NETINET6
13943299c2f1SGregory Neil Shapiro 	struct in6_addr in6_addr;
13953299c2f1SGregory Neil Shapiro #endif /* NETINET6 */
1396c2aa98e2SPeter Wemm 
1397c2aa98e2SPeter Wemm 	/*
1398c2aa98e2SPeter Wemm 	**  Rationality check the arguments.
1399c2aa98e2SPeter Wemm 	*/
1400c2aa98e2SPeter Wemm 
1401c2aa98e2SPeter Wemm 	if (host == NULL)
1402c2aa98e2SPeter Wemm 	{
1403c2aa98e2SPeter Wemm 		syserr("mci_generate_persistent_path: null host");
1404c2aa98e2SPeter Wemm 		return -1;
1405c2aa98e2SPeter Wemm 	}
1406c2aa98e2SPeter Wemm 	if (path == NULL)
1407c2aa98e2SPeter Wemm 	{
1408c2aa98e2SPeter Wemm 		syserr("mci_generate_persistent_path: null path");
1409c2aa98e2SPeter Wemm 		return -1;
1410c2aa98e2SPeter Wemm 	}
1411c2aa98e2SPeter Wemm 
1412c2aa98e2SPeter Wemm 	if (tTd(56, 80))
141312ed1c7cSGregory Neil Shapiro 		sm_dprintf("mci_generate_persistent_path(%s): ", host);
1414c2aa98e2SPeter Wemm 
1415c2aa98e2SPeter Wemm 	if (*host == '\0' || *host == '.')
1416c2aa98e2SPeter Wemm 		return -1;
1417c2aa98e2SPeter Wemm 
1418c2aa98e2SPeter Wemm 	/* make certain this is not a bracketed host number */
1419c2aa98e2SPeter Wemm 	if (strlen(host) > sizeof t_host - 1)
1420c2aa98e2SPeter Wemm 		return -1;
1421c2aa98e2SPeter Wemm 	if (host[0] == '[')
142212ed1c7cSGregory Neil Shapiro 		(void) sm_strlcpy(t_host, host + 1, sizeof t_host);
1423c2aa98e2SPeter Wemm 	else
142412ed1c7cSGregory Neil Shapiro 		(void) sm_strlcpy(t_host, host, sizeof t_host);
1425c2aa98e2SPeter Wemm 
1426c2aa98e2SPeter Wemm 	/*
1427c2aa98e2SPeter Wemm 	**  Delete any trailing dots from the hostname.
1428c2aa98e2SPeter Wemm 	**  Leave 'elem' pointing at the \0.
1429c2aa98e2SPeter Wemm 	*/
1430c2aa98e2SPeter Wemm 
1431c2aa98e2SPeter Wemm 	elem = t_host + strlen(t_host);
1432c2aa98e2SPeter Wemm 	while (elem > t_host &&
1433c2aa98e2SPeter Wemm 	       (elem[-1] == '.' || (host[0] == '[' && elem[-1] == ']')))
1434c2aa98e2SPeter Wemm 		*--elem = '\0';
1435c2aa98e2SPeter Wemm 
1436c2aa98e2SPeter Wemm 	/* check for bogus bracketed address */
143712ed1c7cSGregory Neil Shapiro 	if (host[0] == '[')
143812ed1c7cSGregory Neil Shapiro 	{
143912ed1c7cSGregory Neil Shapiro 		bool good = false;
14403299c2f1SGregory Neil Shapiro # if NETINET6
144112ed1c7cSGregory Neil Shapiro 		if (anynet_pton(AF_INET6, t_host, &in6_addr) == 1)
144212ed1c7cSGregory Neil Shapiro 			good = true;
14433299c2f1SGregory Neil Shapiro # endif /* NETINET6 */
14443299c2f1SGregory Neil Shapiro # if NETINET
144512ed1c7cSGregory Neil Shapiro 		if (inet_addr(t_host) != INADDR_NONE)
144612ed1c7cSGregory Neil Shapiro 			good = true;
14473299c2f1SGregory Neil Shapiro # endif /* NETINET */
144812ed1c7cSGregory Neil Shapiro 		if (!good)
1449c2aa98e2SPeter Wemm 			return -1;
145012ed1c7cSGregory Neil Shapiro 	}
1451c2aa98e2SPeter Wemm 
1452c2aa98e2SPeter Wemm 	/* check for what will be the final length of the path */
1453c2aa98e2SPeter Wemm 	len = strlen(HostStatDir) + 2;
1454c2aa98e2SPeter Wemm 	for (p = (char *) t_host; *p != '\0'; p++)
1455c2aa98e2SPeter Wemm 	{
1456c2aa98e2SPeter Wemm 		if (*p == '.')
1457c2aa98e2SPeter Wemm 			len++;
1458c2aa98e2SPeter Wemm 		len++;
1459c2aa98e2SPeter Wemm 		if (p[0] == '.' && p[1] == '.')
1460c2aa98e2SPeter Wemm 			return -1;
1461c2aa98e2SPeter Wemm 	}
1462c2aa98e2SPeter Wemm 	if (len > pathlen || len < 1)
1463c2aa98e2SPeter Wemm 		return -1;
146412ed1c7cSGregory Neil Shapiro 	(void) sm_strlcpy(path, HostStatDir, pathlen);
1465c2aa98e2SPeter Wemm 	p = path + strlen(path);
1466c2aa98e2SPeter Wemm 	while (elem > t_host)
1467c2aa98e2SPeter Wemm 	{
1468c2aa98e2SPeter Wemm 		if (!path_is_dir(path, createflag))
1469c2aa98e2SPeter Wemm 		{
1470c2aa98e2SPeter Wemm 			ret = -1;
1471c2aa98e2SPeter Wemm 			break;
1472c2aa98e2SPeter Wemm 		}
1473c2aa98e2SPeter Wemm 		elem--;
1474c2aa98e2SPeter Wemm 		while (elem >= t_host && *elem != '.')
1475c2aa98e2SPeter Wemm 			elem--;
1476c2aa98e2SPeter Wemm 		*p++ = '/';
1477c2aa98e2SPeter Wemm 		x = elem + 1;
1478c2aa98e2SPeter Wemm 		while ((ch = *x++) != '\0' && ch != '.')
1479c2aa98e2SPeter Wemm 		{
1480c2aa98e2SPeter Wemm 			if (isascii(ch) && isupper(ch))
1481c2aa98e2SPeter Wemm 				ch = tolower(ch);
1482c2aa98e2SPeter Wemm 			if (ch == '/')
1483c2aa98e2SPeter Wemm 				ch = ':';	/* / -> : */
1484c2aa98e2SPeter Wemm 			*p++ = ch;
1485c2aa98e2SPeter Wemm 		}
1486c2aa98e2SPeter Wemm 		if (elem >= t_host)
1487c2aa98e2SPeter Wemm 			*p++ = '.';
1488c2aa98e2SPeter Wemm 		*p = '\0';
1489c2aa98e2SPeter Wemm 	}
1490c2aa98e2SPeter Wemm 	if (tTd(56, 80))
1491c2aa98e2SPeter Wemm 	{
1492c2aa98e2SPeter Wemm 		if (ret < 0)
149312ed1c7cSGregory Neil Shapiro 			sm_dprintf("FAILURE %d\n", ret);
1494c2aa98e2SPeter Wemm 		else
149512ed1c7cSGregory Neil Shapiro 			sm_dprintf("SUCCESS %s\n", path);
1496c2aa98e2SPeter Wemm 	}
14973299c2f1SGregory Neil Shapiro 	return ret;
1498c2aa98e2SPeter Wemm }
1499