ympons / gossip-protocol-java Goto Github PK
View Code? Open in Web Editor NEWBasic implementation of a gossip protocol to reach agreement among members
Basic implementation of a gossip protocol to reach agreement among members
What steps will reproduce the problem?
1. Run a gossip group with 3 members, let their heartbeats count up over 20
or so, all successfully gossiping
2. Shut one down
3. Wait for all members in live group to decide the dead member is dead
4. Restart dead member
5. Dead member will try to seed but it will be ignored due to it's
heartbeat not being high enough (Client.java: line 329 rev 9509ef5052).
6. Dead member will then not get any membership lists from live group and
think they are dead too.
What is the expected output? What do you see instead?
Dead member when restarted should be able to re join the live gossip group.
Please provide any additional information below.
This can be fixed by having a kind of zombie state between dead and alive
where if you notice that the zombie heartbeat is increasing it must have
restarted and it's heartbeat set back to zero and be increasing from there:
private Map<Member, Long> zombieHeartbeats = new Hashtable<Member, Long>();
...
...
} else if(deadMembers.contains(remoteMember)){
Member deadMember = deadMembers.get(deadMembers.indexOf(remoteMember));
if(remoteMember.getHeartBeat() > deadMember.getHeartBeat()) {
deadMembers.remove(remoteMember);
healthyMembers.add(deadMember);
deadMember.setHeartBeat(remoteMember.getHeartBeat());
deadMember.resetTimeoutTimer();
} else if(zombieHeartbeats.containsKey(remoteMember) &&
remoteMember.getHeartBeat() > zombieHeartbeats.get(remoteMember)) {
deadMembers.remove(remoteMember);
healthyMembers.add(deadMember);
deadMember.setHeartBeat(remoteMember.getHeartBeat());
deadMember.resetTimeoutTimer();
zombieHeartbeats.remove(remoteMember);
} else {
zombieHeartbeats.put(remoteMember, remoteMember.getHeartBeat());
}
Hope that helps.
Original issue reported on code.google.com by [email protected]
on 8 Apr 2010 at 3:54
A declarative, efficient, and flexible JavaScript library for building user interfaces.
๐ Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
An Open Source Machine Learning Framework for Everyone
The Web framework for perfectionists with deadlines.
A PHP framework for web artisans
Bring data to life with SVG, Canvas and HTML. ๐๐๐
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
Some thing interesting about web. New door for the world.
A server is a program made to process requests and deliver data to clients.
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
Some thing interesting about visualization, use data art
Some thing interesting about game, make everyone happy.
We are working to build community through open source technology. NB: members must have two-factor auth.
Open source projects and samples from Microsoft.
Google โค๏ธ Open Source for everyone.
Alibaba Open Source for everyone
Data-Driven Documents codes.
China tencent open source team.