core/include/socperf_common.h

/*
 * Copyright (c) 2022-2024 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.
 */

#ifndef SOC_PERF_SERVICES_CORE_INCLUDE_SOCPERF_COMMON_H
#define SOC_PERF_SERVICES_CORE_INCLUDE_SOCPERF_COMMON_H

#include <climits>
#include <list>
#include <mutex>
#include <string>
#include <vector>
#include <unordered_map>
#include <unordered_set>

#ifdef SOCPERF_ADAPTOR_FFRT
#include "ffrt.h"
#endif

#include "socperf_log.h"
#include "socperf_action_type.h"

namespace OHOS {
namespace SOCPERF {
enum EventType {
    EVENT_INVALID = -1,
    EVENT_OFF,
    EVENT_ON
};

enum InterActionStatus {
    BOOST_STATUS = 0,
    BOOST_END_STATUS,
    WEAK_INTERACTION_STATUS
};

const std::string SOCPERF_RESOURCE_CONFIG_XML = "etc/soc_perf/socperf_resource_config.xml";
const std::string SOCPERF_BOOST_CONFIG_XML    = "etc/soc_perf/socperf_boost_config.xml";
const std::string SOCPERF_BOOST_CONFIG_XML_EXT    = "etc/soc_perf/socperf_boost_config_ext.xml";
const std::string CAMERA_AWARE_CONFIG_XML    = "etc/camera/cas/camera_aware_config.xml";
const int64_t MAX_INT_VALUE                       = 0x7FFFFFFFFFFFFFFF;
const int64_t MIN_INT_VALUE                       = 0x8000000000000000;
const int32_t MAX_INT32_VALUE                     = 0x7FFFFFFF;
const int32_t INVALID_VALUE                       = INT_MIN;
const int32_t RESET_VALUE                         = -1;
const int32_t MIN_RESOURCE_ID                     = 1000;
const int32_t MAX_RESOURCE_ID                     = 5999;
const int32_t RES_ID_ADDITION                     = 10000;
const int32_t RES_ID_AND_VALUE_PAIR               = 2;
const int32_t RES_ID_NUMS_PER_TYPE                = 1000;
const int32_t RES_ID_NUMS_PER_TYPE_EXT            = 10000;
const int32_t WRITE_NODE                          = 0;
const int32_t REPORT_TO_PERFSO                    = 1;
const int32_t PERF_OPEN_TRACE                     = 1;
const int32_t INVALID_THERMAL_CMD_ID              = -1;
const int32_t INVALID_DURATION                    = -1;
const int32_t MIN_THERMAL_LVL                     = -1;
const int32_t RES_MODE_AND_ID_PAIR                = 2;
const int32_t MAX_RES_MODE_LEN                    = 64;
const int32_t MAX_FREQUE_NODE                     = 1;
const int32_t NODE_DEFAULT_VALUE                  = -1;
const int32_t TYPE_TRACE_DEBUG                    = 3;

class ResourceNode {
public:
    int32_t id;
    std::string name;
    int64_t def;
    std::unordered_set<int64_t> available;
    int32_t persistMode;
    bool isGov;
    bool isMaxValue;
    bool trace = false;
public:
    ResourceNode(int32_t id, const std::string& name, int32_t persistMode, bool isGov, bool isMaxValue) : id(id),
        name(name), def(INVALID_VALUE), persistMode(persistMode), isGov(isGov), isMaxValue(isMaxValue) {}
    virtual ~ResourceNode() {};
    virtual void PrintString() {};
};

class ResNode : public ResourceNode {
public:
    std::string path;
    int32_t pair;

public:
    ResNode(int32_t resId, const std::string& resName, int32_t resMode, int32_t resPair, int32_t resPersistMode)
        : ResourceNode(resId, resName, resPersistMode, false, resMode == MAX_FREQUE_NODE)
    {
        pair = resPair;
    }
    ~ResNode() {}
};

class GovResNode : public ResourceNode {
public:
    std::vector<std::string> paths;
    std::mutex levelToStrMutex_;
    std::unordered_map<int64_t, std::vector<std::string>> levelToStr;

public:
    GovResNode(int32_t govResId, const std::string& govResName, int32_t govPersistMode)
        : ResourceNode(govResId, govResName, govPersistMode, true, false) {}
    ~GovResNode() {}
};

class SceneItem {
public:
    std::string name;
    int32_t req;

public:
    SceneItem(const std::string& name, int32_t req) : name(name), req(req) {}
    ~SceneItem() {}
};

class SceneResNode {
public:
    std::string name;
    int32_t persistMode;
    std::vector<std::shared_ptr<SceneItem>> items;

public:
    SceneResNode(const std::string& name, int32_t persistMode) : name(name), persistMode(persistMode) {}
    ~SceneResNode() {}
};

class ModeMap {
public:
    std::string mode;
    int32_t cmdId;

public:
    ModeMap(const std::string& mode, int32_t cmdId) : mode(mode), cmdId(cmdId) {}
    ~ModeMap() {}
};

class Action {
public:
    int32_t thermalCmdId_ = INVALID_THERMAL_CMD_ID;
    int32_t thermalLvl_ = MIN_THERMAL_LVL;
    int32_t duration = INVALID_DURATION;
    std::vector<int64_t> variable;

public:
    Action() {}
    ~Action() {}
};

class Actions {
public:
    int32_t id;
    std::string name;
    std::list<std::shared_ptr<Action>> actionList;
    std::vector<std::shared_ptr<ModeMap>> modeMap;
    bool isLongTimePerf = false;
    bool interaction = true;

public:
    Actions(int32_t cmdId, const std::string& cmdName)
    {
        id = cmdId;
        name = cmdName;
    }
    ~Actions() {}
};

class ResAction {
public:
    int64_t value;
    int32_t duration;
    int32_t type;
    int32_t onOff;
    int32_t cmdId;
    int64_t endTime;
    bool interaction = true;

public:
    ResAction(int64_t resActionValue, int32_t resActionDuration, int32_t resActionType,
        int32_t resActionOnOff, int32_t resActionCmdId, int64_t resActionEndTime)
    {
        value = resActionValue;
        duration = resActionDuration;
        type = resActionType;
        onOff = resActionOnOff;
        cmdId = resActionCmdId;
        endTime = resActionEndTime;
        if (type != ACTION_TYPE_PERF) {
            interaction = false;
        }
    }
    ~ResAction() {}

    bool TotalSame(std::shared_ptr<ResAction> resAction)
    {
        if (value == resAction->value
            && duration == resAction->duration
            && type == resAction->type
            && onOff == resAction->onOff
            && cmdId == resAction->cmdId) {
            return true;
        }
        return false;
    }

    bool PartSame(std::shared_ptr<ResAction> resAction)
    {
        if (value == resAction->value
            && duration == resAction->duration
            && type == resAction->type
            && cmdId == resAction->cmdId) {
            return true;
        }
        return false;
    }
};

class ResActionItem {
public:
    ResActionItem(int32_t id)
    {
        resId = id;
    }

    ~ResActionItem() = default;

    int32_t resId;
    std::shared_ptr<ResAction> resAction = nullptr;
    std::shared_ptr<ResActionItem> next = nullptr;
};

class ResStatus {
public:
    std::vector<std::list<std::shared_ptr<ResAction>>> resActionList;
    std::vector<int64_t> candidatesValue;
    std::vector<int64_t> candidatesEndTime;
    int64_t candidate;
    int64_t currentValue;
    int64_t previousValue;
    int64_t currentEndTime;
    int64_t previousEndTime;

public:
    explicit ResStatus()
    {
        resActionList = std::vector<std::list<std::shared_ptr<ResAction>>>(ACTION_TYPE_MAX);
        candidatesValue = std::vector<int64_t>(ACTION_TYPE_MAX);
        candidatesEndTime = std::vector<int64_t>(ACTION_TYPE_MAX);
        candidatesValue[ACTION_TYPE_PERF] = INVALID_VALUE;
        candidatesValue[ACTION_TYPE_POWER] = INVALID_VALUE;
        candidatesValue[ACTION_TYPE_THERMAL] = INVALID_VALUE;
        candidatesValue[ACTION_TYPE_PERFLVL] = INVALID_VALUE;
        candidatesEndTime[ACTION_TYPE_PERF] = MAX_INT_VALUE;
        candidatesEndTime[ACTION_TYPE_POWER] = MAX_INT_VALUE;
        candidatesEndTime[ACTION_TYPE_THERMAL] = MAX_INT_VALUE;
        candidatesEndTime[ACTION_TYPE_PERFLVL] = MAX_INT_VALUE;
        candidate = NODE_DEFAULT_VALUE;
        currentValue = NODE_DEFAULT_VALUE;
        previousValue = NODE_DEFAULT_VALUE;
        currentEndTime = MAX_INT_VALUE;
        previousEndTime = MAX_INT_VALUE;
    }
    ~ResStatus() {}
};

class InterAction {
public:
    int32_t cmdId;
    int32_t actionType;
    int64_t delayTime;
    int32_t status;
#ifdef SOCPERF_ADAPTOR_FFRT
    ffrt::task_handle timerTask;
#endif

public:
    InterAction(int32_t cmdid, int32_t actiontype, int64_t delaytime)
    {
        cmdId = cmdid;
        actionType = actiontype;
        delayTime = delaytime;
        status = 0;
#ifdef SOCPERF_ADAPTOR_FFRT
        timerTask = nullptr;
#endif
    }
    ~InterAction() {}
};

static inline int64_t Max(int64_t num1, int64_t num2)
{
    if (num1 >= num2) {
        return num1;
    }
    return num2;
}

static inline int64_t Max(int64_t num1, int64_t num2, int64_t num3)
{
    return Max(Max(num1, num2), num3);
}

static inline int64_t Min(int64_t num1, int64_t num2)
{
    if (num1 <= num2) {
        return num1;
    }
    return num2;
}

static inline int64_t Min(int64_t num1, int64_t num2, int64_t num3)
{
    return Min(Min(num1, num2), num3);
}

static inline bool IsNumber(const std::string& str)
{
    for (int32_t i = 0; i < (int32_t)str.size(); i++) {
        if (i == 0 && str.at(i) == '-') {
            continue;
        }
        if (str.at(i) < '0' || str.at(i) > '9') {
            return false;
        }
    }
    return true;
}

static inline bool IsValidRangeResId(int32_t id)
{
    if (id < MIN_RESOURCE_ID || id > MAX_RESOURCE_ID) {
        return false;
    }
    return true;
}

static inline bool IsValidPersistMode(int32_t persistMode)
{
    if (persistMode != WRITE_NODE && persistMode != REPORT_TO_PERFSO) {
        return false;
    }
    return true;
}

static std::vector<std::string> SplitEx(const std::string& str, const std::string& pattern)
{
    int32_t position;
    std::vector<std::string> result;
    std::string tempStr = str;
    tempStr += pattern;
    int32_t length = (int32_t)tempStr.size();
    for (int32_t i = 0; i < length; i++) {
        position = (int32_t)tempStr.find(pattern, i);
        if (position < length) {
            std::string tmp = tempStr.substr(i, position - i);
            result.push_back(tmp);
            i = position + (int32_t)pattern.size() - 1;
        }
    }
    return result;
}

static inline std::vector<std::string> Split(const std::string& str, const std::string& pattern)
{
    return SplitEx(str, pattern);
}

} // namespace SOCPERF
} // namespace OHOS

#endif // SOC_PERF_SERVICES_CORE_INCLUDE_COMMON_H