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

Diff for /pegasus/src/Pegasus/Common/SystemUnix.cpp between version 1.73.2.3 and 1.114

version 1.73.2.3, 2004/04/24 01:38:14 version 1.114, 2005/12/09 20:45:45
Line 1 
Line 1 
 //%2003////////////////////////////////////////////////////////////////////////  //%2005////////////////////////////////////////////////////////////////////////
 // //
 // Copyright (c) 2000, 2001, 2002  BMC Software, Hewlett-Packard Development  // Copyright (c) 2000, 2001, 2002 BMC Software; Hewlett-Packard Development
 // Company, L. P., IBM Corp., The Open Group, Tivoli Systems.  // Company, L.P.; IBM Corp.; The Open Group; Tivoli Systems.
 // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.; // Copyright (c) 2003 BMC Software; Hewlett-Packard Development Company, L. P.;
 // IBM Corp.; EMC Corporation, The Open Group. // IBM Corp.; EMC Corporation, The Open Group.
   // Copyright (c) 2004 BMC Software; Hewlett-Packard Development Company, L.P.;
   // IBM Corp.; EMC Corporation; VERITAS Software Corporation; The Open Group.
   // 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 copy // Permission is hereby granted, free of charge, to any person obtaining a copy
 // of this software and associated documentation files (the "Software"), to // of this software and associated documentation files (the "Software"), to
Line 28 
Line 32 
 // Modified By: Ben Heilbronn (ben_heilbronn@hp.com) // Modified By: Ben Heilbronn (ben_heilbronn@hp.com)
 //              Sushma Fernandes (sushma_fernandes@hp.com) //              Sushma Fernandes (sushma_fernandes@hp.com)
 //              Nag Boranna (nagaraja_boranna@hp.com) //              Nag Boranna (nagaraja_boranna@hp.com)
 //  //              Bapu Patil (bapu_patil@hp.com)
 // Modified By: Dave Rosckes (rosckes@us.ibm.com)  //              Dave Rosckes (rosckes@us.ibm.com)
   //              Amit K Arora (amita@in.ibm.com) for PEP101
   //              David Dillard, VERITAS Software Corp.
   //                  (david.dillard@veritas.com)
   //              Yi Zhou (yi.zhou@hp.com)
   //              Josephine Eskaline Joyce, IBM (jojustin@in.ibm.com) for Bug#3194
   //              Roger Kumpf, Hewlett-Packard Company (roger_kumpf@hp.com)
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #ifdef PEGASUS_OS_HPUX #ifdef PEGASUS_OS_HPUX
 # include <dl.h> # include <dl.h>
   # include <dlfcn.h>
 #elif defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) #elif defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM)
 # include <dll.h> # include <dll.h>
 #elif defined(PEGASUS_PLATFORM_OS400_ISERIES_IBM) #elif defined(PEGASUS_PLATFORM_OS400_ISERIES_IBM)
Line 51 
Line 62 
 #include <unistd.h> #include <unistd.h>
 #include <dirent.h> #include <dirent.h>
 #include <pwd.h> #include <pwd.h>
   #include <grp.h>
   
   #include <errno.h>
   #if defined(PEGASUS_OS_SOLARIS)
   # include <string.h>
   #endif
  
 #if !defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) && !defined(PEGASUS_PLATFORM_OS400_ISERIES_IBM)  #if !defined(PEGASUS_PLATFORM_ZOS_ZSERIES_IBM) && !defined(PEGASUS_PLATFORM_OS400_ISERIES_IBM) && !defined(PEGASUS_PLATFORM_DARWIN_PPC_GNU)
 #include <crypt.h> #include <crypt.h>
 #endif #endif
  
 #ifdef PEGASUS_PLATFORM_ZOS_ZSERIES_IBM #ifdef PEGASUS_PLATFORM_ZOS_ZSERIES_IBM
   #define _OPEN_SYS_SOCK_IPV6
   #include <sys/socket.h>
 #include <arpa/inet.h> #include <arpa/inet.h>
   //#include <__ftp.h>
   #define _OPEN_SYS_EXT
   #include <sys/ps.h>
 #endif #endif
  
 #if defined(PEGASUS_USE_SYSLOGS) #if defined(PEGASUS_USE_SYSLOGS)
Line 72 
Line 94 
 #include <netdb.h> #include <netdb.h>
 #include "System.h" #include "System.h"
 #include <Pegasus/Common/Tracer.h> #include <Pegasus/Common/Tracer.h>
 #include <Pegasus/Common/Destroyer.h>  
 #include <Pegasus/Common/InternalException.h> #include <Pegasus/Common/InternalException.h>
   #include <Pegasus/Common/IPC.h>
 #ifdef PEGASUS_ZOS_SECURITY #ifdef PEGASUS_ZOS_SECURITY
 #include "DynamicLibraryzOS_inline.h" #include "DynamicLibraryzOS_inline.h"
 #endif #endif
  
 PEGASUS_NAMESPACE_BEGIN  #if defined(PEGASUS_OS_LSB)
   #include <netinet/in.h>
 #if defined(PEGASUS_OS_HPUX)  #include <termios.h>
 Boolean System::bindVerbose = false;  #include <stdio.h>
   #include <stdlib.h>
 #endif #endif
  
   PEGASUS_NAMESPACE_BEGIN
   
 #ifdef PEGASUS_OS_OS400 #ifdef PEGASUS_OS_OS400
 typedef struct os400_pnstruct typedef struct os400_pnstruct
 { {
Line 105 
Line 130 
     milliseconds = Uint32(tv.tv_usec) / 1000;     milliseconds = Uint32(tv.tv_usec) / 1000;
 } }
  
   void System::getCurrentTimeUsec(Uint32& seconds, Uint32& microseconds)
   {
       timeval tv;
       gettimeofday(&tv, 0);
       seconds = Uint32(tv.tv_sec);
       microseconds = Uint32(tv.tv_usec);
   }
   
 String System::getCurrentASCIITime() String System::getCurrentASCIITime()
 { {
     char    str[50];     char    str[50];
     time_t  rawTime;     time_t  rawTime;
       struct tm tmBuffer;
  
     time(&rawTime);     time(&rawTime);
     strftime(str, 40,"%m/%d/%Y-%T", localtime(&rawTime));      strftime(str, 40,"%m/%d/%Y-%T", localtime_r(&rawTime, &tmBuffer));
     String time = str;      return String(str);
     return time;  
 } }
  
 void System::sleep(Uint32 seconds) void System::sleep(Uint32 seconds)
Line 396 
Line 429 
     Tracer::trace(TRC_OS_ABSTRACTION, Tracer::LEVEL2,     Tracer::trace(TRC_OS_ABSTRACTION, Tracer::LEVEL2,
                   "Attempting to load library %s", fileName);                   "Attempting to load library %s", fileName);
  
 #if defined(PEGASUS_OS_HPUX)  #if defined(PEGASUS_OS_TRU64)
     void* handle;  
     if (bindVerbose)  
     {  
         handle = shl_load(fileName,  
                      BIND_IMMEDIATE | DYNAMIC_PATH | BIND_VERBOSE, 0L);  
     }  
     else  
     {  
         handle = shl_load(fileName, BIND_IMMEDIATE | DYNAMIC_PATH, 0L);  
     }  
     Tracer::trace(TRC_OS_ABSTRACTION, Tracer::LEVEL2,  
                   "After loading lib %s, error code is %d", fileName,  
                   (handle == (void *)0)?errno:0);  
   
     PEG_METHOD_EXIT();  
     return DynamicLibraryHandle(handle);  
 #elif defined(PEGASUS_OS_TRU64)  
     PEG_METHOD_EXIT();     PEG_METHOD_EXIT();
     return DynamicLibraryHandle(dlopen(fileName, RTLD_NOW));     return DynamicLibraryHandle(dlopen(fileName, RTLD_NOW));
 #elif defined(PEGASUS_OS_ZOS) #elif defined(PEGASUS_OS_ZOS)
Line 431 
Line 447 
     return DynamicLibraryHandle(OS400_LoadDynamicLibrary(fileName));     return DynamicLibraryHandle(OS400_LoadDynamicLibrary(fileName));
 #else #else
     PEG_METHOD_EXIT();     PEG_METHOD_EXIT();
     return DynamicLibraryHandle(dlopen(fileName, RTLD_NOW | RTLD_GLOBAL));      return DynamicLibraryHandle(dlopen(fileName,  RTLD_GLOBAL|RTLD_NOW));
 #endif #endif
  
 } }
  
 void System::unloadDynamicLibrary(DynamicLibraryHandle libraryHandle) void System::unloadDynamicLibrary(DynamicLibraryHandle libraryHandle)
 { {
     // ATTN: Should this method indicate success/failure?  
 #if defined(PEGASUS_OS_LINUX) || defined(PEGASUS_OS_SOLARIS)  
     dlclose(libraryHandle);  
 #endif  
   
 #ifdef PEGASUS_OS_HPUX  
     // Note: shl_unload will unload the library even if it has been loaded  
     // multiple times.  No reference count is kept.  
     int ignored = shl_unload(reinterpret_cast<shl_t>(libraryHandle));  
 #endif  
   
 #ifdef PEGASUS_OS_OS400 #ifdef PEGASUS_OS_OS400
    OS400_UnloadDynamicLibrary((int)libraryHandle);    OS400_UnloadDynamicLibrary((int)libraryHandle);
 #endif  #elif defined(PEGASUS_OS_ZOS)
   
 #ifdef PEGASUS_OS_AIX  
     dlclose(libraryHandle);  
 #endif  
   
 #ifdef PEGASUS_OS_ZOS  
         dllfree(reinterpret_cast<dllhandle *> (libraryHandle));         dllfree(reinterpret_cast<dllhandle *> (libraryHandle));
   #else
       dlclose(libraryHandle);
 #endif #endif
 } }
  
 String System::dynamicLoadError() { String System::dynamicLoadError() {
     // ATTN: Is this safe in a multi-threaded process?  Should this string     // ATTN: Is this safe in a multi-threaded process?  Should this string
     // be returned from loadDynamicLibrary?     // be returned from loadDynamicLibrary?
 #ifdef PEGASUS_OS_HPUX  #ifdef PEGASUS_OS_ZOS
     // ATTN: If shl_load() returns NULL, this value should be strerror(errno)  
     return String();  
 #elif defined(PEGASUS_OS_ZOS)  
     return String();     return String();
 #elif defined(PEGASUS_OS_OS400) #elif defined(PEGASUS_OS_OS400)
     return String(OS400_DynamicLoadError());     return String(OS400_DynamicLoadError());
Line 483 
Line 481 
     DynamicLibraryHandle libraryHandle,     DynamicLibraryHandle libraryHandle,
     const char* symbolName)     const char* symbolName)
 { {
 #ifdef PEGASUS_OS_HPUX  
     char* p = (char*)symbolName;  
     void* proc = 0;  
   
     if (shl_findsym((shl_t*)&libraryHandle, symbolName, TYPE_UNDEFINED,  
                     &proc) == 0)  
     {  
         return DynamicSymbolHandle(proc);  
     }  
   
     if (shl_findsym((shl_t*)libraryHandle,  
                     (String("_") + symbolName).getCString(),  
                     TYPE_UNDEFINED,  
                     &proc) == 0)  
     {  
         return DynamicSymbolHandle(proc);  
     }  
   
     return 0;  
  
 #elif defined(PEGASUS_OS_ZOS)  #ifdef PEGASUS_OS_ZOS
     return DynamicSymbolHandle(dllqueryfn((dllhandle *)libraryHandle,     return DynamicSymbolHandle(dllqueryfn((dllhandle *)libraryHandle,
                                (char*)symbolName));                                (char*)symbolName));
  
Line 519 
Line 498 
  
 String System::getHostName() String System::getHostName()
 { {
     static char hostname[64];      static char hostname[PEGASUS_MAXHOSTNAMELEN + 1];
  
     if (!*hostname)     if (!*hostname)
     {     {
         gethostname(hostname, sizeof(hostname));         gethostname(hostname, sizeof(hostname));
           hostname[sizeof(hostname)-1] = 0;
 #if defined(PEGASUS_OS_OS400) #if defined(PEGASUS_OS_OS400)
         EtoA(hostname);         EtoA(hostname);
 #endif #endif
Line 534 
Line 514 
  
 String System::getFullyQualifiedHostName () String System::getFullyQualifiedHostName ()
 { {
 #ifdef PEGASUS_OS_HPUX  #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_OS_AIX) || defined(PEGASUS_OS_LINUX) || defined(PEGASUS_OS_OS400)
     char hostName [MAXHOSTNAMELEN];      char hostName[PEGASUS_MAXHOSTNAMELEN + 1];
     struct hostent *he;     struct hostent *he;
     String fqName;     String fqName;
  
     if (gethostname (hostName, MAXHOSTNAMELEN) != 0)      if (gethostname(hostName, sizeof(hostName)) != 0)
     {     {
         return String::EMPTY;         return String::EMPTY;
     }     }
       hostName[sizeof(hostName)-1] = 0;
  
     if (he = gethostbyname (hostName))      if ((he = gethostbyname (hostName)))
     {     {
        strcpy (hostName, he->h_name);          strncpy(hostName, he->h_name, sizeof(hostName)-1);
     }     }
  
   #if defined(PEGASUS_OS_OS400)
       EtoA(hostName);
   #endif
   
     fqName.assign (hostName);     fqName.assign (hostName);
  
     return fqName;     return fqName;
   #elif defined(PEGASUS_OS_ZOS)
       char hostName[PEGASUS_MAXHOSTNAMELEN + 1];
       String fqName;
       struct addrinfo *resolv;
       struct addrinfo hint;
       struct hostent *he;
       // receive short name of the local host
       if (gethostname(hostName, PEGASUS_MAXHOSTNAMELEN) != 0)
       {
           return String::EMPTY;
       }
       resolv = new 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 = getaddrinfo(hostName,
                   NULL,
                   &hint,
                   &resolv);
       if (success==0)
       {
           // assign fully qualified hostname
           fqName.assign(resolv->ai_canonname);
       } else
       {
           if ((he = gethostbyname(hostName)))
           {
               strcpy (hostName, he->h_name);
           }
           // assign hostName
           // if gethostbyname was successful assign that result
           // else assign unqualified hostname
       fqName.assign(hostName);
       }
       freeaddrinfo(resolv);
       delete resolv;
   
       return fqName;
 #else #else
     //     //
     //  ATTN: Implement this method to return the fully qualified host name     //  ATTN: Implement this method to return the fully qualified host name
Line 562 
Line 586 
  
 String System::getSystemCreationClassName () String System::getSystemCreationClassName ()
 { {
 #ifdef PEGASUS_OS_HPUX  
     return "CIM_ComputerSystem";  
 #else  
     //     //
     //  ATTN: Implement this method to return the system creation class name      //  The value returned should match the value of the CreationClassName key
       //  property used in the instrumentation of the CIM_ComputerSystem class
       //  as determined by the provider for the CIM_ComputerSystem class
     //     //
     return String::EMPTY;      return "CIM_ComputerSystem";
 #endif  
 } }
  
 Uint32 System::lookupPort( Uint32 System::lookupPort(
Line 583 
Line 605 
     //     //
     // Get wbem-local port from /etc/services     // Get wbem-local port from /etc/services
     //     //
 #if !defined(PEGASUS_OS_OS400)  
 #ifdef PEGASUS_OS_SOLARIS #ifdef PEGASUS_OS_SOLARIS
 #define SERV_BUFF_SIZE  1024 #define SERV_BUFF_SIZE  1024
     struct servent      serv_result;     struct servent      serv_result;
Line 591 
Line 613 
  
     if ( (serv = getservbyname_r(serviceName, TCP, &serv_result,     if ( (serv = getservbyname_r(serviceName, TCP, &serv_result,
                                 buf, SERV_BUFF_SIZE)) != NULL )                                 buf, SERV_BUFF_SIZE)) != NULL )
   #elif defined(PEGASUS_OS_OS400)
       struct servent serv_result;
       serv = &serv_result;
       struct servent_data buf;
       memset(&buf, 0x00, sizeof(struct servent_data));
   
       char srvnameEbcdic[256];
       strcpy(srvnameEbcdic, serviceName);
       AtoE(srvnameEbcdic);
   
       char tcpEbcdic[64];
       strcpy(tcpEbcdic, TCP);
       AtoE(tcpEbcdic);
   
       if ( (getservbyname_r(srvnameEbcdic, tcpEbcdic, &serv_result,
                             &buf)) == 0 )
 #else // PEGASUS_OS_SOLARIS #else // PEGASUS_OS_SOLARIS
     if ( (serv = getservbyname(serviceName, TCP)) != NULL )     if ( (serv = getservbyname(serviceName, TCP)) != NULL )
 #endif // PEGASUS_OS_SOLARIS #endif // PEGASUS_OS_SOLARIS
 #else  // !PEGASUS_OS_OS400  
     // Note - serviceName came from Constants.h - no need to  
     // convert to EBCDIC  
     // Need to cast on OS/400  
     if ( (serv = getservbyname((char *)serviceName, TCP)) != NULL )  
 #endif  // !PEGASUS_OS_OS400  
     {     {
         localPort = htons((uint16_t)serv->s_port);         localPort = htons((uint16_t)serv->s_port);
     }     }
Line 610 
Line 642 
  
     return localPort;     return localPort;
 } }
   #if defined(PEGASUS_OS_LSB)
   /*
      getpass equivalent.
      Adapted from example implementation described in GLIBC documentation
      (http://www.dusek.ch/manual/glibc/libc_32.html) and
      "Advanced Programming in the UNIX Environment" by Richard Stevens,
      pg. 350.
   
   */
   #define MAX_PASS_LEN 1024
   char *getpassword(const char *prompt)
   {
     static char buf[MAX_PASS_LEN];
     struct termios old, new_val;
     char *ptr;
     int c;
   
     buf[0] = 0;
   
     /* Turn echoing off and fail if we can't. */
     if (tcgetattr (fileno (stdin), &old) != 0)
       return buf;
     new_val = old;
     new_val.c_lflag &= ~(ECHO | ECHOE | ECHOK | ECHONL);
     if (tcsetattr (fileno (stdin), TCSAFLUSH, &new_val) != 0)
       return buf;
   
     /* Read the password. */
     fputs (prompt, stdin);
     ptr = buf;
     while ( (c = getc(stdin)) != EOF && c != '\n') {
       if (ptr < &buf[MAX_PASS_LEN])
         *ptr++ = c;
     }
     *ptr = 0;
     putc('\n', stdin);
   
     /* Restore terminal. */
     (void) tcsetattr (fileno (stdin), TCSAFLUSH, &old);
     fclose(stdin);
     return buf;
   }
   #endif
  
 String System::getPassword(const char* prompt) String System::getPassword(const char* prompt)
 { {
Line 618 
Line 693 
  
 #if !defined(PEGASUS_OS_OS400) #if !defined(PEGASUS_OS_OS400)
     // Not supported on OS/400, and we don't need it.     // Not supported on OS/400, and we don't need it.
       // 'getpass' is DEPRECATED
   # if !defined(PEGASUS_OS_LSB)
     password = String(getpass( prompt ));     password = String(getpass( prompt ));
   # else
       password = String(getpassword( prompt ));
   # endif
   
 #endif #endif
  
     return password;     return password;
Line 631 
Line 712 
  
 #if defined(PEGASUS_OS_SOLARIS) || \ #if defined(PEGASUS_OS_SOLARIS) || \
     defined(PEGASUS_OS_HPUX) || \     defined(PEGASUS_OS_HPUX) || \
     defined(PEGASUS_OS_LINUX)      defined(PEGASUS_OS_LINUX) || \
       defined(PEGASUS_OS_OS400)
  
     const unsigned int PWD_BUFF_SIZE = 1024;     const unsigned int PWD_BUFF_SIZE = 1024;
     struct passwd       local_pwd;     struct passwd       local_pwd;
Line 641 
Line 723 
     {     {
         String errorMsg = String("getpwuid_r failure : ") +         String errorMsg = String("getpwuid_r failure : ") +
                             String(strerror(errno));                             String(strerror(errno));
         Tracer::PEG_TRACE_STRING (TRC_OS_ABSTRACTION, Tracer::LEVEL2,          PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2, errorMsg);
                                   errorMsg);          // L10N TODO - This message needs to be added.
         // l10n TODO - Need to add this message  
         //Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,         //Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,
         //                          errorMsg);         //                          errorMsg);
         return userName;  
     }     }
   #elif defined(PEGASUS_OS_ZOS)
       char effective_username[9];
       __getuserid(effective_username, 9);
       __etoa_l(effective_username,9);
       userName.assign(effective_username);
       return userName;
 #else #else
     //     //
     //  get the currently logged in user's UID.     //  get the currently logged in user's UID.
Line 656 
Line 742 
 #endif #endif
     if ( pwd == NULL )     if ( pwd == NULL )
     {     {
          // l10n TODO - Need to add this message           // L10N TODO - This message needs to be added.
          // Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,          // Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,
          //    "getpwuid_r failure, user may have been removed just after login");          //    "getpwuid_r failure, user may have been removed just after login");
          Tracer::trace (TRC_OS_ABSTRACTION, Tracer::LEVEL4,          Tracer::trace (TRC_OS_ABSTRACTION, Tracer::LEVEL4,
Line 694 
Line 780 
  
 #if defined(PEGASUS_OS_SOLARIS) || \ #if defined(PEGASUS_OS_SOLARIS) || \
     defined(PEGASUS_OS_HPUX) || \     defined(PEGASUS_OS_HPUX) || \
     defined(PEGASUS_OS_LINUX)      defined(PEGASUS_OS_LINUX) || \
       defined(PEGASUS_OS_OS400)
  
     const unsigned int PWD_BUFF_SIZE = 1024;     const unsigned int PWD_BUFF_SIZE = 1024;
     struct passwd   pwd;     struct passwd   pwd;
Line 705 
Line 792 
     {     {
         String errorMsg = String("getpwnam_r failure : ") +         String errorMsg = String("getpwnam_r failure : ") +
                             String(strerror(errno));                             String(strerror(errno));
         Tracer::PEG_TRACE_STRING (TRC_OS_ABSTRACTION, Tracer::LEVEL2,          PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2, errorMsg);
                                   errorMsg);          // L10N TODO - This message needs to be added.
         // l10n TODO - Need to add this message  
         // Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,         // Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,
         //                           errorMsg);         //                           errorMsg);
         return false;  
     }     }
     if (result == NULL)     if (result == NULL)
     {     {
Line 731 
Line 816 
 #if defined(PEGASUS_OS_OS400) #if defined(PEGASUS_OS_OS400)
     EtoA((char *)userName);     EtoA((char *)userName);
 #endif #endif
   
     return true;     return true;
 } }
  
 Boolean System::isPrivilegedUser(const String userName)  Boolean System::isPrivilegedUser(const String& userName)
 { {
     //     //
     // Check if the given user is a privileged user     // Check if the given user is a privileged user
Line 745 
Line 831 
     const unsigned int PWD_BUFF_SIZE = 1024;     const unsigned int PWD_BUFF_SIZE = 1024;
     char            pwdBuffer[PWD_BUFF_SIZE];     char            pwdBuffer[PWD_BUFF_SIZE];
  
     if (getpwnam_r(userName.getCString(), &pwd, pwdBuffer, PWD_BUFF_SIZE, &result) != 0)      if (getpwnam_r(
             userName.getCString(), &pwd, pwdBuffer, PWD_BUFF_SIZE, &result) != 0)
     {     {
         String errorMsg = String("getpwnam_r failure : ") +         String errorMsg = String("getpwnam_r failure : ") +
                             String(strerror(errno));                             String(strerror(errno));
         Tracer::PEG_TRACE_STRING (TRC_OS_ABSTRACTION, Tracer::LEVEL2,          PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2, errorMsg);
                                   errorMsg);          // L10N TODO - This message needs to be added.
         // l10n TODO - Need to add this message  
         //Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,         //Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,
         //                          errorMsg);         //                          errorMsg);
         return false;  
     }     }
  
     // Check if the requested entry was found. If not return false.     // Check if the requested entry was found. If not return false.
Line 774 
Line 859 
     AtoE((char *)tmp);     AtoE((char *)tmp);
     return ycmCheckUserCmdAuthorities(tmp);     return ycmCheckUserCmdAuthorities(tmp);
 #endif #endif
   
 } }
  
 String System::getPrivilegedUserName() String System::getPrivilegedUserName()
Line 785 
Line 871 
         struct passwd*   pwd = NULL;         struct passwd*   pwd = NULL;
 #if defined(PEGASUS_OS_SOLARIS) || \ #if defined(PEGASUS_OS_SOLARIS) || \
     defined(PEGASUS_OS_HPUX) || \     defined(PEGASUS_OS_HPUX) || \
     defined(PEGASUS_OS_LINUX)      defined(PEGASUS_OS_LINUX) || \
       defined(PEGASUS_OS_OS400)
         const unsigned int PWD_BUFF_SIZE = 1024;         const unsigned int PWD_BUFF_SIZE = 1024;
         struct passwd   local_pwd;         struct passwd   local_pwd;
         char            buf[PWD_BUFF_SIZE];         char            buf[PWD_BUFF_SIZE];
Line 794 
Line 881 
         {         {
             String errorMsg = String("getpwuid_r failure : ") +             String errorMsg = String("getpwuid_r failure : ") +
                             String(strerror(errno));                             String(strerror(errno));
             Tracer::PEG_TRACE_STRING (TRC_OS_ABSTRACTION, Tracer::LEVEL2,              PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2, errorMsg);
                                   errorMsg);              // L10N TODO - This message needs to be added.
             // l10n TODO - Need to add this message  
             // Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,             // Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,
             //                      errorMsg);             //                      errorMsg);
             return userName;  
         }         }
 #else #else
         //         //
Line 829 
Line 914 
     return (userName);     return (userName);
 } }
  
   Boolean System::isGroupMember(const char* userName, const char* groupName)
   {
       struct group                        grp;
       char                                *member;
       Boolean                             retVal = false;
       const unsigned int                  PWD_BUFF_SIZE = 1024;
       const unsigned int                  GRP_BUFF_SIZE = 1024;
       struct passwd                       pwd;
       struct passwd                       *result;
       struct group                        *grpresult;
       char                                pwdBuffer[PWD_BUFF_SIZE];
       char                                grpBuffer[GRP_BUFF_SIZE];
   
       //
       // Search Primary group information.
       //
   
       // Find the entry that matches "userName"
   
       if (getpwnam_r(userName, &pwd, pwdBuffer, PWD_BUFF_SIZE, &result) != 0)
       {
           String errorMsg = String("getpwnam_r failure : ") +
                               String(strerror(errno));
           PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2, errorMsg);
           Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,
                                     errorMsg);
           throw InternalSystemError();
       }
   
       if ( result != NULL )
       {
           // User found, check for group information.
           gid_t           group_id;
           group_id = pwd.pw_gid;
   
           // Get the group name using group_id and compare with group passed.
           if ( getgrgid_r(group_id, &grp,
                    grpBuffer, GRP_BUFF_SIZE, &grpresult) != 0)
           {
               String errorMsg = String("getgrgid_r failure : ") +
                                    String(strerror(errno));
               PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2, errorMsg);
               Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,
                                     errorMsg);
               throw InternalSystemError();
           }
   
           // Compare the user's group name to groupName.
           if ( strcmp (grp.gr_name, groupName) == 0 )
           {
                // User is a member of the group.
                return true;
           }
       }
   
       //
       // Search supplemental groups.
       // Get a user group entry
       //
   #if defined(PEGASUS_OS_LSB)
       if ( getgrnam_r((char *)groupName, &grp,
                 grpBuffer, GRP_BUFF_SIZE, &grpresult) != 0 )
   #else
       if ( getgrnam_r(groupName, &grp,
                 grpBuffer, GRP_BUFF_SIZE, &grpresult) != 0 )
   
   #endif
       {
           String errorMsg = String("getgrnam_r failure : ") +
                               String(strerror(errno));
           PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2, errorMsg);
           Logger::put(Logger::STANDARD_LOG, "CIMServer", Logger::WARNING,
                                     errorMsg);
           throw InternalSystemError();
       }
   
       // Check if the requested group was found.
       if (grpresult == NULL)
       {
           return false;
       }
   
       Uint32 j = 0;
   
       //
       // Get all the members of the group
       //
       member = grp.gr_mem[j++];
   
       while (member)
       {
           //
           // Check if the user is a member of the group
           //
           if ( strcmp(userName, member) == 0 )
           {
               retVal = true;
               break;
           }
           member = grp.gr_mem[j++];
       }
   
       return retVal;
   }
   #ifndef PEGASUS_OS_OS400
   Boolean System::changeUserContext(const char* userName)
   {
       const unsigned int PWD_BUFF_SIZE = 1024;
       struct passwd pwd;
       struct passwd *result;
       char pwdBuffer[PWD_BUFF_SIZE];
   
   # if defined(PEGASUS_OS_OS400)
       AtoE((char *)userName);
   # endif
   
       int rc = getpwnam_r(userName, &pwd, pwdBuffer, PWD_BUFF_SIZE, &result);
   
   # if defined(PEGASUS_OS_OS400)
       EtoA((char *)userName);
   # endif
   
       if (rc != 0)
       {
           PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2,
               String("getpwnam_r failed: ") + String(strerror(errno)));
           return false;
       }
   
       if (result == 0)
       {
           PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2,
               "getpwnam_r failed.");
           return false;
       }
   
       Tracer::trace(TRC_OS_ABSTRACTION, Tracer::LEVEL4,
           "Changing user context to: uid = %d, gid = %d",
           (int)pwd.pw_uid, (int)pwd.pw_gid);
   
       if (setgid(pwd.pw_gid) != 0)
       {
           PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2,
               String("setgid failed: ") + String(strerror(errno)));
           return false;
       }
   
       if (setuid(pwd.pw_uid) != 0)
       {
           PEG_TRACE_STRING(TRC_OS_ABSTRACTION, Tracer::LEVEL2,
               String("setuid failed: ") + String(strerror(errno)));
           return false;
       }
   
       return true;
   }
   #endif
 Uint32 System::getPID() Uint32 System::getPID()
 { {
     //     //
Line 899 
Line 1141 
     return ( ret != -1 );     return ( ret != -1 );
 } }
  
 void System::openlog(const String ident)  Boolean System::verifyFileOwnership(const char* path)
 { {
 #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU)      struct stat st;
     // ATTN: Hard-code the "cimserver" identifier until the infrastructure  
     // is set up to pass this as the "ident" string.  #if defined(PEGASUS_OS_OS400)
     //::openlog(ident.getCString(), LOG_PID|LOG_CONS, LOG_DAEMON);      OS400_PNSTRUCT pathname;
     ::openlog("cimserver", LOG_PID, LOG_DAEMON);      memset((void*)&pathname, 0x00, sizeof(OS400_PNSTRUCT));
       pathname.qlg_struct.CCSID = 1208;
   #pragma convert(37)
       memcpy(pathname.qlg_struct.Country_ID,"US",2);
       memcpy(pathname.qlg_struct.Language_ID,"ENU",3);
   #pragma convert(0)
       pathname.qlg_struct.Path_Type = QLG_PTR_SINGLE;
       pathname.qlg_struct.Path_Length = strlen(path);
       pathname.qlg_struct.Path_Name_Delimiter[0] = '/';
       pathname.pn = (char *)path;
  
       if (QlgStat((Qlg_Path_Name_T *)&pathname, &st) != 0)
       {
           return false;
       }
   #else
       if (lstat(path, &st) != 0)
       {
           return false;
       }
 #endif #endif
  
     return;      return ((st.st_uid == geteuid()) &&    // Verify the file owner
               S_ISREG(st.st_mode) &&         // Verify it is a regular file
               (st.st_nlink == 1));           // Verify it is not a hard link
 } }
  
 void System::syslog(Uint32 severity, const char *data)  void System::syslog(const String& ident, Uint32 severity, const char* message)
 { {
 #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU)  #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_OS_LINUX)
   
       // Since the openlog(), syslog(), and closelog() function calls must be
       // coordinated (see below), we need a thread control.
   
       static Mutex logMutex;
  
     // FUTURE-SF-P3-20020517 : Use the Syslog on HP-UX. Eventually only      AutoMutex loglock(logMutex);
     // certain messages will go to the Syslog and others to the  
     // Pegasus Logger.  
     Uint32 syslogLevel = LOG_DEBUG;  
  
     // Map the log levels.      // Get a const char* representation of the identifier string.  Note: The
     if (severity & Logger::TRACE) syslogLevel =       LOG_DEBUG;      // character string passed to the openlog() function must persist until
     if (severity & Logger::INFORMATION) syslogLevel = LOG_INFO;      // closelog() is called.  The syslog() method uses this pointer directly
     if (severity & Logger::WARNING) syslogLevel =     LOG_WARNING;      // rather than a copy of the string it refers to.
     if (severity & Logger::SEVERE) syslogLevel =      LOG_ERR;  
     if (severity & Logger::FATAL) syslogLevel =       LOG_CRIT;  
  
     ::syslog(syslogLevel, "%s", data);      CString identCString = ident.getCString();
       openlog(identCString, LOG_PID, LOG_DAEMON);
   
       // Map from the Logger log level to the system log level.
   
       Uint32 syslogLevel;
       if (severity & Logger::FATAL)
       {
           syslogLevel = LOG_CRIT;
       }
       else if (severity & Logger::SEVERE)
       {
           syslogLevel = LOG_ERR;
       }
       else if (severity & Logger::WARNING)
       {
           syslogLevel = LOG_WARNING;
       }
       else if (severity & Logger::INFORMATION)
       {
           syslogLevel = LOG_INFO;
       }
       else // if (severity & Logger::TRACE)
       {
           syslogLevel = LOG_DEBUG;
       }
   
       // Write the message to the system log.
   
       ::syslog(syslogLevel, "%s", message);
   
       closelog();
  
 #elif defined(PEGASUS_OS_OS400) #elif defined(PEGASUS_OS_OS400)
  
     std::string replacementData = data;      std::string replacementData = message;
     // All messages will go to the joblog. In the future     // All messages will go to the joblog. In the future
     // some messages may go to other message queues yet     // some messages may go to other message queues yet
     // to be determined.     // to be determined.
Line 943 
Line 1236 
         // turn into ycmMessage so we can put it in the job log         // turn into ycmMessage so we can put it in the job log
 #pragma convert(37) #pragma convert(37)
         ycmMessage theMessage("CPIDF80",         ycmMessage theMessage("CPIDF80",
                                   data,                                message,
                               strlen(data),                                strlen(message),
                                   "Logger",                                   "Logger",
                               ycmCTLCIMID,                               ycmCTLCIMID,
                                   TRUE);                                   TRUE);
Line 962 
Line 1255 
         // turn into ycmMessage so we can put it in the job log         // turn into ycmMessage so we can put it in the job log
 #pragma convert(37) #pragma convert(37)
         ycmMessage theMessage("CPDDF82",         ycmMessage theMessage("CPDDF82",
                                   data,                                message,
                               strlen(data),                                strlen(message),
                                   "Logger",                                   "Logger",
                               ycmCTLCIMID,                               ycmCTLCIMID,
                                   TRUE);                                   TRUE);
Line 974 
Line 1267 
     }     }
  
 #endif #endif
   
     return;  
 } }
  
 void System::closelog()  // System ID constants for Logger::put and Logger::trace
   #if defined(PEGASUS_PLATFORM_OS400_ISERIES_IBM)
   const String System::CIMSERVER = "qycmcimom";  // Server system ID
   #else
   const String System::CIMSERVER = "cimserver";  // Server system ID
   #endif
   
   
   
   
   //
   // System Initializater for AIX
   //
   #ifdef PEGASUS_OS_AIX
   #include <cstdlib>
   
   class SystemInitializer
 { {
 #if defined(PEGASUS_OS_HPUX) || defined(PEGASUS_PLATFORM_LINUX_GENERIC_GNU)  
  
     ::closelog();  public:
       /**
        *
        * Default constructor.
        *
        */
       SystemInitializer();
   };
   
  
 #endif  
  
     return;  SystemInitializer::SystemInitializer()
   {
       putenv("XPG_SUS_ENV=ON");
 } }
  
 // System ID constants for Logger::put and Logger::trace  static SystemInitializer initializer;
 #if defined(PEGASUS_PLATFORM_OS400_ISERIES_IBM)  
 const String System::CIMSERVER = "qycmcimom";  // Server system ID  
 #else  
 const String System::CIMSERVER = "cimserver";  // Server system ID  
 #endif #endif
  
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END


Legend:
Removed from v.1.73.2.3  
changed lines
  Added in v.1.114

No CVS admin address has been configured
Powered by
ViewCVS 0.9.2