Simulation.Aivika.Distributed.Optimistic.DIO

Tested with: GHC 7.10.3

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

Documentation

data DIO a

The distributed computation based on IO.

Instances

MonadComp DIO

Defined in Simulation.Aivika.Distributed.Optimistic.DIO

MonadDES DIO

Defined in Simulation.Aivika.Distributed.Optimistic.DIO

MonadException DIO

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

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

DIO is an instance of EventIOQueueing.

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Event

Methods

enqueueEventIO :: Double -> Event DIO () -> Event DIO ()

EventQueueing DIO

An implementation of the EventQueueing type class.

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

The implementation of lazy mutable references.

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

Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Lazy

Methods

newRef0 :: a -> DIO (Ref DIO a)

MonadRef DIO

The implementation of strict mutable references.

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

Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Strict

Methods

newRef0 :: a -> DIO (Ref DIO a)

Applicative DIO

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

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

Methods

fmap :: (a -> b) -> DIO a -> DIO b

(<$) :: a -> DIO b -> DIO a

Monad DIO

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

An implementation of the FCFS queue strategy.

Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy

Methods

strategyDequeue :: StrategyQueue DIO FCFS a -> Event DIO a

DequeueStrategy DIO LCFS

An implementation of the LCFS queue strategy.

Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy

Methods

strategyDequeue :: StrategyQueue DIO LCFS a -> Event DIO a

EnqueueStrategy DIO FCFS

An implementation of the FCFS queue strategy.

Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy

Methods

strategyEnqueue :: StrategyQueue DIO FCFS a -> a -> Event DIO ()

EnqueueStrategy DIO LCFS

An implementation of the LCFS queue strategy.

Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy

Methods

strategyEnqueue :: StrategyQueue DIO LCFS a -> a -> Event DIO ()

QueueStrategy DIO FCFS

An implementation of the FCFS queue strategy.

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

An implementation of the LCFS queue strategy.

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)

Defined in Simulation.Aivika.Distributed.Optimistic.DIO

Methods

liftIO :: IO a -> Composite DIO a

MonadIO (Process DIO)

Defined in Simulation.Aivika.Distributed.Optimistic.DIO

Methods

liftIO :: IO a -> Process DIO a

MonadIO (Event DIO)

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Event

Methods

liftIO :: IO a -> Event DIO a

data Generator DIO

Defined in Simulation.Aivika.Distributed.Optimistic.Generator

data Generator DIO = Generator {

• generator01 :: DIO Double
• generatorNormal01 :: DIO Double
• generatorSequenceNo :: DIO Int

}

data EventQueue DIO

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

Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Lazy

newtype Ref DIO a = Ref {

• refValue :: Ref a

}

newtype Ref DIO a

Defined in Simulation.Aivika.Distributed.Optimistic.Ref.Base.Strict

newtype Ref DIO a = Ref {

• refValue :: Ref a

}

newtype StrategyQueue DIO FCFS a

Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy

newtype StrategyQueue DIO FCFS a = FCFSQueue (DoubleLinkedList DIO a)

newtype StrategyQueue DIO LCFS a

Defined in Simulation.Aivika.Distributed.Optimistic.QueueStrategy

newtype StrategyQueue DIO LCFS a = LCFSQueue (DoubleLinkedList DIO a)

data DIOParams

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

Generic DIOParams

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

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

Methods

showsPrec :: Int -> DIOParams -> ShowS

show :: DIOParams -> String

showList :: [DIOParams] -> ShowS

Binary DIOParams

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

Methods

put :: DIOParams -> Put

get :: Get DIOParams

putList :: [DIOParams] -> Put

Eq DIOParams

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

Methods

(==) :: DIOParams -> DIOParams -> Bool

(/=) :: DIOParams -> DIOParams -> Bool

Ord DIOParams

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

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

type Rep DIOParams = D1 ('MetaData "DIOParams" "Simulation.Aivika.Distributed.Optimistic.Internal.DIO" "aivika-distributed-1.5-9UhGvcCbdOeLYFelPUdJpU" '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

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

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

Generic DIOStrategy

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

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

Methods

showsPrec :: Int -> DIOStrategy -> ShowS

show :: DIOStrategy -> String

showList :: [DIOStrategy] -> ShowS

Binary DIOStrategy

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

Methods

put :: DIOStrategy -> Put

get :: Get DIOStrategy

putList :: [DIOStrategy] -> Put

Eq DIOStrategy

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

Methods

(==) :: DIOStrategy -> DIOStrategy -> Bool

(/=) :: DIOStrategy -> DIOStrategy -> Bool

Ord DIOStrategy

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

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.DIO

type Rep DIOStrategy = D1 ('MetaData "DIOStrategy" "Simulation.Aivika.Distributed.Optimistic.Internal.DIO" "aivika-distributed-1.5-9UhGvcCbdOeLYFelPUdJpU" '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)

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)

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

defaultDIOParams :: DIOParams

The default parameters for the DIO computation

defaultDIOEnv :: DIOEnv

The default environment parameters for the DIO computation

dioParams :: DIO DIOParams

Return the parameters of the current computation.

messageInboxId :: DIO ProcessId

Return the process identifier of the inbox that receives messages.

timeServerId :: DIO ProcessId

Return the time server process identifier.

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

Log the message with the specified priority.

terminateDIO :: DIO ()

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

registerDIO :: DIO ()

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

unregisterDIO :: DIO ()

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

monitorProcessDIO :: ProcessId -> DIO ()

Monitor the specified process.

data InboxProcessMessage

The message destined directly for the inbox process.

Constructors

MonitorProcessMessage ProcessId

monitor the logical process by its inbox process identifier

Instances

Generic InboxProcessMessage

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

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message

Methods

showsPrec :: Int -> InboxProcessMessage -> ShowS

show :: InboxProcessMessage -> String

showList :: [InboxProcessMessage] -> ShowS

Binary InboxProcessMessage

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message

Methods

put :: InboxProcessMessage -> Put

get :: Get InboxProcessMessage

putList :: [InboxProcessMessage] -> Put

Eq InboxProcessMessage

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message

Methods

(==) :: InboxProcessMessage -> InboxProcessMessage -> Bool

(/=) :: InboxProcessMessage -> InboxProcessMessage -> Bool

type Rep InboxProcessMessage

Defined in Simulation.Aivika.Distributed.Optimistic.Internal.Message

type Rep InboxProcessMessage

processMonitorSignal :: Signal DIO ProcessMonitorNotification

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

Orphan instances

MonadComp DIO

MonadDES DIO

MonadIO (Composite DIO)

Methods

liftIO :: IO a -> Composite DIO a

MonadIO (Process DIO)

Methods

liftIO :: IO a -> Process DIO a