X-Git-Url: https://code.citadel.org/?p=citadel.git;a=blobdiff_plain;f=citadel%2Fmodules%2Frssclient%2Fserv_rssclient.c;h=e2e9aea12ec9bf8db65213a8b787012234485dab;hp=f9355025a09ceb65b1268d1c3a712c081998a9c5;hb=192056a6112602350c1f8a73eae2e134a31c7ba2;hpb=e83d78b9d9bd2d5ad7b440fd6bc01efae2ad8cf6 diff --git a/citadel/modules/rssclient/serv_rssclient.c b/citadel/modules/rssclient/serv_rssclient.c index f9355025a..e2e9aea12 100644 --- a/citadel/modules/rssclient/serv_rssclient.c +++ b/citadel/modules/rssclient/serv_rssclient.c @@ -459,7 +459,7 @@ int rss_do_fetching(rss_aggregator *Cfg) return 0; } - evcurl_handle_start(IO); + QueueCurlContext(IO); return 1; } @@ -498,12 +498,12 @@ void DeleteRssCfg(void *vptr) eNextState RSSAggregatorTerminate(AsyncIO *IO) { rss_aggregator *rncptr = (rss_aggregator *)IO->Data; - /* - HashPos *At; - long HKLen; - const char *HK; - void *vData; - */ + + HashPos *At; + long HKLen; + const char *HK; + void *vData; + pthread_mutex_lock(&RSSQueueMutex); rncptr->RefCount --; if (rncptr->RefCount == 0) @@ -512,7 +512,7 @@ eNextState RSSAggregatorTerminate(AsyncIO *IO) } pthread_mutex_unlock(&RSSQueueMutex); -/* + At = GetNewHashPos(RSSFetchUrls, 0); pthread_mutex_lock(&RSSQueueMutex); @@ -522,7 +522,6 @@ eNextState RSSAggregatorTerminate(AsyncIO *IO) pthread_mutex_unlock(&RSSQueueMutex); DeleteHashPos(&At); -*/ return eAbort; } @@ -648,7 +647,7 @@ void rssclient_scan_room(struct ctdlroom *qrbuf, void *data) pthread_mutex_unlock(&RSSQueueMutex); - FreeStrBuf(&rncptr->Url); + FreeStrBuf(&rncptr->Url); free(rncptr); rncptr = NULL; continue;