FlushStrBuf(RSSAggr->CData);
}
+
+
/*
* Callback function for passing libcurl's output to expat for parsing
* we don't do streamed parsing so expat can handle non-utf8 documents
}
*/
+
+
eNextState RSSAggregator_ParseReply(AsyncIO *IO)
{
StrBuf *Buf;
long len;
const char *Key;
-
- if (IO->HttpReq.httpcode != 200)
- {
-
- EVRSSATOM_syslog(LOG_ALERT, "need a 200, got a %ld !\n",
- IO->HttpReq.httpcode);
-// TODO: aide error message with rate limit
- return eAbort;
- }
-
RSSAggr = IO->Data;
ri = RSSAggr->Item;
RSSAggr->CData = NewStrBufPlain(NULL, SIZ);
&len,
&Key,
(void**) &RSSAggr->ThisMsg))
- return QueueDBOperation(IO, RSS_FetchNetworkUsetableEntry);
+ return NextDBOperation(IO, RSS_FetchNetworkUsetableEntry);
else
return eAbort;
}