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

updated hooks: multiplexing will soon be replaced by new _{read,write} functions

Browse source
This commit is contained in:
Steffen Vogel 2015-05-06 11:38:57 +02:00
parent 506bb2446c
commit 411e02f034
2 changed files with 13 additions and 48 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

15
server/include/hooks.h
View file

@ -63,21 +63,6 @@ int hook_ts(struct msg *m, struct path *p);
/** Example hook: Finite-Impulse-Response (FIR) filter. */
int hook_fir(struct msg *m, struct path *p);
#define HOOK_FIR_INDEX 1
/** Example hook: collect previous messages to send them at once */
int hook_multiplex(struct msg *m, struct path *p);
/** Example hook: inverse multiplex operation */
int hook_demultiplex(struct msg *m, struct path *p);
#define HOOK_MULTIPLEX_RATIO 10
/* Plausability checks */
#if HOOK_MULTIPLEX_RATIO > POOL_SIZE
#error "POOL_SIZE is too small for given HOOK_MULTIPLEX_RATIO"
#endif
/** Example hook: Discrete Fourier Transform */
int hook_dft(struct msg *m, struct path *p);

46
server/src/hooks.c
View file

@ -15,11 +15,19 @@
#include <string.h>
#include <time.h>
#include "config.h"
#include "msg.h"
#include "hooks.h"
#include "path.h"
#include "utils.h"
/* The configuration of hook parameters is done in "config.h" */
/* Plausability checks */
#if HOOK_MULTIPLEX_RATIO > POOL_SIZE
#error "POOL_SIZE is too small for given HOOK_MULTIPLEX_RATIO"
#endif
/** @todo Make const */
static struct hook_id hook_list[] = {
{ hook_print, "print" },
@ -27,9 +35,7 @@ static struct hook_id hook_list[] = {
{ hook_tofixed, "tofixed" },
{ hook_ts, "ts" },
{ hook_fir, "fir" },
{ hook_dft, "dft"},
{ hook_multiplex, "multiplex" },
{ hook_demultiplex, "demultiplex" },
{ hook_dft, "dft"}
};
hook_cb_t hook_lookup(const char *name)
@ -83,10 +89,10 @@ int hook_fir(struct msg *m, struct path *p)
double sum = 0;
/** Trim FIR length to length of history buffer */
int len = MIN(ARRAY_LEN(coeffs), POOL_SIZE);
int len = MIN(ARRAY_LEN(coeffs), p->poolsize);
for (int i=0; i<len; i++) {
struct msg *old = &p->history[(POOL_SIZE+p->received-i) % POOL_SIZE];
struct msg *old = &p->pool[(p->poolsize+p->received-i) % p->poolsize];
sum += coeffs[i] * old->data[HOOK_FIR_INDEX].f;
}
@ -102,34 +108,8 @@ int hook_decimate(struct msg *m, struct path *p)
return (m->sequence % HOOK_DECIMATE_RATIO == 0) ? -1 : 0;
}
int hook_multiplex(struct msg *m, struct path *p)
{
/* Every HOOK_MULTIPLEX_RATIO'th message contains the collection of the previous ones */
if (p->received % HOOK_MULTIPLEX_RATIO == 0) {
struct msg *c = p->current; /* Current message */
for (int i=1; i<HOOK_MULTIPLEX_RATIO && c->length<MSG_VALUES; i++) {
struct msg *m = p->history[p->received-i];
/* Trim amount of values to actual size of msg buffer */
int len = MIN(m->length, MSG_VALUES - c->length);
memcpy(c->data + c->length, m->data, len * sizeof(m->data[0]));
c->length += len;
}
return 0;
}
else
return -1; /* Message will be dropped */
}
int hook_demultiplex(struct msg *m, struct path *p)
{
}
/** @todo Implement */
int hook_dft(struct msg *m, struct path *p)
{
/** @todo Implement */
return 0;
}