50 size_t session{(size_t)getpid() * 1000};
51 fair::mq::ProgOptions config;
52 config.SetProperty<std::string>(
"session",
std::to_string(session));
54 auto factoryZMQ = fair::mq::TransportFactory::CreateTransportFactory(
"zeromq");
55 auto factorySHM = fair::mq::TransportFactory::CreateTransportFactory(
"shmem",
"transportallocatormap_test", &config);
56 auto allocZMQ = getTransportAllocator(factoryZMQ.get());
57 auto allocSHM = getTransportAllocator(factorySHM.get());
58 BOOST_CHECK(allocZMQ !=
nullptr && allocSHM != allocZMQ);
59 auto _tmp = getTransportAllocator(factoryZMQ.get());
67 size_t session{(size_t)getpid() * 1000 + 1};
68 fair::mq::ProgOptions config;
69 config.SetProperty<std::string>(
"session",
std::to_string(session));
71 auto factoryZMQ = fair::mq::TransportFactory::CreateTransportFactory(
"zeromq");
72 auto factorySHM = fair::mq::TransportFactory::CreateTransportFactory(
"shmem",
"allocator_test", &config);
73 auto allocZMQ = getTransportAllocator(factoryZMQ.get());
74 auto allocSHM = getTransportAllocator(factorySHM.get());
96 size_t session{(size_t)getpid() * 1000 + 2};
97 fair::mq::ProgOptions config;
98 config.SetProperty<std::string>(
"session",
std::to_string(session));
100 auto factoryZMQ = fair::mq::TransportFactory::CreateTransportFactory(
"zeromq");
101 auto factorySHM = fair::mq::TransportFactory::CreateTransportFactory(
"shmem",
"getMessage_test", &config);
102 auto allocZMQ = getTransportAllocator(factoryZMQ.get());
103 auto allocSHM = getTransportAllocator(factorySHM.get());
107 fair::mq::MessagePtr
message{
nullptr};
109 int* messageArray{
nullptr};
117 void* vectorBeginPtr = &
v[0];
123 messageArray =
static_cast<int*
>(
message->GetData());
124 BOOST_CHECK(messageArray[0] == 1 && messageArray[1] == 2 && messageArray[2] == 3);
132 void* vectorBeginPtr = &
v[0];
138 messageArray =
static_cast<int*
>(
message->GetData());
139 BOOST_CHECK(messageArray[0] == 4 && messageArray[1] == 5 && messageArray[2] == 6);