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

added new signal type for signal generator: ramp

Browse source
This commit is contained in:
Steffen Vogel 2016-02-07 01:11:51 +01:00
parent c90b5ba2b4
commit 106d230a24
1 changed files with 24 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

41
src/signal.c
View file

@ -26,6 +26,7 @@ enum SIGNAL_TYPE {
TYPE_SINE,
TYPE_SQUARE,
TYPE_TRIANGLE,
TYPE_RAMP,
TYPE_MIXED
};
@ -33,7 +34,7 @@ int main(int argc, char *argv[])
{
if (argc < 4 || argc > 5) {
printf("Usage: %s SIGNAL VALUES RATE [LIMIT]\n", argv[0]);
printf(" SIGNAL is on of: mixed random sine triangle square\n");
printf(" SIGNAL is on of: mixed random sine triangle square ramp\n");
printf(" VALUES is the number of values a message contains\n");
printf(" RATE how many messages per second\n");
printf(" LIMIT only send LIMIT messages\n\n");
@ -43,42 +44,46 @@ int main(int argc, char *argv[])
exit(EXIT_FAILURE);
}
int values = atoi(argv[2]);
double rate = atof(argv[3]);
int limit = argc >= 5 ? atoi(argv[4]) : -1;
int type = TYPE_MIXED;
int values = atoi(argv[2]);
int limit = argc >= 5 ? atoi(argv[4]) : -1;
int counter = 0;
struct msg *m = msg_create(values);
/* Parse signal type */
if (!strcmp(argv[1], "random"))
type = TYPE_RANDOM;
else if (!strcmp(argv[1], "sine"))
type = TYPE_SINE;
else if (!strcmp(argv[1], "triangle"))
type = TYPE_TRIANGLE;
else if (!strcmp(argv[1], "square"))
type = TYPE_SQUARE;
else if (!strcmp(argv[1], "triangle"))
type = TYPE_TRIANGLE;
else if (!strcmp(argv[1], "ramp"))
type = TYPE_RAMP;
else if (!strcmp(argv[1], "mixed"))
type = TYPE_MIXED;
/* Print header */
fprintf(stderr, "# %-20s\t\t%s\n", "sec.nsec(seq)", "data[]");
/* Setup timer */
int tfd = timerfd_create_rate(rate);
if (tfd < 0)
serror("Failed to create timer");
/* Print header */
fprintf(stderr, "# %-20s\t\t%s\n", "sec.nsec(seq)", "data[]");
struct timespec start = time_now();
struct msg *m = msg_create(values);
/* Block until 1/p->rate seconds elapsed */
while (limit-- > 0 || argc < 5) {
while (counter < limit || argc < 5) {
struct timespec now = time_now();
double running = time_delta(&start, &now);
m->ts.sec = now.tv_sec;
m->ts.nsec = now.tv_nsec;
m->sequence = counter;
for (int i = 0; i < m->values; i++) {
int rtype = (type != TYPE_MIXED) ? type : i % 4;
@ -86,17 +91,19 @@ int main(int argc, char *argv[])
double freq = i+1;
switch (rtype) {
case TYPE_RANDOM: m->data[i].f += box_muller(0, 0.02); break;
case TYPE_SINE: m->data[i].f = ampl * sin(running * freq * M_PI); break;
case TYPE_TRIANGLE: m->data[i].f = ampl * (fabs(fmod(running * freq, 1) - .5) - 0.25) * 4; break;
case TYPE_SQUARE: m->data[i].f = ampl * ( (fmod(running * freq, 1) < .5) ? -1 : 1); break;
case TYPE_RANDOM: m->data[i].f += box_muller(0, 0.02); break;
case TYPE_SINE: m->data[i].f = ampl * sin(running * freq * M_PI); break;
case TYPE_TRIANGLE: m->data[i].f = ampl * (fabs(fmod(running * freq, 1) - .5) - 0.25) * 4; break;
case TYPE_SQUARE: m->data[i].f = ampl * ( (fmod(running * freq, 1) < .5) ? -1 : 1); break;
case TYPE_RAMP: m->data[i].f = counter; /** @todo send as integer? */ break;
}
}
msg_fprint(stdout, m, MSG_PRINT_ALL & ~MSG_PRINT_OFFSET, 0);
fflush(stdout);
m->sequence += timerfd_wait(tfd);
/* Block until 1/p->rate seconds elapsed */
counter += timerfd_wait(tfd);
}
close(tfd);