libqb/tests/loop.c

/*
 * Copyright (C) 2010 Red Hat, Inc.
 *
 * Author: Angus Salkeld <asalkeld@redhat.com>
 *
 * This file is part of libqb.
 *
 * libqb is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as published by
 * the Free Software Foundation, either version 2.1 of the License, or
 * (at your option) any later version.
 *
 * libqb is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with libqb.  If not, see <http://www.gnu.org/licenses/>.
 */
#include "os_base.h"
#include <sys/poll.h>

#include <qb/qbdefs.h>
#include <qb/qbutil.h>
#include <qb/qblog.h>
#include <qb/qbloop.h>

static struct qb_loop *l;
static qb_loop_timer_handle th;

static void job_3_9(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_1_2(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_2_4(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_3_5(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_3_6(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_1_1(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_3_7(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_2_3(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_2_8(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }
static void job_1_9(void *data) { qb_log(LOG_INFO, "%s\n", __func__); }

static void more_important_jobs(void *data)
{
	qb_enter();
	qb_loop_job_add(l, QB_LOOP_HIGH, NULL, job_1_2);
	qb_loop_job_add(l, QB_LOOP_HIGH, NULL, job_1_9);
}

static int32_t handle_reconf_signal(int32_t sig, void *data)
{
	qb_log(LOG_INFO, "signal %d", sig);
	return 0;
}

static int32_t handle_exit_signal(int32_t sig, void *data)
{
	qb_log(LOG_INFO, "exiting (signal %d)... bye", sig);
	qb_loop_stop(l);
	return -1;
}

static void more_jobs(void *data)
{
	qb_log(LOG_INFO, "%s\n", __func__);
	qb_loop_timer_add(l, QB_LOOP_HIGH, 3109*QB_TIME_NS_IN_MSEC, NULL, job_1_1, &th);
	qb_loop_job_add(l, QB_LOOP_LOW,  NULL, job_3_7);
	qb_loop_timer_add(l, QB_LOOP_LOW, 1000*QB_TIME_NS_IN_MSEC, NULL, more_important_jobs, &th);
	qb_loop_job_add(l, QB_LOOP_LOW,  NULL, job_3_7);
	qb_loop_timer_add(l, QB_LOOP_LOW, 2341*QB_TIME_NS_IN_MSEC, NULL, job_3_7, &th);
	qb_loop_timer_add(l, QB_LOOP_LOW, 900, NULL, job_3_6, &th);
	qb_loop_job_add(l, QB_LOOP_LOW,  NULL, job_3_5);
	qb_loop_timer_add(l, QB_LOOP_MED, 4000*QB_TIME_NS_IN_MSEC, NULL, more_jobs, &th);
	qb_loop_job_add(l, QB_LOOP_LOW,  NULL, job_3_9);
	qb_loop_job_add(l, QB_LOOP_HIGH, NULL, job_1_9);
	qb_loop_job_add(l, QB_LOOP_MED,  NULL, job_2_3);
}

static int32_t read_stdin(int32_t fd, int32_t revents, void *data)
{
	char buf[100];
	ssize_t len = read(fd, buf, 100);
	buf[len-1] = '\0';
	qb_log(LOG_INFO, "typed > \"%s\"\n", buf);
	if (strcmp(buf, "more") == 0) {
		more_jobs(NULL);
	}
	qb_loop_job_add(l, QB_LOOP_LOW,  NULL, job_3_9);
	return 0;
}

int main(int argc, char * argv[])
{
	qb_loop_signal_handle sh;

	qb_log_init("loop", LOG_USER, LOG_EMERG);
	qb_log_ctl(QB_LOG_SYSLOG, QB_LOG_CONF_ENABLED, QB_FALSE);
	qb_log_filter_ctl(QB_LOG_STDERR, QB_LOG_FILTER_ADD,
			  QB_LOG_FILTER_FILE, "*", LOG_DEBUG);
	qb_log_ctl(QB_LOG_STDERR, QB_LOG_CONF_ENABLED, QB_TRUE);

	l = qb_loop_create();

	qb_loop_job_add(l, QB_LOOP_LOW,  NULL, job_3_9);
	qb_loop_job_add(l, QB_LOOP_LOW,  NULL, job_2_4);
	qb_loop_job_add(l, QB_LOOP_HIGH, NULL, job_1_2);
	qb_loop_job_add(l, QB_LOOP_MED,  NULL, job_3_7);
/*
 * 	qb_loop_timer_add(l, QB_LOOP_HIGH, 40*QB_TIME_NS_IN_MSEC, NULL, more_jobs, &th);
 */
	qb_loop_job_add(l, QB_LOOP_MED,  NULL, job_2_8);
	qb_loop_job_add(l, QB_LOOP_LOW,  NULL, job_3_6);

	qb_loop_poll_add(l, QB_LOOP_LOW, 0, POLLIN | POLLPRI | POLLNVAL,
			     NULL, read_stdin);

	qb_loop_signal_add(l, QB_LOOP_MED, SIGINT, NULL, handle_exit_signal, &sh);
	qb_loop_signal_add(l, QB_LOOP_MED, SIGSEGV, NULL, handle_exit_signal, &sh);
	qb_loop_signal_add(l, QB_LOOP_MED, SIGHUP, NULL, handle_reconf_signal, &sh);

	qb_loop_run(l);
	return 0;
}