Start of ForwardPacketTable is moved upon expiry.

prrt/proto/socket.c

@@ -425,10 +425,7 @@ bool PrrtSocket_cleanup(PrrtSocket *socket) {
                 prrtSequenceNumber_t lastSequenceNumberBase = (prrtSequenceNumber_t) (last->sequenceNumber -
                                                                                       last->index - 1);
 
-                for (i = 0; i < (lastSequenceNumberBase - firstSequenceNumberBase); i++) {
-                    PrrtForwardPacketTable_test_set_is_number_relevant(socket->forwardPacketTable,
-                                                                       (prrtSequenceNumber_t) (firstSequenceNumberBase + i));
-                }
+                PrrtForwardPacketTable_forward_start(socket->forwardPacketTable, lastSequenceNumberBase);
 
                 PrrtRepairBlockStore_expire_block_range(socket->repairBlockStore, firstSequenceNumberBase,
                                                         lastSequenceNumberBase);

prrt/proto/stores/forwardPacketTable.c

@@ -83,3 +83,17 @@ bool PrrtForwardPacketTable_test_is_block_relevant(PrrtForwardPacketTable *forwa
 
     return res;
 }
+
+void PrrtForwardPacketTable_forward_start(PrrtForwardPacketTable *fpt_ptr, prrtSequenceNumber_t new_start)
+{
+    prrtSequenceNumber_t seqno = fpt_ptr->start;
+
+    while (seqno != new_start) {
+        Bitmap_set(fpt_ptr->bitmap, seqno, true);
+        seqno++;
+    }
+
+    // TODO: make more efficient by using the Bitmap_set_range function
+
+    fpt_ptr->start = seqno;
+}
\ No newline at end of file

prrt/proto/stores/forwardPacketTable.h

@@ -19,4 +19,6 @@ bool PrrtForwardPacketTable_test_set_is_number_relevant(PrrtForwardPacketTable *
 bool PrrtForwardPacketTable_test_is_block_relevant(PrrtForwardPacketTable *forwardPacketTable, prrtSequenceNumber_t start,
                                                    prrtSequenceNumber_t length);
 
+void PrrtForwardPacketTable_forward_start(PrrtForwardPacketTable *fpt_ptr, prrtSequenceNumber_t new_start);
+
 #endif //PRRT_FORWARD_PACKET_TABLE_H