raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10
7248 commits 1 branch 31 tags 268 MiB
Commit graph

83 commits

Author SHA1 Message Date
Viktor Klang
c7d58c600b Adding initial support for Props 2011-08-26 17:25:18 +02:00
Jonas Bonér
f9e82eaee5 Added method to ClusterNode to check if an actor is checked out on a specific (other) node, also added 'start' and 'boot' methods. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 21:48:47 +02:00
Jonas Bonér
472b505077 Adding ClusterActorRef to ActorRegistry. Renamed Address to RemoteAddress. Added isShutdown flag to ClusterNode. Fixes #1132. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-24 12:45:32 +02:00
Jonas Bonér
950ad21117 Fixed problem with node and test infrastructure initialization order causing multi-jvm test to fail randomly. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-19 15:10:13 +02:00
Jonas Bonér
ea92c552d3 Fixed broken tests: RoundRobin2Replicas and RoundRobin3Replicas 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-18 17:16:25 +02:00
Jonas Bonér
ea95588a50 Fixed broken tests: NewLeaderChangeListenerMultiJvmSpec and ReplicationTransactionLogWriteThroughNoSnapshotMultiJvmSpec. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-18 15:53:08 +02:00
Jonas Bonér
dfc1a68aac Fixed race condition in initial and dynamic management of node connections in Cluster 
* Using CAS optimistic concurrency using versioning to fix initial and dynamic management of node connections in Cluster
* Fixed broken bootstrap of ClusterNode - reorganized booting and removed lazy from some fields
* Removed 'start' and 'isRunning' from Cluster
* Removed 'isStarted' Switch in Cluster which was sprinkled all-over cluster impl
* Added more and better logging
* Moved local Cluster ops from Cluster to LocalCluster
* Rewrote RoundRobinFailoverMultiJvmSpec to be correct
* RoundRobinFailoverMultiJvmSpec now passes
* Minor reformatting and edits

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-18 11:35:14 +02:00
Jonas Bonér
48ee9deb3a Split up the TransactionLogSpec into two tests: AsynchronousTransactionLogSpec and SynchronousTransactionLogSpec, also did various minor edits and comments. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-08-15 10:42:09 +02:00
Peter Veentjer
c8e938a44c ticket #992: misc fixes for transaction log, processed review comments 2011-08-08 20:57:01 +03:00
Peter Veentjer
bd049718be ticket #992: misc fixes for transaction log, processed review comments 2011-08-08 20:40:18 +03:00
Peter Veentjer
32df67cb60 ticket #992 after merge 2011-08-06 23:10:30 +03:00
Peter Veentjer
aaec3aef77 ticket #992 2011-08-06 23:08:01 +03:00
Peter Veentjer
320ee3cb4c ticket #934 2011-08-02 09:52:39 +03:00
Peter Veentjer
4b4f38c973 ticket #889 after merge 2011-07-28 16:56:35 +03:00
Viktor Klang
0351858c9e Lots of code cleanup and bugfixes of Deployment, still not AOT/JIT separation 2011-07-26 17:12:00 +02:00
Peter Vlugter
340ed11de5 Reformat with scalariform 2011-07-26 18:33:59 +12:00
Peter Veentjer
96cc0a00b4 ticket #958 2011-07-26 08:16:26 +03:00
Roland
42769599aa Merge branch 'ticket955' 
Conflicts:
	akka-actor-tests/src/test/scala/akka/actor/supervisor/Ticket669Spec.scala
	akka-actor-tests/src/test/scala/akka/routing/RoutingSpec.scala
	akka-camel/src/test/scala/akka/camel/ConsumerScalaTest.scala
 2011-07-19 16:56:44 -04:00
Viktor Klang
3bc7db0dde Closing ticket #1030, removing lots of warnings 2011-07-19 19:28:46 +02:00
Viktor Klang
bb558c03f4 Switching to Serializer.Identifier for storing within ZK 2011-07-19 17:17:04 +02:00
Peter Veentjer
4017a86b4c 1025: some cleanup 2011-07-15 10:59:29 +03:00
Peter Veentjer
966f7d9297 ticket 1025 2011-07-15 09:55:45 +03:00
Viktor Klang
9d71be7778 Updating copyright section to Typesafe Inc. etc 2011-07-14 16:03:08 +02:00
Peter Veentjer
8472df3a47 Fixes some MBean compliance issues 2011-07-13 19:22:49 +03:00
Peter Veentjer
d14f2f6e50 Issue 990: MBean for Cluster improvement 2011-07-13 11:27:16 +03:00
Jonas Bonér
34c838d0f4 1. Completed replication over BookKeeper based transaction log with configurable actor snapshotting every X message. 
2. Completed replay of of transaction log on all replicated actors on migration after node crash.
3. Added end to end tests for write behind and write through replication and replay on fail-over.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-07-08 19:35:27 +02:00
Jonas Bonér
0b1ee758f5 1. Implemented replication through transaction log, e.g. logging all messages and replaying them after actor migration 
2. Added first replication test (out of many)
3. Improved ScalaDoc
4. Enhanced the remote protocol with replication info

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-07-08 08:28:13 +02:00
Jonas Bonér
9af5df4b02 Minor refactoring and restructuring 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-07-05 15:58:19 +02:00
Jonas Bonér
4a179d14bb 1. Makes sure to check if 'akka.enabled-modules=["cluster"]' is set before checking if the akka-cluster.jar is on the classpath, allowing non-cluster deployment even with the JAR on the classpath 
2. Fixed bug with duplicate entries in replica set for an actor address
3. Turned on clustering for all Multi JVM tests

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-07-05 14:46:05 +02:00
Jonas Bonér
f2dd6bddb3 1. Added configuration option for 'preferred-nodes' for a clustered actor. The replica set is now tried to be satisfied by the nodes in the list of preferred nodes, if that is not possible, it is randomly selected among the rest. 
2. Added test for it.
3. Fixed wrong Java fault-tolerance docs
4. Fixed race condition in maintenance of connections to new nodes

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-07-05 13:28:02 +02:00
Roland
5de2ca7aa5 remove Actor.preRestart(cause: Throwable) 
- adapt all internal uses (all tests green)
- start migration guide for 2.0 with this change
 2011-07-03 22:19:34 +02:00
Jonas Bonér
e28db64def Disabled the migration test until race condition solved 2011-07-02 22:03:13 +02:00
Jonas Bonér
828f0355e1 1. Changed the internal structure of cluster meta-data and how it is stored in ZooKeeper. Affected most of the cluster internals which have been rewritten to a large extent. Lots of code removed. 
2. Fixed many issues and both known and hidden bugs in the migration code as well as other parts of the cluster functionality.
3. Made the node holding the ClusterActorRef being potentially part of the replica set for the actor it is representing.
4. Changed and cleaned up ClusterNode API, especially the ClusterNode.store methods.
5. Commented out ClusterNode.remove methods until we have a full story how to do removal
6. Renamed Peter's PeterExample test to a more descriptive name
7. Added round robin router test with 3 replicas
8. Rewrote migration tests to actually test correctly
9. Rewrote existing round robin router tests, now more solid
10. Misc improved logging and documentation and ScalaDoc

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-07-02 18:18:48 +02:00
Peter Veentjer
9ee978f0f6 - moving the storage related file to the storage package 
- added some return types to the Cluster.scala
 2011-06-27 22:27:40 +03:00
Jonas Bonér
82391e728c Fixed broken support for automatic migration of actors residing on crashed node. 
Also hardened the test for automatic migration of actors.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-27 18:57:48 +02:00
Jonas Bonér
fefb902350 Added 'private[cluster]' to all methods in ClusterNode API that deals with UUID. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-27 11:53:24 +02:00
Jonas Bonér
5a04095c6b Added multi-jvm test for ClusterDeployer 2011-06-27 08:51:54 +02:00
Jonas Bonér
7a5c95e44d Added tests for automatic actor migration when node is shut down. 
Updated to modified version of ZkClient (0.3, forked and fixed to allow interrupting connection retry).

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-26 15:04:11 +02:00
Jonas Bonér
15addf2b87 Reorganized tests into matching subfolders. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2011-06-26 13:41:41 +02:00
Jonas Bonér
a0abd5ef57 Fixed problems with actor migration in cluster and added tests for explicit actor migration through API 2011-06-26 09:49:03 +02:00
Jonas Bonér
833238cd44 Added tests for storing, retrieving and removing custom configuration data in cluster storage. 
Signed-off-by: Jonas Bonér <jonasremove@jonasboner.com>
 2011-06-22 12:03:58 +02:00
Jonas Bonér
df8c4dac89 Added methods for Cluster.remove and Cluster.release that accepts ActorRef 2011-06-22 11:31:01 +02:00
Jonas Bonér
5d4f8b4bcb Added test scenarios to cluster registry test suite. 
Signed-off-by: Jonas Bonér <jonasremove@jonasboner.com>
 2011-06-22 11:04:32 +02:00
Jonas Bonér
4d31751793 Fixed clustered management of actor serializer. 
Various renames and refactorings.
Changed all internal usages of 'actorOf' to 'localActorOf'.

Signed-off-by: Jonas Bonér <jonasremove@jonasboner.com>
 2011-06-22 09:59:00 +02:00
Jonas Bonér
b93755080d Added test for Cluster ChangeListener: NodeConnected, more to come. Also fixed bug in Cluster 2011-06-17 16:07:41 +02:00
Jonas Bonér
241831c5ee Added some more localActorOf methods and use them internally in cluster 2011-06-17 12:07:45 +02:00
Jonas Bonér
1997d971a0 Added 'localActorOf' method to get an actor that by-passes the deployment. Made use of it in EventHandler 2011-06-17 11:56:08 +02:00
Jonas Bonér
549f33a3ff Improved error handling in Cluster.scala 2011-06-17 10:25:02 +02:00
Jonas Bonér
bf0515b8e5 Fixed remaining issues in pluggable serializers (cluster impl) 2011-06-14 19:35:18 +02:00
Jonas Bonér
04bf416ead Merge branch 'master' into pluggable-serializer 2011-06-14 14:41:24 +02:00