blob: ef74abe2e5269feb837f2d9e4850c6e38ef8d4ad [file] [log] [blame]
// Copyright (c) 2010 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.
// Implements the Demuxer interface using FFmpeg's libavformat. At this time
// will support demuxing any audio/video format thrown at it. The streams
// output mime types audio/x-ffmpeg and video/x-ffmpeg and include an integer
// key FFmpegCodecID which contains the CodecID enumeration value. The CodecIDs
// can be used to create and initialize the corresponding FFmpeg decoder.
// FFmpegDemuxer sets the duration of pipeline during initialization by using
// the duration of the longest audio/video stream.
// NOTE: since FFmpegDemuxer reads packets sequentially without seeking, media
// files with very large drift between audio/video streams may result in
// excessive memory consumption.
// When stopped, FFmpegDemuxer and FFmpegDemuxerStream release all callbacks
// and buffered packets. Reads from a stopped FFmpegDemuxerStream will not be
// replied to.
#include <deque>
#include <vector>
#include "base/callback.h"
#include "base/gtest_prod_util.h"
#include "base/waitable_event.h"
#include "media/base/buffers.h"
#include "media/base/factory.h"
#include "media/base/filters.h"
#include "media/base/media_format.h"
#include "media/filters/ffmpeg_glue.h"
#include "media/filters/ffmpeg_interfaces.h"
// FFmpeg forward declarations.
struct AVFormatContext;
struct AVPacket;
struct AVRational;
struct AVStream;
namespace media {
class BitstreamConverter;
class FFmpegDemuxer;
// Forward declaration for scoped_ptr_malloc.
class ScopedPtrAVFree;
class FFmpegDemuxerStream : public DemuxerStream, public AVStreamProvider {
// Maintains a reference to |demuxer| and initializes itself using information
// inside |stream|.
FFmpegDemuxerStream(FFmpegDemuxer* demuxer, AVStream* stream);
// Returns true is this stream has pending reads, false otherwise.
// Safe to call on any thread.
virtual bool HasPendingReads();
// Enqueues and takes ownership over the given AVPacket.
virtual void EnqueuePacket(AVPacket* packet);
// Signals to empty the buffer queue and mark next packet as discontinuous.
virtual void FlushBuffers();
// Empties the queues and ignores any additional calls to Read().
virtual void Stop();
// Returns the duration of this stream.
virtual base::TimeDelta duration() { return duration_; }
// DemuxerStream implementation.
virtual const MediaFormat& media_format();
virtual void Read(Callback1<Buffer*>::Type* read_callback);
// Bitstream converter to convert input packet.
void EnableBitstreamConverter();
// AVStreamProvider implementation.
virtual AVStream* GetAVStream() { return stream_; }
virtual void* QueryInterface(const char* interface_id);
virtual ~FFmpegDemuxerStream();
// Carries out enqueuing a pending read on the demuxer thread.
void ReadTask(Callback1<Buffer*>::Type* read_callback);
// Attempts to fulfill a single pending read by dequeueing a buffer and read
// callback pair and executing the callback.
void FulfillPendingRead();
// Converts an FFmpeg stream timestamp into a base::TimeDelta.
static base::TimeDelta ConvertStreamTimestamp(const AVRational& time_base,
int64 timestamp);
FFmpegDemuxer* demuxer_;
AVStream* stream_;
MediaFormat media_format_;
base::TimeDelta duration_;
bool discontinuous_;
bool stopped_;
typedef std::deque<scoped_refptr<Buffer> > BufferQueue;
BufferQueue buffer_queue_;
typedef std::deque<Callback1<Buffer*>::Type*> ReadQueue;
ReadQueue read_queue_;
// Used to translate bitstream formats.
scoped_ptr<BitstreamConverter> bitstream_converter_;
class FFmpegDemuxer : public Demuxer,
public FFmpegURLProtocol {
// FilterFactory provider.
static FilterFactory* CreateFilterFactory() {
return new FilterFactoryImpl0<FFmpegDemuxer>();
// Posts a task to perform additional demuxing.
virtual void PostDemuxTask();
// MediaFilter implementation.
virtual void Stop(FilterCallback* callback);
virtual void Seek(base::TimeDelta time, FilterCallback* callback);
virtual void OnAudioRendererDisabled();
// Demuxer implementation.
virtual void Initialize(DataSource* data_source, FilterCallback* callback);
virtual size_t GetNumberOfStreams();
virtual scoped_refptr<DemuxerStream> GetStream(int stream_id);
// FFmpegProtocol implementation.
virtual int Read(int size, uint8* data);
virtual bool GetPosition(int64* position_out);
virtual bool SetPosition(int64 position);
virtual bool GetSize(int64* size_out);
virtual bool IsStreaming();
// Only allow a factory to create this class.
friend class FilterFactoryImpl0<FFmpegDemuxer>;
friend class MockFFmpegDemuxer;
FRIEND_TEST_ALL_PREFIXES(FFmpegDemuxerTest, ProtocolRead);
virtual ~FFmpegDemuxer();
// Carries out initialization on the demuxer thread.
void InitializeTask(DataSource* data_source, FilterCallback* callback);
// Carries out a seek on the demuxer thread.
void SeekTask(base::TimeDelta time, FilterCallback* callback);
// Carries out demuxing and satisfying stream reads on the demuxer thread.
void DemuxTask();
// Carries out stopping the demuxer streams on the demuxer thread.
void StopTask(FilterCallback* callback);
// Carries out disabling the audio stream on the demuxer thread.
void DisableAudioStreamTask();
// Returns true if any of the streams have pending reads. Since we lazily
// post a DemuxTask() for every read, we use this method to quickly terminate
// the tasks if there is no work to do.
// Must be called on the demuxer thread.
bool StreamsHavePendingReads();
// Signal all FFmpegDemuxerStream that the stream has ended.
// Must be called on the demuxer thread.
void StreamHasEnded();
// Read callback method to be passed to DataSource. When the asynchronous
// read has completed, this method will be called from DataSource with
// number of bytes read or kDataSource in case of error.
void OnReadCompleted(size_t size);
// Wait for asynchronous read to complete and return number of bytes read.
virtual size_t WaitForRead();
// Signal that read has completed, and |size| bytes have been read.
virtual void SignalReadCompleted(size_t size);
// FFmpeg context handle.
AVFormatContext* format_context_;
// Two vector of streams:
// - |streams_| is indexed for the Demuxer interface GetStream(), which only
// contains supported streams and no NULL entries.
// - |packet_streams_| is indexed to mirror AVFormatContext when dealing
// with AVPackets returned from av_read_frame() and contain NULL entries
// representing unsupported streams where we throw away the data.
// Ownership is handled via reference counting.
// Once initialized, operations on FFmpegDemuxerStreams should be carried out
// on the demuxer thread.
typedef std::vector< scoped_refptr<FFmpegDemuxerStream> > StreamVector;
StreamVector streams_;
StreamVector packet_streams_;
// Reference to the data source. Asynchronous read requests are submitted to
// this object.
scoped_refptr<DataSource> data_source_;
// This member is used to block on read method calls from FFmpeg and wait
// until the asynchronous reads in the data source to complete. It is also
// signaled when the demuxer is being stopped.
base::WaitableEvent read_event_;
// Flag to indicate if read has ever failed. Once set to true, it will
// never be reset. This flag is set true and accessed in Read().
bool read_has_failed_;
size_t last_read_bytes_;
int64 read_position_;
} // namespace media