anchor.diff:              #bloom_recon_struct{interval = MySyncI,
                                   reconPid = DestReconPid} = Params,
               ?ASSERT(DestReconPid =/= undefined),
  -            fd:subscribe(DestReconPid),
  +            fd:subscribe(DestRRPid),
               Params1 = Params,
               Reconcile = reconcile,
               Stage = reconciliation;
           merkle_tree ->
               #merkle_params{interval = MySyncI, reconPid = DestReconPid} = Params,
               ?ASSERT(DestReconPid =/= undefined),
  -            fd:subscribe(DestReconPid),
  +            fd:subscribe(DestRRPid),
               Params1 = Params,
               Reconcile = reconcile,
               Stage = reconciliation;
  
positive.code:                                  none =/= (Key = map_key_to_interval(KeyX, DestI))],
      build_struct(DBList, DestI, RestI, State);
  
  on({start_recon, RMethod, Params} = _Msg, State) ->
      ?TRACE1(_Msg, State),
      % initiator got other node's sync struct or parameters over sync interval
      % (mapped to the initiator's range)
  
negative.code:                                   db_chunk = DBChunk,
                                    sig_size = SigSize, ver_size = VSize} = Params,
              ?ASSERT(DestReconPid =/= undefined),
              fd:subscribe(DestRRPid),
              % convert db_chunk to a gb_tree for faster access checks
              DBChunkTree =
                  decompress_kv_list(DBChunk, gb_trees:empty(), SigSize, VSize),
  