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

Added overrun-detection for asynchronous / fixed-rate paths (still missing for synchronous paths)

Browse source
This commit is contained in:
Steffen Vogel 2015-10-11 08:46:11 +02:00
parent 3dc38c0c22
commit 5dbfb0301b
3 changed files with 12 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
server/src/hooks.c
View file

@ -360,7 +360,7 @@ int hook_stats(struct path *p, struct hook *h, int when)
case HOOK_PERIODIC: {
char *buf = path_print(p);
info("%-32s : %-8u %-8u %-8u %-8u %-8u", buf, p->sent, p->received, p->dropped, p->skipped, p->invalid);
info("%-32s : %-8u %-8u %-8u %-8u %-8u %-8u", buf, p->sent, p->received, p->dropped, p->skipped, p->invalid, p->overrun);
free(buf);
break;
}

11
server/src/path.c
View file

@ -55,7 +55,14 @@ static void * path_run_async(void *arg)
struct path *p = arg;
/* Block until 1/p->rate seconds elapsed */
while (timerfd_wait(p->tfd)) {
for (;;) {
/* Check for overruns */
uint64_t expir = timerfd_wait(p->tfd);
if (expir > 1) {
p->overrun += expir;
warn("Overrun detected for path: overruns=%llu", expir);
}
if (path_run_hook(p, HOOK_ASYNC))
continue;
@ -76,7 +83,7 @@ static void * path_run(void *arg)
p->previous = p->current = p->pool;
/* Main thread loop */
for(;;) {
for (;;) {
/* Receive message */
int recv = node_read(p->in, p->pool, p->poolsize, p->received, p->in->combine);
if (recv < 0)

4
server/src/server.c
View file

@ -193,8 +193,8 @@ int main(int argc, char *argv[])
/* Run! */
if (settings.stats > 0) {
info("%-32s : %-8s %-8s %-8s %-8s %-8s",
"Source " MAG("=>") " Destination", "#Sent", "#Recv", "#Drop", "#Skip", "#Invalid");
info("%-32s : %-8s %-8s %-8s %-8s %-8s %-8s",
"Source " MAG("=>") " Destination", "#Sent", "#Recv", "#Drop", "#Skip", "#Invalid", "#Overuns");
line();
do list_foreach(struct path *p, &paths) {