51 size_t session{(size_t)getpid() * 1000};
52 fair::mq::ProgOptions config;
53 config.SetProperty<std::string>(
"session",
std::to_string(session));
55 auto factoryZMQ = fair::mq::TransportFactory::CreateTransportFactory(
"zeromq");
56 auto factorySHM = fair::mq::TransportFactory::CreateTransportFactory(
"shmem",
"transportallocatormap_test", &config);
57 auto allocZMQ = getTransportAllocator(factoryZMQ.get());
58 auto allocSHM = getTransportAllocator(factorySHM.get());
59 BOOST_CHECK(allocZMQ !=
nullptr && allocSHM != allocZMQ);
60 auto _tmp = getTransportAllocator(factoryZMQ.get());
66 size_t session{(size_t)getpid() * 1000 + 1};
67 fair::mq::ProgOptions config;
68 config.SetProperty<std::string>(
"session",
std::to_string(session));
70 auto factoryZMQ = fair::mq::TransportFactory::CreateTransportFactory(
"zeromq");
71 auto factorySHM = fair::mq::TransportFactory::CreateTransportFactory(
"shmem",
"allocator_test", &config);
72 auto allocZMQ = getTransportAllocator(factoryZMQ.get());
73 auto allocSHM = getTransportAllocator(factorySHM.get());
95 size_t session{(size_t)getpid() * 1000 + 2};
96 fair::mq::ProgOptions config;
97 config.SetProperty<std::string>(
"session",
std::to_string(session));
99 auto factoryZMQ = fair::mq::TransportFactory::CreateTransportFactory(
"zeromq");
100 auto factorySHM = fair::mq::TransportFactory::CreateTransportFactory(
"shmem",
"getMessage_test", &config);
101 auto allocZMQ = getTransportAllocator(factoryZMQ.get());
102 auto allocSHM = getTransportAllocator(factorySHM.get());
106 fair::mq::MessagePtr
message{
nullptr};
108 int* messageArray{
nullptr};
116 void* vectorBeginPtr = &
v[0];
122 messageArray =
static_cast<int*
>(
message->GetData());
123 BOOST_CHECK(messageArray[0] == 1 && messageArray[1] == 2 && messageArray[2] == 3);
131 void* vectorBeginPtr = &
v[0];
137 messageArray =
static_cast<int*
>(
message->GetData());
138 BOOST_CHECK(messageArray[0] == 4 && messageArray[1] == 5 && messageArray[2] == 6);