Commit 0dbb64d2 authored by Andreas Schmidt's avatar Andreas Schmidt

asap_wait internally uses timedwait.

parent c44d65c9
Pipeline #2773 passed with stages
in 1 minute and 42 seconds
......@@ -322,7 +322,8 @@ int32_t PrrtSocket_receive_asap_wait(PrrtSocket *s, void *buf_ptr, struct sockad
PrrtPace_track_start(s->appDeliverPace);
PrrtPacket *packet;
do {
packet = PrrtPacketDeliveryStore_get_packet_wait(s->packetDeliveryStore);
struct timespec deadline = abstime_from_now(1000 * 1000);
packet = PrrtPacketDeliveryStore_get_packet_timedwait(s->packetDeliveryStore, 0, MAX_TIMESTAMP, &deadline);
if (PrrtSocket_closing(s)) {
debug(DEBUG_SOCKET, "Cancel asap_wait due to closing.");
return -1;
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment