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
|
/* BEGIN_COMMON_COPYRIGHT_HEADER
* (c)LGPL2+
**
** SysStat is a Qt-based interface to system statistics
**
** Authors:
** Copyright (c) 2009 - 2012 Kuzma Shapran <Kuzma.Shapran@gmail.com>
**
** This library is free software; you can redistribute it and/or
** modify it under the terms of the GNU Lesser General Public
** License as published by the Free Software Foundation; either
** version 2.1 of the License, or (at your option) any later version.
**
** This library is distributed in the hope that it will be useful,
** but WITHOUT ANY WARRANTY; without even the implied warranty of
** MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
** Lesser General Public License for more details.
**
** You should have received a copy of the GNU Lesser General Public
** License along with this library;
** if not, write to the Free Software Foundation, Inc.,
** 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
**
** END_COMMON_COPYRIGHT_HEADER */
#include "netstat.h"
#include "netstat_p.h"
namespace SysStat {
NetStatPrivate::NetStatPrivate(NetStat *parent)
: BaseStatPrivate(parent)
{
mSource = defaultSource();
connect(mTimer, SIGNAL(timeout()), SLOT(timeout()));
QStringList rows(readAllFile("/proc/net/dev").split(QLatin1Char('\n'), Qt::SkipEmptyParts));
rows.erase(rows.cbegin(), rows.cbegin() + 2);
for (const QString &row : std::as_const(rows))
{
QStringList tokens = row.split(QLatin1Char(':'), Qt::SkipEmptyParts);
if (tokens.size() != 2)
continue;
mSources.append(tokens[0].trimmed());
}
}
NetStatPrivate::~NetStatPrivate() = default;
void NetStatPrivate::timeout()
{
QStringList rows(readAllFile("/proc/net/dev").split(QLatin1Char('\n'), Qt::SkipEmptyParts));
if (rows.size() < 2)
return;
QStringList names = rows[1].split(QLatin1Char('|'));
if (names.size() != 3)
return;
QStringList namesR = names[1].split(QLatin1Char(' '), Qt::SkipEmptyParts);
QStringList namesT = names[2].split(QLatin1Char(' '), Qt::SkipEmptyParts);
int receivedIndex = namesR.indexOf(QLatin1String("bytes"));
int transmittedIndex = namesR.size() + namesT.indexOf(QLatin1String("bytes"));
rows.erase(rows.cbegin(), rows.cbegin() + 2);
for (const QString &row : std::as_const(rows))
{
QStringList tokens = row.split(QLatin1Char(':'), Qt::SkipEmptyParts);
if (tokens.size() != 2)
continue;
QString interfaceName = tokens[0].trimmed();
QStringList data = tokens[1].split(QLatin1Char(' '), Qt::SkipEmptyParts);
if (data.size() < transmittedIndex)
continue;
Values current;
current.received = data[receivedIndex ].toULongLong();
current.transmitted = data[transmittedIndex].toULongLong();
if (!mPrevious.contains(interfaceName))
mPrevious.insert(interfaceName, Values());
const Values &previous = mPrevious[interfaceName];
if (interfaceName == mSource)
emit update((( current.received - previous.received ) * 1000 ) / mTimer->interval(), (( current.transmitted - previous.transmitted ) * 1000 ) / mTimer->interval());
mPrevious[interfaceName] = current;
}
}
QString NetStatPrivate::defaultSource()
{
return QLatin1String("lo");
}
NetStatPrivate::Values::Values()
: received(0)
, transmitted(0)
{
}
NetStat::NetStat(QObject *parent)
: BaseStat(parent)
{
impl = new NetStatPrivate(this);
baseimpl = impl;
connect(impl, SIGNAL(update(unsigned,unsigned)), this, SIGNAL(update(unsigned,unsigned)));
}
NetStat::~NetStat() = default;
}
|
