From 132ae69953996cf6eb7070396164f77399b63685 Mon Sep 17 00:00:00 2001
From: Dennis Klein <d.klein@gsi.de>
Date: Thu, 13 Apr 2017 15:38:30 +0200
Subject: [PATCH] add startup and linger times for pubsub

---
 fairmq/test/helper/devices/TestPub.cxx | 14 +++++++++++++-
 fairmq/test/helper/devices/TestSub.cxx | 14 +++++++++++++-
 2 files changed, 26 insertions(+), 2 deletions(-)

diff --git a/fairmq/test/helper/devices/TestPub.cxx b/fairmq/test/helper/devices/TestPub.cxx
index 4162e8bc..2ac4d5e3 100644
--- a/fairmq/test/helper/devices/TestPub.cxx
+++ b/fairmq/test/helper/devices/TestPub.cxx
@@ -11,6 +11,8 @@
 
 #include <FairMQDevice.h>
 #include <FairMQLogger.h>
+#include <chrono>
+#include <thread>
 
 namespace fair
 {
@@ -22,6 +24,16 @@ namespace test
 class Pub : public FairMQDevice
 {
   protected:
+    auto Init() -> void override
+    {
+        std::this_thread::sleep_for(std::chrono::milliseconds(500));
+    }
+    
+    auto Reset() -> void override
+    {
+        std::this_thread::sleep_for(std::chrono::milliseconds(500));
+    }
+
     auto Run() -> void override
     {
         auto ready1 = FairMQMessagePtr{NewMessage()};
@@ -60,7 +72,7 @@ class Pub : public FairMQDevice
         {
             LOG(ERROR) << "Failed receiving ready signal: r1 = " << r1 << ", r2 = " << r2;
         }
-    };
+    }
 };
 
 } // namespace test
diff --git a/fairmq/test/helper/devices/TestSub.cxx b/fairmq/test/helper/devices/TestSub.cxx
index adb8c375..59e6943a 100644
--- a/fairmq/test/helper/devices/TestSub.cxx
+++ b/fairmq/test/helper/devices/TestSub.cxx
@@ -11,6 +11,8 @@
 
 #include <FairMQDevice.h>
 #include <FairMQLogger.h>
+#include <chrono>
+#include <thread>
 
 namespace fair
 {
@@ -22,6 +24,16 @@ namespace test
 class Sub : public FairMQDevice
 {
   protected:
+    auto Init() -> void override
+    {
+        std::this_thread::sleep_for(std::chrono::milliseconds(500));
+    }
+    
+    auto Reset() -> void override
+    {
+        std::this_thread::sleep_for(std::chrono::milliseconds(500));
+    }
+
     auto Run() -> void override
     {
         auto ready = FairMQMessagePtr{NewMessage()};
@@ -54,7 +66,7 @@ class Sub : public FairMQDevice
         {
             LOG(ERROR) << "Failed sending ready signal: r1 = " << r1;
         }
-    };
+    }
 };
 
 } // namespace test