From 9e86f072f214e32b75b7c8cef89ec759c981378d Mon Sep 17 00:00:00 2001
From: Ishan Jayawardena <udeshike@gmail.com>
Date: Fri, 22 Jul 2011 00:02:42 +0530
Subject: Modified debdelta to use ExecFork() ExecWait() instead of fork() and
 waitpid().

---
 apt-pkg/acquire-item.cc |  3 ++-
 cmdline/apt-get.cc      |  2 +-
 methods/debdelta.cc     | 39 +++++++++++++++++----------------------
 3 files changed, 20 insertions(+), 24 deletions(-)

diff --git a/apt-pkg/acquire-item.cc b/apt-pkg/acquire-item.cc
index 0f7f7c00e..e81906714 100644
--- a/apt-pkg/acquire-item.cc
+++ b/apt-pkg/acquire-item.cc
@@ -2080,7 +2080,7 @@ pkgAcqDebdelta::pkgAcqDebdelta(pkgAcquire *Owner,pkgSourceList *Sources,
       + string(Version.ParentPkg().CandVersion()) + "_"
       + string(Version.Arch()) + ".debdelta";
    Retries = _config->FindI("Acquire::Retries",0);
-   Debug = true;
+   Debug = false;
    if (Version.Arch() == 0)
    {
       _error->Error(_("I wasn't able to locate a file for the %s package. "
@@ -2385,6 +2385,7 @@ bool IndexTarget::IsOptional() const {
       return false;
    return true;
 }
+
 bool IndexTarget::IsSubIndex() const {
    if (ShortDesc != "TranslationIndex")
       return false;
diff --git a/cmdline/apt-get.cc b/cmdline/apt-get.cc
index 3292ae745..61caa45cf 100644
--- a/cmdline/apt-get.cc
+++ b/cmdline/apt-get.cc
@@ -3310,7 +3310,7 @@ int main(int argc,const char *argv[])					/*{{{*/
       _error->DumpErrors();
       return 100;
    }
-
+   //_config->Dump();
    // See if the help should be shown
    if (_config->FindB("help") == true ||
        _config->FindB("version") == true ||
diff --git a/methods/debdelta.cc b/methods/debdelta.cc
index a8438a8e5..421829e79 100644
--- a/methods/debdelta.cc
+++ b/methods/debdelta.cc
@@ -48,7 +48,7 @@ bool DebdeltaMethod::Fetch(FetchItem *Itm)						/*{{{*/
    //URIDone(ResTest);
    //return true; 
    ///
-   Debug = true; //_config->FindB("Debug::pkgAcquire::Debdelta", false);
+   Debug = _config->FindB("Debug::pkgAcquire::Debdelta", false);
    FromFile = Itm->DestFile;
    URI U(Itm->Uri);
    DebdeltaFile = U.Path;
@@ -71,7 +71,11 @@ bool DebdeltaMethod::Fetch(FetchItem *Itm)						/*{{{*/
    int Fd[2];
    if (pipe(Fd) != 0)
       return _error->Error("[Debdelta] Could not create the pipe.");
-   pid_t Process = fork();
+   _config->Set("APT::Keep-Fds", Fd[0]);
+   _config->Set("APT::Keep-Fds", Fd[1]);
+   pid_t Process = ExecFork();
+   _config->Clear("APT::Keep-Fds", Fd[0]);
+   _config->Clear("APT::Keep-Fds", Fd[1]);
    if (Process == 0)
    {
       // redirect debpatch's stdout,stderr to the pipe 
@@ -81,14 +85,15 @@ bool DebdeltaMethod::Fetch(FetchItem *Itm)						/*{{{*/
       close(2);
       dup(Fd[1]);
       // make the debpatch command and run it.
+      int n = 0;
       const char* Args[6] = {0};
-      Args[0] = "/usr/bin/debpatch";
+      Args[n++] = "/usr/bin/debpatch";
       if (!FileExists(Args[0]))
 	 return _error->Error("[Debdelta] Could not find debpatch.");
-      Args[1] = "-A";
-      Args[2] = DebdeltaFile.c_str();
-      Args[3] = FromFile.c_str();
-      Args[4] = ToFile.c_str();
+      Args[n++] = "-A";
+      Args[n++] = DebdeltaFile.c_str();
+      Args[n++] = FromFile.c_str();
+      Args[n++] = ToFile.c_str();
       if (Debug == true)
       {
 	 std::cerr << "\n[Debdelta] Command:" << std::endl;
@@ -97,27 +102,20 @@ bool DebdeltaMethod::Fetch(FetchItem *Itm)						/*{{{*/
       }
       std::cerr << "\n\n[Debdelta] Patching " << ToFile << "..." << std::endl;
       execv(Args[0], (char **)Args);
-      close(Fd[1]);
+      return _error->Error("[Debdelta] Could not execv debpatch.");
    }
-   else if (Process != -1)
+   if (ExecWait(Process, "debpatch", false))
    {
-      int status;
-      int options = 0;
-      if (Process !=  waitpid(Process, &status, options))
-	 return _error->Error("[Debdelta] debpatch did not return normally.");
-      
       // read the stderr,stdout outputs of debpatch
       size_t LineSize = 1024;
       char *Line = (char *)malloc(LineSize + 1);
       close(Fd[1]);
-      //close(0);
-      //dup(Fd[0]);
       FILE *fp = fdopen(Fd[0], "r");
       DebpatchOutput = "";
       while (getline(&Line, &LineSize, fp) != EOF)
 	 DebpatchOutput += string(Line);
       fclose(fp);
-	 
+   	  
       if (!FileExists(ToFile))
 	 return _error->Error("\n[Debdelta] Failed to patch %s", ToFile.c_str());
       // move the .deb to Dir::Cache::Archives
@@ -130,12 +128,9 @@ bool DebdeltaMethod::Fetch(FetchItem *Itm)						/*{{{*/
 	 URIDone(Res);
       else
 	 std::cout << "Filename: " << Res.Filename << std::endl;
+      return true;
    }
-   else
-   {
-      return _error->Error("[Debdelta] forking failed.");
-   }
-   return true;
+   return false;
 }
 
 
-- 
cgit v1.2.3