mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-13 16:46:47 +00:00
Remove sleeps from tests that were helping broken linger
This commit is contained in:
parent
dfa1b68867
commit
2e7005225e
|
@ -35,11 +35,6 @@ class Receiver : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto msg = FairMQMessagePtr{NewMessage()};
|
auto msg = FairMQMessagePtr{NewMessage()};
|
||||||
|
|
|
@ -35,11 +35,6 @@ class Sender : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto msg = FairMQMessagePtr{NewMessage()};
|
auto msg = FairMQMessagePtr{NewMessage()};
|
||||||
|
|
|
@ -26,11 +26,6 @@ class PairLeft : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
int counter{0};
|
int counter{0};
|
||||||
|
|
|
@ -26,11 +26,6 @@ class PairRight : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
int counter{0};
|
int counter{0};
|
||||||
|
@ -45,7 +40,7 @@ class PairRight : public FairMQDevice
|
||||||
auto msg4(NewMessageFor("data", 0));
|
auto msg4(NewMessageFor("data", 0));
|
||||||
if (Send(msg4, "data") >= 0) counter++;
|
if (Send(msg4, "data") >= 0) counter++;
|
||||||
if (counter == 4) LOG(info) << "Simple empty message ping pong successfull";
|
if (counter == 4) LOG(info) << "Simple empty message ping pong successfull";
|
||||||
|
|
||||||
// Simple message with short text data
|
// Simple message with short text data
|
||||||
auto msg5(NewMessageFor("data", 0));
|
auto msg5(NewMessageFor("data", 0));
|
||||||
auto ret = Receive(msg5, "data");
|
auto ret = Receive(msg5, "data");
|
||||||
|
|
|
@ -33,11 +33,6 @@ class PollIn : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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
|
auto InitTask() -> void override
|
||||||
{
|
{
|
||||||
fPollType = fConfig->GetValue<int>("poll-type");
|
fPollType = fConfig->GetValue<int>("poll-type");
|
||||||
|
|
|
@ -24,11 +24,6 @@ class PollOut : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto msg1 = FairMQMessagePtr{NewMessage()};
|
auto msg1 = FairMQMessagePtr{NewMessage()};
|
||||||
|
|
|
@ -25,11 +25,6 @@ class Pub : public FairMQDevice
|
||||||
{
|
{
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
|
|
|
@ -27,11 +27,6 @@ class Pull : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto msg = FairMQMessagePtr{NewMessage()};
|
auto msg = FairMQMessagePtr{NewMessage()};
|
||||||
|
|
|
@ -24,11 +24,6 @@ class Push : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto msg = FairMQMessagePtr{NewMessage()};
|
auto msg = FairMQMessagePtr{NewMessage()};
|
||||||
|
|
|
@ -25,11 +25,6 @@ class Rep : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto request1 = FairMQMessagePtr{NewMessage()};
|
auto request1 = FairMQMessagePtr{NewMessage()};
|
||||||
|
|
|
@ -25,11 +25,6 @@ class Req : public FairMQDevice
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto request = FairMQMessagePtr{NewMessage()};
|
auto request = FairMQMessagePtr{NewMessage()};
|
||||||
|
|
|
@ -25,11 +25,6 @@ class Sub : public FairMQDevice
|
||||||
{
|
{
|
||||||
std::this_thread::sleep_for(std::chrono::milliseconds(200));
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in New Issue
Block a user