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

loopback: we need an additional pool for now

Browse source
This commit is contained in:
Steffen Vogel 2017-07-14 16:29:05 +02:00
parent eb471d68ee
commit 98eed183e3
2 changed files with 40 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
include/villas/nodes/loopback.h
View file

@ -32,6 +32,7 @@
#include <libconfig.h>
#include "queue_signalled.h"
#include "pool.h"
/* Forward declarations */
struct node;
@ -42,8 +43,10 @@ struct sample;
*/
struct loopback {
int queuelen;
int samplelen;
struct queue_signalled queue;
struct pool pool;
};
/** @see node_type::print */

41
lib/nodes/loopback.c
View file

@ -34,35 +34,68 @@ int loopback_parse(struct node *n, config_setting_t *cfg)
if (!config_setting_lookup_int(cfg, "queuelen", &l->queuelen))
l->queuelen = DEFAULT_QUEUELEN;
if (!config_setting_lookup_int(cfg, "samplelen", &l->samplelen))
l->samplelen = DEFAULT_SAMPLELEN;
return 0;
}
int loopback_open(struct node *n)
{
int ret;
struct loopback *l = n->_vd;
ret = pool_init(&l->pool, l->queuelen, SAMPLE_LEN(l->samplelen), &memtype_hugepage);
if (ret)
return ret;
return queue_signalled_init(&l->queue, l->queuelen, &memtype_hugepage);
}
int loopback_close(struct node *n)
{
int ret;
struct loopback *l= n->_vd;
ret = pool_destroy(&l->pool);
if (ret)
return ret;
return queue_signalled_destroy(&l->queue);
}
int loopback_read(struct node *n, struct sample *smps[], unsigned cnt)
{
struct loopback *l = n->_vd;
int avail;
return queue_signalled_pull_many(&l->queue, (void **) smps, cnt);
struct loopback *l = n->_vd;
struct sample *cpys[cnt];
avail = queue_signalled_pull_many(&l->queue, (void **) cpys, cnt);
for (int i = 0; i < avail; i++) {
sample_copy(smps[i], cpys[i]);
sample_put(cpys[i]);
}
return avail;
}
int loopback_write(struct node *n, struct sample *smps[], unsigned cnt)
{
struct loopback *l = n->_vd;
int avail;
return queue_signalled_push_many(&l->queue, (void **) smps, cnt);
struct loopback *l = n->_vd;
struct sample *cpys[cnt];
avail = sample_alloc(&l->pool, cpys, cnt);
if (avail < cnt)
warn("Pool underun for node %s", node_name(n));
for (int i = 0; i < avail; i++)
sample_copy(cpys[i], smps[i]);
return queue_signalled_push_many(&l->queue, (void **) cpys, avail);
}
char * loopback_print(struct node *n)