blob: 4db7f1512a7a35287412dfdc6f2149bc469a9a64 [file] [log] [blame]
Mathias Agopian65ab4712010-07-14 17:59:35 -07001/* //device/include/server/AudioFlinger/AudioFlinger.h
2**
3** Copyright 2007, The Android Open Source Project
4**
5** Licensed under the Apache License, Version 2.0 (the "License");
6** you may not use this file except in compliance with the License.
7** You may obtain a copy of the License at
8**
9** http://www.apache.org/licenses/LICENSE-2.0
10**
11** Unless required by applicable law or agreed to in writing, software
12** distributed under the License is distributed on an "AS IS" BASIS,
13** WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14** See the License for the specific language governing permissions and
15** limitations under the License.
16*/
17
18#ifndef ANDROID_AUDIO_FLINGER_H
19#define ANDROID_AUDIO_FLINGER_H
20
21#include <stdint.h>
22#include <sys/types.h>
23#include <limits.h>
24
25#include <media/IAudioFlinger.h>
26#include <media/IAudioFlingerClient.h>
27#include <media/IAudioTrack.h>
28#include <media/IAudioRecord.h>
Glenn Kasten335787f2012-01-20 17:00:00 -080029#include <media/AudioSystem.h>
Mathias Agopian65ab4712010-07-14 17:59:35 -070030
31#include <utils/Atomic.h>
32#include <utils/Errors.h>
33#include <utils/threads.h>
Mathias Agopian65ab4712010-07-14 17:59:35 -070034#include <utils/SortedVector.h>
Dima Zavin799a70e2011-04-18 16:57:27 -070035#include <utils/TypeHelpers.h>
Mathias Agopian65ab4712010-07-14 17:59:35 -070036#include <utils/Vector.h>
37
Mathias Agopian5462fc92010-07-14 18:41:18 -070038#include <binder/BinderService.h>
39#include <binder/MemoryDealer.h>
40
Dima Zavin64760242011-05-11 14:15:23 -070041#include <system/audio.h>
Dima Zavin7394a4f2011-06-13 18:16:26 -070042#include <hardware/audio.h>
Mathias Agopian65ab4712010-07-14 17:59:35 -070043
44#include "AudioBufferProvider.h"
45
Eric Laurentfeb0db62011-07-22 09:04:31 -070046#include <powermanager/IPowerManager.h>
47
Mathias Agopian65ab4712010-07-14 17:59:35 -070048namespace android {
49
50class audio_track_cblk_t;
51class effect_param_cblk_t;
52class AudioMixer;
53class AudioBuffer;
54class AudioResampler;
55
Mathias Agopian65ab4712010-07-14 17:59:35 -070056// ----------------------------------------------------------------------------
57
Mathias Agopian65ab4712010-07-14 17:59:35 -070058static const nsecs_t kStandbyTimeInNsecs = seconds(3);
59
Mathias Agopian5462fc92010-07-14 18:41:18 -070060class AudioFlinger :
61 public BinderService<AudioFlinger>,
62 public BnAudioFlinger
Mathias Agopian65ab4712010-07-14 17:59:35 -070063{
Mathias Agopian5462fc92010-07-14 18:41:18 -070064 friend class BinderService<AudioFlinger>;
Mathias Agopian65ab4712010-07-14 17:59:35 -070065public:
Glenn Kasten54c3b662012-01-06 07:46:30 -080066 static const char* getServiceName() { return "media.audio_flinger"; }
Mathias Agopian65ab4712010-07-14 17:59:35 -070067
68 virtual status_t dump(int fd, const Vector<String16>& args);
69
70 // IAudioFlinger interface
71 virtual sp<IAudioTrack> createTrack(
72 pid_t pid,
Glenn Kastenfff6d712012-01-12 16:38:12 -080073 audio_stream_type_t streamType,
Mathias Agopian65ab4712010-07-14 17:59:35 -070074 uint32_t sampleRate,
Glenn Kasten58f30212012-01-12 12:27:51 -080075 audio_format_t format,
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -070076 uint32_t channelMask,
Mathias Agopian65ab4712010-07-14 17:59:35 -070077 int frameCount,
78 uint32_t flags,
79 const sp<IMemory>& sharedBuffer,
80 int output,
81 int *sessionId,
82 status_t *status);
83
84 virtual uint32_t sampleRate(int output) const;
85 virtual int channelCount(int output) const;
Glenn Kasten58f30212012-01-12 12:27:51 -080086 virtual audio_format_t format(int output) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -070087 virtual size_t frameCount(int output) const;
88 virtual uint32_t latency(int output) const;
89
90 virtual status_t setMasterVolume(float value);
91 virtual status_t setMasterMute(bool muted);
92
93 virtual float masterVolume() const;
94 virtual bool masterMute() const;
95
Glenn Kastenfff6d712012-01-12 16:38:12 -080096 virtual status_t setStreamVolume(audio_stream_type_t stream, float value, int output);
97 virtual status_t setStreamMute(audio_stream_type_t stream, bool muted);
Mathias Agopian65ab4712010-07-14 17:59:35 -070098
Glenn Kastenfff6d712012-01-12 16:38:12 -080099 virtual float streamVolume(audio_stream_type_t stream, int output) const;
100 virtual bool streamMute(audio_stream_type_t stream) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700101
Glenn Kastenf78aee72012-01-04 11:00:47 -0800102 virtual status_t setMode(audio_mode_t mode);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700103
104 virtual status_t setMicMute(bool state);
105 virtual bool getMicMute() const;
106
Mathias Agopian65ab4712010-07-14 17:59:35 -0700107 virtual status_t setParameters(int ioHandle, const String8& keyValuePairs);
Glenn Kastenf587ba52012-01-26 16:25:10 -0800108 virtual String8 getParameters(int ioHandle, const String8& keys) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700109
110 virtual void registerClient(const sp<IAudioFlingerClient>& client);
111
Glenn Kastenf587ba52012-01-26 16:25:10 -0800112 virtual size_t getInputBufferSize(uint32_t sampleRate, audio_format_t format, int channelCount) const;
113 virtual unsigned int getInputFramesLost(int ioHandle) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700114
115 virtual int openOutput(uint32_t *pDevices,
116 uint32_t *pSamplingRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800117 audio_format_t *pFormat,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700118 uint32_t *pChannels,
119 uint32_t *pLatencyMs,
120 uint32_t flags);
121
122 virtual int openDuplicateOutput(int output1, int output2);
123
124 virtual status_t closeOutput(int output);
125
126 virtual status_t suspendOutput(int output);
127
128 virtual status_t restoreOutput(int output);
129
130 virtual int openInput(uint32_t *pDevices,
131 uint32_t *pSamplingRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800132 audio_format_t *pFormat,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700133 uint32_t *pChannels,
Glenn Kastende9719b2012-01-27 12:32:34 -0800134 audio_in_acoustics_t acoustics);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700135
136 virtual status_t closeInput(int input);
137
Glenn Kastenfff6d712012-01-12 16:38:12 -0800138 virtual status_t setStreamOutput(audio_stream_type_t stream, int output);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700139
140 virtual status_t setVoiceVolume(float volume);
141
Glenn Kastenf587ba52012-01-26 16:25:10 -0800142 virtual status_t getRenderPosition(uint32_t *halFrames, uint32_t *dspFrames, int output) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700143
144 virtual int newAudioSessionId();
145
Marco Nelissen3a34bef2011-08-02 13:33:41 -0700146 virtual void acquireAudioSessionId(int audioSession);
147
148 virtual void releaseAudioSessionId(int audioSession);
149
Glenn Kastenf587ba52012-01-26 16:25:10 -0800150 virtual status_t queryNumberEffects(uint32_t *numEffects) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700151
Glenn Kastenf587ba52012-01-26 16:25:10 -0800152 virtual status_t queryEffect(uint32_t index, effect_descriptor_t *descriptor) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700153
Glenn Kastenf587ba52012-01-26 16:25:10 -0800154 virtual status_t getEffectDescriptor(effect_uuid_t *pUuid,
155 effect_descriptor_t *descriptor) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700156
157 virtual sp<IEffect> createEffect(pid_t pid,
158 effect_descriptor_t *pDesc,
159 const sp<IEffectClient>& effectClient,
160 int32_t priority,
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700161 int io,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700162 int sessionId,
163 status_t *status,
164 int *id,
165 int *enabled);
166
Eric Laurent59255e42011-07-27 19:49:51 -0700167 virtual status_t moveEffects(int sessionId, int srcOutput, int dstOutput);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700168
169 enum hardware_call_state {
170 AUDIO_HW_IDLE = 0,
171 AUDIO_HW_INIT,
172 AUDIO_HW_OUTPUT_OPEN,
173 AUDIO_HW_OUTPUT_CLOSE,
174 AUDIO_HW_INPUT_OPEN,
175 AUDIO_HW_INPUT_CLOSE,
176 AUDIO_HW_STANDBY,
177 AUDIO_HW_SET_MASTER_VOLUME,
178 AUDIO_HW_GET_ROUTING,
179 AUDIO_HW_SET_ROUTING,
180 AUDIO_HW_GET_MODE,
181 AUDIO_HW_SET_MODE,
182 AUDIO_HW_GET_MIC_MUTE,
183 AUDIO_HW_SET_MIC_MUTE,
184 AUDIO_SET_VOICE_VOLUME,
185 AUDIO_SET_PARAMETER,
186 };
187
188 // record interface
189 virtual sp<IAudioRecord> openRecord(
190 pid_t pid,
191 int input,
192 uint32_t sampleRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800193 audio_format_t format,
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700194 uint32_t channelMask,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700195 int frameCount,
196 uint32_t flags,
197 int *sessionId,
198 status_t *status);
199
200 virtual status_t onTransact(
201 uint32_t code,
202 const Parcel& data,
203 Parcel* reply,
204 uint32_t flags);
205
Glenn Kastenf78aee72012-01-04 11:00:47 -0800206 audio_mode_t getMode() const { return mMode; }
Mathias Agopian65ab4712010-07-14 17:59:35 -0700207
Eric Laurentbee53372011-08-29 12:42:48 -0700208 bool btNrecIsOff() { return mBtNrecIsOff; }
Eric Laurent59bd0da2011-08-01 09:52:20 -0700209
Mathias Agopian65ab4712010-07-14 17:59:35 -0700210private:
Glenn Kasten335787f2012-01-20 17:00:00 -0800211
Mathias Agopian65ab4712010-07-14 17:59:35 -0700212 AudioFlinger();
213 virtual ~AudioFlinger();
214
Dima Zavin5a61d2f2011-04-19 19:04:32 -0700215 status_t initCheck() const;
216 virtual void onFirstRef();
Dima Zavin799a70e2011-04-18 16:57:27 -0700217 audio_hw_device_t* findSuitableHwDev_l(uint32_t devices);
Marco Nelissen3a34bef2011-08-02 13:33:41 -0700218 void purgeStaleEffects_l();
Mathias Agopian65ab4712010-07-14 17:59:35 -0700219
220 // Internal dump utilites.
221 status_t dumpPermissionDenial(int fd, const Vector<String16>& args);
222 status_t dumpClients(int fd, const Vector<String16>& args);
223 status_t dumpInternals(int fd, const Vector<String16>& args);
224
225 // --- Client ---
226 class Client : public RefBase {
227 public:
228 Client(const sp<AudioFlinger>& audioFlinger, pid_t pid);
229 virtual ~Client();
Glenn Kasten435dbe62012-01-30 10:15:48 -0800230 sp<MemoryDealer> heap() const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700231 pid_t pid() const { return mPid; }
232 sp<AudioFlinger> audioFlinger() { return mAudioFlinger; }
233
234 private:
235 Client(const Client&);
236 Client& operator = (const Client&);
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800237 const sp<AudioFlinger> mAudioFlinger;
238 const sp<MemoryDealer> mMemoryDealer;
239 const pid_t mPid;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700240 };
241
242 // --- Notification Client ---
243 class NotificationClient : public IBinder::DeathRecipient {
244 public:
245 NotificationClient(const sp<AudioFlinger>& audioFlinger,
246 const sp<IAudioFlingerClient>& client,
247 pid_t pid);
248 virtual ~NotificationClient();
249
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800250 sp<IAudioFlingerClient> audioFlingerClient() const { return mAudioFlingerClient; }
Mathias Agopian65ab4712010-07-14 17:59:35 -0700251
252 // IBinder::DeathRecipient
253 virtual void binderDied(const wp<IBinder>& who);
254
255 private:
256 NotificationClient(const NotificationClient&);
257 NotificationClient& operator = (const NotificationClient&);
258
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800259 const sp<AudioFlinger> mAudioFlinger;
260 const pid_t mPid;
261 const sp<IAudioFlingerClient> mAudioFlingerClient;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700262 };
263
264 class TrackHandle;
265 class RecordHandle;
266 class RecordThread;
267 class PlaybackThread;
268 class MixerThread;
269 class DirectOutputThread;
270 class DuplicatingThread;
271 class Track;
272 class RecordTrack;
273 class EffectModule;
274 class EffectHandle;
275 class EffectChain;
Dima Zavin799a70e2011-04-18 16:57:27 -0700276 struct AudioStreamOut;
277 struct AudioStreamIn;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700278
279 class ThreadBase : public Thread {
280 public:
Mathias Agopian65ab4712010-07-14 17:59:35 -0700281
Glenn Kasten23bb8be2012-01-26 10:38:26 -0800282 enum type_t {
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700283 MIXER, // Thread class is MixerThread
284 DIRECT, // Thread class is DirectOutputThread
285 DUPLICATING, // Thread class is DuplicatingThread
286 RECORD // Thread class is RecordThread
287 };
288
Glenn Kasten23bb8be2012-01-26 10:38:26 -0800289 ThreadBase (const sp<AudioFlinger>& audioFlinger, int id, uint32_t device, type_t type);
290 virtual ~ThreadBase();
291
Mathias Agopian65ab4712010-07-14 17:59:35 -0700292 status_t dumpBase(int fd, const Vector<String16>& args);
Eric Laurent1d2bff02011-07-24 17:49:51 -0700293 status_t dumpEffectChains(int fd, const Vector<String16>& args);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700294
Eric Laurentfeb0db62011-07-22 09:04:31 -0700295 void clearPowerManager();
296
Mathias Agopian65ab4712010-07-14 17:59:35 -0700297 // base for record and playback
298 class TrackBase : public AudioBufferProvider, public RefBase {
299
300 public:
301 enum track_state {
302 IDLE,
303 TERMINATED,
304 STOPPED,
305 RESUMING,
306 ACTIVE,
307 PAUSING,
308 PAUSED
309 };
310
311 enum track_flags {
312 STEPSERVER_FAILED = 0x01, // StepServer could not acquire cblk->lock mutex
313 SYSTEM_FLAGS_MASK = 0x0000ffffUL,
314 // The upper 16 bits are used for track-specific flags.
315 };
316
317 TrackBase(const wp<ThreadBase>& thread,
318 const sp<Client>& client,
319 uint32_t sampleRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800320 audio_format_t format,
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700321 uint32_t channelMask,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700322 int frameCount,
323 uint32_t flags,
324 const sp<IMemory>& sharedBuffer,
325 int sessionId);
326 ~TrackBase();
327
328 virtual status_t start() = 0;
329 virtual void stop() = 0;
330 sp<IMemory> getCblk() const;
331 audio_track_cblk_t* cblk() const { return mCblk; }
332 int sessionId() { return mSessionId; }
333
334 protected:
335 friend class ThreadBase;
336 friend class RecordHandle;
337 friend class PlaybackThread;
338 friend class RecordThread;
339 friend class MixerThread;
340 friend class DirectOutputThread;
341
342 TrackBase(const TrackBase&);
343 TrackBase& operator = (const TrackBase&);
344
345 virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer) = 0;
346 virtual void releaseBuffer(AudioBufferProvider::Buffer* buffer);
347
Glenn Kasten58f30212012-01-12 12:27:51 -0800348 audio_format_t format() const {
Mathias Agopian65ab4712010-07-14 17:59:35 -0700349 return mFormat;
350 }
351
352 int channelCount() const ;
353
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700354 uint32_t channelMask() const;
355
Mathias Agopian65ab4712010-07-14 17:59:35 -0700356 int sampleRate() const;
357
358 void* getBuffer(uint32_t offset, uint32_t frames) const;
359
360 bool isStopped() const {
361 return mState == STOPPED;
362 }
363
364 bool isTerminated() const {
365 return mState == TERMINATED;
366 }
367
368 bool step();
369 void reset();
370
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800371 const wp<ThreadBase> mThread;
372 /*const*/ sp<Client> mClient; // see explanation at ~TrackBase() why not const
Mathias Agopian65ab4712010-07-14 17:59:35 -0700373 sp<IMemory> mCblkMemory;
374 audio_track_cblk_t* mCblk;
375 void* mBuffer;
376 void* mBufferEnd;
377 uint32_t mFrameCount;
378 // we don't really need a lock for these
Glenn Kastenb853e982012-01-26 13:39:18 -0800379 track_state mState;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700380 int mClientTid;
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800381 const audio_format_t mFormat;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700382 uint32_t mFlags;
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800383 const int mSessionId;
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700384 uint8_t mChannelCount;
385 uint32_t mChannelMask;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700386 };
387
388 class ConfigEvent {
389 public:
390 ConfigEvent() : mEvent(0), mParam(0) {}
391
392 int mEvent;
393 int mParam;
394 };
395
Eric Laurentfeb0db62011-07-22 09:04:31 -0700396 class PMDeathRecipient : public IBinder::DeathRecipient {
397 public:
398 PMDeathRecipient(const wp<ThreadBase>& thread) : mThread(thread) {}
399 virtual ~PMDeathRecipient() {}
400
401 // IBinder::DeathRecipient
402 virtual void binderDied(const wp<IBinder>& who);
403
404 private:
405 PMDeathRecipient(const PMDeathRecipient&);
406 PMDeathRecipient& operator = (const PMDeathRecipient&);
407
408 wp<ThreadBase> mThread;
409 };
410
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700411 virtual status_t initCheck() const = 0;
Glenn Kasten23bb8be2012-01-26 10:38:26 -0800412 type_t type() const { return mType; }
Mathias Agopian65ab4712010-07-14 17:59:35 -0700413 uint32_t sampleRate() const;
414 int channelCount() const;
Glenn Kasten58f30212012-01-12 12:27:51 -0800415 audio_format_t format() const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700416 size_t frameCount() const;
417 void wakeUp() { mWaitWorkCV.broadcast(); }
418 void exit();
419 virtual bool checkForNewParameters_l() = 0;
420 virtual status_t setParameters(const String8& keyValuePairs);
421 virtual String8 getParameters(const String8& keys) = 0;
422 virtual void audioConfigChanged_l(int event, int param = 0) = 0;
423 void sendConfigEvent(int event, int param = 0);
424 void sendConfigEvent_l(int event, int param = 0);
425 void processConfigEvents();
426 int id() const { return mId;}
427 bool standby() { return mStandby; }
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700428 uint32_t device() { return mDevice; }
429 virtual audio_stream_t* stream() = 0;
430
431 sp<EffectHandle> createEffect_l(
432 const sp<AudioFlinger::Client>& client,
433 const sp<IEffectClient>& effectClient,
434 int32_t priority,
435 int sessionId,
436 effect_descriptor_t *desc,
437 int *enabled,
438 status_t *status);
439 void disconnectEffect(const sp< EffectModule>& effect,
Marco Nelissen3a34bef2011-08-02 13:33:41 -0700440 const wp<EffectHandle>& handle,
441 bool unpiniflast);
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700442
443 // return values for hasAudioSession (bit field)
444 enum effect_state {
445 EFFECT_SESSION = 0x1, // the audio session corresponds to at least one
446 // effect
447 TRACK_SESSION = 0x2 // the audio session corresponds to at least one
448 // track
449 };
450
451 // get effect chain corresponding to session Id.
452 sp<EffectChain> getEffectChain(int sessionId);
453 // same as getEffectChain() but must be called with ThreadBase mutex locked
454 sp<EffectChain> getEffectChain_l(int sessionId);
455 // add an effect chain to the chain list (mEffectChains)
456 virtual status_t addEffectChain_l(const sp<EffectChain>& chain) = 0;
457 // remove an effect chain from the chain list (mEffectChains)
458 virtual size_t removeEffectChain_l(const sp<EffectChain>& chain) = 0;
459 // lock mall effect chains Mutexes. Must be called before releasing the
460 // ThreadBase mutex before processing the mixer and effects. This guarantees the
461 // integrity of the chains during the process.
462 void lockEffectChains_l(Vector<sp <EffectChain> >& effectChains);
463 // unlock effect chains after process
464 void unlockEffectChains(Vector<sp <EffectChain> >& effectChains);
465 // set audio mode to all effect chains
Glenn Kastenf78aee72012-01-04 11:00:47 -0800466 void setMode(audio_mode_t mode);
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700467 // get effect module with corresponding ID on specified audio session
468 sp<AudioFlinger::EffectModule> getEffect_l(int sessionId, int effectId);
469 // add and effect module. Also creates the effect chain is none exists for
470 // the effects audio session
471 status_t addEffect_l(const sp< EffectModule>& effect);
472 // remove and effect module. Also removes the effect chain is this was the last
473 // effect
474 void removeEffect_l(const sp< EffectModule>& effect);
475 // detach all tracks connected to an auxiliary effect
476 virtual void detachAuxEffect_l(int effectId) {}
477 // returns either EFFECT_SESSION if effects on this audio session exist in one
478 // chain, or TRACK_SESSION if tracks on this audio session exist, or both
479 virtual uint32_t hasAudioSession(int sessionId) = 0;
480 // the value returned by default implementation is not important as the
481 // strategy is only meaningful for PlaybackThread which implements this method
482 virtual uint32_t getStrategyForSession_l(int sessionId) { return 0; }
Mathias Agopian65ab4712010-07-14 17:59:35 -0700483
Eric Laurent59255e42011-07-27 19:49:51 -0700484 // suspend or restore effect according to the type of effect passed. a NULL
485 // type pointer means suspend all effects in the session
486 void setEffectSuspended(const effect_uuid_t *type,
487 bool suspend,
488 int sessionId = AUDIO_SESSION_OUTPUT_MIX);
489 // check if some effects must be suspended/restored when an effect is enabled
490 // or disabled
Eric Laurenta85a74a2011-10-19 11:44:54 -0700491 void checkSuspendOnEffectEnabled(const sp<EffectModule>& effect,
Eric Laurent59255e42011-07-27 19:49:51 -0700492 bool enabled,
493 int sessionId = AUDIO_SESSION_OUTPUT_MIX);
Eric Laurenta85a74a2011-10-19 11:44:54 -0700494 void checkSuspendOnEffectEnabled_l(const sp<EffectModule>& effect,
495 bool enabled,
496 int sessionId = AUDIO_SESSION_OUTPUT_MIX);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700497 mutable Mutex mLock;
498
499 protected:
500
Eric Laurent59255e42011-07-27 19:49:51 -0700501 // entry describing an effect being suspended in mSuspendedSessions keyed vector
502 class SuspendedSessionDesc : public RefBase {
503 public:
504 SuspendedSessionDesc() : mRefCount(0) {}
505
506 int mRefCount; // number of active suspend requests
507 effect_uuid_t mType; // effect type UUID
508 };
509
Eric Laurentfeb0db62011-07-22 09:04:31 -0700510 void acquireWakeLock();
511 void acquireWakeLock_l();
512 void releaseWakeLock();
513 void releaseWakeLock_l();
Eric Laurent59255e42011-07-27 19:49:51 -0700514 void setEffectSuspended_l(const effect_uuid_t *type,
515 bool suspend,
516 int sessionId = AUDIO_SESSION_OUTPUT_MIX);
517 // updated mSuspendedSessions when an effect suspended or restored
518 void updateSuspendedSessions_l(const effect_uuid_t *type,
519 bool suspend,
520 int sessionId);
521 // check if some effects must be suspended when an effect chain is added
522 void checkSuspendOnAddEffectChain_l(const sp<EffectChain>& chain);
Eric Laurentfeb0db62011-07-22 09:04:31 -0700523
Marco Nelissen3a34bef2011-08-02 13:33:41 -0700524 friend class AudioFlinger;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700525 friend class Track;
526 friend class TrackBase;
527 friend class PlaybackThread;
528 friend class MixerThread;
529 friend class DirectOutputThread;
530 friend class DuplicatingThread;
531 friend class RecordThread;
532 friend class RecordTrack;
533
Glenn Kasten23bb8be2012-01-26 10:38:26 -0800534 const type_t mType;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700535 Condition mWaitWorkCV;
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800536 const sp<AudioFlinger> mAudioFlinger;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700537 uint32_t mSampleRate;
538 size_t mFrameCount;
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700539 uint32_t mChannelMask;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700540 uint16_t mChannelCount;
Glenn Kastenb9980652012-01-11 09:48:27 -0800541 size_t mFrameSize;
Glenn Kasten58f30212012-01-12 12:27:51 -0800542 audio_format_t mFormat;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700543 Condition mParamCond;
544 Vector<String8> mNewParameters;
545 status_t mParamStatus;
Glenn Kastenf3990f22011-12-13 11:50:00 -0800546 Vector<ConfigEvent> mConfigEvents;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700547 bool mStandby;
548 int mId;
549 bool mExiting;
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700550 Vector< sp<EffectChain> > mEffectChains;
551 uint32_t mDevice; // output device for PlaybackThread
552 // input + output devices for RecordThread
Eric Laurentfeb0db62011-07-22 09:04:31 -0700553 static const int kNameLength = 32;
554 char mName[kNameLength];
555 sp<IPowerManager> mPowerManager;
556 sp<IBinder> mWakeLockToken;
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800557 const sp<PMDeathRecipient> mDeathRecipient;
Eric Laurent59255e42011-07-27 19:49:51 -0700558 // list of suspended effects per session and per type. The first vector is
559 // keyed by session ID, the second by type UUID timeLow field
560 KeyedVector< int, KeyedVector< int, sp<SuspendedSessionDesc> > > mSuspendedSessions;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700561 };
562
563 // --- PlaybackThread ---
564 class PlaybackThread : public ThreadBase {
565 public:
566
Mathias Agopian65ab4712010-07-14 17:59:35 -0700567 enum mixer_state {
568 MIXER_IDLE,
569 MIXER_TRACKS_ENABLED,
570 MIXER_TRACKS_READY
571 };
572
573 // playback track
574 class Track : public TrackBase {
575 public:
576 Track( const wp<ThreadBase>& thread,
577 const sp<Client>& client,
Glenn Kastenfff6d712012-01-12 16:38:12 -0800578 audio_stream_type_t streamType,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700579 uint32_t sampleRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800580 audio_format_t format,
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700581 uint32_t channelMask,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700582 int frameCount,
583 const sp<IMemory>& sharedBuffer,
584 int sessionId);
585 ~Track();
586
587 void dump(char* buffer, size_t size);
588 virtual status_t start();
589 virtual void stop();
590 void pause();
591
592 void flush();
593 void destroy();
594 void mute(bool);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700595 int name() const {
596 return mName;
597 }
598
Glenn Kastenfff6d712012-01-12 16:38:12 -0800599 audio_stream_type_t type() const {
Mathias Agopian65ab4712010-07-14 17:59:35 -0700600 return mStreamType;
601 }
602 status_t attachAuxEffect(int EffectId);
603 void setAuxBuffer(int EffectId, int32_t *buffer);
604 int32_t *auxBuffer() { return mAuxBuffer; }
605 void setMainBuffer(int16_t *buffer) { mMainBuffer = buffer; }
606 int16_t *mainBuffer() { return mMainBuffer; }
607 int auxEffectId() { return mAuxEffectId; }
608
609
610 protected:
611 friend class ThreadBase;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700612 friend class TrackHandle;
613 friend class PlaybackThread;
614 friend class MixerThread;
615 friend class DirectOutputThread;
616
617 Track(const Track&);
618 Track& operator = (const Track&);
619
620 virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer);
621 bool isMuted() { return mMute; }
622 bool isPausing() const {
623 return mState == PAUSING;
624 }
625 bool isPaused() const {
626 return mState == PAUSED;
627 }
628 bool isReady() const;
629 void setPaused() { mState = PAUSED; }
630 void reset();
631
632 bool isOutputTrack() const {
Dima Zavinfce7a472011-04-19 22:30:36 -0700633 return (mStreamType == AUDIO_STREAM_CNT);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700634 }
635
636 // we don't really need a lock for these
Mathias Agopian65ab4712010-07-14 17:59:35 -0700637 volatile bool mMute;
638 // FILLED state is used for suppressing volume ramp at begin of playing
639 enum {FS_FILLING, FS_FILLED, FS_ACTIVE};
640 mutable uint8_t mFillingUpStatus;
641 int8_t mRetryCount;
642 sp<IMemory> mSharedBuffer;
643 bool mResetDone;
Glenn Kastenfff6d712012-01-12 16:38:12 -0800644 audio_stream_type_t mStreamType;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700645 int mName;
646 int16_t *mMainBuffer;
647 int32_t *mAuxBuffer;
648 int mAuxEffectId;
Eric Laurent8f45bd72010-08-31 13:50:07 -0700649 bool mHasVolumeController;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700650 }; // end of Track
651
652
653 // playback track
654 class OutputTrack : public Track {
655 public:
656
657 class Buffer: public AudioBufferProvider::Buffer {
658 public:
659 int16_t *mBuffer;
660 };
661
662 OutputTrack( const wp<ThreadBase>& thread,
663 DuplicatingThread *sourceThread,
664 uint32_t sampleRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800665 audio_format_t format,
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700666 uint32_t channelMask,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700667 int frameCount);
668 ~OutputTrack();
669
670 virtual status_t start();
671 virtual void stop();
672 bool write(int16_t* data, uint32_t frames);
673 bool bufferQueueEmpty() { return (mBufferQueue.size() == 0) ? true : false; }
674 bool isActive() { return mActive; }
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800675 const wp<ThreadBase>& thread() { return mThread; }
Mathias Agopian65ab4712010-07-14 17:59:35 -0700676
677 private:
678
Glenn Kasten335787f2012-01-20 17:00:00 -0800679 enum {
680 NO_MORE_BUFFERS = 0x80000001, // same in AudioTrack.h, ok to be different value
681 };
682
Mathias Agopian65ab4712010-07-14 17:59:35 -0700683 status_t obtainBuffer(AudioBufferProvider::Buffer* buffer, uint32_t waitTimeMs);
684 void clearBufferQueue();
685
686 // Maximum number of pending buffers allocated by OutputTrack::write()
687 static const uint8_t kMaxOverFlowBuffers = 10;
688
689 Vector < Buffer* > mBufferQueue;
690 AudioBufferProvider::Buffer mOutBuffer;
691 bool mActive;
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800692 DuplicatingThread* const mSourceThread; // for waitTimeMs() in write()
Mathias Agopian65ab4712010-07-14 17:59:35 -0700693 }; // end of OutputTrack
694
Glenn Kasten23bb8be2012-01-26 10:38:26 -0800695 PlaybackThread (const sp<AudioFlinger>& audioFlinger, AudioStreamOut* output, int id,
696 uint32_t device, type_t type);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700697 virtual ~PlaybackThread();
698
699 virtual status_t dump(int fd, const Vector<String16>& args);
700
701 // Thread virtuals
702 virtual status_t readyToRun();
703 virtual void onFirstRef();
704
Glenn Kastene0feee32011-12-13 11:53:26 -0800705 virtual status_t initCheck() const { return (mOutput == NULL) ? NO_INIT : NO_ERROR; }
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700706
Mathias Agopian65ab4712010-07-14 17:59:35 -0700707 virtual uint32_t latency() const;
708
709 virtual status_t setMasterVolume(float value);
710 virtual status_t setMasterMute(bool muted);
711
712 virtual float masterVolume() const;
713 virtual bool masterMute() const;
714
Glenn Kastenfff6d712012-01-12 16:38:12 -0800715 virtual status_t setStreamVolume(audio_stream_type_t stream, float value);
716 virtual status_t setStreamMute(audio_stream_type_t stream, bool muted);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700717
Glenn Kastenfff6d712012-01-12 16:38:12 -0800718 virtual float streamVolume(audio_stream_type_t stream) const;
719 virtual bool streamMute(audio_stream_type_t stream) const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700720
Mathias Agopian65ab4712010-07-14 17:59:35 -0700721 sp<Track> createTrack_l(
722 const sp<AudioFlinger::Client>& client,
Glenn Kastenfff6d712012-01-12 16:38:12 -0800723 audio_stream_type_t streamType,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700724 uint32_t sampleRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800725 audio_format_t format,
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700726 uint32_t channelMask,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700727 int frameCount,
728 const sp<IMemory>& sharedBuffer,
729 int sessionId,
730 status_t *status);
731
Glenn Kastenaed850d2012-01-26 09:46:34 -0800732 AudioStreamOut* getOutput() const;
Eric Laurentb8ba0a92011-08-07 16:32:26 -0700733 AudioStreamOut* clearOutput();
734 virtual audio_stream_t* stream();
Mathias Agopian65ab4712010-07-14 17:59:35 -0700735
Mathias Agopian65ab4712010-07-14 17:59:35 -0700736 void suspend() { mSuspended++; }
737 void restore() { if (mSuspended) mSuspended--; }
Glenn Kastena3a85482012-01-04 11:01:11 -0800738 bool isSuspended() const { return (mSuspended != 0); }
Mathias Agopian65ab4712010-07-14 17:59:35 -0700739 virtual String8 getParameters(const String8& keys);
740 virtual void audioConfigChanged_l(int event, int param = 0);
741 virtual status_t getRenderPosition(uint32_t *halFrames, uint32_t *dspFrames);
742 int16_t *mixBuffer() { return mMixBuffer; };
743
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700744 virtual void detachAuxEffect_l(int effectId);
Eric Laurentde070132010-07-13 04:45:46 -0700745 status_t attachAuxEffect(const sp<AudioFlinger::PlaybackThread::Track> track,
746 int EffectId);
747 status_t attachAuxEffect_l(const sp<AudioFlinger::PlaybackThread::Track> track,
748 int EffectId);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700749
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700750 virtual status_t addEffectChain_l(const sp<EffectChain>& chain);
751 virtual size_t removeEffectChain_l(const sp<EffectChain>& chain);
752 virtual uint32_t hasAudioSession(int sessionId);
753 virtual uint32_t getStrategyForSession_l(int sessionId);
Eric Laurentde070132010-07-13 04:45:46 -0700754
Glenn Kastenfff6d712012-01-12 16:38:12 -0800755 void setStreamValid(audio_stream_type_t streamType, bool valid);
Eric Laurent9f6530f2011-08-30 10:18:54 -0700756
Mathias Agopian65ab4712010-07-14 17:59:35 -0700757 struct stream_type_t {
758 stream_type_t()
759 : volume(1.0f),
Eric Laurent9f6530f2011-08-30 10:18:54 -0700760 mute(false),
761 valid(true)
Mathias Agopian65ab4712010-07-14 17:59:35 -0700762 {
763 }
764 float volume;
765 bool mute;
Eric Laurent9f6530f2011-08-30 10:18:54 -0700766 bool valid;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700767 };
768
769 protected:
Mathias Agopian65ab4712010-07-14 17:59:35 -0700770 int16_t* mMixBuffer;
771 int mSuspended;
772 int mBytesWritten;
Glenn Kasten98067102011-12-13 11:47:54 -0800773 private:
Mathias Agopian65ab4712010-07-14 17:59:35 -0700774 bool mMasterMute;
Glenn Kasten98067102011-12-13 11:47:54 -0800775 protected:
Mathias Agopian65ab4712010-07-14 17:59:35 -0700776 SortedVector< wp<Track> > mActiveTracks;
777
778 virtual int getTrackName_l() = 0;
779 virtual void deleteTrackName_l(int name) = 0;
Eric Laurent162b40b2011-12-05 09:47:19 -0800780 virtual uint32_t activeSleepTimeUs();
Mathias Agopian65ab4712010-07-14 17:59:35 -0700781 virtual uint32_t idleSleepTimeUs() = 0;
Eric Laurent25cbe0e2010-08-18 18:13:17 -0700782 virtual uint32_t suspendSleepTimeUs() = 0;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700783
784 private:
785
786 friend class AudioFlinger;
787 friend class OutputTrack;
788 friend class Track;
789 friend class TrackBase;
790 friend class MixerThread;
791 friend class DirectOutputThread;
792 friend class DuplicatingThread;
793
794 PlaybackThread(const Client&);
795 PlaybackThread& operator = (const PlaybackThread&);
796
797 status_t addTrack_l(const sp<Track>& track);
798 void destroyTrack_l(const sp<Track>& track);
Eric Laurentb469b942011-05-09 12:09:06 -0700799 void removeTrack_l(const sp<Track>& track);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700800
801 void readOutputParameters();
802
Mathias Agopian65ab4712010-07-14 17:59:35 -0700803 virtual status_t dumpInternals(int fd, const Vector<String16>& args);
804 status_t dumpTracks(int fd, const Vector<String16>& args);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700805
806 SortedVector< sp<Track> > mTracks;
Glenn Kasten263709e2012-01-06 08:40:01 -0800807 // mStreamTypes[] uses 1 additional stream type internally for the OutputTrack used by DuplicatingThread
Dima Zavinfce7a472011-04-19 22:30:36 -0700808 stream_type_t mStreamTypes[AUDIO_STREAM_CNT + 1];
Glenn Kastenaed850d2012-01-26 09:46:34 -0800809 AudioStreamOut *mOutput;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700810 float mMasterVolume;
811 nsecs_t mLastWriteTime;
812 int mNumWrites;
813 int mNumDelayedWrites;
814 bool mInWrite;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700815 };
816
817 class MixerThread : public PlaybackThread {
818 public:
Eric Laurentde070132010-07-13 04:45:46 -0700819 MixerThread (const sp<AudioFlinger>& audioFlinger,
Dima Zavin799a70e2011-04-18 16:57:27 -0700820 AudioStreamOut* output,
Eric Laurentde070132010-07-13 04:45:46 -0700821 int id,
Glenn Kasten23bb8be2012-01-26 10:38:26 -0800822 uint32_t device,
823 type_t type = MIXER);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700824 virtual ~MixerThread();
825
826 // Thread virtuals
827 virtual bool threadLoop();
828
Glenn Kastenfff6d712012-01-12 16:38:12 -0800829 void invalidateTracks(audio_stream_type_t streamType);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700830 virtual bool checkForNewParameters_l();
831 virtual status_t dumpInternals(int fd, const Vector<String16>& args);
832
833 protected:
Glenn Kasten29c23c32012-01-26 13:37:52 -0800834 mixer_state prepareTracks_l(const SortedVector< wp<Track> >& activeTracks,
Eric Laurentde070132010-07-13 04:45:46 -0700835 Vector< sp<Track> > *tracksToRemove);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700836 virtual int getTrackName_l();
837 virtual void deleteTrackName_l(int name);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700838 virtual uint32_t idleSleepTimeUs();
Eric Laurent25cbe0e2010-08-18 18:13:17 -0700839 virtual uint32_t suspendSleepTimeUs();
Mathias Agopian65ab4712010-07-14 17:59:35 -0700840
Eric Laurent27741442012-01-17 19:20:12 -0800841 AudioMixer* mAudioMixer;
Glenn Kasten29c23c32012-01-26 13:37:52 -0800842 mixer_state mPrevMixerStatus; // previous status returned by prepareTracks_l()
Mathias Agopian65ab4712010-07-14 17:59:35 -0700843 };
844
845 class DirectOutputThread : public PlaybackThread {
846 public:
847
Dima Zavin799a70e2011-04-18 16:57:27 -0700848 DirectOutputThread (const sp<AudioFlinger>& audioFlinger, AudioStreamOut* output, int id, uint32_t device);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700849 ~DirectOutputThread();
850
851 // Thread virtuals
852 virtual bool threadLoop();
853
854 virtual bool checkForNewParameters_l();
855
856 protected:
857 virtual int getTrackName_l();
858 virtual void deleteTrackName_l(int name);
859 virtual uint32_t activeSleepTimeUs();
860 virtual uint32_t idleSleepTimeUs();
Eric Laurent25cbe0e2010-08-18 18:13:17 -0700861 virtual uint32_t suspendSleepTimeUs();
Mathias Agopian65ab4712010-07-14 17:59:35 -0700862
863 private:
864 void applyVolume(uint16_t leftVol, uint16_t rightVol, bool ramp);
865
866 float mLeftVolFloat;
867 float mRightVolFloat;
868 uint16_t mLeftVolShort;
869 uint16_t mRightVolShort;
870 };
871
872 class DuplicatingThread : public MixerThread {
873 public:
874 DuplicatingThread (const sp<AudioFlinger>& audioFlinger, MixerThread* mainThread, int id);
875 ~DuplicatingThread();
876
877 // Thread virtuals
878 virtual bool threadLoop();
879 void addOutputTrack(MixerThread* thread);
880 void removeOutputTrack(MixerThread* thread);
881 uint32_t waitTimeMs() { return mWaitTimeMs; }
882 protected:
883 virtual uint32_t activeSleepTimeUs();
884
885 private:
886 bool outputsReady(SortedVector< sp<OutputTrack> > &outputTracks);
887 void updateWaitTime();
888
889 SortedVector < sp<OutputTrack> > mOutputTracks;
890 uint32_t mWaitTimeMs;
891 };
892
893 PlaybackThread *checkPlaybackThread_l(int output) const;
894 MixerThread *checkMixerThread_l(int output) const;
895 RecordThread *checkRecordThread_l(int input) const;
Glenn Kastenfff6d712012-01-12 16:38:12 -0800896 float streamVolumeInternal(audio_stream_type_t stream) const { return mStreamTypes[stream].volume; }
Mathias Agopian65ab4712010-07-14 17:59:35 -0700897 void audioConfigChanged_l(int event, int ioHandle, void *param2);
898
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700899 uint32_t nextUniqueId();
Eric Laurent59255e42011-07-27 19:49:51 -0700900 status_t moveEffectChain_l(int sessionId,
Eric Laurentde070132010-07-13 04:45:46 -0700901 AudioFlinger::PlaybackThread *srcThread,
Eric Laurent39e94f82010-07-28 01:32:47 -0700902 AudioFlinger::PlaybackThread *dstThread,
903 bool reRegister);
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700904 PlaybackThread *primaryPlaybackThread_l();
905 uint32_t primaryOutputDevice_l();
Mathias Agopian65ab4712010-07-14 17:59:35 -0700906
907 friend class AudioBuffer;
908
909 class TrackHandle : public android::BnAudioTrack {
910 public:
911 TrackHandle(const sp<PlaybackThread::Track>& track);
912 virtual ~TrackHandle();
Glenn Kasten90716c52012-01-26 13:40:12 -0800913 virtual sp<IMemory> getCblk() const;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700914 virtual status_t start();
915 virtual void stop();
916 virtual void flush();
917 virtual void mute(bool);
918 virtual void pause();
Mathias Agopian65ab4712010-07-14 17:59:35 -0700919 virtual status_t attachAuxEffect(int effectId);
920 virtual status_t onTransact(
921 uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags);
922 private:
Glenn Kasten84afa3b2012-01-25 15:28:08 -0800923 const sp<PlaybackThread::Track> mTrack;
Mathias Agopian65ab4712010-07-14 17:59:35 -0700924 };
925
926 friend class Client;
927 friend class PlaybackThread::Track;
928
929
930 void removeClient_l(pid_t pid);
931 void removeNotificationClient(pid_t pid);
932
933
934 // record thread
935 class RecordThread : public ThreadBase, public AudioBufferProvider
936 {
937 public:
938
939 // record track
940 class RecordTrack : public TrackBase {
941 public:
942 RecordTrack(const wp<ThreadBase>& thread,
943 const sp<Client>& client,
944 uint32_t sampleRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800945 audio_format_t format,
Jean-Michel Trivi0d255b22011-05-24 15:53:33 -0700946 uint32_t channelMask,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700947 int frameCount,
948 uint32_t flags,
949 int sessionId);
950 ~RecordTrack();
951
952 virtual status_t start();
953 virtual void stop();
954
955 bool overflow() { bool tmp = mOverflow; mOverflow = false; return tmp; }
956 bool setOverflow() { bool tmp = mOverflow; mOverflow = true; return tmp; }
957
958 void dump(char* buffer, size_t size);
Eric Laurent59255e42011-07-27 19:49:51 -0700959
Mathias Agopian65ab4712010-07-14 17:59:35 -0700960 private:
961 friend class AudioFlinger;
962 friend class RecordThread;
963
964 RecordTrack(const RecordTrack&);
965 RecordTrack& operator = (const RecordTrack&);
966
967 virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer);
968
969 bool mOverflow;
970 };
971
972
973 RecordThread(const sp<AudioFlinger>& audioFlinger,
Dima Zavin799a70e2011-04-18 16:57:27 -0700974 AudioStreamIn *input,
Mathias Agopian65ab4712010-07-14 17:59:35 -0700975 uint32_t sampleRate,
976 uint32_t channels,
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700977 int id,
978 uint32_t device);
Mathias Agopian65ab4712010-07-14 17:59:35 -0700979 ~RecordThread();
980
981 virtual bool threadLoop();
Eric Laurentb8ba0a92011-08-07 16:32:26 -0700982 virtual status_t readyToRun();
Mathias Agopian65ab4712010-07-14 17:59:35 -0700983 virtual void onFirstRef();
984
Glenn Kastene0feee32011-12-13 11:53:26 -0800985 virtual status_t initCheck() const { return (mInput == NULL) ? NO_INIT : NO_ERROR; }
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700986 sp<AudioFlinger::RecordThread::RecordTrack> createRecordTrack_l(
987 const sp<AudioFlinger::Client>& client,
988 uint32_t sampleRate,
Glenn Kasten58f30212012-01-12 12:27:51 -0800989 audio_format_t format,
Eric Laurent7c7f10b2011-06-17 21:29:58 -0700990 int channelMask,
991 int frameCount,
992 uint32_t flags,
993 int sessionId,
994 status_t *status);
995
Mathias Agopian65ab4712010-07-14 17:59:35 -0700996 status_t start(RecordTrack* recordTrack);
997 void stop(RecordTrack* recordTrack);
998 status_t dump(int fd, const Vector<String16>& args);
Glenn Kastenaed850d2012-01-26 09:46:34 -0800999 AudioStreamIn* getInput() const;
Eric Laurentb8ba0a92011-08-07 16:32:26 -07001000 AudioStreamIn* clearInput();
1001 virtual audio_stream_t* stream();
Mathias Agopian65ab4712010-07-14 17:59:35 -07001002
1003 virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer);
1004 virtual void releaseBuffer(AudioBufferProvider::Buffer* buffer);
1005 virtual bool checkForNewParameters_l();
1006 virtual String8 getParameters(const String8& keys);
1007 virtual void audioConfigChanged_l(int event, int param = 0);
1008 void readInputParameters();
1009 virtual unsigned int getInputFramesLost();
1010
Eric Laurent7c7f10b2011-06-17 21:29:58 -07001011 virtual status_t addEffectChain_l(const sp<EffectChain>& chain);
1012 virtual size_t removeEffectChain_l(const sp<EffectChain>& chain);
1013 virtual uint32_t hasAudioSession(int sessionId);
Eric Laurent59bd0da2011-08-01 09:52:20 -07001014 RecordTrack* track();
Eric Laurent7c7f10b2011-06-17 21:29:58 -07001015
Mathias Agopian65ab4712010-07-14 17:59:35 -07001016 private:
1017 RecordThread();
Dima Zavin799a70e2011-04-18 16:57:27 -07001018 AudioStreamIn *mInput;
Eric Laurent7c7f10b2011-06-17 21:29:58 -07001019 RecordTrack* mTrack;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001020 sp<RecordTrack> mActiveTrack;
1021 Condition mStartStopCond;
1022 AudioResampler *mResampler;
1023 int32_t *mRsmpOutBuffer;
1024 int16_t *mRsmpInBuffer;
1025 size_t mRsmpInIndex;
1026 size_t mInputBytes;
Glenn Kasten84afa3b2012-01-25 15:28:08 -08001027 const int mReqChannelCount;
1028 const uint32_t mReqSampleRate;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001029 ssize_t mBytesRead;
1030 };
1031
1032 class RecordHandle : public android::BnAudioRecord {
1033 public:
1034 RecordHandle(const sp<RecordThread::RecordTrack>& recordTrack);
1035 virtual ~RecordHandle();
Glenn Kasten90716c52012-01-26 13:40:12 -08001036 virtual sp<IMemory> getCblk() const;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001037 virtual status_t start();
1038 virtual void stop();
Mathias Agopian65ab4712010-07-14 17:59:35 -07001039 virtual status_t onTransact(
1040 uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags);
1041 private:
Glenn Kasten84afa3b2012-01-25 15:28:08 -08001042 const sp<RecordThread::RecordTrack> mRecordTrack;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001043 };
1044
1045 //--- Audio Effect Management
1046
1047 // EffectModule and EffectChain classes both have their own mutex to protect
1048 // state changes or resource modifications. Always respect the following order
1049 // if multiple mutexes must be acquired to avoid cross deadlock:
1050 // AudioFlinger -> ThreadBase -> EffectChain -> EffectModule
1051
1052 // The EffectModule class is a wrapper object controlling the effect engine implementation
1053 // in the effect library. It prevents concurrent calls to process() and command() functions
1054 // from different client threads. It keeps a list of EffectHandle objects corresponding
1055 // to all client applications using this effect and notifies applications of effect state,
1056 // control or parameter changes. It manages the activation state machine to send appropriate
1057 // reset, enable, disable commands to effect engine and provide volume
1058 // ramping when effects are activated/deactivated.
1059 // When controlling an auxiliary effect, the EffectModule also provides an input buffer used by
1060 // the attached track(s) to accumulate their auxiliary channel.
1061 class EffectModule: public RefBase {
1062 public:
1063 EffectModule(const wp<ThreadBase>& wThread,
1064 const wp<AudioFlinger::EffectChain>& chain,
1065 effect_descriptor_t *desc,
1066 int id,
1067 int sessionId);
1068 ~EffectModule();
1069
1070 enum effect_state {
1071 IDLE,
1072 RESTART,
1073 STARTING,
1074 ACTIVE,
1075 STOPPING,
Eric Laurentec437d82011-07-26 20:54:46 -07001076 STOPPED,
1077 DESTROYED
Mathias Agopian65ab4712010-07-14 17:59:35 -07001078 };
1079
1080 int id() { return mId; }
1081 void process();
1082 void updateState();
Eric Laurent25f43952010-07-28 05:40:18 -07001083 status_t command(uint32_t cmdCode,
1084 uint32_t cmdSize,
1085 void *pCmdData,
1086 uint32_t *replySize,
1087 void *pReplyData);
Mathias Agopian65ab4712010-07-14 17:59:35 -07001088
1089 void reset_l();
1090 status_t configure();
1091 status_t init();
Glenn Kasten28243dd2012-01-26 13:43:46 -08001092 effect_state state() const {
Mathias Agopian65ab4712010-07-14 17:59:35 -07001093 return mState;
1094 }
1095 uint32_t status() {
1096 return mStatus;
1097 }
Eric Laurentde070132010-07-13 04:45:46 -07001098 int sessionId() {
1099 return mSessionId;
1100 }
Mathias Agopian65ab4712010-07-14 17:59:35 -07001101 status_t setEnabled(bool enabled);
1102 bool isEnabled();
Eric Laurent8f45bd72010-08-31 13:50:07 -07001103 bool isProcessEnabled();
Mathias Agopian65ab4712010-07-14 17:59:35 -07001104
1105 void setInBuffer(int16_t *buffer) { mConfig.inputCfg.buffer.s16 = buffer; }
1106 int16_t *inBuffer() { return mConfig.inputCfg.buffer.s16; }
1107 void setOutBuffer(int16_t *buffer) { mConfig.outputCfg.buffer.s16 = buffer; }
1108 int16_t *outBuffer() { return mConfig.outputCfg.buffer.s16; }
Eric Laurentde070132010-07-13 04:45:46 -07001109 void setChain(const wp<EffectChain>& chain) { mChain = chain; }
1110 void setThread(const wp<ThreadBase>& thread) { mThread = thread; }
Glenn Kasten84afa3b2012-01-25 15:28:08 -08001111 const wp<ThreadBase>& thread() { return mThread; }
Mathias Agopian65ab4712010-07-14 17:59:35 -07001112
Glenn Kasten435dbe62012-01-30 10:15:48 -08001113 status_t addHandle(const sp<EffectHandle>& handle);
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001114 void disconnect(const wp<EffectHandle>& handle, bool unpiniflast);
Mathias Agopian65ab4712010-07-14 17:59:35 -07001115 size_t removeHandle (const wp<EffectHandle>& handle);
1116
1117 effect_descriptor_t& desc() { return mDescriptor; }
1118 wp<EffectChain>& chain() { return mChain; }
1119
1120 status_t setDevice(uint32_t device);
1121 status_t setVolume(uint32_t *left, uint32_t *right, bool controller);
Glenn Kastenf78aee72012-01-04 11:00:47 -08001122 status_t setMode(audio_mode_t mode);
Eric Laurentec35a142011-10-05 17:42:25 -07001123 status_t start();
Eric Laurentec437d82011-07-26 20:54:46 -07001124 status_t stop();
Eric Laurent59255e42011-07-27 19:49:51 -07001125 void setSuspended(bool suspended);
Glenn Kastena3a85482012-01-04 11:01:11 -08001126 bool suspended() const;
Eric Laurent59255e42011-07-27 19:49:51 -07001127
1128 sp<EffectHandle> controlHandle();
Mathias Agopian65ab4712010-07-14 17:59:35 -07001129
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001130 bool isPinned() { return mPinned; }
1131 void unPin() { mPinned = false; }
1132
Mathias Agopian65ab4712010-07-14 17:59:35 -07001133 status_t dump(int fd, const Vector<String16>& args);
1134
1135 protected:
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001136 friend class EffectHandle;
1137 friend class AudioFlinger;
1138 bool mPinned;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001139
1140 // Maximum time allocated to effect engines to complete the turn off sequence
1141 static const uint32_t MAX_DISABLE_TIME_MS = 10000;
1142
1143 EffectModule(const EffectModule&);
1144 EffectModule& operator = (const EffectModule&);
1145
1146 status_t start_l();
1147 status_t stop_l();
1148
Glenn Kastena3a85482012-01-04 11:01:11 -08001149mutable Mutex mLock; // mutex for process, commands and handles list protection
Mathias Agopian65ab4712010-07-14 17:59:35 -07001150 wp<ThreadBase> mThread; // parent thread
1151 wp<EffectChain> mChain; // parent effect chain
1152 int mId; // this instance unique ID
1153 int mSessionId; // audio session ID
1154 effect_descriptor_t mDescriptor;// effect descriptor received from effect engine
1155 effect_config_t mConfig; // input and output audio configuration
Eric Laurente1315cf2011-05-17 19:16:02 -07001156 effect_handle_t mEffectInterface; // Effect module C API
Glenn Kasten28243dd2012-01-26 13:43:46 -08001157 status_t mStatus; // initialization status
1158 effect_state mState; // current activation state
Mathias Agopian65ab4712010-07-14 17:59:35 -07001159 Vector< wp<EffectHandle> > mHandles; // list of client handles
1160 uint32_t mMaxDisableWaitCnt; // maximum grace period before forcing an effect off after
1161 // sending disable command.
1162 uint32_t mDisableWaitCnt; // current process() calls count during disable period.
Eric Laurent59255e42011-07-27 19:49:51 -07001163 bool mSuspended; // effect is suspended: temporarily disabled by framework
Mathias Agopian65ab4712010-07-14 17:59:35 -07001164 };
1165
1166 // The EffectHandle class implements the IEffect interface. It provides resources
1167 // to receive parameter updates, keeps track of effect control
1168 // ownership and state and has a pointer to the EffectModule object it is controlling.
1169 // There is one EffectHandle object for each application controlling (or using)
1170 // an effect module.
1171 // The EffectHandle is obtained by calling AudioFlinger::createEffect().
1172 class EffectHandle: public android::BnEffect {
1173 public:
1174
1175 EffectHandle(const sp<EffectModule>& effect,
1176 const sp<AudioFlinger::Client>& client,
1177 const sp<IEffectClient>& effectClient,
1178 int32_t priority);
1179 virtual ~EffectHandle();
1180
1181 // IEffect
1182 virtual status_t enable();
1183 virtual status_t disable();
Eric Laurent25f43952010-07-28 05:40:18 -07001184 virtual status_t command(uint32_t cmdCode,
1185 uint32_t cmdSize,
1186 void *pCmdData,
1187 uint32_t *replySize,
1188 void *pReplyData);
Mathias Agopian65ab4712010-07-14 17:59:35 -07001189 virtual void disconnect();
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001190 virtual void disconnect(bool unpiniflast);
Mathias Agopian65ab4712010-07-14 17:59:35 -07001191 virtual sp<IMemory> getCblk() const;
1192 virtual status_t onTransact(uint32_t code, const Parcel& data,
1193 Parcel* reply, uint32_t flags);
1194
1195
1196 // Give or take control of effect module
Eric Laurent59255e42011-07-27 19:49:51 -07001197 // - hasControl: true if control is given, false if removed
1198 // - signal: true client app should be signaled of change, false otherwise
1199 // - enabled: state of the effect when control is passed
1200 void setControl(bool hasControl, bool signal, bool enabled);
Eric Laurent25f43952010-07-28 05:40:18 -07001201 void commandExecuted(uint32_t cmdCode,
1202 uint32_t cmdSize,
1203 void *pCmdData,
1204 uint32_t replySize,
1205 void *pReplyData);
Mathias Agopian65ab4712010-07-14 17:59:35 -07001206 void setEnabled(bool enabled);
Eric Laurent59255e42011-07-27 19:49:51 -07001207 bool enabled() { return mEnabled; }
Mathias Agopian65ab4712010-07-14 17:59:35 -07001208
1209 // Getters
1210 int id() { return mEffect->id(); }
1211 int priority() { return mPriority; }
1212 bool hasControl() { return mHasControl; }
1213 sp<EffectModule> effect() { return mEffect; }
1214
1215 void dump(char* buffer, size_t size);
1216
1217 protected:
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001218 friend class AudioFlinger;
1219 friend class EffectModule;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001220 EffectHandle(const EffectHandle&);
1221 EffectHandle& operator =(const EffectHandle&);
1222
1223 sp<EffectModule> mEffect; // pointer to controlled EffectModule
1224 sp<IEffectClient> mEffectClient; // callback interface for client notifications
1225 sp<Client> mClient; // client for shared memory allocation
1226 sp<IMemory> mCblkMemory; // shared memory for control block
1227 effect_param_cblk_t* mCblk; // control block for deferred parameter setting via shared memory
1228 uint8_t* mBuffer; // pointer to parameter area in shared memory
1229 int mPriority; // client application priority to control the effect
1230 bool mHasControl; // true if this handle is controlling the effect
Eric Laurent59255e42011-07-27 19:49:51 -07001231 bool mEnabled; // cached enable state: needed when the effect is
1232 // restored after being suspended
Mathias Agopian65ab4712010-07-14 17:59:35 -07001233 };
1234
1235 // the EffectChain class represents a group of effects associated to one audio session.
1236 // There can be any number of EffectChain objects per output mixer thread (PlaybackThread).
1237 // The EffecChain with session ID 0 contains global effects applied to the output mix.
1238 // Effects in this chain can be insert or auxiliary. Effects in other chains (attached to tracks)
1239 // are insert only. The EffectChain maintains an ordered list of effect module, the order corresponding
1240 // in the effect process order. When attached to a track (session ID != 0), it also provide it's own
1241 // input buffer used by the track as accumulation buffer.
1242 class EffectChain: public RefBase {
1243 public:
1244 EffectChain(const wp<ThreadBase>& wThread, int sessionId);
1245 ~EffectChain();
1246
Eric Laurent59255e42011-07-27 19:49:51 -07001247 // special key used for an entry in mSuspendedEffects keyed vector
1248 // corresponding to a suspend all request.
1249 static const int kKeyForSuspendAll = 0;
1250
Eric Laurent544fe9b2011-11-11 15:42:52 -08001251 // minimum duration during which we force calling effect process when last track on
1252 // a session is stopped or removed to allow effect tail to be rendered
1253 static const int kProcessTailDurationMs = 1000;
1254
Mathias Agopian65ab4712010-07-14 17:59:35 -07001255 void process_l();
1256
1257 void lock() {
1258 mLock.lock();
1259 }
1260 void unlock() {
1261 mLock.unlock();
1262 }
1263
Eric Laurentde070132010-07-13 04:45:46 -07001264 status_t addEffect_l(const sp<EffectModule>& handle);
Eric Laurentcab11242010-07-15 12:50:15 -07001265 size_t removeEffect_l(const sp<EffectModule>& handle);
Mathias Agopian65ab4712010-07-14 17:59:35 -07001266
Eric Laurent7c7f10b2011-06-17 21:29:58 -07001267 int sessionId() { return mSessionId; }
1268 void setSessionId(int sessionId) { mSessionId = sessionId; }
Eric Laurentde070132010-07-13 04:45:46 -07001269
Eric Laurentcab11242010-07-15 12:50:15 -07001270 sp<EffectModule> getEffectFromDesc_l(effect_descriptor_t *descriptor);
1271 sp<EffectModule> getEffectFromId_l(int id);
Eric Laurent59255e42011-07-27 19:49:51 -07001272 sp<EffectModule> getEffectFromType_l(const effect_uuid_t *type);
Eric Laurentcab11242010-07-15 12:50:15 -07001273 bool setVolume_l(uint32_t *left, uint32_t *right);
1274 void setDevice_l(uint32_t device);
Glenn Kastenf78aee72012-01-04 11:00:47 -08001275 void setMode_l(audio_mode_t mode);
Mathias Agopian65ab4712010-07-14 17:59:35 -07001276
Mathias Agopian65ab4712010-07-14 17:59:35 -07001277 void setInBuffer(int16_t *buffer, bool ownsBuffer = false) {
1278 mInBuffer = buffer;
1279 mOwnInBuffer = ownsBuffer;
1280 }
1281 int16_t *inBuffer() {
1282 return mInBuffer;
1283 }
1284 void setOutBuffer(int16_t *buffer) {
1285 mOutBuffer = buffer;
1286 }
1287 int16_t *outBuffer() {
1288 return mOutBuffer;
1289 }
1290
Eric Laurentb469b942011-05-09 12:09:06 -07001291 void incTrackCnt() { android_atomic_inc(&mTrackCnt); }
1292 void decTrackCnt() { android_atomic_dec(&mTrackCnt); }
1293 int32_t trackCnt() { return mTrackCnt;}
1294
Eric Laurent544fe9b2011-11-11 15:42:52 -08001295 void incActiveTrackCnt() { android_atomic_inc(&mActiveTrackCnt);
1296 mTailBufferCount = mMaxTailBuffers; }
Eric Laurentb469b942011-05-09 12:09:06 -07001297 void decActiveTrackCnt() { android_atomic_dec(&mActiveTrackCnt); }
1298 int32_t activeTrackCnt() { return mActiveTrackCnt;}
Mathias Agopian65ab4712010-07-14 17:59:35 -07001299
Eric Laurentde070132010-07-13 04:45:46 -07001300 uint32_t strategy() { return mStrategy; }
1301 void setStrategy(uint32_t strategy)
1302 { mStrategy = strategy; }
1303
Eric Laurent59255e42011-07-27 19:49:51 -07001304 // suspend effect of the given type
1305 void setEffectSuspended_l(const effect_uuid_t *type,
1306 bool suspend);
1307 // suspend all eligible effects
1308 void setEffectSuspendedAll_l(bool suspend);
1309 // check if effects should be suspend or restored when a given effect is enable or disabled
Eric Laurenta85a74a2011-10-19 11:44:54 -07001310 void checkSuspendOnEffectEnabled(const sp<EffectModule>& effect,
Eric Laurent59255e42011-07-27 19:49:51 -07001311 bool enabled);
1312
Mathias Agopian65ab4712010-07-14 17:59:35 -07001313 status_t dump(int fd, const Vector<String16>& args);
1314
1315 protected:
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001316 friend class AudioFlinger;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001317 EffectChain(const EffectChain&);
1318 EffectChain& operator =(const EffectChain&);
1319
Eric Laurent59255e42011-07-27 19:49:51 -07001320 class SuspendedEffectDesc : public RefBase {
1321 public:
1322 SuspendedEffectDesc() : mRefCount(0) {}
1323
1324 int mRefCount;
1325 effect_uuid_t mType;
1326 wp<EffectModule> mEffect;
1327 };
1328
1329 // get a list of effect modules to suspend when an effect of the type
1330 // passed is enabled.
Glenn Kastend0539712012-01-30 12:56:03 -08001331 void getSuspendEligibleEffects(Vector< sp<EffectModule> > &effects);
1332
Eric Laurent59255e42011-07-27 19:49:51 -07001333 // get an effect module if it is currently enable
1334 sp<EffectModule> getEffectIfEnabled(const effect_uuid_t *type);
Eric Laurentdb7c0792011-08-10 10:37:50 -07001335 // true if the effect whose descriptor is passed can be suspended
1336 // OEMs can modify the rules implemented in this method to exclude specific effect
1337 // types or implementations from the suspend/restore mechanism.
1338 bool isEffectEligibleForSuspend(const effect_descriptor_t& desc);
Eric Laurent59255e42011-07-27 19:49:51 -07001339
Mathias Agopian65ab4712010-07-14 17:59:35 -07001340 wp<ThreadBase> mThread; // parent mixer thread
1341 Mutex mLock; // mutex protecting effect list
1342 Vector<sp<EffectModule> > mEffects; // list of effect modules
1343 int mSessionId; // audio session ID
1344 int16_t *mInBuffer; // chain input buffer
1345 int16_t *mOutBuffer; // chain output buffer
Eric Laurentb469b942011-05-09 12:09:06 -07001346 volatile int32_t mActiveTrackCnt; // number of active tracks connected
1347 volatile int32_t mTrackCnt; // number of tracks connected
Eric Laurent544fe9b2011-11-11 15:42:52 -08001348 int32_t mTailBufferCount; // current effect tail buffer count
1349 int32_t mMaxTailBuffers; // maximum effect tail buffers
Mathias Agopian65ab4712010-07-14 17:59:35 -07001350 bool mOwnInBuffer; // true if the chain owns its input buffer
Eric Laurentcab11242010-07-15 12:50:15 -07001351 int mVolumeCtrlIdx; // index of insert effect having control over volume
1352 uint32_t mLeftVolume; // previous volume on left channel
1353 uint32_t mRightVolume; // previous volume on right channel
Eric Laurentf997cab2010-07-19 06:24:46 -07001354 uint32_t mNewLeftVolume; // new volume on left channel
1355 uint32_t mNewRightVolume; // new volume on right channel
Eric Laurentde070132010-07-13 04:45:46 -07001356 uint32_t mStrategy; // strategy for this effect chain
Eric Laurent59255e42011-07-27 19:49:51 -07001357 // mSuspendedEffects lists all effect currently suspended in the chain
1358 // use effect type UUID timelow field as key. There is no real risk of identical
1359 // timeLow fields among effect type UUIDs.
1360 KeyedVector< int, sp<SuspendedEffectDesc> > mSuspendedEffects;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001361 };
1362
Glenn Kastenaed850d2012-01-26 09:46:34 -08001363 // AudioStreamOut and AudioStreamIn are immutable, so their fields are const.
1364 // For emphasis, we could also make all pointers to them be "const *",
1365 // but that would clutter the code unnecessarily.
1366
Dima Zavin799a70e2011-04-18 16:57:27 -07001367 struct AudioStreamOut {
Glenn Kastenaed850d2012-01-26 09:46:34 -08001368 audio_hw_device_t* const hwDev;
1369 audio_stream_out_t* const stream;
Dima Zavin799a70e2011-04-18 16:57:27 -07001370
1371 AudioStreamOut(audio_hw_device_t *dev, audio_stream_out_t *out) :
1372 hwDev(dev), stream(out) {}
1373 };
1374
1375 struct AudioStreamIn {
Glenn Kastenaed850d2012-01-26 09:46:34 -08001376 audio_hw_device_t* const hwDev;
1377 audio_stream_in_t* const stream;
Dima Zavin799a70e2011-04-18 16:57:27 -07001378
1379 AudioStreamIn(audio_hw_device_t *dev, audio_stream_in_t *in) :
1380 hwDev(dev), stream(in) {}
1381 };
1382
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001383 struct AudioSessionRef {
Glenn Kasten84afa3b2012-01-25 15:28:08 -08001384 // FIXME rename parameter names when fields get "m" prefix
1385 AudioSessionRef(int sessionid_, pid_t pid_) :
1386 sessionid(sessionid_), pid(pid_), cnt(1) {}
1387 const int sessionid;
1388 const pid_t pid;
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001389 int cnt;
1390 };
1391
Mathias Agopian65ab4712010-07-14 17:59:35 -07001392 friend class RecordThread;
1393 friend class PlaybackThread;
1394
Mathias Agopian65ab4712010-07-14 17:59:35 -07001395 mutable Mutex mLock;
1396
1397 DefaultKeyedVector< pid_t, wp<Client> > mClients;
1398
1399 mutable Mutex mHardwareLock;
Dima Zavin799a70e2011-04-18 16:57:27 -07001400 audio_hw_device_t* mPrimaryHardwareDev;
1401 Vector<audio_hw_device_t*> mAudioHwDevs;
Glenn Kastena4454b42012-01-04 11:02:33 -08001402 mutable hardware_call_state mHardwareStatus; // for dump only
Mathias Agopian65ab4712010-07-14 17:59:35 -07001403
1404
1405 DefaultKeyedVector< int, sp<PlaybackThread> > mPlaybackThreads;
Dima Zavinfce7a472011-04-19 22:30:36 -07001406 PlaybackThread::stream_type_t mStreamTypes[AUDIO_STREAM_CNT];
Glenn Kasten98067102011-12-13 11:47:54 -08001407
1408 // both are protected by mLock
Mathias Agopian65ab4712010-07-14 17:59:35 -07001409 float mMasterVolume;
1410 bool mMasterMute;
1411
1412 DefaultKeyedVector< int, sp<RecordThread> > mRecordThreads;
1413
1414 DefaultKeyedVector< pid_t, sp<NotificationClient> > mNotificationClients;
1415 volatile int32_t mNextUniqueId;
Glenn Kastenf78aee72012-01-04 11:00:47 -08001416 audio_mode_t mMode;
Eric Laurentbee53372011-08-29 12:42:48 -07001417 bool mBtNrecIsOff;
Mathias Agopian65ab4712010-07-14 17:59:35 -07001418
Marco Nelissen3a34bef2011-08-02 13:33:41 -07001419 Vector<AudioSessionRef*> mAudioSessionRefs;
Glenn Kasten98067102011-12-13 11:47:54 -08001420
1421 float masterVolume_l() const { return mMasterVolume; }
1422 bool masterMute_l() const { return mMasterMute; }
Mathias Agopian65ab4712010-07-14 17:59:35 -07001423};
1424
Dima Zavin799a70e2011-04-18 16:57:27 -07001425
Mathias Agopian65ab4712010-07-14 17:59:35 -07001426// ----------------------------------------------------------------------------
1427
1428}; // namespace android
1429
1430#endif // ANDROID_AUDIO_FLINGER_H