Copyright	Copyright (c) 2015-2016, 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 EventQueue DIO #
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 #
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 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
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 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.2-1MtPOGwwBc4JsiuGmLWtyX" 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) 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.

unregisterDIO :: DIO () Source #

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

MonadComp DIO Source #

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