packages feed

aivika-distributed 0.7.4.2 → 0.8

raw patch · 6 files changed

+17/−17 lines, 6 filesdep ~aivikadep ~aivika-transformersPVP ok

version bump matches the API change (PVP)

Dependency ranges changed: aivika, aivika-transformers

API changes (from Hackage documentation)

- Simulation.Aivika.Distributed.Optimistic.DIO: [dioOutputMessageQueueSizeThreshold] :: DIOParams -> Int
- Simulation.Aivika.Distributed.Optimistic.DIO: DIOParams :: Priority -> String -> Int -> Int -> Int -> Int -> Bool -> Bool -> Bool -> Int -> Bool -> Int -> Int -> Int -> Int -> Int -> DIOStrategy -> DIOParams
+ Simulation.Aivika.Distributed.Optimistic.DIO: DIOParams :: Priority -> String -> Int -> Int -> Int -> Bool -> Bool -> Bool -> Int -> Bool -> Int -> Int -> Int -> Int -> Int -> DIOStrategy -> DIOParams

Files

CHANGELOG.md view
@@ -1,4 +1,9 @@ +Version 0.8+-----++* No more restriction on the number of output messages, which would lead to throttling.+ Version 0.7.4.2 -----
Simulation/Aivika/Distributed/Optimistic/Internal/DIO.hs view
@@ -74,8 +74,6 @@               -- ^ The name of the logical process.               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,@@ -194,7 +192,6 @@   DIOParams { dioLoggingPriority = WARNING,               dioName = "LP",               dioUndoableLogSizeThreshold = 1000000,-              dioOutputMessageQueueSizeThreshold = 10000,               dioTransientMessageQueueSizeThreshold = 10000,               dioSyncTimeout = 60000000,               dioAllowPrematureIO = False,@@ -312,7 +309,7 @@ handleException :: DIOParams -> SomeException -> DP.Process () handleException ps e =   do ----     logProcess ps ERROR $ "Exception occured: " ++ show e+     logProcess ps ERROR $ "Exception occurred: " ++ show e      ---      C.throwM e
Simulation/Aivika/Distributed/Optimistic/Internal/Event.hs view
@@ -282,13 +282,11 @@   Event $ \p ->   do let q = runEventQueue $ pointRun p      n1 <- liftIOUnsafe $ logSize (queueLog q)-     n2 <- liftIOUnsafe $ outputMessageQueueSize (queueOutputMessages q)-     n3 <- liftIOUnsafe $ transientMessageQueueSize (queueTransientMessages q)+     n2 <- liftIOUnsafe $ transientMessageQueueSize (queueTransientMessages q)      ps <- dioParams      let th1 = dioUndoableLogSizeThreshold ps-         th2 = dioOutputMessageQueueSizeThreshold ps-         th3 = dioTransientMessageQueueSizeThreshold ps-     if (n1 >= th1) || (n2 >= th2) || (n3 >= th3)+         th2 = dioTransientMessageQueueSizeThreshold ps+     if (n1 >= th1) || (n2 >= th2)        then do logDIO NOTICE $                  "t = " ++ (show $ pointTime p) ++                  ": detected the event overflow"
Simulation/Aivika/Distributed/Optimistic/Internal/TimeServer.hs view
@@ -482,7 +482,7 @@ handleTimeServerException :: TimeServer -> SomeException -> DP.Process () handleTimeServerException server e =   do ----     logTimeServer server ERROR $ "Exception occured: " ++ show e+     logTimeServer server ERROR $ "Exception occurred: " ++ show e      ---      C.throwM e
aivika-distributed.cabal view
@@ -1,5 +1,5 @@ name:            aivika-distributed-version:         0.7.4.2+version:         0.8 synopsis:        Parallel distributed discrete event simulation module for the Aivika library description:     This package extends the aivika-transformers [1] package and allows running parallel distributed simulations.@@ -121,8 +121,8 @@                      containers >= 0.4.0.0,                      exceptions >= 0.8.0.2,                      distributed-process >= 0.6.1,-                     aivika >= 5.2,-                     aivika-transformers >= 5.2+                     aivika >= 5.3.1,+                     aivika-transformers >= 5.3.1      extensions:      MultiParamTypeClasses,                      FlexibleInstances,
tests/cluster.conf view
@@ -1,13 +1,13 @@ # The Simulation Cluster Configuration  # 0: the master simulation node, which must be run last-localhost:8088+127.0.0.1:8088  # 1: the time server-localhost:8080+127.0.0.1:8080  # 2: the first slave simulation node-localhost:8081+127.0.0.1:8081  # 3: the second slave simulation node-localhost:8082+127.0.0.1:8082