Function Cron_Run

src/cron/cron.c:187–215

//------------------------------------------------------------------------------

static void *Cron_Run
(
	void *arg
) {
	while(cron->alive) {
		// execute due tasks
		CRON_TASK *task = NULL;
		while((task = CRON_Peek()) && CRON_TaskDue(task)) {
			if(!CRON_RemoveCurrentTask(task)) {
				// task is aborted
				continue;
			}

			// perform and free task
			CRON_PerformTask(task);
			cron->current_task = NULL;
			CRON_FreeTask(task);
		}

		// sleep
		struct timespec timeout = (task) ? task->due : due_in_ms(1000);
		pthread_mutex_lock(&cron->condv_mutex);
		int res = pthread_cond_timedwait(&cron->condv, &cron->condv_mutex, &timeout);
		ASSERT(res == 0 || res == ETIMEDOUT);
		pthread_mutex_unlock(&cron->condv_mutex);
	}

	return NULL;
}

//------------------------------------------------------------------------------
// User facing API