Simulation.Aivika.Distributed.Optimistic.Guard

Tested with: GHC 8.0.2

This module defines guards that allow correct finishing the distributed simulation.

Guards With Message Passing

runMasterGuard

Arguments

:: (Serializable a, Serializable b)

=> Int

the number of slaves to wait

-> (Map ProcessId a -> Event DIO (Map ProcessId b))

how to transform the messages from the slave processes in the stop time

-> Process DIO (Map ProcessId b)

Run the master guard by the specified number of slaves and transform function.

runSlaveGuard

Arguments

:: (Serializable a, Serializable b)

=> ProcessId

the master process identifier

-> Event DIO a

in the stop time generate a message to pass to the master process

-> Process DIO (Maybe b)

the message returned by the master process

Run the slave guard by the specified master process identifier and message generator.

Guards Without Message Passing

runMasterGuard_ :: Int -> Process DIO ()

Run the master guard by the specified number of slaves when there is no message passing.

runSlaveGuard_ :: ProcessId -> Process DIO ()

Run the slave guard by the specified master process identifier when there is no message passing.