1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
|
// SPDX-FileCopyrightText: 2019 - 2022 UnionTech Software Technology Co., Ltd.
//
// SPDX-License-Identifier: GPL-3.0-or-later
#ifndef LOGAUTHTHREAD_H
#define LOGAUTHTHREAD_H
#include "structdef.h"
#include <QProcess>
#include <QRunnable>
#include <QMap>
/**
* @brief The LogAuthThread class 启动日志 内核日志 kwin日志 xorg日志 dpkg日志获取线程
*/
class LogAuthThread : public QObject, public QRunnable
{
Q_OBJECT
public:
explicit LogAuthThread(QObject *parent = nullptr);
~LogAuthThread() override;
void initDnfLevelMap();
void initLevelMap();
void setType(LOG_FLAG flag) { m_type = flag; }
void setParseMap(bool parseMap) { m_parseMap = parseMap; }
void setFileterParam(const KWIN_FILTERS &iFIlters) { m_kwinFilters = iFIlters; }
void setFileterParam(const XORG_FILTERS &iFIlters) { m_xorgFilters = iFIlters; }
void setFileterParam(const DKPG_FILTERS &iFIlters) { m_dkpgFilters = iFIlters; }
void setFileterParam(const KERN_FILTERS &iFIlters) { m_kernFilters = iFIlters; }
void setFileterParam(const NORMAL_FILTERS &iFIlters) { m_normalFilters = iFIlters; }
void setFileterParam(const DNF_FILTERS &iFIlters) { m_dnfFilters = iFIlters; }
void setFileterParam(const DMESG_FILTERS &iFIlters) { m_dmesgFilters = iFIlters; }
void setFileterParam(const AUDIT_FILTERS &iFIlters) { m_auditFilters = iFIlters; }
void setFileterParam(const COREDUMP_FILTERS &iFIlters) { m_coredumpFilters = iFIlters; }
void stopProccess();
void setFilePath(const QStringList &filePath);
int getIndex();
QString startTime();
/**
* @brief thread_index 静态成员变量，用来每次构造时标记新的当前线程对象 m_threadIndex
*/
static int thread_count;
protected:
void run() override;
void handleBoot();
void handleKern();
void handleKwin();
void handleXorg();
void handleDkpg();
void handleNormal();
/**
* @brief NormalInfoTime 开关机事件信息段解析
*/
void NormalInfoTime();
void handleDnf();
void handleDmesg();
void handleAudit();
void handleCoredump();
void initProccess();
qint64 formatDateTime(QString m, QString d, QString t);
qint64 formatDateTime(QString y, QString t);
signals:
void kernFinished(int index);
/**
* @brief kernData
* @param index 当前线程的数字标号
* @param iDataList 数据list
*/
void kernData(int index, QList<LOG_MSG_JOURNAL> iDataList);
void bootFinished(int index);
/**
* @brief bootData
* @param index 当前线程的数字标号
* @param iDataList 数据list
*/
void bootData(int index, QList<LOG_MSG_BOOT> iDataList);
void kwinFinished(int index);
void kwinData(int index, QList<LOG_MSG_KWIN> iDataList);
void xorgFinished(int index);
void xorgData(int index, QList<LOG_MSG_XORG> iDataList);
void dpkgFinished(int index);
void dpkgData(int index, QList<LOG_MSG_DPKG> iDataList);
void normalFinished(int index);
void normalData(int index, QList<LOG_MSG_NORMAL> iDataList);
void dnfFinished(QList<LOG_MSG_DNF> iKwinList);
void dmesgFinished(QList<LOG_MSG_DMESG> iKwinList);
void auditFinished(int index, bool bShowTip = false);
void auditData(int index, QList<LOG_MSG_AUDIT> iDataList);
void coredumpFinished(int index);
void coredumpData(int index, QList<LOG_MSG_COREDUMP> iDataList);
void proccessError(const QString &iError);
public slots:
// void onFinished(int exitCode);
// void kernDataRecived();
private:
QString readAppLogFromLastLines(const QString& filePath, const int& count);
private:
/**
* @brief m_type 当前线程获取日志数据的类型，用来指定不同的获取逻辑和返回结果
*/
LOG_FLAG m_type;
/**
* @brief m_kwinFilters kwin日志筛选条件
*/
KWIN_FILTERS m_kwinFilters;
/**
* @brief m_xorgFilters xorg日志筛选条件
*/
XORG_FILTERS m_xorgFilters;
/**
* @brief m_dkpgFilters dpkg日志筛选条件
*/
DKPG_FILTERS m_dkpgFilters;
/**
* @brief m_kernFilters 内核日志筛选条件
*/
KERN_FILTERS m_kernFilters;
/**
* @brief m_normalFilters 开关机日志筛选条件
*/
NORMAL_FILTERS m_normalFilters;
DNF_FILTERS m_dnfFilters;
DMESG_FILTERS m_dmesgFilters;
/**
* @brief m_normalFilters 开关机日志筛选条件
*/
AUDIT_FILTERS m_auditFilters;
COREDUMP_FILTERS m_coredumpFilters;
//获取数据用的cat命令的process
QScopedPointer<QProcess> m_process;
/**
* @brief m_canRun 是否可以继续运行的标记量，用于停止运行线程
*/
std::atomic_bool m_canRun = false;
/**
* @brief m_threadIndex 当前线程标号
*/
bool m_parseMap = false; // 崩溃信息是否要解析map信息，即stackinfo
int m_threadCount;
//正在执行停止进程的变量，防止重复执行停止逻辑
bool m_isStopProccess = false;
//日志显示时间(毫秒)
qint64 iTime;
//所有日志文件路径
QStringList m_FilePath;
QMap<int, QString> m_levelMap;
QMap<QString, int> m_dnfLevelDict;
QMap<QString, QString> m_transDnfDict;
QStringList TimeList;
};
#endif // LOGAUTHTHREAD_H
|
