utility/common_utils/tbox.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 "tbox.h"

#include <unistd.h>

#include <regex>
#include "calc_fingerprint.h"
#include "file_util.h"
#include "log_parse.h"
#include "securec.h"
#include "string_util.h"
#include "time_util.h"

using namespace std;
namespace OHOS {
namespace HiviewDFX {
DEFINE_LOG_TAG("Tbox");

const string Tbox::ARRAY_STR = "ARRAY :";

Tbox::Tbox()
{
}

Tbox::~Tbox()
{
}

string Tbox::CalcFingerPrint(const string& val, size_t mask, int mode)
{
    char hash[HAS_LEN] = {'0'};
    int err = -1;
    switch (mode) {
        case FP_FILE:
            err = CalcFingerprint::CalcFileSha(val, hash, sizeof(hash));
            break;
        case FP_BUFFER:
            err = CalcFingerprint::CalcBufferSha(val, val.size(), hash, sizeof(hash));
            break;
        default:
            break;
    }

    if (err != 0) {
        // if file not exist, API will return ENOENT
        HIVIEW_LOGE("ProcessedEvent: calc fingerprint failed, err is %{public}d.", err);
    }
    return string(hash);
}

bool Tbox::GetPartial(const string& src, const string& res, string& des)
{
    des = "";
    regex reNew(res);
    smatch result;
    if (regex_search(src, result, reNew)) {
        for (size_t i = 1; i < result.size(); ++i) {
            if (!result.str(i).empty()) {
                des = string(result.str(i));
                break;
            }
        }
        return true;
    }
    return false;
}

bool Tbox::IsCallStack(const string& line)
{
    if (regex_search(line, regex("^\\s+at (.*)\\(.*")) ||
        regex_search(line, regex("^\\s*at .*")) ||
        regex_search(line, regex("^\\s+- (.*)\\(.*")) ||
        regex_search(line, regex("\\s+#\\d+")) ||
        regex_search(line, regex("[0-9a-zA-Z_]+\\+0x[0-9a-f]+/0x[0-9a-f]+")) ||
        regex_search(line, regex("#\\d+")) ||
        regex_search(line, regex("\\.*"))) {
        return true;
    }
    return false;
}

/*
 * format1:  com.ohos.launcher:extension
 * format2:  #06 pc 00000000000bb328  /system/lib/libart.so (__epoll_pwait+8)
 */
string Tbox::GetStackName(const string& line)
{
    string stackname = UNKNOWN_STR;
    string str;
    if (GetPartial(line, "^\\s+at (.*)\\).*", str) ||
        GetPartial(line, "^\\s*at (.*)", str) || // for jsCrash
        GetPartial(line, "#\\d+ pc [0-9a-f]+ (.*\\+\\d+)\\)", str) ||
        GetPartial(line, "#\\d+ pc [0-9a-f]+ (.*)", str) ||
        GetPartial(line, "([0-9a-zA-Z_]+\\+0x[0-9a-f]+/0x[0-9a-f]+)", str)) {
        stackname = str;
    } else if (GetPartial(line, "^\\s+- (.*)\\(.*", str)) {
        size_t ret = str.find_last_of("+");
        if (ret != string::npos) {
            str.replace(ret, string::npos, ")\0");
            stackname = str;
        } else {
            stackname = UNKNOWN_STR;
        }
    } else if (IsCallStack(line)) {
        stackname = line;
    } else {
        return stackname;
    }
    regex re("(.+?)-(.+)==(.+)");
    stackname = regex_replace(stackname, re, "$1$3");
    return stackname;
}

void Tbox::FilterTrace(std::map<std::string, std::string>& eventInfo, string eventType)
{
    auto iterEndStack = eventInfo.find(PARAMETER_ENDSTACK);
    if (eventInfo.empty() || iterEndStack == eventInfo.end() || iterEndStack->second.empty()) {
        return;
    }
    std::vector<std::string> trace;
    LogParse logparse;
    std::string block = logparse.GetFilterTrace(iterEndStack->second, trace, eventType);
    eventInfo[PARAMETER_ENDSTACK] = block;
    std::stack<std::string> stackTop = logparse.GetStackTop(trace, 3);  // 3 : first/second/last frame
    logparse.SetFrame(stackTop, eventInfo);
}

bool Tbox::WaitForDoneFile(const std::string& file, unsigned int timeout)
{
    uint64_t remainedTime = timeout * NS_PER_SECOND;
    while (remainedTime > 0) {
        if (FileUtil::FileExists(file)) {
            HIVIEW_LOGD("Done file exist: %{public}s", file.c_str());
            return true;
        }
        uint64_t startTime = TimeUtil::GetNanoTime();
        sleep(1);
        uint64_t duration = TimeUtil::GetNanoTime() - startTime;
        remainedTime = (remainedTime > duration) ? (remainedTime - duration) : 0;
    }
    return false;
}

int64_t Tbox::GetHappenTime(const string& src, const string& regex)
{
    int64_t happenTime = HAPPEN_TIME_DEFAULT;
    std::regex recordRegex(regex);
    struct tm tmHappenTime;
    (void)memset_s(&tmHappenTime, sizeof(struct tm), 0, sizeof(struct tm));
    std::smatch matches;
    if (!std::regex_match(src, matches, recordRegex)) {
        HIVIEW_LOGE("unmatch event:%{public}s, skip", src.c_str());
        return happenTime;
    }

    string timeStr;
    for (size_t i = 1; i < matches.size(); ++i) {
        timeStr += matches[i].str();
    }
    strptime(timeStr.c_str(), "%Y%m%d%H%M%S", &tmHappenTime);
    happenTime = mktime(&tmHappenTime);
    //if the HappenTime is 1970, return as original information
    if (tmHappenTime.tm_year == 70) { // 70: The number of years since the HappenTime in 1900
        return happenTime;
    }

    time_t now = time(nullptr);
    struct tm result;
    gmtime_r(&now, &result);
    double offset = difftime(now, mktime(&result)); // zone offset with second. Example, 1 zone is 3600 sec
    if (difftime(now, happenTime) > offset) {
        happenTime = timegm(&tmHappenTime);
    }
    return happenTime;
}
}
}