/* write the uidl to the use table so we don't store this item again */
- CheckIfAlreadySeen("RSS Item Insert", RSSAggr->ThisMsg->MsgGUID, IO->Now, 0, eWrite, CCID, IO->ID);
+ CheckIfAlreadySeen("RSS Item Insert", RSSAggr->ThisMsg->MsgGUID, EvGetNow(IO), 0, eWrite, CCID, IO->ID);
}
if (GetNextHashPos(RSSAggr->Messages,
eNextState RSS_FetchNetworkUsetableEntry(AsyncIO *IO)
{
static const time_t antiExpire = USETABLE_ANTIEXPIRE_HIRES;
- time_t seenstamp = 0;
#ifndef DEBUG_RSS
+ time_t seenstamp = 0;
const char *Key;
long len;
rss_aggregator *Ctx = (rss_aggregator *) IO->Data;
SetRSSState(IO, eRSSUT);
seenstamp = CheckIfAlreadySeen("RSS Item Seen",
Ctx->ThisMsg->MsgGUID,
- IO->Now,
+ EvGetNow(IO),
antiExpire,
eCheckUpdate,
CCID, IO->ID);
- if (seenstamp < antiExpire)
+ if (seenstamp != 0)
{
/* Item has already been seen */
EVRSSC_syslog(LOG_DEBUG,
ChrPtr(ErrMsg),
"RSS Aggregation run failure",
2, strs, (long*) &lens,
- IO->Now,
- IO->ID, CCID);
+ CCID,
+ IO->ID,
+ EvGetNow(IO));
FreeStrBuf(&ErrMsg);
EVRSSC_syslog(LOG_DEBUG,
while (pCfg != NULL)
{
- UpdateLastKnownGood (pCfg, IO->Now);
+ UpdateLastKnownGood (pCfg, EvGetNow(IO));
if ((Ctx->roomlist_parts > 1) &&
(it == NULL))
{
if (CheckIfAlreadySeen("RSS Whole",
guid,
- IO->Now,
- IO->Now - USETABLE_ANTIEXPIRE,
+ EvGetNow(IO),
+ EvGetNow(IO) - USETABLE_ANTIEXPIRE,
eCheckUpdate,
CCID, IO->ID)
!= 0)