| /system/update_engine/common/ |
| D | action.h | 85 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_;
|
| D | action_processor_unittest.cc | 48 ActionProcessor* processor() { return processor_; } in processor()
61 : processor_(processor), in MyActionProcessorDelegate()
69 EXPECT_EQ(processor_, processor); in ProcessingDone()
74 EXPECT_EQ(processor_, processor); in ProcessingStopped()
81 EXPECT_EQ(processor_, processor); in ActionCompleted()
87 const ActionProcessor* processor_; member in chromeos_update_engine::__anon1fb4e3a30111::MyActionProcessorDelegate
|
| D | test_utils.h | 230 CHECK(this->processor_); in PerformAction()
234 this->processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
264 ASSERT_TRUE(this->processor_); in PerformAction()
268 this->processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
|
| D | action_unittest.cc | 45 ActionProcessor* processor() { return processor_; } in processor()
|
| D | utils.h | 435 : processor_(processor), in ScopedActionCompleter()
441 processor_->ActionComplete(action_, code_); in ~ScopedActionCompleter()
450 ActionProcessor* processor_;
|
| /system/connectivity/shill/shims/ |
| D | netfilter_queue_processor_unittest.cc | 35 NetfilterQueueProcessorTest() : processor_(kInputQueue, kOutputQueue) {} in NetfilterQueueProcessorTest()
38 int GetInputQueue() { return processor_.input_queue_; } in GetInputQueue()
39 int GetOutputQueue() { return processor_.output_queue_; } in GetOutputQueue()
40 struct nfq_handle* GetNFQHandle() { return processor_.nfq_handle_; } in GetNFQHandle()
42 return processor_.input_queue_handle_; in GetInputQueueHandle()
45 return processor_.output_queue_handle_; in GetOutputQueueHandle()
48 return processor_.listeners_; in GetListeners()
51 return *processor_.listeners_[index]; in GetListener()
73 processor_.LogOutgoingPacket(packet_, now); in LogOutgoingPacket()
76 return processor_.IsIncomingPacketAllowed(packet_, now); in IsIncomingPacketAllowed()
[all …]
|
| /system/update_engine/ |
| D | update_attempter_android.cc | 88 processor_(new ActionProcessor()) { in UpdateAttempterAndroid()
95 processor_->set_delegate(nullptr); in ~UpdateAttempterAndroid()
224 processor_->SuspendProcessing(); in SuspendUpdate()
231 processor_->ResumeProcessing(); in ResumeUpdate()
238 processor_->StopProcessing(); in CancelUpdate()
402 FROM_HERE, Bind([this] { this->processor_->StartProcessing(); })); in ScheduleProcessingStart()
435 CHECK(!processor_->IsRunning()); in BuildUpdateActions()
436 processor_->set_delegate(this); in BuildUpdateActions()
488 processor_->EnqueueAction(action.get()); in BuildUpdateActions()
|
| D | update_attempter_unittest.cc | 143 processor_ = new NiceMock<MockActionProcessor>(); in SetUp()
144 attempter_.processor_.reset(processor_); // Transfers ownership. in SetUp()
208 NiceMock<MockActionProcessor>* processor_; member in chromeos_update_engine::UpdateAttempterTest
346 EXPECT_CALL(*processor_, EnqueueAction(_)).Times(0); in TEST_F()
347 EXPECT_CALL(*processor_, StartProcessing()).Times(0); in TEST_F()
362 EXPECT_CALL(*processor_, in TEST_F()
365 EXPECT_CALL(*processor_, StartProcessing()); in TEST_F()
410 EXPECT_CALL(*processor_, in UpdateTestStart()
414 EXPECT_CALL(*processor_, StartProcessing()); in UpdateTestStart()
425 EXPECT_EQ(&attempter_, processor_->delegate()); in UpdateTestVerify()
[all …]
|
| D | update_attempter.cc | 129 : processor_(new ActionProcessor()), in UpdateAttempter()
144 processor_->set_delegate(nullptr); in ~UpdateAttempter()
597 CHECK(!processor_->IsRunning()); in BuildUpdateActions()
598 processor_->set_delegate(this); in BuildUpdateActions()
686 processor_->EnqueueAction(action.get()); in BuildUpdateActions()
709 processor_->set_delegate(this); in Rollback()
738 processor_->EnqueueAction(action.get()); in Rollback()
1362 processor_->EnqueueAction(error_event_action.get()); in ScheduleErrorEventAction()
1364 processor_->StartProcessing(); in ScheduleErrorEventAction()
1373 Bind([this] { this->processor_->StartProcessing(); })); in ScheduleProcessingStart()
[all …]
|
| D | update_attempter_android.h | 140 std::unique_ptr<ActionProcessor> processor_; variable
|
| D | omaha_response_handler_action.cc | 52 ScopedActionCompleter completer(processor_, this); in PerformAction()
|
| D | update_attempter.h | 415 std::unique_ptr<ActionProcessor> processor_; variable
|
| D | omaha_request_action.cc | 628 processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
898 ScopedActionCompleter completer(processor_, this); in TransferComplete()
1028 ScopedActionCompleter completer(processor_, this); in CompleteProcessing()
|
| D | omaha_request_action_unittest.cc | 284 processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
|
| /system/update_engine/payload_consumer/ |
| D | postinstall_runner_action_unittest.cc | 149 CHECK(processor_); in CancelWhenStarted()
150 processor_->StopProcessing(); in CancelWhenStarted()
172 ActionProcessor* processor_{nullptr}; member in chromeos_update_engine::PostinstallRunnerActionTest
180 processor_ = &processor; in RunPosinstallAction()
208 processor_ = nullptr; in RunPosinstallAction()
|
| D | download_action_unittest.cc | 338 ActionProcessor* processor() { return processor_; } in processor()
475 processor_.set_delegate(&delegate); in StartDownload()
476 processor_.EnqueueAction(&feeder_action); in StartDownload()
477 processor_.EnqueueAction(download_action_.get()); in StartDownload()
498 ActionProcessor processor_; member in chromeos_update_engine::P2PDownloadActionTest
509 processor_.StartProcessing(); in StartProcessorInRunLoopForP2P()
|
| D | download_action.cc | 318 processor_->ActionComplete(this, code); in TransferComplete()
323 processor_->ActionComplete(this, code_); in TransferTerminated()
|
| D | filesystem_verifier_action.cc | 52 ScopedActionCompleter abort_action_completer(processor_, this); in PerformAction()
126 processor_->ActionComplete(this, code); in Cleanup()
|
| D | install_plan.h | 139 processor_->ActionComplete(this, ErrorCode::kSuccess); in PerformAction()
|
| D | postinstall_runner_action.cc | 328 ScopedActionCompleter completer(processor_, this); in CompletePostinstall()
|