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

!726 Feature：上线后查询获焦应用

Browse Source 
Merge pull request !726 from zhx/master
This commit is contained in:
openharmony_ci 2023-11-13 13:23:29 +00:00 committed by Gitee
commit 2037c42e6c
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
2 changed files with 80 additions and 49 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
services/dtbschedmgr/include/mission/distributed_sched_continue_manager.h
View File

@ -80,6 +80,7 @@ public:
void NotifyScreenLockorOff();
private:
int32_t GetCurrentMissionId();
void AddCancelMissionFocusedTimer(const int32_t missionId);
int32_t SendSoftbusEvent(uint32_t accessTokenId, uint8_t type);
void StartEvent();

128
services/dtbschedmgr/src/mission/distributed_sched_continue_manager.cpp
View File

@ -44,33 +44,42 @@ IMPLEMENT_SINGLE_INSTANCE(DistributedSchedContinueManager);
void DistributedSchedContinueManager::Init()
{
HILOGI("Init start");
missionFocusedListener_ = new DistributedMissionFocusedListener();
int32_t ret = DistributedSchedAdapter::GetInstance().RegisterMissionListener(missionFocusedListener_);
if (ret != ERR_OK) {
HILOGE("get RegisterMissionListener failed, ret: %{public}d", ret);
{
missionFocusedListener_ = new DistributedMissionFocusedListener();
int32_t ret = DistributedSchedAdapter::GetInstance().RegisterMissionListener(missionFocusedListener_);
if (ret != ERR_OK) {
HILOGE("get RegisterMissionListener failed, ret: %{public}d", ret);
return;
}
std::shared_ptr<SoftbusAdapterListener> missionBroadcastListener =
std::make_shared<DistributedMissionBroadcastListener>();
ret = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(missionBroadcastListener);
if (ret != ERR_OK) {
HILOGE("get RegisterSoftbusEventListener failed, ret: %{public}d", ret);
return;
}
missionDiedListener_ = new DistributedMissionDiedListener();
EventFwk::MatchingSkills matchingSkills;
matchingSkills.AddEvent(EventFwk::CommonEventSupport::COMMON_EVENT_SCREEN_LOCKED);
matchingSkills.AddEvent(EventFwk::CommonEventSupport::COMMON_EVENT_SCREEN_OFF);
EventFwk::CommonEventSubscribeInfo subscribeInfo(matchingSkills);
auto applyMonitor = std::make_shared<CommonEventListener>(subscribeInfo);
EventFwk::CommonEventManager::SubscribeCommonEvent(applyMonitor);
eventThread_ = std::thread(&DistributedSchedContinueManager::StartEvent, this);
std::unique_lock<std::mutex> lock(eventMutex_);
eventCon_.wait(lock, [this] {
return eventHandler_ != nullptr;
});
}
int32_t missionId = GetCurrentMissionId();
if (missionId <= 0) {
HILOGW("GetCurrentMissionId failed, init end. ret: %{public}d", missionId);
return;
}
std::shared_ptr<SoftbusAdapterListener> missionBroadcastListener =
std::make_shared<DistributedMissionBroadcastListener>();
ret = SoftbusAdapter::GetInstance().RegisterSoftbusEventListener(missionBroadcastListener);
if (ret != ERR_OK) {
HILOGE("get RegisterSoftbusEventListener failed, ret: %{public}d", ret);
return;
}
missionDiedListener_ = new DistributedMissionDiedListener();
EventFwk::MatchingSkills matchingSkills;
matchingSkills.AddEvent(EventFwk::CommonEventSupport::COMMON_EVENT_SCREEN_LOCKED);
matchingSkills.AddEvent(EventFwk::CommonEventSupport::COMMON_EVENT_SCREEN_OFF);
EventFwk::CommonEventSubscribeInfo subscribeInfo(matchingSkills);
auto applyMonitor = std::make_shared<CommonEventListener>(subscribeInfo);
EventFwk::CommonEventManager::SubscribeCommonEvent(applyMonitor);
eventThread_ = std::thread(&DistributedSchedContinueManager::StartEvent, this);
std::unique_lock<std::mutex> lock(eventMutex_);
eventCon_.wait(lock, [this] {
return eventHandler_ != nullptr;
});
NotifyMissionFocused(missionId);
HILOGI("Init end");
}
@ -87,6 +96,20 @@ void DistributedSchedContinueManager::UnInit()
HILOGI("UnInit end");
}
int32_t DistributedSchedContinueManager::GetCurrentMissionId()
{
HILOGI("GetCurrentMission begin");
sptr<IRemoteObject> token;
int ret = AAFwk::AbilityManagerClient::GetInstance()->GetTopAbility(token);
if (ret != ERR_OK || token == nullptr) {
HILOGE("GetTopAbility failed, ret: %{public}d", ret);
return INVALID_MISSION_ID;
}
int32_t missionId = INVALID_MISSION_ID;
AAFwk::AbilityManagerClient::GetInstance()->GetMissionIdByToken(token, missionId);
return missionId;
}
void DistributedSchedContinueManager::AddCancelMissionFocusedTimer(const int32_t missionId)
{
HILOGI("AddCancelMissionFocusedTimer start, missionId: %{public}d", missionId);
@ -596,32 +619,39 @@ void DistributedSchedContinueManager::NotifyDeid(const sptr<IRemoteObject>& obj)
void DistributedSchedContinueManager::NotifyScreenLockorOff()
{
HILOGI("NotifyScreenLockorOff begin");
std::string senderNetworkId;
std::string bundleName;
{
std::lock_guard<std::mutex> currentIconLock(iconMutex_);
if (iconInfo_.isEmpty()) {
HILOGW("Saved iconInfo has already been cleared, task abort.");
return;
auto func = [this]() {
std::string senderNetworkId;
std::string bundleName;
{
std::lock_guard<std::mutex> currentIconLock(iconMutex_);
if (iconInfo_.isEmpty()) {
HILOGW("Saved iconInfo has already been cleared, task abort.");
return;
}
senderNetworkId = iconInfo_.senderNetworkId;
bundleName = iconInfo_.bundleName;
iconInfo_.senderNetworkId = "";
iconInfo_.bundleName = "";
}
senderNetworkId = iconInfo_.senderNetworkId;
bundleName = iconInfo_.bundleName;
iconInfo_.senderNetworkId = "";
iconInfo_.bundleName = "";
}
HILOGI("Saved iconInfo cleared, networkId = %{public}s, bundleName = %{public}s",
DnetworkAdapter::AnonymizeNetworkId(senderNetworkId).c_str(), bundleName.c_str());
{
std::lock_guard<std::mutex> registerOnListenerMapLock(eventMutex_);
auto iterItem = registerOnListener_.find(onType_);
if (iterItem == registerOnListener_.end()) {
HILOGI("Get iterItem failed from registerOnListener_, nobody registed");
return;
}
std::vector<sptr<IRemoteObject>> objs = iterItem->second;
for (auto iter : objs) {
NotifyRecvBroadcast(iter, senderNetworkId, bundleName, INACTIVE);
HILOGI("Saved iconInfo cleared, networkId = %{public}s, bundleName = %{public}s",
DnetworkAdapter::AnonymizeNetworkId(senderNetworkId).c_str(), bundleName.c_str());
{
std::lock_guard<std::mutex> registerOnListenerMapLock(eventMutex_);
auto iterItem = registerOnListener_.find(onType_);
if (iterItem == registerOnListener_.end()) {
HILOGI("Get iterItem failed from registerOnListener_, nobody registed");
return;
}
std::vector<sptr<IRemoteObject>> objs = iterItem->second;
for (auto iter : objs) {
NotifyRecvBroadcast(iter, senderNetworkId, bundleName, INACTIVE);
}
}
};
if (eventHandler_ != nullptr) {
eventHandler_->PostTask(func);
} else {
HILOGE("eventHandler_ is nullptr");
}
HILOGI("NotifyScreenLockorOff end");
}