projects
/
citadel.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
RSS-CLIENT: remember checksum for whole feed, so we can save parsing work if we know...
[citadel.git]
/
citadel
/
modules
/
rssclient
/
rss_atom_parser.c
diff --git
a/citadel/modules/rssclient/rss_atom_parser.c
b/citadel/modules/rssclient/rss_atom_parser.c
index 86346296244eb3504d1f7b5bccaa532b9b805a50..c1f5285804341e07aaa525ed0076c271fa0d8d07 100644
(file)
--- 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);
}
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
/*
* 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;
eNextState RSSAggregator_ParseReply(AsyncIO *IO)
{
StrBuf *Buf;
@@
-966,16
+970,6
@@
eNextState RSSAggregator_ParseReply(AsyncIO *IO)
long len;
const char *Key;
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);
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))
&len,
&Key,
(void**) &RSSAggr->ThisMsg))
- return
Queue
DBOperation(IO, RSS_FetchNetworkUsetableEntry);
+ return
Next
DBOperation(IO, RSS_FetchNetworkUsetableEntry);
else
return eAbort;
}
else
return eAbort;
}