source_buffer_stream.h revision eb525c5499e34cc9c4b825d6d9e75bb07cc06ace
15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// SourceBufferStream is a data structure that stores media Buffers in ranges. 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Buffers can be appended out of presentation order. Buffers are retrieved by 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// seeking to the desired start point and calling GetNextBuffer(). Buffers are 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// returned in sequential presentation order. 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#ifndef MEDIA_FILTERS_SOURCE_BUFFER_STREAM_H_ 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#define MEDIA_FILTERS_SOURCE_BUFFER_STREAM_H_ 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <deque> 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <list> 152a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include <string> 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <utility> 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <vector> 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/memory/ref_counted.h" 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "media/base/audio_decoder_config.h" 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "media/base/media_export.h" 222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "media/base/media_log.h" 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "media/base/ranges.h" 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "media/base/stream_parser_buffer.h" 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "media/base/video_decoder_config.h" 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace media { 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class SourceBufferRange; 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// See file-level comment for complete description. 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class MEDIA_EXPORT SourceBufferStream { 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) public: 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) typedef std::deque<scoped_refptr<StreamParserBuffer> > BufferQueue; 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Status returned by GetNextBuffer(). 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // kSuccess: Indicates that the next buffer was returned. 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // kNeedBuffer: Indicates that we need more data before a buffer can be 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // returned. 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // kConfigChange: Indicates that the next buffer requires a config change. 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) enum Status { 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) kSuccess, 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) kNeedBuffer, 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) kConfigChange, 457d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) kEndOfStream 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }; 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SourceBufferStream(const AudioDecoderConfig& audio_config, 492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const LogCB& log_cb); 502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) SourceBufferStream(const VideoDecoderConfig& video_config, 512a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const LogCB& log_cb); 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ~SourceBufferStream(); 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Signals that the next buffers appended are part of a new media segment 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // starting at |media_segment_start_time|. 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnNewMediaSegment(base::TimeDelta media_segment_start_time); 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Add the |buffers| to the SourceBufferStream. Buffers within the queue are 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // expected to be in order, but multiple calls to Append() may add buffers out 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // of order or overlapping. Assumes all buffers within |buffers| are in 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // presentation order and are non-overlapping. 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns true if Append() was successful, false if |buffers| are not added. 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // TODO(vrk): Implement garbage collection. (crbug.com/125070) 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool Append(const BufferQueue& buffers); 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Changes the SourceBufferStream's state so that it will start returning 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // buffers starting from the closest keyframe before |timestamp|. 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void Seek(base::TimeDelta timestamp); 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns true if the SourceBufferStream has seeked to a time without 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // buffered data and is waiting for more data to be appended. 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool IsSeekPending() const; 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Notifies the SourceBufferStream that the media duration has been changed to 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |duration| so it should drop any data past that point. 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnSetDuration(base::TimeDelta duration); 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Fills |out_buffer| with a new buffer. Buffers are presented in order from 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the last call to Seek(), or starting with the first buffer appended if 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Seek() has not been called yet. 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |out_buffer|'s timestamp may be earlier than the |timestamp| passed to 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the last Seek() call. 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns kSuccess if |out_buffer| is filled with a valid buffer, kNeedBuffer 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // if there is not enough data buffered to fulfill the request, and 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // kConfigChange if the next buffer requires a config change. 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Status GetNextBuffer(scoped_refptr<StreamParserBuffer>* out_buffer); 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns a list of the buffered time ranges. 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) Ranges<base::TimeDelta> GetBufferedTime() const; 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 927d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) // Notifies this object that end of stream has been signalled. 937d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) void EndOfStream(); 947d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 957d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) // Cancel the previous end of stream notification. 967d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) void CancelEndOfStream(); 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const AudioDecoderConfig& GetCurrentAudioDecoderConfig(); 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const VideoDecoderConfig& GetCurrentVideoDecoderConfig(); 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Notifies this object that the audio config has changed and buffers in 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // future Append() calls should be associated with this new config. 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool UpdateAudioConfig(const AudioDecoderConfig& config); 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Notifies this object that the video config has changed and buffers in 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // future Append() calls should be associated with this new config. 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool UpdateVideoConfig(const VideoDecoderConfig& config); 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns the largest distance between two adjacent buffers in this stream, 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // or an estimate if no two adjacent buffers have been appended to the stream 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // yet. 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta GetMaxInterbufferDistance() const; 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 114eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch void set_memory_limit_for_testing(int memory_limit) { 115eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch memory_limit_ = memory_limit; 116eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch } 117eb525c5499e34cc9c4b825d6d9e75bb07cc06aceBen Murdoch 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) private: 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) typedef std::list<SourceBufferRange*> RangeList; 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Frees up space if the SourceBufferStream is taking up too much memory. 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void GarbageCollectIfNeeded(); 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Attempts to delete approximately |total_bytes_to_free| amount of data 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |ranges_|, starting at the front of |ranges_| and moving linearly forward 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // through the buffers. Deletes starting from the back if |reverse_direction| 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // is true. Returns the number of bytes freed. 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int FreeBuffers(int total_bytes_to_free, bool reverse_direction); 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Appends |new_buffers| into |range_for_new_buffers_itr|, handling start and 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // end overlaps if necessary. 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |deleted_buffers| is an output parameter containing candidates for 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |track_buffer_|. 1342a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Returns true if the buffers were successfully inserted into the existing 1352a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // range. 1362a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Returns false if the buffers being inserted triggered an error. 1372a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool InsertIntoExistingRange( 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const RangeList::iterator& range_for_new_buffers_itr, 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const BufferQueue& new_buffers, 1402a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) BufferQueue* deleted_buffers); 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Resolve overlapping ranges such that no ranges overlap anymore. 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |range_with_new_buffers_itr| points to the range that has newly appended 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // buffers. 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |deleted_buffers| is an output parameter containing candidates for 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |track_buffer_|. 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void ResolveCompleteOverlaps( 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const RangeList::iterator& range_with_new_buffers_itr, 1492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) BufferQueue* deleted_buffers); 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void ResolveEndOverlap( 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const RangeList::iterator& range_with_new_buffers_itr, 1522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) BufferQueue* deleted_buffers); 1532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 1542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Removes buffers, from the |track_buffer_|, that come after |timestamp|. 1552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void PruneTrackBuffer(const base::TimeDelta timestamp); 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Checks to see if |range_with_new_buffers_itr| can be merged with the range 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // next to it, and merges them if so. 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void MergeWithAdjacentRangeIfNecessary( 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const RangeList::iterator& range_with_new_buffers_itr); 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Deletes the buffers between |start_timestamp|, |end_timestamp| from 1632a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // the range that |range_itr| points to. Deletes between [start,end] if 1642a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // |is_range_exclusive| is true, or (start,end) if |is_range_exclusive| is 1652a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // false. Buffers are deleted in GOPs, so this method may delete buffers past 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |end_timestamp| if the keyframe a buffer depends on was deleted. 1672a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void DeleteBetween(const RangeList::iterator& range_itr, 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta start_timestamp, 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta end_timestamp, 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool is_range_exclusive, 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) BufferQueue* deleted_buffers); 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns true if |second_timestamp| is the timestamp of the next buffer in 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // sequence after |first_timestamp|, false otherwise. 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool AreAdjacentInSequence( 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta first_timestamp, base::TimeDelta second_timestamp) const; 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Helper method that returns the timestamp for the next buffer that 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |selected_range_| will return from GetNextBuffer() call, or kNoTimestamp() 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // if in between seeking (i.e. |selected_range_| is null). 1815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta GetNextBufferTimestamp(); 1825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns the timestamp of the last buffer in the |selected_range_| or 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // kNoTimestamp() if |selected_range_| is null. 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta GetEndBufferTimestamp(); 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Finds the range that should contain a media segment that begins with 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |start_timestamp| and returns the iterator pointing to it. Returns 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |ranges_.end()| if there's no such existing range. 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RangeList::iterator FindExistingRangeFor(base::TimeDelta start_timestamp); 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Inserts |new_range| into |ranges_| preserving sorted order. Returns an 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // iterator in |ranges_| that points to |new_range|. 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RangeList::iterator AddToRanges(SourceBufferRange* new_range); 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns an iterator that points to the place in |ranges_| where 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |selected_range_| lives. 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RangeList::iterator GetSelectedRangeItr(); 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Sets the |selected_range_| to |range| and resets the next buffer position 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // for the previous |selected_range_|. 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void SetSelectedRange(SourceBufferRange* range); 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2042a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Seeks |range| to |seek_timestamp| and then calls SetSelectedRange() with 2052a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // |range|. 2062a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void SeekAndSetSelectedRange(SourceBufferRange* range, 2072a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::TimeDelta seek_timestamp); 2082a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Resets this stream back to an unseeked state. 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void ResetSeekState(); 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns true if |seek_timestamp| refers to the beginning of the first range 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // in |ranges_|, false otherwise or if |ranges_| is empty. 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool ShouldSeekToStartOfBuffered(base::TimeDelta seek_timestamp) const; 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 216c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // Returns true if the |prev_is_keyframe| & |current_is_keyframe| combination 217c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // on buffers with the same timestamp should be allowed. Returns false if the 218c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) // combination should signal an error. 219c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) bool AllowSameTimestamp(bool prev_is_keyframe, 220c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) bool current_is_keyframe) const; 221c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles) 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns true if the timestamps of |buffers| are monotonically increasing 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // since the previous append to the media segment, false otherwise. 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool IsMonotonicallyIncreasing(const BufferQueue& buffers) const; 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns true if |selected_range_| is the only range in |ranges_| that 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // HasNextBufferPosition(). 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool OnlySelectedRangeIsSeeked() const; 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Measures the distances between buffer timestamps and tracks the max. 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void UpdateMaxInterbufferDistance(const BufferQueue& buffers); 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Sets the config ID for each buffer to |append_config_index_|. 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void SetConfigIds(const BufferQueue& buffers); 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Called to complete a config change. Updates |current_config_index_| to 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // match the index of the next buffer. Calling this method causes 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // GetNextBuffer() to stop returning kConfigChange and start returning 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // kSuccess. 2405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void CompleteConfigChange(); 2415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2422a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Sets |selected_range_| and seeks to the nearest keyframe after 2432a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // |timestamp| if necessary and possible. This method only attempts to 2442a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // set |selected_range_| if |seleted_range_| is null and |track_buffer_| 2452a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // is empty. 2462a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) void SetSelectedRangeIfNeeded(const base::TimeDelta timestamp); 2472a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2482a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Find a keyframe timestamp that is >= |start_timestamp| and can be used to 2492a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // find a new selected range. 2502a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Returns kNoTimestamp() if an appropriate keyframe timestamp could not be 2512a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // found. 2522a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::TimeDelta FindNewSelectedRangeSeekTimestamp( 2532a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) const base::TimeDelta start_timestamp); 2542a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2552a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Searches |ranges_| for the first keyframe timestamp that is >= |timestamp|. 2562a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // If |ranges_| doesn't contain a GOP that covers |timestamp| or doesn't 2572a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // have a keyframe after |timestamp| then kNoTimestamp() is returned. 2582a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::TimeDelta FindKeyframeAfterTimestamp(const base::TimeDelta timestamp); 2592a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2602a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Returns "VIDEO" for a video SourceBufferStream and "AUDIO" for an audio 2612a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // one. 2622a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) std::string GetStreamTypeName() const; 2632a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2647d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) // Returns true if we don't have any ranges or the last range is selected 2657d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) // or there is a pending seek beyond any existing ranges. 2667d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) bool IsEndSelected() const; 2677d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 2682a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // Callback used to report error strings that can help the web developer 2692a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // figure out what is wrong with the content. 2702a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) LogCB log_cb_; 2712a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 2725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // List of disjoint buffered ranges, ordered by start time. 2735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RangeList ranges_; 2745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Indicates which decoder config is being used by the decoder. 2765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // GetNextBuffer() is only allows to return buffers that have a 2775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // config ID that matches this index. If there is a mismatch then 2785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // it must signal that a config change is needed. 2795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int current_config_index_; 2805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Indicates which decoder config to associate with new buffers 2825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // being appended. Each new buffer appended has its config ID set 2835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // to the value of this field. 2845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int append_config_index_; 2855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Holds the audio/video configs for this stream. |current_config_index_| 2875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // and |append_config_index_| represent indexes into one of these vectors. 2882a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) std::vector<AudioDecoderConfig> audio_configs_; 2892a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) std::vector<VideoDecoderConfig> video_configs_; 2905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // True if more data needs to be appended before the Seek() can complete, 2925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // false if no Seek() has been requested or the Seek() is completed. 2935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool seek_pending_; 2945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2957d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) // True if the end of the stream has been signalled. 2967d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) bool end_of_stream_; 2977d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) 2985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Timestamp of the last request to Seek(). 2995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta seek_buffer_timestamp_; 3005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Pointer to the seeked-to Range. This is the range from which 3025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // GetNextBuffer() calls are fulfilled after the |track_buffer_| has been 3035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // emptied. 3045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) SourceBufferRange* selected_range_; 3055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Queue of the next buffers to be returned from calls to GetNextBuffer(). If 3075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |track_buffer_| is empty, return buffers from |selected_range_|. 3085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) BufferQueue track_buffer_; 3095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The start time of the current media segment being appended. 3115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta media_segment_start_time_; 3125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Points to the range containing the current media segment being appended. 3145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) RangeList::iterator range_for_next_append_; 3155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // True when the next call to Append() begins a new media segment. 3175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool new_media_segment_; 3185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The timestamp of the last buffer appended to the media segment, set to 3205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // kNoTimestamp() if the beginning of the segment. 3212a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::TimeDelta last_appended_buffer_timestamp_; 3222a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) bool last_appended_buffer_is_keyframe_; 3232a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) 3242a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // The decode timestamp on the last buffer returned by the most recent 3252a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // GetNextBuffer() call. Set to kNoTimestamp() if GetNextBuffer() hasn't been 3262a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) // called yet or a seek has happened since the last GetNextBuffer() call. 3272a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles) base::TimeDelta last_output_buffer_timestamp_; 3285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Stores the largest distance between two adjacent buffers in this stream. 3305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::TimeDelta max_interbuffer_distance_; 3315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The maximum amount of data in bytes the stream will keep in memory. 3335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int memory_limit_; 3345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Indicates that a kConfigChanged status has been reported by GetNextBuffer() 3365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // and GetCurrentXXXDecoderConfig() must be called to update the current 3375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // config. GetNextBuffer() must not be called again until 3385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // GetCurrentXXXDecoderConfig() has been called. 3395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool config_change_pending_; 3405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(SourceBufferStream); 3425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 3435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace media 3455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 3465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif // MEDIA_FILTERS_SOURCE_BUFFER_STREAM_H_ 347