Copyright	Copyright (c) 2015-2017 David Sorokin <david.sorokin@gmail.com>
License	BSD3
Maintainer	David Sorokin <david.sorokin@gmail.com>
Stability	experimental
Safe Haskell	Safe-Inferred
Language	Haskell2010

Simulation.Aivika.Distributed.Optimistic.DIO

Contents

Orphan instances

Description

Tested with: GHC 7.10.3

This module defines DIO as an instance of the MonadDES and EventIOQueueing type classes.

Synopsis

data DIO a
data DIOParams = DIOParams {
}
data DIOEnv = DIOEnv {
- dioSimulationMonitoringAction :: Maybe (LogicalProcessState -> Process ())
}
data DIOStrategy
- = WaitIndefinitelyForTimeServer
- | TerminateDueToTimeServerTimeout Int
runDIO :: DIO a -> DIOParams -> ProcessId -> Process (ProcessId, Process a)
runDIOWithEnv :: DIO a -> DIOParams -> DIOEnv -> ProcessId -> Process (ProcessId, Process a)
defaultDIOParams :: DIOParams
defaultDIOEnv :: DIOEnv
dioParams :: DIO DIOParams
messageInboxId :: DIO ProcessId
timeServerId :: DIO ProcessId
logDIO :: Priority -> String -> DIO ()
terminateDIO :: DIO ()
registerDIO :: DIO ()
unregisterDIO :: DIO ()
monitorProcessDIO :: ProcessId -> DIO ()
data InboxProcessMessage = MonitorProcessMessage ProcessId
processMonitorSignal :: Signal DIO ProcessMonitorNotification

Documentation

data DIO a Source #

The distributed computation based on IO.

Instances

Instances details

MonadComp DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.DIO
MonadDES DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.DIO
MonadException DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods catchComp :: Exception e => DIO a -> (e -> DIO a) -> DIO a # finallyComp :: DIO a -> DIO b -> DIO a # throwComp :: Exception e => e -> DIO a #
MonadGenerator DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Generator Associated Types data Generator DIO # Methods generateUniform :: Generator DIO -> Double -> Double -> DIO Double # generateUniformInt :: Generator DIO -> Int -> Int -> DIO Int # generateTriangular :: Generator DIO -> Double -> Double -> Double -> DIO Double # generateNormal :: Generator DIO -> Double -> Double -> DIO Double # generateLogNormal :: Generator DIO -> Double -> Double -> DIO Double # generateExponential :: Generator DIO -> Double -> DIO Double # generateErlang :: Generator DIO -> Double -> Int -> DIO Double # generatePoisson :: Generator DIO -> Double -> DIO Int # generateBinomial :: Generator DIO -> Double -> Int -> DIO Int # generateGamma :: Generator DIO -> Double -> Double -> DIO Double # generateBeta :: Generator DIO -> Double -> Double -> DIO Double # generateWeibull :: Generator DIO -> Double -> Double -> DIO Double # generateDiscrete :: Generator DIO -> DiscretePDF a -> DIO a # generateSequenceNo :: Generator DIO -> DIO Int # newGenerator :: GeneratorType DIO -> DIO (Generator DIO) # newRandomGenerator :: RandomGen g => g -> DIO (Generator DIO) # newRandomGenerator01 :: DIO Double -> DIO (Generator DIO) #
EventIOQueueing DIO Source #	`DIO` is an instance of `EventIOQueueing`.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Event Methods enqueueEventIO :: Double -> Event DIO () -> Event DIO () #
EventQueueing DIO Source #	An implementation of the `EventQueueing` type class.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Event Associated Types data EventQueue DIO # Methods newEventQueue :: Specs DIO -> DIO (EventQueue DIO) # enqueueEventWithPriority :: Double -> EventPriority -> Event DIO () -> Event DIO () # enqueueEvent :: Double -> Event DIO () -> Event DIO () # runEvent :: Event DIO a -> Dynamics DIO a # runEventWith :: EventProcessing -> Event DIO a -> Dynamics DIO a # eventQueueCount :: Event DIO Int #
MonadRef DIO Source #	The implementation of lazy mutable references.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Lazy Associated Types data Ref DIO a # Methods newRef :: a -> Simulation DIO (Ref DIO a) # readRef :: Ref DIO a -> Event DIO a # writeRef :: Ref DIO a -> a -> Event DIO () # modifyRef :: Ref DIO a -> (a -> a) -> Event DIO () # equalRef :: Ref DIO a -> Ref DIO a -> Bool #
MonadRef0 DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Lazy Methods newRef0 :: a -> DIO (Ref DIO a) #
MonadRef DIO Source #	The implementation of strict mutable references.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Strict Associated Types data Ref DIO a # Methods newRef :: a -> Simulation DIO (Ref DIO a) # readRef :: Ref DIO a -> Event DIO a # writeRef :: Ref DIO a -> a -> Event DIO () # modifyRef :: Ref DIO a -> (a -> a) -> Event DIO () # equalRef :: Ref DIO a -> Ref DIO a -> Bool #
MonadRef0 DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Strict Methods newRef0 :: a -> DIO (Ref DIO a) #
Applicative DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods pure :: a -> DIO a # (<>) :: DIO (a -> b) -> DIO a -> DIO b # liftA2 :: (a -> b -> c) -> DIO a -> DIO b -> DIO c # (>) :: DIO a -> DIO b -> DIO b # (<*) :: DIO a -> DIO b -> DIO a #
Functor DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods fmap :: (a -> b) -> DIO a -> DIO b # (<$) :: a -> DIO b -> DIO a #
Monad DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods (>>=) :: DIO a -> (a -> DIO b) -> DIO b # (>>) :: DIO a -> DIO b -> DIO b # return :: a -> DIO a #
DequeueStrategy DIO FCFS Source #	An implementation of the `FCFS` queue strategy.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy Methods strategyDequeue :: StrategyQueue DIO FCFS a -> Event DIO a #
DequeueStrategy DIO LCFS Source #	An implementation of the `LCFS` queue strategy.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy Methods strategyDequeue :: StrategyQueue DIO LCFS a -> Event DIO a #
EnqueueStrategy DIO FCFS Source #	An implementation of the `FCFS` queue strategy.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy Methods strategyEnqueue :: StrategyQueue DIO FCFS a -> a -> Event DIO () #
EnqueueStrategy DIO LCFS Source #	An implementation of the `LCFS` queue strategy.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy Methods strategyEnqueue :: StrategyQueue DIO LCFS a -> a -> Event DIO () #
QueueStrategy DIO FCFS Source #	An implementation of the `FCFS` queue strategy.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy Associated Types data StrategyQueue DIO FCFS :: Type -> Type # Methods newStrategyQueue :: FCFS -> Simulation DIO (StrategyQueue DIO FCFS a) # strategyQueueNull :: StrategyQueue DIO FCFS a -> Event DIO Bool #
QueueStrategy DIO LCFS Source #	An implementation of the `LCFS` queue strategy.
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy Associated Types data StrategyQueue DIO LCFS :: Type -> Type # Methods newStrategyQueue :: LCFS -> Simulation DIO (StrategyQueue DIO LCFS a) # strategyQueueNull :: StrategyQueue DIO LCFS a -> Event DIO Bool #
MonadIO (Composite DIO) Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.DIO Methods liftIO :: IO a -> Composite DIO a #
MonadIO (Process DIO) Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.DIO Methods liftIO :: IO a -> Process DIO a #
MonadIO (Event DIO) Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Event Methods liftIO :: IO a -> Event DIO a #
data Generator DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Generator data Generator DIO = Generator { generator01 :: DIO Double generatorNormal01 :: DIO Double generatorSequenceNo :: DIO Int }
data EventQueue DIO Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Event data EventQueue DIO = EventQueue { queueInputMessages :: InputMessageQueue queueOutputMessages :: OutputMessageQueue queueTransientMessages :: TransientMessageQueue queueAcknowledgementMessages :: AcknowledgementMessageQueue queueLog :: UndoableLog queuePQ :: Ref (PriorityQueue (Point DIO -> DIO ())) queueBusy :: IORef Bool queueTime :: IORef Double queueGlobalTime :: IORef Double queueInFind :: IORef Bool queueProcessMonitorNotificationSource :: SignalSource DIO ProcessMonitorNotification queueIsLeaving :: IORef Bool }
newtype Ref DIO a Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Lazy newtype Ref DIO a = Ref { refValue :: Ref a }
newtype Ref DIO a Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Strict newtype Ref DIO a = Ref { refValue :: Ref a }
newtype StrategyQueue DIO FCFS a Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy newtype StrategyQueue DIO FCFS a = FCFSQueue (DoubleLinkedList DIO a)
newtype StrategyQueue DIO LCFS a Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy newtype StrategyQueue DIO LCFS a = LCFSQueue (DoubleLinkedList DIO a)

data DIOParams Source #

The parameters for the DIO computation.

Constructors

DIOParams

Fields

dioLoggingPriority :: Priority
The logging priority
dioName :: String
The name of the logical process.
dioTimeHorizon :: Maybe Double
The time horizon in modeling time units.
dioUndoableLogSizeThreshold :: Int
The undoable log size threshold used for detecting an overflow
dioOutputMessageQueueSizeThreshold :: Int
The output message queue size threshold used for detecting an overflow
dioTransientMessageQueueSizeThreshold :: Int
The transient message queue size threshold used for detecting an overflow
dioSyncTimeout :: Int
The timeout in microseconds used for synchronising the operations
dioAllowPrematureIO :: Bool
Whether to allow performing the premature IO action; otherwise, raise an error
dioAllowSkippingOutdatedMessage :: Bool
Whether to allow skipping an outdated message with the receive time less than the global time, which is possible after reconnection
dioProcessMonitoringEnabled :: Bool
Whether the process monitoring is enabled
dioProcessMonitoringDelay :: Int
The delay in microseconds which must be applied for monitoring every remote process.
dioProcessReconnectingEnabled :: Bool
Whether the automatic reconnecting to processes is enabled when the monitoring is enabled
dioProcessReconnectingDelay :: Int
The delay in microseconds before reconnecting to the remote process
dioKeepAliveInterval :: Int
The interval in microseconds for sending keep-alive messages
dioTimeServerAcknowledgementTimeout :: Int
The timeout in microseconds for receiving an acknowledgement message from the time server
dioSimulationMonitoringInterval :: Int
The interval in microseconds between sending the simulation monitoring messages
dioSimulationMonitoringTimeout :: Int
The timeout in microseconds when processing the monitoring messages
dioStrategy :: DIOStrategy
The logical process strategy
dioProcessDisconnectingEnabled :: Bool
Whether the process disconnecting is enabled when the monitoring is enabled but the reconnecting is disabled

Instances

Instances details

Generic DIOParams Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Associated Types type Rep DIOParams :: Type -> Type # Methods from :: DIOParams -> Rep DIOParams x # to :: Rep DIOParams x -> DIOParams #
Show DIOParams Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods showsPrec :: Int -> DIOParams -> ShowS # show :: DIOParams -> String # showList :: [DIOParams] -> ShowS #
Binary DIOParams Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods put :: DIOParams -> Put # get :: Get DIOParams # putList :: [DIOParams] -> Put #
Eq DIOParams Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods (==) :: DIOParams -> DIOParams -> Bool # (/=) :: DIOParams -> DIOParams -> Bool #
Ord DIOParams Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods compare :: DIOParams -> DIOParams -> Ordering # (<) :: DIOParams -> DIOParams -> Bool # (<=) :: DIOParams -> DIOParams -> Bool # (>) :: DIOParams -> DIOParams -> Bool # (>=) :: DIOParams -> DIOParams -> Bool # max :: DIOParams -> DIOParams -> DIOParams # min :: DIOParams -> DIOParams -> DIOParams #
type Rep DIOParams Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO type Rep DIOParams = D1 ('MetaData "DIOParams" "Simulation.Aivika.Distributed.Optimistic.Internal.DIO" "aivika-distributed-1.5.1-LD6d5nK4AIqDBvGt7m30NF" 'False) (C1 ('MetaCons "DIOParams" 'PrefixI 'True) ((((S1 ('MetaSel ('Just "dioLoggingPriority") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Priority) :: S1 ('MetaSel ('Just "dioName") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 String)) :: (S1 ('MetaSel ('Just "dioTimeHorizon") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 (Maybe Double)) :: S1 ('MetaSel ('Just "dioUndoableLogSizeThreshold") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int))) :: ((S1 ('MetaSel ('Just "dioOutputMessageQueueSizeThreshold") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :: S1 ('MetaSel ('Just "dioTransientMessageQueueSizeThreshold") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)) :: (S1 ('MetaSel ('Just "dioSyncTimeout") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :: (S1 ('MetaSel ('Just "dioAllowPrematureIO") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :: S1 ('MetaSel ('Just "dioAllowSkippingOutdatedMessage") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool))))) :: (((S1 ('MetaSel ('Just "dioProcessMonitoringEnabled") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :: S1 ('MetaSel ('Just "dioProcessMonitoringDelay") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)) :: (S1 ('MetaSel ('Just "dioProcessReconnectingEnabled") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool) :: (S1 ('MetaSel ('Just "dioProcessReconnectingDelay") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :: S1 ('MetaSel ('Just "dioKeepAliveInterval") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))) :: ((S1 ('MetaSel ('Just "dioTimeServerAcknowledgementTimeout") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :: S1 ('MetaSel ('Just "dioSimulationMonitoringInterval") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)) :: (S1 ('MetaSel ('Just "dioSimulationMonitoringTimeout") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int) :: (S1 ('MetaSel ('Just "dioStrategy") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 DIOStrategy) :: S1 ('MetaSel ('Just "dioProcessDisconnectingEnabled") 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Bool)))))))

data DIOEnv Source #

Those DIO environment parameters that cannot be serialized and passed to another process via the net.

Constructors

DIOEnv
Fields dioSimulationMonitoringAction :: Maybe (LogicalProcessState -> Process ()) The simulation monitoring action

data DIOStrategy Source #

The logical process strategy.

Constructors

WaitIndefinitelyForTimeServer	Wait for the time server forever
TerminateDueToTimeServerTimeout Int	Terminate due to the exceeded time server timeout in microseconds, but not less than `dioSyncTimeout`

Instances

Instances details

Generic DIOStrategy Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Associated Types type Rep DIOStrategy :: Type -> Type # Methods from :: DIOStrategy -> Rep DIOStrategy x # to :: Rep DIOStrategy x -> DIOStrategy #
Show DIOStrategy Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods showsPrec :: Int -> DIOStrategy -> ShowS # show :: DIOStrategy -> String # showList :: [DIOStrategy] -> ShowS #
Binary DIOStrategy Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods put :: DIOStrategy -> Put # get :: Get DIOStrategy # putList :: [DIOStrategy] -> Put #
Eq DIOStrategy Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods (==) :: DIOStrategy -> DIOStrategy -> Bool # (/=) :: DIOStrategy -> DIOStrategy -> Bool #
Ord DIOStrategy Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO Methods compare :: DIOStrategy -> DIOStrategy -> Ordering # (<) :: DIOStrategy -> DIOStrategy -> Bool # (<=) :: DIOStrategy -> DIOStrategy -> Bool # (>) :: DIOStrategy -> DIOStrategy -> Bool # (>=) :: DIOStrategy -> DIOStrategy -> Bool # max :: DIOStrategy -> DIOStrategy -> DIOStrategy # min :: DIOStrategy -> DIOStrategy -> DIOStrategy #
type Rep DIOStrategy Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO type Rep DIOStrategy = D1 ('MetaData "DIOStrategy" "Simulation.Aivika.Distributed.Optimistic.Internal.DIO" "aivika-distributed-1.5.1-LD6d5nK4AIqDBvGt7m30NF" 'False) (C1 ('MetaCons "WaitIndefinitelyForTimeServer" 'PrefixI 'False) (U1 :: Type -> Type) :+: C1 ('MetaCons "TerminateDueToTimeServerTimeout" 'PrefixI 'False) (S1 ('MetaSel ('Nothing :: Maybe Symbol) 'NoSourceUnpackedness 'NoSourceStrictness 'DecidedLazy) (Rec0 Int)))

runDIO :: DIO a -> DIOParams -> ProcessId -> Process (ProcessId, Process a) Source #

Run the computation using the specified parameters along with time server process identifier and return the inbox process identifier and a new simulation process.

runDIOWithEnv :: DIO a -> DIOParams -> DIOEnv -> ProcessId -> Process (ProcessId, Process a) Source #

A full version of runDIO that also allows specifying the environment parameters.

defaultDIOParams :: DIOParams Source #

The default parameters for the DIO computation

defaultDIOEnv :: DIOEnv Source #

The default environment parameters for the DIO computation

dioParams :: DIO DIOParams Source #

Return the parameters of the current computation.

messageInboxId :: DIO ProcessId Source #

Return the process identifier of the inbox that receives messages.

timeServerId :: DIO ProcessId Source #

Return the time server process identifier.

logDIO :: Priority -> String -> DIO () Source #

Log the message with the specified priority.

terminateDIO :: DIO () Source #

Terminate the simulation including the processes in all nodes connected to the time server.

registerDIO :: DIO () Source #

Register the simulation process in the time server, which requires some initial quorum to start synchronizing the global time.

unregisterDIO :: DIO () Source #

Unregister the simulation process from the time server without affecting the processes in other nodes connected to the corresponding time server.

monitorProcessDIO :: ProcessId -> DIO () Source #

Monitor the specified process.

data InboxProcessMessage Source #

The message destined directly for the inbox process.

Constructors

MonitorProcessMessage ProcessId

monitor the logical process by its inbox process identifier

Instances

Instances details

Generic InboxProcessMessage Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message Associated Types type Rep InboxProcessMessage :: Type -> Type # Methods from :: InboxProcessMessage -> Rep InboxProcessMessage x # to :: Rep InboxProcessMessage x -> InboxProcessMessage #
Show InboxProcessMessage Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message Methods showsPrec :: Int -> InboxProcessMessage -> ShowS # show :: InboxProcessMessage -> String # showList :: [InboxProcessMessage] -> ShowS #
Binary InboxProcessMessage Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message Methods put :: InboxProcessMessage -> Put # get :: Get InboxProcessMessage # putList :: [InboxProcessMessage] -> Put #
Eq InboxProcessMessage Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message Methods (==) :: InboxProcessMessage -> InboxProcessMessage -> Bool # (/=) :: InboxProcessMessage -> InboxProcessMessage -> Bool #
type Rep InboxProcessMessage Source #
Instance details Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message type Rep InboxProcessMessage

processMonitorSignal :: Signal DIO ProcessMonitorNotification Source #

A signal triggered when coming the process monitor notification from the Cloud Haskell back-end.

Orphan instances

MonadComp DIO Source #
Instance details
MonadDES DIO Source #
Instance details
MonadIO (Composite DIO) Source #
Instance details Methods liftIO :: IO a -> Composite DIO a #
MonadIO (Process DIO) Source #
Instance details Methods liftIO :: IO a -> Process DIO a #