anchor.diff:  -spec init(#pushy_job{}) ->
       {'ok', job_status(), #state{}} |
       {'stop', 'shutdown', #state{}}.
  -% FIX: This is Erlang not C/C++
   init(#pushy_job{id = JobId, job_nodes = JobNodeList} = Job) ->
  -    % FIX: Get host name at the beginning so we don't start a job
  -    % and have it crash later and lose all the accumulated state
  -    % because we were missing a configuration entry.
       Host = pushy_util:get_env(pushy, server_name, fun is_list/1),
       case pushy_job_state_sup:register_process(JobId) of
           true ->
  
positive.code:     listen_for_down_nodes(JobNodes).
  
  -spec send_command_to_all(binary(), #state{}) -> 'ok'.
  % FIX: This is Erlang not C/C++
  send_command_to_all(Type, #state{job_host=Host, job = Job, job_nodes = JobNodes}) ->
      lager:info("Sending ~p to all nodes", [Type]),
      Message = [{type, Type},
  
negative.code:          complete/2,
           quorum_failed/2]).
  
  -ifdef(TEST).
  -include_lib("eunit/include/eunit.hrl").
  -endif.
  
  -include("pushy.hrl").
  -include("pushy_sql.hrl").
  
  