diff options
author | James Crayne <jim.crayne@gmail.com> | 2018-11-03 07:22:14 -0400 |
---|---|---|
committer | James Crayne <jim.crayne@gmail.com> | 2018-11-03 07:22:14 -0400 |
commit | e150b800acd538edb4b769836bf76d9f29131a94 (patch) | |
tree | b5089f49cf1775d0659fd7b759f87e56f87f5147 /src/Network/Tox/Crypto | |
parent | d1eea83c508c3a977c5423597f3174cfd86b108d (diff) |
since PacketRequests are now lazy, dont add them to outq
Diffstat (limited to 'src/Network/Tox/Crypto')
-rw-r--r-- | src/Network/Tox/Crypto/Handlers.hs | 7 |
1 files changed, 1 insertions, 6 deletions
diff --git a/src/Network/Tox/Crypto/Handlers.hs b/src/Network/Tox/Crypto/Handlers.hs index fd04e1c5..02adbe31 100644 --- a/src/Network/Tox/Crypto/Handlers.hs +++ b/src/Network/Tox/Crypto/Handlers.hs | |||
@@ -815,12 +815,7 @@ runUponHandshake netCryptoSession0 addr pktoq = do | |||
815 | (nums,seqno) <- atomically $ PB.packetNumbersToRequest pktq | 815 | (nums,seqno) <- atomically $ PB.packetNumbersToRequest pktq |
816 | dput XNetCrypto $ "(Request Thread) Missing Packets detected:" ++ show nums | 816 | dput XNetCrypto $ "(Request Thread) Missing Packets detected:" ++ show nums |
817 | getOutGoingParam <- nqToWireIO pktoq | 817 | getOutGoingParam <- nqToWireIO pktoq |
818 | x <- atomically $ do | 818 | sendLossy crypto netCryptoSession0 (createRequestPacket seqno nums) |
819 | ogresult <- tryAppendQueueOutgoing getOutGoingParam pktoq (createRequestPacket seqno nums) | ||
820 | case ogresult of | ||
821 | OGSuccess x -> return x | ||
822 | _ -> retry | ||
823 | sendSessionPacket sessions addr x | ||
824 | loop | 819 | loop |
825 | dput XNetCrypto $ "runUponHandshake: " ++ show threadid ++ " = NetCryptoRequest." ++ show (key2id remotePublicKey) ++ sidStr | 820 | dput XNetCrypto $ "runUponHandshake: " ++ show threadid ++ " = NetCryptoRequest." ++ show (key2id remotePublicKey) ++ sidStr |
826 | 821 | ||