*/
void do_extnotify_queue(void)
{
+
NotifyContext Ctx;
static int doing_queue = 0;
int i = 0;
+ CitContext extnotifyCC;
/*
* This is a simple concurrency check to make sure only one queue run
*/
if (doing_queue) return;
doing_queue = 1;
+
+ /* Give this thread its own private CitContext */
+ CtdlFillSystemContext(&extnotifyCC, "extnotify");
+ citthread_setspecific(MyConKey, (void *)&extnotifyCC );
/*
* Go ahead and run the queue
Ctx.NotifyHostList = GetNotifyHosts();
if (CtdlGetRoom(&CC->room, FNBL_QUEUE_ROOM) != 0) {
CtdlLogPrintf(CTDL_ERR, "Cannot find room <%s>\n", FNBL_QUEUE_ROOM);
+ CtdlClearSystemContext();
return;
}
CtdlForEachMessage(MSGS_ALL, 0L, NULL,
CtdlLogPrintf(CTDL_DEBUG, "serv_extnotify: queue run completed\n");
doing_queue = 0;
+ CtdlClearSystemContext();
}
/*!
* \brief Process messages in the external notification queue
static int doing_pop3client = 0;
struct pop3aggr *pptr;
time_t fastest_scan;
-
+ CitContext popclientCC;
+
+ /* Give this thread its own private CitContext */
+ CtdlFillSystemContext(&popclientCC, "popclient");
+ citthread_setspecific(MyConKey, (void *)&popclientCC );
+
if (config.c_pop3_fastest < config.c_pop3_fetch)
fastest_scan = config.c_pop3_fastest;
else
CtdlLogPrintf(CTDL_DEBUG, "pop3client ended\n");
last_run = time(NULL);
doing_pop3client = 0;
+ CtdlClearSystemContext();
}