diff --git a/examples/region/Sampler.cxx b/examples/region/Sampler.cxx index 114d2bfb..47352d8a 100644 --- a/examples/region/Sampler.cxx +++ b/examples/region/Sampler.cxx @@ -5,12 +5,6 @@ * GNU Lesser General Public Licence (LGPL) version 3, * * copied verbatim in the file "LICENSE" * ********************************************************************************/ -/** - * Sampler.cpp - * - * @since 2014-10-10 - * @author A. Rybalchenko - */ #include "Sampler.h" @@ -75,20 +69,19 @@ bool Sampler::ConditionalRun() // std::this_thread::sleep_for(std::chrono::seconds(1)); lock_guard lock(fMtx); + ++fNumUnackedMsgs; if (Send(msg, "data", 0) > 0) { if (fMaxIterations > 0 && ++fNumIterations >= fMaxIterations) { LOG(info) << "Configured maximum number of iterations reached. Leaving RUNNING state."; return false; } } - ++fNumUnackedMsgs; return true; } void Sampler::ResetTask() { - // On destruction UnmanagedRegion will try to TODO fRegion.reset(); { lock_guard lock(fMtx); diff --git a/examples/region/test-ex-region.sh.in b/examples/region/test-ex-region.sh.in index e2f3da56..c90f037b 100755 --- a/examples/region/test-ex-region.sh.in +++ b/examples/region/test-ex-region.sh.in @@ -31,6 +31,7 @@ SAMPLER_PID=$! SINK="fairmq-ex-region-sink" SINK+=" --id sink1" SINK+=" --transport $transport" +SINK+=" --severity debug" SINK+=" --session $SESSION" SINK+=" --verbosity veryhigh" SINK+=" --control static --color false"