Simulation.Aivika.Distributed.Optimistic.TimeServer

Tested with: GHC 7.10.3

This module allows running the time server that coordinates the global simulation time.

Documentation

data TimeServerParams

The time server parameters.

Constructors

TimeServerParams

Fields

• tsLoggingPriority :: Priority

  the logging priority

• tsReceiveTimeout :: Int

  the timeout in microseconds used when receiving messages

• tsTimeSyncTimeout :: Int

  the timeout in microseconds used for the time synchronization sessions

• tsTimeSyncDelay :: Int

  the delay in microseconds between the time synchronization sessions

• tsProcessMonitoringEnabled :: Bool

  Whether the process monitoring is enabled

• tsProcessMonitoringDelay :: Int

  The delay in microseconds which must be applied for monitoring every remote process.

• tsProcessReconnectingEnabled :: Bool

  Whether the automatic reconnecting to processes is enabled when enabled monitoring

• tsProcessReconnectingDelay :: Int

  the delay in microseconds before reconnecting

Instances

Eq TimeServerParams

Methods

(==) :: TimeServerParams -> TimeServerParams -> Bool

(/=) :: TimeServerParams -> TimeServerParams -> Bool

Ord TimeServerParams

Methods

compare :: TimeServerParams -> TimeServerParams -> Ordering

(<) :: TimeServerParams -> TimeServerParams -> Bool

(<=) :: TimeServerParams -> TimeServerParams -> Bool

(>) :: TimeServerParams -> TimeServerParams -> Bool

(>=) :: TimeServerParams -> TimeServerParams -> Bool

max :: TimeServerParams -> TimeServerParams -> TimeServerParams

min :: TimeServerParams -> TimeServerParams -> TimeServerParams

Show TimeServerParams

Methods

showsPrec :: Int -> TimeServerParams -> ShowS

show :: TimeServerParams -> String

showList :: [TimeServerParams] -> ShowS

Generic TimeServerParams

Associated Types

type Rep TimeServerParams :: * -> *

Methods

from :: TimeServerParams -> Rep TimeServerParams x

to :: Rep TimeServerParams x -> TimeServerParams

Binary TimeServerParams

Methods

put :: TimeServerParams -> Put

get :: Get TimeServerParams

putList :: [TimeServerParams] -> Put

type Rep TimeServerParams

type Rep TimeServerParams = D1 (MetaData "TimeServerParams" "Simulation.Aivika.Distributed.Optimistic.Internal.TimeServer" "aivika-distributed-0.5-6fHLga6dsBxI6C3Kj6ud4C" False) (C1 (MetaCons "TimeServerParams" PrefixI True) ((:*:) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "tsLoggingPriority") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Priority)) (S1 (MetaSel (Just Symbol "tsReceiveTimeout") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int))) ((:*:) (S1 (MetaSel (Just Symbol "tsTimeSyncTimeout") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int)) (S1 (MetaSel (Just Symbol "tsTimeSyncDelay") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int)))) ((:*:) ((:*:) (S1 (MetaSel (Just Symbol "tsProcessMonitoringEnabled") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Bool)) (S1 (MetaSel (Just Symbol "tsProcessMonitoringDelay") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int))) ((:*:) (S1 (MetaSel (Just Symbol "tsProcessReconnectingEnabled") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Bool)) (S1 (MetaSel (Just Symbol "tsProcessReconnectingDelay") NoSourceUnpackedness NoSourceStrictness DecidedLazy) (Rec0 Int))))))

defaultTimeServerParams :: TimeServerParams

The default time server parameters.

timeServer :: Int -> TimeServerParams -> Process ()

Start the time server by the specified initial quorum and parameters. The quorum defines the number of local processes that must be registered in the time server before the global time synchronization is started.

curryTimeServer :: (Int, TimeServerParams) -> Process ()

A curried version of timeServer for starting the time server on remote node.