summaryrefslogtreecommitdiff
path: root/src/Data
diff options
context:
space:
mode:
Diffstat (limited to 'src/Data')
-rw-r--r--src/Data/PacketQueue.hs6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/Data/PacketQueue.hs b/src/Data/PacketQueue.hs
index 560e7382..93256474 100644
--- a/src/Data/PacketQueue.hs
+++ b/src/Data/PacketQueue.hs
@@ -19,6 +19,7 @@ module Data.PacketQueue
19 , packetQueueViewList 19 , packetQueueViewList
20 , newOutGoing 20 , newOutGoing
21 , readyOutGoing 21 , readyOutGoing
22 , getRequested
22 , peekPacket 23 , peekPacket
23 , tryAppendQueueOutgoing 24 , tryAppendQueueOutgoing
24 , dequeueOutgoing 25 , dequeueOutgoing
@@ -208,6 +209,11 @@ data OutGoingResult = OGSuccess | OGFull | OGEncodeFail
208readyOutGoing :: PacketOutQueue extra msg wire fromwire -> IO (STM extra) 209readyOutGoing :: PacketOutQueue extra msg wire fromwire -> IO (STM extra)
209readyOutGoing (PacketOutQueue {pktoToWireIO }) = pktoToWireIO 210readyOutGoing (PacketOutQueue {pktoToWireIO }) = pktoToWireIO
210 211
212getRequested :: STM extra -> PacketOutQueue extra msg wire fromwire -> Word32 -> [Word8] -> STM [Maybe (wire,Word32)]
213getRequested _ _ _ [] = return []
214getRequested getExtra pktoq snum ns = do
215 error "todo getRequested"
216
211peekPacket :: STM extra -> PacketOutQueue extra msg wire fromwire -> msg -> STM (Maybe (wire,Word32)) 217peekPacket :: STM extra -> PacketOutQueue extra msg wire fromwire -> msg -> STM (Maybe (wire,Word32))
212peekPacket getExtra q@(PacketOutQueue { pktoInPQ, pktoOutPQ, pktoPacketNo, pktoToWireIO, pktoToWire }) msg 218peekPacket getExtra q@(PacketOutQueue { pktoInPQ, pktoOutPQ, pktoPacketNo, pktoToWireIO, pktoToWire }) msg
213 = do 219 = do