Packet request Thread, ready for testing

1 files changed, 4 insertions, 0 deletions

diff --git a/src/Data/PacketQueue.hs b/src/Data/PacketQueue.hs
index 23db0ee0..560e7382 100644
--- a/src/Data/PacketQueue.hs
+++ b/src/Data/PacketQueue.hs
@@ -7,6 +7,7 @@
 module Data.PacketQueue
     ( PacketQueue
     , getCapacity
+    , getLastDequeuedPlus1
     , new
     , dequeue
     , getMissing
@@ -48,6 +49,9 @@ packetQueueViewList p = do
         f (n,Just x)  = Just (n,x)
     catMaybes . map f <$> getAssocs (pktq p)
 
+getLastDequeuedPlus1 :: PacketQueue a -> STM Word32
+getLastDequeuedPlus1 PacketQueue {seqno} = readTVar seqno
+
 getCapacity :: Applicative m => PacketQueue t -> m Word32
 getCapacity (PacketQueue { qsize }) = pure qsize