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

Diff for /pegasus/src/Pegasus/Common/FileSystem.cpp between version 1.48 and 1.87

version 1.48, 2004/03/16 23:05:00 version 1.87, 2012/12/13 14:38:55
Line 1 
Line 1 
 //%2003////////////////////////////////////////////////////////////////////////  //%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
 //  // Source License; you may not use this file except in compliance with the
 // Permission is hereby granted, free of charge, to any person obtaining a copy  // License.
 // of this software and associated documentation files (the "Software"), to  //
 // deal in the Software without restriction, including without limitation the  // Permission is hereby granted, free of charge, to any person obtaining a
 // rights to use, copy, modify, merge, publish, distribute, sublicense, and/or  // copy of this software and associated documentation files (the "Software"),
 // sell copies of the Software, and to permit persons to whom the Software is  // to deal in the Software without restriction, including without limitation
 // furnished to do so, subject to the following conditions:  // the rights to use, copy, modify, merge, publish, distribute, sublicense,
 //  // and/or sell copies of the Software, and to permit persons to whom the
 // THE ABOVE COPYRIGHT NOTICE AND THIS PERMISSION NOTICE SHALL BE INCLUDED IN  // Software is furnished to do so, subject to the following conditions:
 // 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  // The above copyright notice and this permission notice shall be included
 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR  // in all copies or substantial portions of the Software.
 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT  //
 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN  // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION  // OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.  // 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:  
 //         Ramnath Ravindran(Ramnath.Ravindran@compaq.com)  
 // //
 //%///////////////////////////////////////////////////////////////////////////// //%/////////////////////////////////////////////////////////////////////////////
  
 #include <iostream> #include <iostream>
 //#include <cstdio>  
 #include <Pegasus/Common/Config.h> #include <Pegasus/Common/Config.h>
 #include <Pegasus/Common/System.h> #include <Pegasus/Common/System.h>
 #include "Destroyer.h"  #include <Pegasus/Common/AutoPtr.h>
   #include <Executor/Match.h>
 #include "FileSystem.h" #include "FileSystem.h"
 #include "Dir.h" #include "Dir.h"
   #ifndef PEGASUS_OS_TYPE_WINDOWS
   #include <pwd.h>
   #endif
   #include <Pegasus/Common/Tracer.h>
  
 PEGASUS_NAMESPACE_BEGIN PEGASUS_NAMESPACE_BEGIN
  
Line 71 
Line 74 
  
 Boolean FileSystem::existsNoCase(const String& path, String& realPath) Boolean FileSystem::existsNoCase(const String& path, String& realPath)
 { {
 #ifdef PEGASUS_OS_OS400  #if !defined(PEGASUS_OS_VMS) && \
     // The OS/400 file system is case insensitive, so just call exists( ).      !defined(PEGASUS_OS_TYPE_WINDOWS) && \
     // This is faster, but the main reason to do this is to      !defined(PEGASUS_OS_DARWIN)
     // avoid multi-threading problems with the IFS directory APIs  
     // (even though they claim to be threadsafe).      // If a file exists that has the same case as the path parmater,
       // then we can bypass the expensive directory scanning below.
   
       if (FileSystem::exists(path))
       {
     realPath = path;     realPath = path;
     return exists(path);          return true;
 #else      }
   
   #endif
   
     realPath.clear();     realPath.clear();
     CString cpath = _clonePath(path);     CString cpath = _clonePath(path);
     const char* p = cpath;     const char* p = cpath;
Line 120 
Line 130 
     }     }
  
     return false;     return false;
 #endif  
 } }
  
 Boolean FileSystem::canRead(const String& path) Boolean FileSystem::canRead(const String& path)
Line 144 
Line 153 
 } }
  
 void FileSystem::loadFileToMemory( void FileSystem::loadFileToMemory(
     Array<Sint8>& array,      Buffer& array,
     const String& fileName)     const String& fileName)
 { {
     Uint32 fileSize;     Uint32 fileSize;
Line 162 
Line 171 
     size_t n;     size_t n;
  
     while ((n = fread(buffer, 1, sizeof(buffer), fp)) > 0)     while ((n = fread(buffer, 1, sizeof(buffer), fp)) > 0)
         array.append(buffer, n);          array.append(buffer, static_cast<Uint32>(n));
  
     fclose(fp);     fclose(fp);
 } }
Line 253 
Line 262 
 #if defined(__GNUC__) && GCC_VERSION >= 30200 #if defined(__GNUC__) && GCC_VERSION >= 30200
     fs.open(_clonePath(realPath), PEGASUS_STD(ios_base::openmode)(mode));     fs.open(_clonePath(realPath), PEGASUS_STD(ios_base::openmode)(mode));
 #else #else
 #if defined(PEGASUS_OS_OS400)  
     fs.open(_clonePath(realPath), mode, PEGASUS_STD(_CCSID_T(1208)) );  
 #else  
     fs.open(_clonePath(realPath), mode);     fs.open(_clonePath(realPath), mode);
 #endif #endif
 #endif  
     return !!fs;     return !!fs;
 } }
  
Line 379 
Line 384 
 // Return the just the base name from the path. // Return the just the base name from the path.
 String  FileSystem::extractFileName(const String& path) String  FileSystem::extractFileName(const String& path)
 { {
   char *p_path = new char[path.size() + 1];      AutoArrayPtr<char> p_path(new char[path.size() + 1]);
   String basename = System::extract_file_name((const char *)path.getCString(), p_path);      String basename = System::extract_file_name(
           (const char*)path.getCString(), p_path.get());
   delete [] p_path;  
  
   return basename;   return basename;
 } }
Line 390 
Line 394 
 // Return just the path to the file or directory into path // Return just the path to the file or directory into path
 String FileSystem::extractFilePath(const String& path) String FileSystem::extractFilePath(const String& path)
 { {
   char *p_path = new char[path.size() + 1];      AutoArrayPtr<char> p_path(new char[path.size() + 1]);
   String newpath = System::extract_file_path((const char *)path.getCString(), p_path);      String newpath = System::extract_file_path(
           (const char*)path.getCString(), p_path.get());
   delete [] p_path;  
  
   return newpath;   return newpath;
 } }
Line 401 
Line 404 
 // Changes file permissions on the given file. // Changes file permissions on the given file.
 Boolean FileSystem::changeFilePermissions(const String& path, mode_t mode) Boolean FileSystem::changeFilePermissions(const String& path, mode_t mode)
 { {
 #if defined(PEGASUS_OS_OS400)  
     // ATTN: If getCString() is modified to return UTF8, then handle the  
     //       EBCDIC coversion in SystemUnix.cpp  
     CString tempPath = path.getCString();     CString tempPath = path.getCString();
 #else  
     CString tempPath = path.getCStringUTF8();  
 #endif  
  
     return System::changeFilePermissions(tempPath, mode);     return System::changeFilePermissions(tempPath, mode);
 } }
  
 String FileSystem::getAbsoluteFileName(const String &paths, const String &filename) {  String FileSystem::getAbsoluteFileName(
       const String& paths,
       const String& filename)
   {
   Uint32 pos =0;   Uint32 pos =0;
   Uint32 token=0;   Uint32 token=0;
   String path = String::EMPTY;      String path;
   String root = String::EMPTY;      String root;
   String tempPath = paths;   String tempPath = paths;
   do {  
     if (( pos = tempPath.find(FileSystem::getPathDelimiter())) == PEG_NOT_FOUND) {      do
       {
           if ((pos = tempPath.find(FileSystem::getPathDelimiter())) ==
               PEG_NOT_FOUND)
           {
                 pos = tempPath.size();                 pos = tempPath.size();
                 token = 0;                 token = 0;
         }         }
         else {          else
           {
                 token = 1;                 token = 1;
         }         }
         path = tempPath.subString(0, pos);         path = tempPath.subString(0, pos);
         tempPath.remove(0,pos+token);         tempPath.remove(0,pos+token);
         if (FileSystem::exists( path + "/" + filename ) == true) {          if (FileSystem::exists(path + "/" + filename) == true)
           {
           root = path + "/" + filename;           root = path + "/" + filename;
           break;           break;
         } else          }
           else
           {           {
           //  cout << "File does not exist.\n";           //  cout << "File does not exist.\n";
           }           }
   } while (tempPath.size() > 0);   } while (tempPath.size() > 0);
   
   return root;   return root;
 } }
  
   String FileSystem::buildLibraryFileName(const String &libraryName)
   {
       String fileName;
   
       //
       // Add the necessary prefix and suffix to convert the library name to its
       // corresponding file name.
       //
   #if defined(PEGASUS_OS_TYPE_WINDOWS)
       fileName = libraryName + String(".dll");
   #else
       fileName = String("lib") + libraryName + getDynamicLibraryExtension();
   #endif
       return fileName;
   }
  
 Boolean GetLine(PEGASUS_STD(istream)& is, String& line)  String FileSystem::getDynamicLibraryExtension()
 { {
     line.clear();  #if defined(PEGASUS_OS_TYPE_WINDOWS)
       return String(".dll");
   #elif defined(PEGASUS_PLATFORM_HPUX_PARISC_ACC) || \
       defined (PEGASUS_PLATFORM_HPUX_PARISC_GNU)
       return String(".sl");
   #elif defined(PEGASUS_OS_DARWIN)
       return String(".dylib");
   #elif defined(PEGASUS_OS_VMS)
       return String(".exe");
   #elif defined(PEGASUS_PLATFORM_ZOS_ZSERIES64_IBM)
       return String("64.so");
   #else
       return String(".so");
   #endif
   }
   
   Boolean GetLine(PEGASUS_STD(istream)& is, Buffer& line)
   {
       const Uint32 buffersize = 1024;
       Uint32 gcount = 0;
  
     Boolean gotChar = false;      line.clear();
     char c;  
  
     while (is.get(c))      // Read the input line in chunks.  A non-full buffer indicates the end of
       // the line has been reached.
       do
     {     {
         gotChar = true;          char input[buffersize];
   
           // This reads up to buffersize-1 char, but stops before consuming
           // a newline character ('\n').
           is.get(input, buffersize);
   
           gcount = (Uint32)is.gcount();
           line.append(input, gcount);
  
         if (c == '\n')          if (is.rdstate() & PEGASUS_STD(istream)::failbit)
           {
               // It is okay if we encounter the newline character without reading
               // data.
               is.clear();
             break;             break;
           }
       } while (gcount == buffersize-1);
   
       if (!is.eof())
       {
           // we need to consume the '\n', because get() doesn't
           char c = 0;
           is.get(c);
       }
   
       return !!is;
   }
   
   //
   // changes the file owner to one specified
   //
   Boolean FileSystem::changeFileOwner(
       const String& fileName,
       const String& userName)
   {
   #if defined(PEGASUS_OS_TYPE_WINDOWS)
   
       return true;
   
   #else
   
       PEG_METHOD_ENTER(TRC_AUTHENTICATION, "FileSystem::changeFileOwner()");
   
       struct passwd* userPasswd;
   #if defined(PEGASUS_OS_SOLARIS) || \
       defined(PEGASUS_OS_HPUX) || \
       defined(PEGASUS_OS_LINUX) || \
       defined (PEGASUS_OS_VMS) || \
       defined (PEGASUS_OS_AIX)
   
       const unsigned int PWD_BUFF_SIZE = 1024;
       struct passwd pwd;
       char pwdBuffer[PWD_BUFF_SIZE];
   
       if (getpwnam_r(userName.getCString(), &pwd, pwdBuffer, PWD_BUFF_SIZE,
                     &userPasswd) != 0)
       {
           userPasswd = (struct passwd*)NULL;
       }
   
   #else
   
       userPasswd = getpwnam(userName.getCString());
   #endif
   
       if (userPasswd  == NULL)
       {
           PEG_METHOD_EXIT();
           return false;
       }
   
       Sint32 ret = chown(
           fileName.getCString(), userPasswd->pw_uid, userPasswd->pw_gid);
   
       if (ret == -1)
       {
           PEG_METHOD_EXIT();
           return false;
       }
   
       PEG_METHOD_EXIT();
   
       return true;
   #endif
   }
   
   #if defined(PEGASUS_OS_HPUX)
   void FileSystem::syncWithDirectoryUpdates(PEGASUS_STD(fstream)& fs)
   {
     #if defined (PEGASUS_PLATFORM_HPUX_IA64_GNU) || \
       defined (PEGASUS_PLATFORM_HPUX_PARISC_GNU)
       // Writes the data from the iostream buffers to the OS buffers
       fs.flush();
       // Writes the data from the OS buffers to the disk
       fs.rdbuf()->pubsync();
       #else
       // Writes the data from the iostream buffers to the OS buffers
       fs.flush();
       // Writes the data from the OS buffers to the disk
       fsync(fs.rdbuf()->fd());
       #endif
   }
   #else
   void FileSystem::syncWithDirectoryUpdates(PEGASUS_STD(fstream)&)
   {
       //Not HP-UX, do nothing (compiler will remove this fct on optimization)
   }
   #endif
   
   Boolean FileSystem::glob(
       const String& path,
       const String& pattern_,
       Array<String>& filenames)
   {
       filenames.clear();
   
       try
       {
           CString pattern(pattern_.getCString());
   
           for (Dir dir(path); dir.more(); dir.next())
           {
               const char* name = dir.getName();
   
               if (strcmp(name, ".") == 0 || strcmp(name, "..") == 0)
                   continue;
  
         line.append(c);              if (Match(pattern, name) == 0)
                   filenames.append(name);
           }
       }
       catch (CannotOpenDirectory&)
       {
           return false;
     }     }
  
     return gotChar;      return true;
 } }
  
 PEGASUS_NAMESPACE_END PEGASUS_NAMESPACE_END


Legend:
Removed from v.1.48  
changed lines
  Added in v.1.87

No CVS admin address has been configured
Powered by
ViewCVS 0.9.2