Merge pull request #697 from basho/bugfix/csm/662-backport

fix heartbeat bug by adding new pattern match and debug line Reviewed-by: jonmeredith
basho · Jun 10, 2015 · 8bbf486 · 8bbf486
2 parents 7f8d584 + 9af9f7a
commit 8bbf486
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/riak_repl2_rtsource_conn.erl b/src/riak_repl2_rtsource_conn.erl
@@ -480,6 +480,11 @@ schedule_heartbeat(State = #state{hb_interval_tref = undefined,
     TRef = erlang:send_after(timer:seconds(HBInterval), self(), send_heartbeat),
     State#state{hb_interval_tref = TRef};
 
+schedule_heartbeat(State = #state{hb_interval_tref = _TRef,
+                                  hb_interval = HBInterval}) when is_integer(HBInterval) ->
+    lager:debug("hb_interval_tref is not undefined when attempting to schedule new heartbeat."),
+    State;
+
 schedule_heartbeat(State) ->
     lager:warning("Heartbeat is misconfigured and is not a valid integer."),
     State.