From 217ce45ff1d4431c7c15bda5a759f1a8ffef175f Mon Sep 17 00:00:00 2001 From: Dennis Potter Date: Tue, 3 Jul 2018 17:37:17 +0200 Subject: [PATCH] Made pools larger to be compatible with IB node --- src/pipe.c | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/src/pipe.c b/src/pipe.c index f1267e876..272f4cf1b 100644 --- a/src/pipe.c +++ b/src/pipe.c @@ -132,7 +132,7 @@ static void * send_loop(void *ctx) struct sample *smps[node->out.vectorize]; /* Initialize memory */ - ret = pool_init(&sendd.pool, LOG2_CEIL(node->out.vectorize), SAMPLE_LEN(DEFAULT_SAMPLELEN), node_memtype(node, &memtype_hugepage)); + ret = pool_init(&sendd.pool, MAX(16384, 2*LOG2_CEIL(node->out.vectorize)), SAMPLE_LEN(DEFAULT_SAMPLELEN), node_memtype(node, &memtype_heap)); if (ret < 0) error("Failed to allocate memory for receive pool."); @@ -196,7 +196,8 @@ static void * recv_loop(void *ctx) struct sample *smps[node->in.vectorize]; /* Initialize memory */ - ret = pool_init(&recvv.pool, LOG2_CEIL(node->in.vectorize), SAMPLE_LEN(DEFAULT_SAMPLELEN), node_memtype(node, &memtype_hugepage)); + ret = pool_init(&recvv.pool, MAX(16*8192, 2*LOG2_CEIL(node->in.vectorize)), SAMPLE_LEN(DEFAULT_SAMPLELEN), node_memtype(node, &memtype_heap)); + if (ret < 0) error("Failed to allocate memory for receive pool."); @@ -204,8 +205,8 @@ static void * recv_loop(void *ctx) ready = sample_alloc_many(&recvv.pool, smps, node->in.vectorize); if (ready < 0) error("Failed to allocate %u samples from receive pool.", node->in.vectorize); -// else if (ready < node->in.vectorize) -// warn("Receive pool underrun"); + else if (ready < node->in.vectorize) + warn("Receive pool underrun"); recv = node_read(node, smps, ready); if (recv < 0)