Searched refs:processor (Results 1 - 18 of 18) sorted by relevance

/system/update_engine/payload_consumer/
H A Dfilesystem_verifier_action_unittest.cc85 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 Ddownload_action_unittest.cc73 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 Dpostinstall_runner_action_unittest.cc53 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 Daction_unittest.cc45 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 Daction_processor_unittest.cc48 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 Daction_processor.h88 // 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 Daction.h54 // 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 Dutils.h436 explicit ScopedActionCompleter(ActionProcessor* processor, argument
438 : processor_(processor),
/system/connectivity/shill/shims/
H A Dnetfilter_queue_helper.cc126 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 Dnetfilter_queue_processor.cc149 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 Dupdate_attempter_android.h72 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 Domaha_response_handler_action_unittest.cc68 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 Dupdate_attempter.h96 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 Domaha_request_action_unittest.cc247 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 Dupdate_attempter_android.cc254 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 Dupdate_attempter.cc916 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 Dfull_update_generator.cc45 // 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 DAndroid.mk39 # final newline (0x0A) to be built correctly by the m4(1) macro processor.

Completed in 307 milliseconds