From 2e7005225e13aa4ed396514e38b7ac60e8cebf8d Mon Sep 17 00:00:00 2001 From: Alexey Rybalchenko Date: Tue, 16 Oct 2018 11:19:08 +0200 Subject: [PATCH] Remove sleeps from tests that were helping broken linger --- test/device/TestReceiver.h | 5 ----- test/device/TestSender.h | 5 ----- test/helper/devices/TestPairLeft.cxx | 5 ----- test/helper/devices/TestPairRight.cxx | 7 +------ test/helper/devices/TestPollIn.cxx | 5 ----- test/helper/devices/TestPollOut.cxx | 5 ----- test/helper/devices/TestPub.cxx | 5 ----- test/helper/devices/TestPull.cxx | 5 ----- test/helper/devices/TestPush.cxx | 5 ----- test/helper/devices/TestRep.cxx | 5 ----- test/helper/devices/TestReq.cxx | 5 ----- test/helper/devices/TestSub.cxx | 5 ----- 12 files changed, 1 insertion(+), 61 deletions(-) diff --git a/test/device/TestReceiver.h b/test/device/TestReceiver.h index 6db57692..389b6b52 100644 --- a/test/device/TestReceiver.h +++ b/test/device/TestReceiver.h @@ -35,11 +35,6 @@ class Receiver : public FairMQDevice 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/test/device/TestSender.h b/test/device/TestSender.h index 4e4903e6..a8621c2f 100644 --- a/test/device/TestSender.h +++ b/test/device/TestSender.h @@ -35,11 +35,6 @@ class Sender : public FairMQDevice 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/test/helper/devices/TestPairLeft.cxx b/test/helper/devices/TestPairLeft.cxx index 60923ce0..f0045409 100644 --- a/test/helper/devices/TestPairLeft.cxx +++ b/test/helper/devices/TestPairLeft.cxx @@ -26,11 +26,6 @@ class PairLeft : public FairMQDevice 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 { int counter{0}; diff --git a/test/helper/devices/TestPairRight.cxx b/test/helper/devices/TestPairRight.cxx index 2771f083..73f264ab 100644 --- a/test/helper/devices/TestPairRight.cxx +++ b/test/helper/devices/TestPairRight.cxx @@ -26,11 +26,6 @@ class PairRight : public FairMQDevice 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 { int counter{0}; @@ -45,7 +40,7 @@ class PairRight : public FairMQDevice auto msg4(NewMessageFor("data", 0)); if (Send(msg4, "data") >= 0) counter++; if (counter == 4) LOG(info) << "Simple empty message ping pong successfull"; - + // Simple message with short text data auto msg5(NewMessageFor("data", 0)); auto ret = Receive(msg5, "data"); diff --git a/test/helper/devices/TestPollIn.cxx b/test/helper/devices/TestPollIn.cxx index a3f6f9ea..ce0c748a 100644 --- a/test/helper/devices/TestPollIn.cxx +++ b/test/helper/devices/TestPollIn.cxx @@ -33,11 +33,6 @@ class PollIn : public FairMQDevice std::this_thread::sleep_for(std::chrono::milliseconds(200)); } - auto Reset() -> void override - { - std::this_thread::sleep_for(std::chrono::milliseconds(100)); - } - auto InitTask() -> void override { fPollType = fConfig->GetValue("poll-type"); diff --git a/test/helper/devices/TestPollOut.cxx b/test/helper/devices/TestPollOut.cxx index 4c92cc69..f251230e 100644 --- a/test/helper/devices/TestPollOut.cxx +++ b/test/helper/devices/TestPollOut.cxx @@ -24,11 +24,6 @@ class PollOut : public FairMQDevice 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 msg1 = FairMQMessagePtr{NewMessage()}; diff --git a/test/helper/devices/TestPub.cxx b/test/helper/devices/TestPub.cxx index cf82da98..924f766d 100644 --- a/test/helper/devices/TestPub.cxx +++ b/test/helper/devices/TestPub.cxx @@ -25,11 +25,6 @@ class Pub : public FairMQDevice { 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 { diff --git a/test/helper/devices/TestPull.cxx b/test/helper/devices/TestPull.cxx index 503b8c13..cbe2ac5b 100644 --- a/test/helper/devices/TestPull.cxx +++ b/test/helper/devices/TestPull.cxx @@ -27,11 +27,6 @@ class Pull : public FairMQDevice 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/test/helper/devices/TestPush.cxx b/test/helper/devices/TestPush.cxx index e6e240ad..a899250e 100644 --- a/test/helper/devices/TestPush.cxx +++ b/test/helper/devices/TestPush.cxx @@ -24,11 +24,6 @@ class Push : public FairMQDevice 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/test/helper/devices/TestRep.cxx b/test/helper/devices/TestRep.cxx index f162d9db..88d21d49 100644 --- a/test/helper/devices/TestRep.cxx +++ b/test/helper/devices/TestRep.cxx @@ -25,11 +25,6 @@ class Rep : public FairMQDevice 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/test/helper/devices/TestReq.cxx b/test/helper/devices/TestReq.cxx index 44149a44..a558dae8 100644 --- a/test/helper/devices/TestReq.cxx +++ b/test/helper/devices/TestReq.cxx @@ -25,11 +25,6 @@ class Req : public FairMQDevice 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/test/helper/devices/TestSub.cxx b/test/helper/devices/TestSub.cxx index 81a5fd3e..121d349d 100644 --- a/test/helper/devices/TestSub.cxx +++ b/test/helper/devices/TestSub.cxx @@ -25,11 +25,6 @@ class Sub : public FairMQDevice { 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 {