}
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;