openharmony/ability_dmsfwk
1
0
Fork 0
mirror of https://gitee.com/openharmony/ability_dmsfwk synced 2025-02-17 04:49:02 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

distributed data api switching

Browse Source 
Signed-off-by: zhangmingxiang <zhangmingxiang@huawei.com>
Change-Id: Ic0e66c266a32d9cfcc79753152611d6e20da3aee
Signed-off-by: zhangmingxiang <zhangmingxiang@huawei.com>
This commit is contained in:
zhangmingxiang 2022-07-30 09:56:17 +08:00
parent f314b25b8c
commit 958f542c54
2 changed files with 18 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
etc/init/distributedsched.cfg
View File

@ -1,10 +1,22 @@
{
"jobs":[{
"name" : "service:distributedsched",
"cmds" : [
"mkdir /data/service/el1/public/database 0711 ddms ddms",
"mkdir /data/service/el1/public/database/distributed_device_profile_service 02770 dms ddms",
"mkdir /data/service/el1/public/database/DistributedSchedule 02770 dms ddms"
]
}
],
"services" : [{
"name" : "distributedsched",
"path" : ["/system/bin/sa_main", "/system/profile/distributedsched.xml"],
"uid" : "dms",
"gid" : ["dms", "shell"],
"permission" : ["ohos.permission.DISTRIBUTED_DATASYNC"],
"jobs" : {
"on-start" : "service:distributedsched"
},
"secon" : "u:r:distributedsche:s0"
}
]

9
services/dtbschedmgr/src/mission/distributed_data_storage.cpp
View File

@ -35,6 +35,7 @@ namespace {
const string TAG = "DistributedDataStorage";
const string APP_ID = "DistributedSchedule";
const string STORE_ID = "SnapshotInfoDataStorage";
const string KVDB_PATH = "/data/service/el1/public/database/DistributedSchedule";
constexpr int32_t RETRY_TIMES_WAIT_KV_DATA = 30;
constexpr int32_t RETRY_TIMES_GET_KVSTORE = 5;
}
@ -143,6 +144,8 @@ Status DistributedDataStorage::GetKvStore()
.encrypt = false,
.autoSync = true,
.kvStoreType = KvStoreType::SINGLE_VERSION,
.area = 1,
.baseDir = KVDB_PATH
};
Status status = dataManager_.GetSingleKvStore(options, appId_, storeId_, kvStorePtr_);
if (status != Status::SUCCESS) {
@ -160,7 +163,7 @@ void DistributedDataStorage::SubscribeDistributedDataStorage()
HILOGW("kvStorePtr is null!");
return;
}
SubscribeType subscribeType = SubscribeType::DEFAULT;
SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_REMOTE;
if (distributedDataChangeListener_ != nullptr) {
HILOGD("SubscribeKvStore start.");
Status status = kvStorePtr_->SubscribeKvStore(subscribeType, move(distributedDataChangeListener_));
@ -211,7 +214,7 @@ bool DistributedDataStorage::UninitDistributedDataStorage()
int64_t begin = GetTickCount();
Status status;
if (distributedDataChangeListener_ != nullptr && kvStorePtr_ != nullptr) {
SubscribeType subscribeType = SubscribeType::DEFAULT;
SubscribeType subscribeType = SubscribeType::SUBSCRIBE_TYPE_REMOTE;
status = kvStorePtr_->UnSubscribeKvStore(subscribeType, move(distributedDataChangeListener_));
HILOGI("[PerformanceTest] UnSubscribeKvStore spend %{public}" PRId64 " ms", GetTickCount() - begin);
if (status != Status::SUCCESS) {
@ -228,7 +231,7 @@ bool DistributedDataStorage::UninitDistributedDataStorage()
}
kvStorePtr_ = nullptr;
}
status = dataManager_.DeleteKvStore(appId_, storeId_);
status = dataManager_.DeleteKvStore(appId_, storeId_, KVDB_PATH);
if (status != Status::SUCCESS) {
HILOGE("DeleteKvStore failed! status = %{public}d.", status);
return false;