Searched refs:processor_ (Results 1 - 20 of 20) sorted by relevance

/system/update_engine/common/
H A Daction.h85 AbstractAction() : processor_(nullptr) {}
107 CHECK(!processor_);
109 CHECK(processor_);
110 processor_ = processor;
115 if (!processor_)
117 return processor_->current_action() == this;
144 ActionProcessor* processor_; member in class:chromeos_update_engine::AbstractAction
H A Daction_processor_unittest.cc48 ActionProcessor* processor() { return processor_; }
61 : processor_(processor),
69 EXPECT_EQ(processor_, processor);
74 EXPECT_EQ(processor_, processor);
81 EXPECT_EQ(processor_, processor);
87 const ActionProcessor* processor_; member in class:chromeos_update_engine::__anon1970::MyActionProcessorDelegate
H A Daction_unittest.cc45 ActionProcessor* processor() { return processor_; }
H A Dtest_utils.h230 CHECK(this->processor_);
234 this->processor_->ActionComplete(this, ErrorCode::kSuccess);
264 ASSERT_TRUE(this->processor_);
268 this->processor_->ActionComplete(this, ErrorCode::kSuccess);
H A Dutils.h438 : processor_(processor),
444 processor_->ActionComplete(action_, code_);
453 ActionProcessor* processor_; member in class:chromeos_update_engine::ScopedActionCompleter
/system/connectivity/shill/shims/
H A Dnetfilter_queue_processor_unittest.cc35 NetfilterQueueProcessorTest() : processor_(kInputQueue, kOutputQueue) {}
38 int GetInputQueue() { return processor_.input_queue_; }
39 int GetOutputQueue() { return processor_.output_queue_; }
40 struct nfq_handle* GetNFQHandle() { return processor_.nfq_handle_; }
42 return processor_.input_queue_handle_;
45 return processor_.output_queue_handle_;
48 return processor_.listeners_;
51 return *processor_.listeners_[index];
73 processor_.LogOutgoingPacket(packet_, now);
76 return processor_
79 NetfilterQueueProcessor processor_; member in class:shill::shims::NetfilterQueueProcessorTest
[all...]
/system/update_engine/
H A Dupdate_attempter_android.cc81 processor_(new ActionProcessor()) {
87 processor_->set_delegate(nullptr);
198 processor_->SuspendProcessing();
205 processor_->ResumeProcessing();
212 processor_->StopProcessing();
353 FROM_HERE, Bind([this] { this->processor_->StartProcessing(); }));
386 CHECK(!processor_->IsRunning());
387 processor_->set_delegate(this);
427 processor_->EnqueueAction(action.get());
H A Dupdate_attempter_unittest.cc143 processor_ = new NiceMock<MockActionProcessor>();
144 attempter_.processor_.reset(processor_); // Transfers ownership.
208 NiceMock<MockActionProcessor>* processor_; member in class:chromeos_update_engine::UpdateAttempterTest
346 EXPECT_CALL(*processor_, EnqueueAction(_)).Times(0);
347 EXPECT_CALL(*processor_, StartProcessing()).Times(0);
362 EXPECT_CALL(*processor_,
365 EXPECT_CALL(*processor_, StartProcessing());
410 EXPECT_CALL(*processor_,
414 EXPECT_CALL(*processor_, StartProcessin
[all...]
H A Dupdate_attempter.cc129 : processor_(new ActionProcessor()),
144 processor_->set_delegate(nullptr);
596 CHECK(!processor_->IsRunning());
597 processor_->set_delegate(this);
685 processor_->EnqueueAction(action.get());
708 processor_->set_delegate(this);
737 processor_->EnqueueAction(action.get());
1355 processor_->EnqueueAction(error_event_action.get());
1357 processor_->StartProcessing();
1366 Bind([this] { this->processor_
[all...]
H A Dupdate_attempter_android.h140 std::unique_ptr<ActionProcessor> processor_; member in class:chromeos_update_engine::UpdateAttempterAndroid
H A Domaha_response_handler_action.cc52 ScopedActionCompleter completer(processor_, this);
H A Dupdate_attempter.h411 std::unique_ptr<ActionProcessor> processor_; member in class:chromeos_update_engine::UpdateAttempter
H A Domaha_request_action.cc628 processor_->ActionComplete(this, ErrorCode::kSuccess);
898 ScopedActionCompleter completer(processor_, this);
1028 ScopedActionCompleter completer(processor_, this);
H A Domaha_request_action_unittest.cc284 processor_->ActionComplete(this, ErrorCode::kSuccess);
/system/update_engine/payload_consumer/
H A Dpostinstall_runner_action_unittest.cc152 CHECK(processor_);
153 processor_->StopProcessing();
178 ActionProcessor* processor_{nullptr};
186 processor_ = &processor;
215 processor_ = nullptr;
H A Dinstall_plan.h138 processor_->ActionComplete(this, ErrorCode::kSuccess);
H A Ddownload_action_unittest.cc338 ActionProcessor* processor() { return processor_; }
475 processor_.set_delegate(&delegate);
476 processor_.EnqueueAction(&feeder_action);
477 processor_.EnqueueAction(download_action_.get());
498 ActionProcessor processor_; member in class:chromeos_update_engine::P2PDownloadActionTest
509 processor_.StartProcessing();
H A Ddownload_action.cc318 processor_->ActionComplete(this, code);
323 processor_->ActionComplete(this, code_);
H A Dfilesystem_verifier_action.cc52 ScopedActionCompleter abort_action_completer(processor_, this);
126 processor_->ActionComplete(this, code);
H A Dpostinstall_runner_action.cc321 ScopedActionCompleter completer(processor_, this);

Completed in 947 milliseconds