AsyncNetworker *NW = IO->Data;
EVN_syslog(LOG_DEBUG, "%s\n", __FUNCTION__);
- EVN_syslog(LOG_DEBUG, "network: polling <%s>\n", ChrPtr(NW->node));
EVN_syslog(LOG_NOTICE, "Connecting to <%s> at %s:%s\n",
ChrPtr(NW->node),
ChrPtr(NW->host),
1);
}
+static int NetworkerCount = 0;
void RunNetworker(AsyncNetworker *NW)
{
+ AsyncIO *IO = &NW->IO;
+
+ NW->n = NetworkerCount++;
+ network_talking_to(SKEY(NW->node), NTT_ADD);
+ EVN_syslog(LOG_DEBUG, "network: polling <%s>\n", ChrPtr(NW->node));
ParseURL(&NW->IO.ConnectMe, NW->Url, 504);
InitIOStruct(&NW->IO,
ChrPtr(NW->port));
if (!network_talking_to(SKEY(NW->node), NTT_CHECK))
{
- network_talking_to(SKEY(NW->node), NTT_ADD);
RunNetworker(NW);
continue;
}