anchor.diff:      SrcI = proplists:get_value(interval, Params),
       Intersec = find_intersection(MyI, SrcI),
       case intervals:is_empty(Intersec) of
  -        false when Method =:= bloom -> 
  -            send_chunk_req(DhtPid, self(), Intersec, mapInterval(Intersec, 1), get_max_items(Method));
           false -> send_chunk_req(DhtPid, self(), Intersec, Intersec, get_max_items(Method));
           true -> comm:send_local(self(), {shutdown, empty_interval})
       end,
  
positive.code:       DhtPid, 
        {get_chunk, SrcPid, I, 
         fun(Item) -> db_entry:get_version(Item) =/= -1 end,
         fun(Item) -> encodeBlob(minKeyInInterval(db_entry:get_key(Item), DestI), 
                                 db_entry:get_version(Item)) 
         end,
         MaxItems}).
  
  
negative.code:     SID = rr_recon_stats:get(session_id, Stats),
      SyncFinished = intervals:is_empty(RestI),
      not SyncFinished andalso
          send_chunk_req(DhtNodePid, self(), RestI, RestI, get_max_items(bloom)),
      Diff = [erlang:element(1, decodeBlob(KV)) || KV <- DBList,
                                                   not ?REP_BLOOM:is_element(BF, KV)],
      ?TRACE("Reconcile Bloom Session=~p ; Diff=~p", [SID, length(Diff)]),
  