| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/cloud/ |
| H A D | icloud_db.h | 49 this->prepareTraceId = traceId; in SetPrepareTraceId()
53 return this->prepareTraceId; in GetPrepareTraceId()
56 std::string prepareTraceId; member in DistributedDB::ICloudDb
|
| H A D | cloud_store_types.h | 159 std::string prepareTraceId; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/ |
| H A D | cloud_extra_data.cpp | 23 SetValue(node[GET_NAME(prepareTraceId)], prepareTraceId); in Marshal()
30 GetValue(node, GET_NAME(prepareTraceId), prepareTraceId); in Unmarshal()
|
| H A D | cloud_db.cpp | 103 void CloudDB::SetPrepareTraceId(const std::string &prepareTraceId) in SetPrepareTraceId() argument
105 (void)prepareTraceId; in SetPrepareTraceId()
|
| H A D | sync_event.cpp | 27 prepareTraceId_(syncParam.prepareTraceId), user_(syncParam.user) in EventInfo()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 80 prepareTraceId_ = param.prepareTraceId; in SyncInfo()
388 auto prepareTraceId = evt.GetPrepareTraceId();
395 return DoExceptionalCallback(async, details, storeInfo, prepareTraceId);
399 ZLOGE("store null, storeId:%{public}s, prepareTraceId:%{public}s", meta.GetStoreAlias().c_str(),
400 prepareTraceId.c_str());
401 return DoExceptionalCallback(async, details, storeInfo, prepareTraceId);
404 storeInfo.bundleName.c_str(), meta.GetStoreAlias().c_str(), prepareTraceId.c_str());
408 Report({ user, storeInfo.bundleName, prepareTraceId, SyncStage::START, E_OK });
409 SyncParam syncParam = { evt.GetMode(), evt.GetWait(), evt.IsCompensation(), MODE_DEFAULT, prepareTraceId };
411 evt.AutoRetry() ? RetryCallback(storeInfo, retryer, evt.GetTriggerMode(), prepareTraceId, use
[all...] |
| H A D | sync_manager.h | 57 std::string prepareTraceId; member
72 void SetPrepareTraceId(const std::string &prepareTraceId);
106 std::function<bool(Duration interval, int32_t status, int32_t dbCode, const std::string &prepareTraceId)>;
143 const StoreInfo &storeInfo, int32_t triggerMode, const std::string &prepareTraceId, int32_t user);
147 const GenAsync &async, GenDetails &details, const StoreInfo &storeInfo, const std::string &prepareTraceId);
150 Retryer retryer, int32_t triggerMode, const std::string &prepareTraceId, int32_t user);
|
| H A D | cloud_service_impl.cpp | 414 auto &prepareTraceId = exData.info.context.prepareTraceId; in NotifyDataChange() local
417 ZLOGD("invalid user:%{public}d, traceId:%{public}s", user, prepareTraceId.c_str()); in NotifyDataChange()
418 syncManager_.Report({ user, bundleName, prepareTraceId, SyncStage::END, INVALID_ARGUMENT }); in NotifyDataChange()
424 ZLOGE("no exist meta, user:%{public}d, traceId:%{public}s", user, prepareTraceId.c_str()); in NotifyDataChange()
425 syncManager_.Report({ user, bundleName, prepareTraceId, SyncStage::END, INVALID_ARGUMENT }); in NotifyDataChange()
430 ZLOGE("GetDbInfoFromExtraData failed, empty database info. traceId:%{public}s.", prepareTraceId.c_str()); in NotifyDataChange()
431 syncManager_.Report({ user, bundleName, prepareTraceId, SyncStage::END, INVALID_ARGUMENT }); in NotifyDataChange()
436 { cloudInfo.user, bundleName, dbInfo.first, dbInfo.second, MODE_PUSH, prepareTraceId })); in NotifyDataChange()
|
| /foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/src/ |
| H A D | data_sync_manager_impl.cpp | 25 std::string prepareTraceId) in TriggerStartSync()
21 TriggerStartSync(const std::string &bundleName, const int32_t userId, bool forceFlag, SyncTriggerType triggerType, std::string prepareTraceId) TriggerStartSync() argument
|
| H A D | cloud_file_kit_impl.cpp | 51 std::string &prepareTraceId) in ResolveNotificationEvent()
48 ResolveNotificationEvent(const int32_t userId, const std::string &extraData, std::string &appBundleName, std::string &prepareTraceId) ResolveNotificationEvent() argument
|
| /foundation/filemanagement/dfs_service/adapter/cloud_adapter_example/include/ |
| H A D | data_sync_manager_impl.h | 28 std::string prepareTraceId = "");
|
| H A D | cloud_file_kit_impl.h | 30 std::string &prepareTraceId) override;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/ |
| H A D | cloud_extra_data.h | 26 std::string prepareTraceId; member in OHOS::DistributedData::final
|
| H A D | cloud_db.h | 67 virtual void SetPrepareTraceId(const std::string &prepareTraceId);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/ |
| H A D | general_value.h | 100 std::string prepareTraceId; member
113 std::string prepareTraceId; member
|
| /foundation/filemanagement/dfs_service/interfaces/inner_api/native/cloud_file_kit_inner/ |
| H A D | cloud_file_kit.h | 41 std::string &prepareTraceId);
|
| H A D | data_sync_manager.h | 36 std::string prepareTraceId = "");
|
| /foundation/filemanagement/dfs_service/frameworks/native/cloud_file_kit_inner/src/ |
| H A D | cloud_file_kit.cpp | 51 std::string &prepareTraceId) in ResolveNotificationEvent()
48 ResolveNotificationEvent(const int32_t userId, const std::string &extraData, std::string &appBundleName, std::string &prepareTraceId) ResolveNotificationEvent() argument
|
| H A D | data_sync_manager.cpp | 26 std::string prepareTraceId) in TriggerStartSync()
22 TriggerStartSync(const std::string &bundleName, const int32_t userId, bool forceFlag, SyncTriggerType triggerType, std::string prepareTraceId) TriggerStartSync() argument
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | cloud_data_test.cpp | 1532 std::string prepareTraceId; in HWTEST_F() local
1533 auto ret = sync.GetRetryer(CloudData::SyncManager::RETRY_TIMES, info, user)(duration, E_OK, E_OK, prepareTraceId); in HWTEST_F()
1536 duration, E_SYNC_TASK_MERGED, E_SYNC_TASK_MERGED, prepareTraceId); in HWTEST_F()
1538 ret = sync.GetRetryer(0, info, user)(duration, E_OK, E_OK, prepareTraceId); in HWTEST_F()
1540 ret = sync.GetRetryer(0, info, user)(duration, E_SYNC_TASK_MERGED, E_SYNC_TASK_MERGED, prepareTraceId); in HWTEST_F()
1560 std::string prepareTraceId; in HWTEST_F() local
1562 sync.GetCallback(async, storeInfo, triggerMode, prepareTraceId, user)(result); in HWTEST_F()
1570 sync.GetCallback(async, storeInfo, triggerMode, prepareTraceId, user)(result); in HWTEST_F()
1575 sync.GetCallback(async, storeInfo, triggerMode, prepareTraceId, user)(result); in HWTEST_F()
1577 sync.GetCallback(async, storeInfo, triggerMode, prepareTraceId, use in HWTEST_F()
1627 std::string prepareTraceId; HWTEST_F() local
1997 auto prepareTraceId = cloudReport->GetPrepareTraceId(100); HWTEST_F() local
[all...] |
| H A D | kvdb_general_store_test.cpp | 419 std::string prepareTraceId; in HWTEST_F() local
420 auto ret = store->CloudSync(devices, cloudSyncMode, asyncs, 0, prepareTraceId); in HWTEST_F()
425 ret = store->CloudSync(devices, cloudSyncMode, asyncs, 0, prepareTraceId); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | icloud_syncer.h | 47 std::string prepareTraceId; member
|
| H A D | cloud_sync_utils.cpp | 627 taskInfo.prepareTraceId = option.prepareTraceId; in InitCompensatedSyncTaskInfo()
643 taskInfo.prepareTraceId = oriTaskInfo.prepareTraceId; in InitCompensatedSyncTaskInfo()
|
| /foundation/filemanagement/dfs_service/services/cloudsyncservice/src/ipc/ |
| H A D | cloud_sync_service.cpp | 499 string prepareTraceId; in NotifyEventChange() local
500 auto ret = instance->ResolveNotificationEvent(userId, extraData, appBundleName, prepareTraceId); in NotifyEventChange()
507 SyncTriggerType::CLOUD_TRIGGER, prepareTraceId); in NotifyEventChange()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_general_store.cpp | 360 int64_t wait, const std::string &prepareTraceId) in CloudSync()
366 syncOption.prepareTraceId = prepareTraceId; in CloudSync()
393 dbStatus = CloudSync(devices, dbMode, async, syncParam.wait, syncParam.prepareTraceId); in Sync()
359 CloudSync(const Devices &devices, DistributedDB::SyncMode cloudSyncMode, DetailAsync async, int64_t wait, const std::string &prepareTraceId) CloudSync() argument
|