anchor.diff:  -spec current_state(node_ref()) -> any().
   current_state(NodeRef) ->
       Pid = pushy_node_state_sup:get_process(NodeRef),
  -    gen_fsm:sync_send_event(Pid, current_state, infinity).
  +    gen_fsm:sync_send_all_state_event(Pid, current_state, infinity).
   
   -spec set_logging(node_ref(), logging_level()) ->  gproc_error().
   set_logging(NodeRef, Level) when Level =:= verbose orelse Level =:= normal ->
  
positive.code:             {stop, shutdown, undefined}
      end.
  
  %%%
  %%% State machine internals
  %%%
  up(current_state, _From, #state{heartbeat_rate=HRate}=State) ->
      {reply, {up, pushy_ema:value(HRate)}, up, State}.
  
  down(current_state, _From, #state{heartbeat_rate=HRate}=State) ->
      {reply, {down, pushy_ema:value(HRate)}, down, State}.
  
  %%
  %% These events are handled the same for every state
  %%
  
negative.code: %% Observers
  -export([start_watching/1,
           stop_watching/1]).
  
  -define(SAVE_MODE, gen_server). % direct or gen_server
  -define(NO_NODE, {error, no_node}).
  