cql-io 0.13.1 → 0.13.2

raw patch · 11 files changed

+20/−6 lines, 11 filesdep ~semigroups

Dependency ranges changed: semigroups

Files

CHANGELOG.md +5/−0
cql-io.cabal +2/−2
src/Database/CQL/IO/Client.hs +2/−0
src/Database/CQL/IO/Cluster/Policies.hs +1/−0
src/Database/CQL/IO/Connection.hs +4/−4
src/Database/CQL/IO/Jobs.hs +1/−0
src/Database/CQL/IO/Settings.hs +1/−0
src/Database/CQL/IO/Signal.hs +1/−0
src/Database/CQL/IO/Sync.hs +1/−0
src/Database/CQL/IO/Tickets.hs +1/−0
src/Database/CQL/IO/Timeouts.hs +1/−0

CHANGELOG.md view

@@ -1,3 +1,8 @@+0.13.2+-----------------------------------------------------------------------------+- Retry on `IOException`.+- Update dependencies.+ 0.13.1 ----------------------------------------------------------------------------- - Support `monad-control` 1.*

cql-io.cabal view

@@ -1,5 +1,5 @@ name:                 cql-io-version:              0.13.1+version:              0.13.2 synopsis:             Cassandra CQL client. stability:            experimental license:              OtherLicense@@ -81,7 +81,7 @@         , mtl                >= 2.1     && < 2.5         , mwc-random         >= 0.13    && < 0.14         , network            >= 2.4     && < 3.0-        , semigroups         >= 0.15    && < 0.16+        , semigroups         >= 0.15    && < 0.20         , stm                >= 2.4     && < 3.0         , text               >= 0.11    && < 2.0         , tinylog            >= 0.8     && < 0.15

src/Database/CQL/IO/Client.hs view

@@ -64,6 +64,7 @@ import Database.CQL.Protocol hiding (Map) import Network.Socket (SockAddr (..), PortNumber) import System.Logger.Class hiding (Settings, new, settings, create)+import Prelude  import qualified Control.Monad.Reader       as Reader import qualified Control.Monad.State.Strict as S@@ -232,6 +233,7 @@             ServerError  {} -> return True             _               -> return False         , const $ Handler $ \(_ :: ConnectionError) -> return True+        , const $ Handler $ \(_ :: IOException)     -> return True         ]  getResponse :: (Tuple a, Tuple b) => Request k a b -> ClientState -> Word -> Client (Response k a b)

src/Database/CQL/IO/Cluster/Policies.hs view

@@ -19,6 +19,7 @@ import Database.CQL.IO.Cluster.Host import Database.CQL.IO.Types (InetAddr) import System.Random.MWC+import Prelude  import qualified Data.Map.Strict as Map

src/Database/CQL/IO/Connection.hs view

@@ -4,7 +4,6 @@  {-# LANGUAGE BangPatterns        #-} {-# LANGUAGE OverloadedStrings   #-}-{-# LANGUAGE RecordWildCards     #-} {-# LANGUAGE TemplateHaskell     #-} {-# LANGUAGE ScopedTypeVariables #-} @@ -66,6 +65,7 @@ import System.IO (nativeNewline, Newline (..)) import System.Logger hiding (Settings, close, defSettings, settings) import System.Timeout+import Prelude  import qualified Data.ByteString            as B import qualified Data.ByteString.Lazy       as L@@ -152,9 +152,9 @@ mkSock :: InetAddr -> IO Socket mkSock (InetAddr a) = socket (familyOf a) Stream defaultProtocol   where-    familyOf (SockAddrInet  {..}) = AF_INET-    familyOf (SockAddrInet6 {..}) = AF_INET6-    familyOf (SockAddrUnix  {..}) = AF_UNIX+    familyOf (SockAddrInet  _ _)     = AF_INET+    familyOf (SockAddrInet6 _ _ _ _) = AF_INET6+    familyOf (SockAddrUnix  _)       = AF_UNIX  ping :: MonadIO m => InetAddr -> m Bool ping a = liftIO $ bracket (mkSock a) S.close $ \s ->

src/Database/CQL/IO/Jobs.hs view

@@ -19,6 +19,7 @@ import Database.CQL.IO.Types import Data.Map.Strict (Map) import Data.Unique+import Prelude  import qualified Data.Map.Strict as Map

src/Database/CQL/IO/Settings.hs view

@@ -20,6 +20,7 @@ import Database.CQL.IO.Pool as P import Database.CQL.IO.Types (Milliseconds (..)) import Network.Socket (PortNumber (..))+import Prelude  data RetrySettings = RetrySettings     { _retryPolicy        :: !RetryPolicy

src/Database/CQL/IO/Signal.hs view

@@ -14,6 +14,7 @@ import Control.Applicative import Control.Concurrent (forkIO) import Data.IORef+import Prelude  newtype Signal a = Sig (IORef [a -> IO ()])

src/Database/CQL/IO/Sync.hs view

@@ -14,6 +14,7 @@ import Control.Applicative import Control.Concurrent.STM import Control.Exception (SomeException, Exception, toException)+import Prelude  data State a     = Empty

src/Database/CQL/IO/Tickets.hs view

@@ -16,6 +16,7 @@ import Control.Concurrent.STM import Control.Exception (SomeException, Exception, toException) import Data.Set (Set)+import Prelude  import qualified Data.Set as Set

src/Database/CQL/IO/Timeouts.hs view

@@ -19,6 +19,7 @@ import Control.Reaper import Control.Monad import Database.CQL.IO.Types (Milliseconds (..), ignore)+import Prelude  data TimeoutManager = TimeoutManager     { roundtrip :: !Int