X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=include%2Fprivate%2Fsyncstorageimpl.hpp;h=f67009d7bdb2f02ff935fc44b069f0c41263a6d7;hb=63869e10ac4d8572238989e1b582c0314da91f9c;hp=735274f549f3dc0f855320f13c184cc3c18dab71;hpb=faf9fc79e58fa4ace9b0ef317b741afb2c1a8abe;p=ric-plt%2Fsdl.git diff --git a/include/private/syncstorageimpl.hpp b/include/private/syncstorageimpl.hpp index 735274f..f67009d 100644 --- a/include/private/syncstorageimpl.hpp +++ b/include/private/syncstorageimpl.hpp @@ -39,6 +39,8 @@ namespace shareddatalayer SyncStorageImpl(std::unique_ptr asyncStorage, System& system); + virtual void waitReady(const Namespace& ns, const std::chrono::steady_clock::duration& timeout) override; + virtual void set(const Namespace& ns, const DataMap& dataMap) override; virtual bool setIf(const Namespace& ns, const Key& key, const Data& oldData, const Data& newData) override; @@ -53,6 +55,8 @@ namespace shareddatalayer virtual Keys findKeys(const Namespace& ns, const std::string& keyPrefix) override; + virtual Keys listKeys(const Namespace& ns, const std::string& pattern) override; + virtual void removeAll(const Namespace& ns) override; virtual void setOperationTimeout(const std::chrono::steady_clock::duration& timeout) override; @@ -75,12 +79,14 @@ namespace shareddatalayer void pollAndHandleEvents(int timeout_ms); - void waitForReadinessCheckCallback(); + void waitForReadinessCheckCallback(const std::chrono::steady_clock::duration& timeout); void waitForOperationCallback(); void waitSdlToBeReady(const Namespace& ns); + void waitSdlToBeReady(const Namespace& ns, const std::chrono::steady_clock::duration& timeout); + void waitReadyAck(const std::error_code& error); void modifyAck(const std::error_code& error);