Use RTT for reception table query window

prrt/proto/processes/dataReceiver.c

@@ -158,6 +158,7 @@ static void handle_data_packet(PrrtSocket *sock_ptr, PrrtPacket *packet) {
         PrrtChannelStateInformation_update_delivery_rate(sock_ptr->senderChannelStateInformation, payload->btlbw);
         sock_ptr->send_peer_btl_pace = payload->btl_pace;
         sock_ptr->send_peer_app_total_pace = payload->appSendTotal_pace;
+        sock_ptr->rtt = payload->groupRTprop_us;
         prrtSequenceNumber_t baseSequenceNumber = packet->sequenceNumber - packet->index;
 
         // forward to application layer

prrt/proto/socket.c

@@ -682,8 +682,8 @@ bool PrrtSocket_cleanup(PrrtSocket *s) {
     debug(DEBUG_CLEANUP, "Loss stats.");
     s->lossStatistics = PrrtLossStatistics_add(
             // TODO find proper timestamps
-            PrrtReceptionTable_calculate_statistics(s->dataReceptionTable, s->send_peer_app_total_pace, 0, now),
-            PrrtReceptionTable_calculate_statistics(s->redundancyReceptionTable, s->send_peer_app_total_pace, 0, now)
+            PrrtReceptionTable_calculate_statistics(s->dataReceptionTable, s->send_peer_app_total_pace, now - 2 * s->rtt, now),
+            PrrtReceptionTable_calculate_statistics(s->redundancyReceptionTable, s->send_peer_app_total_pace, now - 2 * s->rtt, now)
     );
     debug(DEBUG_CLEANUP, "PrrtSocket_cleanup done");
     return true;

prrt/proto/socket.h

@@ -79,6 +79,8 @@ typedef struct prrtSocket {
     PrrtCodingConfiguration *codingParameters;
     PrrtCoder *coder;
 
+    prrtTimedelta_t rtt;
+
     // Pacing
     PrrtPace* appSendPace;
     PrrtPace* prrtTransmitPace;