Use io-sim-1.0.0.0

IntersectMBO · Jan 16, 2023 · 359f05a · 359f05a
1 parent 17f15b4
commit 359f05a
Show file tree

Hide file tree

Showing 132 changed files with 532 additions and 356 deletions.
diff --git a/cardano-ping/cardano-ping.cabal b/cardano-ping/cardano-ping.cabal
@@ -22,12 +22,9 @@ library
   exposed-modules:      Cardano.Network.Ping
   build-depends:        base                          >= 4.9      && < 4.17,
                         aeson                         >= 2.1.1.0  && < 3,
+                        contra-tracer                ^>= 0.1,
                         cborg                         >= 0.2.8    && < 0.3,
                         bytestring                    >= 0.10     && < 0.12,
-                        contra-tracer                 >= 0.1      && < 0.2,
-                        io-classes                    >= 0.3      && < 0.4,
-                        network-mux                   >= 0.2      && < 0.3,
-                        strict-stm                    >= 0.2      && < 0.3,
                         tdigest                       >= 0.2.1.1  && < 0.3,
                         text                          >= 1.2.4    && < 2.1,
 
@@ -36,6 +33,10 @@ library
                         -- https://github.com/haskell/network/issues/484
                         network                       >= 3.1.2.2  && < 3.2,
 
+                        io-classes,
+                        network-mux                  ^>= 0.2,
+                        strict-stm,
+
   if os(windows)
     build-depends:      Win32                         >= 2.5.4.1  && < 3.0,
                         Win32-network                 >= 0.1      && < 0.2,

diff --git a/monoidal-synchronisation/test/Test/Data/Monoid/Synchronisation.hs b/monoidal-synchronisation/test/Test/Data/Monoid/Synchronisation.hs
@@ -1,7 +1,9 @@
+{-# LANGUAGE FlexibleContexts    #-}
 {-# LANGUAGE GADTs               #-}
 {-# LANGUAGE ScopedTypeVariables #-}
 module Test.Data.Monoid.Synchronisation where
 
+import           Control.Monad (MonadPlus)
 import           Control.Concurrent.Class.MonadSTM
 import           Control.Monad.Class.MonadFork
 
@@ -23,6 +25,7 @@ tests =
 lastToFinishExperiment
     :: forall m.
        ( MonadFork  m
+       , MonadPlus (STM m)
        , MonadSTM   m
        )
     => Bool -> m Bool

diff --git a/network-mux/network-mux.cabal b/network-mux/network-mux.cabal
@@ -44,8 +44,9 @@ common demo-deps
 
 library
   build-depends:       base            >=4.9 && <4.17,
-                       io-classes     ^>=0.3,
-                       strict-stm     ^>=0.2,
+                       io-classes     ^>=0.4,
+                       si-timers,
+                       strict-stm,
                        contra-tracer   >=0.1 && <0.2,
                        monoidal-synchronisation
                                        >=0.1 && <0.2,
@@ -123,8 +124,9 @@ test-suite test
   default-language:    Haskell2010
   build-depends:       base,
                        io-classes,
+                       si-timers,
                        strict-stm,
-                       io-sim            >=0.3 && < 0.4,
+                       io-sim            >=0.3 && < 0.5,
                        contra-tracer,
                        network-mux,
                        Win32-network,

diff --git a/network-mux/src/Network/Mux.hs b/network-mux/src/Network/Mux.hs
@@ -55,8 +55,8 @@ import           Control.Monad
 import           Control.Monad.Class.MonadAsync
 import           Control.Monad.Class.MonadFork
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
-import           Control.Monad.Class.MonadTimer hiding (timeout)
+import           Control.Monad.Class.MonadTime.SI
+import           Control.Monad.Class.MonadTimer.SI hiding (timeout)
 import           Control.Tracer
 
 import           Network.Mux.Channel
@@ -198,6 +198,7 @@ runMux :: forall m mode.
           ( MonadAsync m
           , MonadFork m
           , MonadLabelledSTM m
+          , Alternative (STM m)
           , MonadThrow (STM m)
           , MonadTime  m
           , MonadTimer m
@@ -344,6 +345,7 @@ newtype MonitorCtx m mode = MonitorCtx {
 monitor :: forall mode m.
            ( MonadAsync m
            , MonadMask m
+           , Alternative (STM m)
            , MonadThrow (STM m)
            )
         => Tracer m MuxTrace
@@ -621,7 +623,8 @@ traceMuxBearerState tracer state =
 -- irrespective of the 'StartOnDemandOrEagerly' value.
 --
 runMiniProtocol :: forall mode m a.
-                   ( MonadSTM   m
+                   ( Alternative (STM m)
+                   , MonadSTM   m
                    , MonadThrow m
                    , MonadThrow (STM m)
                    )

diff --git a/network-mux/src/Network/Mux/Bearer/AttenuatedChannel.hs b/network-mux/src/Network/Mux/Bearer/AttenuatedChannel.hs
@@ -21,8 +21,8 @@ import           Prelude hiding (read)
 import           Control.Concurrent.Class.MonadSTM.Strict
 import           Control.Monad (when)
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
-import           Control.Monad.Class.MonadTimer
+import           Control.Monad.Class.MonadTime.SI
+import           Control.Monad.Class.MonadTimer.SI
 import           Control.Tracer (Tracer, traceWith)
 
 import           GHC.IO.Exception
@@ -156,7 +156,7 @@ data Attenuation = Attenuation {
 -- | Make a 'AttenuatedChannel' from a 'QueueChannel'.
 --
 newAttenuatedChannel :: forall m.
-                        ( MonadTime       m
+                        ( MonadDelay      m
                         , MonadTimer      m
                         , MonadThrow      m
                         , MonadThrow (STM m)
@@ -232,7 +232,8 @@ newAttenuatedChannel tr Attenuation { aReadAttenuation,
 --
 newConnectedAttenuatedChannelPair
     :: forall m.
-       ( MonadLabelledSTM m
+       ( MonadDelay       m
+       , MonadLabelledSTM m
        , MonadTime        m
        , MonadTimer       m
        , MonadThrow       m

diff --git a/network-mux/src/Network/Mux/Bearer/Pipe.hs b/network-mux/src/Network/Mux/Bearer/Pipe.hs
@@ -16,7 +16,7 @@ module Network.Mux.Bearer.Pipe (
   ) where
 
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
+import           Control.Monad.Class.MonadTime.SI
 import           Control.Tracer
 import qualified Data.ByteString.Lazy as BL
 import           System.IO (Handle, hFlush)

diff --git a/network-mux/src/Network/Mux/Bearer/Queues.hs b/network-mux/src/Network/Mux/Bearer/Queues.hs
@@ -8,7 +8,7 @@ import qualified Data.ByteString.Lazy as BL
 
 import           Control.Concurrent.Class.MonadSTM.Strict
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
+import           Control.Monad.Class.MonadTime.SI
 import           Control.Tracer
 
 import qualified Network.Mux as Mx
@@ -22,7 +22,7 @@ import qualified Network.Mux.Types as Mx
 queuesAsMuxBearer
   :: forall m.
      ( MonadSTM   m
-     , MonadTime  m
+     , MonadMonotonicTime m
      , MonadThrow m
      )
   => Tracer m Mx.MuxTrace

diff --git a/network-mux/src/Network/Mux/Bearer/Socket.hs b/network-mux/src/Network/Mux/Bearer/Socket.hs
@@ -12,8 +12,8 @@ import qualified Data.ByteString.Lazy as BL
 import           Data.Int
 
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
-import           Control.Monad.Class.MonadTimer hiding (timeout)
+import           Control.Monad.Class.MonadTime.SI
+import           Control.Monad.Class.MonadTimer.SI hiding (timeout)
 
 import qualified Network.Socket as Socket
 #if !defined(mingw32_HOST_OS)

diff --git a/network-mux/src/Network/Mux/Channel.hs b/network-mux/src/Network/Mux/Channel.hs
@@ -30,7 +30,7 @@ import qualified System.Process as IO (createPipe)
 
 import           Control.Concurrent.Class.MonadSTM
 import           Control.Monad.Class.MonadSay
-import           Control.Monad.Class.MonadTimer
+import           Control.Monad.Class.MonadTimer.SI
 
 
 data Channel m = Channel {
@@ -209,8 +209,7 @@ channelEffect beforeSend afterRecv Channel{send, recv} =
 -- This is intended for testing, as a crude approximation of network delays.
 -- More accurate models along these lines are of course possible.
 --
-delayChannel :: ( MonadTimer m
-                )
+delayChannel :: MonadDelay m
              => DiffTime
              -> Channel m
              -> Channel m

diff --git a/network-mux/src/Network/Mux/Compat.hs b/network-mux/src/Network/Mux/Compat.hs
@@ -35,14 +35,13 @@ module Network.Mux.Compat
 import qualified Data.ByteString.Lazy as BL
 import           Data.Void (Void)
 
-import           Control.Applicative ((<|>))
+import           Control.Applicative (Alternative (..), (<|>))
 import           Control.Concurrent.Class.MonadSTM.Strict
 import           Control.Monad
 import           Control.Monad.Class.MonadAsync
-import           Control.Monad.Class.MonadFork
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
-import           Control.Monad.Class.MonadTimer
+import           Control.Monad.Class.MonadTime.SI
+import           Control.Monad.Class.MonadTimer.SI
 import           Control.Tracer
 
 import           Network.Mux (StartOnDemandOrEagerly (..), newMux,
@@ -90,6 +89,7 @@ muxStart
        ( MonadAsync m
        , MonadFork m
        , MonadLabelledSTM m
+       , Alternative (STM m)
        , MonadThrow (STM m)
        , MonadTime  m
        , MonadTimer m

diff --git a/network-mux/src/Network/Mux/DeltaQ/TraceStats.hs b/network-mux/src/Network/Mux/DeltaQ/TraceStats.hs
@@ -11,7 +11,7 @@ import qualified Data.IntMap.Strict as IM
 import           Data.Maybe
 import           Data.Word (Word32)
 
-import           Control.Monad.Class.MonadTime
+import           Control.Monad.Class.MonadTime.SI
 import           Network.Mux.DeltaQ.TraceStatsSupport
 import           Network.Mux.DeltaQ.TraceTypes
 import           Network.Mux.Types

diff --git a/network-mux/src/Network/Mux/Egress.hs b/network-mux/src/Network/Mux/Egress.hs
@@ -18,10 +18,9 @@ import qualified Data.ByteString.Lazy as BL
 
 import           Control.Concurrent.Class.MonadSTM.Strict
 import           Control.Monad.Class.MonadAsync
-import           Control.Monad.Class.MonadFork
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
-import           Control.Monad.Class.MonadTimer hiding (timeout)
+import           Control.Monad.Class.MonadTime.SI
+import           Control.Monad.Class.MonadTimer.SI hiding (timeout)
 
 import           Network.Mux.Timeout
 import           Network.Mux.Types

diff --git a/network-mux/src/Network/Mux/Ingress.hs b/network-mux/src/Network/Mux/Ingress.hs
@@ -19,10 +19,9 @@ import           Text.Printf
 import           Control.Concurrent.Class.MonadSTM.Strict
 import           Control.Monad
 import           Control.Monad.Class.MonadAsync
-import           Control.Monad.Class.MonadFork
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
-import           Control.Monad.Class.MonadTimer hiding (timeout)
+import           Control.Monad.Class.MonadTime.SI
+import           Control.Monad.Class.MonadTimer.SI hiding (timeout)
 
 import           Network.Mux.Timeout
 import           Network.Mux.Trace

diff --git a/network-mux/src/Network/Mux/Time.hs b/network-mux/src/Network/Mux/Time.hs
@@ -8,7 +8,7 @@ module Network.Mux.Time
   , timestampMicrosecondsLow32Bits
   ) where
 
-import           Control.Monad.Class.MonadTime (Time (..))
+import           Control.Monad.Class.MonadTime.SI (Time (..))
 import           Data.Time.Clock (DiffTime, diffTimeToPicoseconds,
                      picosecondsToDiffTime)
 import           Data.Word (Word32)

diff --git a/network-mux/src/Network/Mux/Timeout.hs b/network-mux/src/Network/Mux/Timeout.hs
@@ -29,9 +29,9 @@ import           Control.Monad
 import           Control.Monad.Class.MonadAsync
 import           Control.Monad.Class.MonadFork
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
-import           Control.Monad.Class.MonadTimer (MonadTimer, registerDelay)
-import qualified Control.Monad.Class.MonadTimer as MonadTimer
+import           Control.Monad.Class.MonadTime.SI
+import           Control.Monad.Class.MonadTimer.SI (MonadTimer, registerDelay)
+import qualified Control.Monad.Class.MonadTimer.SI as MonadTimer
 
 
 -- | The type of the 'System.Timeout.timeout' function.
@@ -305,8 +305,8 @@ timeout monitorState delay action =
 
 
 monitoringThread :: (MonadFork m, MonadSTM m,
-                     MonadMonotonicTime m, MonadTimer m,
-                     MonadThrow (STM m))
+                     MonadMonotonicTime m,
+                     MonadTimer m, MonadThrow (STM m))
                  => MonitorState m -> m ()
 monitoringThread monitorState@MonitorState{deadlineResetVar} = do
   threadId <- myThreadId

diff --git a/network-mux/src/Network/Mux/Trace.hs b/network-mux/src/Network/Mux/Trace.hs
@@ -23,7 +23,7 @@ import           Text.Printf
 
 import           Control.Exception hiding (throwIO)
 import           Control.Monad.Class.MonadThrow
-import           Control.Monad.Class.MonadTime
+import           Control.Monad.Class.MonadTime.SI
 import           Data.Bifunctor (Bifunctor (..))
 import           Data.Word
 import           GHC.Generics (Generic (..))

diff --git a/network-mux/src/Network/Mux/Types.hs b/network-mux/src/Network/Mux/Types.hs
@@ -52,7 +52,7 @@ import           Quiet
 import           GHC.Generics (Generic)
 
 import           Control.Concurrent.Class.MonadSTM.Strict (StrictTVar)
-import           Control.Monad.Class.MonadTime
+import           Control.Monad.Class.MonadTime.SI
 
 import           Network.Mux.Channel (Channel (..))
 import           Network.Mux.Timeout (TimeoutFn)