From d778559894d5a390b51300bc8149a5bc8188494b Mon Sep 17 00:00:00 2001
From: Simon Rasmussen <zetlon@gmail.com>
Date: Wed, 1 Mar 2017 12:39:04 +0100
Subject: [PATCH] Minor pipeline improvements

---
 include/ur_modern_driver/pipeline.h | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/include/ur_modern_driver/pipeline.h b/include/ur_modern_driver/pipeline.h
index df56421..199345a 100644
--- a/include/ur_modern_driver/pipeline.h
+++ b/include/ur_modern_driver/pipeline.h
@@ -49,15 +49,15 @@ private:
 
             for (auto& p : products) {
                 if (!_queue.try_enqueue(std::move(p))) {
-                    LOG_ERROR("Pipeline owerflowed!");
+                    LOG_ERROR("Pipeline producer owerflowed!");
                 }
             }
 
             products.clear();
         }
         _producer.teardown_producer();
-        //todo cleanup
         LOG_DEBUG("Pipline producer ended");
+        _consumer.stop_consumer();
     }
 
     void run_consumer()
@@ -75,8 +75,8 @@ private:
                 break;
         }
         _consumer.teardown_consumer();
-        //todo cleanup
         LOG_DEBUG("Pipline consumer ended");
+        _producer.stop_producer();
     }
 
 public: