openharmony/filemanagement_dfs_service
1
0
Fork 0
mirror of https://gitee.com/openharmony/filemanagement_dfs_service synced 2024-10-06 21:44:01 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

端到端打点，增加事务级prepareTraceId

Browse Source 
Signed-off-by: zhangshuyi <zhangshuyi14@huawei.com>
This commit is contained in:
zhangshuyi 2024-09-27 10:02:47 +08:00
parent 8038b2c4a0
commit 371e28d868
9 changed files with 20 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
adapter/cloud_adapter_example/include/cloud_file_kit_impl.h
View File

@ -26,7 +26,8 @@ public:
int32_t GetAppSwitchStatus(const std::string &bundleName, const int32_t userId, bool &switchStatus) override;
int32_t ResolveNotificationEvent(const int32_t userId,
const std::string &extraData,
std::string &appBundleName) override;
std::string &appBundleName,
std::string &prepareTraceId) override;
std::shared_ptr<DataSyncManager> GetDataSyncManager() override;
std::shared_ptr<CloudAssetsDownloader> GetCloudAssetsDownloader(const int32_t userId,

3
adapter/cloud_adapter_example/include/data_sync_manager_impl.h
View File

@ -24,7 +24,8 @@ public:
virtual int32_t TriggerStartSync(const std::string &bundleName,
const int32_t userId,
bool forceFlag,
SyncTriggerType triggerType);
SyncTriggerType triggerType,
std::string prepareTraceId = "");
};
} // namespace OHOS::FileManagement::CloudFile

3
adapter/cloud_adapter_example/src/cloud_file_kit_impl.cpp
View File

@ -47,7 +47,8 @@ int32_t CloudFileKitImpl::GetAppSwitchStatus(const std::string &bundleName,
int32_t CloudFileKitImpl::ResolveNotificationEvent(const int32_t userId,
const std::string &extraData,
std::string &appBundleName)
std::string &appBundleName,
std::string &prepareTraceId)
{
appBundleName = "com.ohos.photos";
return E_OK;

3
adapter/cloud_adapter_example/src/data_sync_manager_impl.cpp
View File

@ -21,7 +21,8 @@ using namespace std;
int32_t DataSyncManagerImpl::TriggerStartSync(const std::string &bundleName,
const int32_t userId,
bool forceFlag,
SyncTriggerType triggerType)
SyncTriggerType triggerType,
std::string prepareTraceId)
{
return E_OK;
}

3
frameworks/native/cloud_file_kit_inner/src/cloud_file_kit.cpp
View File

@ -47,7 +47,8 @@ int32_t CloudFileKit::GetAppSwitchStatus(const std::string &bundleName, const in
int32_t CloudFileKit::ResolveNotificationEvent(const int32_t userId,
const std::string &extraData,
std::string &appBundleName)
std::string &appBundleName,
std::string &prepareTraceId)
{
appBundleName = "com.ohos.photos";
return E_OK;

3
frameworks/native/cloud_file_kit_inner/src/data_sync_manager.cpp
View File

@ -22,7 +22,8 @@ using namespace std;
int32_t DataSyncManager::TriggerStartSync(const std::string &bundleName,
const int32_t userId,
bool forceFlag,
SyncTriggerType triggerType)
SyncTriggerType triggerType,
std::string prepareTraceId)
{
return E_OK;
}

3
interfaces/inner_api/native/cloud_file_kit_inner/cloud_file_kit.h
View File

@ -37,7 +37,8 @@ public:
virtual int32_t GetAppSwitchStatus(const std::string &bundleName, const int32_t userId, bool &switchStatus);
virtual int32_t ResolveNotificationEvent(const int32_t userId,
const std::string &extraData,
std::string &appBundleName);
std::string &appBundleName,
std::string &prepareTraceId);
virtual int32_t GetAppConfigParams(const int32_t userId,
const std::string &bundleName,
std::map<std::string, std::string> &param);

3
interfaces/inner_api/native/cloud_file_kit_inner/data_sync_manager.h
View File

@ -31,7 +31,8 @@ public:
virtual int32_t TriggerStartSync(const std::string &bundleName,
const int32_t userId,
bool forceFlag,
SyncTriggerType triggerType);
SyncTriggerType triggerType,
std::string prepareTraceId = "");
virtual int32_t TriggerStopSync(const std::string &bundleName, const int32_t userId,
bool forceFlag, SyncTriggerType triggerType);
virtual int32_t TriggerRecoverySync(SyncTriggerType triggerType);

6
services/cloudsyncservice/src/ipc/cloud_sync_service.cpp
View File

@ -438,13 +438,15 @@ int32_t CloudSyncService::NotifyEventChange(int32_t userId, const std::string &e
}
string appBundleName;
auto ret = instance->ResolveNotificationEvent(userId, extraData, appBundleName);
string prepareTraceId;
auto ret = instance->ResolveNotificationEvent(userId, extraData, appBundleName, prepareTraceId);
if (ret != E_OK) {
LOGE("ResolveNotificationEvent failed, ret:%{public}d", ret);
return E_CLOUD_SDK;
}
return dataSyncManager_->TriggerStartSync(appBundleName, userId, false, SyncTriggerType::CLOUD_TRIGGER);
return dataSyncManager_->TriggerStartSync(appBundleName, userId, false,
SyncTriggerType::CLOUD_TRIGGER, prepareTraceId);
}
int32_t CloudSyncService::DisableCloud(const std::string &accoutId)