From de846d4555b8fb2a0fa9f242e0a778c4f75d595e Mon Sep 17 00:00:00 2001 From: Jonas Boner Date: Sun, 21 Jun 2009 14:08:43 +0200 Subject: [PATCH] completed new actor impl with link/unlink trapExit etc. all tests pass + reorganized package structure --- akka.ipr | 874 ++++++++-------- akka.iws | 983 ++++++++++-------- fun-test-java/akka-funtest-java.iml | 12 +- .../ActiveObjectGuiceConfiguratorTest.java | 4 +- .../akka/api/InMemStateful.java | 2 +- .../akka/api/PersistentClasher.java | 4 +- .../akka/api/PersistentStateTest.java | 4 +- .../akka/api/PersistentStateful.java | 2 +- kernel/akka-kernel.iml | 10 +- kernel/src/main/scala/Actor.scala | 201 ---- kernel/src/main/scala/Boot.scala | 3 +- kernel/src/main/scala/GenericServer.scala | 292 ------ kernel/src/main/scala/Kernel.scala | 2 + kernel/src/main/scala/Supervisor.scala | 334 ------ .../main/scala/{ => actor}/ActiveObject.scala | 183 ++-- kernel/src/main/scala/actor/Actor.scala | 267 +++++ kernel/src/main/scala/actor/Supervisor.scala | 128 +++ .../scala/camel/ActiveObjectConsumer.scala | 2 +- .../scala/camel/ActiveObjectEndpoint.scala | 4 +- .../scala/camel/ActiveObjectProducer.scala | 5 +- .../camel/SupervisorAwareCamelContext.scala | 3 +- .../config/ActiveObjectConfigurator.scala | 3 +- .../ActiveObjectGuiceConfigurator.scala | 38 +- ...ActiveObjectGuiceConfiguratorForJava.scala | 1 - kernel/src/main/scala/config/Config.scala | 9 +- .../scala/{ => config}/Configuration.scala | 2 +- .../ActiveObjectComponentProvider.scala | 5 +- kernel/src/main/scala/nio/ProxyServer.scala | 0 kernel/src/main/scala/reactor/Future.scala | 18 +- .../{ => reactor}/ManagedActorScheduler.scala | 1 + ...her.scala => ProxyMessageDispatcher.scala} | 10 +- kernel/src/main/scala/reactor/Reactor.scala | 3 +- .../scala/reactor/ThreadBasedDispatcher.scala | 49 + .../scala/{ => state}/CassandraNode.scala | 3 +- .../scala/{ => state}/DataFlowVariable.scala | 2 +- kernel/src/main/scala/{ => state}/State.scala | 2 +- .../main/scala/{ => stm}/Transaction.scala | 53 +- .../src/main/scala/{ => util}/HashCode.scala | 2 +- .../src/main/scala/{ => util}/Helpers.scala | 2 +- .../src/main/scala/{ => util}/Logging.scala | 2 +- .../scala/{ => util}/ResultOrFailure.scala | 4 +- .../main/scala/{ => util}/Serializer.scala | 2 +- kernel/src/test/scala/ActorTest.scala | 2 +- kernel/src/test/scala/AllSuite.scala | 7 +- .../scala/GenericServerContainerSuite.scala | 178 ---- kernel/src/test/scala/GenericServerSpec.scala | 40 - kernel/src/test/scala/SupervisorSpec.scala | 209 ++-- .../src/test/scala/SupervisorStateSpec.scala | 98 -- kernel/web.xml | 4 +- 49 files changed, 1809 insertions(+), 2259 deletions(-) mode change 100755 => 100644 fun-test-java/src/test/java/se/scalablesolutions/akka/api/ActiveObjectGuiceConfiguratorTest.java mode change 100755 => 100644 fun-test-java/src/test/java/se/scalablesolutions/akka/api/PersistentStateTest.java delete mode 100644 kernel/src/main/scala/Actor.scala delete mode 100644 kernel/src/main/scala/GenericServer.scala mode change 100755 => 100644 kernel/src/main/scala/Kernel.scala delete mode 100644 kernel/src/main/scala/Supervisor.scala rename kernel/src/main/scala/{ => actor}/ActiveObject.scala (75%) mode change 100755 => 100644 create mode 100644 kernel/src/main/scala/actor/Actor.scala create mode 100644 kernel/src/main/scala/actor/Supervisor.scala rename kernel/src/main/scala/{ => config}/Configuration.scala (97%) create mode 100644 kernel/src/main/scala/nio/ProxyServer.scala rename kernel/src/main/scala/{ => reactor}/ManagedActorScheduler.scala (98%) rename kernel/src/main/scala/reactor/{ProxyDispatcher.scala => ProxyMessageDispatcher.scala} (90%) create mode 100644 kernel/src/main/scala/reactor/ThreadBasedDispatcher.scala rename kernel/src/main/scala/{ => state}/CassandraNode.scala (98%) mode change 100755 => 100644 rename kernel/src/main/scala/{ => state}/DataFlowVariable.scala (99%) rename kernel/src/main/scala/{ => state}/State.scala (99%) rename kernel/src/main/scala/{ => stm}/Transaction.scala (73%) rename kernel/src/main/scala/{ => util}/HashCode.scala (97%) rename kernel/src/main/scala/{ => util}/Helpers.scala (98%) rename kernel/src/main/scala/{ => util}/Logging.scala (97%) rename kernel/src/main/scala/{ => util}/ResultOrFailure.scala (91%) rename kernel/src/main/scala/{ => util}/Serializer.scala (95%) delete mode 100755 kernel/src/test/scala/GenericServerContainerSuite.scala delete mode 100755 kernel/src/test/scala/GenericServerSpec.scala mode change 100755 => 100644 kernel/src/test/scala/SupervisorSpec.scala delete mode 100755 kernel/src/test/scala/SupervisorStateSpec.scala diff --git a/akka.ipr b/akka.ipr index c324192289..0830068922 100644 --- a/akka.ipr +++ b/akka.ipr @@ -30,6 +30,15 @@ -