/system/update_engine/payload_consumer/ |
H A D | filesystem_verifier_action_unittest.cc | 85 void ProcessingDone(const ActionProcessor* processor, ErrorCode code) { argument 88 void ProcessingStopped(const ActionProcessor* processor) { argument 91 void ActionCompleted(ActionProcessor* processor, argument 108 void StartProcessorInRunLoop(ActionProcessor* processor, argument 111 processor->StartProcessing(); 114 processor->StopProcessing(); 193 ActionProcessor processor; local 203 processor.set_delegate(&delegate); 204 processor.EnqueueAction(&feeder_action); 205 processor 250 ActionCompleted(ActionProcessor* processor, AbstractAction* action, ErrorCode code) argument 263 ActionProcessor processor; local 283 ActionProcessor processor; local 360 ActionProcessor processor; local [all...] |
H A D | download_action_unittest.cc | 73 void ProcessingDone(const ActionProcessor* processor, 87 void ActionCompleted(ActionProcessor* processor, 122 void StartProcessorInRunLoop(ActionProcessor* processor, argument 124 processor->StartProcessing(); 186 ActionProcessor processor; local 187 processor.set_delegate(&delegate); 188 processor.EnqueueAction(&feeder_action); 189 processor.EnqueueAction(&download_action); 192 base::Bind(&StartProcessorInRunLoop, &processor, http_fetcher)); 248 void ProcessingStopped(const ActionProcessor* processor) { argument 253 TerminateEarlyTestStarter(ActionProcessor* processor) argument 291 ActionProcessor processor; local 338 ActionProcessor* processor() { return processor_; } function in class:chromeos_update_engine::DownloadActionTestAction 357 ProcessingDone(const ActionProcessor* processor, ErrorCode code) argument 391 ActionProcessor processor; local [all...] |
H A D | postinstall_runner_action_unittest.cc | 53 void ProcessingDone(const ActionProcessor* processor, 58 void ProcessingStopped(const ActionProcessor* processor) override { 63 void ActionCompleted(ActionProcessor* processor, 107 // Setup an action processor and run the PostinstallRunnerAction with a single 176 // A pointer to the posinstall_runner action and the processor. 185 ActionProcessor processor; local 186 processor_ = &processor; 205 processor.EnqueueAction(&feeder_action); 206 processor.EnqueueAction(&runner_action); 207 processor [all...] |
/system/update_engine/common/ |
H A D | action_unittest.cc | 45 ActionProcessor* processor() { return processor_; } function in class:chromeos_update_engine::ActionTestAction 48 ASSERT_TRUE(processor()); 49 processor()->ActionComplete(this, ErrorCode::kSuccess); 63 EXPECT_FALSE(action.processor()); 68 EXPECT_EQ(&action_processor, action.processor());
|
H A D | action_processor_unittest.cc | 48 ActionProcessor* processor() { return processor_; } function in class:chromeos_update_engine::ActionProcessorTestAction 51 ASSERT_TRUE(processor()); 52 processor()->ActionComplete(this, ErrorCode::kSuccess); 60 explicit MyActionProcessorDelegate(const ActionProcessor* processor) argument 61 : processor_(processor), 67 virtual void ProcessingDone(const ActionProcessor* processor, argument 69 EXPECT_EQ(processor_, processor); 73 virtual void ProcessingStopped(const ActionProcessor* processor) { argument 74 EXPECT_EQ(processor_, processor); 78 virtual void ActionCompleted(ActionProcessor* processor, argument [all...] |
H A D | action_processor.h | 88 // Called by an action to notify processor that it's done. Caller passes self. 106 // delegate once the processor is resumed. 109 // Whether the action processor is or should be suspended. 128 virtual void ProcessingDone(const ActionProcessor* processor, argument 133 virtual void ProcessingStopped(const ActionProcessor* processor) {} argument 137 virtual void ActionCompleted(ActionProcessor* processor, argument
|
H A D | action.h | 54 // Each action tells the processor when it has completed, which causes the 96 // ActionProcessor::ActionComplete(this); to notify the processor that it's 103 // Called by the ActionProcessor to tell this Action which processor 105 void SetProcessor(ActionProcessor* processor) { argument 106 if (processor) 110 processor_ = processor; 122 // ActionProcessor::ActionComplete() because the processor knows this 143 // A weak pointer to the processor that owns this Action.
|
H A D | utils.h | 436 explicit ScopedActionCompleter(ActionProcessor* processor, argument 438 : processor_(processor),
|
/system/connectivity/shill/shims/ |
H A D | netfilter_queue_helper.cc | 126 shill::shims::NetfilterQueueProcessor processor(input_queue, output_queue); 128 if (!processor.Start()) { 129 LOG(ERROR) << "Failed to start netfilter processor."; 133 processor.Run();
|
H A D | netfilter_queue_processor.cc | 149 VLOG(2) << "Created netfilter queue processor."; 157 LOG(INFO) << "Netfilter queue processor running."; 179 VLOG(2) << "Netfilter queue processor starting."; 258 NetfilterQueueProcessor* processor = local 262 if (processor->IsIncomingPacketAllowed(packet, now)) { 281 NetfilterQueueProcessor* processor = local 284 processor->LogOutgoingPacket(packet, now);
|
/system/update_engine/ |
H A D | update_attempter_android.h | 72 void ProcessingDone(const ActionProcessor* processor, 74 void ProcessingStopped(const ActionProcessor* processor) override; 75 void ActionCompleted(ActionProcessor* processor, 92 // processor. 98 // Schedules an event loop callback to start the action processor. This is 137 // The list of actions and action processor that runs them asynchronously.
|
H A D | omaha_response_handler_action_unittest.cc | 68 void ActionCompleted(ActionProcessor* processor, argument 97 ActionProcessor processor; local 99 processor.set_delegate(&delegate); 125 processor.EnqueueAction(&feeder_action); 126 processor.EnqueueAction(&response_handler_action); 127 processor.EnqueueAction(&collector_action); 128 processor.StartProcessing(); 129 EXPECT_TRUE(!processor.IsRunning())
|
H A D | update_attempter.h | 96 void ProcessingDone(const ActionProcessor* processor, 98 void ProcessingStopped(const ActionProcessor* processor) override; 99 void ActionCompleted(ActionProcessor* processor, 132 // is asynchronous. On completion, the action processor may be started 292 // OmahaRequestAction once the current action processor is done. 296 // OmahaRequestAction with that event in the current processor, clears the 301 // Schedules an event loop callback to start the action processor. This is 481 // True if the action processor needs to be started by the boot flag updater.
|
H A D | omaha_request_action_unittest.cc | 247 void ProcessingDone(const ActionProcessor* processor, 252 void ActionCompleted(ActionProcessor* processor, 331 ActionProcessor processor; local 332 processor.set_delegate(&delegate); 333 processor.EnqueueAction(&action); 337 processor.EnqueueAction(&collector_action); 357 loop.PostTask(base::Bind([&processor] { processor.StartProcessing(); })); 388 ActionProcessor processor; local 389 processor 857 ActionProcessor processor; local 1003 ProcessingStopped(const ActionProcessor* processor) argument 1008 TerminateTransferTestStarter(ActionProcessor* processor) argument 1027 ActionProcessor processor; local [all...] |
H A D | update_attempter_android.cc | 254 void UpdateAttempterAndroid::ProcessingDone(const ActionProcessor* processor, argument 271 const ActionProcessor* processor) { 275 void UpdateAttempterAndroid::ActionCompleted(ActionProcessor* processor, argument 351 LOG(INFO) << "Scheduling an action processor start."; 270 ProcessingStopped( const ActionProcessor* processor) argument
|
H A D | update_attempter.cc | 916 void UpdateAttempter::ProcessingDone(const ActionProcessor* processor, argument 997 void UpdateAttempter::ProcessingStopped(const ActionProcessor* processor) { argument 1009 void UpdateAttempter::ActionCompleted(ActionProcessor* processor, argument 1362 LOG(INFO) << "Scheduling an action processor start."; 1436 // processor is idle which it isn't due to the two concurrent ping Omaha 1440 LOG(WARNING) << "Action processor running, Omaha ping suppressed.";
|
/system/update_engine/payload_generator/ |
H A D | full_update_generator.cc | 45 // processor reads a chunk of data from the input file descriptor and compresses 46 // it. The processor will destroy itself when the work is done. 189 for (ChunkProcessor& processor : chunk_processors) 190 thread_pool.AddWork(&processor);
|
/system/sepolicy/ |
H A D | Android.mk | 39 # final newline (0x0A) to be built correctly by the m4(1) macro processor.
|