Motown: Various fixes related to video playback support

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 PrimeConnectionCallback& callback) {
   Demand demand;
 
   if (consumer_.is_bound()) {
     base::AutoLock lock(lock_);
-    max_pushes_outstanding_ = 3;  // TODO(dalesat): Made up!
+    max_pushes_outstanding_ = 4;  // TODO(dalesat): Made up!
     demand = current_pushes_outstanding_ < max_pushes_outstanding_
                  ? Demand::kPositive
                  : Demand::kNegative;
   } else {
     demand = Demand::kNeutral;
     if (!mojo_allocator_.initialized()) {
-      mojo_allocator_.InitNew(2048 * 1024);  // TODO(dalesat): Made up!
+      mojo_allocator_.InitNew(4096 * 1024);  // TODO(dalesat): Made up!
     }
   }
 
   DCHECK(demand_callback_);
   demand_callback_(demand);
 
   if (consumer_.is_bound()) {
     consumer_->Prime([this, callback]() { callback.Run(); });
   } else {
     callback.Run();
@@ skipping 59 matching lines @@
   return demand;
 }
 
 void MojoProducer::Connect(InterfaceHandle<MediaConsumer> consumer,
                            const ConnectCallback& callback) {
   DCHECK(consumer);
 
   consumer_ = MediaConsumerPtr::Create(std::move(consumer));
 
   if (!mojo_allocator_.initialized()) {
-    mojo_allocator_.InitNew(2048 * 1024);  // TODO(dalesat): Made up!
+    mojo_allocator_.InitNew(4096 * 1024);  // TODO(dalesat): Made up!
   }
 
   consumer_->SetBuffer(mojo_allocator_.GetDuplicateHandle(),
                        [callback]() { callback.Run(); });
 }
 
 void MojoProducer::Disconnect() {
   DCHECK(demand_callback_);
   demand_callback_(Demand::kNegative);
   consumer_.reset();
@@ skipping 31 matching lines @@
   MediaPacketPtr media_packet = MediaPacket::New();
   media_packet->pts = packet->pts();
   media_packet->end_of_stream = packet->end_of_stream();
   media_packet->payload = region.Pass();
 
   return media_packet.Pass();
 }
 
 }  // namespace media
 }  // namespace mojo