AU: Start checkpointing update progress.

download_action.cc

 // Copyright (c) 2010 The Chromium OS Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "update_engine/download_action.h"
 #include <errno.h>
 #include <algorithm>
 #include <string>
 #include <vector>
 #include <glib.h>
 #include "update_engine/action_pipe.h"
 #include "update_engine/subprocess.h"
 
 using std::min;
 using std::string;
 using std::vector;
 
 namespace chromeos_update_engine {
 
 // Use a buffer to reduce the number of IOPS on SSD devices.
 const size_t kFileWriterBufferSize = 128 * 1024;  // 128 KiB
 
-DownloadAction::DownloadAction(HttpFetcher* http_fetcher)
-    : writer_(NULL),
+DownloadAction::DownloadAction(PrefsInterface* prefs,
+                               HttpFetcher* http_fetcher)
+    : prefs_(prefs),
+      writer_(NULL),
       http_fetcher_(http_fetcher),
       delegate_(NULL),
       bytes_received_(0) {}
 
 DownloadAction::~DownloadAction() {}
 
 void DownloadAction::PerformAction() {
   http_fetcher_->set_delegate(this);
 
   // Get the InstallPlan and read it
@@ skipping 19 matching lines @@
           new SplitFileWriter(kernel_buffered_file_writer_.get(),
                               rootfs_buffered_file_writer_.get()));
       split_file_writer_->SetFirstOpenArgs(
           install_plan_.kernel_install_path.c_str(),
           O_WRONLY | O_CREAT | O_TRUNC | O_LARGEFILE,
           0644);
       decompressing_file_writer_.reset(
           new GzipDecompressingFileWriter(split_file_writer_.get()));
       writer_ = decompressing_file_writer_.get();
     } else {
-      delta_performer_.reset(new DeltaPerformer);
+      delta_performer_.reset(new DeltaPerformer(prefs_));
       writer_ = delta_performer_.get();
     }
   }
   int rc = writer_->Open(install_plan_.install_path.c_str(),
                          O_TRUNC | O_WRONLY | O_CREAT | O_LARGEFILE,
                          0644);
   if (rc < 0) {
     LOG(ERROR) << "Unable to open output file " << install_plan_.install_path;
     // report error to processor
     processor_->ActionComplete(this, kActionCodeInstallDeviceOpenError);
@@ skipping 85 matching lines @@
 
   FlushLinuxCaches();
 
   // Write the path to the output pipe if we're successful.
   if (code == kActionCodeSuccess && HasOutputPipe())
     SetOutputObject(GetInputObject());
   processor_->ActionComplete(this, code);
 }
 
 };  // namespace {}