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
|
/***************************************************************************
* *
* This program is free software; you can redistribute it and/or modify *
* it under the terms of the GNU General Public License as published by *
* the Free Software Foundation; either version 2 of the License, or *
* (at your option) any later version. *
* *
***************************************************************************/
/***************************************************************************
* Solaris specific network code taken out of gkrellm *
* Copyright by Bill Wilson <bill@gkrellm.net> *
* Solaris code by Daisuke Yabuki <dxy@acm.org> *
* adapted for nload by Roland Riegel <feedback@roland-riegel.de> *
***************************************************************************/
#include "devreader-solaris.h"
#include <string.h>
#include <kstat.h>
#include <sys/socket.h>
#include <net/if.h>
#include <string>
#include <list>
using namespace std;
DevReaderSolaris::DevReaderSolaris(const string& deviceName)
: DevReader(deviceName)
{
}
DevReaderSolaris::~DevReaderSolaris()
{
}
list<string> DevReaderSolaris::findAllDevices()
{
list<string> interfaceNames;
struct if_nameindex* interfaces = if_nameindex();
if(!interfaces)
return interfaceNames;
int i = 0;
while(interfaces[i].if_name)
{
interfaceNames.push_back(string(interfaces[i].if_name));
++i;
}
if_freenameindex(interfaces);
return interfaceNames;
}
void DevReaderSolaris::readFromDevice(DataFrame& dataFrame)
{
kstat_ctl_t *kc;
kstat_t *ksp;
kstat_named_t *knp;
char* devName = 0;
if(m_deviceName.empty())
return;
devName = (char*) malloc(m_deviceName.length() + 1);
strncpy(devName, m_deviceName.c_str(), m_deviceName.length());
devName[m_deviceName.length()] = '\0';
kc = kstat_open();
ksp = kstat_lookup(kc, NULL, -1, devName);
if(ksp && kstat_read(kc, ksp, NULL) >= 0)
{
knp = (kstat_named_t *) kstat_data_lookup(ksp, "rbytes");
dataFrame.setTotalDataIn(knp ? knp->value.ui32 : 0);
knp = (kstat_named_t *) kstat_data_lookup(ksp, "obytes");
dataFrame.setTotalDataOut(knp ? knp->value.ui32 : 0);
knp = (kstat_named_t *) kstat_data_lookup(ksp, "ipackets");
dataFrame.setTotalPacketsIn(knp ? knp->value.ui32 : 0);
knp = (kstat_named_t *) kstat_data_lookup(ksp, "opackets");
dataFrame.setTotalPacketsOut(knp ? knp->value.ui32 : 0);
knp = (kstat_named_t *) kstat_data_lookup(ksp, "ierrors");
dataFrame.setTotalErrorsIn(knp ? knp->value.ui32 : 0);
knp = (kstat_named_t *) kstat_data_lookup(ksp, "oerrors");
dataFrame.setTotalErrorsOut(knp ? knp->value.ui32 : 0);
dataFrame.setValid(true);
}
kstat_close(kc);
free(devName);
devName = 0;
}
|
