diff options
Diffstat (limited to 'src/Data')
-rw-r--r-- | src/Data/PacketQueue.hs | 6 |
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 | |||
208 | readyOutGoing :: PacketOutQueue extra msg wire fromwire -> IO (STM extra) | 209 | readyOutGoing :: PacketOutQueue extra msg wire fromwire -> IO (STM extra) |
209 | readyOutGoing (PacketOutQueue {pktoToWireIO }) = pktoToWireIO | 210 | readyOutGoing (PacketOutQueue {pktoToWireIO }) = pktoToWireIO |
210 | 211 | ||
212 | getRequested :: STM extra -> PacketOutQueue extra msg wire fromwire -> Word32 -> [Word8] -> STM [Maybe (wire,Word32)] | ||
213 | getRequested _ _ _ [] = return [] | ||
214 | getRequested getExtra pktoq snum ns = do | ||
215 | error "todo getRequested" | ||
216 | |||
211 | peekPacket :: STM extra -> PacketOutQueue extra msg wire fromwire -> msg -> STM (Maybe (wire,Word32)) | 217 | peekPacket :: STM extra -> PacketOutQueue extra msg wire fromwire -> msg -> STM (Maybe (wire,Word32)) |
212 | peekPacket getExtra q@(PacketOutQueue { pktoInPQ, pktoOutPQ, pktoPacketNo, pktoToWireIO, pktoToWire }) msg | 218 | peekPacket getExtra q@(PacketOutQueue { pktoInPQ, pktoOutPQ, pktoPacketNo, pktoToWireIO, pktoToWire }) msg |
213 | = do | 219 | = do |