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

hook: reworked villas-hook tool

Browse source
This commit is contained in:
Steffen Vogel 2018-03-28 14:17:44 +02:00
parent bdcdb37bb3
commit 05e924161d
1 changed files with 17 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
src/hook.c
View file

@ -104,7 +104,7 @@ static void usage()
int main(int argc, char *argv[])
{
int ret, recv;
int ret, recv, sent;
char *format = "villas-human";
/* Default values */
@ -208,26 +208,31 @@ check: if (optarg == endptr)
error("Failed to start hook");
for (;;) {
if (io_eof(&io)) {
killme(SIGTERM);
pause();
}
ret = sample_alloc_many(&q, smps, cnt);
if (ret != cnt)
error("Failed to allocate %d smps from pool", cnt);
recv = io_scan(&io, smps, cnt);
if (recv < 0)
killme(SIGTERM);
if (recv < 0) {
if (io_eof(&io)) {
killme(SIGTERM);
pause();
}
error("Failed to read from stdin");
}
debug(15, "Read %u smps from stdin", recv);
hook_read(&h, smps, (unsigned *) &recv);
hook_process(&h, smps, (unsigned *) &recv);
hook_write(&h, smps, (unsigned *) &recv);
unsigned send = recv;
io_print(&io, smps, recv);
hook_read(&h, smps, (unsigned *) &send);
hook_process(&h, smps, (unsigned *) &send);
hook_write(&h, smps, (unsigned *) &send);
sent = io_print(&io, smps, send);
if (sent < 0)
error("Failed to write to stdout");
sample_free_many(smps, cnt);
}