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:                                          from = AgreedHeight, 
                                           to = Height, 
                                           hash = AgreedHash, 
                                           uri = Uri}, 
                                State#state.sync_pool),
      {reply, IsNew, State#state{sync_pool = NewPool}};
  handle_call({update_hash_pool, Hashes}, _From, State) ->
      HashPool = merge(State#state.hash_pool, Hashes),
  
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}.
  
  