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

(*>) :: 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 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

}

data Generator DIO

data Generator DIO = Generator {

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

}

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

• 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

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-0.3.1-1o5PCclXNWUDoWGulaWtPT" False) (C1 (MetaCons "DIOParams" PrefixI True) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "dioLoggingPriority") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Priority)) ((:*:) (S1 (MetaSel (Just Symbol "dioUndoableLogSizeThreshold") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int)) (S1 (MetaSel (Just Symbol "dioOutputMessageQueueSizeThreshold") 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 "dioAllowProcessingOutdatedMessage") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Bool))))))

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.

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.

Orphan instances

MonadDES DIO

MonadComp DIO

MonadIO (Process DIO)

Methods

liftIO :: IO a -> Process DIO a