interface_binding_object.h

Go to the documentation of this file.

 
#pragma once
#include "named_graph_object.h"
#include "interface_binding_server_intf.h"
#include "interface_binding_client_intf.h"
#include "interface_binding_proxy_intf.h"
#include "interface_binding_type.h"
 
namespace adtf
{
namespace streaming
{
namespace ant
{
 
class cBindingServer :
    public ucom::catwo::object<IBindingObject, named_graph_object<IBindingServer>>
{
    A_UTILS_D(cBindingServer)
 
    public:
        typedef std::pair<adtf::ucom::IObject, IBindingObject> iobject_resolve_type;
        typedef std::pair<INamedGraphObject, IBindingObject>   inamedgraphobject_resolve_type;
        UCOM_RESOLVE(inamedgraphobject_resolve_type, iobject_resolve_type);
 
        template <typename T>
        using iobject_ptr = adtf::ucom::ant::iobject_ptr < T >;
 
    protected:
        cBindingServer();
        cBindingServer(const char* strName);
 
    public:
 
        explicit cBindingServer(const char* strName,
                                const iobject_ptr<const IBindingType>& pBindingType,
                                const iobject_ptr<IObject>& pServerObject);
        ~cBindingServer();   
 
    public: //Implements IBindingObject
        tResult GetBindingType(iobject_ptr<const IBindingType>& pBindingType) const override;
        tResult GetServerObject(iobject_ptr<IObject>& ppServerObject) const override;
        tResult GetBindingProxy(iobject_ptr<IBindingProxy>& pBindingProxy) const override;
        tResult Unbind() override;
 
    public: //Implements adtf::IBindingServer
        tResult Bind(const iobject_ptr<IBindingProxy>& pBindingProxy) override;
 
    public: 
        tResult SetBindingType(const iobject_ptr<const IBindingType>& pBindingType);
        tResult SetServerObject(const iobject_ptr<IObject>& pServerObject);
 
};
 
 
class cBindingClient :
    public ucom::catwo::object<IBindingObject, named_graph_object<IBindingClient>>
{
    A_UTILS_D(cBindingClient)
 
    public:
        typedef std::pair<adtf::ucom::IObject, IBindingObject> iobject_resolve_type;
        typedef std::pair<INamedGraphObject, IBindingObject>   inamedgraphobject_resolve_type;
        UCOM_RESOLVE(inamedgraphobject_resolve_type, iobject_resolve_type);
 
 
    protected:
        cBindingClient();
 
    public:
 
        explicit cBindingClient(const char* strName,
                                const ucom::ant::iobject_ptr<const IBindingType>& pInterfaceType);
        ~cBindingClient();
 
    public: //Implements adtf::IBindingObject
        tResult GetBindingType(ucom::ant::iobject_ptr<const IBindingType>& pBindingType) const override;
        tResult GetServerObject(ucom::ant::iobject_ptr<ucom::ant::IObject>& pServerObject) const override;
        tResult GetBindingProxy(ucom::ant::iobject_ptr<IBindingProxy>& pBindingProxy) const override;
        tResult Unbind() override;
 
    public:
        tResult Bind(const ucom::ant::iobject_ptr<IBindingProxy>& pBindingProxy) override;
 
    public: 
        tResult SetBindingType(const ucom::ant::iobject_ptr<const IBindingType>& pBindingType);
        virtual tResult SetServerObject(const ucom::ant::iobject_ptr<ucom::ant::IObject>& pServerObject);
};
 
 
 
} // namespace ant
 
namespace elasto
{
 
class cWeakBindingServer:
    public ucom::catwo::object<ant::IBindingObject, ant::named_graph_object<ant::IBindingServer>>
{
    private:
        A_UTILS_D(cWeakBindingServer)
 
    public:
        cWeakBindingServer(const char* strName,
                           const ucom::ant::iobject_ptr<const ant::IBindingType>& pBindingType,
                           const ucom::ant::iobject_ptr<ucom::ant::IObject>& pServerObject);
 
        tResult GetBindingType(ucom::ant::iobject_ptr<const ant::IBindingType>& pBindingType) const override;
        tResult GetServerObject(ucom::ant::iobject_ptr<ucom::ant::IObject>& pServerObject) const override;
        tResult GetBindingProxy(ucom::ant::iobject_ptr<ant::IBindingProxy>& pBindingProxy) const override;
        tResult Unbind() override;
        tResult Bind(const ucom::ant::iobject_ptr<ant::IBindingProxy>& pBindingProxy) override;
 
    private:
        util::cString GetServerObjectName() const;
};
 
template <typename Interface, typename InterfaceBinding>
tResult create_weak_binding_server(InterfaceBinding& oInterfaceBinding,
                                   const char* strName,
                                   const ucom::ant::iobject_ptr<Interface>& pObject)
{
    ucom::object_ptr<IBindingServer> pServer =
            ucom::make_object_ptr<cWeakBindingServer>(strName,
                                                      ucom::ucom_object_ptr_cast<IBindingType>(ucom::make_object_ptr<streaming::ant::binding_type<Interface>>()),
                                                      ucom::ucom_object_ptr_cast<ucom::ant::IObject>(pObject));
    return oInterfaceBinding.RegisterBindingObject(pServer);
}
 
}
 
using ant::cBindingServer;
using ant::cBindingClient;
using elasto::cWeakBindingServer;
using elasto::create_weak_binding_server;
 
} // namespace streaming
} // namespace adtf