#define EVN_syslog(LEVEL, FORMAT, ...) \
NCDBGLOG(LEVEL) syslog(LEVEL, \
- "IO[%ld]CC[%d]NW[%s][%ld]" FORMAT, \
- IO->ID, CCID, NODE, N, __VA_ARGS__)
+ "%s[%ld]CC[%d]NW[%s][%ld]" FORMAT, \
+ IOSTR, IO->ID, CCID, NODE, N, __VA_ARGS__)
#define EVNM_syslog(LEVEL, FORMAT) \
NCDBGLOG(LEVEL) syslog(LEVEL, \
- "IO[%ld]CC[%d]NW[%s][%ld]" FORMAT, \
- IO->ID, CCID, NODE, N)
+ "%s[%ld]CC[%d]NW[%s][%ld]" FORMAT, \
+ IOSTR, IO->ID, CCID, NODE, N)
#define EVNCS_syslog(LEVEL, FORMAT, ...) \
- NCDBGLOG(LEVEL) syslog(LEVEL, "IO[%ld]NW[%s][%ld]" FORMAT, \
- IO->ID, NODE, N, __VA_ARGS__)
+ NCDBGLOG(LEVEL) syslog(LEVEL, "%s[%ld]NW[%s][%ld]" FORMAT, \
+ IOSTR, IO->ID, NODE, N, __VA_ARGS__)
#define EVNCSM_syslog(LEVEL, FORMAT) \
- NCDBGLOG(LEVEL) syslog(LEVEL, "IO[%ld]NW[%s][%ld]" FORMAT, \
- IO->ID, NODE, N)
+ NCDBGLOG(LEVEL) syslog(LEVEL, "%s[%ld]NW[%s][%ld]" FORMAT, \
+ IOSTR, IO->ID, NODE, N)
typedef enum _eNWCState {
long lens[2];
const char *strs[2];
+ EVN_syslog(LOG_DEBUG, "NWC: %s\n", __FUNCTION__);
+
strs[0] = ChrPtr(NW->node);
lens[0] = StrLength(NW->node);
"Connected to node \"%s\" but I was expecting to connect to node \"%s\".",
connected_to, ChrPtr(NW->node));
EVN_syslog(LOG_ERR, "%s\n", ChrPtr(NW->IO.ErrMsg));
- StopClientWatchers(IO, 1);
- return QueueDBOperation(IO, NWC_SendFailureMessage);
+
+ return EventQueueDBOperation(IO, NWC_SendFailureMessage, 1);
}
return eSendReply;
}
else {
SetNWCState(IO, eNWCVSAuthFailNTT);
EVN_syslog(LOG_ERR, "%s\n", ChrPtr(NW->IO.ErrMsg));
- StopClientWatchers(IO, 1);
- return QueueDBOperation(IO, NWC_SendFailureMessage);
+ return EventQueueDBOperation(IO, NWC_SendFailureMessage, 1);
}
return eAbort;
}
eNextState NWC_FailNetworkConnection(AsyncIO *IO)
{
SetNWCState(IO, eNWCVSConnFail);
- StopClientWatchers(IO, 1);
- return QueueDBOperation(IO, NWC_SendFailureMessage);
+ return EventQueueDBOperation(IO, NWC_SendFailureMessage, 1);
}
void NWC_SetTimeout(eNextState NextTCPState, AsyncNetworker *NW)
{
- AsyncIO *IO = &NW->IO;
double Timeout = 0.0;
- EVN_syslog(LOG_DEBUG, "%s - %d\n", __FUNCTION__, NextTCPState);
+ //EVN_syslog(LOG_DEBUG, "%s - %d\n", __FUNCTION__, NextTCPState);
switch (NextTCPState) {
case eSendMore:
return;
}
if (Timeout > 0) {
+ AsyncIO *IO = &NW->IO;
EVN_syslog(LOG_DEBUG,
"%s - %d %f\n",
__FUNCTION__,
rc = NWC_ReadHandlers[NW->State](NW);
- if (rc != eReadMore)
+ if ((rc != eReadMore) &&
+ (rc != eAbort) &&
+ (rc != eDBQuery)) {
NW->State++;
+ }
NWC_SetTimeout(rc, NW);