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

file: make intialization more robust

Browse source
This commit is contained in:
Steffen Vogel 2017-05-07 15:43:56 +02:00
parent 4f74107e91
commit 92e3087a16
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lib/nodes/file.c
View file

@ -143,8 +143,9 @@ char * file_print(struct node *n)
case EPOCH_ORIGINAL: epoch_str = "original"; break;
}
strcatf(&buf, "in=%s, epoch_mode=%s, epoch=%.2f, ",
strcatf(&buf, "in=%s, mode=%s, epoch_mode=%s, epoch=%.2f",
f->read.uri ? f->read.uri : f->read.fmt,
f->read.mode,
epoch_str,
time_to_double(&f->read_epoch)
);
@ -188,6 +189,7 @@ int file_start(struct node *n)
struct file *f = n->_vd;
struct timespec now = time_now();
int ret;
if (f->read.fmt) {
/* Prepare file name */
@ -210,9 +212,13 @@ int file_start(struct node *n)
/* Get timestamp of first line */
struct sample s;
int ret = sample_io_villas_fscan(f->read.handle->file, &s, NULL); arewind(f->read.handle);
arewind(f->read.handle);
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));
arewind(f->read.handle);
f->read_first = s.ts.origin;