|
| template<typename T > |
| using | ValueCallbackType = std::function<void(const DataPointPath&, T&, const MetaData&)> |
| |
| using | NotifyCallbackType = std::function<void(const DataPointPath&, const MetaData&)> |
| |
| using | ErrorCallbackType = std::function<void(std::exception_ptr)> |
| |
| using | SubscriptionId = size_t |
| |
| using | PathList = std::vector<DataPointPath> |
| |
| using | Clock = taiclock::TaiClock |
| |
| using | Timestamp = Clock::time_point |
| |
| using | CallbackType = std::function<void(const DataPointPath&)> |
| | Signature of the callback functions that can be registered with the repository requests.
|
| |
| using | AdapterIdType = elt::mal::Uri |
| | The type used to distinguish between different adapters implementing OldbIf.
|
| |
| | FakeRepositorySubscriber ()=default |
| |
| virtual | ~FakeRepositorySubscriber ()=default |
| |
| template<typename T > |
| Lut::TableEntries | BindTypeHandlers () |
| |
| | RepositorySubscriberIf ()=default |
| |
| virtual | ~RepositorySubscriberIf ()=default |
| |
| template<typename T = void, typename F , std::enable_if_t< std::is_convertible_v< F, NotifyCallbackType > or(not std::is_same_v< T, void > and std::is_convertible_v< F, ValueCallbackType< std::conditional_t< std::is_same_v< T, void >, std::byte, T > > >), bool > = true> |
| Subscription | Subscribe (const DataPointPath &path, const F &cb_value, const ErrorCallbackType &cb_error) const |
| | Subscribes to datapoint values change events by registering callbacks.
|
| |
| Subscription | Subscribe (const CallbackType &cb_created, const CallbackType &cb_deleted, const ErrorCallbackType &cb_error) const |
| | Subscribes to datapoint creation and deletion events by registering callbacks.
|
| |
| virtual RepositoryIf::Response | SendSubscribeRequest (const SubscribeRequest &request) const |
| | This is called to asynchronously send a subscription request for datapoints.
|
| |
| virtual RepositoryIf::Response | SendUnsubscribeRequest (const UnsubscribeRequest &request) const |
| | This is called to asynchronously send a request to unsubscribe from various notifications.
|
| |
| template<typename T , typename F , std::enable_if_t< not std::is_convertible_v< T, RepositorySubscriberIf::NotifyCallbackType >, bool > = true> |
| void | Subscribe (const DataPointPath &path, T &buffer, F handler) const |
| | A convenience template function that will register a callback to receive new datapoint values in a synchronous manner.
|
| |
| template<typename F > |
| void | Subscribe (const DataPointPath &path, F handler) const |
| | A convenience template function that will register a callback to receive datapoint value change notifications in a synchronous manner.
|
| |
| void | Unsubscribe (const DataPointPath &path) const |
| | A simple convenience function that will deregister all callbacks for receiving new datapoint values.
|
| |
| | RepositoryIf ()=default |
| |
| virtual | ~RepositoryIf ()=default |
| |
| BatchResponse | SendRequest (const BatchRequest &request) |
| |
| BatchResponse | SendRequest (const BatchRequest &request) const |
| |
| template<typename T > |
| void | CreateDataPoint (const DataPointPath &path) |
| | Creates a new datapoint in the repository.
|
| |
| template<typename T > |
| void | CreateDataPoint (const DataPointPath &path, const T &initial_value) |
| | Creates a new datapoint in the repository with an initial value.
|
| |
| void | CreateDataPoint (const DataPointPath &path, const char *initial_value) |
| |
| void | DeleteDataPoint (const DataPointPath &path, bool recurse=false) |
| | Deletes a datapoint.
|
| |
| const std::type_info & | GetDataPointType (const DataPointPath &path) const |
| | Fetches the type of the datapoint.
|
| |
| size_t | GetDataPointSize (const DataPointPath &path) const |
| | Fetches the size of the datapoint's data.
|
| |
| RtcVectorUInt64 | GetDataPointShape (const DataPointPath &path) const |
| | Fetches the shape of the datapoint's data.
|
| |
| bool | DataPointExists (const DataPointPath &path) const |
| | Checks for the existence of a datapoint in the repository.
|
| |
| std::pair< PathList, PathList > | GetChildren (const DataPointPath &path, bool recurse=false) const |
| | Queries the child datapoints and paths for a given parent path.
|
| |
| template<typename T > |
| T | GetDataPoint (const DataPointPath &path) const |
| | Fetches a datapoint from the repository.
|
| |
| template<typename T > |
| void | SetDataPoint (const DataPointPath &path, const T &value) |
| | Sets a datapoint in the repository.
|
| |
| void | SetDataPoint (const DataPointPath &path, const char *value) |
| |
| template<typename T > |
| void | ReadDataPoint (const DataPointPath &path, T &buffer) const |
| | Reads a datapoint from the repository.
|
| |
| template<typename T > |
| void | WriteDataPoint (const DataPointPath &path, const T &buffer) |
| | Writes a datapoint to the repository.
|
| |
| void | WriteDataPoint (const DataPointPath &path, const char *buffer) |
| |
| template<typename... T> |
| void | WriteDataPoints (const T &... args) |
| |
| template<typename... T> |
| void | ReadDataPoints (T &... args) const |
| |
| virtual void | CreateDataPoint (const DataPointPath &path, const std::type_info &type) |
| | Creates a new datapoint in the repository with a specified type.
|
| |
| virtual Response | SendReadRequest (const ReadRequest &request) const |
| | Sends a request to read data from the repository.
|
| |
| virtual Response | SendWriteRequest (const WriteRequest &request) |
| | Sends a request to write data to the repository.
|
| |
| | FakeRepository () |
| |
| virtual | ~FakeRepository () |
| |
| template<typename T > |
| Lut::TableEntries | BindTypeHandlers () |
| |
| virtual | ~OldbIf ()=default |
| |
| static const std::type_info & | StringToType (const std::string &arg) |
| | Converts an RTC type string to a type_info.
|
| |
| static std::string | TypeToString (const std::type_info &arg) |
| | Converts a type_info to an RTC type string.
|
| |
| static std::unique_ptr< OldbIf > | CreateAdapter (const elt::mal::Uri &uri) |
| | Factory method used to create the appropriate OLDB adapter depending on the URI scheme.
|
| |
| using | RequestList = std::vector<std::any> |
| |
| template<typename T > |
| void | CreateImpl (detail::CreateRequest< T > &req) |
| |
| template<typename T > |
| void | ReadImpl (detail::ReadRequest< T > &req) |
| |
| template<typename T > |
| void | WriteImpl (detail::WriteRequest< T > &req) |
| |
| template<typename T > |
| void | PartialReadImpl (detail::PartialReadRequest< T > &req) |
| |
| template<typename T > |
| void | PartialWriteImpl (detail::PartialWriteRequest< T > &req) |
| |
| void | ReadMetaDataImpl (detail::ReadMetaDataRequest &req) |
| |
| void | WriteMetaDataImpl (detail::WriteMetaDataRequest &req) |
| |
| void | DeleteImpl (detail::DeleteRequest &req) |
| |
| void | ExistsImpl (detail::ExistsRequest &req) |
| |
| void | GetChildrenImpl (detail::GetChildrenRequest &req) |
| |
| void | CreateLinkImpl (detail::CreateSymlinkRequest &req) |
| |
| void | UpdateLinkImpl (detail::UpdateSymlinkRequest &req) |
| |
| void | SubscribeImpl (detail::ValueSubscribeRequest &req) |
| |
| void | CreateDeleteSubscribeImpl (detail::CreateDeleteSubscribeRequest &req) |
| |
| void | UnsubscribeImpl (detail::UnsubscribeRequest &req) |
| |
| void | InvokeRequestHandler (std::any &request) override |
| |
| void | InvokeCreateCallbacks (const DataPointPath &) |
| |
| void | InvokeDeleteCallbacks (const DataPointPath &) |
| |
| void | InvokeWriteCallbacks (const DataPointPath &) |
| |
| virtual void | DeleteDataPointLegacy (const DataPointPath &path) |
| | Deletes a datapoint.
|
| |
| virtual const std::type_info & | GetDataPointTypeLegacy (const DataPointPath &path) const |
| | Fetches the type of the datapoint.
|
| |
| virtual size_t | GetDataPointSizeLegacy (const DataPointPath &path) const |
| | Fetches the size of the datapoint's data.
|
| |
| virtual bool | DataPointExistsLegacy (const DataPointPath &path) const |
| | Checks for the existence of a datapoint in the repository.
|
| |
| virtual std::pair< PathList, PathList > | GetChildrenLegacy (const DataPointPath &path) const |
| | Queries the datapoints and child paths for a given path.
|
| |
| template<typename T > |
| void | CreateImpl (detail::CreateRequest< T > &req) |
| |
| template<typename T > |
| void | ReadImpl (detail::ReadRequest< T > &req) |
| |
| template<typename T > |
| void | WriteImpl (detail::WriteRequest< T > &req) |
| |
| template<typename T > |
| void | PartialReadImpl (detail::PartialReadRequest< T > &req) |
| |
| template<typename T > |
| void | PartialWriteImpl (detail::PartialWriteRequest< T > &req) |
| |
| void | ReadMetaDataImpl (detail::ReadMetaDataRequest &req) |
| |
| void | WriteMetaDataImpl (detail::WriteMetaDataRequest &req) |
| |
| void | DeleteImpl (detail::DeleteRequest &req) |
| |
| void | ExistsImpl (detail::ExistsRequest &req) |
| |
| std::pair< PathList, PathList > | GetChildrenImpl (const DataPointPath &path) |
| |
| std::pair< PathList, PathList > | GetChildrenRecursive (const DataPointPath &path) |
| |
| void | GetChildrenImpl (detail::GetChildrenRequest &req) |
| |
| void | CreateLinkImpl (detail::CreateSymlinkRequest &req) |
| |
| void | UpdateLinkImpl (detail::UpdateSymlinkRequest &req) |
| |
| template<typename Request > |
| void | InvokeCallback (const Request &req) const |
| |
| template<typename T > |
| void | ReadData (Data &data_node, const DataPointPath &path, gsl::span< T > &data, std::optional< std::reference_wrapper< MetaData > > &metadata, size_t offset) |
| |
| template<typename T > |
| void | WriteData (const DataPointPath &path, const gsl::span< const T > &data, const MetaData &metadata, size_t offset) |
| |
| void | ReadMetaData (const DataPointPath &path, MetaData &metadata, bool check_sequence_id=false) |
| |
| void | WriteMetaData (Data &data_node, const MetaData &metadata) |
| |
| DataPointPath | ResolvePath (const DataPointPath &path) |
| |
| Data & | CreateNewDataNode (const DataPointPath &path) |
| |
| Data & | GetDataNode (const DataPointPath &path) |
| |
| void | CheckDataNodeExists (const DataPointPath &path) |
| |
| BatchResponse | ProcessRequests (const RequestList &requests) override |
| |
| template<typename T > |
| static RequestDispatcher< FakeRepositorySubscriber >::TableEntries | BindTypeHandlers () |
| |
| template<typename T > |
| static RequestDispatcher< FakeRepository >::TableEntries | BindTypeHandlers () |
| |
| std::list< ValueSubscription > | m_value_subscriptions |
| |
| std::list< CreateDeleteSubscription > | m_create_delete_subscriptions |
| |
| std::mutex | m_mutex |
| | Mutex for synchronising access to m_data.
|
| |
| std::map< DataPointPath, Data > | m_data |
| |
| static const RequestDispatcher< FakeRepositorySubscriber > | S_REQUEST_DISPATCHER |
| |
| static const RequestDispatcher< FakeRepository > | S_REQUEST_DISPATCHER |
| |
Implementation of a fake of OldbIf for testing.