| OLD | NEW |
| 1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2009 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 // Implements the Demuxer interface using FFmpeg's libavformat. At this time | 5 // Implements the Demuxer interface using FFmpeg's libavformat. At this time |
| 6 // will support demuxing any audio/video format thrown at it. The streams | 6 // will support demuxing any audio/video format thrown at it. The streams |
| 7 // output mime types audio/x-ffmpeg and video/x-ffmpeg and include an integer | 7 // output mime types audio/x-ffmpeg and video/x-ffmpeg and include an integer |
| 8 // key FFmpegCodecID which contains the CodecID enumeration value. The CodecIDs | 8 // key FFmpegCodecID which contains the CodecID enumeration value. The CodecIDs |
| 9 // can be used to create and initialize the corresponding FFmpeg decoder. | 9 // can be used to create and initialize the corresponding FFmpeg decoder. |
| 10 // | 10 // |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 47 | 47 |
| 48 // Forward declaration for scoped_ptr_malloc. | 48 // Forward declaration for scoped_ptr_malloc. |
| 49 class ScopedPtrAVFree; | 49 class ScopedPtrAVFree; |
| 50 | 50 |
| 51 class FFmpegDemuxerStream : public DemuxerStream, public AVStreamProvider { | 51 class FFmpegDemuxerStream : public DemuxerStream, public AVStreamProvider { |
| 52 public: | 52 public: |
| 53 // Maintains a reference to |demuxer| and initializes itself using information | 53 // Maintains a reference to |demuxer| and initializes itself using information |
| 54 // inside |stream|. | 54 // inside |stream|. |
| 55 FFmpegDemuxerStream(FFmpegDemuxer* demuxer, AVStream* stream); | 55 FFmpegDemuxerStream(FFmpegDemuxer* demuxer, AVStream* stream); |
| 56 | 56 |
| 57 virtual ~FFmpegDemuxerStream(); | |
| 58 | |
| 59 // Returns true is this stream has pending reads, false otherwise. | 57 // Returns true is this stream has pending reads, false otherwise. |
| 60 // | 58 // |
| 61 // Safe to call on any thread. | 59 // Safe to call on any thread. |
| 62 virtual bool HasPendingReads(); | 60 virtual bool HasPendingReads(); |
| 63 | 61 |
| 64 // Enqueues and takes ownership over the given AVPacket, returns the timestamp | 62 // Enqueues and takes ownership over the given AVPacket, returns the timestamp |
| 65 // of the enqueued packet. | 63 // of the enqueued packet. |
| 66 virtual base::TimeDelta EnqueuePacket(AVPacket* packet); | 64 virtual base::TimeDelta EnqueuePacket(AVPacket* packet); |
| 67 | 65 |
| 68 // Signals to empty the buffer queue and mark next packet as discontinuous. | 66 // Signals to empty the buffer queue and mark next packet as discontinuous. |
| 69 virtual void FlushBuffers(); | 67 virtual void FlushBuffers(); |
| 70 | 68 |
| 71 // Empties the queues and ignores any additional calls to Read(). | 69 // Empties the queues and ignores any additional calls to Read(). |
| 72 virtual void Stop(); | 70 virtual void Stop(); |
| 73 | 71 |
| 74 // Returns the duration of this stream. | 72 // Returns the duration of this stream. |
| 75 virtual base::TimeDelta duration() { return duration_; } | 73 virtual base::TimeDelta duration() { return duration_; } |
| 76 | 74 |
| 77 // DemuxerStream implementation. | 75 // DemuxerStream implementation. |
| 78 virtual const MediaFormat& media_format(); | 76 virtual const MediaFormat& media_format(); |
| 79 virtual void Read(Callback1<Buffer*>::Type* read_callback); | 77 virtual void Read(Callback1<Buffer*>::Type* read_callback); |
| 80 | 78 |
| 81 // AVStreamProvider implementation. | 79 // AVStreamProvider implementation. |
| 82 virtual AVStream* GetAVStream() { return stream_; } | 80 virtual AVStream* GetAVStream() { return stream_; } |
| 83 | 81 |
| 84 protected: | 82 protected: |
| 85 virtual void* QueryInterface(const char* interface_id); | 83 virtual void* QueryInterface(const char* interface_id); |
| 86 | 84 |
| 87 private: | 85 private: |
| 86 virtual ~FFmpegDemuxerStream(); |
| 87 |
| 88 // Carries out enqueuing a pending read on the demuxer thread. | 88 // Carries out enqueuing a pending read on the demuxer thread. |
| 89 void ReadTask(Callback1<Buffer*>::Type* read_callback); | 89 void ReadTask(Callback1<Buffer*>::Type* read_callback); |
| 90 | 90 |
| 91 // Attempts to fulfill a single pending read by dequeueing a buffer and read | 91 // Attempts to fulfill a single pending read by dequeueing a buffer and read |
| 92 // callback pair and executing the callback. | 92 // callback pair and executing the callback. |
| 93 void FulfillPendingRead(); | 93 void FulfillPendingRead(); |
| 94 | 94 |
| 95 // Converts an FFmpeg stream timestamp into a base::TimeDelta. | 95 // Converts an FFmpeg stream timestamp into a base::TimeDelta. |
| 96 base::TimeDelta ConvertTimestamp(int64 timestamp); | 96 base::TimeDelta ConvertTimestamp(int64 timestamp); |
| 97 | 97 |
| (...skipping 128 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 226 // If true, then it's our first seek and we won't call av_read_frame(). It's | 226 // If true, then it's our first seek and we won't call av_read_frame(). It's |
| 227 // a hack to get around some issue with FFmpeg. | 227 // a hack to get around some issue with FFmpeg. |
| 228 bool first_seek_hack_; | 228 bool first_seek_hack_; |
| 229 | 229 |
| 230 DISALLOW_COPY_AND_ASSIGN(FFmpegDemuxer); | 230 DISALLOW_COPY_AND_ASSIGN(FFmpegDemuxer); |
| 231 }; | 231 }; |
| 232 | 232 |
| 233 } // namespace media | 233 } // namespace media |
| 234 | 234 |
| 235 #endif // MEDIA_FILTERS_FFMPEG_DEMUXER_H_ | 235 #endif // MEDIA_FILTERS_FFMPEG_DEMUXER_H_ |
| OLD | NEW |