X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=include%2Fprivate%2Fsyncstorageimpl.hpp;fp=include%2Fprivate%2Fsyncstorageimpl.hpp;h=b0f5fb534270b1b00d61864a35bbc662ef61641e;hb=d565df6613d97c08664a00f3fbc7cb5fdcf233f6;hp=735274f549f3dc0f855320f13c184cc3c18dab71;hpb=faf9fc79e58fa4ace9b0ef317b741afb2c1a8abe;p=ric-plt%2Fsdl.git diff --git a/include/private/syncstorageimpl.hpp b/include/private/syncstorageimpl.hpp index 735274f..b0f5fb5 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; @@ -75,12 +77,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);