(file) Return to System.cpp CVS log (file) (dir) Up to [Pegasus] / pegasus / src / Pegasus / Common

Diff for /pegasus/src/Pegasus/Common/System.cpp between version 1.37.2.1 and 1.71

version 1.37.2.1, 2006/06/09 17:36:52 version 1.71, 2008/12/01 17:49:56
Line 1 
Line 1 
 //%2006////////////////////////////////////////////////////////////////////////  //%LICENSE////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development  // 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
 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L.P.;  // 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
 // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;  // Source License; you may not use this file except in compliance with the
 // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.  // License.
 // Copyright (c) 2005 Hewlett-Packard Development Company, L.P.; IBM Corp.;  //
 // EMC Corporation; VERITAS Software Corporation; The Open Group.  // Permission is hereby granted, free of charge, to any person obtaining a
 // Copyright (c) 2006 Hewlett-Packard Development Company, L.P.; IBM Corp.;  // copy of this software and associated documentation files (the "Software"),
 // EMC Corporation; Symantec Corporation; The Open Group.  // to deal in the Software without restriction, including without limitation
   // the rights to use, copy, modify, merge, publish, distribute, sublicense,
   // and/or sell copies of the Software, and to permit persons to whom the
   // Software is furnished to do so, subject to the following conditions:
   //
   // The above copyright notice and this permission notice shall be included
   // in all copies or substantial portions of 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.
 // //
 // Permission is hereby granted, free of charge, to any person obtaining a copy  //////////////////////////////////////////////////////////////////////////
 // of this software and associated documentation files (the "Software"), to  
 // deal in the Software without restriction, including without limitation the  
 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or  
 // sell copies of the Software, and to permit persons to whom the Software is  
 // furnished to do so, subject to the following conditions:  
 //  
 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN  
 // ALL COPIES OR SUBSTANTIAL PORTIONS OF 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  
 //              Sean Keenan, Hewlett-Packard Company (sean.keenan@hp.com)  
 //              David Dillard, Symantec Corp. (david_dillard@symantec.com)  
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #if defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)  
 #include <Pegasus/Common/Config.h> #include <Pegasus/Common/Config.h>
 #endif  
   
  
 #include <fstream> #include <fstream>
 #include <cctype>  // for tolower() #include <cctype>  // for tolower()
 #include <cstring> #include <cstring>
 #include "System.h" #include "System.h"
 #include "Socket.h" #include "Socket.h"
   #include "Network.h"
 #ifdef PEGASUS_OS_TYPE_WINDOWS  
 # include <windows.h>  
 #else  
 # include <arpa/inet.h>  
 #endif  
   
 #include <Pegasus/Common/PegasusVersion.h> #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) #if defined(PEGASUS_OS_TYPE_WINDOWS)
 # include "SystemWindows.cpp" # include "SystemWindows.cpp"
 #elif defined(PEGASUS_OS_TYPE_UNIX)  #elif defined(PEGASUS_OS_TYPE_UNIX) || defined(PEGASUS_OS_VMS)
 # include "SystemUnix.cpp"  # include "SystemPOSIX.cpp"
 #elif defined(PEGASUS_OS_TYPE_NSK)  
 # include "SystemNsk.cpp"  
 #elif defined(PEGASUS_OS_VMS)  
 # include "SystemVms.cpp"  
 #else #else
 # error "Unsupported platform" # error "Unsupported platform"
 #endif #endif
  
 #if defined(PEGASUS_OS_OS400)  
 # include "OS400ConvertChar.h"  
 #endif  
   
 PEGASUS_USING_STD; PEGASUS_USING_STD;
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
Line 87 
Line 59 
 Boolean System::copyFile(const char* fromPath, const char* toPath) Boolean System::copyFile(const char* fromPath, const char* toPath)
 { {
     ifstream is(fromPath PEGASUS_IOS_BINARY);     ifstream is(fromPath PEGASUS_IOS_BINARY);
     ofstream os(toPath PEGASUS_IOS_BINARY);      fstream os(toPath, ios::out  PEGASUS_OR_IOS_BINARY);
  
     char c;     char c;
  
Line 97 
Line 69 
             return false;             return false;
     }     }
  
     return true;      FileSystem::syncWithDirectoryUpdates(os);
       return is.eof();
 } }
  
 static const Uint8 _toLowerTable[256] = static const Uint8 _toLowerTable[256] =
Line 206 
Line 179 
   return dirname;   return dirname;
 } }
  
 String System::getHostIP(const String &hostName)  String System::getHostName()
   {
       static String _hostname;
       static MutexType _mutex = PEGASUS_MUTEX_INITIALIZER;
   
       // Use double-checked locking pattern to avoid overhead of
       // mutex on subsequent calls.
   
       if (0 == _hostname.size())
       {
           mutex_lock(&_mutex);
   
           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(&_mutex);
       }
   
       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);
   
   #endif
   }
   
   String System::getFullyQualifiedHostName()
   {
       static String _hostname;
       static MutexType _mutex = PEGASUS_MUTEX_INITIALIZER;
   
       // Use double-checked locking pattern to avoid overhead of
       // mutex on subsequent calls.
   
       if (0 == _hostname.size())
       {
           mutex_lock(&_mutex);
   
           if (0 == _hostname.size())
           {
               try
               {
                   _hostname = _getFullyQualifiedHostName();
               }
               catch (...)
               {
                   mutex_unlock(&_mutex);
                   throw;
               }
           }
   
           mutex_unlock(&_mutex);
       }
   
       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 hostent* hostEntry;
     struct in_addr inaddr;     struct in_addr inaddr;
     String ipAddress;     String ipAddress;
     CString hostNameCString = hostName.getCString();     CString hostNameCString = hostName.getCString();
     const char* hostNamePtr = hostNameCString;     const char* hostNamePtr = hostNameCString;
  
 #if defined(PEGASUS_OS_LINUX)  
     char hostEntryBuffer[8192];  
     struct hostent hostEntryStruct;  
     int hostEntryErrno;  
   
     gethostbyname_r(  
         hostNamePtr,  
         &hostEntryStruct,  
         hostEntryBuffer,  
         sizeof(hostEntryBuffer),  
         &hostEntry,  
         &hostEntryErrno);  
 #elif defined(PEGASUS_OS_SOLARIS)  
     char hostEntryBuffer[8192];     char hostEntryBuffer[8192];
     struct hostent hostEntryStruct;     struct hostent hostEntryStruct;
     int hostEntryErrno;      hostEntry = getHostByName(hostNamePtr, &hostEntryStruct,
           hostEntryBuffer, sizeof (hostEntryBuffer));
     hostEntry = gethostbyname_r(  
         (char *)hostNamePtr,  
         &hostEntryStruct,  
         hostEntryBuffer,  
         sizeof(hostEntryBuffer),  
         &hostEntryErrno);  
 #elif defined(PEGASUS_OS_OS400)  
     char ebcdicHost[PEGASUS_MAXHOSTNAMELEN];  
     if (strlen(hostNamePtr) < PEGASUS_MAXHOSTNAMELEN)  
         strcpy(ebcdicHost, hostNamePtr);  
     else  
         return ipAddress;  
     AtoE(ebcdicHost);  
     hostEntry = gethostbyname(ebcdicHost);  
 #else  
     hostEntry = gethostbyname(hostNamePtr);  
 #endif  
  
     if (hostEntry)     if (hostEntry)
     {     {
         ::memcpy( &inaddr, hostEntry->h_addr,4);         ::memcpy( &inaddr, hostEntry->h_addr,4);
 #if defined(PEGASUS_OS_OS400)          ipAddress = ::inet_ntoa( inaddr );
         char * gottenIPAdress = NULL;          hostIP = ipAddress;
         gottenIPAdress = ::inet_ntoa( inaddr );          return true;
       }
       return false;
   #endif
   }
   
  
         if (gottenIPAdress != NULL)  #ifdef PEGASUS_ENABLE_IPV6
   Boolean System::isIPv6StackActive()
   {
       SocketHandle ip6Socket;
       if ((ip6Socket = Socket::createSocket(AF_INET6, SOCK_STREAM, IPPROTO_TCP))
           == PEGASUS_INVALID_SOCKET)
         {         {
             EtoA(gottenIPAdress);          if (getSocketError() == PEGASUS_INVALID_ADDRESS_FAMILY)
             ipAddress.assign(gottenIPAdress);          {
               return false;
         }         }
 #else  
         ipAddress = ::inet_ntoa( inaddr );  
 #endif  
     }     }
     return ipAddress;      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 // 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;         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 // 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 // RFC 1123 states: The host SHOULD check the string syntactically for a
 // dotted-decimal number before looking it up in the Domain Name System. // dotted-decimal number before looking it up in the Domain Name System.
 // Hence the call to inet_addr() first. // Hence the call to inet_addr() first.
 //////////////////////////////////////////////////////////////////////////////// ////////////////////////////////////////////////////////////////////////////////
  
 #ifdef PEGASUS_OS_OS400  
         Uint32 tmp_addr = inet_addr(ebcdicHost);  
 #else  
         Uint32 tmp_addr = inet_addr((char *) hostname);         Uint32 tmp_addr = inet_addr((char *) hostname);
 #endif  
   
     struct hostent* hostEntry;     struct hostent* hostEntry;
  
 // Note: 0xFFFFFFFF is actually a valid IP address (255.255.255.255). // Note: 0xFFFFFFFF is actually a valid IP address (255.255.255.255).
Line 311 
Line 459 
  
     if (tmp_addr == 0xFFFFFFFF)  // if hostname is not an IP address     if (tmp_addr == 0xFFFFFFFF)  // if hostname is not an IP address
     {     {
 #if defined(PEGASUS_OS_LINUX)  
         char hostEntryBuffer[8192];  
         struct hostent hostEntryStruct;  
         int hostEntryErrno;  
   
         gethostbyname_r(  
             hostname,  
             &hostEntryStruct,  
             hostEntryBuffer,  
             sizeof(hostEntryBuffer),  
             &hostEntry,  
             &hostEntryErrno);  
 #elif defined(PEGASUS_OS_SOLARIS)  
         char hostEntryBuffer[8192];         char hostEntryBuffer[8192];
         struct hostent hostEntryStruct;         struct hostent hostEntryStruct;
         int hostEntryErrno;          hostEntry = getHostByName(hostname, &hostEntryStruct,
               hostEntryBuffer, sizeof (hostEntryBuffer));
  
         hostEntry = gethostbyname_r(  
             (char *)hostname,  
             &hostEntryStruct,  
             hostEntryBuffer,  
             sizeof(hostEntryBuffer),  
             &hostEntryErrno);  
 #elif defined(PEGASUS_OS_OS400)  
         hostEntry = gethostbyname(ebcdicHost);  
 #elif defined(PEGASUS_OS_ZOS)  
         char hostName[PEGASUS_MAXHOSTNAMELEN + 1];  
         if (String::equalNoCase("localhost",String(hostname)))  
         {  
             gethostname( hostName, PEGASUS_MAXHOSTNAMELEN );  
             hostName[sizeof(hostName)-1] = 0;  
             hostEntry = gethostbyname(hostName);  
         } else  
         {  
             hostEntry = gethostbyname((char *)hostname);  
         }  
 #else  
         hostEntry = gethostbyname((char *)hostname);  
 #endif  
         if (!hostEntry)         if (!hostEntry)
                 {                 {
                         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;                 unsigned char ip_part1,ip_part2,ip_part3,ip_part4;
  
Line 368 
Line 484 
     else    // else hostname *is* a dotted-decimal IP address     else    // else hostname *is* a dotted-decimal IP address
         {         {
                 // resolve hostaddr to a real host entry                 // 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,
 #ifndef PEGASUS_OS_OS400          // those it fits all platforms
         hostEntry = gethostbyaddr((const char *) &tmp_addr, sizeof(tmp_addr), AF_INET);          char hostEntryBuffer[8192];
 #else          struct hostent hostEntryStruct;
                 hostEntry = gethostbyaddr((char *) &tmp_addr, sizeof(tmp_addr), AF_INET);          hostEntry =
 #endif              getHostByAddr((const char*) &tmp_addr, sizeof(tmp_addr), AF_INET,
                   &hostEntryStruct, hostEntryBuffer, sizeof (hostEntryBuffer));
   
                 if (hostEntry == 0)                 if (hostEntry == 0)
                 {                 {
                         // error, couldn't resolve the ip                         // 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;                         unsigned char ip_part1,ip_part2,ip_part3,ip_part4;
  
                         ip_part1 = hostEntry->h_addr[0];                         ip_part1 = hostEntry->h_addr[0];
Line 393 
Line 512 
                         ip = (ip << 8) + ip_part4;                         ip = (ip << 8) + ip_part4;
                 }                 }
         }         }
       memcpy(dst, &ip, sizeof (Uint32));
  
         return ip;      return true;
   #endif
 } }
  
 Boolean System::sameHost (const String & hostName)  Boolean System::resolveHostNameAtDNS(
       const char* hostname,
       Uint32* resolvedNameIP)
 { {
     //      struct hostent* hostEntry;
     //  If a port is included, return false  
     //      // ask the DNS for hostname resolution to IP address
     if (hostName.find (":") != PEG_NOT_FOUND)      // 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;         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)
     //  Retrieve IP addresses for both hostnames  
     //  
     Uint32 hostNameIP, systemHostIP = 0xFFFFFFFF;  
     hostNameIP = System::_acquireIP ((const char *) hostName.getCString ());  
     if (hostNameIP == 0x7F000001)  
     {     {
         //      struct hostent *entry;
         //  localhost or IP address of 127.0.0.1  
         //  real IP address needed for compare      entry = getHostByAddr((const char *) &ip_addr, sizeof(ip_addr), AF_INET);
         //  
         hostNameIP = System::_acquireIP      if (entry == 0)
             ((const char *) System::getHostName ().getCString ());      {
           // error, couldn't resolve the ip
           return false;
     }     }
     if (hostNameIP == 0xFFFFFFFF)      else
     {     {
         //          unsigned char ip_part1,ip_part2,ip_part3,ip_part4;
         //  Malformed IP address or not resolveable          ip_part1 = entry->h_addr[0];
         //          ip_part2 = entry->h_addr[1];
           ip_part3 = entry->h_addr[2];
           ip_part4 = entry->h_addr[3];
           *resolvedIP = ip_part1;
           *resolvedIP = (*resolvedIP << 8) + ip_part2;
           *resolvedIP = (*resolvedIP << 8) + ip_part3;
           *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
       Uint32 ip4 = PEGASUS_IPV4_LOOPBACK_INIT;
       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 !memcmp(&ip4, &n, sizeof (ip4));
           }
       }
   
         return false;         return false;
     }     }
  
     systemHostIP = System::_acquireIP  Boolean System::isLocalHost(const String &hostName)
         ((const char *) System::getFullyQualifiedHostName ().getCString ());  {
   // 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);
  
     if (systemHostIP == 0x7F000001)      res1 = res1root;
       while (res1 && !isLocal)
     {     {
         //          if (isLoopBack(AF_INET,
         //  localhost or IP address of 127.0.0.1              &(reinterpret_cast<struct sockaddr_in*>(res1->ai_addr))->sin_addr))
         //  real IP address needed for compare          {
         //              isLocal = true;
         systemHostIP = System::_acquireIP              break;
             ((const char *) System::getHostName ().getCString ());          }
   
           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;
     }     }
     if (systemHostIP == 0xFFFFFFFF)          res1 = res1->ai_next;
       }
       if (res1root)
     {     {
         //          freeaddrinfo(res1root);
         //  Malformed IP address or not resolveable      }
         //      if (res2root)
         return false;      {
           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 (hostNameIP != systemHostIP)      if (!hostNameIsIPNotation)  // if hostname is not an IP address
     {     {
           // localhost ?
           if (String::equalNoCase(hostName,String("localhost"))) return true;
           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;         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
     }     }
  
     return true;  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;
   
       do
       {
   #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;
   
       do
       {
   #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 // System ID constants for Logger::put and Logger::trace
 const String System::CIMLISTENER = "cimlistener"; // Listener systme ID const String System::CIMLISTENER = "cimlistener"; // Listener systme ID
  


Legend:
Removed from v.1.37.2.1  
changed lines
  Added in v.1.71

No CVS admin address has been configured
Powered by
ViewCVS 0.9.2