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

Diff for /pegasus/src/Pegasus/Common/SystemWindows.cpp between version 1.64 and 1.84

version 1.64, 2006/06/26 22:23:29 version 1.84, 2008/08/14 18:54:02
Line 29 
Line 29 
 // //
 //============================================================================== //==============================================================================
 // //
 // Author: Mike Brasher (mbrasher@bmc.com)  
 //  
 // Modified By: Sushma Fernandes (sushma_fernandes@hp.com)  
 //              Nag Boranna, Hewlett-Packard Company (nagaraja_boranna@hp.com)  
 //              Bapu Patil (bapu_patil@hp.com)  
 //  
 // Modified By: Dave Rosckes (rosckes@us.ibm.com)  
 //              Terry Martin, Hewlett-Packard Company (terry.martin@hp.com)  
 //              Amit K Arora, IBM (amita@in.ibm.com) for Bug#1428  
 //              Seema Gupta (gseema@in.ibm.com) for Bug#1617  
 //              David Dillard, VERITAS Software Corp.  
 //                  (david.dillard@veritas.com)  
 //  
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #include "System.h" #include "System.h"
  
 #include "Network.h" #include "Network.h"
   #include "Mutex.h"
 #include <fcntl.h> #include <fcntl.h>
 #include <sys/types.h> #include <sys/types.h>
 #include <time.h> #include <time.h>
Line 58 
Line 46 
 #include <windows.h> #include <windows.h>
 #include <process.h> #include <process.h>
 #include <lm.h> #include <lm.h>
   #include <Pegasus/Common/Tracer.h>
  
 #define SECURITY_WIN32 #define SECURITY_WIN32
 #include <security.h> #include <security.h>
Line 173 
Line 162 
  
 Boolean System::renameFile(const char* oldPath, const char* newPath) Boolean System::renameFile(const char* oldPath, const char* newPath)
 { {
     return rename(oldPath, newPath) == 0;      if (exists(oldPath))
 }  
   
 DynamicLibraryHandle System::loadDynamicLibrary(const char* fileName)  
 {  
     return DynamicLibraryHandle(LoadLibrary(fileName));  
 }  
   
 void System::unloadDynamicLibrary(DynamicLibraryHandle libraryHandle)  
 {  
     FreeLibrary(HINSTANCE(libraryHandle));  
 }  
   
 String System::dynamicLoadError(void) {  
 return String();  
 }  
   
 DynamicSymbolHandle System::loadDynamicSymbol(  
     DynamicLibraryHandle libraryHandle,  
     const char* symbolName)  
 {  
     return DynamicSymbolHandle(GetProcAddress(  
     (HINSTANCE)libraryHandle, symbolName));  
 }  
   
 String System::getHostName()  
 {  
     static char hostname[PEGASUS_MAXHOSTNAMELEN + 1];  
   
     if (!*hostname)  
     {     {
         gethostname(hostname, sizeof(hostname));          removeFile(newPath);
     }     }
     hostname[sizeof(hostname)-1] = 0;      return rename(oldPath, newPath) == 0;
   
     return hostname;  
 }  
   
 String System::getFullyQualifiedHostName ()  
 {  
     static char FQHostName[PEGASUS_MAXHOSTNAMELEN + 1];  
   
     if (!*FQHostName)  
     {  
         String hostname = getHostName();  
         struct hostent* hostEnt;  
   
         hostEnt = gethostbyname((const char *)hostname.getCString());  
         if (hostEnt == NULL)  
         {  
             return String::EMPTY;  
         }  
         strncpy(FQHostName, hostEnt->h_name, sizeof(FQHostName)-1);  
     }  
   
     return FQHostName;  
 } }
  
 String System::getSystemCreationClassName () String System::getSystemCreationClassName ()
Line 369 
Line 307 
         if (wcscmp(computerName, userDomain) != 0)         if (wcscmp(computerName, userDomain) != 0)
         {         {
         //userId.append(userDomain);         //userId.append(userDomain);
         Uint32 n = wcslen(userDomain);          Uint32 n = (Uint32)wcslen(userDomain);
         for(unsigned long i = 0; i < n; i++)         for(unsigned long i = 0; i < n; i++)
         {         {
             userId.append(Char16(userDomain[i]));             userId.append(Char16(userDomain[i]));
         }         }
                 userId.append("\\");                 userId.append("\\");
                 //userId.append(userName);                 //userId.append(userName);
         n = wcslen(userName);          n = (Uint32)wcslen(userName);
         for(unsigned long i = 0; i < n; i++)         for(unsigned long i = 0; i < n; i++)
         {         {
             userId.append(Char16(userName[i]));             userId.append(Char16(userName[i]));
         }         }
  
         } else      }
       else
         {         {
                 //userId.append(userName);                 //userId.append(userName);
         Uint32 n = wcslen(userName);          Uint32 n = (Uint32)wcslen(userName);
         for(unsigned long i = 0; i < n; i++)         for(unsigned long i = 0; i < n; i++)
         {         {
             userId.append(Char16(userName[i]));             userId.append(Char16(userName[i]));
Line 416 
Line 355 
         userId.append(Char16(pUserName[i]));         userId.append(Char16(pUserName[i]));
     }     }
  
   
     return userId;     return userId;
 #endif #endif
 } }
Line 428 
Line 366 
     char pcSalt[3] = {0};     char pcSalt[3] = {0};
  
     strncpy(pcSalt, salt, 2);     strncpy(pcSalt, salt, 2);
     dwByteCount = strlen(password);      dwByteCount = (DWORD)strlen(password);
     memcpy(pbBuffer, password, dwByteCount);     memcpy(pbBuffer, password, dwByteCount);
     for (DWORD i=0; (i<dwByteCount) || (i>=PW_BUFF_LEN); i++)     for (DWORD i=0; (i<dwByteCount) || (i>=PW_BUFF_LEN); i++)
             (i%2 == 0) ? pbBuffer[i] ^= pcSalt[1] : pbBuffer[i] ^= pcSalt[0];             (i%2 == 0) ? pbBuffer[i] ^= pcSalt[1] : pbBuffer[i] ^= pcSalt[0];
Line 471 
Line 409 
     LPUSER_INFO_1 pUserInfo = NULL;     LPUSER_INFO_1 pUserInfo = NULL;
     NET_API_STATUS nStatus = NULL;     NET_API_STATUS nStatus = NULL;
  
     // Make a copy of the specified username, it cannot be used directly because it's      // Make a copy of the specified username, it cannot be used directly
     // declared as const and strchr() may modify the string.      // because it's declared as const and strchr() may modify the string.
     strncpy(tUserName, userName, sizeof(tUserName) - 1);     strncpy(tUserName, userName, sizeof(tUserName) - 1);
     tUserName[sizeof(tUserName)- 1] = '\0';     tUserName[sizeof(tUserName)- 1] = '\0';
  
Line 484 
Line 422 
         strcpy(mUserName, pbs+1);         strcpy(mUserName, pbs+1);
         usingDomain = true;         usingDomain = true;
  
     } else if ((NULL != (pbs = (strchr(tUserName, '@')))) ||      }
       else if ((NULL != (pbs = (strchr(tUserName, '@')))) ||
                (NULL != (pbs = (strchr(tUserName, '.')))))                (NULL != (pbs = (strchr(tUserName, '.')))))
     {     {
         *pbs = '\0';         *pbs = '\0';
Line 492 
Line 431 
         strcpy(mUserName, tUserName);         strcpy(mUserName, tUserName);
         usingDomain = true;         usingDomain = true;
  
     } else      }
       else
     {     {
         strcpy(mDomainName, ".");         strcpy(mDomainName, ".");
         strcpy(mUserName, tUserName);         strcpy(mUserName, tUserName);
     }     }
  
     //convert domain name to unicode     //convert domain name to unicode
     if (!MultiByteToWideChar(CP_ACP, 0, mDomainName, -1, wDomainName, strlen(mDomainName)+1))      if (!MultiByteToWideChar(
               CP_ACP, 0, mDomainName, -1, wDomainName,
               (int)(strlen(mDomainName) + 1)))
     {     {
         return false;         return false;
     }     }
  
     //convert username to unicode     //convert username to unicode
     if (!MultiByteToWideChar(CP_ACP, 0, mUserName, -1, wUserName, strlen(mUserName)+1))      if (!MultiByteToWideChar(
               CP_ACP, 0, mUserName, -1, wUserName, (int)(strlen(mUserName) + 1)))
     {     {
         return false;         return false;
     }     }
Line 516 
Line 459 
         DWORD rc = NetGetDCName(NULL, wDomainName, &pComputerName);         DWORD rc = NetGetDCName(NULL, wDomainName, &pComputerName);
         if (rc == NERR_Success)         if (rc == NERR_Success)
         {         {
             wcscpy(wDomainName, (LPWSTR) pComputerName); //this is automatically prefixed with "\\"              // this is automatically prefixed with "\\"
               wcscpy(wDomainName, (LPWSTR) pComputerName);
         }         }
         /*         /*
         else         else
         {         {
             // failover             // failover
             // ATTN: This is commented out until there is resolution on Bugzilla 2236. -hns 2/2005              // ATTN: This is commented out until there is resolution on
               // Bugzilla 2236. -hns 2/2005
             // This needs to be more thoroughly tested when we uncomment it out.             // This needs to be more thoroughly tested when we uncomment it out.
  
             PDOMAIN_CONTROLLER_INFO DomainControllerInfo = NULL;             PDOMAIN_CONTROLLER_INFO DomainControllerInfo = NULL;
Line 532 
Line 477 
                              mDomainName,                              mDomainName,
                              NULL,                              NULL,
                              NULL,                              NULL,
                              DS_DIRECTORY_SERVICE_REQUIRED,  //not sure what flags we want here                               //not sure what flags we want here
                                DS_DIRECTORY_SERVICE_REQUIRED,
                              &DomainControllerInfo);                              &DomainControllerInfo);
  
             if (rc == ERROR_SUCCESS && DomainControllerInfo)             if (rc == ERROR_SUCCESS && DomainControllerInfo)
Line 540 
Line 486 
                 strcpy(mDomainName, DomainControllerInfo->DomainName);                 strcpy(mDomainName, DomainControllerInfo->DomainName);
                 NetApiBufferFree(DomainControllerInfo);                 NetApiBufferFree(DomainControllerInfo);
  
                 if (!MultiByteToWideChar(CP_ACP, 0, mDomainName, -1, wDomainName, strlen(mDomainName)+1))                  if (!MultiByteToWideChar(
                           CP_ACP, 0, mDomainName, -1, wDomainName,
                           strlen(mDomainName) + 1))
                 {                 {
                     return false;                     return false;
                 }                 }
Line 602 
Line 550 
         strcpy(mUserName, pbs+1);         strcpy(mUserName, pbs+1);
         usingDomain = true;         usingDomain = true;
  
     } else if ((NULL != (pbs = (strchr(userStr, '@')))) ||      }
       else if ((NULL != (pbs = (strchr(userStr, '@')))) ||
                (NULL != (pbs = (strchr(userStr, '.')))))                (NULL != (pbs = (strchr(userStr, '.')))))
     {     {
         *pbs = '\0';         *pbs = '\0';
Line 610 
Line 559 
         strcpy(mUserName, userStr);         strcpy(mUserName, userStr);
         usingDomain = true;         usingDomain = true;
  
     } else      }
       else
     {     {
         strcpy(mDomainName, ".");         strcpy(mDomainName, ".");
         strcpy(mUserName, userStr);         strcpy(mUserName, userStr);
     }     }
  
     //convert domain name to unicode     //convert domain name to unicode
     if (!MultiByteToWideChar(CP_ACP, 0, mDomainName, -1, wDomainName, strlen(mDomainName)+1))      if (!MultiByteToWideChar(
               CP_ACP, 0, mDomainName, -1, wDomainName,
               (int)(strlen(mDomainName) + 1)))
     {     {
         return false;         return false;
     }     }
  
     //convert username to unicode     //convert username to unicode
     if (!MultiByteToWideChar(CP_ACP, 0, mUserName, -1, wUserName, strlen(mUserName)+1))      if (!MultiByteToWideChar(
               CP_ACP, 0, mUserName, -1, wUserName, (int)(strlen(mUserName) + 1)))
     {     {
         return false;         return false;
     }     }
Line 634 
Line 587 
         DWORD rc = NetGetDCName(NULL, wDomainName, &pComputerName);         DWORD rc = NetGetDCName(NULL, wDomainName, &pComputerName);
         if (rc == NERR_Success)         if (rc == NERR_Success)
         {         {
             wcscpy(wDomainName, (LPWSTR) pComputerName); //this is automatically prefixed with "\\"              // this is automatically prefixed with "\\"
               wcscpy(wDomainName, (LPWSTR) pComputerName);
         }         }
         /*         /*
         else         else
         {         {
             // failover             // failover
             // ATTN: This is commented out until there is resolution on Bugzilla 2236. -hns 2/2005              // ATTN: This is commented out until there is resolution on
               // Bugzilla 2236. -hns 2/2005
             // This needs to be more thoroughly tested when we uncomment it out.             // This needs to be more thoroughly tested when we uncomment it out.
  
             PDOMAIN_CONTROLLER_INFO DomainControllerInfo = NULL;             PDOMAIN_CONTROLLER_INFO DomainControllerInfo = NULL;
Line 650 
Line 605 
                              mDomainName,                              mDomainName,
                              NULL,                              NULL,
                              NULL,                              NULL,
                              DS_DIRECTORY_SERVICE_REQUIRED,  //not sure what flags we want here                               // not sure what flags we want here
                                DS_DIRECTORY_SERVICE_REQUIRED,
                              &DomainControllerInfo);                              &DomainControllerInfo);
  
             if (rc == ERROR_SUCCESS && DomainControllerInfo)             if (rc == ERROR_SUCCESS && DomainControllerInfo)
Line 658 
Line 614 
                 strcpy(mDomainName, DomainControllerInfo->DomainName);                 strcpy(mDomainName, DomainControllerInfo->DomainName);
                 NetApiBufferFree(DomainControllerInfo);                 NetApiBufferFree(DomainControllerInfo);
  
                 if (!MultiByteToWideChar(CP_ACP, 0, mDomainName, -1, wDomainName, strlen(mDomainName)+1))                  if (!MultiByteToWideChar(
                           CP_ACP, 0, mDomainName, -1, wDomainName,
                           strlen(mDomainName) + 1))
                 {                 {
                     return false;                     return false;
                 }                 }
Line 698 
Line 656 
     // ATTN-NB-03-20000304: Implement better way to get the privileged     // ATTN-NB-03-20000304: Implement better way to get the privileged
     // user on the system.     // user on the system.
  
     return (String("Administrator"));      return String("Administrator");
 } }
  
 Boolean System::isGroupMember(const char* userName, const char* groupName) Boolean System::isGroupMember(const char* userName, const char* groupName)
Line 712 
Line 670 
     DWORD dwEntriesRead = 0;     DWORD dwEntriesRead = 0;
     DWORD dwTotalEntries = 0;     DWORD dwTotalEntries = 0;
     NET_API_STATUS nStatus;     NET_API_STATUS nStatus;
       wchar_t wcUserName[UNLEN+1];
       wchar_t wcGroupName[UNLEN+1];
  
       //Convert user name to unicode
       if (!MultiByteToWideChar(CP_ACP,0,userName, -1, wcUserName,
           strlen(userName)+1))
       {
           return false;
       }
   
       //Convert group name to unicode
       if (!MultiByteToWideChar(CP_ACP, 0, groupName, -1, wcGroupName,
           strlen(groupName)+1))
       {
           return false;
       }
  
     //     //
     // Call the NetUserGetLocalGroups function     // Call the NetUserGetLocalGroups function
Line 722 
Line 695 
     // function should also return the names of the local     // function should also return the names of the local
     // groups in which the user is indirectly a member.     // groups in which the user is indirectly a member.
     //     //
     nStatus = NetUserGetLocalGroups(NULL,      nStatus = NetUserGetLocalGroups(
                                    (LPCWSTR)userName,          NULL,
           (LPCWSTR)wcUserName,
                                    dwLevel,                                    dwLevel,
                                    dwFlags,                                    dwFlags,
                                    (LPBYTE *) &pBuf,                                    (LPBYTE *) &pBuf,
Line 751 
Line 725 
                 //                 //
                 // Compare the user's group name to groupName.                 // Compare the user's group name to groupName.
                 //                 //
                 if ( strcmp ((char *)pTmpBuf->lgrui0_name, groupName) == 0 )  
                   if (wcscmp(pTmpBuf->lgrui0_name, wcGroupName) == 0)
                 {                 {
                     // User is a member of the group.                     // User is a member of the group.
                     retVal = true;                     retVal = true;
Line 785 
Line 760 
         //         //
         // Call the NetUserGetGroups function, specifying level 0.         // Call the NetUserGetGroups function, specifying level 0.
         //         //
         nStatus = NetUserGetGroups(NULL,          nStatus = NetUserGetGroups(
                                   (LPCWSTR)userName,              NULL,
               (LPCWSTR)wcUserName,
                                   dwLevel,                                   dwLevel,
                                   (LPBYTE*)&pBuf,                                   (LPBYTE*)&pBuf,
                                   dwPrefMaxLen,                                   dwPrefMaxLen,
                                   &dwEntriesRead,                                   &dwEntriesRead,
                                   &dwTotalEntries);                                   &dwTotalEntries);
   
         //         //
         // If the call succeeds,         // If the call succeeds,
         //         //
Line 812 
Line 789 
                     //                     //
                     // Compare the user's group name to groupName.                     // Compare the user's group name to groupName.
                     //                     //
                     if ( strcmp ((char *)pTmpBuf->grui0_name, groupName) == 0 )                      if (wcscmp(pTmpBuf->grui0_name, wcGroupName) == 0)
                     {                     {
                         // User is a member of the group.                         // User is a member of the group.
                         retVal = true;                         retVal = true;
Line 844 
Line 821 
     return false;     return false;
 } }
  
 Boolean System::changeUserContext(  Boolean System::changeUserContext_SingleThreaded(
       const char* userName,
     const PEGASUS_UID_T& uid,     const PEGASUS_UID_T& uid,
     const PEGASUS_GID_T& gid)     const PEGASUS_GID_T& gid)
 { {
Line 867 
Line 845 
     int fd = open(path, O_RDWR);     int fd = open(path, O_RDWR);
     if (fd != -1)     if (fd != -1)
     {     {
         if (chsize(fd, newSize) == 0)          if (chsize(fd, (long)newSize) == 0)
         {         {
             rv = true;             rv = true;
         }         }
Line 892 
Line 870 
       if (*p == '/')       if (*p == '/')
           *p = '\\';           *p = '\\';
  
     return (strcasecmp(_fullpath( full, path_slash, _MAX_PATH ), path_slash) == 0) ? true : false;      return (strcasecmp(
           _fullpath(full, path_slash, _MAX_PATH), path_slash) == 0);
 } }
  
 // Changes file permissions on the given file. // Changes file permissions on the given file.
Line 914 
Line 893 
     // Not implemented     // Not implemented
 } }
  
   void System::openlog(const char *ident, int logopt, int facility)
   {
       // Not implemented
   }
   
   void System::closelog()
   {
       // Not implemented
   }
   
   
   
 // System ID constants for Logger::put and Logger::trace // System ID constants for Logger::put and Logger::trace
 const String System::CIMSERVER = "cimserver";  // Server system ID const String System::CIMSERVER = "cimserver";  // Server system ID
  
   // check if a given IP address is defined on the local network interfaces
   Boolean System::isIpOnNetworkInterface(Uint32 inIP)
   {
       SOCKET sock;
       int interfaces = 0;
       int errcode;
   
       if ( SOCKET_ERROR != ( sock  = WSASocket(AF_INET,
                            SOCK_RAW, 0, NULL, 0, 0) ) )
       {
           unsigned long *bytes_returned=0;
           char *output_buf = (char *)calloc(1, 256);
           int buf_size = 256;
   
           if ( 0 == (errcode = WSAIoctl(sock,
                                         SIO_ADDRESS_LIST_QUERY,
                                         NULL,
                                         0,
                                         output_buf,
                                         256,
                                         bytes_returned,
                                         NULL,
                                         NULL)) )
           {
               SOCKET_ADDRESS_LIST *addr_list;
               SOCKET_ADDRESS *addr;
               Uint32 ip;
               struct sockaddr_in *sin;
   
               addr_list = (SOCKET_ADDRESS_LIST *)output_buf;
               addr = addr_list->Address;
   
               sin = (struct sockaddr_in *)addr->lpSockaddr;
   
               for ( ; interfaces < addr_list->iAddressCount; interfaces++)
               {
                   ip = sin->sin_addr.s_addr;
                   addr++;
                   sin = (struct sockaddr_in *)addr->lpSockaddr;
                   if (ip == inIP)
                   {
                       free(output_buf);
                       closesocket(sock);
                       return true;
                   }
               }
           }
           else
           {
               free(output_buf);
               return false;
           }
           free(output_buf);
           closesocket(sock);
       }
       return false;
   }
   
   #ifdef PEGASUS_ENABLE_IPV6
   void _getInterfaceAddrs(Array<String> &ips, int af)
   {
       SOCKET sock;
   
       if (INVALID_SOCKET != (sock = WSASocket(af, SOCK_RAW,
           0, NULL, 0, 0)))
       {
           DWORD  bytesReturned;
           char buf[2048];
           int interfaces = 0;
           char str[PEGASUS_INET6_ADDRSTR_LEN];
           void *p;
           if (0 == WSAIoctl(sock, SIO_ADDRESS_LIST_QUERY, NULL, 0,
               buf, 2048, &bytesReturned, NULL,
               NULL))
           {
   
               SOCKET_ADDRESS_LIST *addr_list;
               SOCKET_ADDRESS *addr;
               struct sockaddr *sin;
               addr_list = (SOCKET_ADDRESS_LIST *)buf;
               addr = addr_list->Address;
               for (sin = (struct sockaddr *) addr->lpSockaddr ;
                   interfaces < addr_list->iAddressCount;
                   interfaces++)
               {
                   if (af == AF_INET)
                   {
                       p = &((struct sockaddr_in*)sin)->sin_addr;
                   }
                   else
                   {
                       p = &((struct sockaddr_in6*)sin)->sin6_addr;
                   }
                   // Don't gather loopback addrs
                   if (!System::isLoopBack(af, p))
                   {
                       HostAddress::convertBinaryToText(af, p, str, sizeof(str));
                       ips.append(str);
                   }
                   addr++;
                   sin = (struct sockaddr*)addr->lpSockaddr;
               }
           }
       }
   }
   #endif
   
   Array<String> System::getInterfaceAddrs()
   {
       Array<String> ips;
   
   #ifdef PEGASUS_ENABLE_IPV6
       _getInterfaceAddrs(ips, AF_INET);
       _getInterfaceAddrs(ips, AF_INET6);
   #endif
   
       return ips;
   }
   
   String System::getErrorMSG_NLS(int errorCode,int errorCode2)
   {
       LPVOID winErrorMsg = NULL;
   
       if (FormatMessage(
               FORMAT_MESSAGE_ALLOCATE_BUFFER |
               FORMAT_MESSAGE_FROM_SYSTEM |
               FORMAT_MESSAGE_IGNORE_INSERTS,
               NULL,
               errorCode,
               MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
               (LPTSTR)&winErrorMsg,
               0,
               NULL))
       {
           MessageLoaderParms parms(
               "Common.System.ERROR_MESSAGE.STANDARD",
               "$0 (error code $1)",(char*)winErrorMsg,errorCode);
           LocalFree(winErrorMsg);
           return MessageLoader::getMessage(parms);
       }
   
       MessageLoaderParms parms(
           "Common.System.ERROR_MESSAGE.STANDARD",
           "$0 (error code $1)","",errorCode);
       return MessageLoader::getMessage(parms);
   
   }
   
   String System::getErrorMSG(int errorCode,int errorCode2)
   {
   
       String buffer;
       LPVOID winErrorMsg = NULL;
   
       char strErrorCode[32];
       sprintf(strErrorCode, "%d", errorCode);
   
       if (FormatMessage(
               FORMAT_MESSAGE_ALLOCATE_BUFFER |
               FORMAT_MESSAGE_FROM_SYSTEM |
               FORMAT_MESSAGE_IGNORE_INSERTS,
               NULL,
               errorCode,
               MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
               (LPTSTR)&winErrorMsg,
               0,
               NULL))
       {
           buffer.append((char*)winErrorMsg);
           LocalFree(winErrorMsg);
       }
   
       buffer.append(" (error code ");
       buffer.append(strErrorCode);
       buffer.append(")");
   
       return buffer;
   }
   
   
   ///////////////////////////////////////////////////////////////////////////////
   // AutoFileLock class
   ///////////////////////////////////////////////////////////////////////////////
   
   AutoFileLock::AutoFileLock(const char* fileName)
   {
      // Repeat createFile, if there is a sharing violation.
      do
      {
          _hFile = CreateFile (fileName, GENERIC_READ | GENERIC_WRITE, 0, NULL,
              OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
      }while ((GetLastError() == ERROR_SHARING_VIOLATION));
   
      // If this conditon succeeds, There is an error opening the file. Hence
      // returning from here  as Lock can not be acquired.
      if((_hFile == INVALID_HANDLE_VALUE)
          && (GetLastError() != ERROR_ALREADY_EXISTS)
          && (GetLastError() != ERROR_SUCCESS))
      {
          PEG_TRACE((TRC_DISCARDED_DATA, Tracer::LEVEL1,
             "AutoFileLock: Failed to open lock file '%s', error code %d.",
             fileName, GetLastError()));
          return;
      }
   
      OVERLAPPED l={0,0,0,0,0};
      if(LockFileEx(_hFile,LOCKFILE_EXCLUSIVE_LOCK, 0, 0, 0, &l) == 0)
      {
          PEG_TRACE((TRC_DISCARDED_DATA, Tracer::LEVEL1,
              "AutoFileLock: Failed to Acquire lock on file %s, error code %d.",
              fileName, GetLastError()));
          CloseHandle(_hFile);
          _hFile = INVALID_HANDLE_VALUE;
      }
   }
   
   AutoFileLock::~AutoFileLock()
   {
       if(_hFile != INVALID_HANDLE_VALUE)
       {
           OVERLAPPED l={0,0,0,0,0};
           if(UnlockFileEx (_hFile, 0, 0, 0, &l) == 0)
           {
              PEG_TRACE((TRC_DISCARDED_DATA, Tracer::LEVEL2,
                  "AutoFileLock: Failed to unlock file, error code %d.",
                   GetLastError()));
           }
           CloseHandle(_hFile);
       }
   }
   
   
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END

Legend:
Removed from v.1.64  
changed lines
  Added in v.1.84
No CVS admin address has been configured
 Powered by
ViewCVS 0.9.2