|
|
@ -41,9 +41,7 @@ func (s *Server) lanEventHandler() {
|
|
|
|
s.nodeJoin(e.(serf.MemberEvent), false)
|
|
|
|
s.nodeJoin(e.(serf.MemberEvent), false)
|
|
|
|
s.localMemberEvent(e.(serf.MemberEvent))
|
|
|
|
s.localMemberEvent(e.(serf.MemberEvent))
|
|
|
|
|
|
|
|
|
|
|
|
case serf.EventMemberLeave:
|
|
|
|
case serf.EventMemberLeave, serf.EventMemberFailed:
|
|
|
|
fallthrough
|
|
|
|
|
|
|
|
case serf.EventMemberFailed:
|
|
|
|
|
|
|
|
s.nodeFailed(e.(serf.MemberEvent), false)
|
|
|
|
s.nodeFailed(e.(serf.MemberEvent), false)
|
|
|
|
s.localMemberEvent(e.(serf.MemberEvent))
|
|
|
|
s.localMemberEvent(e.(serf.MemberEvent))
|
|
|
|
|
|
|
|
|
|
|
@ -71,9 +69,7 @@ func (s *Server) wanEventHandler() {
|
|
|
|
switch e.EventType() {
|
|
|
|
switch e.EventType() {
|
|
|
|
case serf.EventMemberJoin:
|
|
|
|
case serf.EventMemberJoin:
|
|
|
|
s.nodeJoin(e.(serf.MemberEvent), true)
|
|
|
|
s.nodeJoin(e.(serf.MemberEvent), true)
|
|
|
|
case serf.EventMemberLeave:
|
|
|
|
case serf.EventMemberLeave, serf.EventMemberFailed:
|
|
|
|
fallthrough
|
|
|
|
|
|
|
|
case serf.EventMemberFailed:
|
|
|
|
|
|
|
|
s.nodeFailed(e.(serf.MemberEvent), true)
|
|
|
|
s.nodeFailed(e.(serf.MemberEvent), true)
|
|
|
|
case serf.EventMemberUpdate: // Ignore
|
|
|
|
case serf.EventMemberUpdate: // Ignore
|
|
|
|
case serf.EventMemberReap: // Ignore
|
|
|
|
case serf.EventMemberReap: // Ignore
|
|
|
|