if (rss_format_item(IO, RSSAggr->ThisMsg))
{
- CM_SetAsFieldSB(&RSSAggr->ThisMsg->Msg, eMesageText,
- &RSSAggr->ThisMsg->Message);
-
+ CM_SetAsFieldSB(&RSSAggr->ThisMsg->Msg, eMesageText, &RSSAggr->ThisMsg->Message);
CtdlSubmitMsg(&RSSAggr->ThisMsg->Msg, &RSSAggr->recp, NULL, 0);
/* write the uidl to the use table so we don't store this item again */
-
CheckIfAlreadySeen("RSS Item Insert", RSSAggr->ThisMsg->MsgGUID, EvGetNow(IO), 0, eWrite, CCID, IO->ID);
}
while (RSSCfg != NULL)
{
pthread_mutex_lock(&RSSQueueMutex);
- GetHash(RSSFetchUrls,
- SKEY(RSSCfg->Url),
- &vptr);
+ GetHash(RSSFetchUrls, SKEY(RSSCfg->Url), &vptr);
use_this_RSSAggr = (rss_aggregator *)vptr;
if (use_this_RSSAggr != NULL)
{
pRSSConfig *pRSSCfg;
- StrBufAppendBufPlain(
- use_this_RSSAggr->rooms,
- qrbuf->QRname,
- -1, 0);
+ StrBufAppendBufPlain(use_this_RSSAggr->rooms, qrbuf->QRname, -1, 0);
if (use_this_RSSAggr->roomlist_parts==1)
{
use_this_RSSAggr->OtherQRnumbers
"rssclient: concurrency check failed; %d rooms and %d url's are queued",
RSSRoomCount, RSSCount
);
+ abort();
return;
}
become_session(&rss_CC);
EVRSSQM_syslog(LOG_DEBUG, "rssclient started");
- CtdlForEachNetCfgRoom(rssclient_scan_room, NULL, rssclient);
+ CtdlForEachNetCfgRoom(rssclient_scan_room, NULL);
if (GetCount(RSSFetchUrls) > 0)
{
Info.Now = time (NULL);
Info.Veto = 0;
- CtdlForEachNetCfgRoom(rssclient_veto_scan_room, &Info, rssclient);
+ CtdlForEachNetCfgRoom(rssclient_veto_scan_room, &Info);
return Info.Veto;;
}