diff --git a/lib/node.c b/lib/node.c index 4bb6aa2da..8725a0ed3 100644 --- a/lib/node.c +++ b/lib/node.c @@ -77,7 +77,7 @@ static int node_direction_destroy(struct node_direction *nd, struct node *n) { int ret; - ret = list_destroy(&nd->signals, (dtor_cb_t) signal_destroy, true); + ret = list_destroy(&nd->signals, (dtor_cb_t) signal_decref, true); if (ret) return ret; diff --git a/lib/path.c b/lib/path.c index 015eda603..ae476e6ea 100644 --- a/lib/path.c +++ b/lib/path.c @@ -800,7 +800,7 @@ int path_destroy(struct path *p) #endif list_destroy(&p->sources, (dtor_cb_t) path_source_destroy, true); list_destroy(&p->destinations, (dtor_cb_t) path_destination_destroy, true); - list_destroy(&p->signals, (dtor_cb_t) signal_destroy, true); + list_destroy(&p->signals, (dtor_cb_t) signal_decref, true); if (p->reader.pfds) free(p->reader.pfds); diff --git a/src/villas-pipe.cpp b/src/villas-pipe.cpp index 59a3cb2ba..80c00803b 100644 --- a/src/villas-pipe.cpp +++ b/src/villas-pipe.cpp @@ -133,7 +133,7 @@ static void * send_loop(void *ctx) struct sample *smps[node->out.vectorize]; /* Initialize memory */ - unsigned pool_size = node_type(node)->pool_size ? node_type(node)->pool_size : LOG2_CEIL(node->out.vectorize)); + unsigned pool_size = node_type(node)->pool_size ? node_type(node)->pool_size : LOG2_CEIL(node->out.vectorize); ret = pool_init(&sendd.pool, pool_size, SAMPLE_LENGTH(DEFAULT_SAMPLE_LENGTH), node_memory_type(node, &memory_hugepage)); @@ -203,7 +203,7 @@ static void * recv_loop(void *ctx) struct sample *smps[node->in.vectorize]; /* Initialize memory */ - unsigned pool_size = node_type(node)->pool_size ? node_type(node)->pool_size : LOG2_CEIL(node->in.vectorize)); + unsigned pool_size = node_type(node)->pool_size ? node_type(node)->pool_size : LOG2_CEIL(node->in.vectorize); ret = pool_init(&recvv.pool, pool_size, SAMPLE_LENGTH(DEFAULT_SAMPLE_LENGTH), node_memory_type(node, &memory_hugepage));