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

adapted AsyncIP for new endianess

Browse source
This commit is contained in:
Steffen Vogel 2017-04-23 22:15:41 +02:00
parent a3222da312
commit df0ee8d98a
1 changed files with 3 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
clients/opal/udp/models/send_receive/src/main.c
View file

@ -139,6 +139,8 @@ static void *SendToIPPort(void *arg)
msg.sequence = seq++;
msg.ts.sec = now.tv_sec;
msg.ts.nsec = now.tv_nsec;
msg_hton(msg);
/* Perform the actual write to the ip port */
if (SendPacket((char *) &msg, MSG_LEN(&msg)) < 0)
@ -207,16 +209,13 @@ static void *RecvFromIPPort(void *arg)
OpalPrint("%s: Received message with unknown version. Skipping..\n", PROGNAME);
continue;
}
msg_ntoh(msg);
if (msg.type != MSG_TYPE_DATA) {
OpalPrint("%s: Received no data. Skipping..\n", PROGNAME);
continue;
}
/* Convert message to host endianess */
if (msg.endian != MSG_ENDIAN_HOST)
msg_swap(&msg);
if (n != MSG_LEN(&msg)) {
OpalPrint("%s: Received incoherent packet (size: %d, complete: %d)\n", PROGNAME, n, MSG_LEN(&msg));
continue;