1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
VILLASnode/lib/formats/line.cpp

169 lines
3.7 KiB
C++

/** Line-based formats
*
* @author Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
* @copyright 2014-2020, 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/>.
*********************************************************************************/
#include <villas/formats/line.hpp>
#include <villas/exceptions.hpp>
using namespace villas;
using namespace villas::node;
int LineFormat::sprint(char *buf, size_t len, size_t *wbytes, const struct sample * const smps[], unsigned cnt)
{
unsigned i;
size_t off = 0;
for (i = 0; i < cnt && off < len; i++)
off += sprintLine(buf + off, len - off, smps[i]);
if (wbytes)
*wbytes = off;
return i;
}
int LineFormat::sscan(const char *buf, size_t len, size_t *rbytes, struct sample * const smps[], unsigned cnt)
{
unsigned i;
size_t off = 0;
if (skip_first_line) {
if (!first_line_skipped) {
while (off < len) {
if (buf[off++] == delimiter)
break;
}
first_line_skipped = true;
}
}
for (i = 0; i < cnt && off < len; i++) {
/* Skip comment lines */
if (buf[off] == comment) {
while (off < len) {
if (buf[++off] == delimiter)
break;
}
if (off == len)
break;
}
off += sscanLine(buf + off, len - off, smps[i]);
}
if (rbytes)
*rbytes = off;
return i;
}
int LineFormat::print(FILE *f, const struct sample * const smps[], unsigned cnt)
{
int ret;
unsigned i;
if (cnt > 0 && smps[0]->signals)
header(f, smps[0]->signals);
for (i = 0; i < cnt; i++) {
size_t wbytes;
ret = sprint(out.buffer, out.buflen, &wbytes, &smps[i], 1);
if (ret < 0)
return ret;
fwrite(out.buffer, wbytes, 1, f);
}
return i;
}
int LineFormat::scan(FILE *f, struct sample * const smps[], unsigned cnt)
{
int ret;
unsigned i;
ssize_t bytes;
if (skip_first_line) {
if (!first_line_skipped) {
bytes = getdelim(&in.buffer, &in.buflen, delimiter, f);
if (bytes < 0)
return -1; /* An error or eof occured */
first_line_skipped = true;
}
}
for (i = 0; i < cnt; i++) {
size_t rbytes;
char *ptr;
skip: bytes = getdelim(&in.buffer, &in.buflen, delimiter, f);
if (bytes < 0)
return -1; /* An error or eof occured */
/* Skip whitespaces, empty and comment lines */
for (ptr = in.buffer; isspace(*ptr); ptr++);
if (ptr[0] == '\0' || ptr[0] == comment)
goto skip;
ret = sscan(in.buffer, bytes, &rbytes, &smps[i], 1);
if (ret < 0)
return ret;
}
return i;
}
void LineFormat::parse(json_t *json)
{
int ret;
json_error_t err;
const char *delim = nullptr;
int header = -1;
int skip = -1;
ret = json_unpack_ex(json, &err, 0, "{ s?: s, s?: b, s?: b }",
"delimiter", &delim,
"header", &header,
"skip_first_line", &skip
);
if (ret)
throw ConfigError(json, err, "node-config-format-line", "Failed to parse format configuration");
if (delim) {
if (strlen(delim) != 1)
throw ConfigError(json, "node-config-format-line-delimiter", "Line delimiter must be a single character!");
delimiter = delim[0];
}
if (header >= 0)
print_header = header;
if (skip >= 0)
skip_first_line = skip;
Format::parse(json);
}