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

changed memory type of path message

Browse source 
git-svn-id: https://zerberus.eonerc.rwth-aachen.de:8443/svn/s2ss/trunk@164 8ec27952-4edc-4aab-86aa-e87bb2611832
This commit is contained in:
Steffen Vogel 2014-07-18 16:05:44 +00:00
parent 78efb846ab
commit 78f2c519b1
1 changed files with 16 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
server/src/path.c
View file

@ -65,26 +65,29 @@ static void * path_send(void *arg)
static void * path_run(void *arg)
{
struct path *p = (struct path *) arg;
struct msg m;
struct msg *m = malloc(sizeof(struct msg));
if (!m)
error("Failed to allocate memory!");
/* Main thread loop */
while (1) {
msg_recv(&m, p->in); /* Receive message */
msg_recv(m, p->in); /* Receive message */
p->received++;
/** Check header fields */
if (m.version != MSG_VERSION) {
if (m->version != MSG_VERSION) {
p->invalid++;
continue;
}
if (m.type != MSG_TYPE_DATA) {
if (m->type != MSG_TYPE_DATA) {
p->invalid++;
continue;
}
/* Check sequence number */
if (m.sequence <= 1) {
if (m->sequence <= 1) {
path_stats(p);
info("Simulation started");
@ -96,30 +99,32 @@ static void * path_run(void *arg)
p->duplicated = 0;
p->invalid = 0;
}
else if (m.sequence < p->sequence) {
else if (m->sequence < p->sequence) {
p->delayed++;
continue;
}
else if (m.sequence == p->sequence) {
else if (m->sequence == p->sequence) {
p->duplicated++;
continue;
}
if (p->hook && p->hook(&m)) {
if (p->hook && p->hook(m)) {
p->skipped++;
continue;
}
/* At fixed rate mode, messages are send by another thread */
if (p->rate)
p->last = &m;
p->last = m;
else
msg_send(&m, p->out);
msg_send(m, p->out);
p->sequence = m.sequence;
p->sequence = m->sequence;
p->sent++;
}
free(m);
return NULL;
}