Index: services/media/framework/stages/transform_stage.cc |
diff --git a/services/media/framework/stages/transform_stage.cc b/services/media/framework/stages/transform_stage.cc |
index dce82545d8eec7cb2273052ebbd0079ebe28792d..cca753c19caa302acfc6b4c4ba81f5c374c8a053 100644 |
--- a/services/media/framework/stages/transform_stage.cc |
+++ b/services/media/framework/stages/transform_stage.cc |
@@ -7,11 +7,8 @@ |
namespace mojo { |
namespace media { |
-TransformStage::TransformStage( |
- std::shared_ptr<Transform> transform) : |
- transform_(transform), |
- allocator_(nullptr), |
- input_packet_is_new_(true) { |
+TransformStage::TransformStage(std::shared_ptr<Transform> transform) |
+ : transform_(transform), allocator_(nullptr), input_packet_is_new_(true) { |
DCHECK(transform_); |
} |
@@ -40,10 +37,9 @@ PayloadAllocator* TransformStage::PrepareInput(size_t index) { |
return nullptr; |
} |
-void TransformStage::PrepareOutput( |
- size_t index, |
- PayloadAllocator* allocator, |
- const UpstreamCallback& callback) { |
+void TransformStage::PrepareOutput(size_t index, |
+ PayloadAllocator* allocator, |
+ const UpstreamCallback& callback) { |
DCHECK_EQ(index, 0u); |
allocator_ = |
@@ -52,9 +48,8 @@ void TransformStage::PrepareOutput( |
callback(0); |
} |
-void TransformStage::UnprepareOutput( |
- size_t index, |
- const UpstreamCallback& callback) { |
+void TransformStage::UnprepareOutput(size_t index, |
+ const UpstreamCallback& callback) { |
allocator_ = nullptr; |
callback(0); |
} |
@@ -65,11 +60,9 @@ void TransformStage::Update(Engine* engine) { |
if (input_.packet_from_upstream() && output_.demand() != Demand::kNegative) { |
PacketPtr output_packet; |
- if (transform_->TransformPacket( |
- input_.packet_from_upstream(), |
- input_packet_is_new_, |
- allocator_, |
- &output_packet)) { |
+ if (transform_->TransformPacket(input_.packet_from_upstream(), |
+ input_packet_is_new_, allocator_, |
+ &output_packet)) { |
input_.packet_from_upstream().reset(); |
input_packet_is_new_ = true; |
} else { |
@@ -84,9 +77,8 @@ void TransformStage::Update(Engine* engine) { |
input_.SetDemand(output_.demand(), engine); |
} |
-void TransformStage::FlushInput( |
- size_t index, |
- const DownstreamCallback& callback) { |
+void TransformStage::FlushInput(size_t index, |
+ const DownstreamCallback& callback) { |
DCHECK_EQ(index, 0u); |
input_.Flush(); |
callback(0); |