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

smaller refactoring in villas-hook

Browse source
This commit is contained in:
Steffen Vogel 2017-03-20 09:04:23 -03:00
parent 7d28fbd6c4
commit 30d5c73fea
1 changed files with 9 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

19
src/hook.c
View file

@ -77,7 +77,7 @@ static void usage()
int main(int argc, char *argv[])
{
int j, ret, level, cnt;
int ret, level, cnt;
/* Default values */
level = V;
@ -140,25 +140,24 @@ int main(int argc, char *argv[])
if (ret != cnt)
error("Failed to allocate %u samples from pool", cnt);
for (j = 0; j < cnt && !feof(stdin); j++) {
hi.count = 0;
for (int j = 0; j < cnt && !feof(stdin); j++) {
ret = sample_fscan(stdin, hi.samples[j], NULL);
if (ret < 0)
break;
hi.samples[j]->ts.received = time_now();
hi.count++;
}
debug(15, "Read %d samples from stdin", cnt);
hi.count = j;
hook_run(&h, HOOK_READ, &hi);
hook_run(&h, HOOK_WRITE, &hi);
if (h._vt->when & HOOK_READ)
hi.count = h._vt->cb(&h, HOOK_READ, &hi);
if (h._vt->when & HOOK_WRITE)
hi.count = h._vt->cb(&h, HOOK_WRITE, &hi);
for (j = 0; j < hi.count; j++)
for (int j = 0; j < hi.count; j++)
sample_fprint(stdout, hi.samples[j], SAMPLE_ALL);
fflush(stdout);
sample_free(samples, cnt);
}