anchor.diff:              MerkleSyncNewRcvL = length(MerkleSyncNewRcv),
               TrivialProcs = MerkleSyncNewSendL + MerkleSyncNewRcvL,
               ?DBG_ASSERT(TrivialProcs > 0), % should always be true in this case!
  +            P1EAllLeaves = calc_n_subparts_p1e(1, Params#merkle_params.p1e, NextP0E),
               ?MERKLE_DEBUG("merkle (NI) - LeafSync~n~B/~B (send), ~B (receive)\tP1EAllLeaves: ~g\t"
                             "ItemsToSend: ~B+~B (~g per leaf)",
                             [SyncDRLCount, MerkleSyncNewSendL, MerkleSyncNewRcvL,
  -                           P1EPhaseX, length(SyncDRK),
  +                           P1EAllLeaves, length(SyncDRK),
                              lists:sum([MyItemCount || {_, _, MyItemCount} <- MerkleSyncNewSend]),
                              ?IIF(MerkleSyncNewSend =/=[],
                                   lists:sum([MyItemCount || {_, _, MyItemCount} <- MerkleSyncNewSend]) /
                                       MerkleSyncNewSendL, 0.0)]),
  -            
               if MerkleSyncNewSend =/= [] ->
                      {Hashes, NStats3} =
                          merkle_resolve_leaves_send(MerkleSyncNewSend, NStats2,
  -                                                  Params, P1EPhaseX, TrivialProcs),
  +                                                  Params, P1EAllLeaves, TrivialProcs),
                      ?MERKLE_DEBUG("merkle (NI) - HashesSize: ~B (~B compressed)",
                                    [erlang:byte_size(Hashes),
                                     erlang:byte_size(
  
positive.code:                    ?DBG_ASSERT(Hashes =/= <<>>),
                     send(DestReconPid, {resolve_req, Hashes}),
                     NewState#rr_recon_state{stage = resolve, stats = NStats2,
                                             misc = [{all_leaf_p1e, P1EPhaseX},
                                                     {trivial_procs, TrivialProcs}]};
                 true ->
                     % only wait for the other node's resolve_req
                     NewState#rr_recon_state{stage = resolve, stats = NStats1,
                                             misc = [{all_leaf_p1e, P1EPhaseX},
                                                     {trivial_procs, TrivialProcs}]}
              end;
          _ ->
  
negative.code:             if MerkleSyncNewSend =/= [] ->
                     {Hashes, NStats2} =
                         merkle_resolve_leaves_send(MerkleSyncNewSend, NStats1,
                                                    Params, P1EAllLeaves, TrivialProcs),
                     ?MERKLE_DEBUG("merkle (I) - HashesSize: ~B (~B compressed)",
                                   [erlang:byte_size(Hashes),
                                    erlang:byte_size(
  