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

Monad DIO

Methods

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

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

return :: a -> DIO a

fail :: String -> DIO a

Functor DIO

Methods

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

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

Applicative 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

MonadException 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

data Ref DIO

data Ref DIO = Ref {

• refValue :: Ref a

}

data Ref DIO

data Ref DIO = Ref {

• refValue :: Ref a

}

data EventQueue DIO

data EventQueue DIO = EventQueue {

• queueInputMessages :: InputMessageQueue
• queueOutputMessages :: OutputMessageQueue
• queueTransientMessages :: TransientMessageQueue
• queueLog :: UndoableLog
• queuePQ :: Ref (PriorityQueue (Point DIO -> DIO ()))
• queueBusy :: IORef Bool
• queueTime :: IORef Double
• queueGlobalTime :: IORef Double
• queueInFind :: IORef Bool
• queueProcessMonitorNotificationSource :: SignalSource DIO ProcessMonitorNotification

}

data Generator DIO

data Generator DIO = Generator {

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

}

data StrategyQueue DIO FCFS

data StrategyQueue DIO FCFS = FCFSQueue (DoubleLinkedList DIO a)

data StrategyQueue DIO LCFS

data StrategyQueue DIO LCFS = 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 enabled monitoring

• dioProcessReconnectingDelay :: Int

  The timeout 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

Instances

Eq DIOParams

Methods

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

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

Ord DIOParams

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

Show DIOParams

Methods

showsPrec :: Int -> DIOParams -> ShowS

show :: DIOParams -> String

showList :: [DIOParams] -> ShowS

Generic DIOParams

Associated Types

type Rep DIOParams :: * -> *

Methods

from :: DIOParams -> Rep DIOParams x

to :: Rep DIOParams x -> DIOParams

Binary DIOParams

Methods

put :: DIOParams -> Put

get :: Get DIOParams

putList :: [DIOParams] -> Put

type Rep DIOParams

type Rep DIOParams = D1 * (MetaData "DIOParams" "Simulation.Aivika.Distributed.Optimistic.Internal.DIO" "aivika-distributed-1.2-34XhNfd7ARLHUummUSadXy" False) (C1 * (MetaCons "DIOParams" PrefixI True) ((:*:) * ((:*:) * ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "dioLoggingPriority") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Priority)) (S1 * (MetaSel (Just Symbol "dioName") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * String))) ((:*:) * (S1 * (MetaSel (Just Symbol "dioTimeHorizon") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * (Maybe Double))) (S1 * (MetaSel (Just Symbol "dioUndoableLogSizeThreshold") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int)))) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "dioOutputMessageQueueSizeThreshold") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int)) (S1 * (MetaSel (Just Symbol "dioTransientMessageQueueSizeThreshold") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int))) ((:*:) * (S1 * (MetaSel (Just Symbol "dioSyncTimeout") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int)) ((:*:) * (S1 * (MetaSel (Just Symbol "dioAllowPrematureIO") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Bool)) (S1 * (MetaSel (Just Symbol "dioAllowSkippingOutdatedMessage") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Bool)))))) ((:*:) * ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "dioProcessMonitoringEnabled") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Bool)) (S1 * (MetaSel (Just Symbol "dioProcessMonitoringDelay") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int))) ((:*:) * (S1 * (MetaSel (Just Symbol "dioProcessReconnectingEnabled") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Bool)) (S1 * (MetaSel (Just Symbol "dioProcessReconnectingDelay") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int)))) ((:*:) * ((:*:) * (S1 * (MetaSel (Just Symbol "dioKeepAliveInterval") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int)) (S1 * (MetaSel (Just Symbol "dioTimeServerAcknowledgementTimeout") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int))) ((:*:) * (S1 * (MetaSel (Just Symbol "dioSimulationMonitoringInterval") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int)) ((:*:) * (S1 * (MetaSel (Just Symbol "dioSimulationMonitoringTimeout") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * Int)) (S1 * (MetaSel (Just Symbol "dioStrategy") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 * DIOStrategy))))))))

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

Eq DIOStrategy

Methods

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

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

Ord DIOStrategy

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

Show DIOStrategy

Methods

showsPrec :: Int -> DIOStrategy -> ShowS

show :: DIOStrategy -> String

showList :: [DIOStrategy] -> ShowS

Generic DIOStrategy

Associated Types

type Rep DIOStrategy :: * -> *

Methods

from :: DIOStrategy -> Rep DIOStrategy x

to :: Rep DIOStrategy x -> DIOStrategy

Binary DIOStrategy

Methods

put :: DIOStrategy -> Put

get :: Get DIOStrategy

putList :: [DIOStrategy] -> Put

type Rep DIOStrategy

type Rep DIOStrategy = D1 * (MetaData "DIOStrategy" "Simulation.Aivika.Distributed.Optimistic.Internal.DIO" "aivika-distributed-1.2-34XhNfd7ARLHUummUSadXy" False) ((:+:) * (C1 * (MetaCons "WaitIndefinitelyForTimeServer" PrefixI False) (U1 *)) (C1 * (MetaCons "TerminateDueToTimeServerTimeout" PrefixI False) (S1 * (MetaSel (Nothing 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

Eq InboxProcessMessage

Methods

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

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

Show InboxProcessMessage

Methods

showsPrec :: Int -> InboxProcessMessage -> ShowS

show :: InboxProcessMessage -> String

showList :: [InboxProcessMessage] -> ShowS

Generic InboxProcessMessage

Associated Types

type Rep InboxProcessMessage :: * -> *

Methods

from :: InboxProcessMessage -> Rep InboxProcessMessage x

to :: Rep InboxProcessMessage x -> InboxProcessMessage

Binary InboxProcessMessage

Methods

put :: InboxProcessMessage -> Put

get :: Get InboxProcessMessage

putList :: [InboxProcessMessage] -> Put

type Rep InboxProcessMessage

type Rep InboxProcessMessage

processMonitorSignal :: Signal DIO ProcessMonitorNotification

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

Orphan instances

MonadDES DIO

MonadComp DIO

MonadIO (Process DIO)

Methods

liftIO :: IO a -> Process DIO a

MonadIO (Composite DIO)

Methods

liftIO :: IO a -> Composite DIO a