src/devreader-solaris.cpp

/*
 * nload
 * real time monitor for network traffic
 * Copyright (C) 2001 - 2012 by Roland Riegel <feedback@roland-riegel.de>
 *
 * 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.
 *
 * This program 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 General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */

/***************************************************************************
 * 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;
}