Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(535)

Unified Diff: services/media/framework/engine.cc

Issue 1822333002: Motown: wholesale clang-format (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: dalesat Created 4 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « services/media/framework/engine.h ('k') | services/media/framework/formatting.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: services/media/framework/engine.cc
diff --git a/services/media/framework/engine.cc b/services/media/framework/engine.cc
index 642191334b8d38aacf2da17cbaac59accc09be5e..9035a88054c150f45e36f74342992a711e49d863 100644
--- a/services/media/framework/engine.cc
+++ b/services/media/framework/engine.cc
@@ -14,43 +14,34 @@ Engine::~Engine() {
}
void Engine::PrepareInput(const InputRef& input) {
- VisitUpstream(
- input,
- [] (const InputRef& input,
- const OutputRef& output,
- const Stage::UpstreamCallback& callback) {
- DCHECK(!input.actual().prepared());
- PayloadAllocator* allocator = input.stage_->PrepareInput(input.index_);
- input.actual().set_prepared(true);
- output.stage_->PrepareOutput(output.index_, allocator, callback);
- });
+ VisitUpstream(input, [](const InputRef& input, const OutputRef& output,
+ const Stage::UpstreamCallback& callback) {
+ DCHECK(!input.actual().prepared());
+ PayloadAllocator* allocator = input.stage_->PrepareInput(input.index_);
+ input.actual().set_prepared(true);
+ output.stage_->PrepareOutput(output.index_, allocator, callback);
+ });
}
void Engine::UnprepareInput(const InputRef& input) {
- VisitUpstream(
- input,
- [] (const InputRef& input,
- const OutputRef& output,
- const Stage::UpstreamCallback& callback) {
- DCHECK(input.actual().prepared());
- input.stage_->UnprepareInput(input.index_);
- output.stage_->UnprepareOutput(output.index_, callback);
- });
+ VisitUpstream(input, [](const InputRef& input, const OutputRef& output,
+ const Stage::UpstreamCallback& callback) {
+ DCHECK(input.actual().prepared());
+ input.stage_->UnprepareInput(input.index_);
+ output.stage_->UnprepareOutput(output.index_, callback);
+ });
}
void Engine::FlushOutput(const OutputRef& output) {
if (!output.connected()) {
return;
}
- VisitDownstream(
- output,
- [] (const OutputRef& output,
- const InputRef& input,
- const Stage::DownstreamCallback& callback) {
- DCHECK(input.actual().prepared());
- output.stage_->FlushOutput(output.index_);
- input.stage_->FlushInput(input.index_, callback);
- });
+ VisitDownstream(output, [](const OutputRef& output, const InputRef& input,
+ const Stage::DownstreamCallback& callback) {
+ DCHECK(input.actual().prepared());
+ output.stage_->FlushOutput(output.index_);
+ input.stage_->FlushInput(input.index_, callback);
+ });
}
void Engine::RequestUpdate(Stage* stage) {
@@ -81,9 +72,8 @@ void Engine::PushToDemandBacklog(Stage* stage) {
}
}
-void Engine::VisitUpstream(
- const InputRef& input,
- const UpstreamVisitor& vistor) {
+void Engine::VisitUpstream(const InputRef& input,
+ const UpstreamVisitor& vistor) {
base::AutoLock lock(lock_);
std::queue<InputRef> backlog;
@@ -98,18 +88,14 @@ void Engine::VisitUpstream(
const OutputRef& output = input.mate();
Stage* output_stage = output.stage_;
- vistor(
- input,
- output,
- [output_stage, &backlog](size_t input_index) {
- backlog.push(InputRef(output_stage, input_index));
- });
+ vistor(input, output, [output_stage, &backlog](size_t input_index) {
+ backlog.push(InputRef(output_stage, input_index));
+ });
}
}
-void Engine::VisitDownstream(
- const OutputRef& output,
- const DownstreamVisitor& vistor) {
+void Engine::VisitDownstream(const OutputRef& output,
+ const DownstreamVisitor& vistor) {
base::AutoLock lock(lock_);
std::queue<OutputRef> backlog;
@@ -124,12 +110,9 @@ void Engine::VisitDownstream(
const InputRef& input = output.mate();
Stage* input_stage = input.stage_;
- vistor(
- output,
- input,
- [input_stage, &backlog](size_t output_index) {
- backlog.push(OutputRef(input_stage, output_index));
- });
+ vistor(output, input, [input_stage, &backlog](size_t output_index) {
+ backlog.push(OutputRef(input_stage, output_index));
+ });
}
}
@@ -153,7 +136,7 @@ void Engine::Update() {
}
}
-void Engine::Update(Stage *stage) {
+void Engine::Update(Stage* stage) {
lock_.AssertAcquired();
DCHECK(stage);
« no previous file with comments | « services/media/framework/engine.h ('k') | services/media/framework/formatting.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698