Refactored DecoderBuffer to use unix_hacker_style naming.

media/filters/chunk_demuxer.cc

 // Copyright (c) 2012 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 "media/filters/chunk_demuxer.h"
 
 #include <algorithm>
 #include <deque>
 #include <limits>
 
@@ skipping 30 matching lines @@
   // Returns true if the data was successfully appended. Returns false if an
   // error occurred.
   bool Append(const uint8* data, size_t length);
 
   // Aborts the current append sequence and resets the parser.
   void Abort();
 
   // Sets |timestamp_offset_| if possible.
   // Returns if the offset was set. Returns false if the offset could not be
   // updated at this time.
-  bool SetTimestampOffset(TimeDelta timestamp_offset);
+  bool set_timestampOffset(TimeDelta timestamp_offset);
 
   TimeDelta timestamp_offset() const { return timestamp_offset_; }
 
  private:
   // Called by the |stream_parser_| at the beginning of a new media segment.
   // |timestamp| is the timestamp on the first buffer in the segment.
   // It modifies the state of this object and then calls |new_segment_cb| with
   // modified version of |timestamp|.
   void OnNewMediaSegment(const StreamParser::NewMediaSegmentCB& new_segment_cb,
                          TimeDelta timestamp);
@@ skipping 27 matching lines @@
   // Keeps track of whether |timestamp_offset_| can be modified.
   bool can_update_offset_;
 
   // The object used to parse appended data.
   scoped_ptr<StreamParser> stream_parser_;
 
   DISALLOW_COPY_AND_ASSIGN(SourceState);
 };
 
 SourceState::SourceState(scoped_ptr<StreamParser> stream_parser)
-    : can_update_offset_(true),
-      stream_parser_(stream_parser.release()) {
-}
+    : can_update_offset_(true), stream_parser_(stream_parser.release()) {}
 
 void SourceState::Init(const StreamParser::InitCB& init_cb,
                        const StreamParser::NewConfigCB& config_cb,
                        const StreamParser::NewBuffersCB& audio_cb,
                        const StreamParser::NewBuffersCB& video_cb,
                        const StreamParser::NewTextBuffersCB& text_cb,
                        const StreamParser::NeedKeyCB& need_key_cb,
                        const AddTextTrackCB& add_text_track_cb,
                        const StreamParser::NewMediaSegmentCB& new_segment_cb,
                        const LogCB& log_cb) {
-  stream_parser_->Init(init_cb, config_cb,
-                       base::Bind(&SourceState::OnBuffers,
-                                  base::Unretained(this), audio_cb),
-                       base::Bind(&SourceState::OnBuffers,
-                                  base::Unretained(this), video_cb),
-                       base::Bind(&SourceState::OnTextBuffers,
-                                  base::Unretained(this), text_cb),
-                       need_key_cb,
-                       add_text_track_cb,
-                       base::Bind(&SourceState::OnNewMediaSegment,
-                                  base::Unretained(this), new_segment_cb),
-                       base::Bind(&SourceState::OnEndOfMediaSegment,
-                                  base::Unretained(this)),
-                       log_cb);
+  stream_parser_->Init(
+      init_cb, config_cb,
+      base::Bind(&SourceState::OnBuffers, base::Unretained(this), audio_cb),
+      base::Bind(&SourceState::OnBuffers, base::Unretained(this), video_cb),
+      base::Bind(&SourceState::OnTextBuffers, base::Unretained(this), text_cb),
+      need_key_cb, add_text_track_cb,
+      base::Bind(&SourceState::OnNewMediaSegment, base::Unretained(this),
+                 new_segment_cb),
+      base::Bind(&SourceState::OnEndOfMediaSegment, base::Unretained(this)),
+      log_cb);
 }
 
-bool SourceState::SetTimestampOffset(TimeDelta timestamp_offset) {
-  if (!can_update_offset_)
-    return false;
+bool SourceState::set_timestampOffset(TimeDelta timestamp_offset) {
+  if (!can_update_offset_) return false;
 
   timestamp_offset_ = timestamp_offset;
   return true;
 }
 
 bool SourceState::Append(const uint8* data, size_t length) {
   return stream_parser_->Parse(data, length);
 }
 
 void SourceState::Abort() {
   stream_parser_->Flush();
   can_update_offset_ = true;
 }
 
 void SourceState::AdjustBufferTimestamps(
     const StreamParser::BufferQueue& buffers) {
-  if (timestamp_offset_ == TimeDelta())
-    return;
+  if (timestamp_offset_ == TimeDelta()) return;
 
   for (StreamParser::BufferQueue::const_iterator itr = buffers.begin();
        itr != buffers.end(); ++itr) {
-    (*itr)->SetDecodeTimestamp(
-        (*itr)->GetDecodeTimestamp() + timestamp_offset_);
-    (*itr)->SetTimestamp((*itr)->GetTimestamp() + timestamp_offset_);
+    (*itr)
+        ->SetDecodeTimestamp((*itr)->GetDecodeTimestamp() + timestamp_offset_);
+    (*itr)->set_timestamp((*itr)->get_timestamp() + timestamp_offset_);
   }
 }
 
 void SourceState::OnNewMediaSegment(
     const StreamParser::NewMediaSegmentCB& new_segment_cb,
     TimeDelta timestamp) {
   DCHECK(timestamp != kNoTimestamp());
   DVLOG(2) << "OnNewMediaSegment(" << timestamp.InSecondsF() << ")";
 
   can_update_offset_ = false;
   new_segment_cb.Run(timestamp + timestamp_offset_);
 }
 
 void SourceState::OnEndOfMediaSegment() {
   DVLOG(2) << "OnEndOfMediaSegment()";
   can_update_offset_ = true;
 }
 
 bool SourceState::OnBuffers(const StreamParser::NewBuffersCB& new_buffers_cb,
                             const StreamParser::BufferQueue& buffers) {
-  if (new_buffers_cb.is_null())
-    return false;
+  if (new_buffers_cb.is_null()) return false;
 
   AdjustBufferTimestamps(buffers);
 
   return new_buffers_cb.Run(buffers);
 }
 
 bool SourceState::OnTextBuffers(
-    const StreamParser::NewTextBuffersCB& new_buffers_cb,
-    TextTrack* text_track,
+    const StreamParser::NewTextBuffersCB& new_buffers_cb, TextTrack* text_track,
     const StreamParser::BufferQueue& buffers) {
-  if (new_buffers_cb.is_null())
-    return false;
+  if (new_buffers_cb.is_null()) return false;
 
   AdjustBufferTimestamps(buffers);
 
   return new_buffers_cb.Run(text_track, buffers);
 }
 
 class ChunkDemuxerStream : public DemuxerStream {
  public:
   typedef std::deque<scoped_refptr<StreamParserBuffer> > BufferQueue;
   typedef std::deque<ReadCB> ReadCBQueue;
   typedef std::deque<base::Closure> ClosureQueue;
 
   ChunkDemuxerStream(const AudioDecoderConfig& audio_config,
                      const LogCB& log_cb);
   ChunkDemuxerStream(const VideoDecoderConfig& video_config,
                      const LogCB& log_cb);
   virtual ~ChunkDemuxerStream();
 
   void StartWaitingForSeek();
   void Seek(TimeDelta time);
   void CancelPendingSeek();
   bool IsSeekPending() const;
 
   // Add buffers to this stream.  Buffers are stored in SourceBufferStreams,
   // which handle ordering and overlap resolution.
   // Returns true if buffers were successfully added.
   bool Append(const StreamParser::BufferQueue& buffers);
 
   // Signal to the stream that duration has changed to |duration|.
-  void OnSetDuration(base::TimeDelta duration);
+  void Onset_duration(base::TimeDelta duration);
 
   // Returns the range of buffered data in this stream, capped at |duration|.
   Ranges<TimeDelta> GetBufferedRanges(base::TimeDelta duration) const;
 
   // Signal to the stream that buffers handed in through subsequent calls to
   // Append() belong to a media segment that starts at |start_timestamp|.
   void OnNewMediaSegment(TimeDelta start_timestamp);
 
   // Called when midstream config updates occur.
   // Returns true if the new config is accepted.
@@ skipping 45 matching lines @@
 
   mutable base::Lock lock_;
   State state_;
   ReadCBQueue read_cbs_;
 
   DISALLOW_IMPLICIT_CONSTRUCTORS(ChunkDemuxerStream);
 };
 
 ChunkDemuxerStream::ChunkDemuxerStream(const AudioDecoderConfig& audio_config,
                                        const LogCB& log_cb)
-    : type_(AUDIO),
-      state_(RETURNING_DATA_FOR_READS) {
+    : type_(AUDIO), state_(RETURNING_DATA_FOR_READS) {
   stream_.reset(new SourceBufferStream(audio_config, log_cb));
 }
 
 ChunkDemuxerStream::ChunkDemuxerStream(const VideoDecoderConfig& video_config,
                                        const LogCB& log_cb)
-    : type_(VIDEO),
-      state_(RETURNING_DATA_FOR_READS) {
+    : type_(VIDEO), state_(RETURNING_DATA_FOR_READS) {
   stream_.reset(new SourceBufferStream(video_config, log_cb));
 }
 
 void ChunkDemuxerStream::StartWaitingForSeek() {
   DVLOG(1) << "ChunkDemuxerStream::StartWaitingForSeek()";
   ReadCBQueue read_cbs;
   {
     base::AutoLock auto_lock(lock_);
     ChangeState_Locked(WAITING_FOR_SEEK);
     std::swap(read_cbs_, read_cbs);
   }
 
   for (ReadCBQueue::iterator it = read_cbs.begin(); it != read_cbs.end(); ++it)
     it->Run(kAborted, NULL);
 }
 
 void ChunkDemuxerStream::Seek(TimeDelta time) {
   base::AutoLock auto_lock(lock_);
 
   DCHECK(read_cbs_.empty());
 
   // Ignore seek requests when canceled.
-  if (state_ == CANCELED)
-    return;
+  if (state_ == CANCELED) return;
 
   stream_->Seek(time);
 
-  if (state_ == WAITING_FOR_SEEK)
-    ChangeState_Locked(RETURNING_DATA_FOR_READS);
+  if (state_ == WAITING_FOR_SEEK) ChangeState_Locked(RETURNING_DATA_FOR_READS);
 }
 
 void ChunkDemuxerStream::CancelPendingSeek() {
   DVLOG(1) << "ChunkDemuxerStream::CancelPendingSeek()";
   ReadCBQueue read_cbs;
   {
     base::AutoLock auto_lock(lock_);
     ChangeState_Locked(CANCELED);
     std::swap(read_cbs_, read_cbs);
   }
 
   for (ReadCBQueue::iterator it = read_cbs.begin(); it != read_cbs.end(); ++it)
     it->Run(kAborted, NULL);
 }
 
 bool ChunkDemuxerStream::IsSeekPending() const {
   base::AutoLock auto_lock(lock_);
   return stream_->IsSeekPending();
 }
 
 void ChunkDemuxerStream::OnNewMediaSegment(TimeDelta start_timestamp) {
   base::AutoLock auto_lock(lock_);
   stream_->OnNewMediaSegment(start_timestamp);
 }
 
 bool ChunkDemuxerStream::Append(const StreamParser::BufferQueue& buffers) {
-  if (buffers.empty())
-    return false;
+  if (buffers.empty()) return false;
 
   ClosureQueue closures;
   {
     base::AutoLock auto_lock(lock_);
     DCHECK_NE(state_, SHUTDOWN);
     if (!stream_->Append(buffers)) {
       DVLOG(1) << "ChunkDemuxerStream::Append() : stream append failed";
       return false;
     }
     CreateReadDoneClosures_Locked(&closures);
   }
 
   for (ClosureQueue::iterator it = closures.begin(); it != closures.end(); ++it)
     it->Run();
 
   return true;
 }
 
-void ChunkDemuxerStream::OnSetDuration(base::TimeDelta duration) {
+void ChunkDemuxerStream::Onset_duration(base::TimeDelta duration) {
   base::AutoLock auto_lock(lock_);
   stream_->OnSetDuration(duration);
 }
 
 Ranges<TimeDelta> ChunkDemuxerStream::GetBufferedRanges(
     base::TimeDelta duration) const {
   base::AutoLock auto_lock(lock_);
   Ranges<TimeDelta> range = stream_->GetBufferedTime();
 
-  if (range.size() == 0u)
-    return range;
+  if (range.size() == 0u) return range;
 
   // Clamp the end of the stream's buffered ranges to fit within the duration.
   // This can be done by intersecting the stream's range with the valid time
   // range.
   Ranges<TimeDelta> valid_time_range;
   valid_time_range.Add(range.start(0), duration);
   return range.IntersectionWith(valid_time_range);
 }
 
 bool ChunkDemuxerStream::UpdateAudioConfig(const AudioDecoderConfig& config) {
@@ skipping 31 matching lines @@
   ReadCBQueue read_cbs;
   {
     base::AutoLock auto_lock(lock_);
     ChangeState_Locked(SHUTDOWN);
     std::swap(read_cbs_, read_cbs);
   }
 
   // Pass end of stream buffers to all callbacks to signal that no more data
   // will be sent.
   for (ReadCBQueue::iterator it = read_cbs.begin(); it != read_cbs.end(); ++it)
-    it->Run(DemuxerStream::kOk, StreamParserBuffer::CreateEOSBuffer());
+    it->Run(DemuxerStream::kOk, StreamParserBuffer::create_eos_buffer());
 }
 
 // Helper function that makes sure |read_cb| runs on |message_loop_proxy|.
 static void RunOnMessageLoop(
     const DemuxerStream::ReadCB& read_cb,
     const scoped_refptr<base::MessageLoopProxy>& message_loop_proxy,
-    DemuxerStream::Status status,
-    const scoped_refptr<DecoderBuffer>& buffer) {
+    DemuxerStream::Status status, const scoped_refptr<DecoderBuffer>& buffer) {
   if (!message_loop_proxy->BelongsToCurrentThread()) {
-    message_loop_proxy->PostTask(FROM_HERE, base::Bind(
-        &RunOnMessageLoop, read_cb, message_loop_proxy, status, buffer));
+    message_loop_proxy->PostTask(
+        FROM_HERE, base::Bind(&RunOnMessageLoop, read_cb, message_loop_proxy,
+                              status, buffer));
     return;
   }
 
   read_cb.Run(status, buffer);
 }
 
 // DemuxerStream methods.
 void ChunkDemuxerStream::Read(const ReadCB& read_cb) {
   DemuxerStream::Status status = kOk;
   scoped_refptr<StreamParserBuffer> buffer;
   {
     base::AutoLock auto_lock(lock_);
     if (!read_cbs_.empty() || !GetNextBuffer_Locked(&status, &buffer)) {
       DeferRead_Locked(read_cb);
       return;
     }
   }
 
-  base::MessageLoopProxy::current()->PostTask(FROM_HERE, base::Bind(
-      read_cb, status, buffer));
+  base::MessageLoopProxy::current()->PostTask(
+      FROM_HERE, base::Bind(read_cb, status, buffer));
 }
 
 DemuxerStream::Type ChunkDemuxerStream::type() { return type_; }
 
 void ChunkDemuxerStream::EnableBitstreamConverter() {}
 
 AudioDecoderConfig ChunkDemuxerStream::audio_decoder_config() {
   CHECK_EQ(type_, AUDIO);
   base::AutoLock auto_lock(lock_);
   return stream_->GetCurrentAudioDecoderConfig();
 }
 
 VideoDecoderConfig ChunkDemuxerStream::video_decoder_config() {
   CHECK_EQ(type_, VIDEO);
   base::AutoLock auto_lock(lock_);
   return stream_->GetCurrentVideoDecoderConfig();
 }
 
 void ChunkDemuxerStream::ChangeState_Locked(State state) {
   lock_.AssertAcquired();
   DVLOG(1) << "ChunkDemuxerStream::ChangeState_Locked() : "
-           << "type " << type_
-           << " - " << state_ << " -> " << state;
+           << "type " << type_ << " - " << state_ << " -> " << state;
   state_ = state;
 }
 
 ChunkDemuxerStream::~ChunkDemuxerStream() {}
 
 void ChunkDemuxerStream::DeferRead_Locked(const ReadCB& read_cb) {
   lock_.AssertAcquired();
   // Wrap & store |read_cb| so that it will
   // get called on the current MessageLoop.
   read_cbs_.push_back(base::Bind(&RunOnMessageLoop, read_cb,
                                  base::MessageLoopProxy::current()));
 }
 
 void ChunkDemuxerStream::CreateReadDoneClosures_Locked(ClosureQueue* closures) {
   lock_.AssertAcquired();
 
-  if (state_ != RETURNING_DATA_FOR_READS)
-    return;
+  if (state_ != RETURNING_DATA_FOR_READS) return;
 
   DemuxerStream::Status status;
   scoped_refptr<StreamParserBuffer> buffer;
   while (!read_cbs_.empty()) {
-    if (!GetNextBuffer_Locked(&status, &buffer))
-      return;
-    closures->push_back(base::Bind(read_cbs_.front(),
-                                   status, buffer));
+    if (!GetNextBuffer_Locked(&status, &buffer)) return;
+    closures->push_back(base::Bind(read_cbs_.front(), status, buffer));
     read_cbs_.pop_front();
   }
 }
 
 bool ChunkDemuxerStream::GetNextBuffer_Locked(
-    DemuxerStream::Status* status,
-    scoped_refptr<StreamParserBuffer>* buffer) {
+    DemuxerStream::Status* status, scoped_refptr<StreamParserBuffer>* buffer) {
   lock_.AssertAcquired();
 
   switch (state_) {
     case RETURNING_DATA_FOR_READS:
       switch (stream_->GetNextBuffer(buffer)) {
         case SourceBufferStream::kSuccess:
           *status = DemuxerStream::kOk;
           return true;
         case SourceBufferStream::kNeedBuffer:
           return false;
         case SourceBufferStream::kEndOfStream:
           *status = DemuxerStream::kOk;
-          *buffer = StreamParserBuffer::CreateEOSBuffer();
+          *buffer = StreamParserBuffer::create_eos_buffer();
           return true;
         case SourceBufferStream::kConfigChange:
           DVLOG(2) << "Config change reported to ChunkDemuxerStream.";
           *status = kConfigChanged;
           *buffer = NULL;
           return true;
       }
       break;
     case CANCELED:
     case WAITING_FOR_SEEK:
       // Null buffers should be returned in this state since we are waiting
       // for a seek. Any buffers in the SourceBuffer should NOT be returned
       // because they are associated with the seek.
       DCHECK(read_cbs_.empty());
       *status = DemuxerStream::kAborted;
       *buffer = NULL;
       return true;
     case SHUTDOWN:
       DCHECK(read_cbs_.empty());
       *status = DemuxerStream::kOk;
-      *buffer = StreamParserBuffer::CreateEOSBuffer();
+      *buffer = StreamParserBuffer::create_eos_buffer();
       return true;
   }
 
   NOTREACHED();
   return false;
 }
 
 ChunkDemuxer::ChunkDemuxer(const base::Closure& open_cb,
                            const NeedKeyCB& need_key_cb,
                            const AddTextTrackCB& add_text_track_cb,
                            const LogCB& log_cb)
     : state_(WAITING_FOR_INIT),
       host_(NULL),
       open_cb_(open_cb),
       need_key_cb_(need_key_cb),
       add_text_track_cb_(add_text_track_cb),
       log_cb_(log_cb),
       duration_(kNoTimestamp()),
       user_specified_duration_(-1) {
   DCHECK(!open_cb_.is_null());
   DCHECK(!need_key_cb_.is_null());
 }
 
 void ChunkDemuxer::Initialize(DemuxerHost* host, const PipelineStatusCB& cb) {
   DVLOG(1) << "Init()";
 
   base::AutoLock auto_lock(lock_);
 
   if (state_ == SHUTDOWN) {
-    base::MessageLoopProxy::current()->PostTask(FROM_HERE, base::Bind(
-        cb, DEMUXER_ERROR_COULD_NOT_OPEN));
+    base::MessageLoopProxy::current()->PostTask(
+        FROM_HERE, base::Bind(cb, DEMUXER_ERROR_COULD_NOT_OPEN));
     return;
   }
   DCHECK_EQ(state_, WAITING_FOR_INIT);
   host_ = host;
 
   ChangeState_Locked(INITIALIZING);
   init_cb_ = cb;
 
   base::ResetAndReturn(&open_cb_).Run();
 }
 
 void ChunkDemuxer::Stop(const base::Closure& callback) {
   DVLOG(1) << "Stop()";
   Shutdown();
   callback.Run();
 }
 
 void ChunkDemuxer::Seek(TimeDelta time, const PipelineStatusCB& cb) {
   DVLOG(1) << "Seek(" << time.InSecondsF() << ")";
   DCHECK(time >= TimeDelta());
   DCHECK(seek_cb_.is_null());
 
   PipelineStatus status = PIPELINE_ERROR_INVALID_STATE;
   {
     base::AutoLock auto_lock(lock_);
 
     if (state_ == INITIALIZED || state_ == ENDED) {
-      if (audio_)
-        audio_->Seek(time);
+      if (audio_) audio_->Seek(time);
 
-      if (video_)
-        video_->Seek(time);
+      if (video_) video_->Seek(time);
 
       if (IsSeekPending_Locked()) {
         DVLOG(1) << "Seek() : waiting for more data to arrive.";
         seek_cb_ = cb;
         return;
       }
 
       status = PIPELINE_OK;
     }
   }
 
   cb.Run(status);
 }
 
 void ChunkDemuxer::OnAudioRendererDisabled() {
   base::AutoLock auto_lock(lock_);
   audio_->Shutdown();
   disabled_audio_ = audio_.Pass();
 }
 
 // Demuxer implementation.
 DemuxerStream* ChunkDemuxer::GetStream(DemuxerStream::Type type) {
   base::AutoLock auto_lock(lock_);
-  if (type == DemuxerStream::VIDEO)
-    return video_.get();
+  if (type == DemuxerStream::VIDEO) return video_.get();
 
-  if (type == DemuxerStream::AUDIO)
-    return audio_.get();
+  if (type == DemuxerStream::AUDIO) return audio_.get();
 
   return NULL;
 }
 
-TimeDelta ChunkDemuxer::GetStartTime() const {
-  return TimeDelta();
-}
+TimeDelta ChunkDemuxer::GetStartTime() const { return TimeDelta(); }
 
 void ChunkDemuxer::StartWaitingForSeek() {
   DVLOG(1) << "StartWaitingForSeek()";
   base::AutoLock auto_lock(lock_);
   DCHECK(state_ == INITIALIZED || state_ == ENDED || state_ == SHUTDOWN);
 
-  if (state_ == SHUTDOWN)
-    return;
+  if (state_ == SHUTDOWN) return;
 
-  if (audio_)
-    audio_->StartWaitingForSeek();
+  if (audio_) audio_->StartWaitingForSeek();
 
-  if (video_)
-    video_->StartWaitingForSeek();
+  if (video_) video_->StartWaitingForSeek();
 }
 
 void ChunkDemuxer::CancelPendingSeek() {
   PipelineStatusCB cb;
   {
     base::AutoLock auto_lock(lock_);
     if (IsSeekPending_Locked() && !seek_cb_.is_null()) {
       std::swap(cb, seek_cb_);
     }
-    if (audio_)
-      audio_->CancelPendingSeek();
+    if (audio_) audio_->CancelPendingSeek();
 
-    if (video_)
-      video_->CancelPendingSeek();
+    if (video_) video_->CancelPendingSeek();
   }
 
-  if (!cb.is_null())
-    cb.Run(PIPELINE_OK);
+  if (!cb.is_null()) cb.Run(PIPELINE_OK);
 }
 
 ChunkDemuxer::Status ChunkDemuxer::AddId(const std::string& id,
                                          const std::string& type,
                                          std::vector<std::string>& codecs) {
   DCHECK_GT(codecs.size(), 0u);
   base::AutoLock auto_lock(lock_);
 
   if ((state_ != WAITING_FOR_INIT && state_ != INITIALIZING) || IsValidId(id))
     return kReachedIdLimit;
 
   bool has_audio = false;
   bool has_video = false;
-  scoped_ptr<media::StreamParser> stream_parser(
-      StreamParserFactory::Create(type, codecs, log_cb_,
-                                  &has_audio, &has_video));
+  scoped_ptr<media::StreamParser> stream_parser(StreamParserFactory::Create(
+      type, codecs, log_cb_, &has_audio, &has_video));
 
-  if (!stream_parser)
-    return ChunkDemuxer::kNotSupported;
+  if (!stream_parser) return ChunkDemuxer::kNotSupported;
 
   if ((has_audio && !source_id_audio_.empty()) ||
       (has_video && !source_id_video_.empty()))
     return kReachedIdLimit;
 
   StreamParser::NewBuffersCB audio_cb;
   StreamParser::NewBuffersCB video_cb;
 
   if (has_audio) {
     source_id_audio_ = id;
-    audio_cb = base::Bind(&ChunkDemuxer::OnAudioBuffers,
-                          base::Unretained(this));
+    audio_cb =
+        base::Bind(&ChunkDemuxer::OnAudioBuffers, base::Unretained(this));
   }
 
   if (has_video) {
     source_id_video_ = id;
-    video_cb = base::Bind(&ChunkDemuxer::OnVideoBuffers,
-                          base::Unretained(this));
+    video_cb =
+        base::Bind(&ChunkDemuxer::OnVideoBuffers, base::Unretained(this));
   }
 
   scoped_ptr<SourceState> source_state(new SourceState(stream_parser.Pass()));
   source_state->Init(
       base::Bind(&ChunkDemuxer::OnSourceInitDone, base::Unretained(this)),
-      base::Bind(&ChunkDemuxer::OnNewConfigs, base::Unretained(this),
-                 has_audio, has_video),
-      audio_cb,
-      video_cb,
+      base::Bind(&ChunkDemuxer::OnNewConfigs, base::Unretained(this), has_audio,
+                 has_video),
+      audio_cb, video_cb,
       base::Bind(&ChunkDemuxer::OnTextBuffers, base::Unretained(this)),
       base::Bind(&ChunkDemuxer::OnNeedKey, base::Unretained(this)),
       add_text_track_cb_,
       base::Bind(&ChunkDemuxer::OnNewMediaSegment, base::Unretained(this), id),
       log_cb_);
 
   source_state_map_[id] = source_state.release();
   return kOk;
 }
 
 void ChunkDemuxer::RemoveId(const std::string& id) {
   base::AutoLock auto_lock(lock_);
   CHECK(IsValidId(id));
 
   delete source_state_map_[id];
   source_state_map_.erase(id);
 
   if (source_id_audio_ == id) {
-    if (audio_)
-      audio_->Shutdown();
+    if (audio_) audio_->Shutdown();
     source_id_audio_.clear();
   }
 
   if (source_id_video_ == id) {
-    if (video_)
-      video_->Shutdown();
+    if (video_) video_->Shutdown();
     source_id_video_.clear();
   }
 }
 
 Ranges<TimeDelta> ChunkDemuxer::GetBufferedRanges(const std::string& id) const {
   base::AutoLock auto_lock(lock_);
   DCHECK(!id.empty());
   DCHECK(IsValidId(id));
   DCHECK(id == source_id_audio_ || id == source_id_video_);
 
   if (id == source_id_audio_ && id != source_id_video_) {
     // Only include ranges that have been buffered in |audio_|
     return audio_ ? audio_->GetBufferedRanges(duration_) : Ranges<TimeDelta>();
   }
 
   if (id != source_id_audio_ && id == source_id_video_) {
     // Only include ranges that have been buffered in |video_|
     return video_ ? video_->GetBufferedRanges(duration_) : Ranges<TimeDelta>();
   }
 
   return ComputeIntersection();
 }
 
 Ranges<TimeDelta> ChunkDemuxer::ComputeIntersection() const {
   lock_.AssertAcquired();
 
-  if (!audio_ || !video_)
-    return Ranges<TimeDelta>();
+  if (!audio_ || !video_) return Ranges<TimeDelta>();
 
   // Include ranges that have been buffered in both |audio_| and |video_|.
   Ranges<TimeDelta> audio_ranges = audio_->GetBufferedRanges(duration_);
   Ranges<TimeDelta> video_ranges = video_->GetBufferedRanges(duration_);
   Ranges<TimeDelta> result = audio_ranges.IntersectionWith(video_ranges);
 
   if (state_ == ENDED && result.size() > 0) {
     // If appending has ended, extend the last intersection range to include the
     // max end time of the last audio/video range. This allows the buffered
     // information to match the actual time range that will get played out if
     // the streams have slightly different lengths.
     TimeDelta audio_start = audio_ranges.start(audio_ranges.size() - 1);
     TimeDelta audio_end = audio_ranges.end(audio_ranges.size() - 1);
     TimeDelta video_start = video_ranges.start(video_ranges.size() - 1);
     TimeDelta video_end = video_ranges.end(video_ranges.size() - 1);
 
     // Verify the last audio range overlaps with the last video range.
     // This is enforced by the logic that controls the transition to ENDED.
     DCHECK((audio_start <= video_start && video_start <= audio_end) ||
            (video_start <= audio_start && audio_start <= video_end));
-    result.Add(result.end(result.size()-1), std::max(audio_end, video_end));
+    result.Add(result.end(result.size() - 1), std::max(audio_end, video_end));
   }
 
   return result;
 }
 
-void ChunkDemuxer::AppendData(const std::string& id,
-                              const uint8* data,
+void ChunkDemuxer::AppendData(const std::string& id, const uint8* data,
                               size_t length) {
   DVLOG(1) << "AppendData(" << id << ", " << length << ")";
 
   DCHECK(!id.empty());
 
   Ranges<TimeDelta> ranges;
 
   PipelineStatusCB cb;
   {
     base::AutoLock auto_lock(lock_);
 
     // Capture if the SourceBuffer has a pending seek before we start parsing.
     bool old_seek_pending = IsSeekPending_Locked();
 
     if (state_ == ENDED) {
       ChangeState_Locked(INITIALIZED);
 
-      if (audio_)
-        audio_->CancelEndOfStream();
+      if (audio_) audio_->CancelEndOfStream();
 
-      if (video_)
-        video_->CancelEndOfStream();
+      if (video_) video_->CancelEndOfStream();
     }
 
-    if (length == 0u)
-      return;
+    if (length == 0u) return;
 
     DCHECK(data);
 
     switch (state_) {
       case INITIALIZING:
         DCHECK(IsValidId(id));
         if (!source_state_map_[id]->Append(data, length)) {
           ReportError_Locked(DEMUXER_ERROR_COULD_NOT_OPEN);
           return;
         }
@@ skipping 23 matching lines @@
     if (old_seek_pending && !IsSeekPending_Locked() && !seek_cb_.is_null()) {
       std::swap(cb, seek_cb_);
     }
 
     ranges = GetBufferedRanges();
   }
 
   for (size_t i = 0; i < ranges.size(); ++i)
     host_->AddBufferedTimeRange(ranges.start(i), ranges.end(i));
 
-  if (!cb.is_null())
-    cb.Run(PIPELINE_OK);
+  if (!cb.is_null()) cb.Run(PIPELINE_OK);
 }
 
 void ChunkDemuxer::Abort(const std::string& id) {
   DVLOG(1) << "Abort(" << id << ")";
   base::AutoLock auto_lock(lock_);
   DCHECK(!id.empty());
   CHECK(IsValidId(id));
   source_state_map_[id]->Abort();
 }
 
 double ChunkDemuxer::GetDuration() {
   base::AutoLock auto_lock(lock_);
   return GetDuration_Locked();
 }
 
 double ChunkDemuxer::GetDuration_Locked() {
   lock_.AssertAcquired();
   if (duration_ == kNoTimestamp())
     return std::numeric_limits<double>::quiet_NaN();
 
   // Return positive infinity if the resource is unbounded.
   // http://www.whatwg.org/specs/web-apps/current-work/multipage/video.html#dom-media-duration
   if (duration_ == kInfiniteDuration())
     return std::numeric_limits<double>::infinity();
 
-  if (user_specified_duration_ >= 0)
-    return user_specified_duration_;
+  if (user_specified_duration_ >= 0) return user_specified_duration_;
 
   return duration_.InSecondsF();
 }
 
 void ChunkDemuxer::SetDuration(double duration) {
   base::AutoLock auto_lock(lock_);
-  DVLOG(1) << "SetDuration(" << duration << ")";
+  DVLOG(1) << "set_duration(" << duration << ")";
   DCHECK_GE(duration, 0);
 
-  if (duration == GetDuration_Locked())
-    return;
+  if (duration == GetDuration_Locked()) return;
 
   // Compute & bounds check the TimeDelta representation of duration.
   // This can be different if the value of |duration| doesn't fit the range or
   // precision of base::TimeDelta.
   base::TimeDelta min_duration = base::TimeDelta::FromInternalValue(1);
   base::TimeDelta max_duration =
       base::TimeDelta::FromInternalValue(kint64max - 1);
   double min_duration_in_seconds = min_duration.InSecondsF();
   double max_duration_in_seconds = max_duration.InSecondsF();
 
   base::TimeDelta duration_td;
   if (duration == std::numeric_limits<double>::infinity()) {
     duration_td = media::kInfiniteDuration();
   } else if (duration < min_duration_in_seconds) {
     duration_td = min_duration;
   } else if (duration > max_duration_in_seconds) {
     duration_td = max_duration;
   } else {
     duration_td = base::TimeDelta::FromMicroseconds(
         duration * base::Time::kMicrosecondsPerSecond);
   }
 
   DCHECK(duration_td > base::TimeDelta());
 
   user_specified_duration_ = duration;
   duration_ = duration_td;
   host_->SetDuration(duration_);
 
-  if (audio_)
-    audio_->OnSetDuration(duration_);
+  if (audio_) audio_->Onset_duration(duration_);
 
-  if (video_)
-    video_->OnSetDuration(duration_);
+  if (video_) video_->Onset_duration(duration_);
 }
 
 bool ChunkDemuxer::SetTimestampOffset(const std::string& id, TimeDelta offset) {
   base::AutoLock auto_lock(lock_);
-  DVLOG(1) << "SetTimestampOffset(" << id << ", " << offset.InSecondsF() << ")";
+  DVLOG(1) << "set_timestampOffset(" << id << ", " << offset.InSecondsF()
+           << ")";
   CHECK(IsValidId(id));
 
-  return source_state_map_[id]->SetTimestampOffset(offset);
+  return source_state_map_[id]->set_timestampOffset(offset);
 }
 
 void ChunkDemuxer::EndOfStream(PipelineStatus status) {
   DVLOG(1) << "EndOfStream(" << status << ")";
   PipelineStatusCB cb;
   {
     base::AutoLock auto_lock(lock_);
     DCHECK_NE(state_, WAITING_FOR_INIT);
     DCHECK_NE(state_, ENDED);
 
-    if (state_ == SHUTDOWN || state_ == PARSE_ERROR)
-      return;
+    if (state_ == SHUTDOWN || state_ == PARSE_ERROR) return;
 
     if (state_ == INITIALIZING) {
       ReportError_Locked(DEMUXER_ERROR_COULD_NOT_OPEN);
       return;
     }
 
     bool old_seek_pending = IsSeekPending_Locked();
-    if (audio_)
-      audio_->EndOfStream();
+    if (audio_) audio_->EndOfStream();
 
-    if (video_)
-      video_->EndOfStream();
+    if (video_) video_->EndOfStream();
 
     // Give a chance to resume the pending seek process.
     if (status != PIPELINE_OK) {
       ReportError_Locked(status);
       return;
     }
 
     ChangeState_Locked(ENDED);
     DecreaseDurationIfNecessary();
 
     if (old_seek_pending && !IsSeekPending_Locked() && !seek_cb_.is_null())
       std::swap(cb, seek_cb_);
   }
 
-  if (!cb.is_null())
-    cb.Run(PIPELINE_OK);
+  if (!cb.is_null()) cb.Run(PIPELINE_OK);
 }
 
 void ChunkDemuxer::Shutdown() {
   DVLOG(1) << "Shutdown()";
   PipelineStatusCB cb;
   {
     base::AutoLock auto_lock(lock_);
 
-    if (state_ == SHUTDOWN)
-      return;
+    if (state_ == SHUTDOWN) return;
 
     std::swap(cb, seek_cb_);
 
-    if (audio_)
-      audio_->Shutdown();
+    if (audio_) audio_->Shutdown();
 
-    if (video_)
-      video_->Shutdown();
+    if (video_) video_->Shutdown();
 
     ChangeState_Locked(SHUTDOWN);
   }
 
-  if (!cb.is_null())
-    cb.Run(PIPELINE_ERROR_ABORT);
+  if (!cb.is_null()) cb.Run(PIPELINE_ERROR_ABORT);
 }
 
 void ChunkDemuxer::ChangeState_Locked(State new_state) {
   lock_.AssertAcquired();
-  DVLOG(1) << "ChunkDemuxer::ChangeState_Locked() : "
-           << state_ << " -> " << new_state;
+  DVLOG(1) << "ChunkDemuxer::ChangeState_Locked() : " << state_ << " -> "
+           << new_state;
   state_ = new_state;
 }
 
 ChunkDemuxer::~ChunkDemuxer() {
   DCHECK_NE(state_, INITIALIZED);
   for (SourceStateMap::iterator it = source_state_map_.begin();
        it != source_state_map_.end(); ++it) {
     delete it->second;
   }
   source_state_map_.clear();
 }
 
 void ChunkDemuxer::ReportError_Locked(PipelineStatus error) {
   DVLOG(1) << "ReportError_Locked(" << error << ")";
   lock_.AssertAcquired();
   DCHECK_NE(error, PIPELINE_OK);
 
   ChangeState_Locked(PARSE_ERROR);
 
   PipelineStatusCB cb;
 
   if (!init_cb_.is_null()) {
     std::swap(cb, init_cb_);
   } else {
-    if (!seek_cb_.is_null())
-      std::swap(cb, seek_cb_);
+    if (!seek_cb_.is_null()) std::swap(cb, seek_cb_);
 
-    if (audio_)
-      audio_->Shutdown();
+    if (audio_) audio_->Shutdown();
 
-    if (video_)
-      video_->Shutdown();
+    if (video_) video_->Shutdown();
   }
 
   if (!cb.is_null()) {
     base::AutoUnlock auto_unlock(lock_);
     cb.Run(error);
     return;
   }
 
   base::AutoUnlock auto_unlock(lock_);
   host_->OnDemuxerError(error);
 }
 
 bool ChunkDemuxer::IsSeekPending_Locked() const {
   lock_.AssertAcquired();
   bool seek_pending = false;
 
-  if (audio_)
-    seek_pending = audio_->IsSeekPending();
+  if (audio_) seek_pending = audio_->IsSeekPending();
 
-  if (!seek_pending && video_)
-    seek_pending = video_->IsSeekPending();
+  if (!seek_pending && video_) seek_pending = video_->IsSeekPending();
 
   return seek_pending;
 }
 
 void ChunkDemuxer::OnSourceInitDone(bool success, TimeDelta duration) {
-  DVLOG(1) << "OnSourceInitDone(" << success << ", "
-           << duration.InSecondsF() << ")";
+  DVLOG(1) << "OnSourceInitDone(" << success << ", " << duration.InSecondsF()
+           << ")";
   lock_.AssertAcquired();
   DCHECK_EQ(state_, INITIALIZING);
   if (!success || (!audio_ && !video_)) {
     ReportError_Locked(DEMUXER_ERROR_COULD_NOT_OPEN);
     return;
   }
 
   if (duration != base::TimeDelta() && duration_ == kNoTimestamp())
     UpdateDuration(duration);
 
   // Wait until all streams have initialized.
   if ((!source_id_audio_.empty() && !audio_) ||
       (!source_id_video_.empty() && !video_))
     return;
 
-  if (audio_)
-    audio_->Seek(TimeDelta());
+  if (audio_) audio_->Seek(TimeDelta());
 
-  if (video_)
-    video_->Seek(TimeDelta());
+  if (video_) video_->Seek(TimeDelta());
 
-  if (duration_ == kNoTimestamp())
-    duration_ = kInfiniteDuration();
+  if (duration_ == kNoTimestamp()) duration_ = kInfiniteDuration();
 
   // The demuxer is now initialized after the |start_timestamp_| was set.
   ChangeState_Locked(INITIALIZED);
   base::ResetAndReturn(&init_cb_).Run(PIPELINE_OK);
 }
 
 bool ChunkDemuxer::OnNewConfigs(bool has_audio, bool has_video,
                                 const AudioDecoderConfig& audio_config,
                                 const VideoDecoderConfig& video_config) {
-  DVLOG(1) << "OnNewConfigs(" << has_audio << ", " << has_video
-           << ", " << audio_config.IsValidConfig()
-           << ", " << video_config.IsValidConfig() << ")";
+  DVLOG(1) << "OnNewConfigs(" << has_audio << ", " << has_video << ", "
+           << audio_config.IsValidConfig() << ", "
+           << video_config.IsValidConfig() << ")";
   lock_.AssertAcquired();
 
   if (!audio_config.IsValidConfig() && !video_config.IsValidConfig()) {
     DVLOG(1) << "OnNewConfigs() : Audio & video config are not valid!";
     return false;
   }
 
   // Signal an error if we get configuration info for stream types that weren't
   // specified in AddId() or more configs after a stream is initialized.
   // Only allow a single audio config for now.
@@ skipping 36 matching lines @@
   }
 
   DVLOG(1) << "OnNewConfigs() : " << (success ? "success" : "failed");
   return success;
 }
 
 bool ChunkDemuxer::OnAudioBuffers(const StreamParser::BufferQueue& buffers) {
   lock_.AssertAcquired();
   DCHECK_NE(state_, SHUTDOWN);
 
-  if (!audio_)
-    return false;
+  if (!audio_) return false;
 
   CHECK(IsValidId(source_id_audio_));
-  if (!audio_->Append(buffers))
-    return false;
+  if (!audio_->Append(buffers)) return false;
 
   IncreaseDurationIfNecessary(buffers, audio_.get());
   return true;
 }
 
 bool ChunkDemuxer::OnVideoBuffers(const StreamParser::BufferQueue& buffers) {
   lock_.AssertAcquired();
   DCHECK_NE(state_, SHUTDOWN);
 
-  if (!video_)
-    return false;
+  if (!video_) return false;
 
   CHECK(IsValidId(source_id_video_));
-  if (!video_->Append(buffers))
-    return false;
+  if (!video_->Append(buffers)) return false;
 
   IncreaseDurationIfNecessary(buffers, video_.get());
   return true;
 }
 
-bool ChunkDemuxer::OnTextBuffers(
-  TextTrack* text_track,
-  const StreamParser::BufferQueue& buffers) {
+bool ChunkDemuxer::OnTextBuffers(TextTrack* text_track,
+                                 const StreamParser::BufferQueue& buffers) {
   lock_.AssertAcquired();
   DCHECK_NE(state_, SHUTDOWN);
 
   // TODO(matthewjheaney): IncreaseDurationIfNecessary
 
   for (StreamParser::BufferQueue::const_iterator itr = buffers.begin();
        itr != buffers.end(); ++itr) {
     const StreamParserBuffer* const buffer = itr->get();
-    const base::TimeDelta start = buffer->GetTimestamp();
-    const base::TimeDelta end = start + buffer->GetDuration();
+    const base::TimeDelta start = buffer->get_timestamp();
+    const base::TimeDelta end = start + buffer->get_duration();
 
     std::string id, settings, content;
 
-    WebMWebVTTParser::Parse(buffer->GetData(),
-                            buffer->GetDataSize(),
-                            &id, &settings, &content);
+    WebMWebVTTParser::Parse(buffer->get_data(), buffer->get_data_size(), &id,
+                            &settings, &content);
 
     text_track->addWebVTTCue(start, end, id, content, settings);
   }
 
   return true;
 }
 
 // TODO(acolwell): Remove bool from StreamParser::NeedKeyCB so that
 // this method can be removed and need_key_cb_ can be passed directly
 // to the parser.
@@ skipping 25 matching lines @@
 }
 
 void ChunkDemuxer::UpdateDuration(base::TimeDelta new_duration) {
   DCHECK(duration_ != new_duration);
   user_specified_duration_ = -1;
   duration_ = new_duration;
   host_->SetDuration(new_duration);
 }
 
 void ChunkDemuxer::IncreaseDurationIfNecessary(
-    const StreamParser::BufferQueue& buffers,
-    ChunkDemuxerStream* stream) {
+    const StreamParser::BufferQueue& buffers, ChunkDemuxerStream* stream) {
   DCHECK(!buffers.empty());
-  if (buffers.back()->GetTimestamp() <= duration_)
-    return;
+  if (buffers.back()->get_timestamp() <= duration_) return;
 
   Ranges<TimeDelta> ranges = stream->GetBufferedRanges(kInfiniteDuration());
   DCHECK_GT(ranges.size(), 0u);
 
   base::TimeDelta last_timestamp_buffered = ranges.end(ranges.size() - 1);
   if (last_timestamp_buffered > duration_)
     UpdateDuration(last_timestamp_buffered);
 }
 
 void ChunkDemuxer::DecreaseDurationIfNecessary() {
   Ranges<TimeDelta> ranges = GetBufferedRanges();
-  if (ranges.size() == 0u)
-    return;
+  if (ranges.size() == 0u) return;
 
   base::TimeDelta last_timestamp_buffered = ranges.end(ranges.size() - 1);
   if (last_timestamp_buffered < duration_)
     UpdateDuration(last_timestamp_buffered);
 }
 
 Ranges<TimeDelta> ChunkDemuxer::GetBufferedRanges() const {
   if (audio_ && !video_)
     return audio_->GetBufferedRanges(duration_);
   else if (!audio_ && video_)
     return video_->GetBufferedRanges(duration_);
   return ComputeIntersection();
 }
 
 }  // namespace media