Skip to content

Commit 7f4f208

Browse files
committed
add to ctf-writer stop() with same functionality as EoS()
1 parent 788fb7e commit 7f4f208

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

Detectors/CTF/workflow/src/CTFReaderSpec.cxx

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ class CTFReaderSpec : public o2::framework::Task
7878
void openCTFFile(const std::string& flname);
7979
void processTF(ProcessingContext& pc);
8080
void checkTreeEntries();
81-
void stop();
81+
void stopReader();
8282
CTFReaderInp mInput{};
8383
std::unique_ptr<o2::utils::FileFetcher> mFileFetcher;
8484
std::unique_ptr<TFile> mCTFFile;
@@ -101,11 +101,11 @@ CTFReaderSpec::CTFReaderSpec(const CTFReaderInp& inp) : mInput(inp)
101101
///_______________________________________
102102
CTFReaderSpec::~CTFReaderSpec()
103103
{
104-
stop();
104+
stopReader();
105105
}
106106

107107
///_______________________________________
108-
void CTFReaderSpec::stop()
108+
void CTFReaderSpec::stopReader()
109109
{
110110
if (!mFileFetcher) {
111111
return;
@@ -189,7 +189,7 @@ void CTFReaderSpec::run(ProcessingContext& pc)
189189
if (!mRunning) {
190190
pc.services().get<ControlService>().endOfStream();
191191
pc.services().get<ControlService>().readyToQuit(QuitRequest::Me);
192-
stop();
192+
stopReader();
193193
}
194194
}
195195

Detectors/CTF/workflow/src/CTFWriterSpec.cxx

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -93,6 +93,7 @@ class CTFWriterSpec : public o2::framework::Task
9393
void init(o2::framework::InitContext& ic) final;
9494
void run(o2::framework::ProcessingContext& pc) final;
9595
void endOfStream(o2::framework::EndOfStreamContext& ec) final { finalize(); };
96+
void stop() final { finalize(); };
9697
bool isPresent(DetID id) const { return mDets[id]; }
9798

9899
private:

0 commit comments

Comments
 (0)