Copyright	Copyright (c) 2015-2017 David Sorokin <david.sorokin@gmail.com>
License	BSD3
Maintainer	David Sorokin <david.sorokin@gmail.com>
Stability	experimental
Safe Haskell	None
Language	Haskell98

Simulation.Aivika.Distributed.Optimistic.DIO

Contents

Orphan instances

Description

Tested with: GHC 7.10.3

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

Synopsis

Documentation

data DIO a Source #

The distributed computation based on IO.

Instances

Monad DIO Source #
Methods (>>=) :: DIO a -> (a -> DIO b) -> DIO b # (>>) :: DIO a -> DIO b -> DIO b # return :: a -> DIO a # fail :: String -> DIO a #
Functor DIO Source #
Methods fmap :: (a -> b) -> DIO a -> DIO b # (<$) :: a -> DIO b -> DIO a #
Applicative DIO Source #
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 Source #
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 Source #

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
dioTimeServerAcknowledgementTimeout :: Int
The timeout in microseconds for receiving an acknowledgement message from the time server
dioStrategy :: DIOStrategy
The logical process strategy

Instances

Eq DIOParams Source #
Methods (==) :: DIOParams -> DIOParams -> Bool # (/=) :: DIOParams -> DIOParams -> Bool #
Ord DIOParams Source #
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 Source #
Methods showsPrec :: Int -> DIOParams -> ShowS # show :: DIOParams -> String # showList :: [DIOParams] -> ShowS #
Generic DIOParams Source #
Associated Types type Rep DIOParams :: * -> * # Methods from :: DIOParams -> Rep DIOParams x # to :: Rep DIOParams x -> DIOParams #
Binary DIOParams Source #
Methods put :: DIOParams -> Put # get :: Get DIOParams # putList :: [DIOParams] -> Put #
type Rep DIOParams Source #
type Rep DIOParams = D1 (MetaData "DIOParams" "Simulation.Aivika.Distributed.Optimistic.Internal.DIO" "aivika-distributed-0.7.2-FCdKdkrd9d2LTuZWSKPZe3" 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 "dioTimeServerAcknowledgementTimeout") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int)) (S1 (MetaSel (Just Symbol "dioStrategy") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 DIOStrategy)))))))

data DIOStrategy Source #

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 Source #
Methods (==) :: DIOStrategy -> DIOStrategy -> Bool # (/=) :: DIOStrategy -> DIOStrategy -> Bool #
Ord DIOStrategy Source #
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 Source #
Methods showsPrec :: Int -> DIOStrategy -> ShowS # show :: DIOStrategy -> String # showList :: [DIOStrategy] -> ShowS #
Generic DIOStrategy Source #
Associated Types type Rep DIOStrategy :: * -> * # Methods from :: DIOStrategy -> Rep DIOStrategy x # to :: Rep DIOStrategy x -> DIOStrategy #
Binary DIOStrategy Source #
Methods put :: DIOStrategy -> Put # get :: Get DIOStrategy # putList :: [DIOStrategy] -> Put #
type Rep DIOStrategy Source #
type Rep DIOStrategy = D1 (MetaData "DIOStrategy" "Simulation.Aivika.Distributed.Optimistic.Internal.DIO" "aivika-distributed-0.7.2-FCdKdkrd9d2LTuZWSKPZe3" 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) Source #

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

The default parameters for the DIO computation

dioParams :: DIO DIOParams Source #

Return the parameters of the current computation.

messageInboxId :: DIO ProcessId Source #

Return the process identifier of the inbox that receives messages.

timeServerId :: DIO ProcessId Source #

Return the time server process identifier.

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

Log the message with the specified priority.

terminateDIO :: DIO () Source #

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

registerDIO :: DIO () Source #

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

unregisterDIO :: DIO () Source #

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

monitorProcessDIO :: ProcessId -> DIO () Source #

Monitor the specified process.

data InboxProcessMessage Source #

The message destined directly for the inbox process.

Constructors

MonitorProcessMessage ProcessId

monitor the logical process by its inbox process identifier

Instances

Eq InboxProcessMessage Source #
Methods (==) :: InboxProcessMessage -> InboxProcessMessage -> Bool # (/=) :: InboxProcessMessage -> InboxProcessMessage -> Bool #
Show InboxProcessMessage Source #
Methods showsPrec :: Int -> InboxProcessMessage -> ShowS # show :: InboxProcessMessage -> String # showList :: [InboxProcessMessage] -> ShowS #
Generic InboxProcessMessage Source #
Associated Types type Rep InboxProcessMessage :: * -> * # Methods from :: InboxProcessMessage -> Rep InboxProcessMessage x # to :: Rep InboxProcessMessage x -> InboxProcessMessage #
Binary InboxProcessMessage Source #
Methods put :: InboxProcessMessage -> Put # get :: Get InboxProcessMessage # putList :: [InboxProcessMessage] -> Put #
type Rep InboxProcessMessage Source #
type Rep InboxProcessMessage

processMonitorSignal :: Signal DIO ProcessMonitorNotification Source #

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

Orphan instances

MonadDES DIO Source #

MonadComp DIO Source #

MonadIO (Process DIO) Source #
Methods liftIO :: IO a -> Process DIO a #
MonadIO (Composite DIO) Source #
Methods liftIO :: IO a -> Composite DIO a #