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: %% merkle tree sync messages
  %%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%
  
  on({?check_nodes, SenderPid, ToCheck, SigSizeI, SigSizeILeafDiff}, State) ->
      NewState = State#rr_recon_state{dest_recon_pid = SenderPid},
      on({?check_nodes, ToCheck, SigSizeI, SigSizeILeafDiff}, NewState);
  
  on({?check_nodes, ToCheck0, SigSizeI, SigSizeILeafDiff},
     State = #rr_recon_state{stage = reconciliation,    initiator = false,
  
negative.code:     case Initiator of
          true ->
              SigSize = 160,
              P1E = Params#merkle_params.p1e,
              Req = merkle_compress_hashlist([merkle_tree:get_root(MySyncStruct)],
                                             <<>>, SigSize, SigSize),
              send(DestReconPid, {?check_nodes, comm:this(), Req, SigSize}),
              State#rr_recon_state{stats = Stats1,
                                   misc = [{signature_size, {SigSize, SigSize}},
                                           {p1e, P1E}],
                                   kv_list = []};
          false ->
              MerkleI = merkle_tree:get_interval(MySyncStruct),
              MerkleV = merkle_tree:get_branch_factor(MySyncStruct),
              MerkleB = merkle_tree:get_bucket_size(MySyncStruct),
              P1E = get_p1e(),
              MySyncParams = #merkle_params{interval = MerkleI,
                                            branch_factor = MerkleV,
                                            bucket_size = MerkleB,
                                            p1e = P1E},
              SyncParams = MySyncParams#merkle_params{reconPid = comm:this()},
              SID = rr_recon_stats:get(session_id, Stats),
              send(DestRRPid, {?IIF(SID =:= null, start_recon, continue_recon),
  