mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-13 00:31:14 +00:00
add startup and linger times for pubsub
This commit is contained in:
parent
541538e3de
commit
132ae69953
|
@ -11,6 +11,8 @@
|
||||||
|
|
||||||
#include <FairMQDevice.h>
|
#include <FairMQDevice.h>
|
||||||
#include <FairMQLogger.h>
|
#include <FairMQLogger.h>
|
||||||
|
#include <chrono>
|
||||||
|
#include <thread>
|
||||||
|
|
||||||
namespace fair
|
namespace fair
|
||||||
{
|
{
|
||||||
|
@ -22,6 +24,16 @@ namespace test
|
||||||
class Pub : public FairMQDevice
|
class Pub : public FairMQDevice
|
||||||
{
|
{
|
||||||
protected:
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto ready1 = FairMQMessagePtr{NewMessage()};
|
auto ready1 = FairMQMessagePtr{NewMessage()};
|
||||||
|
@ -60,7 +72,7 @@ class Pub : public FairMQDevice
|
||||||
{
|
{
|
||||||
LOG(ERROR) << "Failed receiving ready signal: r1 = " << r1 << ", r2 = " << r2;
|
LOG(ERROR) << "Failed receiving ready signal: r1 = " << r1 << ", r2 = " << r2;
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
} // namespace test
|
} // namespace test
|
||||||
|
|
|
@ -11,6 +11,8 @@
|
||||||
|
|
||||||
#include <FairMQDevice.h>
|
#include <FairMQDevice.h>
|
||||||
#include <FairMQLogger.h>
|
#include <FairMQLogger.h>
|
||||||
|
#include <chrono>
|
||||||
|
#include <thread>
|
||||||
|
|
||||||
namespace fair
|
namespace fair
|
||||||
{
|
{
|
||||||
|
@ -22,6 +24,16 @@ namespace test
|
||||||
class Sub : public FairMQDevice
|
class Sub : public FairMQDevice
|
||||||
{
|
{
|
||||||
protected:
|
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 Run() -> void override
|
||||||
{
|
{
|
||||||
auto ready = FairMQMessagePtr{NewMessage()};
|
auto ready = FairMQMessagePtr{NewMessage()};
|
||||||
|
@ -54,7 +66,7 @@ class Sub : public FairMQDevice
|
||||||
{
|
{
|
||||||
LOG(ERROR) << "Failed sending ready signal: r1 = " << r1;
|
LOG(ERROR) << "Failed sending ready signal: r1 = " << r1;
|
||||||
}
|
}
|
||||||
};
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
} // namespace test
|
} // namespace test
|
||||||
|
|
Loading…
Reference in New Issue
Block a user