From df0ee8d98af48bc2892c7a8fb53cd23c077839cd Mon Sep 17 00:00:00 2001 From: Steffen Vogel Date: Sun, 23 Apr 2017 22:15:41 +0200 Subject: [PATCH] adapted AsyncIP for new endianess --- clients/opal/udp/models/send_receive/src/main.c | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/clients/opal/udp/models/send_receive/src/main.c b/clients/opal/udp/models/send_receive/src/main.c index 744399482..e12c03380 100644 --- a/clients/opal/udp/models/send_receive/src/main.c +++ b/clients/opal/udp/models/send_receive/src/main.c @@ -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;