Prevent uxr_read_*_data_platform() from blocking too long

This commit recomputes the timeout in uxr_read_*_data_platform() after each
occurrence of an EINTR interrupt. This ensures that the function will never
block longer than the specified timeout.

Signed-off-by: J. S. Seldenthuis <jseldenthuis@lely.com>

Author: jseldent

src/c/profile/transport/ip/tcp/tcp_transport_posix.c

@@ -121,11 +121,15 @@ size_t uxr_read_tcp_data_platform(
 {
     size_t rv = 0;
     int errsv = errno;
+    int64_t start_timestamp = uxr_millis();
+    int remaining_time = timeout;
     int poll_rv;
     do
     {
         errno = errsv;
-        poll_rv = poll(&platform->poll_fd, 1, timeout);
+        remaining_time = (remaining_time <= 0) ? 0 : remaining_time;
+        poll_rv = poll(&platform->poll_fd, 1, remaining_time);
+        remaining_time = timeout - (int)(uxr_millis() - start_timestamp);
     } while (-1 == poll_rv && EINTR == errno);
     if (0 < poll_rv)
     {

src/c/profile/transport/ip/tcp/tcp_transport_posix_nopoll.c

@@ -123,19 +123,25 @@ size_t uxr_read_tcp_data_platform(
     size_t rv = 0;
     int errsv = errno;
 
-    timeout = (timeout <= 0) ? 1 : timeout;
-
-    struct timeval tv;
-    tv.tv_sec = timeout / 1000;
-    tv.tv_usec = (timeout % 1000) * 1000;
-
-    setsockopt(platform->fd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv));
+    int64_t start_timestamp = uxr_millis();
+    int remaining_time = timeout;
 
     ssize_t bytes_received;
     do
     {
         errno = errsv;
+
+        remaining_time = (remaining_time <= 0) ? 1 : remaining_time;
+
+        struct timeval tv;
+        tv.tv_sec = remaining_time / 1000;
+        tv.tv_usec = (remaining_time % 1000) * 1000;
+
+        setsockopt(platform->fd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv));
+
         bytes_received = recv(platform->fd, (void*)buf, len, 0);
+
+        remaining_time = timeout - (int)(uxr_millis() - start_timestamp);
     } while (-1 == bytes_received && EINTR == errno);
     if (-1 != bytes_received)
     {

src/c/profile/transport/ip/udp/udp_transport_posix.c

@@ -108,11 +108,15 @@ size_t uxr_read_udp_data_platform(
 {
     size_t rv = 0;
     int errsv = errno;
+    int64_t start_timestamp = uxr_millis();
+    int remaining_time = timeout;
     int poll_rv;
     do
     {
         errno = errsv;
-        poll_rv = poll(&platform->poll_fd, 1, timeout);
+        remaining_time = (remaining_time <= 0) ? 0 : remaining_time;
+        poll_rv = poll(&platform->poll_fd, 1, remaining_time);
+        remaining_time = timeout - (int)(uxr_millis() - start_timestamp);
     } while (-1 == poll_rv && EINTR == errno);
     if (0 < poll_rv)
     {

src/c/profile/transport/ip/udp/udp_transport_posix_nopoll.c

@@ -110,19 +110,25 @@ size_t uxr_read_udp_data_platform(
     size_t rv = 0;
     int errsv = errno;
 
-    timeout = (timeout <= 0) ? 1 : timeout;
-
-    struct timeval tv;
-    tv.tv_sec = timeout / 1000;
-    tv.tv_usec = (timeout % 1000) * 1000;
-
-    setsockopt(platform->fd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv));
+    int64_t start_timestamp = uxr_millis();
+    int remaining_time = timeout;
 
     ssize_t bytes_received;
     do
     {
         errno = errsv;
+
+        remaining_time = (remaining_time <= 0) ? 1 : remaining_time;
+
+        struct timeval tv;
+        tv.tv_sec = remaining_time / 1000;
+        tv.tv_usec = (remaining_time % 1000) * 1000;
+
+        setsockopt(platform->fd, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv));
+
         bytes_received = recv(platform->fd, (void*)buf, len, 0);
+
+        remaining_time = timeout - (int)(uxr_millis() - start_timestamp);
     } while (-1 == bytes_received && EINTR == errno);
     if (-1 != bytes_received)
     {