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

fixing compilation errors

Browse source
This commit is contained in:
Steffen Vogel 2021-06-25 09:09:11 -04:00
parent 99100f526a
commit 7ca46937ae
4 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
include/villas/path_source.h
View file

@ -43,7 +43,7 @@ enum PathSourceType {
};
struct vpath_source {
Logger logger;
villas::Logger logger;
struct vnode *node;
struct vpath *path;

10
lib/mapping.cpp
View file

@ -200,9 +200,11 @@ int mapping_update(const struct mapping_entry *me, struct sample *remapped, cons
case MappingTimestampType::RECEIVED:
ts = &original->ts.received;
break;
case MappingTimestampType::ORIGIN:
ts = &original->ts.origin;
break;
default:
return -1;
}
@ -228,11 +230,9 @@ int mapping_update(const struct mapping_entry *me, struct sample *remapped, cons
break;
case MappingType::DATA:
for (unsigned j = me->data.offset,
i = me->offset;
j < MIN(original->length, (unsigned) (me->data.offset + me->length));
j++,
i++)
for (unsigned j = me->data.offset, i = me->offset;
j < MIN(original->length, (unsigned) (me->data.offset + me->length));
j++, i++)
{
if (j >= original->length)
remapped->data[i].f = -1;

2
lib/nodes/kafka.cpp
View file

@ -67,9 +67,9 @@ static void kafka_logger_cb(const rd_kafka_t *rk, int level, const char *fac, co
static void kafka_message_cb(void *ctx, const rd_kafka_message_t *msg)
{
int ret, cnt = n->in.vectorize;
struct vnode *n = (struct vnode *) ctx;
struct kafka *k = (struct kafka *) n->_vd;
int ret, cnt = n->in.vectorize;
struct sample *smps[cnt];
n->logger->debug("Received a message of {} bytes from broker {}", msg->len, k->server);

2
lib/signal.cpp
View file

@ -228,7 +228,7 @@ int signal_parse(struct signal *s, json_t *json)
signal_data_set(&s->init, s->type, 0);
if (en >= 0)
s->enabled == en != 0;
s->enabled = en != 0;
return 0;
}