Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 16:46:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

enable shmem tests

Browse Source
This commit is contained in:
Dennis Klein 2017-05-22 19:59:29 +02:00 committed by Mohammad Al-Turany
parent 8b93b4f8ed
commit 89423eb737
1 changed files with 22 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
fairmq/test/protocols/_push_pull_multipart.cxx
View File

@ -24,6 +24,7 @@ using namespace std;
auto RunSingleThreadedMultipart(string transport, string address) -> void { auto RunSingleThreadedMultipart(string transport, string address) -> void {
auto factory = FairMQTransportFactory::CreateTransportFactory(transport); auto factory = FairMQTransportFactory::CreateTransportFactory(transport);
factory->Initialize(nullptr);
auto push = FairMQChannel{"Push", "push", factory}; auto push = FairMQChannel{"Push", "push", factory};
ASSERT_TRUE(push.Bind(address)); ASSERT_TRUE(push.Bind(address));
auto pull = FairMQChannel{"Pull", "pull", factory}; auto pull = FairMQChannel{"Pull", "pull", factory};
@ -51,11 +52,14 @@ auto RunSingleThreadedMultipart(string transport, string address) -> void {
out << string{static_cast<char*>(part->GetData()), part->GetSize()}; out << string{static_cast<char*>(part->GetData()), part->GetSize()};
}); });
ASSERT_EQ(out.str(), "123"); ASSERT_EQ(out.str(), "123");
factory->Shutdown();
} }
auto RunMultiThreadedMultipart(string transport, string address) -> void auto RunMultiThreadedMultipart(string transport, string address) -> void
{ {
auto factory = FairMQTransportFactory::CreateTransportFactory(transport); auto factory = FairMQTransportFactory::CreateTransportFactory(transport);
factory->Initialize(nullptr);
auto push = FairMQChannel{"Push", "push", factory}; auto push = FairMQChannel{"Push", "push", factory};
ASSERT_TRUE(push.Bind(address)); ASSERT_TRUE(push.Bind(address));
auto pull = FairMQChannel{"Pull", "pull", factory}; auto pull = FairMQChannel{"Pull", "pull", factory};
@ -87,6 +91,8 @@ auto RunMultiThreadedMultipart(string transport, string address) -> void
pusher.join(); pusher.join();
puller.join(); puller.join();
factory->Shutdown();
} }
TEST(PushPull, ST_ZeroMQ__inproc_Multipart) TEST(PushPull, ST_ZeroMQ__inproc_Multipart)
@ -94,10 +100,10 @@ TEST(PushPull, ST_ZeroMQ__inproc_Multipart)
RunSingleThreadedMultipart("zeromq", "inproc://test"); RunSingleThreadedMultipart("zeromq", "inproc://test");
} }
//TEST(PushPull, ST_Shmem___inproc_Multipart) TEST(PushPull, ST_Shmem___inproc_Multipart)
//{ {
//RunSingleThreadedMultipart("shmem", "inproc://test"); RunSingleThreadedMultipart("shmem", "inproc://test");
//} }
#ifdef NANOMSG_FOUND #ifdef NANOMSG_FOUND
TEST(PushPull, ST_Nanomsg_inproc_Multipart) TEST(PushPull, ST_Nanomsg_inproc_Multipart)
@ -111,10 +117,10 @@ TEST(PushPull, ST_ZeroMQ__ipc____Multipart)
RunSingleThreadedMultipart("zeromq", "ipc://test"); RunSingleThreadedMultipart("zeromq", "ipc://test");
} }
//TEST(PushPull, ST_Shmen___ipc____Multipart) TEST(PushPull, ST_Shmen___ipc____Multipart)
//{ {
//RunSingleThreadedMultipart("shmem", "ipc://test"); RunSingleThreadedMultipart("shmem", "ipc://test");
//} }
#ifdef NANOMSG_FOUND #ifdef NANOMSG_FOUND
TEST(PushPull, ST_Nanomsg_ipc____Multipart) TEST(PushPull, ST_Nanomsg_ipc____Multipart)
@ -128,10 +134,10 @@ TEST(PushPull, MT_ZeroMQ__inproc_Multipart)
RunMultiThreadedMultipart("zeromq", "inproc://test"); RunMultiThreadedMultipart("zeromq", "inproc://test");
} }
//TEST(PushPull, MT_Shmem___inproc_Multipart) TEST(PushPull, MT_Shmem___inproc_Multipart)
//{ {
//RunMultiThreadedMultipart("shmem", "inproc://test"); RunMultiThreadedMultipart("shmem", "inproc://test");
//} }
#ifdef NANOMSG_FOUND #ifdef NANOMSG_FOUND
TEST(PushPull, MT_Nanomsg_inproc_Multipart) TEST(PushPull, MT_Nanomsg_inproc_Multipart)
@ -145,10 +151,10 @@ TEST(PushPull, MT_ZeroMQ__ipc____Multipart)
RunMultiThreadedMultipart("zeromq", "ipc://test"); RunMultiThreadedMultipart("zeromq", "ipc://test");
} }
//TEST(PushPull, MT_Shmem___ipc____Multipart) TEST(PushPull, MT_Shmem___ipc____Multipart)
//{ {
//RunMultiThreadedMultipart("shmem", "ipc://test"); RunMultiThreadedMultipart("shmem", "ipc://test");
//} }
#ifdef NANOMSG_FOUND #ifdef NANOMSG_FOUND
TEST(PushPull, MT_Nanomsg_ipc____Multipart) TEST(PushPull, MT_Nanomsg_ipc____Multipart)