Ignore heartbeats from self in gossip strategy. (bitwalker#23)

mkorszun · Aug 4, 2017 · d7a7547 · d7a7547
1 parent df43178
commit d7a7547
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/strategy/gossip.ex b/lib/strategy/gossip.ex
@@ -107,7 +107,10 @@ defmodule Cluster.Strategy.Gossip do
   # is different, and thus a node we can ignore
   @spec handle_heartbeat(State.t, binary) :: :ok
   defp handle_heartbeat(%State{connect: connect, list_nodes: list_nodes} = state, <<"heartbeat::", rest::binary>>) do
+    self = node()
     case :erlang.binary_to_term(rest) do
+      %{node: ^self} ->
+        :ok
       %{node: n} when is_atom(n) ->
         debug state.topology, "received heartbeat from #{n}"
         Cluster.Strategy.connect_nodes(state.topology, connect, list_nodes, [n])