blind attempt to fix false termination issue

rbx · matthiasrichter · commit 991add180c00 · 2014-10-10T23:14:56.000+02:00
diff --git a/devices/aliceHLTwrapper/WrapperDevice.cxx b/devices/aliceHLTwrapper/WrapperDevice.cxx
@@ -156,6 +156,12 @@ void WrapperDevice::Run()
 
   rateLogger.interrupt();
   rateLogger.join();
+
+  Shutdown();
+
+  boost::lock_guard<boost::mutex> lock(fRunningMutex);
+  fRunningFinished = true;
+  fRunningCondition.notify_one();
 }
 
 void WrapperDevice::Pause()
diff --git a/devices/aliceHLTwrapper/aliceHLTWrapper.cxx b/devices/aliceHLTwrapper/aliceHLTWrapper.cxx
@@ -172,8 +172,11 @@ int main(int argc, char** argv)
   device.ChangeState(FairMQDevice::SETINPUT);
   device.ChangeState(FairMQDevice::RUN);
 
-  char ch;
-  cin.get(ch);
+  boost::unique_lock<boost::mutex> lock(device.fRunningMutex);
+  while (!device.fRunningFinished)
+  {
+      device.fRunningCondition.wait(lock);
+  }
 
   device.ChangeState(FairMQDevice::STOP);
   device.ChangeState(FairMQDevice::END);
