}
FreeAsyncIOContents(&RSSAggr->IO);
+ memset(RSSAggr, 0, sizeof(rss_aggregator));
free(RSSAggr);
}
EVRSSCM_syslog(LOG_DEBUG, "RSS: Terminating.\n");
-
+ StopCurlWatchers(IO);
UnlinkRSSAggregator(RSSAggr);
return eAbort;
}
EVRSSCM_syslog(LOG_DEBUG, "RSS: Terminating.\n");
+ StopDBWatchers(&RSSAggr->IO);
UnlinkRSSAggregator(RSSAggr);
return eAbort;
}
return eAbort;
}
-
-eNextState AbortNetworkSaveMessage (AsyncIO *IO)
-{
- return eAbort; ///TODO
-}
-
eNextState RSSSaveMessage(AsyncIO *IO)
{
long len;
DeleteHash(&RSSQueueRooms);
}
-void LogDebugEnableRSSClient(void)
+void LogDebugEnableRSSClient(const int n)
{
- RSSClientDebugEnabled = 1;
+ RSSClientDebugEnabled = n;
}
CTDL_MODULE_INIT(rssclient)
syslog(LOG_INFO, "%s\n", curl_version());
CtdlRegisterSessionHook(rssclient_scan, EVT_TIMER);
CtdlRegisterEVCleanupHook(rss_cleanup);
- CtdlRegisterDebugFlagHook(HKEY("rssclient"), LogDebugEnableRSSClient);
+ CtdlRegisterDebugFlagHook(HKEY("rssclient"), LogDebugEnableRSSClient, &RSSClientDebugEnabled);
}
return "rssclient";
}