Simulation.Aivika.Distributed.Optimistic.DIO

Tested with: GHC 7.10.3

This module defines DIO as an instance of the MonadDES type class.

Documentation

data DIO a

The distributed computation based on IO.

Instances

Monad DIO

Functor DIO

Applicative DIO

MonadException DIO

data Ref DIO = Ref {

• refValue :: Ref a

}

data EventQueue DIO = EventQueue {

• queueInputMessages :: InputMessageQueue
• queueOutputMessages :: OutputMessageQueue
• queueLog :: UndoableLog
• queuePQ :: Ref (PriorityQueue (Point DIO -> DIO ()))
• queueBusy :: IORef Bool
• queueTime :: IORef Double
• queueGlobalTime :: IORef Double
• queueLocalTime :: IORef Double
• queueLocalTime0 :: IORef Double
• queueLocalTimeTimestamp :: IORef UTCTime
• queueLocalTimeInterval :: NominalDiffTime

}

data Generator DIO = Generator {

• generator01 :: DIO Double
• generatorNormal01 :: DIO Double

}

data StrategyQueue DIO FCFS = FCFSQueue (DoubleLinkedList DIO a)

data StrategyQueue DIO LCFS = LCFSQueue (DoubleLinkedList DIO a)

data DIOParams

The parameters for the DIO computation.

Constructors

DIOParams

Fields

dioLoggingPriority :: Priority

The logging priority

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

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

dioAllowProcessingOutdatedMessage :: Bool

Whether to allow processing an outdated message with the receive time less than the global time

Instances

Eq DIOParams

Ord DIOParams

Show DIOParams

Generic DIOParams

Binary DIOParams

type Rep DIOParams

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.

defaultDIOParams :: DIOParams

The default 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.

unregisterDIO :: DIO ()

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