rpc_object_server_registry_intf.h

Go to the documentation of this file.

#pragma once
#include <adtfucom3/adtf_ucom3.h>
#include <adtfbase/rawmemory_intf.h>
#include <adtfbase/string_intf.h>
#include <rpc/rpc.h>

#define CID_ADTF_RPC_OBJECT_REGISTRY "rpc_object_registry.service.adtf.cid"
 
namespace adtf
{
namespace remote
{
namespace ant
{

class IRPCObjectServer : public ucom::ant::IObject
{
    protected:
        ~IRPCObjectServer() = default;
    public:
        ADTF_IID(IRPCObjectServer, "rpc_object_server.ant.services.adtf.iid");
    public:
        virtual tResult Receive(const base::ant::IRawMemory& oRequest,
                                base::ant::IRawMemory&& oResponse) = 0;
        virtual tResult GetRPCIID(base::ant::IString&& strIID) const = 0;
        virtual tResult GetRPCName(base::ant::IString&& strRPCName) const = 0;
        virtual tResult SetRPCName(const char* strRPCName) = 0;
};
 
}
 
namespace catwo
{

class IRPCInterfaceDefinition: public ucom::ant::IObject
{
    public:
        ADTF_IID(IRPCInterfaceDefinition, "rpc_interface_definition.catwo.services.adtf.iid");
 
    public:
        virtual tResult GetInterfaceDefinition(base::ant::IString&& strInterfaceDefinition) const = 0;
};
 
}
 
using ant::IRPCObjectServer;
using catwo::IRPCInterfaceDefinition;
 
}
 
namespace services
{
namespace ant
{
    class IRPCObjectServerRegistry : public ucom::ant::IObject
    {
        protected:
            ~IRPCObjectServerRegistry() = default;
        public:
            ADTF_IID(IRPCObjectServerRegistry, "rpc_object_server_registry.ant.services.adtf.iid");
 
        public:
            virtual tResult GetProtocol(base::ant::IString&& strProtocol) const = 0;

            virtual tResult GetRPCObjectServers(ucom::ant::iobject_enum<remote::ant::IRPCObjectServer>& lstObjects) const = 0;

            virtual tResult RegisterRPCObjectServer(const char* strObjectName,
                                                    const ucom::ant::iobject_ptr<remote::ant::IRPCObjectServer>& pObject) = 0;
            virtual tResult UnregisterRPCObjectServer(const char* strObjectName) = 0;

            virtual tResult StartListening() = 0;
            virtual tResult StopListening() = 0;
    };
}
 
namespace bat
{
 
class IRPCObjectServerRegistry: public ant::IRPCObjectServerRegistry
{
    public:
        ADTF_IID(IRPCObjectServerRegistry, "rpc_object_server_registry.bat.services.adtf.iid");
 
     public:
        using ant::IRPCObjectServerRegistry::StartListening;
        virtual tResult StartListening(const char* strURL) = 0;
};
 
}
 
namespace catwo
{
 
class IRPCObjectServerRegistry: public bat::IRPCObjectServerRegistry
{
    public:
        ADTF_IID(IRPCObjectServerRegistry, "rpc_object_server_registry.catwo.services.adtf.iid");
 
     public:
        virtual tResult RegisterRPCObject(const char* strObjectName,
                                          const adtf::ucom::ant::iobject_enum<adtf::remote::ant::IRPCObjectServer>& oInterfaceObjects) = 0;
 
        virtual tResult GetRPCObjectInterfaces(const char* strObjectName,
                                               adtf::ucom::ant::iobject_enum<adtf::remote::ant::IRPCObjectServer>& oInterfaceObjects) const = 0;
};
 
}
 
namespace lucky
{
    class IRPCObjectServerRegistry : public catwo::IRPCObjectServerRegistry
    {
    public:
        ADTF_IID(IRPCObjectServerRegistry, "rpc_object_server_registry.iron.services.adtf.iid");
 
    public:
        class IRPCServer
        {
        public:
            virtual tResult StartListening(const char* strURL) = 0;
            virtual tResult StopListening() = 0;
 
            virtual tResult RegisterRPCObject(const char* strName, rpc::IRPCObject* pObject) = 0;
            virtual tResult UnregisterRPCObject(const char* strName) = 0;
        };
        
 
        virtual tResult AddRPCServer(IRPCServer* pRPCServer) = 0;
    };
 
}
 
using lucky::IRPCObjectServerRegistry;
 
} //service
}