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

• 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

• dioTimeServerAcknowledgmentTimeout :: Int

  The timeout in microseconds for receiving an acknowledgment message from the time server

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.7-FpEceMKtJFj99JkCePS2qe" 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 "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 "dioTimeServerAcknowledgmentTimeout") 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.

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.

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