eNextState NWC_SendQUIT(AsyncNetworker *NW);
eNextState NWC_DispatchWriteDone(AsyncIO *IO);
-
-void DestroyNetworker(AsyncNetworker *NW)
+void DeleteNetworker(void *vptr)
{
+ AsyncNetworker *NW = (AsyncNetworker *)vptr;
+ FreeStrBuf(&NW->SpoolFileName);
+ FreeStrBuf(&NW->tempFileName);
+ FreeStrBuf(&NW->node);
+ FreeStrBuf(&NW->host);
+ FreeStrBuf(&NW->port);
+ FreeStrBuf(&NW->secret);
+ FreeStrBuf(&NW->Url);
+ FreeAsyncIOContents(&NW->IO);
+ free(NW);
}
#define NWC_DBG_SEND() syslog(LOG_DEBUG, "NW client[%ld]: > %s", NW->n, ChrPtr(NW->IO.SendBuf.Buf))
#define NWC_DBG_READ() syslog(LOG_DEBUG, "NW client[%ld]: < %s\n", NW->n, ChrPtr(NW->IO.IOBuf))
#define NWC_OK (strncasecmp(ChrPtr(NW->IO.IOBuf), "+OK", 3) == 0)
+eNextState FinalizeNetworker(AsyncIO *IO)
+{
+ AsyncNetworker *NW = (AsyncNetworker *)IO->Data;
+
+ network_talking_to(ChrPtr(NW->node), NTT_REMOVE);
+
+ DeleteNetworker(IO->Data);
+ return eAbort;
+}
+
eNextState NWC_ReadGreeting(AsyncNetworker *NW)
{
char connected_to[SIZ];
eNextState NWC_SendREAD(AsyncNetworker *NW)
{
+ eNextState rc;
+
if (NW->IO.IOB.TotalSentAlready < NW->IO.IOB.TotalSendSize)
{
/*
if (server_shutting_down)
{
close(NW->IO.IOB.OtherFD);
-////// unlink(ChrPtr(NW->tempFileName));
+ unlink(ChrPtr(NW->tempFileName));
return eAbort;
}
StrBufPrintf(NW->IO.SendBuf.Buf, "READ %ld|%ld\n",
NW->IO.IOB.TotalSentAlready,
+ NW->IO.IOB.TotalSendSize);
+/*
((NW->IO.IOB.TotalSendSize - NW->IO.IOB.TotalSentAlready > IGNET_PACKET_SIZE)
? IGNET_PACKET_SIZE :
(NW->IO.IOB.TotalSendSize - NW->IO.IOB.TotalSentAlready))
);
+*/
+ NWC_DBG_SEND();
return eSendReply;
+ }
+ else
+ {
+ NW->State = eCLOS;
+ rc = NWC_DispatchWriteDone(&NW->IO);
+ NWC_DBG_SEND();
-
-
+ return rc;
}
- else {} // continue sending
- return eSendReply;
}
eNextState NWC_ReadREADState(AsyncNetworker *NW)
{
NW->IO.IOB.ChunkSendRemain =
NW->IO.IOB.ChunkSize = atol(ChrPtr(NW->IO.IOBuf)+4);
-/// NW->IO.IOB.TotalSentAlready += NW->IO.IOB.ChunkSize;
-/// TODO StrBufReadjustIOBuffer(NW->IO.RecvBuf, NW->BlobReadSize);
return eReadFile;
}
return eAbort;
eNextState NWC_ReadREADBlobDone(AsyncNetworker *NW);
eNextState NWC_ReadREADBlob(AsyncNetworker *NW)
{
- /// FlushIOBuffer(NW->IO.RecvBuf); /// TODO
-
- ///NW->bytes_received += NW->IO.IOB.ChunkSize;
-
- if (NW->IO.IOB.TotalSentAlready < NW->IO.IOB.TotalSendSize)
+ NWC_DBG_READ();
+ if (NW->IO.IOB.TotalSendSize == NW->IO.IOB.TotalSentAlready)
{
- NW->State = eREAD - 1;
- return eSendReply;/* now fetch next chunk*/
+ NW->State ++;
+
+ close(NW->IO.IOB.OtherFD);
+
+ if (link(ChrPtr(NW->SpoolFileName), ChrPtr(NW->tempFileName)) != 0) {
+ syslog(LOG_ALERT,
+ "Could not link %s to %s: %s\n",
+ ChrPtr(NW->tempFileName),
+ ChrPtr(NW->SpoolFileName),
+ strerror(errno));
+ }
+
+ unlink(ChrPtr(NW->tempFileName));
+ return NWC_DispatchWriteDone(&NW->IO);
+ }
+ else {
+ NW->State --;
+ NW->IO.IOB.ChunkSendRemain = NW->IO.IOB.ChunkSize;
+ return NWC_DispatchWriteDone(&NW->IO);
}
- else
- return NWC_ReadREADBlobDone(NW);
}
eNextState NWC_ReadREADBlobDone(AsyncNetworker *NW)
{
+ NWC_DBG_READ();
if (NW->IO.IOB.TotalSendSize == NW->IO.IOB.TotalSentAlready)
{
NW->State ++;
strerror(errno));
}
-///// unlink(ChrPtr(NW->tempFileName));
+ unlink(ChrPtr(NW->tempFileName));
return NWC_DispatchWriteDone(&NW->IO);
}
else {
NW->State --;
+ NW->IO.IOB.ChunkSendRemain = NW->IO.IOB.ChunkSize;
return NWC_DispatchWriteDone(&NW->IO);
}
}
eNextState NWC_SendCLOS(AsyncNetworker *NW)
{
StrBufPlain(NW->IO.SendBuf.Buf, HKEY("CLOS\n"));
-//// unlink(ChrPtr(NW->tempFileName));
- return eReadMessage;
+ NWC_DBG_SEND();
+ return eSendReply;
}
eNextState NWC_ReadCLOSReply(AsyncNetworker *NW)
{
-/// todo
+ NWC_DBG_READ();
if (ChrPtr(NW->IO.IOBuf)[0] != '2')
return eTerminateConnection;
return eSendReply;
eNextState NWC_SendNUOP(AsyncNetworker *NW)
{
+ eNextState rc;
long TotalSendSize;
struct stat statbuf;
int fd;
strerror(errno));
}
NW->State = eQUIT;
- return NWC_SendQUIT(NW);
+ rc = NWC_SendQUIT(NW);
+ NWC_DBG_SEND();
}
if (fstat(fd, &statbuf) == -1) {
syslog(LOG_DEBUG,
"Nothing to send.\n");
NW->State = eQUIT;
- return NWC_SendQUIT(NW);
+ rc = NWC_SendQUIT(NW);
+ NWC_DBG_SEND();
+ return rc;
}
FDIOBufferInit(&NW->IO.IOB, &NW->IO.SendBuf, fd, TotalSendSize);
-//// NW->bytes_written = 0;
-
StrBufPlain(NW->IO.SendBuf.Buf, HKEY("NUOP\n"));
+ NWC_DBG_SEND();
return eSendReply;
}
{
StrBufPrintf(NW->IO.SendBuf.Buf, "WRIT %ld\n",
NW->IO.IOB.TotalSendSize - NW->IO.IOB.TotalSentAlready);
-
+ NWC_DBG_SEND();
return eSendReply;
}
eNextState NWC_ReadWRITReply(AsyncNetworker *NW)
NW->IO.IOB.ChunkSendRemain =
NW->IO.IOB.ChunkSize = atol(ChrPtr(NW->IO.IOBuf)+4);
-/// NW->IO.IOB.TotalSentAlready += NW->IO.IOB.ChunkSize;
return eSendFile;
}
NW->State ++;
close(NW->IO.IOB.OtherFD);
-//// TODO: unlink networker file?
rc = NWC_DispatchWriteDone(&NW->IO);
NW->State --;
return rc;
}
else {
NW->State --;
+ NW->IO.IOB.ChunkSendRemain = NW->IO.IOB.ChunkSize;
return NWC_DispatchWriteDone(&NW->IO);
}
}
eNextState NWC_SendUCLS(AsyncNetworker *NW)
{
StrBufPlain(NW->IO.SendBuf.Buf, HKEY("UCLS 1\n"));
+ NWC_DBG_SEND();
return eSendReply;
}
NWC_DBG_READ();
syslog(LOG_NOTICE, "Sent %ld octets to <%s>\n", NW->IO.IOB.ChunkSize, ChrPtr(NW->node));
-/// syslog(LOG_DEBUG, "<%s\n", buf);
if (ChrPtr(NW->IO.IOBuf)[0] == '2') {
syslog(LOG_DEBUG, "Removing <%s>\n", ChrPtr(NW->tempFileName));
-/// unlink(ChrPtr(NW->tempFileName));
+ unlink(ChrPtr(NW->tempFileName));
}
return eSendReply;
}
{
StrBufPlain(NW->IO.SendBuf.Buf, HKEY("QUIT\n"));
- network_talking_to(ChrPtr(NW->node), NTT_REMOVE);
+ NWC_DBG_SEND();
return eSendReply;
}
{
NWC_DBG_READ();
- return eTerminateConnection;
+ return eAbort;
}
NWC_ReadWRITReply,
NWC_SendBlobDone,
NWC_ReadUCLS,
- NWC_ReadQUIT
-};
+ NWC_ReadQUIT};
+
+long NWC_ConnTimeout = 100;
const long NWC_SendTimeouts[] = {
100,
{
AsyncNetworker *NW = IO->Data;
/*
- * here we start with the lookup of one host. it might be...
- * - the relay host *sigh*
- * - the direct hostname if there was no mx record
- * - one of the mx'es
+ * here we start with the lookup of one host.
*/
InitC_ares_dns(IO);
*/
eReadState NWC_ReadServerStatus(AsyncIO *IO)
{
- AsyncNetworker *NW = IO->Data;
+// AsyncNetworker *NW = IO->Data;
eReadState Finished = eBufferNotEmpty;
switch (IO->NextState) {
case eReadFile:
case eSendFile:
case eReadPayload:
-////TODO Finished = IOBufferStrLength(&IO->RecvBuf) >= NW->BlobReadSize;
break;
}
return Finished;
eNextState NWC_FailNetworkConnection(AsyncIO *IO)
{
- return eTerminateConnection;
+ return eAbort;
+}
+
+void NWC_SetTimeout(eNextState NextTCPState, AsyncNetworker *NW)
+{
+ double Timeout = 0.0;
+
+ syslog(LOG_DEBUG, "NWC3: %s\n", __FUNCTION__);
+
+ switch (NextTCPState) {
+ case eSendReply:
+ case eSendMore:
+ break;
+ case eReadFile:
+ case eReadMessage:
+ Timeout = NWC_ReadTimeouts[NW->State];
+ break;
+ case eReadPayload:
+ Timeout = 100000;
+ /* TODO!!! */
+ break;
+ case eSendDNSQuery:
+ case eReadDNSReply:
+ case eConnect:
+ case eSendFile:
+//TODO
+ case eTerminateConnection:
+ case eDBQuery:
+ case eAbort:
+ case eReadMore://// TODO
+ return;
+ }
+ SetNextTimeout(&NW->IO, Timeout);
}
rc = NWC_ReadHandlers[NW->State](NW);
if (rc != eReadMore)
NW->State++;
- ////NWCSetTimeout(rc, NW);
+ NWC_SetTimeout(rc, NW);
return rc;
}
eNextState NWC_DispatchWriteDone(AsyncIO *IO)
eNextState rc;
rc = NWC_SendHandlers[NW->State](NW);
- ////NWCSetTimeout(rc, NW);
+ NWC_SetTimeout(rc, NW);
return rc;
}
eNextState NWC_Terminate(AsyncIO *IO)
{
syslog(LOG_DEBUG, "Nw: %s\n", __FUNCTION__);
-/// FinalizeNetworker(IO); TODO
+ FinalizeNetworker(IO);
return eAbort;
}
eNextState NWC_Timeout(AsyncIO *IO)
{
-// AsyncNetworker *NW = IO->Data;
-
syslog(LOG_DEBUG, "NW: %s\n", __FUNCTION__);
-// StrBufPlain(IO->ErrMsg, CKEY(POP3C_ReadErrors[pMsg->State])); todo
+
return NWC_FailNetworkConnection(IO);
}
eNextState NWC_ConnFail(AsyncIO *IO)
syslog(LOG_DEBUG, "NW: %s\n", __FUNCTION__);
//// pop3aggr *pMsg = IO->Data;
- ////pMsg->MyQEntry->Status = 3;
- ///StrBufPlain(pMsg->MyQEntry->StatusMessage, HKEY("server shutdown during message retrieval."));
-/// FinalizePOP3AggrRun(IO); todo
+ FinalizeNetworker(IO);
return eAbort;
}
ChrPtr(NW->host),
ChrPtr(NW->port));
-//// IO->ConnectMe = &NW->Pop3Host;
- /* Bypass the ns lookup result like this: IO->Addr.sin_addr.s_addr = inet_addr("127.0.0.1"); */
-
- /////// SetConnectStatus(IO);
-
- return InitEventIO(IO, NW, 100, 100, 1); /*
- NWC_ConnTimeout,
- NWC_ReadTimeouts[0],
- 1);*/
+ return InitEventIO(IO, NW,
+ NWC_ConnTimeout,
+ NWC_ReadTimeouts[0],
+ 1);
}
void RunNetworker(AsyncNetworker *NW)
continue;
}
}
- DestroyNetworker(NW);
+ DeleteNetworker(NW);
}
}
+ FreeStrBuf(&CfgData);
+ FreeStrBuf(&Line);
}
projects / citadel.git / blobdiff