anchor.diff:           interval       = ?required(merkle_param, interval)       :: intervals:interval(),
            reconPid       = undefined                               :: comm:mypid() | undefined,
            branch_factor  = ?required(merkle_param, branch_factor)  :: pos_integer(),
  -         bucket_size    = ?required(merkle_param, bucket_size)    :: pos_integer()
  +         bucket_size    = ?required(merkle_param, bucket_size)    :: pos_integer(),
  +         p1e            = ?required(merkle_param, p1e)            :: float()
           }).
   
   -record(art_recon_struct,
  
positive.code:     case Initiator of
          true ->
              SigSize = 160,
              Req = merkle_compress_hashlist([merkle_tree:get_root(MySyncStruct)],
                                             <<>>, SigSize, SigSize),
              send(DestReconPid, {?check_nodes, comm:this(), Req, SigSize, 0}),
              State#rr_recon_state{stats = Stats1,
                                   misc = [{signature_size, {SigSize, SigSize}},
                                           {p1e, get_p1e()}],
                                   kv_list = []};
          false ->
              MerkleI = merkle_tree:get_interval(MySyncStruct),
              MerkleV = merkle_tree:get_branch_factor(MySyncStruct),
              MerkleB = merkle_tree:get_bucket_size(MySyncStruct),
              MySyncParams = #merkle_params{interval = MerkleI,
                                            branch_factor = MerkleV,
                                            bucket_size = MerkleB},
              SyncParams = MySyncParams#merkle_params{reconPid = comm:this()},
              SID = rr_recon_stats:get(session_id, Stats),
              send(DestRRPid, {?IIF(SID =:= null, start_recon, continue_recon),
  
negative.code: begin_sync(MySyncStruct, _OtherSyncStruct,
             State = #rr_recon_state{method = merkle_tree, initiator = Initiator,
                                     ownerPid = OwnerL, stats = Stats,
                                     params = Params,
                                     dest_recon_pid = DestReconPid,
                                     dest_rr_pid = DestRRPid}) ->
      ?TRACE("BEGIN SYNC", []),
  