Run tcp-send in forked threads and ignore exceptions.

1 files changed, 6 insertions, 3 deletions

diff --git a/src/Network/QueryResponse/TCP.hs b/src/Network/QueryResponse/TCP.hs
index 154e9145..328a19e1 100644
--- a/src/Network/QueryResponse/TCP.hs
+++ b/src/Network/QueryResponse/TCP.hs
@@ -98,7 +98,7 @@ acquireConnection mvar tcpcache stream addr = do
                 killThread (tcpThread r)
                 streamGoodbye st
                 hClose (tcpHandle r)
-            atomically $ writeTVar (lru tcpcache) cache'
+                atomically $ modifyTVar' (lru tcpcache) $ MM.delete (TCPAddress k)
 
             return $ Just $ streamEncode st
         Just (tm,v) -> do
@@ -126,7 +126,10 @@ tcpTransport maxcon stream = do
     return Transport
         { awaitMessage   = (takeMVar msgvar >>=)
         , sendMessage    = \addr y -> do
-                                msock <- acquireConnection msgvar tcpcache stream addr
-                                mapM_ ($ y) msock
+                                t <- forkIO $ do
+                                    msock <- acquireConnection msgvar tcpcache stream addr
+                                    mapM_ ($ y) msock
+                                  `catchIOError` \e -> return ()
+                                labelThread t "tcp-send"
         , closeTransport = closeAll tcpcache stream
         }