| | |
| | | #include "defs.h" |
| | | #include "util.h" |
| | | #include <atomic> |
| | | #include <boost/uuid/uuid_generators.hpp> |
| | | #include <boost/uuid/uuid_io.hpp> |
| | | #include <condition_variable> |
| | | #include <stdio.h> |
| | | #include <string> |
| | | #include <thread> |
| | | #include <vector> |
| | | |
| | | using namespace bhome_shm; |
| | | using namespace bhome_msg; |
| | | |
| | | SharedMemory &TestShm() |
| | | { |
| | | static SharedMemory shm("utest_0", 1024 * 1024 * 512); |
| | | return shm; |
| | | } |
| | | |
| | | template <class A, class B> |
| | | struct IsSameType { |
| | |
| | | |
| | | BOOST_AUTO_TEST_CASE(PubSubTest) |
| | | { |
| | | const std::string shm_name("ShmPubSub"); |
| | | ShmRemover auto_remove(shm_name); //remove twice? in case of killed? |
| | | SharedMemory shm(shm_name, 1024 * 1024 * 50); |
| | | DEFER1(shm.Remove()); |
| | | SharedMemory &shm = TestShm(); |
| | | MsgI::BindShm(shm); |
| | | |
| | | auto Avail = [&]() { return shm.get_free_memory(); }; |
| | | auto init_avail = Avail(); |
| | | int *flag = shm.find_or_construct<int>("flag")(123); |
| | | int *flag = shm.FindOrCreate<int>("flag", 123); |
| | | printf("flag = %d\n", *flag); |
| | | ++*flag; |
| | | const std::string sub_proc_id = "subscriber"; |
| | |
| | | |
| | | BOOST_AUTO_TEST_CASE(ReqRepTest) |
| | | { |
| | | const std::string shm_name("ShmReqRep"); |
| | | ShmRemover auto_remove(shm_name); |
| | | SharedMemory shm(shm_name, 1024 * 1024 * 512); |
| | | SharedMemory &shm = TestShm(); |
| | | MsgI::BindShm(shm); |
| | | |
| | | auto Avail = [&]() { return shm.get_free_memory(); }; |
| | | auto init_avail = Avail(); |
| | | int *flag = shm.find_or_construct<int>("flag")(123); |
| | | int *flag = shm.FindOrCreate<int>("flag", 123); |
| | | printf("flag = %d\n", *flag); |
| | | ++*flag; |
| | | |
| | |
| | | boost::timer::auto_cpu_timer timer; |
| | | for (int i = 0; i < nreq; ++i) { |
| | | std::string msg_id; |
| | | if (!client.ClientAsyncRequest(req, msg_id)) { |
| | | if (!client.ClientAsyncRequest(BHAddress(), req, msg_id)) { |
| | | printf("client request failed\n"); |
| | | ++count; |
| | | } |