Start action processing asynchronously in UpdateAttempter.

update_attempter.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/update_attempter.h"
 
 // From 'man clock_gettime': feature test macro: _POSIX_C_SOURCE >= 199309L
 #ifndef _POSIX_C_SOURCE
 #define _POSIX_C_SOURCE 199309L
 #endif  // _POSIX_C_SOURCE
@@ skipping 230 matching lines @@
   BondActions(kernel_filesystem_copier_action.get(),
               download_action.get());
   BondActions(download_action.get(),
               filesystem_verifier_action.get());
   BondActions(filesystem_verifier_action.get(),
               kernel_filesystem_verifier_action.get());
   BondActions(kernel_filesystem_verifier_action.get(),
               postinstall_runner_action.get());
 
   SetStatusAndNotify(UPDATE_STATUS_CHECKING_FOR_UPDATE);
-  processor_->StartProcessing();
+
+  // Start the processing asynchronously to unblock the event loop.
+  g_idle_add(&StaticStartProcessing, this);
 }
 
 void UpdateAttempter::CheckForUpdate(const std::string& app_version,
                                      const std::string& omaha_url) {
   if (status_ != UPDATE_STATUS_IDLE) {
     LOG(INFO) << "Check for update requested, but status is "
               << UpdateStatusToString(status_) << ", so not checking.";
     return;
   }
   Update(app_version, omaha_url, true);
@@ skipping 258 matching lines @@
     g_source_destroy(manage_priority_source_);
     manage_priority_source_ = NULL;
   }
   SetPriority(utils::kProcessPriorityNormal);
 }
 
 gboolean UpdateAttempter::StaticManagePriorityCallback(gpointer data) {
   return reinterpret_cast<UpdateAttempter*>(data)->ManagePriorityCallback();
 }
 
+gboolean UpdateAttempter::StaticStartProcessing(gpointer data) {
+  reinterpret_cast<UpdateAttempter*>(data)->processor_->StartProcessing();
+  return FALSE;  // Don't call this callback again.
+}
+
 bool UpdateAttempter::ManagePriorityCallback() {
   SetPriority(utils::kProcessPriorityNormal);
   manage_priority_source_ = NULL;
   return false;  // Destroy the timeout source.
 }
 
 void UpdateAttempter::DisableDeltaUpdateIfNeeded() {
   int64_t delta_failures;
   if (omaha_request_params_.delta_okay &&
       prefs_->GetInt64(kPrefsDeltaUpdateFailures, &delta_failures) &&
@@ skipping 32 matching lines @@
     uint64_t resume_offset = manifest_metadata_size + next_data_offset;
     if (resume_offset < response_handler_action_->install_plan().size) {
       fetcher->AddRange(resume_offset, -1);
     }
   } else {
     fetcher->AddRange(0, -1);
   }
 }
 
 }  // namespace chromeos_update_engine