reserve-0.1.0: src/Util.hs

{-# LANGUAGE ScopedTypeVariables #-}
module Util where

import           Control.Concurrent
import           Control.Exception
import           System.IO
import           Network

connectRetry :: Int -> HostName ->  PortNumber -> (Maybe Handle -> IO a) -> IO a
connectRetry delay host port action = go 0
  where
    go n
      | n < (10 :: Int) = do
        tryConnect >>= either (\(_ :: IOException) -> retry n) return
      | otherwise = action Nothing

    tryConnect = try $ bracket connect hClose (action . Just)
    retry n = threadDelay delay >> go (succ n)
    connect = connectTo host $ PortNumber port