/*************************************************************************** * * * 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. * * * ***************************************************************************/ /*************************************************************************** * HP-UX specific network code * * * * Copyright 1998 by Hewlett-Packard Company * * * * Permission to use, copy, modify, and distribute this * * software and its documentation for any purpose and without * * fee is hereby granted, provided that the above copyright * * notice appear in all copies and that both that copyright * * notice and this permission notice appear in supporting * * documentation, and that the name of Hewlett-Packard Company not * * be used in advertising or publicity pertaining to distribution * * of the software without specific, written prior permission. * * Hewlett-Packard makes no representations about the * * suitability of this software for any purpose. It is provided * * "as is" without express or implied warranty. * * * * * * Modification History: * * * * int_stats.c : Get network statistics from the dlpi device * * On 10.20 only get a mib_ifEntry, on 11.0 this is followed * * by an mib_Dot3StatsEntry. Accessing the latter structure * * is left as an exercise for the reader, the struct is defined * * in /usr/include/sys/mib.h along with mib_ifEntry. * * * * Author: Jon Dewis, SPP 3/26/98 * * (With ackn to 'lanadmin' source code and streams class notes) * * * * 24-June-1998 Add mib3 stats (AJD) when compiling * * for 11.0 ensure HP_UX11 macro defined * * e.g. cc -o int_stats -DHP_UX11 int_stats.c * * 16-Dec-1999 Change to obviate need for lanscan to get * * nmid - thus assumes any old nmid will do * * and just iterates thru the 1st 100 possibilities * * (MAX_NMID). Works on 10.20 and 11.0 * * Dec 2003 Modified by Roshan Sequeira roshan.sequeira@hp.com, * * to get network statistics for the nload port to HP-UX. * * Original code available at * * http://h21007.www2.hp.com/dspp/tech/tech_TechDocumentDetailPage_IDX/1,1701,2599,00.html * * ***************************************************************************/ #include "devreader-hpux.h" #include "stringutils.h" #ifdef HAVE_CONFIG_H #include #endif #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include using namespace std; #define AREA_SIZE 40000 #define LONG_AREA_SIZE (AREA_SIZE / sizeof(u_long)) static u_long ctrl_area[LONG_AREA_SIZE]; /* for control messages */ static u_long data_area[LONG_AREA_SIZE]; /* for data messages */ static u_long ppa_area[LONG_AREA_SIZE]; /* for saving ppa area */ static struct strbuf ctrl_buf = {AREA_SIZE, 0, (char*) ctrl_area}; static struct strbuf data_buf = {AREA_SIZE, 0, (char*) data_area}; DevReaderHpux::DevReaderHpux(const string& deviceName) : DevReader(deviceName) { } DevReaderHpux::~DevReaderHpux() { } list DevReaderHpux::findAllDevices() { list devicesFound; dl_hp_ppa_info_t* ppa_info_temp; dl_hp_ppa_req_t* ppa_req; dl_hp_ppa_ack_t* ppa_ack; dl_attach_req_t* attach_req; int fd = -1; if((fd = open("/dev/dlpi", O_RDWR)) < 0) { perror("open /dev/dlpi"); return devicesFound; } do { ppa_req = (dl_hp_ppa_req_t*) ctrl_area; ppa_ack = (dl_hp_ppa_ack_t*) ctrl_area; ppa_req->dl_primitive = DL_HP_PPA_REQ; ctrl_buf.len = sizeof(dl_hp_ppa_req_t); if(putmsg(fd, &ctrl_buf, 0, 0) < 0) { perror("putmsg DL_HP_PPA_REQ"); break; } int flags = 0; ctrl_area[0] = 0; if(getmsg(fd, &ctrl_buf, &data_buf, &flags) < 0) { perror("getmsg DL_HP_PPA_REQ"); break; } if(ppa_ack->dl_length == 0) { fprintf(stderr, "error: no PPAs available\n"); break; } // save all the PPA information memcpy((u_char*) ppa_area, (u_char*) ctrl_area + ppa_ack->dl_offset, ppa_ack->dl_length); int ppa_count = ppa_ack->dl_count; int count; for(count = 0, ppa_info_temp = (dl_hp_ppa_info_t*) ppa_area; count < ppa_count; count++, ppa_info_temp++) devicesFound.push_back(string("lan") + toString(ppa_info_temp->dl_ppa)); } while(0); close(fd); return devicesFound; } void DevReaderHpux::readFromDevice(DataFrame& dataFrame) { dl_get_statistics_req_t* get_statistics_req = (dl_get_statistics_req_t*) ctrl_area; dl_get_statistics_ack_t* get_statistics_ack = (dl_get_statistics_ack_t*) ctrl_area; dl_hp_ppa_info_t ppa_info; dl_hp_ppa_info_t* ppa_info_temp; dl_hp_ppa_req_t* ppa_req; dl_hp_ppa_ack_t* ppa_ack; dl_attach_req_t* attach_req; mib_ifEntry* mib_ptr; unsigned int ppa = 0; int flags = 0, ppa_count = 0, count = 0; // make sure interface name begins with lan if(m_deviceName.length() < 3 || m_deviceName.substr(0, 3) != "lan") return; // get the PPA from the interface name ppa = fromString(m_deviceName.substr(3)); if(ppa == 0 && m_deviceName != "lan0") return; int fd = -1; if((fd = open("/dev/dlpi", O_RDWR)) < 0) { perror("open /dev/dlpi"); return; } do { ppa_req = (dl_hp_ppa_req_t*) ctrl_area; ppa_ack = (dl_hp_ppa_ack_t*) ctrl_area; ppa_req->dl_primitive = DL_HP_PPA_REQ; ctrl_buf.len = sizeof(dl_hp_ppa_req_t); if(putmsg(fd, &ctrl_buf, 0, 0) < 0) { perror("putmsg DL_HP_PPA_REQ"); break; } flags = 0; ctrl_area[0] = 0; if(getmsg(fd, &ctrl_buf, &data_buf, &flags) < 0) { perror("getmsg DL_HP_PPA_REQ"); break; } if(ppa_ack->dl_length == 0) { fprintf(stderr, "Error: No PPAs available\n"); break; } // save all the PPA information memcpy((u_char*) ppa_area, (u_char*) ctrl_area + ppa_ack->dl_offset, ppa_ack->dl_length); ppa_count = ppa_ack->dl_count; bool found = false; for(count = 0, ppa_info_temp = (dl_hp_ppa_info_t*) ppa_area; count < ppa_count; count++, ppa_info_temp++) { if(ppa_info_temp->dl_ppa == ppa) { found = true; break; } } if(!found) { fprintf(stderr, "error: PPA %d not found\n", ppa); break; } attach_req = (dl_attach_req_t*) ctrl_area; attach_req->dl_primitive = DL_ATTACH_REQ; attach_req->dl_ppa = ppa; ctrl_buf.len = sizeof(dl_attach_req_t); if(putmsg(fd, &ctrl_buf, 0, 0) < 0) { perror("putmsg DL_ATTACH_REQ"); break; } ctrl_area[0] = 0; if(getmsg(fd, &ctrl_buf, &data_buf, &flags) < 0) { perror("getmsg DL_ATTACH_REQ"); break; } memcpy(&ppa_info, ppa_info_temp, sizeof(ppa_info)); get_statistics_req->dl_primitive = DL_GET_STATISTICS_REQ; ctrl_buf.len = sizeof(dl_get_statistics_req_t); flags = 0; if(putmsg(fd, &ctrl_buf, NULL, 0) < 0) { perror("putmsg DL_GET_STATISTICS_REQ"); break; } if(getmsg(fd, &ctrl_buf, NULL, &flags) < 0) { perror("getmsg DL_GET_STATISTICS_REQ"); break; } if(get_statistics_ack->dl_primitive != DL_GET_STATISTICS_ACK) fprintf(stderr, "error: wrong primitive\n"); mib_ptr = (mib_ifEntry*) ((u_char*) ctrl_area + get_statistics_ack->dl_stat_offset); dataFrame.setTotalDataIn(mib_ptr->ifInOctets); dataFrame.setTotalDataOut(mib_ptr->ifOutOctets); dataFrame.setTotalPacketsIn(mib_ptr->ifInUcastPkts + mib_ptr->ifInNUcastPkts); dataFrame.setTotalPacketsOut(mib_ptr->ifOutUcastPkts + mib_ptr->ifOutNUcastPkts); dataFrame.setTotalErrorsIn(mib_ptr->ifInErrors); dataFrame.setTotalErrorsOut(mib_ptr->ifOutErrors); dataFrame.setTotalDropsIn(mib_ptr->ifInDiscards); dataFrame.setTotalDropsOut(mib_ptr->ifOutDiscards); dataFrame.setValid(true); } while(0); close(fd); }