bugfix: missing stop() method on BufferingAgent

pelican · May 8, 2015 · 4a9893b · 4a9893b
1 parent d163f5d
commit 4a9893b
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 1 deletion.
diff --git a/src/lib/BufferingAgent.h b/src/lib/BufferingAgent.h
@@ -37,6 +37,7 @@ class BufferingAgent : public QThread
         ~BufferingAgent();
 
         void run();
+        void stop();
 
         void getData(DataBlobHash& hash);
 

diff --git a/src/lib/src/BufferingAgent.cpp b/src/lib/src/BufferingAgent.cpp
@@ -35,6 +35,12 @@ void BufferingAgent::run() {
     }
 }
 
+void BufferingAgent::stop()
+{
+    _halt = true;
+    quit();
+}
+
 void BufferingAgent::getData(BufferingAgent::DataBlobHash& hash) {
     // spin until we have data
     do{}

diff --git a/src/lib/src/BufferingDataClient.cpp b/src/lib/src/BufferingDataClient.cpp
@@ -9,7 +9,7 @@ namespace lofar {
 template<class DataClientType>
 BufferingDataClient<DataClientType>::BufferingDataClient(const ConfigNode& configNode, const DataTypes& types, const Config* config)
     : DataClientType(configNode, types, config)
-    , _agent(boost::bind(&DataClientType::getNext, this))
+    , _agent(boost::bind(&DataClientType::getData, this))
 {
     // start the thread running
     _agent.start();