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
|
#include "consoleworker.h"
#include "copythread.h"
#include "datasource/cpuload.h"
#include "datasource/networkspeed.h"
#include <QFile>
#include <QCoreApplication>
#include <cstdio>
ConsoleWorker::ConsoleWorker(QString fileName) :
_thread(nullptr),
_fileName(fileName),
_networkSource(nullptr)
{
_timer.setInterval(200);
connect(&_timer, &QTimer::timeout, this, &ConsoleWorker::updateTimer);
QTimer::singleShot(1, [this]() {
QFile *file = new QFile(_fileName);
if (!file->open(QIODevice::ReadOnly)) {
puts(tr("Could not open %1 for reading.").arg(_fileName).toLocal8Bit().constData());
return;
}
_networkSource = new NetworkSpeed();
_thread = new CopyThread(file, this);
connect(_thread, &CopyThread::logMessage, this, &ConsoleWorker::logMessage, Qt::QueuedConnection);
connect(_thread, &CopyThread::finished, this, &ConsoleWorker::testFinished, Qt::QueuedConnection);
_timer.start();
_thread->start();
});
}
ConsoleWorker::~ConsoleWorker()
{
delete _networkSource;
}
void ConsoleWorker::logMessage(CopyThread::LogMessageId msgId, QString message)
{
if (msgId == CopyThread::TestRandomStart) {
printf("+SEQ");
} else if (msgId == CopyThread::TestFinished) {
printf("+RND");
}
if (msgId == CopyThread::TestRandomStart || msgId == CopyThread::TestFinished) {
for (int i : _series) {
printf(",%i", i);
}
putchar('\n');
}
_series.clear();
puts(message.toLocal8Bit().constData());
}
void ConsoleWorker::testFinished()
{
_timer.stop();
delete _thread;
_thread = NULL;
QCoreApplication::instance()->quit();
}
void ConsoleWorker::updateTimer()
{
int i = (int)_networkSource->read();
_series.append(i);
}
|
