X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=citadel%2Fmodules%2Frssclient%2Frss_atom_parser.c;h=c1f5285804341e07aaa525ed0076c271fa0d8d07;hb=e296d96701baded9253071b142887af824a1db84;hp=86346296244eb3504d1f7b5bccaa532b9b805a50;hpb=1f6d08274ce7f2bacb657e039880bed95e49e029;p=citadel.git diff --git a/citadel/modules/rssclient/rss_atom_parser.c b/citadel/modules/rssclient/rss_atom_parser.c index 863462962..c1f528580 100644 --- a/citadel/modules/rssclient/rss_atom_parser.c +++ b/citadel/modules/rssclient/rss_atom_parser.c @@ -946,6 +946,8 @@ void rss_xml_end(void *data, const char *supplied_el) 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 @@ -956,6 +958,8 @@ size_t rss_libcurl_callback(void *ptr, size_t size, size_t nmemb, void *stream) } */ + + eNextState RSSAggregator_ParseReply(AsyncIO *IO) { StrBuf *Buf; @@ -966,16 +970,6 @@ eNextState RSSAggregator_ParseReply(AsyncIO *IO) 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); @@ -1045,7 +1039,7 @@ eNextState RSSAggregator_ParseReply(AsyncIO *IO) &len, &Key, (void**) &RSSAggr->ThisMsg)) - return QueueDBOperation(IO, RSS_FetchNetworkUsetableEntry); + return NextDBOperation(IO, RSS_FetchNetworkUsetableEntry); else return eAbort; }