Skip to content

Commit 2d0ee67

Browse files
shahor02shahor02
committed
add verbosity hangle for entropy encoding/decoding
1 parent 85ce6d5 commit 2d0ee67

52 files changed

Lines changed: 181 additions & 144 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎DataFormats/Detectors/Common/include/DetectorsCommonDataFormats/EncodedBlocks.h‎

Lines changed: 25 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,7 @@ struct Metadata {
109109
};
110110
size_t messageLength = 0;
111111
size_t nLiterals = 0;
112+
uint8_t messageWordSize = 0;
112113
uint8_t coderType = 0;
113114
uint8_t streamSize = 0;
114115
uint8_t probabilityBits = 0;
@@ -123,6 +124,7 @@ struct Metadata {
123124
{
124125
min = max = 0;
125126
messageLength = 0;
127+
messageWordSize = 0;
126128
nLiterals = 0;
127129
coderType = 0;
128130
streamSize = 0;
@@ -131,7 +133,7 @@ struct Metadata {
131133
nDataWords = 0;
132134
nLiteralWords = 0;
133135
}
134-
ClassDefNV(Metadata, 1);
136+
ClassDefNV(Metadata, 2);
135137
};
136138

137139
/// registry struct for the buffer start and offsets of writable space
@@ -440,7 +442,7 @@ class EncodedBlocks
440442
static std::vector<char> createDictionaryBlocks(const std::vector<o2::rans::FrequencyTable>& vfreq, const std::vector<Metadata>& prbits);
441443

442444
/// print itself
443-
void print(const std::string& prefix = "") const;
445+
void print(const std::string& prefix = "", int verbosity = 1) const;
444446
void dump(const std::string& prefix = "", int ncol = 20) const;
445447

446448
protected:
@@ -708,13 +710,25 @@ inline auto EncodedBlocks<H, N, W>::create(VD& v)
708710
///_____________________________________________________________________________
709711
/// print itself
710712
template <typename H, int N, typename W>
711-
void EncodedBlocks<H, N, W>::print(const std::string& prefix) const
713+
void EncodedBlocks<H, N, W>::print(const std::string& prefix, int verbosity) const
712714
{
713-
LOG(INFO) << prefix << "Container of " << N << " blocks, size: " << size() << " bytes, unused: " << getFreeSize();
714-
for (int i = 0; i < N; i++) {
715-
LOG(INFO) << "Block " << i << " for " << mMetadata[i].messageLength << " message words |"
716-
<< " NDictWords: " << mBlocks[i].getNDict() << " NDataWords: " << mBlocks[i].getNData()
717-
<< " NLiteralWords: " << mBlocks[i].getNLiterals();
715+
if (verbosity > 0) {
716+
LOG(INFO) << prefix << "Container of " << N << " blocks, size: " << size() << " bytes, unused: " << getFreeSize();
717+
for (int i = 0; i < N; i++) {
718+
LOG(INFO) << "Block " << i << " for " << mMetadata[i].messageLength << " message words of " << mMetadata[i].messageWordSize << " bytes |"
719+
<< " NDictWords: " << mBlocks[i].getNDict() << " NDataWords: " << mBlocks[i].getNData()
720+
<< " NLiteralWords: " << mBlocks[i].getNLiterals();
721+
}
722+
} else if (verbosity == 0) {
723+
size_t inpSize = 0, ndict = 0, ndata = 0, nlit = 0;
724+
for (int i = 0; i < N; i++) {
725+
inpSize += mMetadata[i].messageLength * mMetadata[i].messageWordSize;
726+
ndict += mBlocks[i].getNDict();
727+
ndata += mBlocks[i].getNData();
728+
nlit += mBlocks[i].getNLiterals();
729+
}
730+
LOG(INFO) << prefix << N << " blocks, input size: " << inpSize << ", output size: " << size()
731+
<< " NDictWords: " << ndict << " NDataWords: " << ndata << " NLiteralWords: " << nlit;
718732
}
719733
}
720734

@@ -817,7 +831,7 @@ void EncodedBlocks<H, N, W>::encode(const input_IT srcBegin, // iterator be
817831

818832
// case 1: empty source message
819833
if (messageLength == 0) {
820-
mMetadata[slot] = Metadata{0, 0, sizeof(ransState_t), sizeof(ransStream_t), symbolTablePrecision, Metadata::OptStore::NODATA, 0, 0, 0, 0, 0};
834+
mMetadata[slot] = Metadata{0, 0, sizeof(input_t), sizeof(ransState_t), sizeof(ransStream_t), symbolTablePrecision, Metadata::OptStore::NODATA, 0, 0, 0, 0, 0};
821835
return;
822836
}
823837

@@ -900,6 +914,7 @@ void EncodedBlocks<H, N, W>::encode(const input_IT srcBegin, // iterator be
900914

901915
*thisMetadata = Metadata{messageLength,
902916
nLiteralSymbols,
917+
sizeof(input_t),
903918
sizeof(ransState_t),
904919
sizeof(ransStream_t),
905920
static_cast<uint8_t>(encoder->getSymbolTablePrecision()),
@@ -922,7 +937,7 @@ void EncodedBlocks<H, N, W>::encode(const input_IT srcBegin, // iterator be
922937
expandStorage(nBufferElems);
923938
thisBlock->storeData(thisMetadata->nDataWords, reinterpret_cast<const storageBuffer_t*>(tmp.data()));
924939

925-
*thisMetadata = Metadata{messageLength, 0, sizeof(ransState_t), sizeof(storageBuffer_t), symbolTablePrecision, opt, 0, 0, 0, static_cast<int>(nBufferElems), 0};
940+
*thisMetadata = Metadata{messageLength, 0, sizeof(input_t), sizeof(ransState_t), sizeof(storageBuffer_t), symbolTablePrecision, opt, 0, 0, 0, static_cast<int>(nBufferElems), 0};
926941
}
927942
}
928943

‎Detectors/Base/include/DetectorsBase/CTFCoderBase.h‎

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -89,6 +89,9 @@ class CTFCoderBase
8989
void setMemMarginFactor(float v) { mMemMarginFactor = v > 1.f ? v : 1.f; }
9090
float getMemMarginFactor() const { return mMemMarginFactor; }
9191

92+
void setVerbosity(int v) { mVerbosity = v; }
93+
int getVerbosity() const { return mVerbosity; }
94+
9295
protected:
9396
std::string getPrefix() const { return o2::utils::Str::concat_string(mDet.getName(), "_CTF: "); }
9497
void assignDictVersion(CTFDictHeader& h) const
@@ -103,6 +106,7 @@ class CTFCoderBase
103106
DetID mDet;
104107
CTFDictHeader mExtHeader; // external dictionary header
105108
float mMemMarginFactor = 1.0f; // factor for memory allocation in EncodedBlocks
109+
int mVerbosity = 0;
106110

107111
ClassDefNV(CTFCoderBase, 1);
108112
};

‎Detectors/CPV/reconstruction/include/CPVReconstruction/CTFCoder.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -95,7 +95,7 @@ void CTFCoder::encode(VEC& buff, const gsl::span<const TriggerRecord>& trigData,
9595
ENCODECPV(helper.begin_energy(), helper.end_energy(), CTF::BLC_energy, 0);
9696
ENCODECPV(helper.begin_status(), helper.end_status(), CTF::BLC_status, 0);
9797
// clang-format on
98-
CTF::get(buff.data())->print(getPrefix());
98+
CTF::get(buff.data())->print(getPrefix(), mVerbosity);
9999
}
100100

101101
/// decode entropy-encoded clusters to standard compact clusters
@@ -104,7 +104,7 @@ void CTFCoder::decode(const CTF::base& ec, VTRG& trigVec, VCLUSTER& cluVec)
104104
{
105105
auto header = ec.getHeader();
106106
checkDictVersion(static_cast<const o2::ctf::CTFDictHeader&>(header));
107-
ec.print(getPrefix());
107+
ec.print(getPrefix(), mVerbosity);
108108
std::vector<uint16_t> bcInc, entries, posX, posZ;
109109
std::vector<uint32_t> orbitInc;
110110
std::vector<uint8_t> energy, status;

‎Detectors/CPV/workflow/include/CPVWorkflow/EntropyDecoderSpec.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ namespace cpv
2828
class EntropyDecoderSpec : public o2::framework::Task
2929
{
3030
public:
31-
EntropyDecoderSpec();
31+
EntropyDecoderSpec(int verbosity);
3232
~EntropyDecoderSpec() override = default;
3333
void run(o2::framework::ProcessingContext& pc) final;
3434
void init(o2::framework::InitContext& ic) final;
@@ -40,7 +40,7 @@ class EntropyDecoderSpec : public o2::framework::Task
4040
};
4141

4242
/// create a processor spec
43-
framework::DataProcessorSpec getEntropyDecoderSpec();
43+
framework::DataProcessorSpec getEntropyDecoderSpec(int verbosity);
4444

4545
} // namespace cpv
4646
} // namespace o2

‎Detectors/CPV/workflow/src/EntropyDecoderSpec.cxx‎

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,10 +24,11 @@ namespace o2
2424
namespace cpv
2525
{
2626

27-
EntropyDecoderSpec::EntropyDecoderSpec()
27+
EntropyDecoderSpec::EntropyDecoderSpec(int verbosity)
2828
{
2929
mTimer.Stop();
3030
mTimer.Reset();
31+
mCTFCoder.setVerbosity(verbosity);
3132
}
3233

3334
void EntropyDecoderSpec::init(o2::framework::InitContext& ic)
@@ -62,7 +63,7 @@ void EntropyDecoderSpec::endOfStream(EndOfStreamContext& ec)
6263
mTimer.CpuTime(), mTimer.RealTime(), mTimer.Counter() - 1);
6364
}
6465

65-
DataProcessorSpec getEntropyDecoderSpec()
66+
DataProcessorSpec getEntropyDecoderSpec(int verbosity)
6667
{
6768
std::vector<OutputSpec> outputs{
6869
OutputSpec{{"triggers"}, "CPV", "CLUSTERTRIGRECS", 0, Lifetime::Timeframe},
@@ -72,7 +73,7 @@ DataProcessorSpec getEntropyDecoderSpec()
7273
"cpv-entropy-decoder",
7374
Inputs{InputSpec{"ctf", "CPV", "CTFDATA", 0, Lifetime::Timeframe}},
7475
outputs,
75-
AlgorithmSpec{adaptFromTask<EntropyDecoderSpec>()},
76+
AlgorithmSpec{adaptFromTask<EntropyDecoderSpec>(verbosity)},
7677
Options{{"ctf-dict", VariantType::String, o2::base::NameConf::getCTFDictFileName(), {"File of CTF decoding dictionary"}}}};
7778
}
7879

‎Detectors/CTF/workflow/include/CTFWorkflow/CTFWriterSpec.h‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ namespace ctf
2424
{
2525

2626
/// create a processor spec
27-
framework::DataProcessorSpec getCTFWriterSpec(o2::detectors::DetID::mask_t dets, uint64_t run, const std::string& outType);
27+
framework::DataProcessorSpec getCTFWriterSpec(o2::detectors::DetID::mask_t dets, uint64_t run, const std::string& outType, int verbosity);
2828

2929
} // namespace ctf
3030
} // namespace o2

‎Detectors/CTF/workflow/src/CTFWriterSpec.cxx‎

Lines changed: 9 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ class CTFWriterSpec : public o2::framework::Task
8888
{
8989
public:
9090
CTFWriterSpec() = delete;
91-
CTFWriterSpec(DetID::mask_t dm, uint64_t r, const std::string& outType);
91+
CTFWriterSpec(DetID::mask_t dm, uint64_t r, const std::string& outType, int verbosity);
9292
~CTFWriterSpec() final { finalize(); }
9393
void init(o2::framework::InitContext& ic) final;
9494
void run(o2::framework::ProcessingContext& pc) final;
@@ -120,6 +120,7 @@ class CTFWriterSpec : public o2::framework::Task
120120
bool mDictPerDetector = false;
121121
bool mCreateRunEnvDir = true;
122122
bool mStoreMetaFile = false;
123+
int mVerbosity = 0;
123124
int mSaveDictAfter = 0; // if positive and mWriteCTF==true, save dictionary after each mSaveDictAfter TFs processed
124125
int mFlagMinDet = 1; // append list of detectors to LHC period if their number is <= mFlagMinDet
125126
uint64_t mRun = 0;
@@ -169,8 +170,8 @@ class CTFWriterSpec : public o2::framework::Task
169170
const std::string CTFWriterSpec::TMPFileEnding{".part"};
170171

171172
//___________________________________________________________________
172-
CTFWriterSpec::CTFWriterSpec(DetID::mask_t dm, uint64_t r, const std::string& outType)
173-
: mDets(dm), mRun(r), mOutputType(outType)
173+
CTFWriterSpec::CTFWriterSpec(DetID::mask_t dm, uint64_t r, const std::string& outType, int verbosity)
174+
: mDets(dm), mRun(r), mOutputType(outType), mVerbosity(verbosity)
174175
{
175176
mTimer.Stop();
176177
mTimer.Reset();
@@ -261,7 +262,7 @@ size_t CTFWriterSpec::processDet(o2::framework::ProcessingContext& pc, DetID det
261262
}
262263
auto ctfBuffer = pc.inputs().get<gsl::span<o2::ctf::BufferType>>(det.getName());
263264
const auto ctfImage = C::getImage(ctfBuffer.data());
264-
ctfImage.print(o2::utils::Str::concat_string(det.getName(), ": "));
265+
ctfImage.print(o2::utils::Str::concat_string(det.getName(), ": "), mVerbosity);
265266
if (mWriteCTF) {
266267
sz += ctfImage.appendToTree(*tree, det.getName());
267268
header.detectors.set(det);
@@ -283,7 +284,7 @@ size_t CTFWriterSpec::processDet(o2::framework::ProcessingContext& pc, DetID det
283284
auto& mdSave = mFreqsMetaData[det][ib];
284285
const auto& md = ctfImage.getMetadata(ib);
285286
freq.addFrequencies(bl.getDict(), bl.getDict() + bl.getNDict(), md.min, md.max);
286-
mdSave = o2::ctf::Metadata{0, 0, md.coderType, md.streamSize, md.probabilityBits, md.opt, freq.getMinSymbol(), freq.getMaxSymbol(), (int)freq.size(), 0, 0};
287+
mdSave = o2::ctf::Metadata{0, 0, md.messageWordSize, md.coderType, md.streamSize, md.probabilityBits, md.opt, freq.getMinSymbol(), freq.getMaxSymbol(), (int)freq.size(), 0, 0};
287288
}
288289
}
289290
}
@@ -718,7 +719,7 @@ size_t CTFWriterSpec::getAvailableDiskSpace(const std::string& path, int level)
718719
}
719720

720721
//___________________________________________________________________
721-
DataProcessorSpec getCTFWriterSpec(DetID::mask_t dets, uint64_t run, const std::string& outType)
722+
DataProcessorSpec getCTFWriterSpec(DetID::mask_t dets, uint64_t run, const std::string& outType, int verbosity)
722723
{
723724
std::vector<InputSpec> inputs;
724725
LOG(DEBUG) << "Detectors list:";
@@ -732,8 +733,8 @@ DataProcessorSpec getCTFWriterSpec(DetID::mask_t dets, uint64_t run, const std::
732733
"ctf-writer",
733734
inputs,
734735
Outputs{},
735-
AlgorithmSpec{adaptFromTask<CTFWriterSpec>(dets, run, outType)}, // RS FIXME once global/local options clash is solved, --output-type will become device option
736-
Options{ //{"output-type", VariantType::String, "ctf", {"output types: ctf (per TF) or dict (create dictionaries) or both or none"}},
736+
AlgorithmSpec{adaptFromTask<CTFWriterSpec>(dets, run, outType, verbosity)}, // RS FIXME once global/local options clash is solved, --output-type will become device option
737+
Options{ //{"output-type", VariantType::String, "ctf", {"output types: ctf (per TF) or dict (create dictionaries) or both or none"}},
737738
{"save-ctf-after", VariantType::Int, 0, {"if > 0, autosave CTF tree with multiple CTFs after every N CTFs"}},
738739
{"save-dict-after", VariantType::Int, 0, {"if > 0, in dictionary generation mode save it dictionary after certain number of TFs processed"}},
739740
{"ctf-dict-dir", VariantType::String, "none", {"CTF dictionary directory, must exist"}},

‎Detectors/CTF/workflow/src/ctf-reader-workflow.cxx‎

Lines changed: 18 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@ void customize(std::vector<o2::framework::ConfigParamSpec>& workflowOptions)
5757
options.push_back(ConfigParamSpec{"ctf-file-regex", VariantType::String, ".*o2_ctf_run.+\\.root$", {"regex string to identify CTF files"}});
5858
options.push_back(ConfigParamSpec{"remote-regex", VariantType::String, "^/eos/aliceo2/.+", {"regex string to identify remote files"}});
5959
options.push_back(ConfigParamSpec{"max-cached-files", VariantType::Int, 3, {"max CTF files queued (copied for remote source)"}});
60+
options.push_back(ConfigParamSpec{"ctf-reader-verbosity", VariantType::Int, 0, {"verbosity level (0: summary per detector, 1: summary per block"}});
6061
options.push_back(ConfigParamSpec{"configKeyValues", VariantType::String, "", {"Semicolon separated key=value strings"}});
6162
//
6263
options.push_back(ConfigParamSpec{"its-digits", VariantType::Bool, false, {"convert ITS clusters to digits"}});
@@ -108,55 +109,56 @@ WorkflowSpec defineDataProcessing(ConfigContext const& configcontext)
108109
ctfInput.remoteRegex = configcontext.options().get<std::string>("remote-regex");
109110

110111
specs.push_back(o2::ctf::getCTFReaderSpec(ctfInput));
112+
int verbosity = configcontext.options().get<int>("ctf-reader-verbosity");
111113

112114
// add decodors for all allowed detectors.
113115
if (ctfInput.detMask[DetID::ITS]) {
114-
specs.push_back(o2::itsmft::getEntropyDecoderSpec(DetID::getDataOrigin(DetID::ITS), configcontext.options().get<bool>("its-digits")));
116+
specs.push_back(o2::itsmft::getEntropyDecoderSpec(DetID::getDataOrigin(DetID::ITS), verbosity, configcontext.options().get<bool>("its-digits")));
115117
}
116118
if (ctfInput.detMask[DetID::MFT]) {
117-
specs.push_back(o2::itsmft::getEntropyDecoderSpec(DetID::getDataOrigin(DetID::MFT), configcontext.options().get<bool>("mft-digits")));
119+
specs.push_back(o2::itsmft::getEntropyDecoderSpec(DetID::getDataOrigin(DetID::MFT), verbosity, configcontext.options().get<bool>("mft-digits")));
118120
}
119121
if (ctfInput.detMask[DetID::TPC]) {
120-
specs.push_back(o2::tpc::getEntropyDecoderSpec());
122+
specs.push_back(o2::tpc::getEntropyDecoderSpec(verbosity));
121123
}
122124
if (ctfInput.detMask[DetID::TRD]) {
123-
specs.push_back(o2::trd::getEntropyDecoderSpec());
125+
specs.push_back(o2::trd::getEntropyDecoderSpec(verbosity));
124126
}
125127
if (ctfInput.detMask[DetID::TOF]) {
126-
specs.push_back(o2::tof::getEntropyDecoderSpec());
128+
specs.push_back(o2::tof::getEntropyDecoderSpec(verbosity));
127129
}
128130
if (ctfInput.detMask[DetID::FT0]) {
129-
specs.push_back(o2::ft0::getEntropyDecoderSpec());
131+
specs.push_back(o2::ft0::getEntropyDecoderSpec(verbosity));
130132
}
131133
if (ctfInput.detMask[DetID::FV0]) {
132-
specs.push_back(o2::fv0::getEntropyDecoderSpec());
134+
specs.push_back(o2::fv0::getEntropyDecoderSpec(verbosity));
133135
}
134136
if (ctfInput.detMask[DetID::FDD]) {
135-
specs.push_back(o2::fdd::getEntropyDecoderSpec());
137+
specs.push_back(o2::fdd::getEntropyDecoderSpec(verbosity));
136138
}
137139
if (ctfInput.detMask[DetID::MID]) {
138-
specs.push_back(o2::mid::getEntropyDecoderSpec());
140+
specs.push_back(o2::mid::getEntropyDecoderSpec(verbosity));
139141
}
140142
if (ctfInput.detMask[DetID::MCH]) {
141-
specs.push_back(o2::mch::getEntropyDecoderSpec());
143+
specs.push_back(o2::mch::getEntropyDecoderSpec(verbosity));
142144
}
143145
if (ctfInput.detMask[DetID::EMC]) {
144-
specs.push_back(o2::emcal::getEntropyDecoderSpec());
146+
specs.push_back(o2::emcal::getEntropyDecoderSpec(verbosity));
145147
}
146148
if (ctfInput.detMask[DetID::PHS]) {
147-
specs.push_back(o2::phos::getEntropyDecoderSpec());
149+
specs.push_back(o2::phos::getEntropyDecoderSpec(verbosity));
148150
}
149151
if (ctfInput.detMask[DetID::CPV]) {
150-
specs.push_back(o2::cpv::getEntropyDecoderSpec());
152+
specs.push_back(o2::cpv::getEntropyDecoderSpec(verbosity));
151153
}
152154
if (ctfInput.detMask[DetID::ZDC]) {
153-
specs.push_back(o2::zdc::getEntropyDecoderSpec());
155+
specs.push_back(o2::zdc::getEntropyDecoderSpec(verbosity));
154156
}
155157
if (ctfInput.detMask[DetID::HMP]) {
156-
specs.push_back(o2::hmpid::getEntropyDecoderSpec());
158+
specs.push_back(o2::hmpid::getEntropyDecoderSpec(verbosity));
157159
}
158160
if (ctfInput.detMask[DetID::CTP]) {
159-
specs.push_back(o2::ctp::getEntropyDecoderSpec());
161+
specs.push_back(o2::ctp::getEntropyDecoderSpec(verbosity));
160162
}
161163

162164
return std::move(specs);

‎Detectors/CTF/workflow/src/ctf-writer-workflow.cxx‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ void customize(std::vector<o2::framework::ConfigParamSpec>& workflowOptions)
3434
options.push_back(ConfigParamSpec{"grpfile", VariantType::String, o2::base::NameConf::getGRPFileName(), {"name of the grp file"}});
3535
options.push_back(ConfigParamSpec{"no-grp", VariantType::Bool, false, {"do not read GRP file"}});
3636
options.push_back(ConfigParamSpec{"output-type", VariantType::String, "ctf", {"output types: ctf (per TF) or dict (create dictionaries) or both or none"}});
37+
options.push_back(ConfigParamSpec{"ctf-writer-verbosity", VariantType::Int, 0, {"verbosity level (0: summary per detector, 1: summary per block"}});
3738
options.push_back(ConfigParamSpec{"configKeyValues", VariantType::String, "", {"Semicolon separated key=value strings"}});
3839
std::swap(workflowOptions, options);
3940
}
@@ -72,6 +73,6 @@ WorkflowSpec defineDataProcessing(ConfigContext const& configcontext)
7273
}
7374
outType = configcontext.options().get<std::string>("output-type");
7475
}
75-
WorkflowSpec specs{o2::ctf::getCTFWriterSpec(dets, run, outType)};
76+
WorkflowSpec specs{o2::ctf::getCTFWriterSpec(dets, run, outType, configcontext.options().get<int>("ctf-writer-verbosity"))};
7677
return std::move(specs);
7778
}

‎Detectors/CTP/reconstruction/include/CTPReconstruction/CTFCoder.h‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ void CTFCoder::encode(VEC& buff, const gsl::span<const CTPDigit>& data)
9090
ENCODECTP(helper.begin_bytesClass(), helper.end_bytesClass(), CTF::BLC_bytesClass, 0);
9191

9292
// clang-format on
93-
CTF::get(buff.data())->print(getPrefix());
93+
CTF::get(buff.data())->print(getPrefix(), mVerbosity);
9494
}
9595

9696
/// decode entropy-encoded digits
@@ -99,7 +99,7 @@ void CTFCoder::decode(const CTF::base& ec, VTRG& data)
9999
{
100100
auto header = ec.getHeader();
101101
checkDictVersion(static_cast<const o2::ctf::CTFDictHeader&>(header));
102-
ec.print(getPrefix());
102+
ec.print(getPrefix(), mVerbosity);
103103
std::vector<uint16_t> bcInc;
104104
std::vector<uint32_t> orbitInc;
105105
std::vector<uint8_t> bytesInput, bytesClass;

0 commit comments

Comments
 (0)