diff options
Diffstat (limited to 'Connection')
| -rw-r--r-- | Connection/Tcp.hs | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/Connection/Tcp.hs b/Connection/Tcp.hs index 73d01c40..01e0f473 100644 --- a/Connection/Tcp.hs +++ b/Connection/Tcp.hs | |||
| @@ -466,7 +466,7 @@ newConnection server sessionConduits params conkey u h inout = do | |||
| 466 | _ -> ( pingInterval params | 466 | _ -> ( pingInterval params |
| 467 | , timeout params ) | 467 | , timeout params ) |
| 468 | 468 | ||
| 469 | new <- do pinglogic <- forkPingMachine idle_ms timeout_ms | 469 | new <- do pinglogic <- forkPingMachine "newConnection" idle_ms timeout_ms |
| 470 | connectionThreads h pinglogic | 470 | connectionThreads h pinglogic |
| 471 | started <- atomically $ newEmptyTMVar | 471 | started <- atomically $ newEmptyTMVar |
| 472 | kontvar <- atomically newEmptyTMVar | 472 | kontvar <- atomically newEmptyTMVar |
| @@ -778,7 +778,7 @@ tcpManager :: ( Show k, Ord k, Ord conkey ) => | |||
| 778 | -> IO (Manager TCPStatus k) | 778 | -> IO (Manager TCPStatus k) |
| 779 | tcpManager grokKey s2k resolvKey sv = do | 779 | tcpManager grokKey s2k resolvKey sv = do |
| 780 | rmap <- atomically $ newTVar Map.empty -- Map k (Maybe conkey) | 780 | rmap <- atomically $ newTVar Map.empty -- Map k (Maybe conkey) |
| 781 | nullping <- forkPingMachine 0 0 | 781 | nullping <- forkPingMachine "tcpManager" 0 0 |
| 782 | return Manager { | 782 | return Manager { |
| 783 | setPolicy = \k -> \case | 783 | setPolicy = \k -> \case |
| 784 | TryingToConnect -> join $ atomically $ do | 784 | TryingToConnect -> join $ atomically $ do |