Propagate ETIMEDOUT.

prrt/proto/socket.c

@@ -305,6 +305,9 @@ int32_t PrrtSocket_receive_asap_timedwait(PrrtSocket *s, void *buf_ptr, struct t
     check(s->isSender == false, "Cannot receive on sender socket.")
 
     PrrtPacket *packet = PrrtPacketDeliveryStore_get_packet_timedwait(s->packetDeliveryStore, 0, MAX_TIMESTAMP, deadline);
+    if (packet == NULL && errno == ETIMEDOUT) {
+        return -1 * ETIMEDOUT;
+    }
 
     return deliver_packet(s, buf_ptr, packet);
     error:
@@ -355,6 +358,10 @@ int32_t PrrtSocket_receive_ordered_timedwait(PrrtSocket *s, void *buf_ptr, prrtT
 
     PrrtPacket *packet = PrrtPacketDeliveryStore_get_packet_timedwait(s->packetDeliveryStore, now - time_window_us,
                                                                       now + time_window_us, deadline);
+    if (packet == NULL && errno == ETIMEDOUT) {
+        return -1 * ETIMEDOUT;
+    }
+
     return deliver_packet(s, buf_ptr, packet);
     error:
     PERROR("There was a failure while receiving from socket.%s", "");

prrt/proto/stores/packetDeliveryStore.c

@@ -31,7 +31,11 @@ PrrtPacket * PrrtPacketDeliveryStore_get_packet_timedwait(PrrtPacketDeliveryStor
 
     packet = PrrtPacketDeliveryStore_get_packet(q, start, stop);
     if (!packet && !atomic_load_explicit(&q->closing, memory_order_acquire)) {
-        pthread_cond_timedwait(&q->wait_for_data, &q->lock, deadline);
+        int res = pthread_cond_timedwait(&q->wait_for_data, &q->lock, deadline);
+        if (res == ETIMEDOUT) {
+            errno = ETIMEDOUT;
+            return NULL;
+        }
         packet = PrrtPacketDeliveryStore_get_packet(q, start, stop);
     }