Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-30 00:00:11 +01:00
Code Issues Releases Wiki Activity

path: dump signal list during startup

Browse source
This commit is contained in:
Steffen Vogel 2020-07-04 17:14:39 +02:00 • committed by Steffen Vogel
parent b6d0a67b8e
commit 86d7f91eb5
4 changed files with 11 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
include/villas/signal.h
View file

@ -119,7 +119,7 @@ int signal_list_destroy(struct vlist *list);
int signal_list_parse(struct vlist *list, json_t *cfg);
int signal_list_generate(struct vlist *list, unsigned len, enum SignalType fmt);
int signal_list_generate2(struct vlist *list, const char *dt);
void signal_list_dump(const struct vlist *list, const union signal_data *data, unsigned len);
void signal_list_dump(const struct vlist *list, const union signal_data *data = nullptr, unsigned len = 0);
int signal_list_copy(struct vlist *dst, const struct vlist *src);
json_t * signal_list_to_json(struct vlist *list);

3
lib/path.cpp
View file

@ -305,6 +305,9 @@ int path_prepare(struct vpath *p)
if (p->original_sequence_no == -1)
p->original_sequence_no = vlist_length(&p->sources) == 1;
p->logger->info("Prepared path {} with output signals:", path_name(p));
signal_list_dump(&p->signals);
p->state = State::PREPARED;
return 0;

10
lib/sample.cpp
View file

@ -294,19 +294,21 @@ enum SignalType sample_format(const struct sample *s, unsigned idx)
void sample_dump(struct sample *s)
{
debug(5, "Sample: sequence=%" PRIu64 ", length=%d, capacity=%d, flags=%#x, signals=%p, #signals=%zu, "
info("Sample: sequence=%" PRIu64 ", length=%d, capacity=%d, flags=%#x, signals=%p, #signals=%zu, "
"refcnt=%d, pool_off=%zd",
s->sequence, s->length, s->capacity, s->flags, s->signals,
s->signals ? vlist_length(s->signals) : 0, atomic_load(&s->refcnt), s->pool_off);
if (s->flags & (int) SampleFlags::HAS_TS_ORIGIN)
debug(5, " ts.origin=%ld.%ld", s->ts.origin.tv_sec, s->ts.origin.tv_nsec);
info(" ts.origin=%ld.%ld", s->ts.origin.tv_sec, s->ts.origin.tv_nsec);
if (s->flags & (int) SampleFlags::HAS_TS_RECEIVED)
debug(5, " ts.received=%ld.%ld", s->ts.received.tv_sec, s->ts.received.tv_nsec);
info(" ts.received=%ld.%ld", s->ts.received.tv_sec, s->ts.received.tv_nsec);
if (s->signals)
if (s->signals) {
info(" Signals:");
signal_list_dump(s->signals, s->data, s->length);
}
}
void sample_data_insert(struct sample *smp, const union signal_data *src, size_t offset, size_t len)

4
lib/signal.cpp
View file

@ -321,8 +321,6 @@ int signal_list_generate2(struct vlist *list, const char *dt)
void signal_list_dump(const struct vlist *list, const union signal_data *data, unsigned len)
{
debug(5, " Signals:");
for (size_t i = 0; i < vlist_length(list); i++) {
struct signal *sig = (struct signal *) vlist_at(list, i);
@ -344,7 +342,7 @@ void signal_list_dump(const struct vlist *list, const union signal_data *data, u
strcatf(&buf, " = %s", val);
}
debug(5, "%s", buf);
info("%s", buf);
free(buf);
}
}