From ff969047cc25ef40c6423c474b313a18b81f0858 Mon Sep 17 00:00:00 2001 From: Jonas Boner Date: Mon, 6 Jul 2009 23:45:15 +0200 Subject: [PATCH] fixed last stm issues and failing tests + added new thread-based dispatcher (plus test) --- akka.ipr | 34 +- akka.iws | 1744 ++++------------- .../scalablesolutions/akka/api/AllTest.java | 24 + .../scalablesolutions/akka/api/AllTests.java | 38 - .../akka/api/PersistenceManager.java | 13 + .../akka/api/PersistentNestedStateTest.java | 7 +- .../akka/api/PersistentStateTest.java | 6 +- .../akka/api/RemoteInMemoryStateTest.java | 2 - .../akka/api/RemotePersistentStateTest.java | 7 +- .../scalablesolutions/akka/api/RestTest.java | 11 +- kernel/pom.xml | 10 - kernel/src/main/resources/aop.xml | 9 + .../src/main/scala/actor/ActiveObject.scala | 10 +- kernel/src/main/scala/actor/Actor.scala | 158 +- kernel/src/main/scala/actor/Supervisor.scala | 6 +- kernel/src/main/scala/collection/Vector.scala | 10 +- .../ActiveObjectGuiceConfigurator.scala | 10 +- kernel/src/main/scala/config/Config.scala | 15 +- .../src/main/scala/config/Configuration.scala | 2 +- kernel/src/main/scala/nio/RemoteServer.scala | 8 +- .../src/main/scala/reactor/Dispatchers.scala | 44 + .../EventBasedSingleThreadDispatcher.scala | 16 +- .../EventBasedThreadPoolDispatcher.scala | 20 +- .../scala/reactor/MessageDispatcherBase.scala | 35 +- kernel/src/main/scala/reactor/Reactor.scala | 76 +- .../scala/reactor/ThreadBasedDispatcher.scala | 55 + .../main/scala/state/CassandraStorage.scala | 10 +- .../main/scala/state/DataFlowVariable.scala | 4 +- kernel/src/main/scala/stm/Transaction.scala | 24 +- .../scala/stm/TransactionManagement.scala | 40 +- kernel/src/test/scala/AllTest.scala | 26 + kernel/src/test/scala/AllTests.scala | 22 - ...ventBasedSingleThreadDispatcherTest.scala} | 24 +- .../EventBasedThreadPoolDispatcherTest.scala | 143 ++ kernel/src/test/scala/InMemoryActorSpec.scala | 3 +- .../src/test/scala/RemoteSupervisorSpec.scala | 22 +- kernel/src/test/scala/SupervisorSpec.scala | 22 +- .../scala/ThreadBasedDispatcherTest.scala | 123 +- .../test/scala/TransactionClasherSpec.scala | 56 +- .../akka/annotation/configuration.java | 11 + 40 files changed, 1063 insertions(+), 1837 deletions(-) create mode 100644 fun-test-java/src/test/java/se/scalablesolutions/akka/api/AllTest.java delete mode 100644 fun-test-java/src/test/java/se/scalablesolutions/akka/api/AllTests.java create mode 100644 fun-test-java/src/test/java/se/scalablesolutions/akka/api/PersistenceManager.java create mode 100644 kernel/src/main/resources/aop.xml mode change 100755 => 100644 kernel/src/main/scala/collection/Vector.scala mode change 100755 => 100644 kernel/src/main/scala/config/Configuration.scala create mode 100644 kernel/src/main/scala/reactor/Dispatchers.scala create mode 100644 kernel/src/main/scala/reactor/ThreadBasedDispatcher.scala create mode 100644 kernel/src/test/scala/AllTest.scala delete mode 100644 kernel/src/test/scala/AllTests.scala rename kernel/src/test/scala/{EventBasedDispatcherTest.scala => EventBasedSingleThreadDispatcherTest.scala} (81%) create mode 100644 kernel/src/test/scala/EventBasedThreadPoolDispatcherTest.scala create mode 100644 util-java/src/main/java/se/scalablesolutions/akka/annotation/configuration.java diff --git a/akka.ipr b/akka.ipr index 10621d8129..46fa8b50b5 100644 --- a/akka.ipr +++ b/akka.ipr @@ -9,19 +9,19 @@ diff --git a/akka.iws b/akka.iws index 688a8ac498..6af29de35c 100644 --- a/akka.iws +++ b/akka.iws @@ -1,17 +1,51 @@ - + - + + + + + + + + + + + + + + + + - + + + + + + + + + + + + + + + + + + + + @@ -33,7 +67,7 @@ - + - - - - - - - - - - - - - - - - - - - - - - - +