HomeSort by relevance Sort by last modified time
    Searched refs:ActionProcessor (Results 1 - 16 of 16) sorted by null

  /system/update_engine/common/
action_processor.h 27 // The structure of these classes (Action, ActionPipe, ActionProcessor, etc.)
35 // An ActionProcessor keeps a queue of Actions and processes them in order.
42 class ActionProcessor {
44 ActionProcessor() = default;
46 virtual ~ActionProcessor();
66 // Resume the suspended processing. If the ActionProcessor is not suspended
115 DISALLOW_COPY_AND_ASSIGN(ActionProcessor);
119 // in an ActionProcessor. An instance of this class can be passed to an
120 // ActionProcessor to register itself.
125 // Called when all processing in an ActionProcessor has completed. A pointe
    [all...]
mock_action_processor.h 26 class MockActionProcessor : public ActionProcessor {
action_processor.cc 30 ActionProcessor::~ActionProcessor() {
37 void ActionProcessor::EnqueueAction(AbstractAction* action) {
42 void ActionProcessor::StartProcessing() {
46 LOG(INFO) << "ActionProcessor: starting " << current_action_->Type();
52 void ActionProcessor::StopProcessing() {
58 LOG(INFO) << "ActionProcessor: aborted "
71 void ActionProcessor::SuspendProcessing() {
82 LOG(INFO) << "ActionProcessor: suspending " << current_action_->Type();
86 void ActionProcessor::ResumeProcessing()
    [all...]
action_processor_unittest.cc 48 ActionProcessor* processor() { return processor_; }
60 explicit MyActionProcessorDelegate(const ActionProcessor* processor)
67 virtual void ProcessingDone(const ActionProcessor* processor,
73 virtual void ProcessingStopped(const ActionProcessor* processor) {
78 virtual void ActionCompleted(ActionProcessor* processor,
87 const ActionProcessor* processor_;
107 // The ActionProcessor under test.
108 ActionProcessor action_processor_;
170 ActionProcessor action_processor;
235 // The processing should not be done since the ActionProcessor is suspende
    [all...]
action_unittest.cc 45 ActionProcessor* processor() { return processor_; }
66 ActionProcessor action_processor;
action.h 31 // The structure of these classes (Action, ActionPipe, ActionProcessor, etc.)
38 // http://code.google.com/p/update-engine/wiki/ActionProcessor
52 // An ActionProcessor contains a queue of Actions to perform. When
53 // ActionProcessor::StartProcessing() is called, it executes the first action.
55 // Processor to execute the next action. ActionProcessor may have a delegate
96 // ActionProcessor::ActionComplete(this); to notify the processor that it's
100 // Called on ActionProcess::ActionComplete() by ActionProcessor.
103 // Called by the ActionProcessor to tell this Action which processor
105 void SetProcessor(ActionProcessor* processor) {
113 // Returns true iff the action is the current action of its ActionProcessor
    [all...]
utils.h 364 // A little object to call ActionComplete on the ActionProcessor when
368 explicit ScopedActionCompleter(ActionProcessor* processor,
385 ActionProcessor* processor_;
  /system/update_engine/
update_attempter_android.h 71 void ProcessingDone(const ActionProcessor* processor,
73 void ProcessingStopped(const ActionProcessor* processor) override;
74 void ActionCompleted(ActionProcessor* processor,
135 std::unique_ptr<ActionProcessor> processor_;
update_attempter.h 100 void ProcessingDone(const ActionProcessor* processor,
102 void ProcessingStopped(const ActionProcessor* processor) override;
103 void ActionCompleted(ActionProcessor* processor,
400 std::unique_ptr<ActionProcessor> processor_;
update_attempter_android.cc 88 processor_(new ActionProcessor()) {
93 // Release ourselves as the ActionProcessor's delegate to prevent
292 void UpdateAttempterAndroid::ProcessingDone(const ActionProcessor* processor,
326 const ActionProcessor* processor) {
330 void UpdateAttempterAndroid::ActionCompleted(ActionProcessor* processor,
340 // If an action failed, the ActionProcessor will cancel the whole thing.
409 Bind([](ActionProcessor* processor) { processor->StartProcessing(); },
omaha_request_action_unittest.cc 296 void ProcessingDone(const ActionProcessor* processor,
301 void ActionCompleted(ActionProcessor* processor,
380 ActionProcessor processor;
407 [](ActionProcessor* processor) { processor->StartProcessing(); },
437 ActionProcessor processor;
442 [](ActionProcessor* processor) { processor->StartProcessing(); },
703 ActionProcessor processor;
707 [](ActionProcessor* processor) { processor->StartProcessing(); },
    [all...]
update_attempter.cc 127 : processor_(new ActionProcessor()),
141 // Release ourselves as the ActionProcessor's delegate to prevent
    [all...]
omaha_response_handler_action_unittest.cc 72 void ActionCompleted(ActionProcessor* processor,
102 ActionProcessor processor;
  /system/update_engine/payload_consumer/
filesystem_verifier_action_unittest.cc 81 void ProcessingDone(const ActionProcessor* processor, ErrorCode code) {
84 void ProcessingStopped(const ActionProcessor* processor) {
87 void ActionCompleted(ActionProcessor* processor,
104 void StartProcessorInRunLoop(ActionProcessor* processor,
168 ActionProcessor processor;
225 void ActionCompleted(ActionProcessor* processor,
238 ActionProcessor processor;
257 ActionProcessor processor;
download_action_unittest.cc 73 void ProcessingDone(const ActionProcessor* processor,
87 void ActionCompleted(ActionProcessor* processor,
122 void StartProcessorInRunLoop(ActionProcessor* processor,
186 ActionProcessor processor;
248 void ProcessingStopped(const ActionProcessor* processor) {
253 void TerminateEarlyTestStarter(ActionProcessor* processor) {
292 ActionProcessor processor;
339 ActionProcessor* processor() { return processor_; }
354 // run loop when the ActionProcessor has completed processing. It's used
358 void ProcessingDone(const ActionProcessor* processor, ErrorCode code)
    [all...]
postinstall_runner_action_unittest.cc 54 void ProcessingDone(const ActionProcessor* processor,
59 void ProcessingStopped(const ActionProcessor* processor) override {
64 void ActionCompleted(ActionProcessor* processor,
165 ActionProcessor* processor_{nullptr};
172 ActionProcessor processor;
199 [](ActionProcessor* processor) { processor->StartProcessing(); },

Completed in 2192 milliseconds