| | |
| | | T *Find(const std::string &name) { return find<T>(name.c_str()).first; } |
| | | }; |
| | | |
| | | template <class D> |
| | | using Allocator = allocator<D, SharedMemory::segment_manager>; |
| | | template <class D> |
| | | using Deleter = deleter<D, SharedMemory::segment_manager>; |
| | | template <class D> |
| | | using SharedPtr = shared_ptr<D, Allocator<void>, Deleter<D>>; |
| | | |
| | | // ShmObject manages an object in shared memory, but ShmObject itself is not in shared memory. |
| | | // works like a smart pointer of an object in shared memory. |
| | | // TODO handshake with center, and can be removed if killed. |
| | | template <class T> |
| | | class ShmObject : private boost::noncopyable |
| | | { |
| | |
| | | const Data *operator->() const { return data(); } |
| | | bool Remove() { return shm_.destroy<Data>(ObjName(name_).c_str()); } |
| | | }; |
| | | |
| | | template <class D> |
| | | using Allocator = allocator<D, SharedMemory::segment_manager>; |
| | | |
| | | } // namespace bhome_shm |
| | | |
| | |
| | | #include <boost/uuid/uuid_generators.hpp> |
| | | #include <boost/uuid/uuid_io.hpp> |
| | | |
| | | // TODO !!! add garbage collection, and handshake with gc-center. |
| | | // smart pointer will NOT work if user crash. |
| | | // problem of process release mq: client query success; server exits; client send. |
| | | // client query success; server exits; client send. |
| | | |
| | | namespace bhome_shm |
| | | { |
| | | using namespace bhome_msg; |
| | |
| | | |
| | | ShmMsgQueue::~ShmMsgQueue() |
| | | { |
| | | Remove(); |
| | | // It's not safe to remove, others may still holder pointers and write to it. |
| | | // TODO use smart_ptr or garbage collection. |
| | | //Remove(); |
| | | } |
| | | |
| | | bool ShmMsgQueue::Send(SharedMemory &shm, const MQId &remote_id, const MsgI &msg, const int timeout_ms, OnSend const &onsend) |