anchor.diff:              case new_header(Uri, Hdr, AgreedHeight, AgreedHash) of
                   false ->
                       lager:debug("Already syncing with peer ~p", [Uri]),
  -                    %% Already a sync in progress with this peer
                       ok;
                   true ->
                       PoolResult = fill_pool(Uri, AgreedHash),
  
positive.code:     aec_peers:add_and_ping_peers(Peers, true),
      {ok, #state{}}.
  
  handle_call({new_header, Uri, Header, AgreedHeight, AgreedHash}, _, State) ->
      Height = aec_headers:height(Header),
      Difficulty = aec_headers:difficulty(Header),
      %% We have talked to the Uri, so Uri can be trusted
  
negative.code:         _ -> ignore
      end,
      {noreply, State};
  handle_info({'DOWN', _Ref, process, Pid, Reason}, State) ->
      %% It might be one of our syncing workers that crashed
      if Reason =/= normal -> lager:info("worker stopped with reason: ~p", [Reason]);
         true -> ok
      end,
      {noreply, State#state{sync_pool = lists:keydelete(Pid, #sync_peer.pid, State#state.sync_pool)}};
  handle_info(_, State) ->
      {noreply, State}.
  
  