Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(380)

Side by Side Diff: media/audio/audio_output_controller.h

Issue 9121062: Remove "high"-latency audio code path (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Rebase ToT Created 8 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 #ifndef MEDIA_AUDIO_AUDIO_OUTPUT_CONTROLLER_H_ 5 #ifndef MEDIA_AUDIO_AUDIO_OUTPUT_CONTROLLER_H_
6 #define MEDIA_AUDIO_AUDIO_OUTPUT_CONTROLLER_H_ 6 #define MEDIA_AUDIO_AUDIO_OUTPUT_CONTROLLER_H_
7 7
8 #include "base/callback.h" 8 #include "base/callback.h"
9 #include "base/memory/ref_counted.h" 9 #include "base/memory/ref_counted.h"
10 #include "base/memory/scoped_ptr.h" 10 #include "base/memory/scoped_ptr.h"
11 #include "base/memory/weak_ptr.h" 11 #include "base/memory/weak_ptr.h"
12 #include "base/synchronization/lock.h" 12 #include "base/synchronization/lock.h"
13 #include "base/time.h" 13 #include "base/time.h"
14 #include "media/audio/audio_buffers_state.h" 14 #include "media/audio/audio_buffers_state.h"
15 #include "media/audio/audio_io.h" 15 #include "media/audio/audio_io.h"
16 #include "media/audio/audio_manager.h" 16 #include "media/audio/audio_manager.h"
17 #include "media/audio/simple_sources.h" 17 #include "media/audio/simple_sources.h"
18 18
19 namespace base { 19 namespace base {
20 class WaitableEvent; 20 class WaitableEvent;
21 } // namespace base 21 } // namespace base
22 22
23 class MessageLoop; 23 class MessageLoop;
24 24
25 // An AudioOutputController controls an AudioOutputStream and provides data 25 // An AudioOutputController controls an AudioOutputStream and provides data
26 // to this output stream. It has an important function that it executes 26 // to this output stream. It has an important function that it executes
27 // audio operations like play, pause, stop, etc. on a separate thread, 27 // audio operations like play, pause, stop, etc. on a separate thread,
28 // namely the audio controller thread. 28 // namely the audio manager thread.
29 // 29 //
30 // All the public methods of AudioOutputController are non-blocking. 30 // All the public methods of AudioOutputController are non-blocking.
31 // The actual operations are performed on the audio thread. 31 // The actual operations are performed on the audio manager thread.
32 // 32 //
33 // Here is a state diagram for the AudioOutputController for default low 33 // Here is a state diagram for the AudioOutputController:
34 // latency mode; in normal latency mode there is no "starting" or "paused when
35 // starting" states, "created" immediately switches to "playing":
36 // 34 //
37 // .-----------------------> [ Closed / Error ] <------. 35 // .-----------------------> [ Closed / Error ] <------.
38 // | ^ | 36 // | ^ |
39 // | | | 37 // | | |
40 // [ Created ] --> [ Starting ] --> [ Playing ] --> [ Paused ] 38 // [ Created ] --> [ Starting ] --> [ Playing ] --> [ Paused ]
41 // ^ | ^ | ^ 39 // ^ | ^ | ^
42 // | | | | | 40 // | | | | |
43 // | | `----------------' | 41 // | | `----------------' |
44 // | V | 42 // | V |
45 // | [ PausedWhenStarting ] ------------------------' 43 // | [ PausedWhenStarting ] ------------------------'
46 // | 44 // |
47 // *[ Empty ] 45 // *[ Empty ]
48 // 46 //
49 // * Initial state 47 // * Initial state
50 // 48 //
51 // There are two modes of buffering operations supported by this class. 49 // The AudioOutputStream can request data from the AudioOutputController via the
50 // AudioSourceCallback interface. AudioOutputController uses the SyncReader
51 // passed to it via construction to synchronously fulfill this read request.
52 // 52 //
53 // Regular latency mode: 53 // The audio manager thread is owned by the AudioManager that the
54 // In this mode we receive signals from AudioOutputController and then we 54 // AudioOutputController holds a reference to. When performing tasks on this
55 // enqueue data into it. 55 // thread, the controller must not add or release references to the
56 //
57 // Low latency mode:
58 // In this mode a DataSource object is given to the AudioOutputController
59 // and AudioOutputController reads from it synchronously.
60 //
61 // The audio thread itself is owned by the AudioManager that the
62 // AudioOutputController holds a reference to. When performing tasks on the
63 // audio thread, the controller must not add or release references to the
64 // AudioManager or itself (since it in turn holds a reference to the manager), 56 // AudioManager or itself (since it in turn holds a reference to the manager),
65 // for delayed tasks as it can slow down or even prevent normal shut down. 57 // for delayed tasks as it can slow down or even prevent normal shut down.
66 // So, for tasks on the audio thread, the controller uses WeakPtr which enables 58 // So, for tasks on the audio thread, the controller uses WeakPtr which enables
67 // us to safely cancel pending polling tasks. 59 // us to safely cancel pending polling tasks.
68 // The owner of the audio thread, AudioManager, will take care of properly 60 //
69 // shutting it down. 61 // AudioManager will take care of properly shutting down the audio manager
62 // thread.
70 // 63 //
71 #include "media/base/media_export.h" 64 #include "media/base/media_export.h"
72 65
73 namespace media { 66 namespace media {
74 67
75 class MEDIA_EXPORT AudioOutputController 68 class MEDIA_EXPORT AudioOutputController
76 : public base::RefCountedThreadSafe<AudioOutputController>, 69 : public base::RefCountedThreadSafe<AudioOutputController>,
77 public AudioOutputStream::AudioSourceCallback { 70 public AudioOutputStream::AudioSourceCallback {
78 public: 71 public:
79 // Value sent by the controller to the renderer in low-latency mode 72 // Value sent by the controller to the renderer in low-latency mode
80 // indicating that the stream is paused. 73 // indicating that the stream is paused.
81 static const int kPauseMark; 74 static const int kPauseMark;
82 75
83 // An event handler that receives events from the AudioOutputController. The 76 // An event handler that receives events from the AudioOutputController. The
84 // following methods are called on the audio controller thread. 77 // following methods are called on the audio manager thread.
85 class MEDIA_EXPORT EventHandler { 78 class MEDIA_EXPORT EventHandler {
86 public: 79 public:
87 virtual ~EventHandler() {} 80 virtual ~EventHandler() {}
88 virtual void OnCreated(AudioOutputController* controller) = 0; 81 virtual void OnCreated(AudioOutputController* controller) = 0;
89 virtual void OnPlaying(AudioOutputController* controller) = 0; 82 virtual void OnPlaying(AudioOutputController* controller) = 0;
90 virtual void OnPaused(AudioOutputController* controller) = 0; 83 virtual void OnPaused(AudioOutputController* controller) = 0;
91 virtual void OnError(AudioOutputController* controller, int error_code) = 0; 84 virtual void OnError(AudioOutputController* controller, int error_code) = 0;
92
93 // Audio controller asks for more data.
94 // |pending_bytes| is the number of bytes still on the controller.
95 // |timestamp| is then time when |pending_bytes| is recorded.
96 virtual void OnMoreData(AudioOutputController* controller,
97 AudioBuffersState buffers_state) = 0;
98 }; 85 };
99 86
100 // A synchronous reader interface used by AudioOutputController for 87 // A synchronous reader interface used by AudioOutputController for
101 // synchronous reading. 88 // synchronous reading.
102 class SyncReader { 89 class SyncReader {
103 public: 90 public:
104 virtual ~SyncReader() {} 91 virtual ~SyncReader() {}
105 92
106 // Notify the synchronous reader the number of bytes in the 93 // Notify the synchronous reader the number of bytes in the
107 // AudioOutputController not yet played. This is used by SyncReader to 94 // AudioOutputController not yet played. This is used by SyncReader to
108 // prepare more data and perform synchronization. 95 // prepare more data and perform synchronization.
109 virtual void UpdatePendingBytes(uint32 bytes) = 0; 96 virtual void UpdatePendingBytes(uint32 bytes) = 0;
110 97
111 // Read certain amount of data into |data|. This method returns if some 98 // Read certain amount of data into |data|. This method returns if some
112 // data is available. 99 // data is available.
113 virtual uint32 Read(void* data, uint32 size) = 0; 100 virtual uint32 Read(void* data, uint32 size) = 0;
114 101
115 // Close this synchronous reader. 102 // Close this synchronous reader.
116 virtual void Close() = 0; 103 virtual void Close() = 0;
117 104
118 // Poll if data is ready. 105 // Poll if data is ready.
119 // Not reliable, as there is no guarantee that renderer is "new-style" 106 // Not reliable, as there is no guarantee that renderer is "new-style"
120 // renderer that writes metadata into buffer. After several unsuccessful 107 // renderer that writes metadata into buffer. After several unsuccessful
121 // attempts caller should assume the data is ready even if that function 108 // attempts caller should assume the data is ready even if that function
122 // returns false. 109 // returns false.
123 virtual bool DataReady() = 0; 110 virtual bool DataReady() = 0;
124 }; 111 };
125 112
126 // Factory method for creating an AudioOutputController. 113 // Factory method for creating an AudioOutputController.
127 // If successful, an audio controller thread is created. The audio device 114 // This posts a method on the |audio_manager|'s thread to create an
henrika (OOO until Aug 14) 2012/02/01 13:11:29 Would it be possible to make this comment a bit mo
vrk (LEFT CHROMIUM) 2012/02/02 21:05:41 Done.
128 // will be created on the audio controller thread and when that is done 115 // AudioOutputStream. After the stream is created successfully, OnCreated()
129 // event handler will receive a OnCreated() call. 116 // is called on the |event_handler|, and is *not* guaranteed to be called on
117 // the same thread on which this object was created.
130 static scoped_refptr<AudioOutputController> Create( 118 static scoped_refptr<AudioOutputController> Create(
131 AudioManager* audio_manager, 119 AudioManager* audio_manager,
132 EventHandler* event_handler, 120 EventHandler* event_handler,
133 const AudioParameters& params, 121 const AudioParameters& params,
134 // Soft limit for buffer capacity in this controller. This parameter
135 // is used only in regular latency mode.
136 uint32 buffer_capacity);
137
138 // Factory method for creating a low latency audio stream.
139 static scoped_refptr<AudioOutputController> CreateLowLatency(
140 AudioManager* audio_manager,
141 EventHandler* event_handler,
142 const AudioParameters& params,
143 // External synchronous reader for audio controller. 122 // External synchronous reader for audio controller.
144 SyncReader* sync_reader); 123 SyncReader* sync_reader);
145 124
146 // Methods to control playback of the stream. 125 // Methods to control playback of the stream.
147 126
148 // Starts the playback of this audio output stream. 127 // Starts the playback of this audio output stream.
149 void Play(); 128 void Play();
150 129
151 // Pause this audio output stream. 130 // Pause this audio output stream.
152 void Pause(); 131 void Pause();
153 132
154 // Discard all audio data buffered in this output stream. This method only 133 // Discard all audio data buffered in this output stream. This method only
155 // has effect when the stream is paused. 134 // has effect when the stream is paused.
156 void Flush(); 135 void Flush();
157 136
158 // Closes the audio output stream. The state is changed and the resources 137 // Closes the audio output stream. The state is changed and the resources
159 // are freed on the audio thread. closed_task is executed after that. 138 // are freed on the audio manager thread. closed_task is executed after that.
160 // Callbacks (EventHandler and SyncReader) must exist until closed_task is 139 // Callbacks (EventHandler and SyncReader) must exist until closed_task is
161 // called. 140 // called.
162 // 141 //
163 // It is safe to call this method more than once. Calls after the first one 142 // It is safe to call this method more than once. Calls after the first one
164 // will have no effect. 143 // will have no effect.
165 void Close(const base::Closure& closed_task); 144 void Close(const base::Closure& closed_task);
166 145
167 // Sets the volume of the audio output stream. 146 // Sets the volume of the audio output stream.
168 void SetVolume(double volume); 147 void SetVolume(double volume);
169 148
170 // Enqueue audio |data| into the controller. This method is used only in
171 // the regular latency mode and it is illegal to call this method when
172 // SyncReader is present.
173 void EnqueueData(const uint8* data, uint32 size);
174
175 bool LowLatencyMode() const { return sync_reader_ != NULL; }
176
177 /////////////////////////////////////////////////////////////////////////// 149 ///////////////////////////////////////////////////////////////////////////
178 // AudioSourceCallback methods. 150 // AudioSourceCallback methods.
179 virtual uint32 OnMoreData(AudioOutputStream* stream, 151 virtual uint32 OnMoreData(AudioOutputStream* stream,
180 uint8* dest, 152 uint8* dest,
181 uint32 max_size, 153 uint32 max_size,
182 AudioBuffersState buffers_state) OVERRIDE; 154 AudioBuffersState buffers_state) OVERRIDE;
183 virtual void OnError(AudioOutputStream* stream, int code) OVERRIDE; 155 virtual void OnError(AudioOutputStream* stream, int code) OVERRIDE;
184 virtual void WaitTillDataReady() OVERRIDE; 156 virtual void WaitTillDataReady() OVERRIDE;
185 157
186 protected: 158 protected:
(...skipping 12 matching lines...) Expand all
199 friend class base::RefCountedThreadSafe<AudioOutputController>; 171 friend class base::RefCountedThreadSafe<AudioOutputController>;
200 virtual ~AudioOutputController(); 172 virtual ~AudioOutputController();
201 173
202 private: 174 private:
203 // We are polling sync reader if data became available. 175 // We are polling sync reader if data became available.
204 static const int kPollNumAttempts; 176 static const int kPollNumAttempts;
205 static const int kPollPauseInMilliseconds; 177 static const int kPollPauseInMilliseconds;
206 178
207 AudioOutputController(AudioManager* audio_manager, 179 AudioOutputController(AudioManager* audio_manager,
208 EventHandler* handler, 180 EventHandler* handler,
209 uint32 capacity, SyncReader* sync_reader); 181 SyncReader* sync_reader);
210 182
211 // The following methods are executed on the audio controller thread. 183 // The following methods are executed on the audio manager thread.
212 void DoCreate(const AudioParameters& params); 184 void DoCreate(const AudioParameters& params);
213 void DoPlay(); 185 void DoPlay();
214 void PollAndStartIfDataReady(); 186 void PollAndStartIfDataReady();
215 void DoPause(); 187 void DoPause();
216 void DoFlush(); 188 void DoFlush();
217 void DoClose(const base::Closure& closed_task); 189 void DoClose(const base::Closure& closed_task);
218 void DoSetVolume(double volume); 190 void DoSetVolume(double volume);
219 void DoReportError(int code); 191 void DoReportError(int code);
220 192
221 // Helper method to submit a OnMoreData() call to the event handler.
222 void SubmitOnMoreData_Locked();
223
224 // Helper method that starts physical stream. 193 // Helper method that starts physical stream.
225 void StartStream(); 194 void StartStream();
226 195
227 // Helper method that stops, closes, and NULLs |*stream_|. 196 // Helper method that stops, closes, and NULLs |*stream_|.
228 // Signals event when done if it is not NULL. 197 // Signals event when done if it is not NULL.
229 void DoStopCloseAndClearStream(base::WaitableEvent *done); 198 void DoStopCloseAndClearStream(base::WaitableEvent *done);
230 199
231 scoped_refptr<AudioManager> audio_manager_; 200 scoped_refptr<AudioManager> audio_manager_;
232 // |handler_| may be called only if |state_| is not kClosed. 201 // |handler_| may be called only if |state_| is not kClosed.
233 EventHandler* handler_; 202 EventHandler* handler_;
234 AudioOutputStream* stream_; 203 AudioOutputStream* stream_;
235 204
236 // The current volume of the audio stream. 205 // The current volume of the audio stream.
237 double volume_; 206 double volume_;
238 207
239 // |state_| is written on the audio controller thread and is read on the 208 // |state_| is written on the audio manager thread and is read on the
240 // hardware audio thread. These operations need to be locked. But lock 209 // hardware audio thread. These operations need to be locked. But lock
241 // is not required for reading on the audio controller thread. 210 // is not required for reading on the audio manager thread.
242 State state_; 211 State state_;
243 212
244 AudioBuffersState buffers_state_; 213 // The |lock_| must be acquired whenever we access |state_| from a thread
245 214 // other than the audio manager thread.
246 // The |lock_| must be acquired whenever we access |buffer_|.
247 base::Lock lock_; 215 base::Lock lock_;
248 216
249 media::SeekableBuffer buffer_;
250
251 bool pending_request_;
252
253 // SyncReader is used only in low latency mode for synchronous reading. 217 // SyncReader is used only in low latency mode for synchronous reading.
254 SyncReader* sync_reader_; 218 SyncReader* sync_reader_;
255 219
256 // The message loop of audio thread that this object runs on. 220 // The message loop of audio manager thread that this object runs on.
257 scoped_refptr<base::MessageLoopProxy> message_loop_; 221 scoped_refptr<base::MessageLoopProxy> message_loop_;
258 222
259 // When starting stream we wait for data to become available. 223 // When starting stream we wait for data to become available.
260 // Number of times left. 224 // Number of times left.
261 int number_polling_attempts_left_; 225 int number_polling_attempts_left_;
262 226
263 // Used to post delayed tasks to ourselves that we can cancel. 227 // Used to post delayed tasks to ourselves that we can cancel.
264 // We don't want the tasks to hold onto a reference as it will slow down 228 // We don't want the tasks to hold onto a reference as it will slow down
265 // shutdown and force it to wait for the most delayed task. 229 // shutdown and force it to wait for the most delayed task.
266 // Also, if we're shutting down, we do not want to poll for more data. 230 // Also, if we're shutting down, we do not want to poll for more data.
267 base::WeakPtrFactory<AudioOutputController> weak_this_; 231 base::WeakPtrFactory<AudioOutputController> weak_this_;
268 232
269 DISALLOW_COPY_AND_ASSIGN(AudioOutputController); 233 DISALLOW_COPY_AND_ASSIGN(AudioOutputController);
270 }; 234 };
271 235
272 } // namespace media 236 } // namespace media
273 237
274 #endif // MEDIA_AUDIO_AUDIO_OUTPUT_CONTROLLER_H_ 238 #endif // MEDIA_AUDIO_AUDIO_OUTPUT_CONTROLLER_H_
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698