pegasus/src/Pegasus/Common/System.cpp - diff

Return to System.cpp CVS log

Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/System.cpp between version 1.24 and 1.79

version 1.24, 2005/01/17 15:41:44

version 1.79, 2010/10/13 14:24:46

Line 1

//%2004////////////////////////////////////////////////////////////////////////

//%LICENSE////////////////////////////////////////////////////////////////

// Licensed to The Open Group (TOG) under one or more contributor license

// Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.

// agreements. Refer to the OpenPegasusNOTICE.txt file distributed with

// this work for additional information regarding copyright ownership.

// IBM Corp.; EMC Corporation, The Open Group.

// Each contributor licenses this file to you under the OpenPegasus Open

// Source License; you may not use this file except in compliance with the

// IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.

// License.

// Permission is hereby granted, free of charge, to any person obtaining a copy

// Permission is hereby granted, free of charge, to any person obtaining a

// of this software and associated documentation files (the "Software"), to

// copy of this software and associated documentation files (the "Software"),

// deal in the Software without restriction, including without limitation the

// to deal in the Software without restriction, including without limitation

// rights to use, copy, modify, merge, publish, distribute, sublicense, and/or

// the rights to use, copy, modify, merge, publish, distribute, sublicense,

// sell copies of the Software, and to permit persons to whom the Software is

// and/or sell copies of the Software, and to permit persons to whom the

// furnished to do so, subject to the following conditions:

// Software is furnished to do so, subject to the following conditions:

// THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN

// The above copyright notice and this permission notice shall be included

// ALL COPIES OR SUBSTANTIAL PORTIONS OF THE SOFTWARE. THE SOFTWARE IS PROVIDED

// in all copies or substantial portions of the Software.

// "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT

// LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR

// PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT

// HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN

// ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION

// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

//==============================================================================

// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS

// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF

// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.

// IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY

// CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT,

// TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE

// SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

// Author: Mike Brasher (mbrasher@bmc.com)

//////////////////////////////////////////////////////////////////////////

// Modified By: Rudy Schuet (rudy.schuet@compaq.com) 11/12/01

// added nsk platform support

// Ramnath Ravindran (Ramnath.Ravindran@compaq.com) 03/21/2002

// replaced instances of "| ios::binary" with

// PEGASUS_OR_IOS_BINARY

// Robert Kieninger, IBM (kieningr@de.ibm.com) for Bug#667

// Dave Sudlik, IBM (dsudlik@us.ibm.com) for Bug#1462

//%/////////////////////////////////////////////////////////////////////////////

#if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)

#include <Pegasus/Common/Config.h>

#endif

#include <fstream>

#include <cctype> // for tolower()

#include <cstring>

#include "System.h"

#include "Socket.h"

#include "Network.h"

#ifdef PEGASUS_PLATFORM_WIN32_IX86_MSVC

# include <windows.h>

#else

# include <arpa/inet.h>

#endif

#include <Pegasus/Common/PegasusVersion.h>

#include <Pegasus/Common/FileSystem.h>

#include <Pegasus/Common/HostAddress.h>

#include <Pegasus/Common/Array.h>

#if defined(PEGASUS_OS_TYPE_WINDOWS)

# include "SystemWindows.cpp"

#elif defined(PEGASUS_OS_TYPE_UNIX)

# include "SystemPOSIX.cpp"

# include "SystemUnix.cpp"

#elif defined(PEGASUS_OS_TYPE_NSK)

#elif defined(PEGASUS_OS_VMS)

# include "SystemNsk.cpp"

# include "SystemPOSIX.cpp"

# include "SystemVms.cpp"

#else

# error "Unsupported platform"

#endif

#if defined(PEGASUS_OS_OS400)

# include "OS400ConvertChar.h"

#endif

PEGASUS_USING_STD;

PEGASUS_NAMESPACE_BEGIN

Boolean System::bindVerbose = false;

MutexType System::_mutexForGetHostName = PEGASUS_MUTEX_INITIALIZER;

MutexType System::_mutexForGetFQHN = PEGASUS_MUTEX_INITIALIZER;

Boolean System::copyFile(const char* fromPath, const char* toPath)

{

ifstream is(fromPath PEGASUS_IOS_BINARY);

ofstream os(toPath PEGASUS_IOS_BINARY);

fstream os(toPath, ios::out PEGASUS_OR_IOS_BINARY);

char c;

Line 89

Line 77

return false;

}

return true;

FileSystem::syncWithDirectoryUpdates(os);

return is.eof();

}

// ATTN: Move to platform-specific System implementation files and call

static const Uint8 _toLowerTable[256] =

// strcasecmp where it is available.

Sint32 System::strcasecmp(const char* s1, const char* s2)

{

while (*s1 && *s2)

0x00,0x01,0x02,0x03,0x04,0x05,0x06,0x07,

0x08,0x09,0x0A,0x0B,0x0C,0x0D,0x0E,0x0F,

0x10,0x11,0x12,0x13,0x14,0x15,0x16,0x17,

0x18,0x19,0x1A,0x1B,0x1C,0x1D,0x1E,0x1F,

0x20,0x21,0x22,0x23,0x24,0x25,0x26,0x27,

0x28,0x29,0x2A,0x2B,0x2C,0x2D,0x2E,0x2F,

0x30,0x31,0x32,0x33,0x34,0x35,0x36,0x37,

0x38,0x39,0x3A,0x3B,0x3C,0x3D,0x3E,0x3F,

0x40,0x61,0x62,0x63,0x64,0x65,0x66,0x67,

0x68,0x69,0x6A,0x6B,0x6C,0x6D,0x6E,0x6F,

0x70,0x71,0x72,0x73,0x74,0x75,0x76,0x77,

0x78,0x79,0x7A,0x5B,0x5C,0x5D,0x5E,0x5F,

0x60,0x61,0x62,0x63,0x64,0x65,0x66,0x67,

0x68,0x69,0x6A,0x6B,0x6C,0x6D,0x6E,0x6F,

0x70,0x71,0x72,0x73,0x74,0x75,0x76,0x77,

0x78,0x79,0x7A,0x7B,0x7C,0x7D,0x7E,0x7F,

0x80,0x81,0x82,0x83,0x84,0x85,0x86,0x87,

0x88,0x89,0x8A,0x8B,0x8C,0x8D,0x8E,0x8F,

0x90,0x91,0x92,0x93,0x94,0x95,0x96,0x97,

0x98,0x99,0x9A,0x9B,0x9C,0x9D,0x9E,0x9F,

0xA0,0xA1,0xA2,0xA3,0xA4,0xA5,0xA6,0xA7,

0xA8,0xA9,0xAA,0xAB,0xAC,0xAD,0xAE,0xAF,

0xB0,0xB1,0xB2,0xB3,0xB4,0xB5,0xB6,0xB7,

0xB8,0xB9,0xBA,0xBB,0xBC,0xBD,0xBE,0xBF,

0xC0,0xC1,0xC2,0xC3,0xC4,0xC5,0xC6,0xC7,

0xC8,0xC9,0xCA,0xCB,0xCC,0xCD,0xCE,0xCF,

0xD0,0xD1,0xD2,0xD3,0xD4,0xD5,0xD6,0xD7,

0xD8,0xD9,0xDA,0xDB,0xDC,0xDD,0xDE,0xDF,

0xE0,0xE1,0xE2,0xE3,0xE4,0xE5,0xE6,0xE7,

0xE8,0xE9,0xEA,0xEB,0xEC,0xED,0xEE,0xEF,

0xF0,0xF1,0xF2,0xF3,0xF4,0xF5,0xF6,0xF7,

0xF8,0xF9,0xFA,0xFB,0xFC,0xFD,0xFE,0xFF,

};

Sint32 System::strcasecmp(const char* s1, const char* s2)

{

int r = tolower(*s1++) - tolower(*s2++);

// Note: this is faster than glibc strcasecmp().

if (r)

Uint8* p = (Uint8*)s1;

return r;

Uint8* q = (Uint8*)s2;

int r;

for (;;)

{

if ((r = _toLowerTable[p[0]] - _toLowerTable[q[0]]) || !p[0] ||

(r = _toLowerTable[p[1]] - _toLowerTable[q[1]]) || !p[1] ||

(r = _toLowerTable[p[2]] - _toLowerTable[q[2]]) || !p[2] ||

(r = _toLowerTable[p[3]] - _toLowerTable[q[3]]) || !p[3])

break;

p += 4;

q += 4;

}

if (*s2)

return r;

return -1;

}

else if (*s1)

return 1;

return 0;

bool System::strncasecmp(

const char* s1,

size_t s1_l,

const char* s2,

size_t s2_l)

{

// Function is even faster than System::strcasecmp()

if (s1_l != s2_l)

{

return false;

}

Uint8* p = (Uint8*)s1;

Uint8* q = (Uint8*)s2;

// lets do a loop-unrolling optimized compare here

while (len >= 8)

{

if ((_toLowerTable[p[0]]-_toLowerTable[q[0]]) ||

(_toLowerTable[p[1]]-_toLowerTable[q[1]]) ||

(_toLowerTable[p[2]]-_toLowerTable[q[2]]) ||

(_toLowerTable[p[3]]-_toLowerTable[q[3]]) ||

(_toLowerTable[p[4]]-_toLowerTable[q[4]]) ||

(_toLowerTable[p[5]]-_toLowerTable[q[5]]) ||

(_toLowerTable[p[6]]-_toLowerTable[q[6]]) ||

(_toLowerTable[p[7]]-_toLowerTable[q[7]]))

{

return false;

}

len -= 8;

p += 8;

q += 8;

}

while (len >= 4)

{

if ((_toLowerTable[p[0]]-_toLowerTable[q[0]]) ||

(_toLowerTable[p[1]]-_toLowerTable[q[1]]) ||

(_toLowerTable[p[2]]-_toLowerTable[q[2]]) ||

(_toLowerTable[p[3]]-_toLowerTable[q[3]]))

{

return false;

}

len -= 4;

p += 4;

q += 4;

}

while (len--)

{

if ((_toLowerTable[p[0]]-_toLowerTable[q[0]]))

{

return false;

}

p++;

q++;

}

return true;

}

// Return the just the file name from the path into basename

char *System::extract_file_name(const char *fullpath, char *basename)

{

char *p;

char buff[2048];

if (fullpath == NULL)

{

basename[0] = '\0';

return basename;

}

strcpy(buff, fullpath);

for(p = buff + strlen(buff); p >= buff; p--)

for (const char* p = fullpath + strlen(fullpath) - 1; p >= fullpath; p--)

{

if (*p == '\\' || *p == '/')

{

Line 131

Line 215

return basename;

}

strcpy(basename, fullpath);

return basename;

}

Line 139

Line 224

char *System::extract_file_path(const char *fullpath, char *dirname)

{

char *p;

char buff[2048];

char buff[4096];

if (fullpath == NULL)

{

dirname[0] = '\0';

return dirname;

}

strcpy(buff, fullpath);

strncpy(buff, fullpath, sizeof(buff)-1);

buff[sizeof(buff)-1] = '\0';

for(p = buff + strlen(buff); p >= buff; p--)

{

if (*p == '\\' || *p == '/')

Line 159

Line 245

return dirname;

}

String System::getHostIP(const String &hostName)

String System::getHostName()

{

struct hostent * phostent;

static String _hostname;

struct in_addr inaddr;

String ipAddress = String::EMPTY;

// Use double-checked locking pattern to avoid overhead of

// mutex on subsequent calls.

if (0 == _hostname.size())

{

mutex_lock(&_mutexForGetHostName);

if (0 == _hostname.size())

{

char hostname[PEGASUS_MAXHOSTNAMELEN + 1];

// If gethostname() fails, an empty or truncated value is used.

hostname[0] = 0;

gethostname(hostname, sizeof(hostname));

hostname[sizeof(hostname)-1] = 0;

_hostname.assign(hostname);

}

mutex_unlock(&_mutexForGetHostName);

}

return _hostname;

}

static String _getFullyQualifiedHostName()

{

char hostName[PEGASUS_MAXHOSTNAMELEN + 1];

// Get the short name of the local host.

// If gethostname() fails, an empty or truncated value is used.

hostName[0] = 0;

gethostname(hostName, sizeof(hostName));

hostName[sizeof(hostName)-1] = 0;

#if defined(PEGASUS_OS_ZOS)|| \

defined(PEGASUS_OS_VMS)

String fqName;

struct addrinfo *resolv;

struct addrinfo hint;

struct hostent *he;

memset (&hint, 0, sizeof(struct addrinfo));

hint.ai_flags = AI_CANONNAME;

hint.ai_family = AF_UNSPEC; // any family

hint.ai_socktype = 0; // any socket type

hint.ai_protocol = 0; // any protocol

int success = System::getAddrInfo(hostName, NULL, &hint, &resolv);

if (success==0)

{

// assign fully qualified hostname

fqName.assign(resolv->ai_canonname);

}

else

{

if ((he = System::getHostByName(hostName)))

{

strncpy(hostName, he->h_name, sizeof(hostName) - 1);

}

// assign hostName

// if gethostbyname was successful assign that result

// else assign unqualified hostname

fqName.assign(hostName);

}

if (resolv)

{

freeaddrinfo(resolv);

}

return fqName;

#else /* !PEGASUS_OS_ZOS && !PEGASUS_OS_VMS */

char hostEntryBuffer[8192];

struct hostent hostEntryStruct;

struct hostent* hostEntry = System::getHostByName(

hostName, &hostEntryStruct, hostEntryBuffer, sizeof (hostEntryBuffer));

if (hostEntry)

{

strncpy(hostName, hostEntry->h_name, sizeof(hostName) - 1);

}

return String(hostName);

if ((phostent = ::gethostbyname((const char *)hostName.getCString())) != NULL)

#endif

}

String System::getFullyQualifiedHostName()

{

static String _hostname;

// Use double-checked locking pattern to avoid overhead of

// mutex on subsequent calls.

if (0 == _hostname.size())

{

::memcpy( &inaddr, phostent->h_addr,4);

mutex_lock(&_mutexForGetFQHN);

#ifdef PEGASUS_PLATFORM_ZOS_ZSERIES_IBM

char * gottenIPAdress = NULL;

if (0 == _hostname.size())

gottenIPAdress = ::inet_ntoa( inaddr );

{

__etoa(gottenIPAdress);

try

if (gottenIPAdress != NULL)

{

ipAddress.assign(gottenIPAdress);

_hostname = _getFullyQualifiedHostName();

}

catch (...)

{

mutex_unlock(&_mutexForGetFQHN);

throw;

}

mutex_unlock(&_mutexForGetFQHN);

}

return _hostname;

}

Boolean System::getHostIP(const String &hostName, int *af, String &hostIP)

{

#ifdef PEGASUS_ENABLE_IPV6

struct addrinfo *info, hints;

memset (&hints, 0, sizeof(struct addrinfo));

// Check for valid IPV4 address, if found return ipv4 address

*af = AF_INET;

hints.ai_family = *af;

hints.ai_protocol = IPPROTO_TCP;

hints.ai_socktype = SOCK_STREAM;

if (!getAddrInfo(hostName.getCString(), 0, &hints, &info))

{

char ipAddress[PEGASUS_INET_ADDRSTR_LEN];

HostAddress::convertBinaryToText(info->ai_family,

&(reinterpret_cast<struct sockaddr_in*>(info->ai_addr))->sin_addr,

ipAddress,

PEGASUS_INET_ADDRSTR_LEN);

hostIP = ipAddress;

freeaddrinfo(info);

return true;

}

// Check for valid IPV6 Address.

*af = AF_INET6;

hints.ai_family = *af;

hints.ai_protocol = IPPROTO_TCP;

hints.ai_socktype = SOCK_STREAM;

if (!getAddrInfo(hostName.getCString(), 0, &hints, &info))

{

char ipAddress[PEGASUS_INET6_ADDRSTR_LEN];

HostAddress::convertBinaryToText(info->ai_family,

&(reinterpret_cast<struct sockaddr_in6*>(info->ai_addr))->sin6_addr,

ipAddress,

PEGASUS_INET6_ADDRSTR_LEN);

hostIP = ipAddress;

freeaddrinfo(info);

return true;

}

return false;

#else

*af = AF_INET;

struct hostent* hostEntry;

struct in_addr inaddr;

String ipAddress;

CString hostNameCString = hostName.getCString();

const char* hostNamePtr = hostNameCString;

char hostEntryBuffer[8192];

struct hostent hostEntryStruct;

hostEntry = getHostByName(hostNamePtr, &hostEntryStruct,

hostEntryBuffer, sizeof (hostEntryBuffer));

if (hostEntry)

{

::memcpy( &inaddr, hostEntry->h_addr,4);

ipAddress = ::inet_ntoa( inaddr );

hostIP = ipAddress;

return true;

}

return false;

#endif

}

return ipAddress;

#ifdef PEGASUS_ENABLE_IPV6

Boolean System::isIPv6StackActive()

{

SocketHandle ip6Socket;

if ((ip6Socket = Socket::createSocket(AF_INET6, SOCK_STREAM, IPPROTO_TCP))

== PEGASUS_INVALID_SOCKET)

{

if (getSocketError() == PEGASUS_INVALID_ADDRESS_FAMILY)

{

return false;

}

else

{

#if defined(PEGASUS_OS_VMS)

// vms has tcpipv6 support in the kernel so socket

// will always work so a call to "bind" is needed

// to complete this test.

struct sockaddr_storage listenAddress;

memset(&listenAddress, 0, sizeof (listenAddress));

SocketLength addressLength;

HostAddress::convertTextToBinary(

HostAddress::AT_IPV6,

"::1",

&reinterpret_cast<struct sockaddr_in6*>(&listenAddress)->sin6_addr);

listenAddress.ss_family = AF_INET6;

reinterpret_cast<struct sockaddr_in6*>(&listenAddress)->sin6_port = 0;

addressLength = sizeof(struct sockaddr_in6);

if (::bind(

ip6Socket,

reinterpret_cast<struct sockaddr*>(&listenAddress),

addressLength) < 0)

{

Socket::close(ip6Socket);

return false;

}

#endif // PEGASUS_OS_VMS

Socket::close(ip6Socket);

}

return true;

}

#endif

// ------------------------------------------------------------------------

// Convert a hostname into a a single host unique integer representation

// ------------------------------------------------------------------------

Uint32 System::_acquireIP(const char* hostname)

Boolean System::acquireIP(const char* hostname, int *af, void *dst)

{

#ifdef PEGASUS_ENABLE_IPV6

String ipAddress;

if(getHostIP(hostname, af, ipAddress))

{

HostAddress::convertTextToBinary(*af, ipAddress.getCString(), dst);

return true;

}

return false;

#else

*af = AF_INET;

Uint32 ip = 0xFFFFFFFF;

if (!hostname) return 0xFFFFFFFF;

if (!hostname)

{

#ifdef PEGASUS_OS_OS400

*af = 0xFFFFFFFF;

char ebcdicHost[PEGASUS_MAXHOSTNAMELEN];

return false;

if (strlen(hostname) < PEGASUS_MAXHOSTNAMELEN)

}

strcpy(ebcdicHost, hostname);

else

return 0xFFFFFFFF;

AtoE(ebcdicHost);

#endif

////////////////////////////////////////////////////////////////////////////////

// This code used to check if the first character of "hostname" was alphabetic

// to indicate hostname instead of IP address. But RFC 1123, section 2.1, relaxed

// to indicate hostname instead of IP address. But RFC 1123, section 2.1,

// this requirement to alphabetic character *or* digit. So bug 1462 changed the

// relaxed this requirement to alphabetic character *or* digit. So bug 1462

// flow here to call inet_addr first to check for a valid IP address in dotted

// changed the flow here to call inet_addr first to check for a valid IP

// decimal notation. If it's not a valid IP address, then try to validate

// address in dotted decimal notation. If it's not a valid IP address, then

// it as a hostname.

// try to validate it as a hostname.

// RFC 1123 states: The host SHOULD check the string syntactically for a

// dotted-decimal number before looking it up in the Domain Name System.

// Hence the call to inet_addr() first.

////////////////////////////////////////////////////////////////////////////////

#ifdef PEGASUS_OS_OS400

Uint32 tmp_addr = inet_addr(ebcdicHost);

#elif defined(PEGASUS_OS_ZOS)

Uint32 tmp_addr = inet_addr_ebcdic((char *)hostname);

#else

Uint32 tmp_addr = inet_addr((char *) hostname);

#endif

struct hostent* hostEntry;

struct hostent *entry;

// Note: 0xFFFFFFFF is actually a valid IP address (255.255.255.255).

// A better solution would be to use inet_aton() or equivalent, as

Line 228

Line 522

if (tmp_addr == 0xFFFFFFFF) // if hostname is not an IP address

{

#ifdef PEGASUS_PLATFORM_SOLARIS_SPARC_CC

char hostEntryBuffer[8192];

#define HOSTENT_BUFF_SIZE 8192

struct hostent hostEntryStruct;

char buf[HOSTENT_BUFF_SIZE];

hostEntry = getHostByName(hostname, &hostEntryStruct,

int h_errorp;

hostEntryBuffer, sizeof (hostEntryBuffer));

struct hostent hp;

if (!hostEntry)

entry = gethostbyname_r((char *)hostname, &hp, buf,

HOSTENT_BUFF_SIZE, &h_errorp);

#elif defined(PEGASUS_OS_OS400)

entry = gethostbyname(ebcdicHost);

#elif defined(PEGASUS_OS_ZOS)

char hostName[ PEGASUS_MAXHOSTNAMELEN ];

if (String::equalNoCase("localhost",String(hostname)))

{

gethostname( hostName, PEGASUS_MAXHOSTNAMELEN );

entry = gethostbyname(hostName);

} else

{

entry = gethostbyname((char *)hostname);

}

#else

entry = gethostbyname((char *)hostname);

#endif

if (!entry)

{

return 0xFFFFFFFF;

// error, couldn't resolve the ip

memcpy(dst, &ip, sizeof (Uint32));

return false;

}

unsigned char ip_part1,ip_part2,ip_part3,ip_part4;

ip_part1 = entry->h_addr[0];

ip_part1 = hostEntry->h_addr[0];

ip_part2 = entry->h_addr[1];

ip_part2 = hostEntry->h_addr[1];

ip_part3 = entry->h_addr[2];

ip_part3 = hostEntry->h_addr[2];

ip_part4 = entry->h_addr[3];

ip_part4 = hostEntry->h_addr[3];

ip = ip_part1;

ip = (ip << 8) + ip_part2;

ip = (ip << 8) + ip_part3;

Line 269

Line 547

else // else hostname *is* a dotted-decimal IP address

{

// resolve hostaddr to a real host entry

// casting to (const char *) as (char *) will work as (void *) too, those it fits all platforms

// casting to (const char *) as (char *) will work as (void *) too,

entry = gethostbyaddr((const char *) &tmp_addr, sizeof(tmp_addr), AF_INET);

// those it fits all platforms

char hostEntryBuffer[8192];

struct hostent hostEntryStruct;

hostEntry =

getHostByAddr((const char*) &tmp_addr, sizeof(tmp_addr), AF_INET,

&hostEntryStruct, hostEntryBuffer, sizeof (hostEntryBuffer));

if (entry == 0)

if (hostEntry == 0)

{

// error, couldn't resolve the ip

return 0xFFFFFFFF;

memcpy(dst, &ip, sizeof (Uint32));

} else

return false;

}

else

{

unsigned char ip_part1,ip_part2,ip_part3,ip_part4;

ip_part1 = hostEntry->h_addr[0];

ip_part2 = hostEntry->h_addr[1];

ip_part3 = hostEntry->h_addr[2];

ip_part4 = hostEntry->h_addr[3];

ip = ip_part1;

ip = (ip << 8) + ip_part2;

ip = (ip << 8) + ip_part3;

ip = (ip << 8) + ip_part4;

}

memcpy(dst, &ip, sizeof (Uint32));

return true;

#endif

}

Boolean System::resolveHostNameAtDNS(

const char* hostname,

Uint32* resolvedNameIP)

{

struct hostent* hostEntry;

// ask the DNS for hostname resolution to IP address

// this can mean a time delay for as long as the DNS

// takes to answer

char hostEntryBuffer[8192];

struct hostent hostEntryStruct;

hostEntry = getHostByName(hostname, &hostEntryStruct,

hostEntryBuffer, sizeof (hostEntryBuffer));

if (hostEntry == 0)

{

// error, couldn't resolve the hostname to an ip address

return false;

}

else

{

unsigned char ip_part1,ip_part2,ip_part3,ip_part4;

ip_part1 = hostEntry->h_addr[0];

ip_part2 = hostEntry->h_addr[1];

ip_part3 = hostEntry->h_addr[2];

ip_part4 = hostEntry->h_addr[3];

*resolvedNameIP = ip_part1;

*resolvedNameIP = (*resolvedNameIP << 8) + ip_part2;

*resolvedNameIP = (*resolvedNameIP << 8) + ip_part3;

*resolvedNameIP = (*resolvedNameIP << 8) + ip_part4;

}

return true;

}

Boolean System::resolveIPAtDNS(Uint32 ip_addr, Uint32 * resolvedIP)

{

struct hostent *entry;

entry = getHostByAddr((const char *) &ip_addr, sizeof(ip_addr), AF_INET);

if (entry == 0)

{

// error, couldn't resolve the ip

return false;

}

else

{

unsigned char ip_part1,ip_part2,ip_part3,ip_part4;

ip_part1 = entry->h_addr[0];

ip_part2 = entry->h_addr[1];

ip_part3 = entry->h_addr[2];

ip_part4 = entry->h_addr[3];

ip = ip_part1;

*resolvedIP = ip_part1;

ip = (ip << 8) + ip_part2;

*resolvedIP = (*resolvedIP << 8) + ip_part2;

ip = (ip << 8) + ip_part3;

*resolvedIP = (*resolvedIP << 8) + ip_part3;

ip = (ip << 8) + ip_part4;

*resolvedIP = (*resolvedIP << 8) + ip_part4;

}

return true;

}

Boolean System::isLoopBack(int af, void *binIPAddress)

{

#ifdef PEGASUS_ENABLE_IPV6

struct in6_addr ip6 = PEGASUS_IPV6_LOOPBACK_INIT;

#endif

switch (af)

{

#ifdef PEGASUS_ENABLE_IPV6

case AF_INET6:

return !memcmp(&ip6, binIPAddress, sizeof (ip6));

#endif

case AF_INET:

{

Uint32 tmp;

memcpy(&tmp, binIPAddress, sizeof(Uint32));

Uint32 n = ntohl(tmp);

return n >= PEGASUS_IPV4_LOOPBACK_RANGE_START &&

n <= PEGASUS_IPV4_LOOPBACK_RANGE_END;

}

return false;

}

return ip;

Boolean System::isLocalHost(const String &hostName)

{

// shortcut if hostname == localhost

if (String::equalNoCase(hostName,String("localhost"))) return true;

// Get all ip addresses on the node and compare them with the given hostname.

#ifdef PEGASUS_ENABLE_IPV6

CString csName = hostName.getCString();

struct addrinfo hints, *res1, *res2, *res1root, *res2root;

char localHostName[PEGASUS_MAXHOSTNAMELEN];

gethostname(localHostName, PEGASUS_MAXHOSTNAMELEN);

Boolean isLocal = false;

memset(&hints, 0, sizeof(hints));

hints.ai_family = AF_INET;

hints.ai_socktype = SOCK_STREAM;

hints.ai_protocol = IPPROTO_TCP;

res1root = res2root = 0;

getAddrInfo(csName, 0, &hints, &res1root);

getAddrInfo(localHostName, 0, &hints, &res2root);

res1 = res1root;

while (res1 && !isLocal)

{

if (isLoopBack(AF_INET,

&(reinterpret_cast<struct sockaddr_in*>(res1->ai_addr))->sin_addr))

{

isLocal = true;

break;

}

res2 = res2root;

while (res2)

{

if (!memcmp(

&(reinterpret_cast<struct sockaddr_in*>(res1->ai_addr))->

sin_addr,

&(reinterpret_cast<struct sockaddr_in*>(res2->ai_addr))->

sin_addr,

sizeof (struct in_addr)))

{

isLocal = true;

break;

}

res2 = res2->ai_next;

}

res1 = res1->ai_next;

}

if (res1root)

{

freeaddrinfo(res1root);

}

if (res2root)

{

freeaddrinfo(res2root);

}

if (isLocal)

{

return true;

}

hints.ai_family = AF_INET6;

res1root = res2root = 0;

getAddrInfo(csName, 0, &hints, &res1root);

getAddrInfo(localHostName, 0, &hints, &res2root);

res1 = res1root;

while (res1 && !isLocal)

{

if (isLoopBack(

AF_INET6,

&(reinterpret_cast<struct sockaddr_in6*>(res1->ai_addr))->

sin6_addr))

{

isLocal = true;

break;

}

res2 = res2root;

while (res2)

{

if (!memcmp(

&(reinterpret_cast<struct sockaddr_in6*>(res1->ai_addr))->

sin6_addr,

&(reinterpret_cast<struct sockaddr_in6*>(res2->ai_addr))->

sin6_addr,

sizeof (struct in6_addr)))

{

isLocal = true;

break;

}

res2 = res2->ai_next;

}

res1 = res1->ai_next;

}

if (res1root)

{

freeaddrinfo(res1root);

}

if (res2root)

{

freeaddrinfo(res2root);

}

return isLocal;

#else

// differentiate between a dotted IP address given

// and a real hostname given

CString csName = hostName.getCString();

char cc_hostname[PEGASUS_MAXHOSTNAMELEN];

strcpy(cc_hostname, (const char*) csName);

Uint32 tmp_addr = 0xFFFFFFFF;

Boolean hostNameIsIPNotation;

// Note: Platforms already supporting the inet_aton()

// should define their platform here,

// as this is the superior way to work

#if defined(PEGASUS_OS_LINUX) || \

defined(PEGASUS_OS_AIX) || \

defined(PEGASUS_OS_HPUX) || \

defined(PEGASUS_OS_PASE) || \

defined(PEGASUS_OS_VMS)

struct in_addr inaddr;

// if inet_aton failed(return=0),

// we do not have a valip IP address (x.x.x.x)

int atonSuccess = inet_aton(cc_hostname, &inaddr);

if (atonSuccess == 0) hostNameIsIPNotation = false;

else

{

hostNameIsIPNotation = true;

tmp_addr = inaddr.s_addr;

}

#else

// Note: 0xFFFFFFFF is actually a valid IP address (255.255.255.255).

// A better solution would be to use inet_aton() or equivalent, as

// inet_addr() is now considered "obsolete".

// Note: inet_aton() not yet supported on all Pegasus platforms

tmp_addr = inet_addr((char *) cc_hostname);

if (tmp_addr == 0xFFFFFFFF) hostNameIsIPNotation = false;

else hostNameIsIPNotation = true;

#endif

if (!hostNameIsIPNotation) // if hostname is not an IP address

{

char localHostName[PEGASUS_MAXHOSTNAMELEN];

CString cstringLocalHostName = System::getHostName().getCString();

strcpy(localHostName, (const char*) cstringLocalHostName);

// given hostname equals what system returns as local hostname ?

if (String::equalNoCase(hostName,localHostName)) return true;

Uint32 hostIP;

// bail out if hostname unresolveable

if (!System::resolveHostNameAtDNS(cc_hostname, &hostIP)) return false;

// lets see if the IP is defined on one of the network interfaces

// this can help us avoid another call to DNS

if (System::isIpOnNetworkInterface(hostIP)) return true;

// need to check if the local hosts name is possibly

// registered at the DNS with the IP address equal resolvedNameIP

Uint32 localHostIP;

if (!System::resolveHostNameAtDNS(localHostName, &localHostIP))

return false;

if (localHostIP == hostIP) return true;

}

else

{ // hostname is an IP address

// 127.0.0.1 is always the loopback

// inet_addr returns network byte order

if (tmp_addr == htonl(0x7F000001)) return true;

// IP defined on a local AF_INET network interface

if (System::isIpOnNetworkInterface(tmp_addr)) return true;

// out of luck so far, lets ask the DNS what our IP is

// and check against what we got

Uint32 localHostIP;

if (!System::resolveHostNameAtDNS(

(const char*) System::getHostName().getCString(), &localHostIP))

return false;

if (localHostIP == tmp_addr) return true;

// not yet, sometimes resolving the IP address we got against the DNS

// can solve the problem

// casting to (const char *) as (char *) will work as (void *) too,

// those it fits all platforms

Uint32 hostIP;

if (!System::resolveIPAtDNS(tmp_addr, &hostIP)) return false;

if (hostIP == localHostIP) return true;

}

return false;

#endif

}

struct hostent* System::getHostByName(

const char* name,

struct hostent* he,

char* buf,

size_t len)

{

int hostEntryErrno = 0;

struct hostent* hostEntry = 0;

unsigned int maxTries = 5;

{

#if defined(PEGASUS_OS_LINUX)

gethostbyname_r(name,

he,

buf,

len,

&hostEntry,

&hostEntryErrno);

#elif defined(PEGASUS_OS_SOLARIS)

hostEntry = gethostbyname_r((char *)name,

he,

buf,

len,

&hostEntryErrno);

#elif defined(PEGASUS_OS_ZOS)

char hostName[PEGASUS_MAXHOSTNAMELEN + 1];

if (String::equalNoCase("localhost", String(name)))

{

gethostname(hostName, PEGASUS_MAXHOSTNAMELEN);

hostName[sizeof(hostName) - 1] = 0;

hostEntry = gethostbyname(hostName);

}

else

{

hostEntry = gethostbyname((char *)name);

}

hostEntryErrno = h_errno;

#else

hostEntry = gethostbyname((char *)name);

hostEntryErrno = h_errno;

#endif

} while (hostEntry == 0 && hostEntryErrno == TRY_AGAIN &&

maxTries-- > 0);

return hostEntry;

}

struct hostent* System::getHostByAddr(

const char *addr,

int len,

int type,

struct hostent* he,

char* buf,

size_t buflen)

{

int hostEntryErrno = 0;

struct hostent* hostEntry = 0;

unsigned int maxTries = 5;

{

#if defined(PEGASUS_OS_LINUX)

gethostbyaddr_r(addr,

len,

type,

he,

buf,

buflen,

&hostEntry,

&hostEntryErrno);

#elif defined(PEGASUS_OS_SOLARIS)

char hostEntryBuffer[8192];

struct hostent hostEntryStruct;

hostEntry = gethostbyaddr_r(addr,

len,

type,

he,

buf,

buflen,

&hostEntryErrno);

#else

hostEntry = gethostbyaddr(addr,

len,

type);

hostEntryErrno = h_errno;

#endif

} while (hostEntry == 0 && hostEntryErrno == TRY_AGAIN &&

maxTries-- > 0);

return hostEntry;

}

#if defined(PEGASUS_OS_ZOS) || \

defined(PEGASUS_OS_VMS) || \

defined(PEGASUS_ENABLE_IPV6)

int System::getAddrInfo(

const char *hostname,

const char *servname,

const struct addrinfo *hints,

struct addrinfo **res)

{

int rc = 0;

unsigned int maxTries = 5;

#ifdef PEGASUS_OS_PASE

CString hostNameCString;

if (String::equalNoCase(hostname, "localhost"))

{

hostNameCString = getHostName().getCString();

hostname = (const char*)hostNameCString;

}

#endif

while ((rc = getaddrinfo(hostname,

servname,

hints,

res)) == EAI_AGAIN &&

maxTries-- > 0)

;

return rc;

}

int System::getNameInfo(

const struct sockaddr *sa,

size_t salen,

char *host,

size_t hostlen,

char *serv,

size_t servlen,

int flags)

{

int rc = 0;

unsigned int maxTries = 5;

while ((rc = getnameinfo(sa,

salen,

host,

hostlen,

serv,

servlen,

flags)) == EAI_AGAIN &&

maxTries-- > 0)

;

return rc;

}

#endif

// System ID constants for Logger::put and Logger::trace

#ifdef PEGASUS_FLAVOR

const String System::CIMLISTENER = "cimlistener" PEGASUS_FLAVOR;

#else

const String System::CIMLISTENER = "cimlistener"; // Listener systme ID

#endif

PEGASUS_NAMESPACE_END

Legend:

Removed from v.1.24
changed lines
	Added in v.1.79

No CVS admin address has been configured