diff options
Diffstat (limited to 'dht/src/Network/Tox/Onion/Routes.hs')
-rw-r--r-- | dht/src/Network/Tox/Onion/Routes.hs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/dht/src/Network/Tox/Onion/Routes.hs b/dht/src/Network/Tox/Onion/Routes.hs index 46ded48d..93e9bfcd 100644 --- a/dht/src/Network/Tox/Onion/Routes.hs +++ b/dht/src/Network/Tox/Onion/Routes.hs | |||
@@ -539,16 +539,16 @@ handleEvent getnodes or e@(BuildRoute (RouteId rid)) = do | |||
539 | Nothing -> routeLogger or $ "ONION Failed RouteId " ++ show rid | 539 | Nothing -> routeLogger or $ "ONION Failed RouteId " ++ show rid |
540 | 540 | ||
541 | 541 | ||
542 | lookupSender :: OnionRouter -> SockAddr -> Nonce8 -> IO (Maybe (OnionDestination RouteId)) | 542 | lookupSender :: OnionRouter -> SockAddr -> Nonce8 -> STM (Maybe (OnionDestination RouteId)) |
543 | lookupSender or = lookupSender' (pendingQueries or) (routeLog or) | 543 | lookupSender or saddr n8 = lookupSender' (pendingQueries or) (routeLog or) saddr n8 |
544 | 544 | ||
545 | lookupSender' :: TVar (Word64Map PendingQuery) | 545 | lookupSender' :: TVar (Word64Map PendingQuery) |
546 | -> TChan String | 546 | -> TChan String |
547 | -> SockAddr | 547 | -> SockAddr |
548 | -> Nonce8 | 548 | -> Nonce8 |
549 | -> IO (Maybe (OnionDestination RouteId)) | 549 | -> STM (Maybe (OnionDestination RouteId)) |
550 | lookupSender' pending log saddr (Nonce8 w8) = do | 550 | lookupSender' pending log saddr (Nonce8 w8) = do |
551 | result <- atomically $ do | 551 | result <- do |
552 | ks <- readTVar pending | 552 | ks <- readTVar pending |
553 | let r = W64.lookup w8 ks | 553 | let r = W64.lookup w8 ks |
554 | writeTChan log $ "ONION lookupSender " ++ unwords [show w8, "->", show r] | 554 | writeTChan log $ "ONION lookupSender " ++ unwords [show w8, "->", show r] |