VILLASnode/server/src/msg.c

/** Message related functions.
 *
 * @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
 * @copyright 2014-2015, Institute for Automation of Complex Power Systems, EONERC
 *   This file is part of S2SS. All Rights Reserved. Proprietary and confidential.
 *   Unauthorized copying of this file, via any medium is strictly prohibited. 
 *********************************************************************************/

#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <ctype.h>

#ifdef __linux__
 #include <byteswap.h>
#elif defined(__PPC__) /* Xilinx toolchain */
 #include <xil_io.h>
 #define bswap_32(x)	Xil_EndianSwap32(x)
#endif

#include "msg.h"
#include "node.h"
#include "utils.h"

void msg_swap(struct msg *m)
{
	int i;
	for (i = 0; i < m->length; i++)
		m->data[i].i = bswap_32(m->data[i].i);

	m->endian ^= 1;
}

int msg_verify(struct msg *m)
{
	return ((m->version == MSG_VERSION) &&
		(m->type    == MSG_TYPE_DATA) &&
		(m->length  > 0) &&
		(m->length  <= MSG_VALUES))
	   ?  0
	   : -1;
}

int msg_fprint(FILE *f, struct msg *m)
{
	if (m->endian != MSG_ENDIAN_HOST)
		msg_swap(m);

	fprintf(f, "%hu", m->sequence);

	for (int i = 0; i < m->length; i++)
		fprintf(f, "\t%.6f", m->data[i].f);

	fprintf(f, "\n");

	return 0;
}

int msg_fscan(FILE *f, struct msg *m)
{
	char line[MSG_VALUES * 16];
	char *ptr = line;

	if (!fgets(line, sizeof(line), f))
		return 0;

	m->sequence = (uint16_t) strtol(ptr, &ptr, 10);

	int i;
	for (i = 0; i <= MSG_VALUES; i++) {
		while(isblank(*ptr++));
		if (*ptr == '\n' || *ptr == '\0')
			break;

		m->data[i].f = strtod(ptr, &ptr);
	}

	m->length = i;
	m->endian = MSG_ENDIAN_HOST;
	
	return m->length;
}

void msg_random(struct msg *m)
{
	for (int i = 0; i < m->length; i++)
		m->data[i].f += box_muller(0, 1);

	m->endian = MSG_ENDIAN_HOST;
}