anchor.diff:      %server starts sync
       api_dht_raw:unreliable_lookup(IKey, {?send_to_group_member, rrepair,
                                                 {request_sync, Method, CKey, comm:this()}}),
  -    wait_for_session_end(),
  +    waitForSyncRoundEnd([IKey, CKey], true),
       %measure sync degree
       IMNew = count_dbsize(IKey),
       CMNew = count_dbsize(CKey),
  
positive.code: %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  -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),
      ok.
  
  -spec waitForSyncRoundEnd(NodeKeys::[?RT:key()]) -> ok.
  waitForSyncRoundEnd(NodeKeys) ->
      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).
  
negative.code:     %trace_mpath:start(TraceName, fun mpath_map/3),
      trace_mpath:start(TraceName),
      api_dht_raw:unreliable_lookup(SKey, {?send_to_group_member, rrepair,
                                                {request_sync, Method, CKey, comm:this()}}),
      waitForSyncRoundEnd([SKey, CKey], true),
      trace_mpath:stop(),
      %TRACE
      A = trace_mpath:get_trace(TraceName),
  