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

Unified Diff: services/media/framework_mojo/mojo_consumer.cc

Issue 2097953002: Motown: Rename MediaProducer/Consumer to MediaPacketProducer/Consumer (Closed) Base URL: https://github.com/domokit/mojo.git@master
Patch Set: Renamed MojoConsumer and MojoProducer Created 4 years, 6 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
Index: services/media/framework_mojo/mojo_consumer.cc
diff --git a/services/media/framework_mojo/mojo_consumer.cc b/services/media/framework_mojo/mojo_consumer.cc
deleted file mode 100644
index a07a54fb9ab8457667ab769db6201918f05e59e6..0000000000000000000000000000000000000000
--- a/services/media/framework_mojo/mojo_consumer.cc
+++ /dev/null
@@ -1,112 +0,0 @@
-// 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/logging.h"
-#include "base/message_loop/message_loop.h"
-#include "services/media/framework_mojo/mojo_consumer.h"
-
-namespace mojo {
-namespace media {
-
-void MojoConsumerMediaConsumer::Flush(const FlushCallback& callback) {
- MediaConsumerFlush(callback);
-}
-
-MojoConsumer::MojoConsumer() {}
-
-MojoConsumer::~MojoConsumer() {}
-
-void MojoConsumer::AddBinding(InterfaceRequest<MediaConsumer> consumer) {
- bindings_.AddBinding(this, consumer.Pass());
- DCHECK(base::MessageLoop::current());
- task_runner_ = base::MessageLoop::current()->task_runner();
- DCHECK(task_runner_);
-}
-
-void MojoConsumer::SetPrimeRequestedCallback(
- const PrimeRequestedCallback& callback) {
- prime_requested_callback_ = callback;
-}
-
-void MojoConsumer::SetFlushRequestedCallback(
- const FlushRequestedCallback& callback) {
- flush_requested_callback_ = callback;
-}
-
-void MojoConsumer::SetBuffer(ScopedSharedBufferHandle buffer,
- const SetBufferCallback& callback) {
- buffer_.InitFromHandle(buffer.Pass());
- callback.Run();
-}
-
-void MojoConsumer::SendPacket(MediaPacketPtr media_packet,
- const SendPacketCallback& callback) {
- DCHECK(media_packet);
- DCHECK(supply_callback_);
- supply_callback_(
- PacketImpl::Create(media_packet.Pass(), callback, task_runner_, buffer_));
-}
-
-void MojoConsumer::Prime(const PrimeCallback& callback) {
- if (prime_requested_callback_) {
- prime_requested_callback_(callback);
- } else {
- LOG(WARNING) << "prime requested but no callback registered";
- callback.Run();
- }
-}
-
-void MojoConsumer::MediaConsumerFlush(const FlushCallback& callback) {
- if (flush_requested_callback_) {
- flush_requested_callback_(callback);
- } else {
- LOG(WARNING) << "flush requested but no callback registered";
- callback.Run();
- }
-}
-
-bool MojoConsumer::can_accept_allocator() const {
- return false;
-}
-
-void MojoConsumer::set_allocator(PayloadAllocator* allocator) {
- LOG(ERROR) << "set_allocator called on MojoConsumer";
-}
-
-void MojoConsumer::SetSupplyCallback(const SupplyCallback& supply_callback) {
- supply_callback_ = supply_callback;
-}
-
-void MojoConsumer::SetDownstreamDemand(Demand demand) {}
-
-MojoConsumer::PacketImpl::PacketImpl(
- MediaPacketPtr media_packet,
- const SendPacketCallback& callback,
- scoped_refptr<base::SingleThreadTaskRunner> task_runner,
- const MappedSharedBuffer& buffer)
- : Packet(media_packet->pts,
- media_packet->end_of_stream,
- media_packet->payload->length,
- media_packet->payload->length == 0
- ? nullptr
- : buffer.PtrFromOffset(media_packet->payload->offset)),
- media_packet_(media_packet.Pass()),
- callback_(callback),
- task_runner_(task_runner) {}
-
-MojoConsumer::PacketImpl::~PacketImpl() {}
-
-// static
-void MojoConsumer::PacketImpl::RunCallback(const SendPacketCallback& callback) {
- callback.Run(MediaConsumer::SendResult::CONSUMED);
-}
-
-void MojoConsumer::PacketImpl::Release() {
- task_runner_->PostTask(FROM_HERE, base::Bind(&RunCallback, callback_));
- delete this;
-}
-
-} // namespace media
-} // namespace mojo

Powered by Google App Engine
This is Rietveld 408576698