Implemented end-of-stream callback for media::PipelineImpl.

media/filters/audio_renderer_base.h

 // Copyright (c) 2009 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.
 
 // AudioRendererBase takes care of the tricky queuing work and provides simple
 // methods for subclasses to peek and poke at audio data.  In addition to
 // AudioRenderer interface methods this classes doesn't implement, subclasses
 // must also implement the following methods:
 //   OnInitialized
 //   OnStop
@@ skipping 21 matching lines @@
  public:
   // MediaFilter implementation.
   virtual void Play(FilterCallback* callback);
   virtual void Pause(FilterCallback* callback);
   virtual void Stop();
 
   virtual void Seek(base::TimeDelta time, FilterCallback* callback);
 
   // AudioRenderer implementation.
   virtual void Initialize(AudioDecoder* decoder, FilterCallback* callback);
+  virtual bool HasEnded();
 
  protected:
   // Only allow a factory to create this class.
   AudioRendererBase();
   virtual ~AudioRendererBase();
 
   // Called by Initialize().  |media_format| is the format of the AudioDecoder.
   // Subclasses should return true if they were able to initialize, false
   // otherwise.
   virtual bool OnInitialize(const MediaFormat& media_format) = 0;
@@ skipping 56 matching lines @@
   enum State {
     kUninitialized,
     kPaused,
     kSeeking,
     kPlaying,
     kStopped,
     kError,
   };
   State state_;
 
+  // Keeps track of whether we received and rendered the end of stream buffer.
+  bool recieved_end_of_stream_;
+  bool rendered_end_of_stream_;
+
   // Keeps track of our pending reads.  We *must* have no pending reads before
   // executing the pause callback, otherwise we breach the contract that all
   // filters are idling.
   //
   // We use size_t since we compare against std::deque::size().
   size_t pending_reads_;
 
   // Audio time at end of last call to FillBuffer().
   // TODO(ralphl): Update this value after seeking.
   base::TimeDelta last_fill_buffer_time_;
 
   // Filter callbacks.
   scoped_ptr<FilterCallback> pause_callback_;
   scoped_ptr<FilterCallback> seek_callback_;
 
   DISALLOW_COPY_AND_ASSIGN(AudioRendererBase);
 };
 
 }  // namespace media
 
 #endif  // MEDIA_FILTERS_AUDIO_RENDERER_BASE_H_