OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
67 // Enters the end of stream state. After delivering remaining queued buffers | 67 // Enters the end of stream state. After delivering remaining queued buffers |
68 // only end of stream buffers will be delivered. | 68 // only end of stream buffers will be delivered. |
69 void SetEndOfStream(); | 69 void SetEndOfStream(); |
70 | 70 |
71 // Drops queued buffers and clears end of stream state. | 71 // Drops queued buffers and clears end of stream state. |
72 void FlushBuffers(); | 72 void FlushBuffers(); |
73 | 73 |
74 // Empties the queues and ignores any additional calls to Read(). | 74 // Empties the queues and ignores any additional calls to Read(). |
75 void Stop(); | 75 void Stop(); |
76 | 76 |
77 // Returns the duration of this stream. | 77 base::TimeDelta duration() const { return duration_; } |
78 base::TimeDelta duration(); | |
79 | 78 |
80 // DemuxerStream implementation. | 79 // DemuxerStream implementation. |
81 virtual Type type() OVERRIDE; | 80 virtual Type type() OVERRIDE; |
82 virtual void Read(const ReadCB& read_cb) OVERRIDE; | 81 virtual void Read(const ReadCB& read_cb) OVERRIDE; |
83 virtual void EnableBitstreamConverter() OVERRIDE; | 82 virtual void EnableBitstreamConverter() OVERRIDE; |
84 virtual bool SupportsConfigChanges() OVERRIDE; | 83 virtual bool SupportsConfigChanges() OVERRIDE; |
85 virtual AudioDecoderConfig audio_decoder_config() OVERRIDE; | 84 virtual AudioDecoderConfig audio_decoder_config() OVERRIDE; |
86 virtual VideoDecoderConfig video_decoder_config() OVERRIDE; | 85 virtual VideoDecoderConfig video_decoder_config() OVERRIDE; |
87 | 86 |
88 // Returns the range of buffered data in this stream. | 87 // Returns the range of buffered data in this stream. |
89 Ranges<base::TimeDelta> GetBufferedRanges() const; | 88 Ranges<base::TimeDelta> GetBufferedRanges() const; |
90 | 89 |
91 // Returns elapsed time based on the already queued packets. | 90 // Returns elapsed time based on the already queued packets. |
92 // Used to determine stream duration when it's not known ahead of time. | 91 // Used to determine stream duration when it's not known ahead of time. |
93 base::TimeDelta GetElapsedTime() const; | 92 base::TimeDelta GetElapsedTime() const; |
94 | 93 |
95 // Returns true if this stream has capacity for additional data. | 94 // Returns true if this stream has capacity for additional data. |
96 bool HasAvailableCapacity(); | 95 bool HasAvailableCapacity(); |
97 | 96 |
98 // Returns the total buffer size FFMpegDemuxerStream is holding onto. | 97 // Returns the total buffer size FFMpegDemuxerStream is holding onto. |
99 size_t MemoryUsage() const; | 98 size_t MemoryUsage() const; |
100 | 99 |
101 TextKind GetTextKind() const; | 100 TextKind GetTextKind() const; |
102 | 101 |
103 // Returns the value associated with |key| in the metadata for the avstream. | 102 // Returns the value associated with |key| in the metadata for the avstream. |
104 // Returns an empty string if the key is not present. | 103 // Returns an empty string if the key is not present. |
105 std::string GetMetadata(const char* key) const; | 104 std::string GetMetadata(const char* key) const; |
106 | 105 |
| 106 // Tells the DemuxerStream that all packets with negative timestamps should be |
| 107 // marked for post-decode discard. |
| 108 void enable_negative_timestamp_discard() { |
| 109 discard_negative_timestamps_ = true; |
| 110 } |
| 111 |
107 private: | 112 private: |
108 friend class FFmpegDemuxerTest; | 113 friend class FFmpegDemuxerTest; |
109 | 114 |
110 // Runs |read_cb_| if present with the front of |buffer_queue_|, calling | 115 // Runs |read_cb_| if present with the front of |buffer_queue_|, calling |
111 // NotifyCapacityAvailable() if capacity is still available. | 116 // NotifyCapacityAvailable() if capacity is still available. |
112 void SatisfyPendingRead(); | 117 void SatisfyPendingRead(); |
113 | 118 |
114 // Converts an FFmpeg stream timestamp into a base::TimeDelta. | 119 // Converts an FFmpeg stream timestamp into a base::TimeDelta. |
115 static base::TimeDelta ConvertStreamTimestamp(const AVRational& time_base, | 120 static base::TimeDelta ConvertStreamTimestamp(const AVRational& time_base, |
116 int64 timestamp); | 121 int64 timestamp); |
(...skipping 12 matching lines...) Expand all Loading... |
129 DecoderBufferQueue buffer_queue_; | 134 DecoderBufferQueue buffer_queue_; |
130 ReadCB read_cb_; | 135 ReadCB read_cb_; |
131 | 136 |
132 #if defined(USE_PROPRIETARY_CODECS) | 137 #if defined(USE_PROPRIETARY_CODECS) |
133 scoped_ptr<FFmpegH264ToAnnexBBitstreamConverter> bitstream_converter_; | 138 scoped_ptr<FFmpegH264ToAnnexBBitstreamConverter> bitstream_converter_; |
134 #endif | 139 #endif |
135 | 140 |
136 bool bitstream_converter_enabled_; | 141 bool bitstream_converter_enabled_; |
137 | 142 |
138 std::string encryption_key_id_; | 143 std::string encryption_key_id_; |
| 144 bool discard_negative_timestamps_; |
139 | 145 |
140 DISALLOW_COPY_AND_ASSIGN(FFmpegDemuxerStream); | 146 DISALLOW_COPY_AND_ASSIGN(FFmpegDemuxerStream); |
141 }; | 147 }; |
142 | 148 |
143 class MEDIA_EXPORT FFmpegDemuxer : public Demuxer { | 149 class MEDIA_EXPORT FFmpegDemuxer : public Demuxer { |
144 public: | 150 public: |
145 FFmpegDemuxer(const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, | 151 FFmpegDemuxer(const scoped_refptr<base::SingleThreadTaskRunner>& task_runner, |
146 DataSource* data_source, | 152 DataSource* data_source, |
147 const NeedKeyCB& need_key_cb, | 153 const NeedKeyCB& need_key_cb, |
148 const scoped_refptr<MediaLog>& media_log); | 154 const scoped_refptr<MediaLog>& media_log); |
149 virtual ~FFmpegDemuxer(); | 155 virtual ~FFmpegDemuxer(); |
150 | 156 |
151 // Demuxer implementation. | 157 // Demuxer implementation. |
152 virtual void Initialize(DemuxerHost* host, | 158 virtual void Initialize(DemuxerHost* host, |
153 const PipelineStatusCB& status_cb, | 159 const PipelineStatusCB& status_cb, |
154 bool enable_text_tracks) OVERRIDE; | 160 bool enable_text_tracks) OVERRIDE; |
155 virtual void Stop(const base::Closure& callback) OVERRIDE; | 161 virtual void Stop(const base::Closure& callback) OVERRIDE; |
156 virtual void Seek(base::TimeDelta time, const PipelineStatusCB& cb) OVERRIDE; | 162 virtual void Seek(base::TimeDelta time, const PipelineStatusCB& cb) OVERRIDE; |
157 virtual DemuxerStream* GetStream(DemuxerStream::Type type) OVERRIDE; | 163 virtual DemuxerStream* GetStream(DemuxerStream::Type type) OVERRIDE; |
158 virtual base::TimeDelta GetStartTime() const OVERRIDE; | |
159 virtual base::Time GetTimelineOffset() const OVERRIDE; | 164 virtual base::Time GetTimelineOffset() const OVERRIDE; |
160 virtual Liveness GetLiveness() const OVERRIDE; | 165 virtual Liveness GetLiveness() const OVERRIDE; |
161 | 166 |
162 // Calls |need_key_cb_| with the initialization data encountered in the file. | 167 // Calls |need_key_cb_| with the initialization data encountered in the file. |
163 void FireNeedKey(const std::string& init_data_type, | 168 void FireNeedKey(const std::string& init_data_type, |
164 const std::string& encryption_key_id); | 169 const std::string& encryption_key_id); |
165 | 170 |
166 // Allow FFmpegDemuxerStream to notify us when there is updated information | 171 // Allow FFmpegDemuxerStream to notify us when there is updated information |
167 // about capacity and what buffered data is available. | 172 // about capacity and what buffered data is available. |
168 void NotifyCapacityAvailable(); | 173 void NotifyCapacityAvailable(); |
169 void NotifyBufferingChanged(); | 174 void NotifyBufferingChanged(); |
170 | 175 |
| 176 // The lowest demuxed timestamp. DemuxerStream's must use this to adjust |
| 177 // packet timestamps such that external clients see a zero-based timeline. |
| 178 base::TimeDelta start_time() const { return start_time_; } |
| 179 |
171 private: | 180 private: |
172 // To allow tests access to privates. | 181 // To allow tests access to privates. |
173 friend class FFmpegDemuxerTest; | 182 friend class FFmpegDemuxerTest; |
174 | 183 |
175 // FFmpeg callbacks during initialization. | 184 // FFmpeg callbacks during initialization. |
176 void OnOpenContextDone(const PipelineStatusCB& status_cb, bool result); | 185 void OnOpenContextDone(const PipelineStatusCB& status_cb, bool result); |
177 void OnFindStreamInfoDone(const PipelineStatusCB& status_cb, int result); | 186 void OnFindStreamInfoDone(const PipelineStatusCB& status_cb, int result); |
178 | 187 |
179 // FFmpeg callbacks during seeking. | 188 // FFmpeg callbacks during seeking. |
180 void OnSeekFrameDone(const PipelineStatusCB& cb, int result); | 189 void OnSeekFrameDone(const PipelineStatusCB& cb, int result); |
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
238 | 247 |
239 // Provides asynchronous IO to this demuxer. Consumed by |url_protocol_| to | 248 // Provides asynchronous IO to this demuxer. Consumed by |url_protocol_| to |
240 // integrate with libavformat. | 249 // integrate with libavformat. |
241 DataSource* data_source_; | 250 DataSource* data_source_; |
242 | 251 |
243 scoped_refptr<MediaLog> media_log_; | 252 scoped_refptr<MediaLog> media_log_; |
244 | 253 |
245 // Derived bitrate after initialization has completed. | 254 // Derived bitrate after initialization has completed. |
246 int bitrate_; | 255 int bitrate_; |
247 | 256 |
248 // The first timestamp of the opened media file. This is used to set the | 257 // The first timestamp of the audio or video stream, whichever is lower. This |
249 // starting clock value to match the timestamps in the media file. Default | 258 // is used to adjust timestamps so that external consumers always see a zero |
250 // is 0. | 259 // based timeline. |
251 base::TimeDelta start_time_; | 260 base::TimeDelta start_time_; |
252 | 261 |
253 // The Time associated with timestamp 0. Set to a null | 262 // The Time associated with timestamp 0. Set to a null |
254 // time if the file doesn't have an association to Time. | 263 // time if the file doesn't have an association to Time. |
255 base::Time timeline_offset_; | 264 base::Time timeline_offset_; |
256 | 265 |
257 // Liveness of the stream. | 266 // Liveness of the stream. |
258 Liveness liveness_; | 267 Liveness liveness_; |
259 | 268 |
260 // Whether text streams have been enabled for this demuxer. | 269 // Whether text streams have been enabled for this demuxer. |
261 bool text_enabled_; | 270 bool text_enabled_; |
262 | 271 |
263 // Set if we know duration of the audio stream. Used when processing end of | 272 // Set if we know duration of the audio stream. Used when processing end of |
264 // stream -- at this moment we definitely know duration. | 273 // stream -- at this moment we definitely know duration. |
265 bool duration_known_; | 274 bool duration_known_; |
266 | 275 |
267 // FFmpegURLProtocol implementation and corresponding glue bits. | 276 // FFmpegURLProtocol implementation and corresponding glue bits. |
268 scoped_ptr<BlockingUrlProtocol> url_protocol_; | 277 scoped_ptr<BlockingUrlProtocol> url_protocol_; |
269 scoped_ptr<FFmpegGlue> glue_; | 278 scoped_ptr<FFmpegGlue> glue_; |
270 | 279 |
271 const NeedKeyCB need_key_cb_; | 280 const NeedKeyCB need_key_cb_; |
272 | 281 |
| 282 // The index of the stream in |streams_| to use for seeking. Chosen by the |
| 283 // stream with the lowest starting timestamp. |
| 284 int stream_index_for_seeking_; |
| 285 |
273 // NOTE: Weak pointers must be invalidated before all other member variables. | 286 // NOTE: Weak pointers must be invalidated before all other member variables. |
274 base::WeakPtrFactory<FFmpegDemuxer> weak_factory_; | 287 base::WeakPtrFactory<FFmpegDemuxer> weak_factory_; |
275 | 288 |
276 DISALLOW_COPY_AND_ASSIGN(FFmpegDemuxer); | 289 DISALLOW_COPY_AND_ASSIGN(FFmpegDemuxer); |
277 }; | 290 }; |
278 | 291 |
279 } // namespace media | 292 } // namespace media |
280 | 293 |
281 #endif // MEDIA_FILTERS_FFMPEG_DEMUXER_H_ | 294 #endif // MEDIA_FILTERS_FFMPEG_DEMUXER_H_ |
OLD | NEW |