| | |
| | | */ |
| | | #include "defs.h" |
| | | #include "msg.h" |
| | | #include "shm_queue.h" |
| | | #include "shm_msg_queue.h" |
| | | |
| | | namespace |
| | | { |
| | |
| | | |
| | | } // namespace |
| | | |
| | | std::string BHomeShmName() |
| | | { |
| | | return "bhome_default_shm_v0"; |
| | | } |
| | | bhome_shm::SharedMemory &BHomeShm() |
| | | { |
| | | static bhome_shm::SharedMemory shm("bhome_default_shm_v0", 1024 * 1024 * 512); |
| | | static bhome_shm::SharedMemory shm(BHomeShmName(), 1024 * 1024 * 512); |
| | | return shm; |
| | | } |
| | | |
| | |
| | | MsgI::BindShm(shm); |
| | | typedef std::atomic<MQId> IdSrc; |
| | | IdSrc *psrc = shm.FindOrCreate<IdSrc>("shmqIdSrc0", 100000); |
| | | return ShmMsgQueue::SetData(*psrc); |
| | | return psrc && ShmMsgQueue::SetData(*psrc); |
| | | } |
| | | |
| | | void SetLastError(const int ec, const std::string &msg) |