X-Git-Url: https://code.citadel.org/?a=blobdiff_plain;f=citadel%2Fmodules%2Frssclient%2Fserv_rssclient.c;h=c125f61748aa956a38d48a3915135e1e737db01e;hb=fd29e13821d3aa616b03d447f92cfb2de112b31d;hp=e2e9aea12ec9bf8db65213a8b787012234485dab;hpb=97668dbe6f8483b76010503dc467636701c6f1ac;p=citadel.git

diff --git a/citadel/modules/rssclient/serv_rssclient.c b/citadel/modules/rssclient/serv_rssclient.c
index e2e9aea12..c125f6174 100644
--- a/citadel/modules/rssclient/serv_rssclient.c
+++ b/citadel/modules/rssclient/serv_rssclient.c
@@ -240,6 +240,11 @@ void RSSQueueSaveMessage(struct CtdlMessage *Msg, struct recptypes *recp, StrBuf
 {
 	networker_save_message *Ctx;
 
+	pthread_mutex_lock(&RSSQueueMutex);
+	Cfg->RefCount ++;
+	pthread_mutex_unlock(&RSSQueueMutex);
+
+
 	Ctx = (networker_save_message *) malloc(sizeof(networker_save_message));
 	memset(Ctx, 0, sizeof(networker_save_message));
 	
@@ -434,7 +439,7 @@ int rss_do_fetching(rss_aggregator *Cfg)
 
 	if ((Cfg->next_poll != 0) && (now < Cfg->next_poll))
 		return 0;
-	Cfg->RefCount = 1;
+	Cfg->RefCount++;
 
 	ri = (rss_item*) malloc(sizeof(rss_item));
 	memset(ri, 0, sizeof(rss_item));