anchor.diff:          #state{job = Job, voting_timeout = VotingTimeout} = State) ->
       lager:debug([{job_id,Job#pushy_job.id}],
                   "Timeout occurred during voting on job ~p after ~ps", [Job#pushy_job.id, VotingTimeout]),
  -    State1 = do_on_matching_state(new, fun(N, S) -> add_quorum_vote_event(S, N#pushy_job_node.node_name, voting_timeout) end, State), 
  +    State1 = do_on_matching_state(new, fun(N, S) -> add_quorum_vote_event(S, N#pushy_job_node.node_name, voting_timeout) end, State),
       % Set all nodes that have not responded to the vote, to new, forcing voting to finish
       State2 = send_matching_to_rehab(new, unavailable, State1),
       maybe_finished_voting(State2);
  
positive.code:     {_, NodeName} = NodeRef,
      State2 = add_quorum_vote_event(State1, NodeName, Status),
      maybe_finished_voting(State2);
  voting({Response, NodeRef}, State) ->
      State1 = case Response of
          down ->
                  {_, NodeName} = NodeRef,
                  add_quorum_vote_event(State, NodeName, down);
          _ ->
                  lager:error("bad response while voting: ~p", [Response]),
                  State
      end,
      State2 = case get_node_state(NodeRef, State1) of
  
negative.code:             State = add_start_event(State0, Job#pushy_job.command, Job#pushy_job.run_timeout, Job#pushy_job.quorum, NodeCount, Requestor),
              listen_for_down_nodes(dict:fetch_keys(JobNodes)),
  
              lager:info([{job_id,Job#pushy_job.id}],
                          "Job ~p starting '~p' on ~p nodes, with timeout ~ps",
                          [JobId, Job#pushy_job.command, length(JobNodeList), Job#pushy_job.run_timeout]),
  
  