From 7d4e0995661810b75799bf649e364f5da6698a07 Mon Sep 17 00:00:00 2001 From: Armon Dadgar Date: Wed, 12 Mar 2014 12:46:14 -0700 Subject: [PATCH] consul: Ignore new Serf events --- consul/client.go | 3 +++ consul/serf.go | 6 ++++++ 2 files changed, 9 insertions(+) diff --git a/consul/client.go b/consul/client.go index b0ca744882..74dbc3fba7 100644 --- a/consul/client.go +++ b/consul/client.go @@ -190,6 +190,9 @@ func (c *Client) lanEventHandler() { c.nodeFail(e.(serf.MemberEvent)) case serf.EventUser: c.localEvent(e.(serf.UserEvent)) + case serf.EventMemberUpdate: // Ignore + case serf.EventMemberReap: // Ignore + case serf.EventQuery: // Ignore default: c.logger.Printf("[WARN] consul: unhandled LAN Serf Event: %#v", e) } diff --git a/consul/serf.go b/consul/serf.go index 4e03661dbe..31a19444db 100644 --- a/consul/serf.go +++ b/consul/serf.go @@ -18,8 +18,11 @@ func (s *Server) lanEventHandler() { fallthrough case serf.EventMemberFailed: s.localMemberEvent(e.(serf.MemberEvent)) + case serf.EventMemberUpdate: // Ignore + case serf.EventMemberReap: // Ignore case serf.EventUser: s.localEvent(e.(serf.UserEvent)) + case serf.EventQuery: // Ignore default: s.logger.Printf("[WARN] consul: unhandled LAN Serf Event: %#v", e) } @@ -42,7 +45,10 @@ func (s *Server) wanEventHandler() { fallthrough case serf.EventMemberFailed: s.remoteFailed(e.(serf.MemberEvent)) + case serf.EventMemberUpdate: // Ignore + case serf.EventMemberReap: // Ignore case serf.EventUser: + case serf.EventQuery: // Ignore default: s.logger.Printf("[WARN] consul: unhandled WAN Serf Event: %#v", e) }