Take advantage of MojoGetBufferInformation

services/media/framework_mojo/mojo_producer.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "base/bind.h"
 #include "base/bind_helpers.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop.h"
 #include "services/media/framework_mojo/mojo_producer.h"
 
@@ skipping 11 matching lines @@
 
 void MojoProducer::AddBinding(InterfaceRequest<MediaProducer> producer) {
   bindings_.AddBinding(this, producer.Pass());
 }
 
 void MojoProducer::PrimeConnection(const FlushConnectionCallback& callback) {
   Demand demand;
 
   {
     base::AutoLock lock(lock_);
-    max_pushes_outstanding_ = 10; // TODO(dalesat): Made up!
+    max_pushes_outstanding_ = 10;  // TODO(dalesat): Made up!
     demand = current_pushes_outstanding_ < max_pushes_outstanding_ ?
         Demand::kPositive :
         Demand::kNegative;
   }
 
   DCHECK(demand_callback_);
   demand_callback_(demand);
   SetState(MediaState::PAUSED);
 
   DCHECK(consumer_.is_bound());
   consumer_->Prime([this, callback]() {
     callback.Run();
   });
 }
 
 void MojoProducer::FlushConnection(const FlushConnectionCallback& callback) {
   {
     base::AutoLock lock(lock_);
     max_pushes_outstanding_ = 0;
   }
 
   DCHECK(demand_callback_);
   demand_callback_(Demand::kNegative);
 
   DCHECK(consumer_.is_bound());
   consumer_->Flush(callback);
   first_presentation_time_since_flush_ = Packet::kUnknownPresentationTime;
-  end_of_stream_= false;
+  end_of_stream_ = false;
 }
 
 void MojoProducer::SetStatusCallback(
     const StatusCallback& callback) {
   status_callback_ = callback;
 }
 
 int64_t MojoProducer::GetFirstPresentationTimeSinceFlush() {
   return first_presentation_time_since_flush_;
 }
@@ skipping 52 matching lines @@
 }
 
 void MojoProducer::Connect(
     InterfaceHandle<MediaConsumer> consumer,
     const ConnectCallback& callback) {
   DCHECK(consumer);
 
   consumer_ = MediaConsumerPtr::Create(std::move(consumer));
 
   if (!mojo_allocator_.initialized()) {
-    mojo_allocator_.InitNew(256 * 1024); // TODO(dalesat): Made up!
+    mojo_allocator_.InitNew(256 * 1024);  // TODO(dalesat): Made up!
   }
 
   consumer_->SetBuffer(
       mojo_allocator_.GetDuplicateHandle(),
-      mojo_allocator_.size(),
       [callback]() {
     callback.Run();
   });
 }
 
 void MojoProducer::Disconnect() {
   DCHECK(demand_callback_);
   demand_callback_(Demand::kNegative);
   SetState(MediaState::UNPREPARED);
   consumer_.reset();
@@ skipping 44 matching lines @@
 
   MediaPacketPtr media_packet = MediaPacket::New();
   media_packet->pts = packet->presentation_time();
   media_packet->duration = packet->duration();
   media_packet->end_of_stream = packet->end_of_stream();
   media_packet->payload = region.Pass();
 
   return media_packet.Pass();
 }
 
-} // namespace media
-} // namespace mojo
+}  // namespace media
+}  // namespace mojo