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

test_rtt: fix compiler warning

Browse source
This commit is contained in:
Steffen Vogel 2019-04-08 10:15:49 +02:00
parent 5e43ea7ea4
commit 400a9d3b84
2 changed files with 17 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
include/villas/nodes/test_rtt.h
View file

@ -58,7 +58,7 @@ struct test_rtt {
double cooldown; /**< Number of seconds to wait beween tests. */
unsigned current; /**< Index of current test in test_rtt::cases */
int current; /**< Index of current test in test_rtt::cases */
int counter;
struct vlist cases; /**< List of test cases */

32
lib/nodes/test_rtt.cpp
View file

@ -336,11 +336,12 @@ int test_rtt_stop(struct node *n)
int test_rtt_read(struct node *n, struct sample *smps[], unsigned cnt, unsigned *release)
{
int ret;
unsigned i, values;
unsigned i;
uint64_t steps;
struct test_rtt *t = (struct test_rtt *) n->_vd;
/* Handle start/stop of new cases */
if (t->counter == -1) {
if (t->current < 0) {
t->current = 0;
@ -353,7 +354,7 @@ int test_rtt_read(struct node *n, struct sample *smps[], unsigned cnt, unsigned
t->current++;
}
if (t->current >= vlist_length(&t->cases)) {
if ((unsigned) t->current >= vlist_length(&t->cases)) {
info("This was the last case. Stopping node %s", node_name(n));
n->state = STATE_STOPPING;
@ -361,8 +362,6 @@ int test_rtt_read(struct node *n, struct sample *smps[], unsigned cnt, unsigned
return -1;
}
else {
struct test_rtt_case *c = (struct test_rtt_case *) vlist_at(&t->cases, t->current);
info("Starting case #%d: filename=%s, rate=%f, values=%d, limit=%d", t->current, c->filename, c->rate, c->values, c->limit);
ret = test_rtt_case_start(t, t->current);
if (ret)
return ret;
@ -376,17 +375,14 @@ int test_rtt_read(struct node *n, struct sample *smps[], unsigned cnt, unsigned
if (steps > 1)
warning("Skipped %ld steps", (long) (steps - 1));
if (t->counter == 0)
info("Starting case #%d: filename=%s, rate=%f, values=%d, limit=%d", t->current, c->filename_formatted, c->rate, c->values, c->limit);
struct timespec now = time_now();
/* Prepare samples */
for (i = 0; i < cnt; i++) {
values = c->values;
if (smps[i]->capacity < values) {
values = smps[i]->capacity;
warning("Sample capacity too small. Limiting to %d values.", values);
}
smps[i]->length = values;
smps[i]->length = c->values;
smps[i]->sequence = t->counter;
smps[i]->ts.origin = now;
smps[i]->flags = SAMPLE_HAS_DATA | SAMPLE_HAS_SEQUENCE | SAMPLE_HAS_TS_ORIGIN;
@ -395,13 +391,17 @@ int test_rtt_read(struct node *n, struct sample *smps[], unsigned cnt, unsigned
}
if ((unsigned) t->counter >= c->limit) {
info("Entering cooldown phase. Waiting %f seconds...", t->cooldown);
info("Stopping case #%d", t->current);
t->counter = -1;
if (t->cooldown) {
info("Entering cooldown phase. Waiting %f seconds...", t->cooldown);
ret = task_set_timeout(&t->task, t->cooldown);
if (ret < 0)
return ret;
t->counter = -1;
ret = task_set_timeout(&t->task, t->cooldown);
if (ret < 0)
return ret;
}
}
return i;