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