Commit graph

18 commits

Author SHA1 Message Date
Jonas Bonér
0e6d272a8d Added support for checking for Cluster Convergence and completed support for MembershipChangeListener (including tests).
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-02-28 11:15:53 +01:00
Jonas Bonér
cfd04bba3d Fixed remaining issues with gossip based failure detection and removal of unreachable nodes.
* Completed gossip based failure detection.
* Completed removal of unreachable nodes according to failure detector.
* Added passing tests.
* Misc other fixes, more logging, more comments.

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-02-28 11:15:53 +01:00
Jonas Bonér
84f886def1 Merged with master 2012-02-28 11:14:26 +01:00
Jonas Bonér
07defa71a4 Fixed bug in failure detector which also fixes bug in cluster scrutinize service. Also added test case for the bug.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-02-28 11:14:26 +01:00
Jonas Bonér
709c86b48d Disabling out erroneous cluster 'scrutinize' service until fixed and proper tests are written.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-02-28 11:14:26 +01:00
Jonas Bonér
a2785bc89e Finalized initial cluster membership and merging of vector clocks and gossips in case of concurrent cluster updates. Plus misc other fixes.
* Finalized initial cluster membership.
* Added merging of vector clocks and gossips in case of concurrent cluster updates.
* Added toString methods to all cluster protocol classes
* Fixed bugs in incrementation of vector clocks
* Added updates of 'seen' table for cluster convergence
* Revamped to use new VectorClock impl
* Refactored Gossip.State

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-02-28 11:14:25 +01:00
Jonas Bonér
cb9ce7b663 Implemented 'receive(newGossip)' plus misc other changes and fixes.
* Implemented 'receive(newGossip)'
* Added GossipEnvelope
* Added MetaDataChangeListener
* Changed MembershipChangeListener API
* Changed most internal API to work with Address rather than Member
* Added builder style API to Gossip for changing it in an immutable way
* Moved 'self: Member' from Gossip to State

Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-02-28 11:14:25 +01:00
Jonas Bonér
ccba27a829 Refactored Gossip state and management. Introduced GossipOverview with convergence info, renamed some fields, added some new cluster commands.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-02-28 11:14:25 +01:00
Jonas Bonér
84f63db0ae Skips gossipping and cluster scrutinization if singleton cluster.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-02-28 11:14:25 +01:00
Jonas Bonér
379e9b9219 Switching node status to Up if singleton cluster. Added 'switchStatusTo' method. Updated the test. Profit.
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
Viktor Klang
73fce52235 Fixing returns to return in ScalaDoc 2012-02-06 16:59:09 +01:00
Viktor Klang
985acc821c Fixing Deadline, removing TimeoutException and fixing bugs in Gossiper etc 2012-02-01 14:29:56 +01:00
Jonas Bonér
7dbb5e9abb Added try-finally blocks for each shutdown step in the Gossipper.shutdown method.
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-01-31 15:07:15 +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
Jonas Bonér
0fa184560c Moved Gossiper, FailureDetector and VectorClock (with tests) to the akka-cluster module. Deleted all old unused cluster code (ZooKeeper-based stuff).
Signed-off-by: Jonas Bonér <jonas@jonasboner.com>
2012-01-31 13:34:06 +01:00
Renamed from akka-remote/src/main/scala/akka/remote/Gossiper.scala (Browse further)