anchor.diff:  
       %% perform RDHT operations to collect missing TLog entries
       %% rdht requests for independent keys are processed in parallel.
  -    ReqListWithReqIds = initiate_rdht_ops(ReqListonRDHT),
  -
  -    RTLog = collect_replies(tx_tlog:empty(), ReqListWithReqIds),
  +    ReqIds = initiate_rdht_ops(ReqListonRDHT),
  +
  +    RTLog = collect_replies(tx_tlog:empty(), ReqIds),
   
       %% merge TLogs (insert fail, abort, when version mismatch
       %% in reads for same key is detected)
  
positive.code:                 end
      end.
  
  -spec receive_answer() -> {tx_tlog:tx_op(), req_id(), tx_tlog:tlog_entry()}.
  receive_answer() ->
      receive
          ?SCALARIS_RECV(
             {tx_tm_rtm_commit_reply, _, _}, %%->
             %% probably an outdated commit reply: drop it.
               receive_answer()
            );
          ?SCALARIS_RECV(
             {tx_timeout, _}, %% ->
             %% probably an outdated commit reply: drop it.
               receive_answer()
            );
          ?SCALARIS_RECV(
             {_Op, _RdhtId, _RdhtTlog} = Msg, %% ->
               Msg
            )
      end.
  
  -spec req_get_op(api_tx:request_on_key())
  
negative.code:     end.
  
  %% @doc Trigger operations for the DHT.
  -spec initiate_rdht_ops([request_on_key()]) -> [req_id()].
  initiate_rdht_ops(ReqList) ->
      ?TRACE("rdht_tx:initiate_rdht_ops(~p)~n", [ReqList]),
      %% @todo should choose a dht_node in the local VM at random or even
  