-- | -- Module : Simulation.Aivika.Distributed.Optimistic.Internal.OutputMessageQueue -- Copyright : Copyright (c) 2015-2016, David Sorokin -- License : BSD3 -- Maintainer : David Sorokin -- Stability : experimental -- Tested with: GHC 7.10.3 -- -- This is an hs-boot file. -- module Simulation.Aivika.Distributed.Optimistic.Internal.OutputMessageQueue (OutputMessageQueue, newOutputMessageQueue, outputMessageQueueSize, sendMessage, rollbackOutputMessages, reduceOutputMessages) where import Simulation.Aivika.Trans.Simulation import Simulation.Aivika.Trans.Event import Simulation.Aivika.Trans.Signal import Simulation.Aivika.Distributed.Optimistic.Internal.Message import Simulation.Aivika.Distributed.Optimistic.Internal.DIO data OutputMessageQueue newOutputMessageQueue :: DIO OutputMessageQueue outputMessageQueueSize :: OutputMessageQueue -> IO Int sendMessage :: OutputMessageQueue -> Message -> DIO () rollbackOutputMessages :: OutputMessageQueue -> Double -> Bool -> DIO () reduceOutputMessages :: OutputMessageQueue -> Double -> IO ()