Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

convert: added new tool which converts between different IO formats

Browse source
This commit is contained in:
Steffen Vogel 2018-05-09 09:18:10 +02:00
parent f4b6f28e17
commit a623eec35f
2 changed files with 141 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
src/Makefile.inc
View file

@ -23,7 +23,8 @@
# Executables
TARGETS = $(BUILDDIR)/villas-node \
$(BUILDDIR)/villas-test-rtt \
$(BUILDDIR)/villas-test-shmem
$(BUILDDIR)/villas-test-shmem \
$(BUILDDIR)/villas-convert
ifeq ($(WITH_IO),1)
ifeq ($(WITH_HOOKS),1)

139
src/convert.c Normal file
View file

@ -0,0 +1,139 @@
/** Convert between samples IO formats
*
* @file
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
* @copyright 2017, Institute for Automation of Complex Power Systems, EONERC
* @license GNU General Public License (version 3)
*
* VILLASnode
*
* 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
* 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/>.
*
* @addtogroup tools Test and debug tools
* @{
*********************************************************************************/
#include <villas/utils.h>
#include <villas/io.h>
#include <villas/sample.h>
#include <villas/plugin.h>
static void usage()
{
printf("Usage: villas-convert [OPTIONS]\n");
printf(" OPTIONS are:\n");
printf(" -i FMT set the input format\n");
printf(" -o FMT set the output format\n");
printf(" -d LVL set debug log level to LVL\n");
printf(" -h show this usage information\n");
printf(" -V show the version of the tool\n\n");
print_copyright();
}
int main(int argc, char *argv[])
{
int ret, level = V;
char *input_format = "villas.human";
char *output_format = "villas.human";
char c, *endptr;
while ((c = getopt(argc, argv, "Vhd:i:o:")) != -1) {
switch (c) {
case 'V':
print_version();
exit(EXIT_SUCCESS);
case 'i':
input_format = optarg;
break;
case 'o':
output_format = optarg;
break;
case 'd':
level = strtoul(optarg, &endptr, 10);
goto check;
case 'h':
case '?':
usage();
exit(c == '?' ? EXIT_FAILURE : EXIT_SUCCESS);
}
continue;
check: if (optarg == endptr)
error("Failed to parse parse option argument '-%c %s'", c, optarg);
}
if (argc != optind) {
usage();
exit(EXIT_FAILURE);
}
struct plugin *p;
struct log log;
struct io input;
struct io output;
ret = log_init(&log, level, LOG_ALL);
if (ret)
error("Failed to initialize log");
ret = log_start(&log);
if (ret)
error("Failed to start log");
struct {
char *name;
struct io *io;
} dirs[] = {
{ input_format, &input },
{ output_format, &output },
};
for (int i = 0; i < ARRAY_LEN(dirs); i++) {
p = plugin_lookup(PLUGIN_TYPE_IO, dirs[i].name);
if (!p)
error("Invalid format: %s", dirs[i].name);
ret = io_init(dirs[i].io, &p->io, SAMPLE_HAS_ALL);
if (ret)
error("Failed to initialize IO: %s", dirs[i].name);
ret = io_open(dirs[i].io, NULL);
if (ret)
error("Failed to open IO");
}
struct sample *smp = sample_alloc_mem(DEFAULT_SAMPLELEN);
for (;;) {
ret = io_scan(&input, &smp, 1);
if (ret == 0)
continue;
if (ret < 0)
break;
io_print(&output, &smp, 1);
}
for (int i = 0; i < ARRAY_LEN(dirs); i++) {
ret = io_close(dirs[i].io);
if (ret)
error("Failed to close IO");
}
return 0;
}
/** @} */