Adding upstream version 1.8.2.3.upstream/1.8.2.3upstream

Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>

1 files changed, 151 insertions, 0 deletions

diff --git a/apt-pkg/clean.cc b/apt-pkg/clean.cc
new file mode 100644
index 0000000..f335554
--- /dev/null
+++ b/apt-pkg/clean.cc
@@ -0,0 +1,151 @@
+// -*- mode: cpp; mode: fold -*-
+// Description								/*{{{*/
+/* ######################################################################
+
+   Clean - Clean out downloaded directories
+   
+   ##################################################################### */
+									/*}}}*/
+// Includes								/*{{{*/
+#include <config.h>
+
+#include <apt-pkg/aptconfiguration.h>
+#include <apt-pkg/clean.h>
+#include <apt-pkg/configuration.h>
+#include <apt-pkg/error.h>
+#include <apt-pkg/fileutl.h>
+#include <apt-pkg/pkgcache.h>
+#include <apt-pkg/strutl.h>
+
+#include <string>
+#include <dirent.h>
+#include <fcntl.h>
+#include <string.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+#include <unistd.h>
+
+#include <apti18n.h>
+									/*}}}*/
+// ArchiveCleaner::Go - Perform smart cleanup of the archive		/*{{{*/
+// ---------------------------------------------------------------------
+/* Scan the directory for files to erase, we check the version information
+   against our database to see if it is interesting */
+bool pkgArchiveCleaner::Go(std::string Dir,pkgCache &Cache)
+{
+   bool CleanInstalled = _config->FindB("APT::Clean-Installed",true);
+
+   if(Dir == "/")
+      return _error->Error(_("Clean of %s is not supported"), Dir.c_str());
+
+   // non-existing directories are always clean
+   // we do not check for a directory explicitly to support symlinks
+   if (FileExists(Dir) == false)
+      return true;
+
+   auto const withoutChangingDir = dynamic_cast<pkgArchiveCleaner2*>(this);
+   int const dirfd = open(Dir.c_str(), O_RDONLY | O_DIRECTORY | O_CLOEXEC);
+   if (dirfd == -1)
+      return _error->Errno("open",_("Unable to read %s"),Dir.c_str());
+   std::string CWD;
+   if (withoutChangingDir == nullptr)
+   {
+      CWD = SafeGetCWD();
+      if (fchdir(dirfd) != 0)
+	 return _error->Errno("fchdir",_("Unable to change to %s"),Dir.c_str());
+   }
+   DIR * const D = fdopendir(dirfd);
+   if (D == nullptr)
+      return _error->Errno("opendir",_("Unable to read %s"),Dir.c_str());
+
+   for (struct dirent *Dir = readdir(D); Dir != 0; Dir = readdir(D))
+   {
+      // Skip some files..
+      if (strcmp(Dir->d_name, "lock") == 0 ||
+	  strcmp(Dir->d_name, "partial") == 0 ||
+	  strcmp(Dir->d_name, "auxfiles") == 0 ||
+	  strcmp(Dir->d_name, "lost+found") == 0 ||
+	  strcmp(Dir->d_name, ".") == 0 ||
+	  strcmp(Dir->d_name, "..") == 0)
+	 continue;
+
+      struct stat St;
+      if (fstatat(dirfd, Dir->d_name,&St, 0) != 0)
+      {
+	 _error->Errno("stat",_("Unable to stat %s."),Dir->d_name);
+	 closedir(D);
+	 return false;
+      }
+
+      // Grab the package name
+      const char *I = Dir->d_name;
+      for (; *I != 0 && *I != '_';I++);
+      if (*I != '_')
+	 continue;
+      std::string Pkg = DeQuoteString(std::string(Dir->d_name,I-Dir->d_name));
+
+      // Grab the version
+      const char *Start = I + 1;
+      for (I = Start; *I != 0 && *I != '_';I++);
+      if (*I != '_')
+	 continue;
+      std::string Ver = DeQuoteString(std::string(Start,I-Start));
+
+      // Grab the arch
+      Start = I + 1;
+      for (I = Start; *I != 0 && *I != '.' ;I++);
+      if (*I != '.')
+	 continue;
+      std::string const Arch = DeQuoteString(std::string(Start,I-Start));
+
+      // ignore packages of unconfigured architectures
+      if (APT::Configuration::checkArchitecture(Arch) == false)
+	 continue;
+
+      // Lookup the package
+      pkgCache::PkgIterator P = Cache.FindPkg(Pkg, Arch);
+      if (P.end() != true)
+      {
+	 pkgCache::VerIterator V = P.VersionList();
+	 for (; V.end() == false; ++V)
+	 {
+	    // See if we can fetch this version at all
+	    bool IsFetchable = false;
+	    for (pkgCache::VerFileIterator J = V.FileList(); 
+		 J.end() == false; ++J)
+	    {
+	       if (CleanInstalled == true &&
+		   J.File().Flagged(pkgCache::Flag::NotSource))
+		  continue;
+	       IsFetchable = true;
+	       break;
+	    }
+
+	    // See if this version matches the file
+	    if (IsFetchable == true && Ver == V.VerStr())
+	       break;
+	 }
+
+	 // We found a match, keep the file
+	 if (V.end() == false)
+	    continue;
+      }
+
+      if (withoutChangingDir == nullptr)
+      {
+	 APT_IGNORE_DEPRECATED_PUSH
+	 Erase(Dir->d_name, Pkg, Ver, St);
+	 APT_IGNORE_DEPRECATED_POP
+      }
+      else
+	 withoutChangingDir->Erase(dirfd, Dir->d_name, Pkg, Ver, St);
+   }
+   closedir(D);
+   if (withoutChangingDir == nullptr && chdir(CWD.c_str()) != 0)
+      return _error->Errno("chdir", _("Unable to change to %s"),Dir.c_str());
+   return true;
+}
+									/*}}}*/
+
+pkgArchiveCleaner::pkgArchiveCleaner() : d(NULL) {}
+pkgArchiveCleaner::~pkgArchiveCleaner() {}