}
-/*! \brief Create the notify message queue. We use the exact same room
- * as the Funambol module.
+/* Create the notify message queue. We use the exact same room
+ * as the Funambol module.
*
- * Run at server startup, creates FNBL_QUEUE_ROOM if it doesn't exist
- * and sets as system room.
+ * Run at server startup, creates FNBL_QUEUE_ROOM if it doesn't exist
+ * and sets as system room.
*/
void create_extnotify_queue(void) {
struct ctdlroom qrbuf;
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
*/
CtdlLogPrintf(CTDL_DEBUG, "serv_extnotify: queue run completed\n");
doing_queue = 0;
- CtdlClearSystemContext();
}
-/*!
- * \brief Process messages in the external notification queue
+
+/*
+ * Process messages in the external notification queue
*/
void process_notify(long NotifyMsgnum, void *usrdata)
{
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;
CtdlLogPrintf(CTDL_DEBUG, "pop3client ended\n");
last_run = time(NULL);
doing_pop3client = 0;
- CtdlClearSystemContext();
}
static time_t last_run = 0L;
static int doing_rssclient = 0;
rssnetcfg *rptr = NULL;
- CitContext rssclientCC;
-
- /* Give this thread its own private CitContext */
- CtdlFillSystemContext(&rssclientCC, "rssclient");
- citthread_setspecific(MyConKey, (void *)&rssclientCC );
/*
* This is a simple concurrency check to make sure only one rssclient run
CtdlLogPrintf(CTDL_DEBUG, "rssclient ended\n");
last_run = time(NULL);
doing_rssclient = 0;
- CtdlClearSystemContext();
return NULL;
}