Skip to content

Commit fa94e6b

Browse files
committed
[ntuple] Merger: use fWriteOpts.GetEnablePageChecksums() when resealing
1 parent 5932648 commit fa94e6b

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

tree/ntuple/src/RNTupleMerger.cxx

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -301,6 +301,7 @@ struct RResealFunc {
301301
ROOT::Internal::RPageAllocator &fPageAlloc;
302302
std::uint8_t *fBuffer;
303303
std::size_t fBufSize;
304+
const ROOT::RNTupleWriteOptions &fWriteOpts;
304305

305306
void operator()() const
306307
{
@@ -310,7 +311,7 @@ struct RResealFunc {
310311
sealConf.fPage = &page;
311312
sealConf.fBuffer = fBuffer;
312313
sealConf.fCompressionSettings = *fMergeOptions.fCompressionSettings;
313-
sealConf.fWriteChecksum = fSealedPage.GetHasChecksum();
314+
sealConf.fWriteChecksum = fWriteOpts.GetEnablePageChecksums();
314315
assert(fBufSize >= fSealedPage.GetDataSize() + fSealedPage.GetHasChecksum() * sizeof(std::uint64_t));
315316
auto refSealedPage = RPageSink::SealPage(sealConf);
316317
fSealedPage = refSealedPage;
@@ -905,6 +906,7 @@ RNTupleMerger::MergeCommonColumns(ROOT::Internal::RClusterPool &clusterPool,
905906
*fPageAlloc,
906907
buffer.get(),
907908
bufSize,
909+
mergeData.fDestination.GetWriteOptions()
908910
});
909911
} else {
910912
RTaskVisitor{fTaskGroup}(RChangeCompressionFunc{

0 commit comments

Comments
 (0)