From f39b41d68ca9b31c7f53a73fcea6f5336ec8b22d Mon Sep 17 00:00:00 2001 From: Dennis Klein Date: Thu, 20 Apr 2017 17:51:10 +0200 Subject: [PATCH] tweak startup and linger times --- fairmq/test/helper/devices/TestPub.cxx | 4 ++-- fairmq/test/helper/devices/TestPull.cxx | 10 ++++++++++ fairmq/test/helper/devices/TestPush.cxx | 10 ++++++++++ fairmq/test/helper/devices/TestRep.cxx | 10 ++++++++++ fairmq/test/helper/devices/TestReq.cxx | 10 ++++++++++ fairmq/test/helper/devices/TestSub.cxx | 4 ++-- 6 files changed, 44 insertions(+), 4 deletions(-) diff --git a/fairmq/test/helper/devices/TestPub.cxx b/fairmq/test/helper/devices/TestPub.cxx index 62cec1f9..796eee56 100644 --- a/fairmq/test/helper/devices/TestPub.cxx +++ b/fairmq/test/helper/devices/TestPub.cxx @@ -23,12 +23,12 @@ class Pub : public FairMQDevice protected: auto Init() -> void override { - std::this_thread::sleep_for(std::chrono::milliseconds(500)); + std::this_thread::sleep_for(std::chrono::milliseconds(200)); } auto Reset() -> void override { - std::this_thread::sleep_for(std::chrono::milliseconds(500)); + std::this_thread::sleep_for(std::chrono::milliseconds(100)); } auto Run() -> void override diff --git a/fairmq/test/helper/devices/TestPull.cxx b/fairmq/test/helper/devices/TestPull.cxx index 18256595..c7d7ad7b 100644 --- a/fairmq/test/helper/devices/TestPull.cxx +++ b/fairmq/test/helper/devices/TestPull.cxx @@ -21,6 +21,16 @@ using namespace std; class Pull : public FairMQDevice { protected: + auto Init() -> void override + { + std::this_thread::sleep_for(std::chrono::milliseconds(200)); + } + + auto Reset() -> void override + { + std::this_thread::sleep_for(std::chrono::milliseconds(100)); + } + auto Run() -> void override { auto msg = FairMQMessagePtr{NewMessage()}; diff --git a/fairmq/test/helper/devices/TestPush.cxx b/fairmq/test/helper/devices/TestPush.cxx index 0311af89..ef856432 100644 --- a/fairmq/test/helper/devices/TestPush.cxx +++ b/fairmq/test/helper/devices/TestPush.cxx @@ -18,6 +18,16 @@ namespace test class Push : public FairMQDevice { protected: + auto Init() -> void override + { + std::this_thread::sleep_for(std::chrono::milliseconds(200)); + } + + auto Reset() -> void override + { + std::this_thread::sleep_for(std::chrono::milliseconds(100)); + } + auto Run() -> void override { auto msg = FairMQMessagePtr{NewMessage()}; diff --git a/fairmq/test/helper/devices/TestRep.cxx b/fairmq/test/helper/devices/TestRep.cxx index 4444baa6..850533f1 100644 --- a/fairmq/test/helper/devices/TestRep.cxx +++ b/fairmq/test/helper/devices/TestRep.cxx @@ -19,6 +19,16 @@ namespace test class Rep : public FairMQDevice { protected: + auto Init() -> void override + { + std::this_thread::sleep_for(std::chrono::milliseconds(200)); + } + + auto Reset() -> void override + { + std::this_thread::sleep_for(std::chrono::milliseconds(100)); + } + auto Run() -> void override { auto request1 = FairMQMessagePtr{NewMessage()}; diff --git a/fairmq/test/helper/devices/TestReq.cxx b/fairmq/test/helper/devices/TestReq.cxx index b2eeb2f7..f507183a 100644 --- a/fairmq/test/helper/devices/TestReq.cxx +++ b/fairmq/test/helper/devices/TestReq.cxx @@ -19,6 +19,16 @@ namespace test class Req : public FairMQDevice { protected: + auto Init() -> void override + { + std::this_thread::sleep_for(std::chrono::milliseconds(200)); + } + + auto Reset() -> void override + { + std::this_thread::sleep_for(std::chrono::milliseconds(100)); + } + auto Run() -> void override { auto request = FairMQMessagePtr{NewMessage()}; diff --git a/fairmq/test/helper/devices/TestSub.cxx b/fairmq/test/helper/devices/TestSub.cxx index f6d574c6..56e25238 100644 --- a/fairmq/test/helper/devices/TestSub.cxx +++ b/fairmq/test/helper/devices/TestSub.cxx @@ -23,12 +23,12 @@ class Sub : public FairMQDevice protected: auto Init() -> void override { - std::this_thread::sleep_for(std::chrono::milliseconds(500)); + std::this_thread::sleep_for(std::chrono::milliseconds(200)); } auto Reset() -> void override { - std::this_thread::sleep_for(std::chrono::milliseconds(500)); + std::this_thread::sleep_for(std::chrono::milliseconds(100)); } auto Run() -> void override