| /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()
|