| | |
| | | #include <boost/interprocess/sync/interprocess_mutex.hpp> |
| | | #include <boost/interprocess/sync/scoped_lock.hpp> |
| | | #include <boost/noncopyable.hpp> |
| | | #include <boost/uuid/uuid.hpp> |
| | | #include <chrono> |
| | | #include <thread> |
| | | |
| | |
| | | ~SharedMemory(); |
| | | std::string name() const { return name_; } |
| | | bool Remove() { return Remove(name()); } |
| | | |
| | | template <class T, class... Params> |
| | | T *FindOrCreate(const std::string &name, Params &&...params) |
| | | { |
| | | return find_or_construct<T>(name.c_str(), std::nothrow)(std::forward<decltype(params)>(params)...); |
| | | } |
| | | template <class T, class... Params> |
| | | T *Create(const std::string &name, Params &&...params) |
| | | { |
| | | return construct<T>(name.c_str(), std::nothrow)(std::forward<decltype(params)>(params)...); |
| | | } |
| | | void *Alloc(const size_t size) { return allocate(size, std::nothrow); } |
| | | void Dealloc(void *p) |
| | | { |
| | |
| | | void Dealloc(offset_ptr<T> ptr) { return Dealloc(ptr.get()); } |
| | | |
| | | template <class T, class... Params> |
| | | T *New(Params const &...params) { return construct<T>(anonymous_instance, std::nothrow)(params...); } |
| | | T *New(Params &&...params) { return construct<T>(anonymous_instance, std::nothrow)(std::forward<decltype(params)>(params)...); } |
| | | template <class T> |
| | | void Delete(T *p) |
| | | { |
| | |
| | | ShmObject(ShmType &segment, const std::string &name, Params &&...t) : |
| | | shm_(segment), name_(name) |
| | | { |
| | | pdata_ = shm_.find_or_construct<Data>(ObjName(name_).c_str(), std::nothrow)(t...); |
| | | pdata_ = shm_.Create<Data>(ObjName(name_), std::forward<decltype(t)>(t)...); |
| | | if (!IsOk()) { |
| | | throw("Error: Not enough memory, can not allocate \"" + name_ + "\""); |
| | | } |