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

villas-pipe: automatically fill sequence numbers if not provided

Browse source
This commit is contained in:
Steffen Vogel 2017-10-16 23:08:27 +02:00
parent a6f158b250
commit af39651d09
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/pipe.c
View file

@ -107,6 +107,7 @@ static void usage()
static void * send_loop(void *ctx)
{
unsigned last_sequenceno = 0;
int ret, scanned, sent, ready, cnt = 0;
struct sample *smps[node->vectorize];
@ -130,6 +131,14 @@ static void * send_loop(void *ctx)
else if (scanned == 0)
continue;
/* Fill in missing sequence numbers */
for (int i = 0; i < scanned; i++) {
if (smps[i]->flags & SAMPLE_HAS_SEQUENCE)
last_sequenceno = smps[i]->sequence;
else
smps[i]->sequence = last_sequenceno++;
}
sent = node_write(node, smps, scanned);
if (sent < 0) {
warn("Failed to sent samples to node %s: reason=%d", node_name(node), sent);