tweak startup and linger times

This commit is contained in:
Dennis Klein 2017-04-20 17:51:10 +02:00 committed by Mohammad Al-Turany
parent bbc8da54b4
commit f39b41d68c
6 changed files with 44 additions and 4 deletions

View File

@ -23,12 +23,12 @@ class Pub : public FairMQDevice
protected: protected:
auto Init() -> void override 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 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 auto Run() -> void override

View File

@ -21,6 +21,16 @@ using namespace std;
class Pull : public FairMQDevice class Pull : public FairMQDevice
{ {
protected: 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 Run() -> void override
{ {
auto msg = FairMQMessagePtr{NewMessage()}; auto msg = FairMQMessagePtr{NewMessage()};

View File

@ -18,6 +18,16 @@ namespace test
class Push : public FairMQDevice class Push : public FairMQDevice
{ {
protected: 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 Run() -> void override
{ {
auto msg = FairMQMessagePtr{NewMessage()}; auto msg = FairMQMessagePtr{NewMessage()};

View File

@ -19,6 +19,16 @@ namespace test
class Rep : public FairMQDevice class Rep : public FairMQDevice
{ {
protected: 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 Run() -> void override
{ {
auto request1 = FairMQMessagePtr{NewMessage()}; auto request1 = FairMQMessagePtr{NewMessage()};

View File

@ -19,6 +19,16 @@ namespace test
class Req : public FairMQDevice class Req : public FairMQDevice
{ {
protected: 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 Run() -> void override
{ {
auto request = FairMQMessagePtr{NewMessage()}; auto request = FairMQMessagePtr{NewMessage()};

View File

@ -23,12 +23,12 @@ class Sub : public FairMQDevice
protected: protected:
auto Init() -> void override 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 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 auto Run() -> void override