Home
last modified time | relevance | path

Searched refs:processor_ (Results 1 – 23 of 23) sorted by relevance

/system/update_engine/payload_consumer/
Dfilesystem_verifier_action_unittest.cc53 ActionProcessor processor_; member in chromeos_update_engine::FilesystemVerifierActionTest
142 processor_.set_delegate(&delegate); in DoTest()
152 base::Unretained(&processor_), in DoTest()
200 processor_.EnqueueAction(std::move(feeder_action)); in BuildActions()
201 processor_.EnqueueAction(std::move(verifier_action)); in BuildActions()
202 processor_.EnqueueAction(std::move(collector_action)); in BuildActions()
226 processor_.EnqueueAction(std::move(copier_action)); in TEST_F()
227 processor_.EnqueueAction(std::move(collector_action)); in TEST_F()
230 processor_.set_delegate(&delegate); in TEST_F()
232 processor_.StartProcessing(); in TEST_F()
[all …]
Dpostinstall_runner_action_unittest.cc143 CHECK(processor_); in CancelWhenStarted()
144 processor_->StopProcessing(); in CancelWhenStarted()
166 ActionProcessor* processor_{nullptr}; member in chromeos_update_engine::PostinstallRunnerActionTest
175 processor_ = &processor; in RunPostinstallAction()
209 processor_ = nullptr; in RunPostinstallAction()
Ddownload_action_unittest.cc430 ActionProcessor* processor() { return processor_; } in processor()
580 processor_.set_delegate(&delegate_); in StartDownload()
581 processor_.EnqueueAction(std::move(feeder_action)); in StartDownload()
582 processor_.EnqueueAction(std::move(download_action)); in StartDownload()
588 action_test->processor_.StartProcessing(); in StartDownload()
606 ActionProcessor processor_; member in chromeos_update_engine::P2PDownloadActionTest
Dfilesystem_verifier_action.cc45 ScopedActionCompleter abort_action_completer(processor_, this); in PerformAction()
79 processor_->ActionComplete(this, code); in Cleanup()
Dinstall_plan.h182 processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
Ddownload_action.cc413 processor_->ActionComplete(this, code); in TransferComplete()
418 processor_->ActionComplete(this, code_); in TransferTerminated()
Dpostinstall_runner_action.cc350 ScopedActionCompleter completer(processor_, this); in CompletePostinstall()
/system/update_engine/common/
Daction.h85 AbstractAction() : processor_(nullptr) {} in AbstractAction()
107 CHECK(!processor_); in SetProcessor()
109 CHECK(processor_); in SetProcessor()
110 processor_ = processor; in SetProcessor()
115 if (!processor_) in IsRunning()
117 return processor_->current_action() == this; in IsRunning()
144 ActionProcessor* processor_;
Daction_processor_unittest.cc49 ActionProcessor* processor() { return processor_; } in processor()
62 : processor_(processor), in MyActionProcessorDelegate()
70 EXPECT_EQ(processor_, processor); in ProcessingDone()
75 EXPECT_EQ(processor_, processor); in ProcessingStopped()
82 EXPECT_EQ(processor_, processor); in ActionCompleted()
88 const ActionProcessor* processor_; member in chromeos_update_engine::__anon01019b6b0111::MyActionProcessorDelegate
Dtest_utils.h205 CHECK(this->processor_); in PerformAction()
209 this->processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
238 ASSERT_TRUE(this->processor_); in PerformAction()
242 this->processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
Dutils.h371 : processor_(processor), in ScopedActionCompleter()
375 CHECK(processor_); in ScopedActionCompleter()
379 processor_->ActionComplete(action_, code_); in ~ScopedActionCompleter()
388 ActionProcessor* processor_;
Daction_unittest.cc48 ActionProcessor* processor() { return processor_; } in processor()
/system/update_engine/
Dupdate_boot_flags_action.cc32 processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
37 processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
80 processor_->ActionComplete(this, ErrorCode::kSuccess); in CompleteUpdateBootFlags()
Dupdate_attempter_android.cc108 processor_(new ActionProcessor()), in UpdateAttempterAndroid()
117 processor_->set_delegate(nullptr); in ~UpdateAttempterAndroid()
141 if (processor_->IsRunning()) { in ApplyPayload()
292 if (!processor_->IsRunning()) in SuspendUpdate()
294 processor_->SuspendProcessing(); in SuspendUpdate()
299 if (!processor_->IsRunning()) in ResumeUpdate()
301 processor_->ResumeProcessing(); in ResumeUpdate()
306 if (!processor_->IsRunning()) in CancelUpdate()
308 processor_->StopProcessing(); in CancelUpdate()
570 base::Unretained(processor_.get()))); in ScheduleProcessingStart()
[all …]
Dupdate_attempter.cc122 : processor_(new ActionProcessor()), in UpdateAttempter()
133 processor_->set_delegate(nullptr); in ~UpdateAttempter()
622 CHECK(!processor_->IsRunning()); in BuildUpdateActions()
623 processor_->set_delegate(this); in BuildUpdateActions()
686 processor_->EnqueueAction(std::move(update_check_action)); in BuildUpdateActions()
687 processor_->EnqueueAction(std::move(response_handler_action)); in BuildUpdateActions()
688 processor_->EnqueueAction(std::move(update_boot_flags_action)); in BuildUpdateActions()
689 processor_->EnqueueAction(std::move(download_started_action)); in BuildUpdateActions()
690 processor_->EnqueueAction(std::move(download_action)); in BuildUpdateActions()
691 processor_->EnqueueAction(std::move(download_finished_action)); in BuildUpdateActions()
[all …]
Dupdate_attempter_unittest.cc153 processor_ = new NiceMock<MockActionProcessor>(); in SetUp()
154 attempter_.processor_.reset(processor_); // Transfers ownership. in SetUp()
215 NiceMock<MockActionProcessor>* processor_; member in chromeos_update_engine::UpdateAttempterTest
435 EXPECT_CALL(*processor_, EnqueueAction(_)).Times(0); in TEST_F()
436 EXPECT_CALL(*processor_, StartProcessing()).Times(0); in TEST_F()
450 EXPECT_CALL(*processor_, in TEST_F()
453 EXPECT_CALL(*processor_, StartProcessing()); in TEST_F()
502 EXPECT_CALL(*processor_, in UpdateTestStart()
506 EXPECT_CALL(*processor_, StartProcessing()); in UpdateTestStart()
517 EXPECT_EQ(&attempter_, processor_->delegate()); in UpdateTestVerify()
[all …]
Dreal_system_state.cc213 processor_.EnqueueAction(std::move(update_boot_flags_action)); in StartUpdater()
218 base::Unretained(&processor_)), in StartUpdater()
Dupdate_attempter_android.h175 std::unique_ptr<ActionProcessor> processor_; variable
Dreal_system_state.h197 ActionProcessor processor_; variable
Domaha_response_handler_action.cc51 ScopedActionCompleter completer(processor_, this); in PerformAction()
Dupdate_attempter_android_unittest.cc52 update_attempter_android_.processor_.reset( in SetUp()
Dupdate_attempter.h422 std::unique_ptr<ActionProcessor> processor_; variable
Domaha_request_action.cc828 processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
1213 ScopedActionCompleter completer(processor_, this); in TransferComplete()
1359 ScopedActionCompleter completer(processor_, this); in CompleteProcessing()