X-Git-Url: https://git.saurik.com/apt.git/blobdiff_plain/6c139d6e362f04a1582e8a8f511f8aeab031fecf..de3c15eac1431a50c71a557257adb42105ade1d9:/apt-pkg/contrib/fileutl.cc diff --git a/apt-pkg/contrib/fileutl.cc b/apt-pkg/contrib/fileutl.cc index 29b12bef1..6baafcfcf 100644 --- a/apt-pkg/contrib/fileutl.cc +++ b/apt-pkg/contrib/fileutl.cc @@ -1,6 +1,6 @@ // -*- mode: cpp; mode: fold -*- // Description /*{{{*/ -// $Id: fileutl.cc,v 1.3 1998/07/07 04:17:12 jgg Exp $ +// $Id: fileutl.cc,v 1.18 1999/02/03 23:13:37 jgg Exp $ /* ###################################################################### File Utilities @@ -15,10 +15,10 @@ /*}}}*/ // Include Files /*{{{*/ #ifdef __GNUG__ -#pragma implementation "pkglib/fileutl.h" +#pragma implementation "apt-pkg/fileutl.h" #endif -#include -#include +#include +#include #include #include @@ -29,7 +29,7 @@ // CopyFile - Buffered copy of a file /*{{{*/ // --------------------------------------------------------------------- /* The caller is expected to set things so that failure causes erasure */ -bool CopyFile(File From,File To) +bool CopyFile(FileFd &From,FileFd &To) { if (From.IsOpen() == false || To.IsOpen() == false) return false; @@ -68,10 +68,10 @@ int GetLock(string File,bool Errors) // Aquire a write lock struct flock fl; - fl.l_type= F_WRLCK; - fl.l_whence= SEEK_SET; - fl.l_start= 0; - fl.l_len= 1; + fl.l_type = F_WRLCK; + fl.l_whence = SEEK_SET; + fl.l_start = 0; + fl.l_len = 0; if (fcntl(FD,F_SETLK,&fl) == -1) { if (Errors == true) @@ -102,18 +102,86 @@ string SafeGetCWD() // Stash the current dir. char S[300]; S[0] = 0; - if (getcwd(S,sizeof(S)) == 0) + if (getcwd(S,sizeof(S)-2) == 0) return "/"; + unsigned int Len = strlen(S); + S[Len] = '/'; + S[Len+1] = 0; return S; } /*}}}*/ +// flNotDir - Strip the directory from the filename /*{{{*/ +// --------------------------------------------------------------------- +/* */ +string flNotDir(string File) +{ + string::size_type Res = File.rfind('/'); + if (Res == string::npos) + return File; + Res++; + return string(File,Res,Res - File.length()); +} + /*}}}*/ +// flNotFile - Strip the file from the directory name /*{{{*/ +// --------------------------------------------------------------------- +/* */ +string flNotFile(string File) +{ + string::size_type Res = File.rfind('/'); + if (Res == string::npos) + return File; + Res++; + return string(File,0,Res); +} + /*}}}*/ +// SetCloseExec - Set the close on exec flag /*{{{*/ +// --------------------------------------------------------------------- +/* */ +void SetCloseExec(int Fd,bool Close) +{ + if (fcntl(Fd,F_SETFD,(Close == false)?0:FD_CLOEXEC) != 0) + { + cerr << "FATAL -> Could not set close on exec " << strerror(errno) << endl; + exit(100); + } +} + /*}}}*/ +// SetNonBlock - Set the nonblocking flag /*{{{*/ +// --------------------------------------------------------------------- +/* */ +void SetNonBlock(int Fd,bool Block) +{ + int Flags = fcntl(Fd,F_GETFL) & (~O_NONBLOCK); + if (fcntl(Fd,F_SETFL,Flags | ((Block == false)?0:O_NONBLOCK)) != 0) + { + cerr << "FATAL -> Could not set non-blocking flag " << strerror(errno) << endl; + exit(100); + } +} + /*}}}*/ +// WaitFd - Wait for a FD to become readable /*{{{*/ +// --------------------------------------------------------------------- +/* This waits for a FD to become readable using select. It is usefull for + applications making use of non-blocking sockets. */ +bool WaitFd(int Fd) +{ + fd_set Set; + FD_ZERO(&Set); + FD_SET(Fd,&Set); + + if (select(Fd+1,&Set,0,0,0) <= 0) + return false; -// File::File - Open a file /*{{{*/ + return true; +} + /*}}}*/ + +// FileFd::FileFd - Open a file /*{{{*/ // --------------------------------------------------------------------- /* The most commonly used open mode combinations are given with Mode */ -File::File(string FileName,OpenMode Mode, unsigned long Perms) +FileFd::FileFd(string FileName,OpenMode Mode, unsigned long Perms) { - Flags = 0; + Flags = AutoClose; switch (Mode) { case ReadOnly: @@ -121,34 +189,45 @@ File::File(string FileName,OpenMode Mode, unsigned long Perms) break; case WriteEmpty: - unlink(FileName.c_str()); - iFd = open(FileName.c_str(),O_RDWR | O_CREAT | O_EXCL,Perms); - break; + { + struct stat Buf; + if (stat(FileName.c_str(),&Buf) == 0 && S_ISLNK(Buf.st_mode)) + unlink(FileName.c_str()); + iFd = open(FileName.c_str(),O_RDWR | O_CREAT | O_TRUNC,Perms); + break; + } case WriteExists: iFd = open(FileName.c_str(),O_RDWR); break; + + case WriteAny: + iFd = open(FileName.c_str(),O_RDWR | O_CREAT,Perms); + break; } if (iFd < 0) _error->Errno("open","Could not open file %s",FileName.c_str()); else + { this->FileName = FileName; + SetCloseExec(iFd,true); + } } /*}}}*/ -// File::~File - Closes the file /*{{{*/ +// FileFd::~File - Closes the file /*{{{*/ // --------------------------------------------------------------------- /* If the proper modes are selected then we close the Fd and possibly unlink the file on error. */ -File::~File() +FileFd::~FileFd() { Close(); } /*}}}*/ -// File::Read - Read a bit of the file /*{{{*/ +// FileFd::Read - Read a bit of the file /*{{{*/ // --------------------------------------------------------------------- /* */ -bool File::Read(void *To,unsigned long Size) +bool FileFd::Read(void *To,unsigned long Size) { if (read(iFd,To,Size) != (signed)Size) { @@ -159,10 +238,10 @@ bool File::Read(void *To,unsigned long Size) return true; } /*}}}*/ -// File::Write - Write to the file /*{{{*/ +// FileFd::Write - Write to the file /*{{{*/ // --------------------------------------------------------------------- /* */ -bool File::Write(void *From,unsigned long Size) +bool FileFd::Write(const void *From,unsigned long Size) { if (write(iFd,From,Size) != (signed)Size) { @@ -173,10 +252,10 @@ bool File::Write(void *From,unsigned long Size) return true; } /*}}}*/ -// File::Seek - Seek in the file /*{{{*/ +// FileFd::Seek - Seek in the file /*{{{*/ // --------------------------------------------------------------------- /* */ -bool File::Seek(unsigned long To) +bool FileFd::Seek(unsigned long To) { if (lseek(iFd,To,SEEK_SET) != (signed)To) { @@ -187,10 +266,21 @@ bool File::Seek(unsigned long To) return true; } /*}}}*/ -// File::Size - Return the size of the file /*{{{*/ +// FileFd::Tell - Current seek position /*{{{*/ // --------------------------------------------------------------------- /* */ -unsigned long File::Size() +unsigned long FileFd::Tell() +{ + off_t Res = lseek(iFd,0,SEEK_CUR); + if (Res == (off_t)-1) + _error->Errno("lseek","Failed to determine the current file position"); + return Res; +} + /*}}}*/ +// FileFd::Size - Return the size of the file /*{{{*/ +// --------------------------------------------------------------------- +/* */ +unsigned long FileFd::Size() { struct stat Buf; if (fstat(iFd,&Buf) != 0) @@ -198,16 +288,17 @@ unsigned long File::Size() return Buf.st_size; } /*}}}*/ -// File::Close - Close the file if the close flag is set /*{{{*/ +// FileFd::Close - Close the file if the close flag is set /*{{{*/ // --------------------------------------------------------------------- /* */ -bool File::Close() +bool FileFd::Close() { bool Res = true; if ((Flags & AutoClose) == AutoClose) - if (close(iFd) != 0) + if (iFd >= 0 && close(iFd) != 0) Res &= _error->Errno("close","Problem closing the file"); - + iFd = -1; + if ((Flags & Fail) == Fail && (Flags & DelOnFail) == DelOnFail && FileName.empty() == false) if (unlink(FileName.c_str()) != 0)