xref: /foundation/resourceschedule/qos_manager/frameworks/concurrent_task_client/src/concurrent_task_client.cpp

/*
 * 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 "concurrent_task_client.h"
#include <cinttypes>
#include "if_system_ability_manager.h"
#include "iservice_registry.h"
#include "concurrent_task_log.h"
#include "concurrent_task_errors.h"
#include "system_ability_definition.h"

namespace OHOS {
namespace ConcurrentTask {
ConcurrentTaskClient& ConcurrentTaskClient::GetInstance()
{
    static ConcurrentTaskClient instance;
    return instance;
}

void ConcurrentTaskClient::ReportData(uint32_t resType, int64_t value,
                                      const std::unordered_map<std::string, std::string>& mapPayload)
{
    CONCUR_LOGD("ConcurrentTaskClient::ReportData receive resType = %{public}u, value = %{public}" PRId64 ".",
                  resType, value);
    if (TryConnect() != ERR_OK) {
        return;
    }
    Json::Value payload;
    for (auto it = mapPayload.begin(); it != mapPayload.end(); ++it) {
        payload[it->first] = it->second;
    }
    clientService_->ReportData(resType, value, payload);
}

void ConcurrentTaskClient::ReportSceneInfo(uint32_t type,
                                           const std::unordered_map<std::string, std::string>& mapPayload)
{
    if (TryConnect() != ERR_OK) {
        return;
    }
    Json::Value payload;
    for (auto it = mapPayload.begin(); it != mapPayload.end(); ++it) {
        payload[it->first] = it->second;
    }
    clientService_->ReportSceneInfo(type, payload);
}

void ConcurrentTaskClient::QueryInterval(int queryItem, IntervalReply& queryRs)
{
    if (TryConnect() != ERR_OK) {
        CONCUR_LOGE("QueryInterval connnect fail");
        return;
    }
    clientService_->QueryInterval(queryItem, queryRs);
    return;
}

void ConcurrentTaskClient::QueryDeadline(int queryItem, DeadlineReply& ddlReply,
                                         const std::unordered_map<pid_t, uint32_t>& mapPayload)
{
    if (TryConnect() != ERR_OK) {
        return;
    }
    Json::Value payload;
    for (auto it = mapPayload.begin(); it != mapPayload.end(); ++it) {
        payload[std::to_string(it->first)] = std::to_string(it->second);
    }
    clientService_->QueryDeadline(queryItem, ddlReply, payload);
    return;
}

void ConcurrentTaskClient::RequestAuth(const std::unordered_map<std::string, std::string>& mapPayload)
{
    if (TryConnect() != ERR_OK) {
        return;
    }
    Json::Value payload;
    for (auto it = mapPayload.begin(); it != mapPayload.end(); ++it) {
        payload[it->first] = it->second;
    }
    clientService_->RequestAuth(payload);
    return;
}

void ConcurrentTaskClient::QueryDeadline(int queryItem, DeadlineReply& ddlReply,
                                         const std::unordered_map<std::string, std::string>& mapPayload)
{
    if (TryConnect() != ERR_OK) {
        return;
    }
    Json::Value payload;
    for (auto it = mapPayload.begin(); it != mapPayload.end(); ++it) {
        payload[it->first] = it->second;
    }
    clientService_->QueryDeadline(queryItem, ddlReply, payload);
    return;
}

ErrCode ConcurrentTaskClient::TryConnect()
{
    std::lock_guard<std::mutex> lock(mutex_);
    if (clientService_) {
        return ERR_OK;
    }

    sptr<ISystemAbilityManager> systemManager = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
    if (!systemManager) {
        CONCUR_LOGE("ConcurrentTaskClient::Fail to get registry.");
        return GET_CONCURRENT_TASK_SERVICE_FAILED;
    }

    remoteObject_ = systemManager->GetSystemAbility(CONCURRENT_TASK_SERVICE_ID);
    if (!remoteObject_) {
        CONCUR_LOGE("ConcurrentTaskClient::Fail to connect concurrent task schedule service.");
        return GET_CONCURRENT_TASK_SERVICE_FAILED;
    }

    clientService_ = iface_cast<IConcurrentTaskService>(remoteObject_);
    if (!clientService_) {
        return GET_CONCURRENT_TASK_SERVICE_FAILED;
    }
    try {
        recipient_ = new ConcurrentTaskDeathRecipient(*this);
    } catch (const std::bad_alloc& e) {
        CONCUR_LOGE("ConcurrentTaskClient::New ConcurrentTaskDeathRecipient fail.");
    }
    if (!recipient_) {
        return GET_CONCURRENT_TASK_SERVICE_FAILED;
    }
    clientService_->AsObject()->AddDeathRecipient(recipient_);
    CONCUR_LOGD("ConcurrentTaskClient::Connect concurrent task service success.");
    return ERR_OK;
}

void ConcurrentTaskClient::StopRemoteObject()
{
    if (clientService_ && clientService_->AsObject()) {
        clientService_->AsObject()->RemoveDeathRecipient(recipient_);
    }
    clientService_ = nullptr;
}

ConcurrentTaskClient::ConcurrentTaskDeathRecipient::ConcurrentTaskDeathRecipient(
    ConcurrentTaskClient& concurrentTaskClient) : concurrentTaskClient_(concurrentTaskClient) {}

ConcurrentTaskClient::ConcurrentTaskDeathRecipient::~ConcurrentTaskDeathRecipient() {}

void ConcurrentTaskClient::ConcurrentTaskDeathRecipient::OnRemoteDied(const wptr<IRemoteObject>& object)
{
    concurrentTaskClient_.StopRemoteObject();
}

#ifdef __cplusplus
extern "C" {
#endif
void CTC_QueryInterval(int queryItem, OHOS::ConcurrentTask::IntervalReply& queryRs)
{
    OHOS::ConcurrentTask::ConcurrentTaskClient::GetInstance().QueryInterval(queryItem, queryRs);
}
#ifdef __cplusplus
}
#endif
} // namespace ConcurrentTask
} // namespace OHOS