oldbAdapter.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_OLDBADAPTER_HPP
#define RTCTK_COMPONENTFRAMEWORK_OLDBADAPTER_HPP
 
#include <rtctk/componentFramework/oldbIf.hpp>
 
#include <ciiOldb.hpp>
#include <ciiOldbSubscription.hpp>
#include <ciiOldbTypedDataBase.hpp>
 
namespace rtctk::componentFramework {
 
class OldbAdapter : public OldbIf {
public:
    inline static const std::string SUPPORTED_URI_SCHEME = "cii.oldb";
 
    OldbAdapter() = delete;
 
    OldbAdapter(const OldbAdapter&) = delete;
 
    OldbAdapter& operator=(const OldbAdapter&) = delete;
 
    OldbAdapter(OldbAdapter&&) = default;
 
    OldbAdapter& operator=(OldbAdapter&&) = default;
 
    explicit OldbAdapter(const elt::mal::Uri& baseuri);
 
    virtual ~OldbAdapter();
 
protected:
    BatchResponse ProcessRequests(const RequestList& requests) override;
 
    template <typename T>
    void CreateImpl(detail::CreateRequest<T>&);
 
    template <typename T>
    void WriteImpl(detail::WriteRequest<T>&);
 
    template <typename T>
    void ReadImpl(detail::ReadRequest<T>&);
 
    template <typename T>
    void PartialWriteImpl(detail::PartialWriteRequest<T>&);
 
    template <typename T>
    void PartialReadImpl(detail::PartialReadRequest<T>&);
 
    void WriteMetaDataImpl(detail::WriteMetaDataRequest&);
 
    void ReadMetaDataImpl(detail::ReadMetaDataRequest&);
 
    void DeleteImpl(detail::DeleteRequest&);
    void ExistsImpl(detail::ExistsRequest&);
    void GetChildrenImpl(detail::GetChildrenRequest&);
    void GetChildrenImplRecursive(const DataPointPath&, PathList&, PathList&, bool);
    void CreateLinkImpl(detail::CreateSymlinkRequest&);
 
    void UpdateLinkImpl(detail::UpdateSymlinkRequest&);
 
    void SubscribeImpl(detail::ValueSubscribeRequest&);
 
    void CreateDeleteSubscribeImpl(detail::CreateDeleteSubscribeRequest&);
 
    void UnsubscribeImpl(detail::UnsubscribeRequest&);
 
    virtual void InvokeRequestHandler(std::any&);
 
    template <typename T>
    void AddSubscription(detail::ValueSubscribeRequest&,
                         const std::shared_ptr<elt::oldb::CiiOldbTypedDataBase>&);
 
    const elt::mal::Uri m_baseuri;
 
    mutable std::shared_ptr<elt::oldb::CiiOldb> m_client;
 
    mutable std::mutex m_mutex;
 
    // data structures to hold active subscriptions
    struct SubscriptionEntry {
        std::shared_ptr<elt::oldb::CiiOldbTypedDataBase> dp;
        std::shared_ptr<elt::oldb::CiiOldbDpSubscriptionBase> sub;
        std::function<void(SubscriptionEntry&)> unreg_cb;
    };
    std::map<SubscriptionId, SubscriptionEntry> m_subscriptions;
 
    using DispatchFunction = std::function<void(OldbAdapter*, std::any&)>;
    using LookupTable = std::unordered_map<std::type_index, DispatchFunction>;
    using TableEntry = typename LookupTable::value_type;
 
    template <typename T>
    static TableEntry Bind(void (OldbAdapter::*method)(T&));
 
    static const LookupTable S_REQUEST_DISPATCHER_TABLE;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_OLDBADAPTER_HPP