anchor.diff:  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
   -spec startSyncRound(NodeKeys::[?RT:key()]) -> ok.
   startSyncRound(NodeKeys) ->
  -    lists:foreach(fun(X) ->
  -                          api_dht_raw:unreliable_lookup(X, {?send_to_group_member, rrepair, {rr_trigger}})
  -                  end,
  -                  NodeKeys),
  +    lists:foreach(
  +      fun(X) ->
  +              Req = {?send_to_group_member, rrepair, {rr_trigger}},
  +              api_dht_raw:unreliable_lookup(X, Req)
  +      end,
  +      NodeKeys),
       ok.
   
  --spec waitForSyncRoundEnd(NodeKeys::[?RT:key()]) -> ok.
  -waitForSyncRoundEnd(NodeKeys) ->
  +-spec waitForSyncRoundEnd(NodeKeys::[?RT:key()], RcvReqCompleteMsg::boolean()) -> ok.
  +waitForSyncRoundEnd(NodeKeys, RcvReqCompleteMsg) ->
  +    RcvReqCompleteMsg andalso
  +        receive
  +            {request_sync_complete, _} -> true
  +        end,
       Req = {?send_to_group_member, rrepair,
              {get_state, comm:this(), [open_sessions, open_recon, open_resolve]}},
       util:wait_for(fun() -> wait_for_sync_round_end2(Req, NodeKeys) end, 100).
  
positive.code:     %server starts sync
      api_dht_raw:unreliable_lookup(IKey, {?send_to_group_member, rrepair,
                                                {request_sync, Method, CKey, comm:this()}}),
      wait_for_session_end(),
      %measure sync degree
      IMNew = count_dbsize(IKey),
      CMNew = count_dbsize(CKey),
  
negative.code: %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  % Helper Functions
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
  % @doc
  %    runs the bloom filter synchronization [Rounds]-times
  