* -------------------------------------------------------------------------
* This file is part of the MindStudio project.
* Copyright (c) 2025 Huawei Technologies Co.,Ltd.
*
* MindStudio is licensed under Mulan PSL v2.
* You can use this software according to the terms and conditions of the Mulan PSL v2.
* You may obtain a copy of Mulan PSL v2 at:
*
* http://license.coscl.org.cn/MulanPSL2
*
* THIS SOFTWARE IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OF ANY KIND,
* EITHER EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO NON-INFRINGEMENT,
* MERCHANTABILITY OR FIT FOR A PARTICULAR PURPOSE.
* See the Mulan PSL v2 for more details.
* -------------------------------------------------------------------------
*/
#ifndef PROFILER_SERVER_SYSTEMVIEWOVERALLTEXTREPO_H
#define PROFILER_SERVER_SYSTEMVIEWOVERALLTEXTREPO_H
#include "SystemViewOverallRepoInterface.h"
using namespace Dic::Protocol;
namespace Dic::Module::Timeline {
class SystemViewOverallTextRepo : public SystemViewOverallRepoInterface {
public:
~SystemViewOverallTextRepo() override = default;
std::vector<OverallTmpInfo> QueryOverlapAnalysisDataForOverallMetric(
const Protocol::SystemViewOverallReqParam &requestParams,
const std::shared_ptr<VirtualTraceDatabase> &database) override;
bool QueryDataForComputingOverallMetric(const Protocol::SystemViewOverallReqParam &requestParams,
SystemViewOverallHelper &computeHelper, const std::shared_ptr<VirtualTraceDatabase> &database) override;
void QueryCommunicationOverlapOverallInfos(const Protocol::SystemViewOverallReqParam &requestParams,
SystemViewOverallHelper &overallHelper, std::vector<Protocol::SystemViewOverallRes> &responseBody,
const std::shared_ptr<VirtualTraceDatabase> &database) override;
bool QueryCommunicationOpsTimeDataByGroupName(const SystemViewOverallReqParam ¶ms, uint64_t offset,
const std::vector<Protocol::ThreadTraces> ¬OverlapData, std::vector<SameOperatorsDetails> &opsDetails,
const std::shared_ptr<VirtualTraceDatabase> &database) override;
private:
static bool CheckDataForSystemViewOverall(const std::shared_ptr<VirtualTraceDatabase> &database);
static std::map<uint64_t, uint64_t> QueryFlowDict(const Protocol::SystemViewOverallReqParam &requestParams,
const std::shared_ptr<VirtualTraceDatabase> &database);
static std::vector<CpuCubeOpInfo> QueryCpuCubeOp(const Protocol::SystemViewOverallReqParam &requestParams,
const std::shared_ptr<VirtualTraceDatabase> &database);
static std::vector<OverallTmpInfo> QueryKernelEventsForSystemViewOverall(
const Protocol::SystemViewOverallReqParam &requestParams, const std::map<uint64_t, uint64_t> &flowDict,
const std::shared_ptr<VirtualTraceDatabase> &database);
static void QueryBwdTrackIdForComputingOverall(
uint64_t &bwdTrackId, const std::shared_ptr<VirtualTraceDatabase> &database);
};
}
#endif