blob: 684c2629b3dabe555e19f48b6327fdcfd1a50fb3 [file] [log] [blame]
// Copyright 2014 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 <memory>
#include "base/callback_forward.h"
#include "base/macros.h"
#include "base/memory/weak_ptr.h"
#include "media/base/demuxer_stream.h"
#include "media/mojo/interfaces/demuxer_stream.mojom.h"
#include "mojo/public/cpp/bindings/binding.h"
namespace media {
class DemuxerStream;
class MojoDecoderBufferWriter;
// This class wraps a media::DemuxerStream and exposes it as a
// mojom::DemuxerStream for use as a proxy from remote applications.
class MojoDemuxerStreamImpl : public mojom::DemuxerStream {
// |stream| is the underlying DemuxerStream we are proxying for.
// Note: |this| does not take ownership of |stream|.
MojoDemuxerStreamImpl(media::DemuxerStream* stream,
mojo::InterfaceRequest<mojom::DemuxerStream> request);
~MojoDemuxerStreamImpl() override;
// mojom::DemuxerStream implementation.
// InitializeCallback and ReadCallback are defined in
// mojom::DemuxerStream.
void Initialize(const InitializeCallback& callback) override;
void Read(const ReadCallback& callback) override;
void EnableBitstreamConverter() override;
// Sets an error handler that will be called if a connection error occurs on
// the bound message pipe.
void set_connection_error_handler(const base::Closure& error_handler) {
using Type = media::DemuxerStream::Type;
using Status = media::DemuxerStream::Status;
void OnBufferReady(const ReadCallback& callback,
Status status,
const scoped_refptr<media::DecoderBuffer>& buffer);
mojo::Binding<mojom::DemuxerStream> binding_;
// See constructor. We do not own |stream_|.
media::DemuxerStream* stream_;
std::unique_ptr<MojoDecoderBufferWriter> mojo_decoder_buffer_writer_;
base::WeakPtrFactory<MojoDemuxerStreamImpl> weak_factory_;
} // namespace media