Commit 54e839ad authored by Andreas Schmidt's avatar Andreas Schmidt
Browse files

Fix cleanup indexing.

parent 2447de48

prrt/proto/stores/packetDeliveryStore.c

+3 −3
Original line number Diff line number Diff line
@@ -176,9 +176,9 @@ void PrrtPacketDeliveryStore_cleanup(PrrtPacketDeliveryStore *store, prrtTimesta 
        BPTree_get_range(store->tree, packetList, now + TIMESTAMP_SPACE/2, TIMESTAMP_SPACE);

    }

    while (List_count(packetList) > 0) {

        PrrtPacket *block = List_shift(packetList);

        store->tree = BPTree_delete(store->tree, block->sequenceNumber);

        PrrtPacket_destroy(block);

        PrrtPacket *packet = List_shift(packetList);

        store->tree = BPTree_delete(store->tree, PrrtDataPacket_packet_timeout(packet));

        PrrtPacket_destroy(packet);

    }

    List_destroy(packetList);

    check(pthread_mutex_unlock(&store->lock) == EXIT_SUCCESS, "Unlock failed.");