methods/copy.cc

   1 // -*- mode: cpp; mode: fold -*-
   2 // Description                                                          /*{{{*/
   3 // $Id: copy.cc,v 1.7.2.1 2004/01/16 18:58:50 mdz Exp $
   4 /* ######################################################################
   5
   6    Copy URI - This method takes a uri like a file: uri and copies it
   7    to the destination file.
   8
   9    ##################################################################### */
  10                                                                         /*}}}*/
  11 // Include Files                                                        /*{{{*/
  12 #include <config.h>
  13
  14 #include <apt-pkg/fileutl.h>
  15 #include <apt-pkg/strutl.h>
  16 #include <apt-pkg/acquire-method.h>
  17 #include <apt-pkg/error.h>
  18 #include <apt-pkg/hashes.h>
  19 #include <apt-pkg/configuration.h>
  20
  21 #include <string>
  22 #include <sys/stat.h>
  23 #include <sys/time.h>
  24
  25 #include <apti18n.h>
  26                                                                         /*}}}*/
  27
  28 class CopyMethod : public pkgAcqMethod
  29 {
  30    virtual bool Fetch(FetchItem *Itm);
  31    void CalculateHashes(FetchResult &Res);
  32
  33    public:
  34
  35    CopyMethod() : pkgAcqMethod("1.0",SingleInstance | SendConfig) {};
  36 };
  37
  38 void CopyMethod::CalculateHashes(FetchResult &Res)
  39 {
  40    Hashes Hash;
  41    FileFd::CompressMode CompressMode = FileFd::None;
  42    if (_config->FindB("Acquire::GzipIndexes", false) == true)
  43       CompressMode = FileFd::Extension;
  44
  45    FileFd Fd(Res.Filename, FileFd::ReadOnly, CompressMode);
  46    Hash.AddFD(Fd);
  47    Res.TakeHashes(Hash);
  48 }
  49
  50 // CopyMethod::Fetch - Fetch a file                                     /*{{{*/
  51 // ---------------------------------------------------------------------
  52 /* */
  53 bool CopyMethod::Fetch(FetchItem *Itm)
  54 {
  55    // this ensures that relative paths work in copy
  56    std::string File = Itm->Uri.substr(Itm->Uri.find(':')+1);
  57
  58    // Stat the file and send a start message
  59    struct stat Buf;
  60    if (stat(File.c_str(),&Buf) != 0)
  61       return _error->Errno("stat",_("Failed to stat"));
  62
  63    // Forumulate a result and send a start message
  64    FetchResult Res;
  65    Res.Size = Buf.st_size;
  66    Res.Filename = Itm->DestFile;
  67    Res.LastModified = Buf.st_mtime;
  68    Res.IMSHit = false;
  69    URIStart(Res);
  70
  71    // when the files are identical, just compute the hashes
  72    if(File == Itm->DestFile)
  73    {
  74       CalculateHashes(Res);
  75       URIDone(Res);
  76       return true;
  77    }
  78
  79    // just calc the hashes if the source and destination are identical
  80    if (File == Itm->DestFile)
  81    {
  82       CalculateHashes(Res);
  83       URIDone(Res);
  84       return true;
  85    }
  86
  87    // See if the file exists
  88    FileFd From(File,FileFd::ReadOnly);
  89    FileFd To(Itm->DestFile,FileFd::WriteAtomic);
  90    To.EraseOnFailure();
  91    if (_error->PendingError() == true)
  92    {
  93       To.OpFail();
  94       return false;
  95    }
  96
  97    // Copy the file
  98    if (CopyFile(From,To) == false)
  99    {
 100       To.OpFail();
 101       return false;
 102    }
 103
 104    From.Close();
 105    To.Close();
 106
 107    // Transfer the modification times
 108    struct timeval times[2];
 109    times[0].tv_sec = Buf.st_atime;
 110    times[1].tv_sec = Buf.st_mtime;
 111    times[0].tv_usec = times[1].tv_usec = 0;
 112    if (utimes(Res.Filename.c_str(), times) != 0)
 113       return _error->Errno("utimes",_("Failed to set modification time"));
 114
 115    CalculateHashes(Res);
 116
 117    URIDone(Res);
 118    return true;
 119 }
 120                                                                         /*}}}*/
 121
 122 int main()
 123 {
 124    setlocale(LC_ALL, "");
 125
 126    CopyMethod Mth;
 127
 128    return Mth.Run();
 129 }