mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-17 02:21:47 +00:00
@@ -41,6 +41,7 @@ void RunOptionsTest(const string& transport)
|
||||
{
|
||||
ProgOptions config;
|
||||
config.SetProperty<string>("session", tools::Uuid());
|
||||
config.SetProperty<bool>("shm-monitor", true);
|
||||
config.SetProperty<size_t>("shm-segment-size", 100000000);
|
||||
auto factory = TransportFactory::CreateTransportFactory(transport, tools::Uuid(), &config);
|
||||
Channel channel("Push", "push", factory);
|
||||
@@ -75,6 +76,7 @@ void ZeroingAndMlock(const string& transport)
|
||||
config.SetProperty<size_t>("shm-segment-size", 16384); // NOLINT
|
||||
config.SetProperty<bool>("shm-zero-segment", true);
|
||||
config.SetProperty<bool>("shm-mlock-segment", true);
|
||||
config.SetProperty<bool>("shm-monitor", true);
|
||||
|
||||
auto factory = TransportFactory::CreateTransportFactory(transport, tools::Uuid(), &config);
|
||||
|
||||
@@ -93,6 +95,7 @@ void ZeroingAndMlockOnCreation(const string& transport)
|
||||
config.SetProperty<size_t>("shm-segment-size", 16384); // NOLINT
|
||||
config.SetProperty<bool>("shm-mlock-segment-on-creation", true);
|
||||
config.SetProperty<bool>("shm-zero-segment-on-creation", true);
|
||||
config.SetProperty<bool>("shm-monitor", true);
|
||||
|
||||
auto factory = TransportFactory::CreateTransportFactory(transport, tools::Uuid(), &config);
|
||||
|
||||
|
@@ -26,6 +26,7 @@ void GetFreeMemory()
|
||||
ProgOptions config;
|
||||
string sessionId(to_string(tools::UuidHash()));
|
||||
config.SetProperty<string>("session", sessionId);
|
||||
config.SetProperty<bool>("shm-monitor", true);
|
||||
|
||||
ASSERT_THROW(shmem::Monitor::GetFreeMemory(shmem::SessionId{sessionId}, 0), shmem::Monitor::MonitorError);
|
||||
|
||||
|
@@ -52,6 +52,7 @@ auto RunTransferTimeout(string transport) -> void
|
||||
<< " --control static"
|
||||
<< " --shm-segment-size 100000000"
|
||||
<< " --severity debug"
|
||||
<< " --shm-monitor true"
|
||||
<< " --transport " << transport
|
||||
<< " --session " << session
|
||||
<< " --color false"
|
||||
@@ -75,6 +76,7 @@ void InterruptTransfer(const string& transport, const string& _address)
|
||||
fair::mq::ProgOptions config;
|
||||
config.SetProperty<string>("session", to_string(session));
|
||||
config.SetProperty<size_t>("shm-segment-size", 100000000);
|
||||
config.SetProperty<bool>("shm-monitor", true);
|
||||
|
||||
auto factory = TransportFactory::CreateTransportFactory(transport, Uuid(), &config);
|
||||
|
||||
|
Reference in New Issue
Block a user