rpc_object_registry.h

Go to the documentation of this file.

 
#ifndef PKG_RPC_OBJECTSERVER_REGISTRY_H_INCLUDED
#define PKG_RPC_OBJECTSERVER_REGISTRY_H_INCLUDED
 
#include <a_util/concurrency/shared_mutex.h>
#include <a_util/result/result_type.h>
#include <rpc/rpc_server.h>
 
#include <map>
 
namespace rpc {

class cRPCObjectsRegistry : public IRPCObjectsRegistry {
public: // types
    typedef std::pair<std::unique_ptr<a_util::concurrency::shared_mutex>, IRPCObject*> tRPCItem;
 
public:
    virtual a_util::result::Result RegisterRPCObject(const char* strName, IRPCObject* pObject);

    virtual a_util::result::Result UnregisterRPCObject(const char* strName);

    class cLockedRPCObject final {
        typedef std::pair<a_util::concurrency::shared_mutex*, IRPCObject*> tRPCRawItem;
        tRPCRawItem m_oItem;
 
    public:
        cLockedRPCObject() = default;
        cLockedRPCObject(const tRPCItem& oItem);
        ~cLockedRPCObject();
        cLockedRPCObject(const cLockedRPCObject& other);
        cLockedRPCObject& operator=(const cLockedRPCObject& other);
        cLockedRPCObject(cLockedRPCObject&&) = default;
        cLockedRPCObject& operator=(cLockedRPCObject&&) = default;
        IRPCObject* operator->();
        operator bool() const;
    };

    virtual cLockedRPCObject GetRPCObject(const char* strName) const;
 
private:
    mutable a_util::concurrency::shared_mutex m_oObjectsLock;
    typedef std::map<std::string, tRPCItem> tRPCObjects;
    tRPCObjects m_oRPCObjects;
};
 
} // namespace rpc
 
#endif // PKG_RPC_OBJECTSERVER_REGISTRY_H_INCLUDED