diff --git a/test/message/_message.cxx b/test/message/_message.cxx index 4ff46fac6..d50c03119 100644 --- a/test/message/_message.cxx +++ b/test/message/_message.cxx @@ -50,7 +50,7 @@ auto RunPushPullWithMsgResize(string const & transport, string const & _address, Channel push{"Push", "push", factory}; Channel pull{"Pull", "pull", factory}; - auto const address(tools::ToString(_address, "_", transport)); + auto const address(tools::ToString(_address, "_", transport, "_", config.GetProperty("session"))); push.Bind(address); pull.Connect(address); @@ -153,7 +153,7 @@ auto RunPushPullWithAlignment(string const& transport, string const& _address, b Channel push{"Push", "push", factory}; Channel pull{"Pull", "pull", factory}; - auto const address(tools::ToString(_address, "_", transport)); + auto const address(tools::ToString(_address, "_", transport, "_", config.GetProperty("session"))); push.Bind(address); pull.Connect(address); @@ -211,7 +211,7 @@ auto EmptyMessage(string const& transport, string const& _address, bool expanded Channel push{"Push", "push", factory}; Channel pull{"Pull", "pull", factory}; - auto const address(tools::ToString(_address, "_", transport)); + auto const address(tools::ToString(_address, "_", transport, "_", config.GetProperty("session"))); push.Bind(address); pull.Connect(address); @@ -321,8 +321,8 @@ auto ZeroCopyFromUnmanaged(string const& address, bool expandedShmMetadata = fal Channel push("Push", "push", factory1); Channel pull("Pull", "pull", factory2); - push.Bind(address); - pull.Connect(address); + push.Bind(address + "_" + session); + pull.Connect(address + "_" + session); const size_t offset = 100; auto msg1(push.NewMessage(region, static_cast(region->GetData()), msgSize, nullptr)); diff --git a/test/protocols/_push_pull_multipart.cxx b/test/protocols/_push_pull_multipart.cxx index d8694e672..d98fe8dc9 100644 --- a/test/protocols/_push_pull_multipart.cxx +++ b/test/protocols/_push_pull_multipart.cxx @@ -35,6 +35,9 @@ auto RunSingleThreadedMultipart(string transport, string address1, string addres config.SetProperty("shm-metadata-msg-size", 2048); } + address1 += "_" + config.GetProperty("session"); + address2 += "_" + config.GetProperty("session"); + auto factory = TransportFactory::CreateTransportFactory(transport, tools::Uuid(), &config); Channel push1("Push1", "push", factory); @@ -118,6 +121,8 @@ auto RunMultiThreadedMultipart(string transport, string address1, bool expandedS config.SetProperty("shm-metadata-msg-size", 2048); } + address1 += "_" + config.GetProperty("session"); + auto factory = TransportFactory::CreateTransportFactory(transport, tools::Uuid(), &config); Channel push1("Push1", "push", factory);