1 files changed, 101 insertions, 0 deletions
diff --git a/src/devreader-solaris.cpp b/src/devreader-solaris.cpp
new file mode 100644
index 0000000..478b3ca
--- /dev/null
+++ b/src/devreader-solaris.cpp
@@ -0,0 +1,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;
+}
+