From e34c5f00368a0451645003b312fa04e355c54c7f Mon Sep 17 00:00:00 2001
From: Steffen Vogel <stvogel@eonerc.rwth-aachen.de>
Date: Sat, 9 Feb 2019 21:21:31 +0000
Subject: [PATCH] pipe: fix invalid pool size

---
 src/villas-pipe.cpp | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/villas-pipe.cpp b/src/villas-pipe.cpp
index 497d5629a..a96976308 100644
--- a/src/villas-pipe.cpp
+++ b/src/villas-pipe.cpp
@@ -68,7 +68,8 @@ public:
 
 
 		/* Initialize memory */
-		unsigned pool_size = node_type(node)->pool_size ? node_type(node)->pool_size : LOG2_CEIL(node->out.vectorize);
+		unsigned vec = LOG2_CEIL(MAX(node->out.vectorize, node->in.vectorize));
+		unsigned pool_size = node_type(node)->pool_size ? node_type(node)->pool_size : vec;
 
 		int ret = pool_init(&pool, pool_size, SAMPLE_LENGTH(DEFAULT_SAMPLE_LENGTH), node_memory_type(node, &memory_hugepage));
 		if (ret < 0)