main.c

/*
 * Copyright (C) 2015, CompuLab ltd.
 * Author: Andrey Gelman <andrey.gelman@compulab.co.il>
 * License: GNU GPLv2 or later, at your option
 */

#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <errno.h>
#include <fcntl.h>
#include <syslog.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/file.h>
#include <sensors/sensors.h>

#include "common.h"
#include "thread-pool.h"
#include "registers.h"
#include "panel.h"
#include "sensors.h"
#include "domain-logic.h"
#include "stats.h"
#include "vga-tools.h"
#include "hdd-info.h"
#include "options.h"


ThreadPool *frontend_thread;
ThreadPool *backend_thread;

static InProcessingBitmap in_processing = {0};
static Options options;

static void main_thread(void *priv_context, void *shared_context);


static void signal_handler(int signo)
{
	switch (signo)
	{
	case SIGALRM:
		thread_pool_add_request(frontend_thread, main_thread, NULL);
		break;

	case SIGUSR1:
		stat_show();
		break;

	case SIGUSR2:
		/* nothing - interrupt sleep */
		break;
	}
}

static void install_sighandler(int signo)
{
	struct sigaction sig = {{0}};
	int err;

	sig.sa_handler = signal_handler;
	sigemptyset(&sig.sa_mask);
	sig.sa_flags = SA_RESTART;

	err = sigaction(signo, &sig, NULL);
	if (err) {
		sloge("Signal %d: could not install handler: %d", signo, err);
		exit(EXIT_FAILURE);
	}
}

enum {DTERM_INIT, DTERM_WAIT};

static void daemon_termination(int phase)
{
	sigset_t signals;
	int signo = 0;

	sigemptyset(&signals);
	sigaddset(&signals, SIGTERM);

	switch (phase) {
	case DTERM_INIT:
		pthread_sigmask(SIG_BLOCK, &signals, NULL);
		break;
	case DTERM_WAIT:
		while (signo != SIGTERM)
			sigwait(&signals, &signo);
		break;
	}
}

static void daemonize(void)
{
	int fd;
	int err;

	/*
	 * assert a single instance of the daemon
	 */
	fd = open(ATFP_DAEMON_LOCKFILE, O_CREAT, 0);
	if (fd < 0) {
		fprintf(stderr, "Could not open lock file: %d. \n", errno);
		exit(1);
	}
	err = flock(fd, (LOCK_EX | LOCK_NB));
	if (err < 0) {
		if (errno == EWOULDBLOCK)
			fprintf(stderr, "An instance of the daemon already runs. \n");
		else
			fprintf(stderr, "Could not acquire lock file: %d. \n", errno);
		exit(1);
	}

	/*
	 * fork background daemon
	 */
	err = daemon(0, 0);
	if (err < 0) {
		fprintf(stderr, "Could not daemon-ize: %m \n");
		exit(1);
	}
	umask(0022);
}

static void initialize(void)
{
	int err;

	/* set up logging */
	openlog(ATFP_SYSLOG_IDENT, LOG_PID, LOG_USER);
	setlogmask(LOG_UPTO(options.loglevel));

	install_sighandler(SIGALRM);
	install_sighandler(SIGUSR1);
	install_sighandler(SIGUSR2);
	daemon_termination(DTERM_INIT);
	err = panel_open_i2c(options.i2c_bus, I2C_PANEL_INTERFACE_ADDR, options.i2c_delay);
	if ( err )
		exit(1);
	err = panel_reset();
	if ( err )
		exit(1);

	err = sensors_coretemp_init();
	if ( err )
		exit(1);

	gpu_sensors_init();

	frontend_thread = thread_pool_create(1, ATFP_FRONTEND_QUEUE_LEN, &in_processing);
	backend_thread = thread_pool_create(ATFP_BACKEND_THREAD_NUM, ATFP_BACKEND_QUEUE_LEN, NULL);
}

static void cleanup(void)
{
	thread_pool_join(frontend_thread);
	thread_pool_destroy(backend_thread);
	thread_pool_destroy(frontend_thread);

	panel_close();
	sensors_cleanup();
	closelog();
}

static void show_info_and_exit(void)
{
	char *p;
	char *name_list;
	DList *dl;
	SMARTinfo *si;

	name_list = vga_driver_name_list();
	printf("Video drivers: %s \n", strtok(name_list, " "));
	while ((p = strtok(NULL, " ")) != NULL)
		printf("               %s \n", p);

	printf("\nTemperature sensors: \n");
	sensors_show(SENSORS_FEATURE_TEMP);

	printf("\nHDD: \n");
	hdd_get_temperature(&dl);
	while ((si = dlist_pop_front(dl)) != NULL) {
		printf("%10s: ", si->devname);
		if (si->size_valid)
			printf("%u [GB] \n", si->size_GB);
		else
			printf("-- \n");

		delete_SMARTinfo(si);
	}

	exit(0);
}

#define UNSUPPORTED_REQ_MESSAGE(r)	do { slogw("%s: "#r" request is not supported", __FUNCTION__); } while (0)

void in_processing_add_request(long request, InProcessingBitmap *processing)
{
	processing->bitmap |= request;
}

void in_processing_remove_request(long request, InProcessingBitmap *processing)
{
	processing->bitmap &= ~request;
}

long in_processing_get_bitmap(InProcessingBitmap *processing)
{
	return processing->bitmap;
}

static void main_thread(void *priv_context, void *shared_context)
{
	int i;
	long request_bitmap;
	long request;
	InProcessingBitmap *processing = (InProcessingBitmap *)shared_context;

	request_bitmap = ATFP_MASK_PENDR0_HDDTR | ATFP_MASK_PENDR0_CPUFR |
			 ATFP_MASK_PENDR0_CPUTR | ATFP_MASK_PENDR0_GPUTR;

	/* (optionally) disable particular functions */
	request_bitmap &= ~options.disable;

	/* ignore requests currently being processed */
	request_bitmap &= ~in_processing_get_bitmap(processing);

	/* dispatch each request */
	for (i = 0; i < (sizeof(request_bitmap) * 8); ++i) {
		request = request_bitmap & (1L << i);
		in_processing_add_request(request, processing);
		switch (request) {
		case 0:
			/* no pending requests */
			break;

		case ATFP_MASK_PENDR0_HDDTR:
			panel_update_hdd_temp();
			break;

		case ATFP_MASK_PENDR0_CPUFR:
			panel_update_frequency();
			break;

		case ATFP_MASK_PENDR0_CPUTR:
			panel_update_temperature();
			break;

		case ATFP_MASK_PENDR0_GPUTR:
			panel_update_gpu_temp();
			break;

		default:
			/* 'request' should not be added in the first place */
			in_processing_remove_request(request, processing);
			break;
		}
	}

	/* program our next appearance */
	alarm(options.poll_cycle);
}


int main(int argc, char *argv[])
{
	options_process_or_abort(&options, argc, argv);
	if (options.info)
		show_info_and_exit();

	if ( !options.i2c_bus_set ) {
		options.i2c_bus = panel_lookup_i2c_bus();
		if (options.i2c_bus < 0) {
			fprintf(stderr, "Could not detect front panel I2C bus \n");
			exit(1);
		}
	}

	daemonize();
	initialize();
	slogn("AirTop Front-Panel Service -- start");
	/*
	 * Main FP communication routine is armed
	 * upon SIGALRM reception.
	 */
	alarm(ATFP_MAIN_STARTUP_DELAY);
	FP_store_daemon_postcode();
	daemon_termination(DTERM_WAIT);
	slogn("AirTop Front-Panel Service -- stop");

	cleanup();
	return 0;
}