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

17 commits

Author SHA1 Message Date
Patrik Nordwall
b27bae6554 Use dedicated cluster scheduler only when default scheduler resolution isn't good enough, see #2214 
* Config properties for scheduler
* Commented shutdown considerations
 2012-06-12 13:34:59 +02:00
Patrik Nordwall
a7d2be10eb Merge branch 'master' into wip-2214-heartbeats-patriknw 
Conflicts:
	akka-cluster/src/main/scala/akka/cluster/AccrualFailureDetector.scala
	akka-cluster/src/main/scala/akka/cluster/Cluster.scala
 2012-06-11 22:27:08 +02:00
Patrik Nordwall
e2551494c4 Use Use separate heartbeats for FailureDetector, see #2214 
* Send Heartbeat message to all members at regular interval
* Removed the need to gossip to myself
 2012-06-11 15:00:44 +02:00
Jonas Bonér
a4499b06bb Abstracted the FailureDetector into a interface trait and added controllable failure detector mock. 
- Abstracted a FailureDetector trait.
- Added a FailureDetectorPuppet mock that can be user controllable
- Added option to define a custom failure detector
- Misc minor fixes

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-06-10 16:52:33 +02:00
Jonas Bonér
391fed6594 Misc changes, fixes and improvements after review. 
- Renamed all 'frequency' to 'interval'
- Split up NodeJoinAndUpSpec and into NodeJoinSpec and NodeUpSpec.
- Split up MembershipChangeListenerJoinAndUpSpec and into MembershipChangeListenerJoinSpec and MembershipChangeListenerUpSpec.
- Added utility method 'startClusterNode()'
- Fixed race in register listener and telling node to leave
- Removed 'after' blocks
- Cleaned up unused code
- Improved comments

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-06-04 23:21:28 +02:00
Jonas Bonér
5adaa1a271 Added the concept of PortPrefix in the clustering tests to avoid clashes in binding of server port when running the tests in parallel. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-05-04 15:03:23 +02:00
Jonas Bonér
f7ca01a26b Merge branch 'master' of github.com:akka/akka 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-03-22 17:10:43 +01:00
Jonas Bonér
1ae2c68d2f Added config options for run frequency of the different periodic node tasks. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-03-15 23:00:20 +01:00
Jonas Bonér
50d11593c9 Added 'ClusterSpec' abstract class with 'awaitConvergence' method to get rid of most 'Thread.sleep()' calls. Updated all cluster specs. Now works more reliable. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-03-15 21:25:55 +01:00
Jonas Bonér
81b68e2fc0 Added DOWNING (user downing and auto-downing) and LEADER actions. 
* Added possibility for user to 'down' a node
* Added possibility for the leader to 'auto-down' a node.
* Added leader role actions
  - Moving nodes from JOINING -> UP
  - Moving nodes from EXITING -> REMOVED
  - AUTO-DOWNING
* Added tests for user and leader downing
* Added 'auto-down' option to turn auto-downing on and off
* Fixed bug in semantic Member Ordering
* Removed FSM stuff from ClusterCommandDaemon (including the test) since the node status should only be in the converged gossip state

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-03-09 12:57:17 +01:00
Jonas Bonér
e4b1d8609f Added support for 'deputy-nodes'. 
* Added 'nr-of-deputy-nodes' config option
* Added fetching of current deputy node addresses
* Minor refactorings

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-02-28 11:15:53 +01:00
Jonas Bonér
2c67a6d50d Split up ClusterDaemon into ClusterGossipDaemon (routed with configurable N instances) and ClusterCommandDaemon (shortly to be an FSM). Removed ConnectionManager crap. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-02-28 11:15:53 +01:00
Jonas Bonér
0413b44c98 Completed singleton and N-node cluster boot up and joining phase. 
* Simplified node join phase.
* Added tests for cluster node startup and joining, both for singleton cluster and 2-node cluster.
* Fixed bug in cluster node address and cluster daemon lookup.
* Changed some APIs.
* Renamed 'contact-point' to 'node-to-join'.
* Minor refactorings.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-02-28 11:14:25 +01:00
Jonas Bonér
3b5c5e5f0f Removed cluster seed nodes, added 'join.contact-point', changed joining phase, added singleton cluster mode plus misc other changes. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-02-28 11:14:25 +01:00
Jonas Bonér
75c1b5717c Completed singleton and N-node cluster boot up and joining phase. 
* Simplified node join phase.
* Added tests for cluster node startup and joining, both for singleton cluster and 2-node cluster.
* Fixed bug in cluster node address and cluster daemon lookup.
* Changed some APIs.
* Renamed 'contact-point' to 'node-to-join'.
* Minor refactorings.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-02-28 11:14:24 +01:00
Jonas Bonér
bb0e5536be Removed cluster seed nodes, added 'join.contact-point', changed joining phase, added singleton cluster mode plus misc other changes. 
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-02-28 11:14:24 +01:00
Jonas Bonér
0b59640820 Fixed bunch of stuff based on feedback on pull request. 
Moved all cluster config to akka-cluster (and added test).

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
 2012-01-31 15:01:06 +01:00