openharmony/ability_dmsfwk
1
0
Fork 0
mirror of https://gitee.com/openharmony/ability_dmsfwk synced 2024-11-23 06:20:07 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

update services/dtbschedmgr/src/distributed_sched_stub.cpp.

Browse Source 
Signed-off-by: 师皓杰 <shihaojie10@huawei.com>
This commit is contained in:
师皓杰 2024-06-13 02:53:17 +00:00 committed by Gitee
parent a3b469e1d8
commit 58a4a5a7a9
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
services/dtbschedmgr/src/distributed_sched_stub.cpp
View File

@ -481,16 +481,6 @@ int32_t DistributedSchedStub::SendResultFromRemoteInner(MessageParcel& data, Mes
return ERR_NONE;
}
bool DistributedSchedStub::IsInstall(const std::string &networkId, const std::string &bundleName)
{
DmsBundleInfo info;
DmsBmStorage::GetInstance()->GetStorageDistributeInfo(networkId, bundleName, info);
if (info.bundleName.empty()) {
return false;
}
return true;
}
int32_t DistributedSchedStub::ContinueMissionInner(MessageParcel& data, MessageParcel& reply)
{
bool isLocalCalling = IPCSkeleton::IsLocalCalling();
@ -528,7 +518,7 @@ int32_t DistributedSchedStub::ContinueMissionInner(MessageParcel& data, MessageP
missionInfo.want.SetParams(*wantParams);
bool isFreeInstall = missionInfo.want.GetBoolParam("isFreeInstall", false);
if ((!isFreeInstall && IsUsingQos(remoteDeviceId)) ||
(isFreeInstall && IsInstall(remoteDeviceId, sourceBundleName))) {
(isFreeInstall && IsRemoteInstall(remoteDeviceId, sourceBundleName))) {
DSchedTransportSoftbusAdapter::GetInstance().SetCallingTokenId(IPCSkeleton::GetCallingTokenID());
result = DSchedContinueManager::GetInstance().ContinueMission(srcDevId, dstDevId, missionId, callback,
*wantParams);
@ -581,8 +571,8 @@ int32_t DistributedSchedStub::ContinueMissionOfBundleNameInner(MessageParcel& da
std::string remoteDeviceId = (IPCSkeleton::GetCallingDeviceID() == srcDevId) ? dstDevId : srcDevId;
missionInfo.want.SetParams(*wantParams);
bool isFreeInstall = missionInfo.want.GetBoolParam("isFreeInstall", false);
if ((!isFreeInstall&&IsUsingQos(remoteDeviceId)) ||
(isFreeInstall&&IsInstall(remoteDeviceId, bundleName))) {
if ((!isFreeInstall && IsUsingQos(remoteDeviceId)) ||
(isFreeInstall && IsRemoteInstall(remoteDeviceId, bundleName))) {
DSchedTransportSoftbusAdapter::GetInstance().SetCallingTokenId(IPCSkeleton::GetCallingTokenID());
result = DSchedContinueManager::GetInstance().ContinueMission(srcDevId, dstDevId, bundleName, continueType,
callback, *wantParams);
@ -595,6 +585,16 @@ int32_t DistributedSchedStub::ContinueMissionOfBundleNameInner(MessageParcel& da
PARCEL_WRITE_REPLY_NOERROR(reply, Int32, result);
}
bool DistributedSchedStub::IsRemoteInstall(const std::string &networkId, const std::string &bundleName)
{
DmsBundleInfo info;
DmsBmStorage::GetInstance()->GetStorageDistributeInfo(networkId, bundleName, info);
if (info.bundleName.empty()) {
return false;
}
return true;
}
int32_t DistributedSchedStub::StartContinuationInner(MessageParcel& data, MessageParcel& reply)
{
int64_t saveDataEnd = GetTickCount();