/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/adaptor/ |
H A D | object_callback_impl.cpp | 37 void ObjectRetrieveCallback::Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) in Completed() argument 39 callback_(results, allReady); in Completed() 48 void ObjectChangeCallback::Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) in Completed() argument 50 callback_(results, allReady); in Completed()
|
H A D | flat_object_store.cpp | 79 std::function<void(const std::map<std::string, std::vector<uint8_t>> &data, bool allReady)> callback = in ResumeObject() 81 const std::map<std::string, std::vector<uint8_t>> &data, bool allReady) { in ResumeObject() 86 LOG_INFO("retrieve success, data.size:%{public}zu, allReady:%{public}d", data.size(), allReady); in ResumeObject() 91 if (allReady) { in ResumeObject() 104 std::function<void(const std::map<std::string, std::vector<uint8_t>> &data, bool allReady)> remoteResumeCallback = in SubscribeDataChange() 105 [sessionId, this](const std::map<std::string, std::vector<uint8_t>> &data, bool allReady) { in SubscribeDataChange() 106 LOG_INFO("DataChange callback. data.size:%{public}zu, allReady:%{public}d", data.size(), allReady); in SubscribeDataChange() 116 if (allReady) { in SubscribeDataChange() [all...] |
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/ |
H A D | object_callback_stub.cpp | 81 bool allReady; in OnRemoteRequest() local 82 if (!ITypesUtil::Unmarshal(data, results, allReady)) { in OnRemoteRequest() 86 Completed(results, allReady); in OnRemoteRequest() 104 bool allReady; in OnRemoteRequest() local 105 if (!ITypesUtil::Unmarshal(data, results, allReady)) { in OnRemoteRequest() 109 Completed(results, allReady); in OnRemoteRequest()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
H A D | object_callback_proxy.cpp | 83 void ObjectRetrieveCallbackProxy::Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) in Completed() argument 91 if (!ITypesUtil::Marshal(data, results, allReady)) { in Completed() 102 void ObjectChangeCallbackProxy::Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) in Completed() argument 110 if (!ITypesUtil::Marshal(data, results, allReady)) { in Completed()
|
H A D | object_callback_proxy.h | 63 void Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) override; 78 void Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) override;
|
H A D | object_manager.cpp | 259 bool allReady = false;
in Retrieve() local 262 allReady = true;
in Retrieve() 265 restoreStatus_.ComputeIfPresent(objectKey, [&allReady](const auto &key, auto &value) {
in Retrieve() 267 allReady = true;
in Retrieve() 284 proxy->Completed(results, allReady);
in Retrieve() 285 if (allReady) {
in Retrieve() 634 const std::map<std::string, ObjectRecord>& data, bool allReady)
in DoNotify() 641 observer.second->Completed((*it).second, allReady);
in DoNotify() 642 if (allReady) {
in DoNotify() 656 const std::string& objectKey, bool allReady)
in DoNotifyAssetsReady() 633 DoNotify(uint32_t tokenId, const CallbackInfo& value, const std::map<std::string, ObjectRecord>& data, bool allReady) DoNotify() argument 655 DoNotifyAssetsReady(uint32_t tokenId, const CallbackInfo& value, const std::string& objectKey, bool allReady) DoNotifyAssetsReady() argument 662 observer.second->Completed(ObjectRecord(), allReady); DoNotifyAssetsReady() local [all...] |
H A D | object_manager.h | 167 bool allReady);
168 void DoNotifyAssetsReady(uint32_t tokenId, const CallbackInfo& value, const std::string& objectKey, bool allReady);
|
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/ |
H A D | object_callback.h | 41 virtual void Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) = 0; 46 virtual void Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) = 0;
|
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/include/adaptor/ |
H A D | object_callback_impl.h | 46 void Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) override; 56 void Completed(const std::map<std::string, std::vector<uint8_t>> &results, bool allReady) override;
|
H A D | flat_object_store.h | 44 std::function<void(const std::map<std::string, std::vector<uint8_t>> &data, bool allReady)> &callback); 46 std::function<void(const std::map<std::string, std::vector<uint8_t>> &data, bool allReady)> &callback);
|
/foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/test/unittest/src/ |
H A D | object_store_test.cpp | 1255 std::function<void(const std::map<std::string, std::vector<uint8_t>> &data, bool allReady)> callback = in HWTEST_F() 1256 [](const std::map<std::string, std::vector<uint8_t>> &data, bool allReady) {}; in HWTEST_F() 1271 std::function<void(const std::map<std::string, std::vector<uint8_t>> &data, bool allReady)> callback = in HWTEST_F() 1272 [](const std::map<std::string, std::vector<uint8_t>> &data, bool allReady) {}; in HWTEST_F()
|