start overhaul of windows net_interface impls
This commit is contained in:
Doug MacEachern
parent
e26be5dc38
commit
1bc2ad33a4
|
|
@ -34,7 +34,7 @@
|
|||
#define _STRUCT_TM
|
||||
#include <nwtime.h>
|
||||
#include <nit/nwservst.h>
|
||||
|
||||
#include <monitor.h>
|
||||
/*
|
||||
* http://developer.novell.com/research/appnotes/2003/may/05/a0305058.htm
|
||||
*/
|
||||
|
|
@ -442,3 +442,244 @@ int sigar_os_sys_info_get(sigar_t *sigar,
|
|||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
int sigar_get_iftype(const char *name, int *type, int *inst)
|
||||
{
|
||||
if (strnEQ(name, "eth", IFTYPE_ETH)) {
|
||||
*type = IFTYPE_ETH;
|
||||
}
|
||||
else if (strnEQ(name, "lo", IFTYPE_LO)) {
|
||||
*type = IFTYPE_LO;
|
||||
}
|
||||
else {
|
||||
return EINVAL;
|
||||
}
|
||||
|
||||
if (isdigit(*(name + *type))) {
|
||||
*inst = atoi(name + *type);
|
||||
}
|
||||
else {
|
||||
return EINVAL;
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
static void hwaddr_lookup(sigar_t *sigar,
|
||||
sigar_net_interface_config_t *ifconfig,
|
||||
int num)
|
||||
{
|
||||
uint8_t addr[SIGAR_IFHWADDRLEN];
|
||||
|
||||
if (netware_net_macaddr(num+1, addr) == 0) {
|
||||
sigar_net_address_mac_set(ifconfig->hwaddr,
|
||||
addr,
|
||||
sizeof(addr));
|
||||
}
|
||||
else {
|
||||
sigar_hwaddr_set_null(ifconfig);
|
||||
}
|
||||
}
|
||||
|
||||
static int sigar_ioctl_iflist(sigar_t *sigar,
|
||||
SOCKET sock,
|
||||
DWORD *bytes)
|
||||
{
|
||||
return WSAIoctl(sock,
|
||||
SIO_GET_INTERFACE_LIST,
|
||||
NULL,
|
||||
0,
|
||||
(void *)sigar->ifconf_buf,
|
||||
sigar->ifconf_len,
|
||||
bytes,
|
||||
NULL,
|
||||
NULL);
|
||||
}
|
||||
|
||||
static int get_iflist(sigar_t *sigar, DWORD *bytes)
|
||||
{
|
||||
SOCKET sock = INVALID_SOCKET;
|
||||
int status, rc, limit;
|
||||
|
||||
sock = socket(AF_INET, SOCK_DGRAM, 0);
|
||||
|
||||
if (sock == INVALID_SOCKET) {
|
||||
return WSAGetLastError();
|
||||
}
|
||||
|
||||
if (sigar->ifconf_len == 0) {
|
||||
sigar->ifconf_len = 8192;
|
||||
sigar->ifconf_buf = malloc(sigar->ifconf_len);
|
||||
}
|
||||
|
||||
/*
|
||||
* XXX We can't tell ahead of time what buffer size is required
|
||||
* limit just incase.
|
||||
*/
|
||||
for (limit=0; limit<100; limit++) {
|
||||
rc = sigar_ioctl_iflist(sigar, sock, bytes);
|
||||
if (rc && (WSAGetLastError() == WSAEFAULT)) {
|
||||
sigar->ifconf_len += (sizeof(INTERFACE_INFO) * 16);
|
||||
sigar->ifconf_buf = malloc(sigar->ifconf_len);
|
||||
}
|
||||
}
|
||||
|
||||
status = rc ? WSAGetLastError() : SIGAR_OK;
|
||||
|
||||
closesocket(sock);
|
||||
|
||||
return status;
|
||||
}
|
||||
|
||||
SIGAR_DECLARE(int)
|
||||
sigar_net_interface_config_get(sigar_t *sigar,
|
||||
const char *name,
|
||||
sigar_net_interface_config_t *ifconfig)
|
||||
{
|
||||
DWORD i, num, bytes;
|
||||
DWORD lo=0, eth=0;
|
||||
int status, type, inst;
|
||||
INTERFACE_INFO *if_info = NULL;
|
||||
u_long flags;
|
||||
|
||||
/* win32 lacks socket ioctls to query given interface.
|
||||
* so we loop through the list to find our made up ifname.
|
||||
*/
|
||||
status = get_iflist(sigar, &bytes);
|
||||
if (status != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
num = bytes / sizeof(INTERFACE_INFO);
|
||||
|
||||
if ((status = sigar_get_iftype(name, &type, &inst)) != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
for (i=0; i<num ; i++) {
|
||||
if_info = ((INTERFACE_INFO *)sigar->ifconf_buf) + i;
|
||||
|
||||
if (if_info->iiFlags & IFF_LOOPBACK) {
|
||||
if ((type == IFTYPE_LO) && (inst == lo)) {
|
||||
break;
|
||||
}
|
||||
++lo;
|
||||
}
|
||||
else {
|
||||
if ((type == IFTYPE_ETH) && (inst == eth)) {
|
||||
break;
|
||||
}
|
||||
++eth;
|
||||
}
|
||||
|
||||
if_info = NULL;
|
||||
}
|
||||
|
||||
if (!if_info) {
|
||||
return ENOENT;
|
||||
}
|
||||
|
||||
SIGAR_ZERO(ifconfig);
|
||||
|
||||
SIGAR_SSTRCPY(ifconfig->name, name);
|
||||
|
||||
#define if_s_addr(a) \
|
||||
((struct sockaddr_in *)&a)->sin_addr.s_addr
|
||||
|
||||
sigar_net_address_set(ifconfig->address,
|
||||
if_s_addr(if_info->iiAddress));
|
||||
sigar_net_address_set(ifconfig->broadcast,
|
||||
if_s_addr(if_info->iiBroadcastAddress));
|
||||
sigar_net_address_set(ifconfig->netmask,
|
||||
if_s_addr(if_info->iiNetmask));
|
||||
|
||||
flags = if_info->iiFlags;
|
||||
|
||||
if (flags & IFF_UP) {
|
||||
ifconfig->flags |= SIGAR_IFF_UP|SIGAR_IFF_RUNNING;
|
||||
}
|
||||
if (flags & IFF_BROADCAST) {
|
||||
ifconfig->flags |= SIGAR_IFF_BROADCAST;
|
||||
}
|
||||
if (flags & IFF_LOOPBACK) {
|
||||
ifconfig->flags |= SIGAR_IFF_LOOPBACK;
|
||||
sigar_net_address_set(ifconfig->destination,
|
||||
ifconfig->address.addr.in);
|
||||
sigar_net_address_set(ifconfig->broadcast, 0);
|
||||
SIGAR_SSTRCPY(ifconfig->type,
|
||||
SIGAR_NIC_LOOPBACK);
|
||||
}
|
||||
else {
|
||||
SIGAR_SSTRCPY(ifconfig->type,
|
||||
SIGAR_NIC_ETHERNET);
|
||||
}
|
||||
|
||||
/* should be overridden w/ better description
|
||||
* using MIB_IFROW.bDescr when hwaddr is lookedup
|
||||
*/
|
||||
SIGAR_SSTRCPY(ifconfig->description,
|
||||
ifconfig->name);
|
||||
|
||||
hwaddr_lookup(sigar, ifconfig, i);
|
||||
|
||||
if (flags & IFF_POINTTOPOINT) {
|
||||
ifconfig->flags |= SIGAR_IFF_POINTOPOINT;
|
||||
}
|
||||
if (flags & IFF_MULTICAST) {
|
||||
ifconfig->flags |= SIGAR_IFF_MULTICAST;
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
/*
|
||||
* win32 interface list does not include a name.
|
||||
* and the name from GetIfList() is the name of card
|
||||
* including vendor name, etc. so we use 'eth' for ethernet
|
||||
* interfaces and 'lo' for loopback.
|
||||
*/
|
||||
|
||||
#define ETH "eth"
|
||||
#define LO "lo"
|
||||
|
||||
SIGAR_DECLARE(int)
|
||||
sigar_net_interface_list_get(sigar_t *sigar,
|
||||
sigar_net_interface_list_t *iflist)
|
||||
{
|
||||
char eth[56], lo[56];
|
||||
int ethcnt=0, locnt=0;
|
||||
DWORD i, num, bytes;
|
||||
int status;
|
||||
|
||||
status = get_iflist(sigar, &bytes);
|
||||
if (status != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
num = bytes / sizeof(INTERFACE_INFO);
|
||||
|
||||
iflist->number = 0;
|
||||
iflist->size = num;
|
||||
iflist->data =
|
||||
malloc(sizeof(*(iflist->data)) * iflist->size);
|
||||
|
||||
for (i=0; i<num ; i++) {
|
||||
INTERFACE_INFO *if_info =
|
||||
((INTERFACE_INFO *)sigar->ifconf_buf) + i;
|
||||
char *name;
|
||||
|
||||
if (if_info->iiFlags & IFF_LOOPBACK) {
|
||||
sprintf(lo, LO "%d", locnt++);
|
||||
name = strdup(lo);
|
||||
}
|
||||
else {
|
||||
/* XXX: assuming ethernet here */
|
||||
sprintf(eth, ETH "%d", ethcnt++);
|
||||
name = strdup(eth);
|
||||
}
|
||||
|
||||
iflist->data[iflist->number++] = name;
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -32,6 +32,8 @@
|
|||
#include <errno.h>
|
||||
#include <tlhelp32.h>
|
||||
|
||||
#include "sigar_util.h"
|
||||
|
||||
#define INT64_C(val) val##i64
|
||||
|
||||
/* see apr/include/arch/win32/atime.h */
|
||||
|
|
@ -482,6 +484,9 @@ struct sigar_t {
|
|||
sigar_winsta_t winsta;
|
||||
sigar_kernel_t kernel;
|
||||
sigar_win32_pinfo_t pinfo;
|
||||
sigar_cache_t *netif_adapters;
|
||||
sigar_cache_t *netif_mib_rows;
|
||||
|
||||
WORD ws_version;
|
||||
int ws_error;
|
||||
LPBYTE peb; //scratch pad for getting peb info
|
||||
|
|
|
|||
|
|
@ -341,6 +341,23 @@ static int sigar_dllmod_init(sigar_t *sigar,
|
|||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
int sigar_wsa_init(sigar_t *sigar)
|
||||
{
|
||||
if (sigar->ws_version == 0) {
|
||||
WSADATA data;
|
||||
|
||||
if (WSAStartup(MAKEWORD(2, 0), &data)) {
|
||||
sigar->ws_error = WSAGetLastError();
|
||||
WSACleanup();
|
||||
return sigar->ws_error;
|
||||
}
|
||||
|
||||
sigar->ws_version = data.wVersion;
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
int sigar_os_open(sigar_t **sigar_ptr)
|
||||
{
|
||||
LONG result;
|
||||
|
|
@ -396,6 +413,8 @@ int sigar_os_open(sigar_t **sigar_ptr)
|
|||
(sigar_dll_module_t *)&sigar->advapi,
|
||||
FALSE);
|
||||
|
||||
sigar->netif_mib_rows = NULL;
|
||||
sigar->netif_adapters = NULL;
|
||||
sigar->pinfo.pid = -1;
|
||||
sigar->ws_version = 0;
|
||||
sigar->ncpu = 0;
|
||||
|
|
@ -426,6 +445,14 @@ int sigar_os_close(sigar_t *sigar)
|
|||
WSACleanup();
|
||||
}
|
||||
|
||||
if (sigar->netif_mib_rows) {
|
||||
sigar_cache_destroy(sigar->netif_mib_rows);
|
||||
}
|
||||
|
||||
if (sigar->netif_adapters) {
|
||||
sigar_cache_destroy(sigar->netif_adapters);
|
||||
}
|
||||
|
||||
if (sigar->peb) {
|
||||
free(sigar->peb);
|
||||
}
|
||||
|
|
@ -1868,6 +1895,53 @@ static int sigar_get_adapters_info(sigar_t *sigar,
|
|||
}
|
||||
}
|
||||
|
||||
static int sigar_get_adapter_info(sigar_t *sigar,
|
||||
DWORD index,
|
||||
IP_ADAPTER_INFO **adapter)
|
||||
{
|
||||
sigar_cache_entry_t *entry;
|
||||
*adapter = NULL;
|
||||
|
||||
if (sigar->netif_adapters) {
|
||||
entry = sigar_cache_get(sigar->netif_adapters, index);
|
||||
if (entry->value) {
|
||||
*adapter = (IP_ADAPTER_INFO *)entry->value;
|
||||
}
|
||||
}
|
||||
else {
|
||||
int status;
|
||||
IP_ADAPTER_INFO *info;
|
||||
|
||||
sigar->netif_adapters = sigar_cache_new(10);
|
||||
|
||||
status = sigar_get_adapters_info(sigar, &info);
|
||||
if (status != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
while (info) {
|
||||
entry = sigar_cache_get(sigar->netif_adapters,
|
||||
info->Index);
|
||||
if (!entry->value) {
|
||||
entry->value = malloc(sizeof(*info));
|
||||
}
|
||||
memcpy(entry->value, info, sizeof(*info));
|
||||
if (info->Index == index) {
|
||||
*adapter = info;
|
||||
}
|
||||
|
||||
info = info->Next;
|
||||
}
|
||||
}
|
||||
|
||||
if (*adapter) {
|
||||
return SIGAR_OK;
|
||||
}
|
||||
else {
|
||||
return ENOENT;
|
||||
}
|
||||
}
|
||||
|
||||
SIGAR_DECLARE(int) sigar_net_info_get(sigar_t *sigar,
|
||||
sigar_net_info_t *netinfo)
|
||||
{
|
||||
|
|
@ -2039,63 +2113,104 @@ static int get_mib_ifrow(sigar_t *sigar,
|
|||
const char *name,
|
||||
MIB_IFROW **ifrp)
|
||||
{
|
||||
DWORD rc, i;
|
||||
MIB_IFTABLE *ift;
|
||||
MIB_IFROW *ifr;
|
||||
DWORD lo=0, eth=0;
|
||||
int status, type, inst;
|
||||
int status, key;
|
||||
sigar_cache_entry_t *entry;
|
||||
|
||||
if ((status = sigar_get_iftype(name, &type, &inst)) != SIGAR_OK) {
|
||||
return status;
|
||||
if (!sigar->netif_mib_rows) {
|
||||
status = sigar_net_interface_list_get(sigar, NULL);
|
||||
if (status != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
}
|
||||
key = netif_hash(name);
|
||||
entry = sigar_cache_get(sigar->netif_mib_rows, key);
|
||||
if (!entry->value) {
|
||||
return ENOENT;
|
||||
}
|
||||
|
||||
/* XXX refresh */
|
||||
*ifrp = (MIB_IFROW *)entry->value;
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
static int netif_hash(char *s)
|
||||
{
|
||||
int hash = 0;
|
||||
while (*s) {
|
||||
hash = 31*hash + *s++;
|
||||
}
|
||||
return hash;
|
||||
}
|
||||
|
||||
SIGAR_DECLARE(int)
|
||||
sigar_net_interface_list_get(sigar_t *sigar,
|
||||
sigar_net_interface_list_t *iflist)
|
||||
{
|
||||
MIB_IFTABLE *ift;
|
||||
int i, status;
|
||||
int lo=0, eth=0;
|
||||
|
||||
if (!sigar->netif_mib_rows) {
|
||||
sigar->netif_mib_rows = sigar_cache_new(10);
|
||||
}
|
||||
|
||||
if ((status = sigar_get_if_table(sigar, &ift)) != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
for (i=0; i<ift->dwNumEntries; i++) {
|
||||
ifr = ift->table + i;
|
||||
if (iflist) {
|
||||
iflist->number = 0;
|
||||
iflist->size = ift->dwNumEntries;
|
||||
iflist->data =
|
||||
malloc(sizeof(*(iflist->data)) * iflist->size);
|
||||
}
|
||||
|
||||
if (!(ifr->dwOperStatus & MIB_IF_OPER_STATUS_OPERATIONAL)) {
|
||||
continue;
|
||||
}
|
||||
for (i=0; i<ift->dwNumEntries; i++) {
|
||||
char name[16];
|
||||
int key;
|
||||
MIB_IFROW *ifr = ift->table + i;
|
||||
sigar_cache_entry_t *entry;
|
||||
|
||||
if (ifr->dwType == MIB_IF_TYPE_LOOPBACK) {
|
||||
if ((type == IFTYPE_LO) && (inst == lo)) {
|
||||
break;
|
||||
}
|
||||
++lo;
|
||||
sprintf(name, "lo%d", lo++);
|
||||
}
|
||||
else if (ifr->dwType == MIB_IF_TYPE_ETHERNET) {
|
||||
if ((type == IFTYPE_ETH) && (inst == eth)) {
|
||||
break;
|
||||
}
|
||||
++eth;
|
||||
else {
|
||||
sprintf(name, "eth%d", eth++);
|
||||
}
|
||||
|
||||
ifr = NULL;
|
||||
}
|
||||
if (iflist) {
|
||||
iflist->data[iflist->number++] = strdup(name);
|
||||
}
|
||||
|
||||
if (!ifr) {
|
||||
return ENOENT;
|
||||
key = netif_hash(name);
|
||||
entry = sigar_cache_get(sigar->netif_mib_rows, key);
|
||||
if (!entry->value) {
|
||||
entry->value = malloc(sizeof(*ifr));
|
||||
}
|
||||
memcpy(entry->value, ifr, sizeof(*ifr));
|
||||
}
|
||||
|
||||
*ifrp = ifr;
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
int sigar_get_ifentry_config(sigar_t *sigar,
|
||||
sigar_net_interface_config_t *ifconfig)
|
||||
SIGAR_DECLARE(int)
|
||||
sigar_net_interface_config_get(sigar_t *sigar,
|
||||
const char *name,
|
||||
sigar_net_interface_config_t *ifconfig)
|
||||
{
|
||||
MIB_IFROW *ifr;
|
||||
int status;
|
||||
|
||||
status = get_mib_ifrow(sigar, ifconfig->name, &ifr);
|
||||
status = get_mib_ifrow(sigar, name, &ifr);
|
||||
if (status != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
SIGAR_ZERO(ifconfig);
|
||||
|
||||
SIGAR_SSTRCPY(ifconfig->name, name);
|
||||
|
||||
ifconfig->mtu = ifr->dwMtu;
|
||||
|
||||
sigar_net_address_mac_set(ifconfig->hwaddr,
|
||||
|
|
@ -2105,6 +2220,54 @@ int sigar_get_ifentry_config(sigar_t *sigar,
|
|||
SIGAR_SSTRCPY(ifconfig->description,
|
||||
ifr->bDescr);
|
||||
|
||||
if (ifr->dwOperStatus & MIB_IF_OPER_STATUS_OPERATIONAL) {
|
||||
ifconfig->flags |= SIGAR_IFF_UP|SIGAR_IFF_RUNNING;
|
||||
}
|
||||
|
||||
if (ifr->dwType == MIB_IF_TYPE_LOOPBACK) {
|
||||
ifconfig->flags |= SIGAR_IFF_LOOPBACK;
|
||||
|
||||
sigar_net_address_set(ifconfig->address,
|
||||
inet_addr("127.0.0.1")); /*XXX*/
|
||||
sigar_net_address_set(ifconfig->netmask,
|
||||
inet_addr("255.0.0.0")); /*XXX*/
|
||||
sigar_net_address_set(ifconfig->destination,
|
||||
ifconfig->address.addr.in);
|
||||
sigar_net_address_set(ifconfig->broadcast, 0);
|
||||
|
||||
SIGAR_SSTRCPY(ifconfig->type,
|
||||
SIGAR_NIC_LOOPBACK);
|
||||
}
|
||||
else {
|
||||
IP_ADAPTER_INFO *adapter;
|
||||
status = sigar_get_adapter_info(sigar,
|
||||
ifr->dwIndex,
|
||||
&adapter);
|
||||
|
||||
if (status == SIGAR_OK) {
|
||||
char *addr;
|
||||
if (adapter->CurrentIpAddress) {
|
||||
addr = adapter->CurrentIpAddress->IpAddress.String;
|
||||
sigar_net_address_set(ifconfig->address,
|
||||
inet_addr(addr));
|
||||
addr = adapter->CurrentIpAddress->IpMask.String;
|
||||
sigar_net_address_set(ifconfig->netmask,
|
||||
inet_addr(addr));
|
||||
}
|
||||
else {
|
||||
addr = adapter->IpAddressList.IpAddress.String;
|
||||
sigar_net_address_set(ifconfig->address,
|
||||
inet_addr(addr));
|
||||
addr = adapter->IpAddressList.IpMask.String;
|
||||
sigar_net_address_set(ifconfig->netmask,
|
||||
inet_addr(addr));
|
||||
}
|
||||
}
|
||||
|
||||
SIGAR_SSTRCPY(ifconfig->type,
|
||||
SIGAR_NIC_ETHERNET);
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
|
|
|
|||
|
|
@ -1,369 +0,0 @@
|
|||
/*
|
||||
* Copyright (C) [2004, 2005, 2006], Hyperic, Inc.
|
||||
* This file is part of SIGAR.
|
||||
*
|
||||
* SIGAR is free software; you can redistribute it and/or modify
|
||||
* it under the terms version 2 of the GNU General Public License as
|
||||
* published by the Free Software Foundation. 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.
|
||||
*/
|
||||
|
||||
#if defined(WIN32) || defined(NETWARE)
|
||||
|
||||
#define WIN32_LEAN_AND_MEAN
|
||||
|
||||
#include "sigar.h"
|
||||
#include "sigar_private.h"
|
||||
#include "sigar_os.h"
|
||||
#include "sigar_util.h"
|
||||
|
||||
#include <errno.h>
|
||||
#include <windows.h>
|
||||
#ifdef NETWARE
|
||||
#include <stdio.h>
|
||||
#include <novsock2.h>
|
||||
#include <ws2tcpip.h>
|
||||
#include <monitor.h>
|
||||
#endif
|
||||
|
||||
int sigar_get_iftype(const char *name, int *type, int *inst)
|
||||
{
|
||||
if (strnEQ(name, "eth", IFTYPE_ETH)) {
|
||||
*type = IFTYPE_ETH;
|
||||
}
|
||||
else if (strnEQ(name, "lo", IFTYPE_LO)) {
|
||||
*type = IFTYPE_LO;
|
||||
}
|
||||
else {
|
||||
return EINVAL;
|
||||
}
|
||||
|
||||
if (isdigit(*(name + *type))) {
|
||||
*inst = atoi(name + *type);
|
||||
}
|
||||
else {
|
||||
return EINVAL;
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
#ifdef WIN32
|
||||
int sigar_wsa_init(sigar_t *sigar)
|
||||
{
|
||||
if (sigar->ws_version == 0) {
|
||||
WSADATA data;
|
||||
|
||||
if (WSAStartup(MAKEWORD(2, 0), &data)) {
|
||||
sigar->ws_error = WSAGetLastError();
|
||||
WSACleanup();
|
||||
return sigar->ws_error;
|
||||
}
|
||||
|
||||
sigar->ws_version = data.wVersion;
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
#include <nb30.h>
|
||||
|
||||
static void hwaddr_lookup_netbios(sigar_net_interface_config_t *ifconfig,
|
||||
int num)
|
||||
{
|
||||
NCB ncb;
|
||||
UCHAR rc;
|
||||
struct {
|
||||
ADAPTER_STATUS status;
|
||||
NAME_BUFFER name[30];
|
||||
} adapter;
|
||||
|
||||
memset(&ncb, 0, sizeof(ncb));
|
||||
ncb.ncb_command = NCBRESET;
|
||||
ncb.ncb_lana_num = num;
|
||||
Netbios(&ncb);
|
||||
|
||||
memset(&ncb, 0, sizeof(ncb));
|
||||
ncb.ncb_command = NCBASTAT;
|
||||
ncb.ncb_lana_num = num;
|
||||
|
||||
/*
|
||||
* http://msdn.microsoft.com/library/default.asp?url=/library/en-us/netbios/netbios_1l82.asp
|
||||
* mdsn docs claim this needs to be padded with spaces and
|
||||
* suggest the following silly code:
|
||||
* strcpy(ncb.ncb_callname, "* ");
|
||||
*/
|
||||
ncb.ncb_callname[0] = '*';
|
||||
memset(&ncb.ncb_callname[1], ' ',
|
||||
sizeof(ncb.ncb_callname)-1);
|
||||
|
||||
ncb.ncb_callname[sizeof(ncb.ncb_callname)-1] = '\0';
|
||||
|
||||
ncb.ncb_buffer = (unsigned char *)&adapter;
|
||||
ncb.ncb_length = sizeof(adapter);
|
||||
if ((rc = Netbios(&ncb)) == 0) {
|
||||
sigar_net_address_mac_set(ifconfig->hwaddr,
|
||||
adapter.status.adapter_address,
|
||||
SIGAR_IFHWADDRLEN);
|
||||
}
|
||||
else {
|
||||
sigar_hwaddr_set_null(ifconfig);
|
||||
}
|
||||
}
|
||||
|
||||
static void hwaddr_lookup(sigar_t *sigar,
|
||||
sigar_net_interface_config_t *ifconfig,
|
||||
int num)
|
||||
{
|
||||
/* try IFMIB first, fallback on netbios for hwaddr */
|
||||
if (sigar_get_ifentry_config(sigar, ifconfig) != SIGAR_OK) {
|
||||
if (ifconfig->flags & SIGAR_IFF_LOOPBACK) {
|
||||
sigar_hwaddr_set_null(ifconfig);
|
||||
}
|
||||
else {
|
||||
hwaddr_lookup_netbios(ifconfig, num);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
#else /* NETWARE */
|
||||
|
||||
static void hwaddr_lookup(sigar_t *sigar,
|
||||
sigar_net_interface_config_t *ifconfig,
|
||||
int num)
|
||||
{
|
||||
uint8_t addr[SIGAR_IFHWADDRLEN];
|
||||
|
||||
if (netware_net_macaddr(num+1, addr) == 0) {
|
||||
sigar_net_address_mac_set(ifconfig->hwaddr,
|
||||
addr,
|
||||
sizeof(addr));
|
||||
}
|
||||
else {
|
||||
sigar_hwaddr_set_null(ifconfig);
|
||||
}
|
||||
}
|
||||
|
||||
#endif /* WIN32 */
|
||||
|
||||
static int sigar_ioctl_iflist(sigar_t *sigar,
|
||||
SOCKET sock,
|
||||
DWORD *bytes)
|
||||
{
|
||||
return WSAIoctl(sock,
|
||||
SIO_GET_INTERFACE_LIST,
|
||||
NULL,
|
||||
0,
|
||||
(void *)sigar->ifconf_buf,
|
||||
sigar->ifconf_len,
|
||||
bytes,
|
||||
NULL,
|
||||
NULL);
|
||||
}
|
||||
|
||||
static int get_iflist(sigar_t *sigar, DWORD *bytes)
|
||||
{
|
||||
SOCKET sock = INVALID_SOCKET;
|
||||
int status, rc, limit;
|
||||
|
||||
#ifdef WIN32
|
||||
status = sigar_wsa_init(sigar);
|
||||
|
||||
if (status != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
sock = WSASocket(PF_INET, SOCK_RAW, AF_INET, 0, 0, 0);
|
||||
#else
|
||||
sock = socket(AF_INET, SOCK_DGRAM, 0);
|
||||
#endif
|
||||
|
||||
if (sock == INVALID_SOCKET) {
|
||||
return WSAGetLastError();
|
||||
}
|
||||
|
||||
if (sigar->ifconf_len == 0) {
|
||||
sigar->ifconf_len = 8192;
|
||||
sigar->ifconf_buf = malloc(sigar->ifconf_len);
|
||||
}
|
||||
|
||||
/*
|
||||
* XXX We can't tell ahead of time what buffer size is required
|
||||
* limit just incase.
|
||||
*/
|
||||
for (limit=0; limit<100; limit++) {
|
||||
rc = sigar_ioctl_iflist(sigar, sock, bytes);
|
||||
if (rc && (WSAGetLastError() == WSAEFAULT)) {
|
||||
sigar->ifconf_len += (sizeof(INTERFACE_INFO) * 16);
|
||||
sigar->ifconf_buf = malloc(sigar->ifconf_len);
|
||||
}
|
||||
}
|
||||
|
||||
status = rc ? WSAGetLastError() : SIGAR_OK;
|
||||
|
||||
closesocket(sock);
|
||||
|
||||
return status;
|
||||
}
|
||||
|
||||
SIGAR_DECLARE(int)
|
||||
sigar_net_interface_config_get(sigar_t *sigar,
|
||||
const char *name,
|
||||
sigar_net_interface_config_t *ifconfig)
|
||||
{
|
||||
DWORD i, num, bytes;
|
||||
DWORD lo=0, eth=0;
|
||||
int status, type, inst;
|
||||
INTERFACE_INFO *if_info = NULL;
|
||||
u_long flags;
|
||||
|
||||
/* win32 lacks socket ioctls to query given interface.
|
||||
* so we loop through the list to find our made up ifname.
|
||||
*/
|
||||
status = get_iflist(sigar, &bytes);
|
||||
if (status != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
num = bytes / sizeof(INTERFACE_INFO);
|
||||
|
||||
if ((status = sigar_get_iftype(name, &type, &inst)) != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
for (i=0; i<num ; i++) {
|
||||
if_info = ((INTERFACE_INFO *)sigar->ifconf_buf) + i;
|
||||
|
||||
if (if_info->iiFlags & IFF_LOOPBACK) {
|
||||
if ((type == IFTYPE_LO) && (inst == lo)) {
|
||||
break;
|
||||
}
|
||||
++lo;
|
||||
}
|
||||
else {
|
||||
if ((type == IFTYPE_ETH) && (inst == eth)) {
|
||||
break;
|
||||
}
|
||||
++eth;
|
||||
}
|
||||
|
||||
if_info = NULL;
|
||||
}
|
||||
|
||||
if (!if_info) {
|
||||
return ENOENT;
|
||||
}
|
||||
|
||||
SIGAR_ZERO(ifconfig);
|
||||
|
||||
SIGAR_SSTRCPY(ifconfig->name, name);
|
||||
|
||||
#define if_s_addr(a) \
|
||||
((struct sockaddr_in *)&a)->sin_addr.s_addr
|
||||
|
||||
sigar_net_address_set(ifconfig->address,
|
||||
if_s_addr(if_info->iiAddress));
|
||||
sigar_net_address_set(ifconfig->broadcast,
|
||||
if_s_addr(if_info->iiBroadcastAddress));
|
||||
sigar_net_address_set(ifconfig->netmask,
|
||||
if_s_addr(if_info->iiNetmask));
|
||||
|
||||
flags = if_info->iiFlags;
|
||||
|
||||
if (flags & IFF_UP) {
|
||||
ifconfig->flags |= SIGAR_IFF_UP|SIGAR_IFF_RUNNING;
|
||||
}
|
||||
if (flags & IFF_BROADCAST) {
|
||||
ifconfig->flags |= SIGAR_IFF_BROADCAST;
|
||||
}
|
||||
if (flags & IFF_LOOPBACK) {
|
||||
ifconfig->flags |= SIGAR_IFF_LOOPBACK;
|
||||
sigar_net_address_set(ifconfig->destination,
|
||||
ifconfig->address.addr.in);
|
||||
sigar_net_address_set(ifconfig->broadcast, 0);
|
||||
SIGAR_SSTRCPY(ifconfig->type,
|
||||
SIGAR_NIC_LOOPBACK);
|
||||
}
|
||||
else {
|
||||
SIGAR_SSTRCPY(ifconfig->type,
|
||||
SIGAR_NIC_ETHERNET);
|
||||
}
|
||||
|
||||
/* should be overridden w/ better description
|
||||
* using MIB_IFROW.bDescr when hwaddr is lookedup
|
||||
*/
|
||||
SIGAR_SSTRCPY(ifconfig->description,
|
||||
ifconfig->name);
|
||||
|
||||
hwaddr_lookup(sigar, ifconfig, i);
|
||||
|
||||
if (flags & IFF_POINTTOPOINT) {
|
||||
ifconfig->flags |= SIGAR_IFF_POINTOPOINT;
|
||||
}
|
||||
if (flags & IFF_MULTICAST) {
|
||||
ifconfig->flags |= SIGAR_IFF_MULTICAST;
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
/*
|
||||
* win32 interface list does not include a name.
|
||||
* and the name from GetIfList() is the name of card
|
||||
* including vendor name, etc. so we use 'eth' for ethernet
|
||||
* interfaces and 'lo' for loopback.
|
||||
*/
|
||||
|
||||
#define ETH "eth"
|
||||
#define LO "lo"
|
||||
|
||||
SIGAR_DECLARE(int)
|
||||
sigar_net_interface_list_get(sigar_t *sigar,
|
||||
sigar_net_interface_list_t *iflist)
|
||||
{
|
||||
char eth[56], lo[56];
|
||||
int ethcnt=0, locnt=0;
|
||||
DWORD i, num, bytes;
|
||||
int status;
|
||||
|
||||
status = get_iflist(sigar, &bytes);
|
||||
if (status != SIGAR_OK) {
|
||||
return status;
|
||||
}
|
||||
|
||||
num = bytes / sizeof(INTERFACE_INFO);
|
||||
|
||||
iflist->number = 0;
|
||||
iflist->size = num;
|
||||
iflist->data =
|
||||
malloc(sizeof(*(iflist->data)) * iflist->size);
|
||||
|
||||
for (i=0; i<num ; i++) {
|
||||
INTERFACE_INFO *if_info =
|
||||
((INTERFACE_INFO *)sigar->ifconf_buf) + i;
|
||||
char *name;
|
||||
|
||||
if (if_info->iiFlags & IFF_LOOPBACK) {
|
||||
sprintf(lo, LO "%d", locnt++);
|
||||
name = strdup(lo);
|
||||
}
|
||||
else {
|
||||
/* XXX: assuming ethernet here */
|
||||
sprintf(eth, ETH "%d", ethcnt++);
|
||||
name = strdup(eth);
|
||||
}
|
||||
|
||||
iflist->data[iflist->number++] = name;
|
||||
}
|
||||
|
||||
return SIGAR_OK;
|
||||
}
|
||||
|
||||
#endif /* WIN32ISH */
|
||||
Loading…
Reference in New Issue