Slower onion queries improve performance.

1 files changed, 14 insertions, 2 deletions

diff --git a/src/Network/Tox.hs b/src/Network/Tox.hs
index ff42fb0d..4cff4f74 100644
--- a/src/Network/Tox.hs
+++ b/src/Network/Tox.hs
@@ -119,7 +119,6 @@ import Text.XXD
 import qualified Data.HashMap.Strict as HashMap
 import Data.HashMap.Strict (HashMap)
 import qualified Data.Map.Strict as Map
-import Control.Concurrent (threadDelay)
 import DPut
 import Network.Tox.Avahi
 
@@ -239,6 +238,8 @@ newClient drg net classify selfAddr handlers modifytbl modifynet = do
                     , clientPending       = var
                     , clientAddress       = selfAddr
                     , clientResponseId    = genNonce24 var
+                    , clientEnterQuery    = \_ -> return ()
+                    , clientLeaveQuery    = \_ _ -> return ()
                     }
             in client
     return $ either mkclient mkclient tblvar handlers
@@ -407,6 +408,14 @@ getOnionAlias crypto dhtself remoteNode = atomically $ do
     return $ Onion.OnionDestination Onion.SearchingAlias alias Nothing
 
 
+retardSend micros client = do
+    mvar <- newMVar () :: IO (MVar ())
+    return client { clientEnterQuery = \tid -> do
+                        takeMVar mvar
+                        threadDelay micros
+                        putMVar mvar ()
+                  }
+
 newTox :: TVar Onion.AnnouncedKeys   -- ^ Store of announced keys we are a rendezvous for.
        -> SockAddr                   -- ^ Bind-address to listen on.
        -> Maybe NetCryptoSessions    -- ^ State of all one-on-one Tox links.
@@ -484,9 +493,12 @@ newTox keydb addr mbSessionsState suppliedDHTKey = do
                     (hookQueries orouter' DHT.transactionKey)
                     (const id)
 
+    -- onionclientSerialized <- serializeClient onionclient
+    onionRetarded <- retardSend 200000 onionclient
+
     return Tox
         { toxDHT            = dhtclient
-        , toxOnion          = onionclient
+        , toxOnion          = onionRetarded
         , toxToRoute        = onInbound (updateContactInfo roster) dtacrypt
         , toxCrypto         = addHandler (hPutStrLn stderr) (sessionPacketH sessionsState) cryptonet
         , toxHandshakes     = addHandler (hPutStrLn stderr) (handshakeH     sessionsState) handshakes