/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
H A D | single_kvstore.h | 170 * @param syncCallback The callback will be called when sync finished. 174 std::shared_ptr<KvStoreSyncCallback> syncCallback) in Sync() 176 return Sync(devices, mode, query, syncCallback, 0); in Sync() 191 * @param syncCallback The callback will be called when sync finished. 195 std::shared_ptr<KvStoreSyncCallback> syncCallback, uint32_t delay) in Sync() 173 Sync(const std::vector<std::string> &devices, SyncMode mode, const DataQuery &query, std::shared_ptr<KvStoreSyncCallback> syncCallback) Sync() argument 194 Sync(const std::vector<std::string> &devices, SyncMode mode, const DataQuery &query, std::shared_ptr<KvStoreSyncCallback> syncCallback, uint32_t delay) Sync() argument
|
/foundation/deviceprofile/device_info_manager/old/services/core/test/unittest/ |
H A D | profile_storage_test.cpp | 719 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback = nullptr; in HWTEST_F() local 720 int32_t res = onlineSyncTbl_->RegisterSyncCallback(syncCallback); in HWTEST_F() 733 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback = in HWTEST_F() local 735 int32_t res = onlineSyncTbl_->RegisterSyncCallback(syncCallback); in HWTEST_F() 852 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback = in HWTEST_F() local 854 int32_t res = onlineSyncTbl_->RegisterSyncCallback(syncCallback); in HWTEST_F() 868 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback = nullptr; in HWTEST_F() local 869 int32_t res = onlineSyncTbl_->RegisterSyncCallback(syncCallback); in HWTEST_F() 1048 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback = in HWTEST_F() local 1054 onlineSyncTblTest_->syncCallback_ = syncCallback; in HWTEST_F() 1307 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback = HWTEST_F() local 1335 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback = HWTEST_F() local 1424 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback = HWTEST_F() local [all...] |
/foundation/arkui/ace_engine/frameworks/core/components_ng/render/adapter/ |
H A D | component_snapshot.cpp | 411 auto syncCallback = std::make_shared<SyncCustomizedCallback>(); in GetSync() local 416 rsInterface.TakeSurfaceCaptureForUI(rsNode, syncCallback, in GetSync() 418 return syncCallback->GetPixelMap(SNAPSHOT_TIMEOUT_DURATION); in GetSync() 463 auto syncCallback = std::make_shared<SyncCustomizedCallback>(); in CreateSync() local 464 rsInterface.TakeSurfaceCaptureForUI(rsNode, syncCallback, 1.f, 1.f, true); in CreateSync() 465 auto pair = syncCallback->GetPixelMap(CREATE_SNAPSHOT_TIMEOUT_DURATION); in CreateSync()
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/mission/ |
H A D | dsched_sync_e2e.cpp | 258 std::shared_ptr<DmsKvSyncCB> syncCallback = std::make_shared<DmsKvSyncCB>();
in PushAndPullData() local 259 Status status = kvStorePtr_->Sync(networkIdList, DistributedKv::SyncMode::PUSH_PULL, dataQuery, syncCallback);
in PushAndPullData() 283 std::shared_ptr<DmsKvSyncCB> syncCallback = std::make_shared<DmsKvSyncCB>();
in PushAndPullData() local 284 Status status = kvStorePtr_->Sync(networkIdList, DistributedKv::SyncMode::PUSH_PULL, dataQuery, syncCallback);
in PushAndPullData()
|
/foundation/distributeddatamgr/kv_store/test/distributedtest/single_kvstore_client/ |
H A D | distributed_test.cpp | 110 std::shared_ptr<KvStoreSyncCallback> syncCallback = std::make_shared<KvStoreSyncCallbackTestImpl>();
in SetUpTestCase() local 111 status = singleKvStore_->RegisterSyncCallback(syncCallback);
in SetUpTestCase()
|
H A D | distributed_test_agent.cpp | 125 std::shared_ptr<KvStoreSyncCallback> syncCallback = std::make_shared<KvStoreSyncCallbackTestImpl>();
in SetUp() local 126 status = singleKvStore_->RegisterSyncCallback(syncCallback);
in SetUp()
|
/foundation/bundlemanager/distributed_bundle_framework/services/dbms/src/ |
H A D | distributed_data_storage.cpp | 318 std::shared_ptr<DistributedDataStorageCallback> syncCallback = std::make_shared<DistributedDataStorageCallback>(); in SyncAndCompleted() local 319 syncCallback->setUuid(uuid); in SyncAndCompleted() 320 Status status = kvStorePtr_->Sync(networkIdList, DistributedKv::SyncMode::PUSH_PULL, dataQuery, syncCallback); in SyncAndCompleted() 326 Status statusResult = syncCallback->GetResultCode(); in SyncAndCompleted()
|
/foundation/deviceprofile/device_info_manager/services/core/test/unittest/ |
H A D | dp_profile_service_test.cpp | 286 sptr<IRemoteObject> syncCallback = nullptr; in HWTEST_F() local 287 int32_t ret = DistributedDeviceProfileServiceNew::GetInstance().SyncDeviceProfile(syncOptions, syncCallback); in HWTEST_F()
|
/foundation/ability/form_fwk/test/mock/include/ |
H A D | mock_single_kv_store.h | 93 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback) override
|
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/include/ |
H A D | single_store_impl.h | 73 std::shared_ptr<SyncCallback> syncCallback, uint32_t delay) override;
|
/foundation/distributeddatamgr/kv_store/test/fuzztest/devicekvstore_fuzzer/ |
H A D | devicekvstore_fuzzer.cpp | 168 auto syncCallback = std::make_shared<DeviceSyncCallbackTestImpl>(); in SyncCallbackFuzz() local 169 deviceKvStore_->RegisterSyncCallback(syncCallback); in SyncCallbackFuzz() 181 syncCallback->SyncCompleted(results); in SyncCallbackFuzz()
|
/foundation/distributeddatamgr/kv_store/test/fuzztest/singlekvstore_fuzzer/ |
H A D | singlekvstore_fuzzer.cpp | 188 auto syncCallback = std::make_shared<DeviceSyncCallbackTestImpl>(); in SyncCallbackFuzz() local 189 singleKvStore_->RegisterSyncCallback(syncCallback); in SyncCallbackFuzz() 201 syncCallback->SyncCompleted(results); in SyncCallbackFuzz()
|
/foundation/ability/ability_runtime/test/mock/common/include/ |
H A D | mock_single_kv_store.h | 90 std::shared_ptr<DistributedKv::KvStoreSyncCallback> syncCallback) override
|
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
H A D | single_store_impl.h | 89 std::shared_ptr<SyncCallback> syncCallback, uint32_t delay) override;
|
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/test/unittest/ |
H A D | single_kvstore_client_test.cpp | 337 auto syncCallback = std::make_shared<KvStoreSyncCallbackTestImpl>(); in HWTEST_F() local 338 auto syncStatus = singleKvStore->RegisterSyncCallback(syncCallback); in HWTEST_F() 351 syncCallback->SyncCompleted(results); in HWTEST_F()
|
H A D | device_kvstore_test.cpp | 449 auto syncCallback = std::make_shared<DeviceSyncCallbackTestImpl>(); in HWTEST_F() local 450 auto syncStatus = kvStore_->RegisterSyncCallback(syncCallback); in HWTEST_F() 463 syncCallback->SyncCompleted(results); in HWTEST_F()
|
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/innerkitsimpl/kvdb/src/ |
H A D | single_store_impl.cpp | 441 std::shared_ptr<SyncCallback> syncCallback, uint32_t delay) in Sync() 440 Sync(const std::vector<std::string> &devices, SyncMode mode, const DataQuery &query, std::shared_ptr<SyncCallback> syncCallback, uint32_t delay) Sync() argument
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
H A D | kvdb_service_impl.cpp | 942 GenAsync syncCallback = [tokenId = storeInfo.tokenId, seqId = syncInfo.seqId, this](const GenDetails &details) { in DoCloudSync() local 947 auto info = ChangeEvent::EventInfo({ mixMode, 0, false, syncInfo.triggerMode }, false, nullptr, syncCallback); in DoCloudSync()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
H A D | object_manager.cpp | 161 SyncCallBack syncCallback =
in Save() local 166 result = SyncOnStore(GetPropertyPrefix(dstBundleName, sessionId, deviceId), {deviceId}, syncCallback);
in Save()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
H A D | rdb_service_impl.cpp | 549 GenAsync syncCallback = [async, ¶m](const GenDetails &details) { 562 : syncCallback);
|
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
H A D | single_store_impl.cpp | 589 std::shared_ptr<SyncCallback> syncCallback, uint32_t delay) in Sync() 598 return DoSync(syncInfo, syncCallback); in Sync() 588 Sync(const std::vector<std::string> &devices, SyncMode mode, const DataQuery &query, std::shared_ptr<SyncCallback> syncCallback, uint32_t delay) Sync() argument
|