[khatus.git] / x5 / khatus_sensor_time.c

#include <assert.h>
#include <ctype.h>
#include <errno.h>
#include <fcntl.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>

#include "khatus_lib_log.h"
#include "khatus_lib_time.h"

#define usage(...) {print_usage(); fprintf(stderr, "Error:\n    " __VA_ARGS__); exit(EXIT_FAILURE);}

#define MAX_LEN 20
#define END_OF_MESSAGE '\n'

char *argv0;

void
print_usage()
{
	printf(
	    "%s: [OPT ...] FIFO\n"
	    "\n"
	    "FIFO = string    # path to fifo file\n"
	    "OPT = -i int     # interval\n"
	    "    | -f string  # format string\n"
	    "    | -h         # help message (i.e. what you're reading now :) )\n",
	    argv0);
}

int
main(int argc, char **argv)
{
	argv0 = argv[0];

	double opt_interval = 1.0;
	char *opt_fmt = "%a %b %d %H:%M:%S";

	time_t t;
	struct timespec ti;
	char buf[MAX_LEN];
	char c;

	char *fifo_name;
	int   fifo_fd = -1;

	int n = 0;  /* written */
	int r = 0;  /* remaining */
	int i = 0;  /* buffer position */

	signal(SIGPIPE, SIG_IGN);  /* Handling manually */

	memset(buf, '\0', MAX_LEN);
	while ((c = getopt(argc, argv, "f:i:h")) != -1)
		switch (c) {
		case 'f':
			opt_fmt = calloc(strlen(optarg), sizeof(char));
			strcpy(opt_fmt, optarg);
			break;
		case 'i':
			opt_interval = atof(optarg);
			break;
		case 'h':
			print_usage();
			return 0;
		case '?':
			if (optopt == 'f' || optopt == 'i')
				fprintf(stderr,
					"Option -%c requires an argument.\n",
					optopt);
			else if (isprint(optopt))
				fprintf (stderr,
					"Unknown option `-%c'.\n",
					optopt);
			else
				fprintf(stderr,
					"Unknown option character `\\x%x'.\n",
					optopt);
			return 1;
		default:
			assert(0);
		}
	fifo_name = argv[optind];
	debug("fifo_name: %s\n", fifo_name);
	if (!fifo_name)
		usage("No filename was provided\n");
	ti = timespec_of_float(opt_interval);
	for (;;) {
		debug("openning \"%s\"\n", fifo_name);
		fifo_fd = open(fifo_name, O_WRONLY);
		if (fifo_fd < 0)
			fatal("Failed to open FIFO file: \"%s\". Error: %s\n",
			    fifo_name,
			    strerror(errno));
		debug("openned. fd: %d\n", fifo_fd);
		t = time(NULL);
		strftime(buf, MAX_LEN, opt_fmt, localtime(&t));
		r = strlen(buf);
		buf[r] = END_OF_MESSAGE;
		for (i = 0; (n = write(fifo_fd, buf + i++, 1)) && r; r--)
			;
		if (n < 0)
			fatal("Failed to write to %s. Err num: %d, Err msg: %s\n",
			    fifo_name,
			    errno,
			    strerror(errno));
		if (close(fifo_fd) < 0)
			fatal("Failed to close %s. Err num: %d, Err msg: %s\n",
			    fifo_name,
			    errno,
			    strerror(errno));
		fifo_fd = -1;
		debug("closed. fd: %d\n", fifo_fd);
		snooze(&ti);
	}
	return EXIT_SUCCESS;
}
Commit	Line	Data
707b2f79 SK	1	#include <assert.h>
707b2f79 SK	2	#include <ctype.h>
8345f2b3	3	#include <errno.h>
707b2f79 SK	4	#include <fcntl.h>
707b2f79 SK	5	#include <signal.h>
8345f2b3 SK	6	#include <stdio.h>
	7	#include <stdlib.h>
	8	#include <string.h>
	9	#include <time.h>
	10	#include <unistd.h>
	11
	12	#include "khatus_lib_log.h"
	13	#include "khatus_lib_time.h"
	14
707b2f79 SK	15	#define usage(...) {print_usage(); fprintf(stderr, "Error:\n " __VA_ARGS__); exit(EXIT_FAILURE);}
	16
	17	#define MAX_LEN 20
	18	#define END_OF_MESSAGE '\n'
	19
8345f2b3 SK	20	char *argv0;
	21
	22	void
707b2f79	23	print_usage()
8345f2b3 SK	24	{
8345f2b3 SK	25	printf(
707b2f79	26	"%s: [OPT ...] FIFO\n"
8345f2b3	27	"\n"
707b2f79	28	"FIFO = string # path to fifo file\n"
8345f2b3 SK	29	"OPT = -i int # interval\n"
	30	" \| -f string # format string\n"
	31	" \| -h # help message (i.e. what you're reading now :) )\n",
	32	argv0);
8345f2b3 SK	33	}
	34
	35	int
	36	main(int argc, char **argv)
	37	{
	38	argv0 = argv[0];
	39
	40	double opt_interval = 1.0;
	41	char *opt_fmt = "%a %b %d %H:%M:%S";
	42
	43	time_t t;
	44	struct timespec ti;
707b2f79	45	char buf[MAX_LEN];
8345f2b3 SK	46	char c;
8345f2b3 SK	47
707b2f79 SK	48	char *fifo_name;
	49	int fifo_fd = -1;
	50
	51	int n = 0; /* written */
	52	int r = 0; /* remaining */
	53	int i = 0; /* buffer position */
	54
	55	signal(SIGPIPE, SIG_IGN); /* Handling manually */
	56
	57	memset(buf, '\0', MAX_LEN);
8345f2b3 SK	58	while ((c = getopt(argc, argv, "f:i:h")) != -1)
	59	switch (c) {
	60	case 'f':
	61	opt_fmt = calloc(strlen(optarg), sizeof(char));
	62	strcpy(opt_fmt, optarg);
	63	break;
	64	case 'i':
	65	opt_interval = atof(optarg);
	66	break;
	67	case 'h':
707b2f79 SK	68	print_usage();
	69	return 0;
	70	case '?':
	71	if (optopt == 'f' \|\| optopt == 'i')
	72	fprintf(stderr,
	73	"Option -%c requires an argument.\n",
	74	optopt);
	75	else if (isprint(optopt))
	76	fprintf (stderr,
	77	"Unknown option `-%c'.\n",
	78	optopt);
	79	else
	80	fprintf(stderr,
	81	"Unknown option character `\\x%x'.\n",
	82	optopt);
	83	return 1;
8345f2b3	84	default:
707b2f79	85	assert(0);
8345f2b3	86	}
707b2f79 SK	87	fifo_name = argv[optind];
	88	debug("fifo_name: %s\n", fifo_name);
	89	if (!fifo_name)
	90	usage("No filename was provided\n");
8345f2b3 SK	91	ti = timespec_of_float(opt_interval);
8345f2b3 SK	92	for (;;) {
707b2f79 SK	93	debug("openning \"%s\"\n", fifo_name);
	94	fifo_fd = open(fifo_name, O_WRONLY);
	95	if (fifo_fd < 0)
	96	fatal("Failed to open FIFO file: \"%s\". Error: %s\n",
	97	fifo_name,
	98	strerror(errno));
	99	debug("openned. fd: %d\n", fifo_fd);
8345f2b3	100	t = time(NULL);
707b2f79 SK	101	strftime(buf, MAX_LEN, opt_fmt, localtime(&t));
	102	r = strlen(buf);
	103	buf[r] = END_OF_MESSAGE;
	104	for (i = 0; (n = write(fifo_fd, buf + i++, 1)) && r; r--)
	105	;
	106	if (n < 0)
	107	fatal("Failed to write to %s. Err num: %d, Err msg: %s\n",
	108	fifo_name,
	109	errno,
	110	strerror(errno));
	111	if (close(fifo_fd) < 0)
	112	fatal("Failed to close %s. Err num: %d, Err msg: %s\n",
	113	fifo_name,
	114	errno,
	115	strerror(errno));
	116	fifo_fd = -1;
	117	debug("closed. fd: %d\n", fifo_fd);
8345f2b3 SK	118	snooze(&ti);
	119	}
	120	return EXIT_SUCCESS;
	121	}