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

node: improve logging

Browse source
This commit is contained in:
Steffen Vogel 2018-05-23 02:25:27 +02:00
parent 995d5a58ae
commit 5bc1831cc4
1 changed files with 7 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
lib/node.c
View file

@ -298,15 +298,12 @@ int node_read(struct node *n, struct sample *smps[], unsigned cnt)
return readd;
nread += readd;
debug(LOG_NODES | 5, "Received %u samples from node %s", readd, node_name(n));
}
}
else {
nread = n->_vt->read(n, smps, cnt);
if (nread < 0)
return nread;
debug(LOG_NODES | 5, "Received %u samples from node %s", nread, node_name(n));
}
/* Add missing fields */
@ -332,17 +329,18 @@ int node_read(struct node *n, struct sample *smps[], unsigned cnt)
#ifdef WITH_HOOKS
/* Run read hooks */
int rread = hook_read_list(&n->hooks, smps, nread);
if (nread != rread) {
int skipped = nread - rread;
int skipped = nread - rread;
debug(LOG_NODES | 10, "Hooks skipped %u out of %u samples for node %s", skipped, nread, node_name(n));
if (n->stats)
stats_update(n->stats, STATS_SKIPPED, skipped);
if (skipped > 0 && n->stats != NULL) {
stats_update(n->stats, STATS_SKIPPED, skipped);
}
debug(LOG_NODES | 5, "Received %u samples from node %s of which %d have been skipped", nread, node_name(n), skipped);
return rread;
#else
debug(LOG_NODES | 5, "Received %u samples from node %s", nread, node_name(n));
return nread;
#endif /* WITH_HOOKS */
}