int nRemain;
StrBuf *MsgData;
AsyncIO *IO = &Msg->IO;
- EVS_syslog(LOG_DEBUG, "SMTP: %s\n", __FUNCTION__);
IDestructQueItem = DecreaseQReference(Msg->MyQItem);
"");
FreeStrBuf(&MsgData);
}
+ RemoveContext(Msg->IO.CitContext);
if (IDestructQueItem)
RemoveQItem(Msg->MyQItem);
-
- RemoveContext(Msg->IO.CitContext);
DeleteSmtpOutMsg(Msg);
}
/*
* possible ways here:
* - connection timeout
- * -
+ * - dns lookup failed
*/
StopClientWatchers(IO);
if (SendMsg->pCurrRelay != NULL)
SendMsg->pCurrRelay = SendMsg->pCurrRelay->Next;
- if (SendMsg->pCurrRelay == NULL)
+ if (SendMsg->pCurrRelay == NULL) {
+ EVS_syslog(LOG_DEBUG, "SMTP: %s Aborting\n", __FUNCTION__);
return eAbort;
- if (SendMsg->pCurrRelay->IsIP)
+ }
+ if (SendMsg->pCurrRelay->IsIP) {
+ EVS_syslog(LOG_DEBUG, "SMTP: %s connecting IP\n", __FUNCTION__);
return mx_connect_ip(IO);
- else
+ }
+ else {
+ EVS_syslog(LOG_DEBUG, "SMTP: %s resolving next MX Record\n", __FUNCTION__);
return get_one_mx_host_ip(IO);
+ }
}
p->Host = SendMsg->node;
*pp = p;
- pp = &p;
+ pp = &p->Next;
}
SendMsg->CXFlags = SendMsg->CXFlags & F_DIRECT;
}
SendMsg->IO.IOBuf = NewStrBuf();
SendMsg->IO.NextState = eReadMessage;
-
+
return SendMsg;
}
int KeepMsgText, /* KeepMsgText allows us to use MsgText as ours. */
int MsgCount)
{
+ AsyncIO *IO;
SmtpOutMsg *SendMsg;
syslog(LOG_DEBUG, "SMTP: %s\n", __FUNCTION__);
SendMsg = new_smtp_outmsg(MyQItem, MyQEntry, MsgCount);
+ IO = &SendMsg->IO;
if (KeepMsgText) SendMsg->msgtext = MsgText;
else SendMsg->msgtext = NewStrBufDup(MsgText);
SubC = CloneContext (CC);
SubC->session_specific_data = (char*) SendMsg;
SendMsg->IO.CitContext = SubC;
-
- syslog(LOG_DEBUG, "SMTP Starting: [%ld] \n",
+
+ safestrncpy(SubC->cs_host, SendMsg->node, sizeof(SubC->cs_host));
+ syslog(LOG_DEBUG, "SMTP Starting: [%ld] <%s> CC <%d> \n",
SendMsg->MyQItem->MessageID,
- ChrPtr(SendMsg->MyQEntry->Recipient));
+ ChrPtr(SendMsg->MyQEntry->Recipient),
+ ((CitContext*)SendMsg->IO.CitContext)->cs_pid);
if (SendMsg->pCurrRelay == NULL)
QueueEventContext(&SendMsg->IO,
resolve_mx_records);
SmtpOutMsg *pMsg = IO->Data;
EVS_syslog(LOG_DEBUG, "SMTP: %s\n", __FUNCTION__);
- StrBufPlain(IO->ErrMsg, CKEY(ReadErrors[pMsg->State]));
return FailOneAttempt(IO);
}
eNextState SMTP_C_Shutdown(AsyncIO *IO)