| OLD | NEW | 
|    1 // Copyright (c) 2010 The Chromium OS Authors. All rights reserved. |    1 // Copyright (c) 2010 The Chromium OS Authors. All rights reserved. | 
|    2 // Use of this source code is governed by a BSD-style license that can be |    2 // Use of this source code is governed by a BSD-style license that can be | 
|    3 // found in the LICENSE file. |    3 // found in the LICENSE file. | 
|    4  |    4  | 
|    5 #include "update_engine/update_attempter.h" |    5 #include "update_engine/update_attempter.h" | 
|    6  |    6  | 
|    7 // From 'man clock_gettime': feature test macro: _POSIX_C_SOURCE >= 199309L |    7 // From 'man clock_gettime': feature test macro: _POSIX_C_SOURCE >= 199309L | 
|    8 #ifndef _POSIX_C_SOURCE |    8 #ifndef _POSIX_C_SOURCE | 
|    9 #define _POSIX_C_SOURCE 199309L |    9 #define _POSIX_C_SOURCE 199309L | 
|   10 #endif  // _POSIX_C_SOURCE |   10 #endif  // _POSIX_C_SOURCE | 
| (...skipping 116 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  127   } |  127   } | 
|  128   if (!omaha_request_params_.Init(app_version, omaha_url)) { |  128   if (!omaha_request_params_.Init(app_version, omaha_url)) { | 
|  129     LOG(ERROR) << "Unable to initialize Omaha request device params."; |  129     LOG(ERROR) << "Unable to initialize Omaha request device params."; | 
|  130     return; |  130     return; | 
|  131   } |  131   } | 
|  132   CHECK(!processor_.IsRunning()); |  132   CHECK(!processor_.IsRunning()); | 
|  133   processor_.set_delegate(this); |  133   processor_.set_delegate(this); | 
|  134  |  134  | 
|  135   // Actions: |  135   // Actions: | 
|  136   shared_ptr<OmahaRequestAction> update_check_action( |  136   shared_ptr<OmahaRequestAction> update_check_action( | 
|  137       new OmahaRequestAction(omaha_request_params_, |  137       new OmahaRequestAction(prefs_, | 
 |  138                              omaha_request_params_, | 
|  138                              NULL, |  139                              NULL, | 
|  139                              new LibcurlHttpFetcher)); |  140                              new LibcurlHttpFetcher)); | 
|  140   shared_ptr<OmahaResponseHandlerAction> response_handler_action( |  141   shared_ptr<OmahaResponseHandlerAction> response_handler_action( | 
|  141       new OmahaResponseHandlerAction); |  142       new OmahaResponseHandlerAction); | 
|  142   shared_ptr<FilesystemCopierAction> filesystem_copier_action( |  143   shared_ptr<FilesystemCopierAction> filesystem_copier_action( | 
|  143       new FilesystemCopierAction(false)); |  144       new FilesystemCopierAction(false)); | 
|  144   shared_ptr<FilesystemCopierAction> kernel_filesystem_copier_action( |  145   shared_ptr<FilesystemCopierAction> kernel_filesystem_copier_action( | 
|  145       new FilesystemCopierAction(true)); |  146       new FilesystemCopierAction(true)); | 
|  146   shared_ptr<OmahaRequestAction> download_started_action( |  147   shared_ptr<OmahaRequestAction> download_started_action( | 
|  147       new OmahaRequestAction(omaha_request_params_, |  148       new OmahaRequestAction(prefs_, | 
 |  149                              omaha_request_params_, | 
|  148                              new OmahaEvent( |  150                              new OmahaEvent( | 
|  149                                  OmahaEvent::kTypeUpdateDownloadStarted), |  151                                  OmahaEvent::kTypeUpdateDownloadStarted), | 
|  150                              new LibcurlHttpFetcher)); |  152                              new LibcurlHttpFetcher)); | 
|  151   shared_ptr<DownloadAction> download_action( |  153   shared_ptr<DownloadAction> download_action( | 
|  152       new DownloadAction(new LibcurlHttpFetcher)); |  154       new DownloadAction(new LibcurlHttpFetcher)); | 
|  153   shared_ptr<OmahaRequestAction> download_finished_action( |  155   shared_ptr<OmahaRequestAction> download_finished_action( | 
|  154       new OmahaRequestAction(omaha_request_params_, |  156       new OmahaRequestAction(prefs_, | 
 |  157                              omaha_request_params_, | 
|  155                              new OmahaEvent( |  158                              new OmahaEvent( | 
|  156                                  OmahaEvent::kTypeUpdateDownloadFinished), |  159                                  OmahaEvent::kTypeUpdateDownloadFinished), | 
|  157                              new LibcurlHttpFetcher)); |  160                              new LibcurlHttpFetcher)); | 
|  158   shared_ptr<PostinstallRunnerAction> postinstall_runner_action_precommit( |  161   shared_ptr<PostinstallRunnerAction> postinstall_runner_action_precommit( | 
|  159       new PostinstallRunnerAction(true)); |  162       new PostinstallRunnerAction(true)); | 
|  160   shared_ptr<SetBootableFlagAction> set_bootable_flag_action( |  163   shared_ptr<SetBootableFlagAction> set_bootable_flag_action( | 
|  161       new SetBootableFlagAction); |  164       new SetBootableFlagAction); | 
|  162   shared_ptr<PostinstallRunnerAction> postinstall_runner_action_postcommit( |  165   shared_ptr<PostinstallRunnerAction> postinstall_runner_action_postcommit( | 
|  163       new PostinstallRunnerAction(false)); |  166       new PostinstallRunnerAction(false)); | 
|  164   shared_ptr<OmahaRequestAction> update_complete_action( |  167   shared_ptr<OmahaRequestAction> update_complete_action( | 
|  165       new OmahaRequestAction(omaha_request_params_, |  168       new OmahaRequestAction(prefs_, | 
 |  169                              omaha_request_params_, | 
|  166                              new OmahaEvent(OmahaEvent::kTypeUpdateComplete), |  170                              new OmahaEvent(OmahaEvent::kTypeUpdateComplete), | 
|  167                              new LibcurlHttpFetcher)); |  171                              new LibcurlHttpFetcher)); | 
|  168  |  172  | 
|  169   download_action->set_delegate(this); |  173   download_action->set_delegate(this); | 
|  170   response_handler_action_ = response_handler_action; |  174   response_handler_action_ = response_handler_action; | 
|  171  |  175  | 
|  172   actions_.push_back(shared_ptr<AbstractAction>(update_check_action)); |  176   actions_.push_back(shared_ptr<AbstractAction>(update_check_action)); | 
|  173   actions_.push_back(shared_ptr<AbstractAction>(response_handler_action)); |  177   actions_.push_back(shared_ptr<AbstractAction>(response_handler_action)); | 
|  174   actions_.push_back(shared_ptr<AbstractAction>(filesystem_copier_action)); |  178   actions_.push_back(shared_ptr<AbstractAction>(filesystem_copier_action)); | 
|  175   actions_.push_back(shared_ptr<AbstractAction>( |  179   actions_.push_back(shared_ptr<AbstractAction>( | 
| (...skipping 206 matching lines...) Expand 10 before | Expand all | Expand 10 after  Loading... | 
|  382   error_event_.reset(new OmahaEvent(OmahaEvent::kTypeUpdateComplete, |  386   error_event_.reset(new OmahaEvent(OmahaEvent::kTypeUpdateComplete, | 
|  383                                     OmahaEvent::kResultError, |  387                                     OmahaEvent::kResultError, | 
|  384                                     code)); |  388                                     code)); | 
|  385 } |  389 } | 
|  386  |  390  | 
|  387 bool UpdateAttempter::ScheduleErrorEventAction() { |  391 bool UpdateAttempter::ScheduleErrorEventAction() { | 
|  388   if (error_event_.get() == NULL) |  392   if (error_event_.get() == NULL) | 
|  389     return false; |  393     return false; | 
|  390  |  394  | 
|  391   shared_ptr<OmahaRequestAction> error_event_action( |  395   shared_ptr<OmahaRequestAction> error_event_action( | 
|  392       new OmahaRequestAction(omaha_request_params_, |  396       new OmahaRequestAction(prefs_, | 
 |  397                              omaha_request_params_, | 
|  393                              error_event_.release(),  // Pass ownership. |  398                              error_event_.release(),  // Pass ownership. | 
|  394                              new LibcurlHttpFetcher)); |  399                              new LibcurlHttpFetcher)); | 
|  395   actions_.push_back(shared_ptr<AbstractAction>(error_event_action)); |  400   actions_.push_back(shared_ptr<AbstractAction>(error_event_action)); | 
|  396   processor_.EnqueueAction(error_event_action.get()); |  401   processor_.EnqueueAction(error_event_action.get()); | 
|  397   SetStatusAndNotify(UPDATE_STATUS_REPORTING_ERROR_EVENT); |  402   SetStatusAndNotify(UPDATE_STATUS_REPORTING_ERROR_EVENT); | 
|  398   processor_.StartProcessing(); |  403   processor_.StartProcessing(); | 
|  399   return true; |  404   return true; | 
|  400 } |  405 } | 
|  401  |  406  | 
|  402 }  // namespace chromeos_update_engine |  407 }  // namespace chromeos_update_engine | 
| OLD | NEW |