trace_dump.c

/*
	Copyright Jeroen Vreeken (pe1rxq@amsat.org), 2007, 2008, 2011, 2013
	Copyright Stichting C.A. Muller Radioastronomiestation, 2007, 2008, 2011

	This program is free software: you can redistribute it and/or modify
	it under the terms of the GNU General Public License as published by
	the Free Software Foundation, either version 3 of the License, or
	(at your option) any later version.

	This program 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 General Public License for more details.

	You should have received a copy of the GNU General Public License
	along with this program.  If not, see <http://www.gnu.org/licenses/>.

 */

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <string.h>
#include <math.h>

#include <trace/trace.h>

struct timespec t_int;
char *tracename;
enum trace_value_type tracetype;

static void handler_interval(struct trace *trace, 
    struct timespec *interval, enum trace_interval_type type)
{
	memcpy(&t_int, interval, sizeof(struct timespec));
}

static void handler_list_entry(struct trace *trace, 
    char *name, enum trace_value_type type, char *unit)
{
	if (!strcmp(name, tracename)) {
		tracetype = type;
	}
}

int main(int argc, char **argv)
{
	struct trace *trace;
	struct trace_pkt *pkt;
	int interval = 1;

	if (argc < 2) {
		printf("Usage:\n\n");
		printf("%s [trace] <interval>\n", argv[0]);
	}

	tracename = argv[1];

	trace = trace_open("localhost", 10000);

	if (argc >= 3) {
		interval = atoi(argv[2]);
	}
	
	trace->handler_interval = handler_interval;
	trace->handler_list_entry = handler_list_entry;

	while (trace_state_get(trace) == TRACE_STATE_CONNECTED) {
		fd_set fdrx;
		int high = 0;
		
		trace_fd_set(trace, &fdrx, &high);
		
		select(high + 1, &fdrx, NULL, NULL, NULL);
		
		trace_handle(trace, &fdrx);
	}
	
	if (interval != 1) {
		t_int.tv_sec *= interval;
		t_int.tv_nsec *= interval;
		
		if (t_int.tv_nsec > 1000000000) {
			t_int.tv_sec++;
			t_int.tv_nsec -= 1000000000;
		}

		pkt = trace_packet_new();
		trace_packet_interval_set(pkt, 
		    &t_int, TRACE_INTERVAL_TYPE_INTERVAL);
		trace_packet_write(trace, pkt);
		trace_packet_put(pkt);
	}

	pkt = trace_packet_new();
	trace_packet_name_set(pkt, tracename);
	trace_packet_write(trace, pkt);
	trace_packet_put(pkt);

	while (trace_state_get(trace) == TRACE_STATE_RECEIVING ||
	       trace_state_get(trace) == TRACE_STATE_READY) {
		fd_set fdrx;
		int high = 0;
		
		trace_fd_set(trace, &fdrx, &high);
		
		select(high + 1, &fdrx, NULL, NULL, NULL);
		
		trace_handle(trace, &fdrx);
	}
	
	return 0;
}