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

file: make flush() configurable

Browse source
This commit is contained in:
Steffen Vogel 2017-07-02 19:00:08 +02:00
parent 5f3620e3b4
commit 16f2b22a12
4 changed files with 17 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
include/villas/nodes/file.h
View file

@ -50,6 +50,8 @@ struct file {
char *uri; /**< Real file name. */
} read, write;
int flush; /**< Flush / upload file contents after each write. */
enum read_epoch_mode {
FILE_EPOCH_DIRECT,

21
lib/nodes/file.c
View file

@ -119,6 +119,9 @@ int file_parse(struct node *n, config_setting_t *cfg)
if (cfg_out) {
if (file_parse_direction(cfg_out, f, FILE_WRITE))
cerror(cfg_out, "Failed to parse output file for node %s", node_name(n));
if (!config_setting_lookup_bool(cfg_out, "flush", &f->flush))
f->flush = 0;
}
cfg_in = config_setting_get_member(cfg, "in");
@ -259,12 +262,12 @@ int file_start(struct node *n)
if (f->read_timer < 0)
serror("Failed to create timer");
/* Get timestamp of first line */
struct sample s;
arewind(f->read.handle);
/* Get timestamp of first line */
if (f->read_epoch_mode != FILE_EPOCH_ORIGINAL) {
struct sample s;
ret = sample_io_villas_fscan(f->read.handle->file, &s, NULL);
if (ret < 0)
error("Failed to read first timestamp of node %s", node_name(n));
@ -292,9 +295,6 @@ int file_stop(struct node *n)
{
struct file *f = n->_vd;
free(f->read.uri);
free(f->write.uri);
if (f->read_timer)
close(f->read_timer);
if (f->read.handle)
@ -302,6 +302,9 @@ int file_stop(struct node *n)
if (f->write.handle)
afclose(f->write.handle);
free(f->read.uri);
free(f->write.uri);
return 0;
}
@ -374,7 +377,9 @@ int file_write(struct node *n, struct sample *smps[], unsigned cnt)
assert(cnt == 1);
sample_io_villas_fprint(f->write.handle->file, s, SAMPLE_IO_ALL & ~SAMPLE_IO_OFFSET);
afflush(f->write.handle);
if (f->flush)
afflush(f->write.handle);
return 1;
}

1
tests/integration/pipe-file-advio.sh
View file

@ -38,6 +38,7 @@ nodes = {
out = {
uri = "${URI}"
mode = "w+"
flush = false /* WebDav / OwnCloud / Sciebo do not support partial upload */
},
},
remote_file_in = {

1
tests/integration/pipe-loopback-file.sh
View file

@ -44,6 +44,7 @@ nodes = {
out = {
uri = "${NODE_FILE}"
mode = "w+"
flush = true /* we need to flush / upload the new samples continously for a loopback */
}
}
}