mirror of
https://github.com/openharmony/windowmanager.git
synced 2026-07-21 04:25:28 -04:00
dubj
573e474ca8
Signed-off-by: dubj <dubingjian@huawei.com> Change-Id: I52bf1465f0558fadf7ef21dd19a4aed79ab5f87b
97 lines
3.1 KiB
C++
97 lines
3.1 KiB
C++
/*
|
|
* Copyright (c) 2022 Huawei Device Co., Ltd.
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
#include "window_common_event.h"
|
|
|
|
#include <thread>
|
|
#include <want.h>
|
|
#include "common_event_subscribe_info.h"
|
|
#include "event_runner.h"
|
|
#include "skills.h"
|
|
#include "window_manager_hilog.h"
|
|
#include "window_manager_service.h"
|
|
|
|
namespace OHOS {
|
|
namespace Rosen {
|
|
namespace {
|
|
constexpr HiviewDFX::HiLogLabel LABEL = {LOG_CORE, HILOG_DOMAIN_WINDOW, "WindowCommonEvent"};
|
|
constexpr int RETRY_MAX_COUNT = 3;
|
|
const std::string THREAD_ID = "window_common_event_handler";
|
|
}
|
|
|
|
WindowCommonEvent::WindowCommonEvent()
|
|
{
|
|
handleCommonEventFuncs_.insert(make_pair(EventFwk::CommonEventSupport::COMMON_EVENT_USER_SWITCHED,
|
|
&WindowCommonEvent::HandleAccountSwitched));
|
|
auto runner = AppExecFwk::EventRunner::Create(THREAD_ID);
|
|
eventHandler_ = std::make_shared<AppExecFwk::EventHandler>(runner);
|
|
}
|
|
|
|
WindowCommonEvent::~WindowCommonEvent()
|
|
{
|
|
}
|
|
|
|
void WindowCommonEvent::SubscriberEvent()
|
|
{
|
|
EventFwk::MatchingSkills skills;
|
|
skills.AddEvent(EventFwk::CommonEventSupport::COMMON_EVENT_USER_SWITCHED);
|
|
EventFwk::CommonEventSubscribeInfo info(skills);
|
|
subscriber_ = std::make_shared<EventSubscriber>(info, shared_from_this());
|
|
int retry = RETRY_MAX_COUNT;
|
|
SubscriberEventInner(retry);
|
|
}
|
|
|
|
void WindowCommonEvent::SubscriberEventInner(int retry)
|
|
{
|
|
if (retry <= 0) {
|
|
return;
|
|
}
|
|
retry--;
|
|
WLOGFI("called action = %{public}d", retry);
|
|
if (EventFwk::CommonEventManager::SubscribeCommonEvent(subscriber_)) {
|
|
return;
|
|
}
|
|
std::function<void()> func = std::bind(&WindowCommonEvent::SubscriberEventInner, this, retry);
|
|
// post task delay 500ms
|
|
eventHandler_->PostTask(func, 500, AppExecFwk::EventQueue::Priority::HIGH);
|
|
}
|
|
|
|
void WindowCommonEvent::UnSubscriberEvent()
|
|
{
|
|
auto task = [this] {
|
|
EventFwk::CommonEventManager::UnSubscribeCommonEvent(subscriber_);
|
|
};
|
|
eventHandler_->PostTask(task, AppExecFwk::EventQueue::Priority::HIGH);
|
|
}
|
|
|
|
void WindowCommonEvent::OnReceiveEvent(const EventFwk::CommonEventData& data)
|
|
{
|
|
auto task = [this, data] {
|
|
std::string action = data.GetWant().GetAction();
|
|
WLOGFI("called action = %{public}s", action.c_str());
|
|
if (handleCommonEventFuncs_.count(action)) {
|
|
(this->*handleCommonEventFuncs_[action])(data);
|
|
}
|
|
};
|
|
eventHandler_->PostTask(task, AppExecFwk::EventQueue::Priority::HIGH);
|
|
}
|
|
|
|
void WindowCommonEvent::HandleAccountSwitched(const EventFwk::CommonEventData& data) const
|
|
{
|
|
int accountId = data.GetCode();
|
|
WindowManagerService::GetInstance().OnAccountSwitched(accountId);
|
|
}
|
|
} // Rosen
|
|
} // OHOS
|