//
//  Rewritten for Solaris by Arno Augustin 1999
//  augustin@informatik.uni-erlangen.de
//

#include "netmeter.h"
#include <stdlib.h>
#include <unistd.h>
#include <stropts.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/sockio.h>
#include <string.h>
#include <iostream>
#ifdef DEBUG
#include <sstream>
#endif


NetMeter::NetMeter( XOSView *parent, kstat_ctl_t *kc, float max )
  : FieldMeterGraph( parent, 3, "NET", "IN/OUT/IDLE" ){
  _kc = kc;
  _ignored = false;
  _maxpackets = max;
  _lastBytesIn = _lastBytesOut = 0;
  _nets = KStatList::getList(_kc, KStatList::NETS);
  if ( (_socket = socket(AF_INET, SOCK_DGRAM, 0)) < 0 ) {
    std::cerr << "Opening socket failed." << std::endl;
    parent_->done(1);
    return;
  }
}

NetMeter::~NetMeter( void ){
  close(_socket);
}

void NetMeter::checkResources( void ){
  FieldMeterGraph::checkResources();

  setfieldcolor( 0, parent_->getResource("netInColor") );
  setfieldcolor( 1, parent_->getResource("netOutColor") );
  setfieldcolor( 2, parent_->getResource("netBackground") );
  priority_ = atoi( parent_->getResource("netPriority") );
  dodecay_ = parent_->isResourceTrue("netDecay");
  useGraph_ = parent_->isResourceTrue("netGraph");
  SetUsedFormat( parent_->getResource("netUsedFormat") );
  _netIface = parent_->getResource("netIface");
  if (_netIface[0] == '-') {
    _ignored = true;
    _netIface.erase(0, _netIface.find_first_not_of("- "));
  }
}

void NetMeter::checkevent( void ){
  getnetstats();
  drawfields();
}

void NetMeter::getnetstats( void ){
  uint64_t nowBytesIn = 0, nowBytesOut = 0;
  kstat_named_t *k;
  kstat_t *ksp;
  total_ = _maxpackets;
  _nets->update(_kc);

  IntervalTimerStop();
  for (unsigned int i = 0; i < _nets->count(); i++) {
#ifdef DEBUG
    std::stringstream msg;
#endif
    ksp = (*_nets)[i];
    if ( _netIface != "False" &&
         ( (!_ignored && ksp->ks_name != _netIface) ||
           ( _ignored && ksp->ks_name == _netIface) ) )
      continue;
    if ( kstat_read(_kc, ksp, NULL) == -1 )
      continue;

#ifdef DEBUG
    msg << ksp->ks_name << ": ";
#endif
    // try 64-bit byte counter first, then 32-bit one, then packet counter
    if ( (k = (kstat_named_t *)kstat_data_lookup(ksp, "rbytes64")) == NULL ) {
      if ( (k = (kstat_named_t *)kstat_data_lookup(ksp, "rbytes")) == NULL ) {
        if ( (k = (kstat_named_t *)kstat_data_lookup(ksp, "ipackets")) == NULL )
          continue;
        // for packet counter, mtu is needed
        strncpy(_lfr.lifr_name, ksp->ks_name, sizeof(_lfr.lifr_name));
        if ( ioctl(_socket, SIOCGLIFMTU, (caddr_t)&_lfr) < 0 )
          continue;
        nowBytesIn += kstat_to_ui64(k) * _lfr.lifr_mtu; // not exactly, but must do
#ifdef DEBUG
        msg << kstat_to_ui64(k) << " packets received ";
#endif
      }
      else {
        nowBytesIn += kstat_to_ui64(k);
#ifdef DEBUG
        msg << kstat_to_ui64(k) << " bytes received ";
#endif
      }
    }
    else {
      nowBytesIn += kstat_to_ui64(k);
#ifdef DEBUG
        msg << kstat_to_ui64(k) << " bytes received ";
#endif
    }

    if ( (k = (kstat_named_t *)kstat_data_lookup(ksp, "obytes64")) == NULL ) {
      if ( (k = (kstat_named_t *)kstat_data_lookup(ksp, "obytes")) == NULL ) {
        if ( (k = (kstat_named_t *)kstat_data_lookup(ksp, "opackets")) == NULL )
          continue;
        strncpy(_lfr.lifr_name, ksp->ks_name, sizeof(_lfr.lifr_name));
        if ( ioctl(_socket, SIOCGLIFMTU, (caddr_t)&_lfr) < 0 )
          continue;
        nowBytesOut += kstat_to_ui64(k) * _lfr.lifr_mtu;
#ifdef DEBUG
        msg << kstat_to_ui64(k) << " packets sent ";
#endif
      }
      else {
        nowBytesOut += kstat_to_ui64(k);
#ifdef DEBUG
        msg << kstat_to_ui64(k) << " bytes sent ";
#endif
      }
    }
    else {
      nowBytesOut += kstat_to_ui64(k);
#ifdef DEBUG
      msg << kstat_to_ui64(k) << " bytes sent ";
#endif
    }
#ifdef DEBUG
    msg << std::ends;
    XOSDEBUG("%s\n", msg.str().c_str())
#endif
  }

  uint64_t correction = 0x10000000;
  correction *= 0x10;
  /*  Deal with 32-bit wrap by making last value 2^32 less.  Yes,
   *  this is a better idea than adding to nowBytesIn -- the
   *  latter would only work for the first wrap (1+2^32 vs. 1)
   *  but not for the second (1+2*2^32 vs. 1) -- 1+2^32 -
   *  (1+2^32) is still too big.  */
  if (nowBytesIn < _lastBytesIn)
    _lastBytesIn -= correction;
  if (nowBytesOut < _lastBytesOut)
    _lastBytesOut -= correction;
  if(_lastBytesIn == 0)
    _lastBytesIn = nowBytesIn;
  if(_lastBytesOut == 0)
    _lastBytesOut = nowBytesOut;

  double t = IntervalTimeInSecs();
  fields_[0] = (double)(nowBytesIn - _lastBytesIn) / t;
  fields_[1] = (double)(nowBytesOut - _lastBytesOut) / t;

  IntervalTimerStart();
  _lastBytesIn = nowBytesIn;
  _lastBytesOut = nowBytesOut;

  if (total_ < fields_[0] + fields_[1])
    total_ = fields_[0] + fields_[1];
  fields_[2] = total_ - fields_[0] - fields_[1];
  setUsed(fields_[0] + fields_[1], total_);
}