| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1 | /* //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 Kasten | 335787f | 2012-01-20 17:00:00 -0800 | [diff] [blame] | 29 | #include <media/AudioSystem.h> | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 30 |  | 
|  | 31 | #include <utils/Atomic.h> | 
|  | 32 | #include <utils/Errors.h> | 
|  | 33 | #include <utils/threads.h> | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 34 | #include <utils/SortedVector.h> | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 35 | #include <utils/TypeHelpers.h> | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 36 | #include <utils/Vector.h> | 
|  | 37 |  | 
| Mathias Agopian | 5462fc9 | 2010-07-14 18:41:18 -0700 | [diff] [blame] | 38 | #include <binder/BinderService.h> | 
|  | 39 | #include <binder/MemoryDealer.h> | 
|  | 40 |  | 
| Dima Zavin | 6476024 | 2011-05-11 14:15:23 -0700 | [diff] [blame] | 41 | #include <system/audio.h> | 
| Dima Zavin | 7394a4f | 2011-06-13 18:16:26 -0700 | [diff] [blame] | 42 | #include <hardware/audio.h> | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 43 |  | 
|  | 44 | #include "AudioBufferProvider.h" | 
|  | 45 |  | 
| Eric Laurent | feb0db6 | 2011-07-22 09:04:31 -0700 | [diff] [blame] | 46 | #include <powermanager/IPowerManager.h> | 
|  | 47 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 48 | namespace android { | 
|  | 49 |  | 
|  | 50 | class audio_track_cblk_t; | 
|  | 51 | class effect_param_cblk_t; | 
|  | 52 | class AudioMixer; | 
|  | 53 | class AudioBuffer; | 
|  | 54 | class AudioResampler; | 
|  | 55 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 56 | // ---------------------------------------------------------------------------- | 
|  | 57 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 58 | static const nsecs_t kStandbyTimeInNsecs = seconds(3); | 
|  | 59 |  | 
| Mathias Agopian | 5462fc9 | 2010-07-14 18:41:18 -0700 | [diff] [blame] | 60 | class AudioFlinger : | 
|  | 61 | public BinderService<AudioFlinger>, | 
|  | 62 | public BnAudioFlinger | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 63 | { | 
| Mathias Agopian | 5462fc9 | 2010-07-14 18:41:18 -0700 | [diff] [blame] | 64 | friend class BinderService<AudioFlinger>; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 65 | public: | 
| Glenn Kasten | 54c3b66 | 2012-01-06 07:46:30 -0800 | [diff] [blame] | 66 | static const char* getServiceName() { return "media.audio_flinger"; } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 67 |  | 
|  | 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 Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 73 | audio_stream_type_t streamType, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 74 | uint32_t sampleRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 75 | audio_format_t format, | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 76 | uint32_t channelMask, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 77 | 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 Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 86 | virtual     audio_format_t format(int output) const; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 87 | 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 Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 96 | 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 Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 98 |  | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 99 | virtual     float       streamVolume(audio_stream_type_t stream, int output) const; | 
|  | 100 | virtual     bool        streamMute(audio_stream_type_t stream) const; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 101 |  | 
| Glenn Kasten | f78aee7 | 2012-01-04 11:00:47 -0800 | [diff] [blame] | 102 | virtual     status_t    setMode(audio_mode_t mode); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 103 |  | 
|  | 104 | virtual     status_t    setMicMute(bool state); | 
|  | 105 | virtual     bool        getMicMute() const; | 
|  | 106 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 107 | virtual     status_t    setParameters(int ioHandle, const String8& keyValuePairs); | 
|  | 108 | virtual     String8     getParameters(int ioHandle, const String8& keys); | 
|  | 109 |  | 
|  | 110 | virtual     void        registerClient(const sp<IAudioFlingerClient>& client); | 
|  | 111 |  | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 112 | virtual     size_t      getInputBufferSize(uint32_t sampleRate, audio_format_t format, int channelCount); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 113 | virtual     unsigned int  getInputFramesLost(int ioHandle); | 
|  | 114 |  | 
|  | 115 | virtual int openOutput(uint32_t *pDevices, | 
|  | 116 | uint32_t *pSamplingRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 117 | audio_format_t *pFormat, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 118 | 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 Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 132 | audio_format_t *pFormat, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 133 | uint32_t *pChannels, | 
|  | 134 | uint32_t acoustics); | 
|  | 135 |  | 
|  | 136 | virtual status_t closeInput(int input); | 
|  | 137 |  | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 138 | virtual status_t setStreamOutput(audio_stream_type_t stream, int output); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 139 |  | 
|  | 140 | virtual status_t setVoiceVolume(float volume); | 
|  | 141 |  | 
|  | 142 | virtual status_t getRenderPosition(uint32_t *halFrames, uint32_t *dspFrames, int output); | 
|  | 143 |  | 
|  | 144 | virtual int newAudioSessionId(); | 
|  | 145 |  | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 146 | virtual void acquireAudioSessionId(int audioSession); | 
|  | 147 |  | 
|  | 148 | virtual void releaseAudioSessionId(int audioSession); | 
|  | 149 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 150 | virtual status_t queryNumberEffects(uint32_t *numEffects); | 
|  | 151 |  | 
|  | 152 | virtual status_t queryEffect(uint32_t index, effect_descriptor_t *descriptor); | 
|  | 153 |  | 
|  | 154 | virtual status_t getEffectDescriptor(effect_uuid_t *pUuid, effect_descriptor_t *descriptor); | 
|  | 155 |  | 
|  | 156 | virtual sp<IEffect> createEffect(pid_t pid, | 
|  | 157 | effect_descriptor_t *pDesc, | 
|  | 158 | const sp<IEffectClient>& effectClient, | 
|  | 159 | int32_t priority, | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 160 | int io, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 161 | int sessionId, | 
|  | 162 | status_t *status, | 
|  | 163 | int *id, | 
|  | 164 | int *enabled); | 
|  | 165 |  | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 166 | virtual status_t moveEffects(int sessionId, int srcOutput, int dstOutput); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 167 |  | 
|  | 168 | enum hardware_call_state { | 
|  | 169 | AUDIO_HW_IDLE = 0, | 
|  | 170 | AUDIO_HW_INIT, | 
|  | 171 | AUDIO_HW_OUTPUT_OPEN, | 
|  | 172 | AUDIO_HW_OUTPUT_CLOSE, | 
|  | 173 | AUDIO_HW_INPUT_OPEN, | 
|  | 174 | AUDIO_HW_INPUT_CLOSE, | 
|  | 175 | AUDIO_HW_STANDBY, | 
|  | 176 | AUDIO_HW_SET_MASTER_VOLUME, | 
|  | 177 | AUDIO_HW_GET_ROUTING, | 
|  | 178 | AUDIO_HW_SET_ROUTING, | 
|  | 179 | AUDIO_HW_GET_MODE, | 
|  | 180 | AUDIO_HW_SET_MODE, | 
|  | 181 | AUDIO_HW_GET_MIC_MUTE, | 
|  | 182 | AUDIO_HW_SET_MIC_MUTE, | 
|  | 183 | AUDIO_SET_VOICE_VOLUME, | 
|  | 184 | AUDIO_SET_PARAMETER, | 
|  | 185 | }; | 
|  | 186 |  | 
|  | 187 | // record interface | 
|  | 188 | virtual sp<IAudioRecord> openRecord( | 
|  | 189 | pid_t pid, | 
|  | 190 | int input, | 
|  | 191 | uint32_t sampleRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 192 | audio_format_t format, | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 193 | uint32_t channelMask, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 194 | int frameCount, | 
|  | 195 | uint32_t flags, | 
|  | 196 | int *sessionId, | 
|  | 197 | status_t *status); | 
|  | 198 |  | 
|  | 199 | virtual     status_t    onTransact( | 
|  | 200 | uint32_t code, | 
|  | 201 | const Parcel& data, | 
|  | 202 | Parcel* reply, | 
|  | 203 | uint32_t flags); | 
|  | 204 |  | 
| Glenn Kasten | f78aee7 | 2012-01-04 11:00:47 -0800 | [diff] [blame] | 205 | audio_mode_t getMode() const { return mMode; } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 206 |  | 
| Eric Laurent | bee5337 | 2011-08-29 12:42:48 -0700 | [diff] [blame] | 207 | bool        btNrecIsOff() { return mBtNrecIsOff; } | 
| Eric Laurent | 59bd0da | 2011-08-01 09:52:20 -0700 | [diff] [blame] | 208 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 209 | private: | 
| Glenn Kasten | 335787f | 2012-01-20 17:00:00 -0800 | [diff] [blame] | 210 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 211 | AudioFlinger(); | 
|  | 212 | virtual                 ~AudioFlinger(); | 
|  | 213 |  | 
| Dima Zavin | 5a61d2f | 2011-04-19 19:04:32 -0700 | [diff] [blame] | 214 | status_t                initCheck() const; | 
|  | 215 | virtual     void        onFirstRef(); | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 216 | audio_hw_device_t*      findSuitableHwDev_l(uint32_t devices); | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 217 | void                    purgeStaleEffects_l(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 218 |  | 
|  | 219 | // Internal dump utilites. | 
|  | 220 | status_t dumpPermissionDenial(int fd, const Vector<String16>& args); | 
|  | 221 | status_t dumpClients(int fd, const Vector<String16>& args); | 
|  | 222 | status_t dumpInternals(int fd, const Vector<String16>& args); | 
|  | 223 |  | 
|  | 224 | // --- Client --- | 
|  | 225 | class Client : public RefBase { | 
|  | 226 | public: | 
|  | 227 | Client(const sp<AudioFlinger>& audioFlinger, pid_t pid); | 
|  | 228 | virtual             ~Client(); | 
|  | 229 | const sp<MemoryDealer>&     heap() const; | 
|  | 230 | pid_t               pid() const { return mPid; } | 
|  | 231 | sp<AudioFlinger>    audioFlinger() { return mAudioFlinger; } | 
|  | 232 |  | 
|  | 233 | private: | 
|  | 234 | Client(const Client&); | 
|  | 235 | Client& operator = (const Client&); | 
|  | 236 | sp<AudioFlinger>    mAudioFlinger; | 
|  | 237 | sp<MemoryDealer>    mMemoryDealer; | 
|  | 238 | pid_t               mPid; | 
|  | 239 | }; | 
|  | 240 |  | 
|  | 241 | // --- Notification Client --- | 
|  | 242 | class NotificationClient : public IBinder::DeathRecipient { | 
|  | 243 | public: | 
|  | 244 | NotificationClient(const sp<AudioFlinger>& audioFlinger, | 
|  | 245 | const sp<IAudioFlingerClient>& client, | 
|  | 246 | pid_t pid); | 
|  | 247 | virtual             ~NotificationClient(); | 
|  | 248 |  | 
|  | 249 | sp<IAudioFlingerClient>    client() { return mClient; } | 
|  | 250 |  | 
|  | 251 | // IBinder::DeathRecipient | 
|  | 252 | virtual     void        binderDied(const wp<IBinder>& who); | 
|  | 253 |  | 
|  | 254 | private: | 
|  | 255 | NotificationClient(const NotificationClient&); | 
|  | 256 | NotificationClient& operator = (const NotificationClient&); | 
|  | 257 |  | 
|  | 258 | sp<AudioFlinger>        mAudioFlinger; | 
|  | 259 | pid_t                   mPid; | 
|  | 260 | sp<IAudioFlingerClient> mClient; | 
|  | 261 | }; | 
|  | 262 |  | 
|  | 263 | class TrackHandle; | 
|  | 264 | class RecordHandle; | 
|  | 265 | class RecordThread; | 
|  | 266 | class PlaybackThread; | 
|  | 267 | class MixerThread; | 
|  | 268 | class DirectOutputThread; | 
|  | 269 | class DuplicatingThread; | 
|  | 270 | class Track; | 
|  | 271 | class RecordTrack; | 
|  | 272 | class EffectModule; | 
|  | 273 | class EffectHandle; | 
|  | 274 | class EffectChain; | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 275 | struct AudioStreamOut; | 
|  | 276 | struct AudioStreamIn; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 277 |  | 
|  | 278 | class ThreadBase : public Thread { | 
|  | 279 | public: | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 280 | ThreadBase (const sp<AudioFlinger>& audioFlinger, int id, uint32_t device); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 281 | virtual             ~ThreadBase(); | 
|  | 282 |  | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 283 |  | 
|  | 284 | enum type { | 
|  | 285 | MIXER,              // Thread class is MixerThread | 
|  | 286 | DIRECT,             // Thread class is DirectOutputThread | 
|  | 287 | DUPLICATING,        // Thread class is DuplicatingThread | 
|  | 288 | RECORD              // Thread class is RecordThread | 
|  | 289 | }; | 
|  | 290 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 291 | status_t dumpBase(int fd, const Vector<String16>& args); | 
| Eric Laurent | 1d2bff0 | 2011-07-24 17:49:51 -0700 | [diff] [blame] | 292 | status_t dumpEffectChains(int fd, const Vector<String16>& args); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 293 |  | 
| Eric Laurent | feb0db6 | 2011-07-22 09:04:31 -0700 | [diff] [blame] | 294 | void clearPowerManager(); | 
|  | 295 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 296 | // base for record and playback | 
|  | 297 | class TrackBase : public AudioBufferProvider, public RefBase { | 
|  | 298 |  | 
|  | 299 | public: | 
|  | 300 | enum track_state { | 
|  | 301 | IDLE, | 
|  | 302 | TERMINATED, | 
|  | 303 | STOPPED, | 
|  | 304 | RESUMING, | 
|  | 305 | ACTIVE, | 
|  | 306 | PAUSING, | 
|  | 307 | PAUSED | 
|  | 308 | }; | 
|  | 309 |  | 
|  | 310 | enum track_flags { | 
|  | 311 | STEPSERVER_FAILED = 0x01, //  StepServer could not acquire cblk->lock mutex | 
|  | 312 | SYSTEM_FLAGS_MASK = 0x0000ffffUL, | 
|  | 313 | // The upper 16 bits are used for track-specific flags. | 
|  | 314 | }; | 
|  | 315 |  | 
|  | 316 | TrackBase(const wp<ThreadBase>& thread, | 
|  | 317 | const sp<Client>& client, | 
|  | 318 | uint32_t sampleRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 319 | audio_format_t format, | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 320 | uint32_t channelMask, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 321 | int frameCount, | 
|  | 322 | uint32_t flags, | 
|  | 323 | const sp<IMemory>& sharedBuffer, | 
|  | 324 | int sessionId); | 
|  | 325 | ~TrackBase(); | 
|  | 326 |  | 
|  | 327 | virtual status_t    start() = 0; | 
|  | 328 | virtual void        stop() = 0; | 
|  | 329 | sp<IMemory> getCblk() const; | 
|  | 330 | audio_track_cblk_t* cblk() const { return mCblk; } | 
|  | 331 | int         sessionId() { return mSessionId; } | 
|  | 332 |  | 
|  | 333 | protected: | 
|  | 334 | friend class ThreadBase; | 
|  | 335 | friend class RecordHandle; | 
|  | 336 | friend class PlaybackThread; | 
|  | 337 | friend class RecordThread; | 
|  | 338 | friend class MixerThread; | 
|  | 339 | friend class DirectOutputThread; | 
|  | 340 |  | 
|  | 341 | TrackBase(const TrackBase&); | 
|  | 342 | TrackBase& operator = (const TrackBase&); | 
|  | 343 |  | 
|  | 344 | virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer) = 0; | 
|  | 345 | virtual void releaseBuffer(AudioBufferProvider::Buffer* buffer); | 
|  | 346 |  | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 347 | audio_format_t format() const { | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 348 | return mFormat; | 
|  | 349 | } | 
|  | 350 |  | 
|  | 351 | int channelCount() const ; | 
|  | 352 |  | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 353 | uint32_t channelMask() const; | 
|  | 354 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 355 | int sampleRate() const; | 
|  | 356 |  | 
|  | 357 | void* getBuffer(uint32_t offset, uint32_t frames) const; | 
|  | 358 |  | 
|  | 359 | bool isStopped() const { | 
|  | 360 | return mState == STOPPED; | 
|  | 361 | } | 
|  | 362 |  | 
|  | 363 | bool isTerminated() const { | 
|  | 364 | return mState == TERMINATED; | 
|  | 365 | } | 
|  | 366 |  | 
|  | 367 | bool step(); | 
|  | 368 | void reset(); | 
|  | 369 |  | 
|  | 370 | wp<ThreadBase>      mThread; | 
|  | 371 | sp<Client>          mClient; | 
|  | 372 | sp<IMemory>         mCblkMemory; | 
|  | 373 | audio_track_cblk_t* mCblk; | 
|  | 374 | void*               mBuffer; | 
|  | 375 | void*               mBufferEnd; | 
|  | 376 | uint32_t            mFrameCount; | 
|  | 377 | // we don't really need a lock for these | 
|  | 378 | int                 mState; | 
|  | 379 | int                 mClientTid; | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 380 | audio_format_t      mFormat; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 381 | uint32_t            mFlags; | 
|  | 382 | int                 mSessionId; | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 383 | uint8_t             mChannelCount; | 
|  | 384 | uint32_t            mChannelMask; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 385 | }; | 
|  | 386 |  | 
|  | 387 | class ConfigEvent { | 
|  | 388 | public: | 
|  | 389 | ConfigEvent() : mEvent(0), mParam(0) {} | 
|  | 390 |  | 
|  | 391 | int mEvent; | 
|  | 392 | int mParam; | 
|  | 393 | }; | 
|  | 394 |  | 
| Eric Laurent | feb0db6 | 2011-07-22 09:04:31 -0700 | [diff] [blame] | 395 | class PMDeathRecipient : public IBinder::DeathRecipient { | 
|  | 396 | public: | 
|  | 397 | PMDeathRecipient(const wp<ThreadBase>& thread) : mThread(thread) {} | 
|  | 398 | virtual     ~PMDeathRecipient() {} | 
|  | 399 |  | 
|  | 400 | // IBinder::DeathRecipient | 
|  | 401 | virtual     void        binderDied(const wp<IBinder>& who); | 
|  | 402 |  | 
|  | 403 | private: | 
|  | 404 | PMDeathRecipient(const PMDeathRecipient&); | 
|  | 405 | PMDeathRecipient& operator = (const PMDeathRecipient&); | 
|  | 406 |  | 
|  | 407 | wp<ThreadBase> mThread; | 
|  | 408 | }; | 
|  | 409 |  | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 410 | virtual     status_t    initCheck() const = 0; | 
|  | 411 | int         type() const { return mType; } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 412 | uint32_t    sampleRate() const; | 
|  | 413 | int         channelCount() const; | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 414 | audio_format_t format() const; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 415 | size_t      frameCount() const; | 
|  | 416 | void        wakeUp()    { mWaitWorkCV.broadcast(); } | 
|  | 417 | void        exit(); | 
|  | 418 | virtual     bool        checkForNewParameters_l() = 0; | 
|  | 419 | virtual     status_t    setParameters(const String8& keyValuePairs); | 
|  | 420 | virtual     String8     getParameters(const String8& keys) = 0; | 
|  | 421 | virtual     void        audioConfigChanged_l(int event, int param = 0) = 0; | 
|  | 422 | void        sendConfigEvent(int event, int param = 0); | 
|  | 423 | void        sendConfigEvent_l(int event, int param = 0); | 
|  | 424 | void        processConfigEvents(); | 
|  | 425 | int         id() const { return mId;} | 
|  | 426 | bool        standby() { return mStandby; } | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 427 | uint32_t    device() { return mDevice; } | 
|  | 428 | virtual     audio_stream_t* stream() = 0; | 
|  | 429 |  | 
|  | 430 | sp<EffectHandle> createEffect_l( | 
|  | 431 | const sp<AudioFlinger::Client>& client, | 
|  | 432 | const sp<IEffectClient>& effectClient, | 
|  | 433 | int32_t priority, | 
|  | 434 | int sessionId, | 
|  | 435 | effect_descriptor_t *desc, | 
|  | 436 | int *enabled, | 
|  | 437 | status_t *status); | 
|  | 438 | void disconnectEffect(const sp< EffectModule>& effect, | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 439 | const wp<EffectHandle>& handle, | 
|  | 440 | bool unpiniflast); | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 441 |  | 
|  | 442 | // return values for hasAudioSession (bit field) | 
|  | 443 | enum effect_state { | 
|  | 444 | EFFECT_SESSION = 0x1,   // the audio session corresponds to at least one | 
|  | 445 | // effect | 
|  | 446 | TRACK_SESSION = 0x2     // the audio session corresponds to at least one | 
|  | 447 | // track | 
|  | 448 | }; | 
|  | 449 |  | 
|  | 450 | // get effect chain corresponding to session Id. | 
|  | 451 | sp<EffectChain> getEffectChain(int sessionId); | 
|  | 452 | // same as getEffectChain() but must be called with ThreadBase mutex locked | 
|  | 453 | sp<EffectChain> getEffectChain_l(int sessionId); | 
|  | 454 | // add an effect chain to the chain list (mEffectChains) | 
|  | 455 | virtual     status_t addEffectChain_l(const sp<EffectChain>& chain) = 0; | 
|  | 456 | // remove an effect chain from the chain list (mEffectChains) | 
|  | 457 | virtual     size_t removeEffectChain_l(const sp<EffectChain>& chain) = 0; | 
|  | 458 | // lock mall effect chains Mutexes. Must be called before releasing the | 
|  | 459 | // ThreadBase mutex before processing the mixer and effects. This guarantees the | 
|  | 460 | // integrity of the chains during the process. | 
|  | 461 | void lockEffectChains_l(Vector<sp <EffectChain> >& effectChains); | 
|  | 462 | // unlock effect chains after process | 
|  | 463 | void unlockEffectChains(Vector<sp <EffectChain> >& effectChains); | 
|  | 464 | // set audio mode to all effect chains | 
| Glenn Kasten | f78aee7 | 2012-01-04 11:00:47 -0800 | [diff] [blame] | 465 | void setMode(audio_mode_t mode); | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 466 | // get effect module with corresponding ID on specified audio session | 
|  | 467 | sp<AudioFlinger::EffectModule> getEffect_l(int sessionId, int effectId); | 
|  | 468 | // add and effect module. Also creates the effect chain is none exists for | 
|  | 469 | // the effects audio session | 
|  | 470 | status_t addEffect_l(const sp< EffectModule>& effect); | 
|  | 471 | // remove and effect module. Also removes the effect chain is this was the last | 
|  | 472 | // effect | 
|  | 473 | void removeEffect_l(const sp< EffectModule>& effect); | 
|  | 474 | // detach all tracks connected to an auxiliary effect | 
|  | 475 | virtual     void detachAuxEffect_l(int effectId) {} | 
|  | 476 | // returns either EFFECT_SESSION if effects on this audio session exist in one | 
|  | 477 | // chain, or TRACK_SESSION if tracks on this audio session exist, or both | 
|  | 478 | virtual uint32_t hasAudioSession(int sessionId) = 0; | 
|  | 479 | // the value returned by default implementation is not important as the | 
|  | 480 | // strategy is only meaningful for PlaybackThread which implements this method | 
|  | 481 | virtual uint32_t getStrategyForSession_l(int sessionId) { return 0; } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 482 |  | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 483 | // suspend or restore effect according to the type of effect passed. a NULL | 
|  | 484 | // type pointer means suspend all effects in the session | 
|  | 485 | void setEffectSuspended(const effect_uuid_t *type, | 
|  | 486 | bool suspend, | 
|  | 487 | int sessionId = AUDIO_SESSION_OUTPUT_MIX); | 
|  | 488 | // check if some effects must be suspended/restored when an effect is enabled | 
|  | 489 | // or disabled | 
| Eric Laurent | a85a74a | 2011-10-19 11:44:54 -0700 | [diff] [blame] | 490 | void checkSuspendOnEffectEnabled(const sp<EffectModule>& effect, | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 491 | bool enabled, | 
|  | 492 | int sessionId = AUDIO_SESSION_OUTPUT_MIX); | 
| Eric Laurent | a85a74a | 2011-10-19 11:44:54 -0700 | [diff] [blame] | 493 | void checkSuspendOnEffectEnabled_l(const sp<EffectModule>& effect, | 
|  | 494 | bool enabled, | 
|  | 495 | int sessionId = AUDIO_SESSION_OUTPUT_MIX); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 496 | mutable     Mutex                   mLock; | 
|  | 497 |  | 
|  | 498 | protected: | 
|  | 499 |  | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 500 | // entry describing an effect being suspended in mSuspendedSessions keyed vector | 
|  | 501 | class SuspendedSessionDesc : public RefBase { | 
|  | 502 | public: | 
|  | 503 | SuspendedSessionDesc() : mRefCount(0) {} | 
|  | 504 |  | 
|  | 505 | int mRefCount;          // number of active suspend requests | 
|  | 506 | effect_uuid_t mType;    // effect type UUID | 
|  | 507 | }; | 
|  | 508 |  | 
| Eric Laurent | feb0db6 | 2011-07-22 09:04:31 -0700 | [diff] [blame] | 509 | void        acquireWakeLock(); | 
|  | 510 | void        acquireWakeLock_l(); | 
|  | 511 | void        releaseWakeLock(); | 
|  | 512 | void        releaseWakeLock_l(); | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 513 | void setEffectSuspended_l(const effect_uuid_t *type, | 
|  | 514 | bool suspend, | 
|  | 515 | int sessionId = AUDIO_SESSION_OUTPUT_MIX); | 
|  | 516 | // updated mSuspendedSessions when an effect suspended or restored | 
|  | 517 | void        updateSuspendedSessions_l(const effect_uuid_t *type, | 
|  | 518 | bool suspend, | 
|  | 519 | int sessionId); | 
|  | 520 | // check if some effects must be suspended when an effect chain is added | 
|  | 521 | void checkSuspendOnAddEffectChain_l(const sp<EffectChain>& chain); | 
| Eric Laurent | feb0db6 | 2011-07-22 09:04:31 -0700 | [diff] [blame] | 522 |  | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 523 | friend class AudioFlinger; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 524 | friend class Track; | 
|  | 525 | friend class TrackBase; | 
|  | 526 | friend class PlaybackThread; | 
|  | 527 | friend class MixerThread; | 
|  | 528 | friend class DirectOutputThread; | 
|  | 529 | friend class DuplicatingThread; | 
|  | 530 | friend class RecordThread; | 
|  | 531 | friend class RecordTrack; | 
|  | 532 |  | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 533 | int                     mType; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 534 | Condition               mWaitWorkCV; | 
|  | 535 | sp<AudioFlinger>        mAudioFlinger; | 
|  | 536 | uint32_t                mSampleRate; | 
|  | 537 | size_t                  mFrameCount; | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 538 | uint32_t                mChannelMask; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 539 | uint16_t                mChannelCount; | 
| Glenn Kasten | b998065 | 2012-01-11 09:48:27 -0800 | [diff] [blame] | 540 | size_t                  mFrameSize; | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 541 | audio_format_t          mFormat; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 542 | Condition               mParamCond; | 
|  | 543 | Vector<String8>         mNewParameters; | 
|  | 544 | status_t                mParamStatus; | 
| Glenn Kasten | f3990f2 | 2011-12-13 11:50:00 -0800 | [diff] [blame] | 545 | Vector<ConfigEvent>     mConfigEvents; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 546 | bool                    mStandby; | 
|  | 547 | int                     mId; | 
|  | 548 | bool                    mExiting; | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 549 | Vector< sp<EffectChain> > mEffectChains; | 
|  | 550 | uint32_t                mDevice;    // output device for PlaybackThread | 
|  | 551 | // input + output devices for RecordThread | 
| Eric Laurent | feb0db6 | 2011-07-22 09:04:31 -0700 | [diff] [blame] | 552 | static const int        kNameLength = 32; | 
|  | 553 | char                    mName[kNameLength]; | 
|  | 554 | sp<IPowerManager>       mPowerManager; | 
|  | 555 | sp<IBinder>             mWakeLockToken; | 
|  | 556 | sp<PMDeathRecipient>    mDeathRecipient; | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 557 | // list of suspended effects per session and per type. The first vector is | 
|  | 558 | // keyed by session ID, the second by type UUID timeLow field | 
|  | 559 | KeyedVector< int, KeyedVector< int, sp<SuspendedSessionDesc> > >  mSuspendedSessions; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 560 | }; | 
|  | 561 |  | 
|  | 562 | // --- PlaybackThread --- | 
|  | 563 | class PlaybackThread : public ThreadBase { | 
|  | 564 | public: | 
|  | 565 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 566 | enum mixer_state { | 
|  | 567 | MIXER_IDLE, | 
|  | 568 | MIXER_TRACKS_ENABLED, | 
|  | 569 | MIXER_TRACKS_READY | 
|  | 570 | }; | 
|  | 571 |  | 
|  | 572 | // playback track | 
|  | 573 | class Track : public TrackBase { | 
|  | 574 | public: | 
|  | 575 | Track(  const wp<ThreadBase>& thread, | 
|  | 576 | const sp<Client>& client, | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 577 | audio_stream_type_t streamType, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 578 | uint32_t sampleRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 579 | audio_format_t format, | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 580 | uint32_t channelMask, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 581 | int frameCount, | 
|  | 582 | const sp<IMemory>& sharedBuffer, | 
|  | 583 | int sessionId); | 
|  | 584 | ~Track(); | 
|  | 585 |  | 
|  | 586 | void        dump(char* buffer, size_t size); | 
|  | 587 | virtual status_t    start(); | 
|  | 588 | virtual void        stop(); | 
|  | 589 | void        pause(); | 
|  | 590 |  | 
|  | 591 | void        flush(); | 
|  | 592 | void        destroy(); | 
|  | 593 | void        mute(bool); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 594 | int name() const { | 
|  | 595 | return mName; | 
|  | 596 | } | 
|  | 597 |  | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 598 | audio_stream_type_t type() const { | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 599 | return mStreamType; | 
|  | 600 | } | 
|  | 601 | status_t    attachAuxEffect(int EffectId); | 
|  | 602 | void        setAuxBuffer(int EffectId, int32_t *buffer); | 
|  | 603 | int32_t     *auxBuffer() { return mAuxBuffer; } | 
|  | 604 | void        setMainBuffer(int16_t *buffer) { mMainBuffer = buffer; } | 
|  | 605 | int16_t     *mainBuffer() { return mMainBuffer; } | 
|  | 606 | int         auxEffectId() { return mAuxEffectId; } | 
|  | 607 |  | 
|  | 608 |  | 
|  | 609 | protected: | 
|  | 610 | friend class ThreadBase; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 611 | friend class TrackHandle; | 
|  | 612 | friend class PlaybackThread; | 
|  | 613 | friend class MixerThread; | 
|  | 614 | friend class DirectOutputThread; | 
|  | 615 |  | 
|  | 616 | Track(const Track&); | 
|  | 617 | Track& operator = (const Track&); | 
|  | 618 |  | 
|  | 619 | virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer); | 
|  | 620 | bool isMuted() { return mMute; } | 
|  | 621 | bool isPausing() const { | 
|  | 622 | return mState == PAUSING; | 
|  | 623 | } | 
|  | 624 | bool isPaused() const { | 
|  | 625 | return mState == PAUSED; | 
|  | 626 | } | 
|  | 627 | bool isReady() const; | 
|  | 628 | void setPaused() { mState = PAUSED; } | 
|  | 629 | void reset(); | 
|  | 630 |  | 
|  | 631 | bool isOutputTrack() const { | 
| Dima Zavin | fce7a47 | 2011-04-19 22:30:36 -0700 | [diff] [blame] | 632 | return (mStreamType == AUDIO_STREAM_CNT); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 633 | } | 
|  | 634 |  | 
|  | 635 | // we don't really need a lock for these | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 636 | volatile bool       mMute; | 
|  | 637 | // FILLED state is used for suppressing volume ramp at begin of playing | 
|  | 638 | enum {FS_FILLING, FS_FILLED, FS_ACTIVE}; | 
|  | 639 | mutable uint8_t     mFillingUpStatus; | 
|  | 640 | int8_t              mRetryCount; | 
|  | 641 | sp<IMemory>         mSharedBuffer; | 
|  | 642 | bool                mResetDone; | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 643 | audio_stream_type_t mStreamType; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 644 | int                 mName; | 
|  | 645 | int16_t             *mMainBuffer; | 
|  | 646 | int32_t             *mAuxBuffer; | 
|  | 647 | int                 mAuxEffectId; | 
| Eric Laurent | 8f45bd7 | 2010-08-31 13:50:07 -0700 | [diff] [blame] | 648 | bool                mHasVolumeController; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 649 | };  // end of Track | 
|  | 650 |  | 
|  | 651 |  | 
|  | 652 | // playback track | 
|  | 653 | class OutputTrack : public Track { | 
|  | 654 | public: | 
|  | 655 |  | 
|  | 656 | class Buffer: public AudioBufferProvider::Buffer { | 
|  | 657 | public: | 
|  | 658 | int16_t *mBuffer; | 
|  | 659 | }; | 
|  | 660 |  | 
|  | 661 | OutputTrack(  const wp<ThreadBase>& thread, | 
|  | 662 | DuplicatingThread *sourceThread, | 
|  | 663 | uint32_t sampleRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 664 | audio_format_t format, | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 665 | uint32_t channelMask, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 666 | int frameCount); | 
|  | 667 | ~OutputTrack(); | 
|  | 668 |  | 
|  | 669 | virtual status_t    start(); | 
|  | 670 | virtual void        stop(); | 
|  | 671 | bool        write(int16_t* data, uint32_t frames); | 
|  | 672 | bool        bufferQueueEmpty() { return (mBufferQueue.size() == 0) ? true : false; } | 
|  | 673 | bool        isActive() { return mActive; } | 
|  | 674 | wp<ThreadBase>&     thread()  { return mThread; } | 
|  | 675 |  | 
|  | 676 | private: | 
|  | 677 |  | 
| Glenn Kasten | 335787f | 2012-01-20 17:00:00 -0800 | [diff] [blame] | 678 | enum { | 
|  | 679 | NO_MORE_BUFFERS = 0x80000001,   // same in AudioTrack.h, ok to be different value | 
|  | 680 | }; | 
|  | 681 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 682 | status_t            obtainBuffer(AudioBufferProvider::Buffer* buffer, uint32_t waitTimeMs); | 
|  | 683 | void                clearBufferQueue(); | 
|  | 684 |  | 
|  | 685 | // Maximum number of pending buffers allocated by OutputTrack::write() | 
|  | 686 | static const uint8_t kMaxOverFlowBuffers = 10; | 
|  | 687 |  | 
|  | 688 | Vector < Buffer* >          mBufferQueue; | 
|  | 689 | AudioBufferProvider::Buffer mOutBuffer; | 
|  | 690 | bool                        mActive; | 
|  | 691 | DuplicatingThread*          mSourceThread; | 
|  | 692 | };  // end of OutputTrack | 
|  | 693 |  | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 694 | PlaybackThread (const sp<AudioFlinger>& audioFlinger, AudioStreamOut* output, int id, uint32_t device); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 695 | virtual             ~PlaybackThread(); | 
|  | 696 |  | 
|  | 697 | virtual     status_t    dump(int fd, const Vector<String16>& args); | 
|  | 698 |  | 
|  | 699 | // Thread virtuals | 
|  | 700 | virtual     status_t    readyToRun(); | 
|  | 701 | virtual     void        onFirstRef(); | 
|  | 702 |  | 
| Glenn Kasten | e0feee3 | 2011-12-13 11:53:26 -0800 | [diff] [blame] | 703 | virtual     status_t    initCheck() const { return (mOutput == NULL) ? NO_INIT : NO_ERROR; } | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 704 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 705 | virtual     uint32_t    latency() const; | 
|  | 706 |  | 
|  | 707 | virtual     status_t    setMasterVolume(float value); | 
|  | 708 | virtual     status_t    setMasterMute(bool muted); | 
|  | 709 |  | 
|  | 710 | virtual     float       masterVolume() const; | 
|  | 711 | virtual     bool        masterMute() const; | 
|  | 712 |  | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 713 | virtual     status_t    setStreamVolume(audio_stream_type_t stream, float value); | 
|  | 714 | virtual     status_t    setStreamMute(audio_stream_type_t stream, bool muted); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 715 |  | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 716 | virtual     float       streamVolume(audio_stream_type_t stream) const; | 
|  | 717 | virtual     bool        streamMute(audio_stream_type_t stream) const; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 718 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 719 | sp<Track>   createTrack_l( | 
|  | 720 | const sp<AudioFlinger::Client>& client, | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 721 | audio_stream_type_t streamType, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 722 | uint32_t sampleRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 723 | audio_format_t format, | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 724 | uint32_t channelMask, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 725 | int frameCount, | 
|  | 726 | const sp<IMemory>& sharedBuffer, | 
|  | 727 | int sessionId, | 
|  | 728 | status_t *status); | 
|  | 729 |  | 
| Glenn Kasten | aed850d | 2012-01-26 09:46:34 -0800 | [diff] [blame^] | 730 | AudioStreamOut* getOutput() const; | 
| Eric Laurent | b8ba0a9 | 2011-08-07 16:32:26 -0700 | [diff] [blame] | 731 | AudioStreamOut* clearOutput(); | 
|  | 732 | virtual audio_stream_t* stream(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 733 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 734 | void        suspend() { mSuspended++; } | 
|  | 735 | void        restore() { if (mSuspended) mSuspended--; } | 
| Glenn Kasten | a3a8548 | 2012-01-04 11:01:11 -0800 | [diff] [blame] | 736 | bool        isSuspended() const { return (mSuspended != 0); } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 737 | virtual     String8     getParameters(const String8& keys); | 
|  | 738 | virtual     void        audioConfigChanged_l(int event, int param = 0); | 
|  | 739 | virtual     status_t    getRenderPosition(uint32_t *halFrames, uint32_t *dspFrames); | 
|  | 740 | int16_t     *mixBuffer() { return mMixBuffer; }; | 
|  | 741 |  | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 742 | virtual     void detachAuxEffect_l(int effectId); | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 743 | status_t attachAuxEffect(const sp<AudioFlinger::PlaybackThread::Track> track, | 
|  | 744 | int EffectId); | 
|  | 745 | status_t attachAuxEffect_l(const sp<AudioFlinger::PlaybackThread::Track> track, | 
|  | 746 | int EffectId); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 747 |  | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 748 | virtual status_t addEffectChain_l(const sp<EffectChain>& chain); | 
|  | 749 | virtual size_t removeEffectChain_l(const sp<EffectChain>& chain); | 
|  | 750 | virtual uint32_t hasAudioSession(int sessionId); | 
|  | 751 | virtual uint32_t getStrategyForSession_l(int sessionId); | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 752 |  | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 753 | void setStreamValid(audio_stream_type_t streamType, bool valid); | 
| Eric Laurent | 9f6530f | 2011-08-30 10:18:54 -0700 | [diff] [blame] | 754 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 755 | struct  stream_type_t { | 
|  | 756 | stream_type_t() | 
|  | 757 | :   volume(1.0f), | 
| Eric Laurent | 9f6530f | 2011-08-30 10:18:54 -0700 | [diff] [blame] | 758 | mute(false), | 
|  | 759 | valid(true) | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 760 | { | 
|  | 761 | } | 
|  | 762 | float       volume; | 
|  | 763 | bool        mute; | 
| Eric Laurent | 9f6530f | 2011-08-30 10:18:54 -0700 | [diff] [blame] | 764 | bool        valid; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 765 | }; | 
|  | 766 |  | 
|  | 767 | protected: | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 768 | int16_t*                        mMixBuffer; | 
|  | 769 | int                             mSuspended; | 
|  | 770 | int                             mBytesWritten; | 
| Glenn Kasten | 9806710 | 2011-12-13 11:47:54 -0800 | [diff] [blame] | 771 | private: | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 772 | bool                            mMasterMute; | 
| Glenn Kasten | 9806710 | 2011-12-13 11:47:54 -0800 | [diff] [blame] | 773 | protected: | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 774 | SortedVector< wp<Track> >       mActiveTracks; | 
|  | 775 |  | 
|  | 776 | virtual int             getTrackName_l() = 0; | 
|  | 777 | virtual void            deleteTrackName_l(int name) = 0; | 
| Eric Laurent | 162b40b | 2011-12-05 09:47:19 -0800 | [diff] [blame] | 778 | virtual uint32_t        activeSleepTimeUs(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 779 | virtual uint32_t        idleSleepTimeUs() = 0; | 
| Eric Laurent | 25cbe0e | 2010-08-18 18:13:17 -0700 | [diff] [blame] | 780 | virtual uint32_t        suspendSleepTimeUs() = 0; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 781 |  | 
|  | 782 | private: | 
|  | 783 |  | 
|  | 784 | friend class AudioFlinger; | 
|  | 785 | friend class OutputTrack; | 
|  | 786 | friend class Track; | 
|  | 787 | friend class TrackBase; | 
|  | 788 | friend class MixerThread; | 
|  | 789 | friend class DirectOutputThread; | 
|  | 790 | friend class DuplicatingThread; | 
|  | 791 |  | 
|  | 792 | PlaybackThread(const Client&); | 
|  | 793 | PlaybackThread& operator = (const PlaybackThread&); | 
|  | 794 |  | 
|  | 795 | status_t    addTrack_l(const sp<Track>& track); | 
|  | 796 | void        destroyTrack_l(const sp<Track>& track); | 
| Eric Laurent | b469b94 | 2011-05-09 12:09:06 -0700 | [diff] [blame] | 797 | void        removeTrack_l(const sp<Track>& track); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 798 |  | 
|  | 799 | void        readOutputParameters(); | 
|  | 800 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 801 | virtual status_t    dumpInternals(int fd, const Vector<String16>& args); | 
|  | 802 | status_t    dumpTracks(int fd, const Vector<String16>& args); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 803 |  | 
|  | 804 | SortedVector< sp<Track> >       mTracks; | 
| Glenn Kasten | 263709e | 2012-01-06 08:40:01 -0800 | [diff] [blame] | 805 | // mStreamTypes[] uses 1 additional stream type internally for the OutputTrack used by DuplicatingThread | 
| Dima Zavin | fce7a47 | 2011-04-19 22:30:36 -0700 | [diff] [blame] | 806 | stream_type_t                   mStreamTypes[AUDIO_STREAM_CNT + 1]; | 
| Glenn Kasten | aed850d | 2012-01-26 09:46:34 -0800 | [diff] [blame^] | 807 | AudioStreamOut                  *mOutput; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 808 | float                           mMasterVolume; | 
|  | 809 | nsecs_t                         mLastWriteTime; | 
|  | 810 | int                             mNumWrites; | 
|  | 811 | int                             mNumDelayedWrites; | 
|  | 812 | bool                            mInWrite; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 813 | }; | 
|  | 814 |  | 
|  | 815 | class MixerThread : public PlaybackThread { | 
|  | 816 | public: | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 817 | MixerThread (const sp<AudioFlinger>& audioFlinger, | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 818 | AudioStreamOut* output, | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 819 | int id, | 
|  | 820 | uint32_t device); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 821 | virtual             ~MixerThread(); | 
|  | 822 |  | 
|  | 823 | // Thread virtuals | 
|  | 824 | virtual     bool        threadLoop(); | 
|  | 825 |  | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 826 | void        invalidateTracks(audio_stream_type_t streamType); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 827 | virtual     bool        checkForNewParameters_l(); | 
|  | 828 | virtual     status_t    dumpInternals(int fd, const Vector<String16>& args); | 
|  | 829 |  | 
|  | 830 | protected: | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 831 | uint32_t    prepareTracks_l(const SortedVector< wp<Track> >& activeTracks, | 
|  | 832 | Vector< sp<Track> > *tracksToRemove); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 833 | virtual     int         getTrackName_l(); | 
|  | 834 | virtual     void        deleteTrackName_l(int name); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 835 | virtual     uint32_t    idleSleepTimeUs(); | 
| Eric Laurent | 25cbe0e | 2010-08-18 18:13:17 -0700 | [diff] [blame] | 836 | virtual     uint32_t    suspendSleepTimeUs(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 837 |  | 
| Eric Laurent | 2774144 | 2012-01-17 19:20:12 -0800 | [diff] [blame] | 838 | AudioMixer* mAudioMixer; | 
|  | 839 | uint32_t    mPrevMixerStatus; // previous status (mixer_state) returned by | 
|  | 840 | // prepareTracks_l() | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 841 | }; | 
|  | 842 |  | 
|  | 843 | class DirectOutputThread : public PlaybackThread { | 
|  | 844 | public: | 
|  | 845 |  | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 846 | DirectOutputThread (const sp<AudioFlinger>& audioFlinger, AudioStreamOut* output, int id, uint32_t device); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 847 | ~DirectOutputThread(); | 
|  | 848 |  | 
|  | 849 | // Thread virtuals | 
|  | 850 | virtual     bool        threadLoop(); | 
|  | 851 |  | 
|  | 852 | virtual     bool        checkForNewParameters_l(); | 
|  | 853 |  | 
|  | 854 | protected: | 
|  | 855 | virtual     int         getTrackName_l(); | 
|  | 856 | virtual     void        deleteTrackName_l(int name); | 
|  | 857 | virtual     uint32_t    activeSleepTimeUs(); | 
|  | 858 | virtual     uint32_t    idleSleepTimeUs(); | 
| Eric Laurent | 25cbe0e | 2010-08-18 18:13:17 -0700 | [diff] [blame] | 859 | virtual     uint32_t    suspendSleepTimeUs(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 860 |  | 
|  | 861 | private: | 
|  | 862 | void applyVolume(uint16_t leftVol, uint16_t rightVol, bool ramp); | 
|  | 863 |  | 
|  | 864 | float mLeftVolFloat; | 
|  | 865 | float mRightVolFloat; | 
|  | 866 | uint16_t mLeftVolShort; | 
|  | 867 | uint16_t mRightVolShort; | 
|  | 868 | }; | 
|  | 869 |  | 
|  | 870 | class DuplicatingThread : public MixerThread { | 
|  | 871 | public: | 
|  | 872 | DuplicatingThread (const sp<AudioFlinger>& audioFlinger, MixerThread* mainThread, int id); | 
|  | 873 | ~DuplicatingThread(); | 
|  | 874 |  | 
|  | 875 | // Thread virtuals | 
|  | 876 | virtual     bool        threadLoop(); | 
|  | 877 | void        addOutputTrack(MixerThread* thread); | 
|  | 878 | void        removeOutputTrack(MixerThread* thread); | 
|  | 879 | uint32_t    waitTimeMs() { return mWaitTimeMs; } | 
|  | 880 | protected: | 
|  | 881 | virtual     uint32_t    activeSleepTimeUs(); | 
|  | 882 |  | 
|  | 883 | private: | 
|  | 884 | bool        outputsReady(SortedVector< sp<OutputTrack> > &outputTracks); | 
|  | 885 | void        updateWaitTime(); | 
|  | 886 |  | 
|  | 887 | SortedVector < sp<OutputTrack> >  mOutputTracks; | 
|  | 888 | uint32_t    mWaitTimeMs; | 
|  | 889 | }; | 
|  | 890 |  | 
|  | 891 | PlaybackThread *checkPlaybackThread_l(int output) const; | 
|  | 892 | MixerThread *checkMixerThread_l(int output) const; | 
|  | 893 | RecordThread *checkRecordThread_l(int input) const; | 
| Glenn Kasten | fff6d71 | 2012-01-12 16:38:12 -0800 | [diff] [blame] | 894 | float streamVolumeInternal(audio_stream_type_t stream) const { return mStreamTypes[stream].volume; } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 895 | void audioConfigChanged_l(int event, int ioHandle, void *param2); | 
|  | 896 |  | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 897 | uint32_t nextUniqueId(); | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 898 | status_t moveEffectChain_l(int sessionId, | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 899 | AudioFlinger::PlaybackThread *srcThread, | 
| Eric Laurent | 39e94f8 | 2010-07-28 01:32:47 -0700 | [diff] [blame] | 900 | AudioFlinger::PlaybackThread *dstThread, | 
|  | 901 | bool reRegister); | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 902 | PlaybackThread *primaryPlaybackThread_l(); | 
|  | 903 | uint32_t primaryOutputDevice_l(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 904 |  | 
|  | 905 | friend class AudioBuffer; | 
|  | 906 |  | 
|  | 907 | class TrackHandle : public android::BnAudioTrack { | 
|  | 908 | public: | 
|  | 909 | TrackHandle(const sp<PlaybackThread::Track>& track); | 
|  | 910 | virtual             ~TrackHandle(); | 
|  | 911 | virtual status_t    start(); | 
|  | 912 | virtual void        stop(); | 
|  | 913 | virtual void        flush(); | 
|  | 914 | virtual void        mute(bool); | 
|  | 915 | virtual void        pause(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 916 | virtual sp<IMemory> getCblk() const; | 
|  | 917 | virtual status_t    attachAuxEffect(int effectId); | 
|  | 918 | virtual status_t onTransact( | 
|  | 919 | uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags); | 
|  | 920 | private: | 
|  | 921 | sp<PlaybackThread::Track> mTrack; | 
|  | 922 | }; | 
|  | 923 |  | 
|  | 924 | friend class Client; | 
|  | 925 | friend class PlaybackThread::Track; | 
|  | 926 |  | 
|  | 927 |  | 
|  | 928 | void        removeClient_l(pid_t pid); | 
|  | 929 | void        removeNotificationClient(pid_t pid); | 
|  | 930 |  | 
|  | 931 |  | 
|  | 932 | // record thread | 
|  | 933 | class RecordThread : public ThreadBase, public AudioBufferProvider | 
|  | 934 | { | 
|  | 935 | public: | 
|  | 936 |  | 
|  | 937 | // record track | 
|  | 938 | class RecordTrack : public TrackBase { | 
|  | 939 | public: | 
|  | 940 | RecordTrack(const wp<ThreadBase>& thread, | 
|  | 941 | const sp<Client>& client, | 
|  | 942 | uint32_t sampleRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 943 | audio_format_t format, | 
| Jean-Michel Trivi | 0d255b2 | 2011-05-24 15:53:33 -0700 | [diff] [blame] | 944 | uint32_t channelMask, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 945 | int frameCount, | 
|  | 946 | uint32_t flags, | 
|  | 947 | int sessionId); | 
|  | 948 | ~RecordTrack(); | 
|  | 949 |  | 
|  | 950 | virtual status_t    start(); | 
|  | 951 | virtual void        stop(); | 
|  | 952 |  | 
|  | 953 | bool        overflow() { bool tmp = mOverflow; mOverflow = false; return tmp; } | 
|  | 954 | bool        setOverflow() { bool tmp = mOverflow; mOverflow = true; return tmp; } | 
|  | 955 |  | 
|  | 956 | void        dump(char* buffer, size_t size); | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 957 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 958 | private: | 
|  | 959 | friend class AudioFlinger; | 
|  | 960 | friend class RecordThread; | 
|  | 961 |  | 
|  | 962 | RecordTrack(const RecordTrack&); | 
|  | 963 | RecordTrack& operator = (const RecordTrack&); | 
|  | 964 |  | 
|  | 965 | virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer); | 
|  | 966 |  | 
|  | 967 | bool                mOverflow; | 
|  | 968 | }; | 
|  | 969 |  | 
|  | 970 |  | 
|  | 971 | RecordThread(const sp<AudioFlinger>& audioFlinger, | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 972 | AudioStreamIn *input, | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 973 | uint32_t sampleRate, | 
|  | 974 | uint32_t channels, | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 975 | int id, | 
|  | 976 | uint32_t device); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 977 | ~RecordThread(); | 
|  | 978 |  | 
|  | 979 | virtual bool        threadLoop(); | 
| Eric Laurent | b8ba0a9 | 2011-08-07 16:32:26 -0700 | [diff] [blame] | 980 | virtual status_t    readyToRun(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 981 | virtual void        onFirstRef(); | 
|  | 982 |  | 
| Glenn Kasten | e0feee3 | 2011-12-13 11:53:26 -0800 | [diff] [blame] | 983 | virtual status_t    initCheck() const { return (mInput == NULL) ? NO_INIT : NO_ERROR; } | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 984 | sp<AudioFlinger::RecordThread::RecordTrack>  createRecordTrack_l( | 
|  | 985 | const sp<AudioFlinger::Client>& client, | 
|  | 986 | uint32_t sampleRate, | 
| Glenn Kasten | 58f3021 | 2012-01-12 12:27:51 -0800 | [diff] [blame] | 987 | audio_format_t format, | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 988 | int channelMask, | 
|  | 989 | int frameCount, | 
|  | 990 | uint32_t flags, | 
|  | 991 | int sessionId, | 
|  | 992 | status_t *status); | 
|  | 993 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 994 | status_t    start(RecordTrack* recordTrack); | 
|  | 995 | void        stop(RecordTrack* recordTrack); | 
|  | 996 | status_t    dump(int fd, const Vector<String16>& args); | 
| Glenn Kasten | aed850d | 2012-01-26 09:46:34 -0800 | [diff] [blame^] | 997 | AudioStreamIn* getInput() const; | 
| Eric Laurent | b8ba0a9 | 2011-08-07 16:32:26 -0700 | [diff] [blame] | 998 | AudioStreamIn* clearInput(); | 
|  | 999 | virtual audio_stream_t* stream(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1000 |  | 
|  | 1001 | virtual status_t    getNextBuffer(AudioBufferProvider::Buffer* buffer); | 
|  | 1002 | virtual void        releaseBuffer(AudioBufferProvider::Buffer* buffer); | 
|  | 1003 | virtual bool        checkForNewParameters_l(); | 
|  | 1004 | virtual String8     getParameters(const String8& keys); | 
|  | 1005 | virtual void        audioConfigChanged_l(int event, int param = 0); | 
|  | 1006 | void        readInputParameters(); | 
|  | 1007 | virtual unsigned int  getInputFramesLost(); | 
|  | 1008 |  | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 1009 | virtual status_t addEffectChain_l(const sp<EffectChain>& chain); | 
|  | 1010 | virtual size_t removeEffectChain_l(const sp<EffectChain>& chain); | 
|  | 1011 | virtual uint32_t hasAudioSession(int sessionId); | 
| Eric Laurent | 59bd0da | 2011-08-01 09:52:20 -0700 | [diff] [blame] | 1012 | RecordTrack* track(); | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 1013 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1014 | private: | 
|  | 1015 | RecordThread(); | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 1016 | AudioStreamIn                       *mInput; | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 1017 | RecordTrack*                        mTrack; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1018 | sp<RecordTrack>                     mActiveTrack; | 
|  | 1019 | Condition                           mStartStopCond; | 
|  | 1020 | AudioResampler                      *mResampler; | 
|  | 1021 | int32_t                             *mRsmpOutBuffer; | 
|  | 1022 | int16_t                             *mRsmpInBuffer; | 
|  | 1023 | size_t                              mRsmpInIndex; | 
|  | 1024 | size_t                              mInputBytes; | 
|  | 1025 | int                                 mReqChannelCount; | 
|  | 1026 | uint32_t                            mReqSampleRate; | 
|  | 1027 | ssize_t                             mBytesRead; | 
|  | 1028 | }; | 
|  | 1029 |  | 
|  | 1030 | class RecordHandle : public android::BnAudioRecord { | 
|  | 1031 | public: | 
|  | 1032 | RecordHandle(const sp<RecordThread::RecordTrack>& recordTrack); | 
|  | 1033 | virtual             ~RecordHandle(); | 
|  | 1034 | virtual status_t    start(); | 
|  | 1035 | virtual void        stop(); | 
|  | 1036 | virtual sp<IMemory> getCblk() const; | 
|  | 1037 | virtual status_t onTransact( | 
|  | 1038 | uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags); | 
|  | 1039 | private: | 
|  | 1040 | sp<RecordThread::RecordTrack> mRecordTrack; | 
|  | 1041 | }; | 
|  | 1042 |  | 
|  | 1043 | //--- Audio Effect Management | 
|  | 1044 |  | 
|  | 1045 | // EffectModule and EffectChain classes both have their own mutex to protect | 
|  | 1046 | // state changes or resource modifications. Always respect the following order | 
|  | 1047 | // if multiple mutexes must be acquired to avoid cross deadlock: | 
|  | 1048 | // AudioFlinger -> ThreadBase -> EffectChain -> EffectModule | 
|  | 1049 |  | 
|  | 1050 | // The EffectModule class is a wrapper object controlling the effect engine implementation | 
|  | 1051 | // in the effect library. It prevents concurrent calls to process() and command() functions | 
|  | 1052 | // from different client threads. It keeps a list of EffectHandle objects corresponding | 
|  | 1053 | // to all client applications using this effect and notifies applications of effect state, | 
|  | 1054 | // control or parameter changes. It manages the activation state machine to send appropriate | 
|  | 1055 | // reset, enable, disable commands to effect engine and provide volume | 
|  | 1056 | // ramping when effects are activated/deactivated. | 
|  | 1057 | // When controlling an auxiliary effect, the EffectModule also provides an input buffer used by | 
|  | 1058 | // the attached track(s) to accumulate their auxiliary channel. | 
|  | 1059 | class EffectModule: public RefBase { | 
|  | 1060 | public: | 
|  | 1061 | EffectModule(const wp<ThreadBase>& wThread, | 
|  | 1062 | const wp<AudioFlinger::EffectChain>& chain, | 
|  | 1063 | effect_descriptor_t *desc, | 
|  | 1064 | int id, | 
|  | 1065 | int sessionId); | 
|  | 1066 | ~EffectModule(); | 
|  | 1067 |  | 
|  | 1068 | enum effect_state { | 
|  | 1069 | IDLE, | 
|  | 1070 | RESTART, | 
|  | 1071 | STARTING, | 
|  | 1072 | ACTIVE, | 
|  | 1073 | STOPPING, | 
| Eric Laurent | ec437d8 | 2011-07-26 20:54:46 -0700 | [diff] [blame] | 1074 | STOPPED, | 
|  | 1075 | DESTROYED | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1076 | }; | 
|  | 1077 |  | 
|  | 1078 | int         id() { return mId; } | 
|  | 1079 | void process(); | 
|  | 1080 | void updateState(); | 
| Eric Laurent | 25f4395 | 2010-07-28 05:40:18 -0700 | [diff] [blame] | 1081 | status_t command(uint32_t cmdCode, | 
|  | 1082 | uint32_t cmdSize, | 
|  | 1083 | void *pCmdData, | 
|  | 1084 | uint32_t *replySize, | 
|  | 1085 | void *pReplyData); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1086 |  | 
|  | 1087 | void reset_l(); | 
|  | 1088 | status_t configure(); | 
|  | 1089 | status_t init(); | 
|  | 1090 | uint32_t state() { | 
|  | 1091 | return mState; | 
|  | 1092 | } | 
|  | 1093 | uint32_t status() { | 
|  | 1094 | return mStatus; | 
|  | 1095 | } | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 1096 | int sessionId() { | 
|  | 1097 | return mSessionId; | 
|  | 1098 | } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1099 | status_t    setEnabled(bool enabled); | 
|  | 1100 | bool isEnabled(); | 
| Eric Laurent | 8f45bd7 | 2010-08-31 13:50:07 -0700 | [diff] [blame] | 1101 | bool isProcessEnabled(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1102 |  | 
|  | 1103 | void        setInBuffer(int16_t *buffer) { mConfig.inputCfg.buffer.s16 = buffer; } | 
|  | 1104 | int16_t     *inBuffer() { return mConfig.inputCfg.buffer.s16; } | 
|  | 1105 | void        setOutBuffer(int16_t *buffer) { mConfig.outputCfg.buffer.s16 = buffer; } | 
|  | 1106 | int16_t     *outBuffer() { return mConfig.outputCfg.buffer.s16; } | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 1107 | void        setChain(const wp<EffectChain>& chain) { mChain = chain; } | 
|  | 1108 | void        setThread(const wp<ThreadBase>& thread) { mThread = thread; } | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1109 | wp<ThreadBase>& thread() { return mThread; } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1110 |  | 
|  | 1111 | status_t addHandle(sp<EffectHandle>& handle); | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 1112 | void disconnect(const wp<EffectHandle>& handle, bool unpiniflast); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1113 | size_t removeHandle (const wp<EffectHandle>& handle); | 
|  | 1114 |  | 
|  | 1115 | effect_descriptor_t& desc() { return mDescriptor; } | 
|  | 1116 | wp<EffectChain>&     chain() { return mChain; } | 
|  | 1117 |  | 
|  | 1118 | status_t         setDevice(uint32_t device); | 
|  | 1119 | status_t         setVolume(uint32_t *left, uint32_t *right, bool controller); | 
| Glenn Kasten | f78aee7 | 2012-01-04 11:00:47 -0800 | [diff] [blame] | 1120 | status_t         setMode(audio_mode_t mode); | 
| Eric Laurent | ec35a14 | 2011-10-05 17:42:25 -0700 | [diff] [blame] | 1121 | status_t         start(); | 
| Eric Laurent | ec437d8 | 2011-07-26 20:54:46 -0700 | [diff] [blame] | 1122 | status_t         stop(); | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1123 | void             setSuspended(bool suspended); | 
| Glenn Kasten | a3a8548 | 2012-01-04 11:01:11 -0800 | [diff] [blame] | 1124 | bool             suspended() const; | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1125 |  | 
|  | 1126 | sp<EffectHandle> controlHandle(); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1127 |  | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 1128 | bool             isPinned() { return mPinned; } | 
|  | 1129 | void             unPin() { mPinned = false; } | 
|  | 1130 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1131 | status_t         dump(int fd, const Vector<String16>& args); | 
|  | 1132 |  | 
|  | 1133 | protected: | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 1134 | friend class EffectHandle; | 
|  | 1135 | friend class AudioFlinger; | 
|  | 1136 | bool                mPinned; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1137 |  | 
|  | 1138 | // Maximum time allocated to effect engines to complete the turn off sequence | 
|  | 1139 | static const uint32_t MAX_DISABLE_TIME_MS = 10000; | 
|  | 1140 |  | 
|  | 1141 | EffectModule(const EffectModule&); | 
|  | 1142 | EffectModule& operator = (const EffectModule&); | 
|  | 1143 |  | 
|  | 1144 | status_t start_l(); | 
|  | 1145 | status_t stop_l(); | 
|  | 1146 |  | 
| Glenn Kasten | a3a8548 | 2012-01-04 11:01:11 -0800 | [diff] [blame] | 1147 | mutable Mutex               mLock;      // mutex for process, commands and handles list protection | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1148 | wp<ThreadBase>      mThread;    // parent thread | 
|  | 1149 | wp<EffectChain>     mChain;     // parent effect chain | 
|  | 1150 | int                 mId;        // this instance unique ID | 
|  | 1151 | int                 mSessionId; // audio session ID | 
|  | 1152 | effect_descriptor_t mDescriptor;// effect descriptor received from effect engine | 
|  | 1153 | effect_config_t     mConfig;    // input and output audio configuration | 
| Eric Laurent | e1315cf | 2011-05-17 19:16:02 -0700 | [diff] [blame] | 1154 | effect_handle_t  mEffectInterface; // Effect module C API | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1155 | status_t mStatus;               // initialization status | 
|  | 1156 | uint32_t mState;                // current activation state (effect_state) | 
|  | 1157 | Vector< wp<EffectHandle> > mHandles;    // list of client handles | 
|  | 1158 | uint32_t mMaxDisableWaitCnt;    // maximum grace period before forcing an effect off after | 
|  | 1159 | // sending disable command. | 
|  | 1160 | uint32_t mDisableWaitCnt;       // current process() calls count during disable period. | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1161 | bool     mSuspended;            // effect is suspended: temporarily disabled by framework | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1162 | }; | 
|  | 1163 |  | 
|  | 1164 | // The EffectHandle class implements the IEffect interface. It provides resources | 
|  | 1165 | // to receive parameter updates, keeps track of effect control | 
|  | 1166 | // ownership and state and has a pointer to the EffectModule object it is controlling. | 
|  | 1167 | // There is one EffectHandle object for each application controlling (or using) | 
|  | 1168 | // an effect module. | 
|  | 1169 | // The EffectHandle is obtained by calling AudioFlinger::createEffect(). | 
|  | 1170 | class EffectHandle: public android::BnEffect { | 
|  | 1171 | public: | 
|  | 1172 |  | 
|  | 1173 | EffectHandle(const sp<EffectModule>& effect, | 
|  | 1174 | const sp<AudioFlinger::Client>& client, | 
|  | 1175 | const sp<IEffectClient>& effectClient, | 
|  | 1176 | int32_t priority); | 
|  | 1177 | virtual ~EffectHandle(); | 
|  | 1178 |  | 
|  | 1179 | // IEffect | 
|  | 1180 | virtual status_t enable(); | 
|  | 1181 | virtual status_t disable(); | 
| Eric Laurent | 25f4395 | 2010-07-28 05:40:18 -0700 | [diff] [blame] | 1182 | virtual status_t command(uint32_t cmdCode, | 
|  | 1183 | uint32_t cmdSize, | 
|  | 1184 | void *pCmdData, | 
|  | 1185 | uint32_t *replySize, | 
|  | 1186 | void *pReplyData); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1187 | virtual void disconnect(); | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 1188 | virtual void disconnect(bool unpiniflast); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1189 | virtual sp<IMemory> getCblk() const; | 
|  | 1190 | virtual status_t onTransact(uint32_t code, const Parcel& data, | 
|  | 1191 | Parcel* reply, uint32_t flags); | 
|  | 1192 |  | 
|  | 1193 |  | 
|  | 1194 | // Give or take control of effect module | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1195 | // - hasControl: true if control is given, false if removed | 
|  | 1196 | // - signal: true client app should be signaled of change, false otherwise | 
|  | 1197 | // - enabled: state of the effect when control is passed | 
|  | 1198 | void setControl(bool hasControl, bool signal, bool enabled); | 
| Eric Laurent | 25f4395 | 2010-07-28 05:40:18 -0700 | [diff] [blame] | 1199 | void commandExecuted(uint32_t cmdCode, | 
|  | 1200 | uint32_t cmdSize, | 
|  | 1201 | void *pCmdData, | 
|  | 1202 | uint32_t replySize, | 
|  | 1203 | void *pReplyData); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1204 | void setEnabled(bool enabled); | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1205 | bool enabled() { return mEnabled; } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1206 |  | 
|  | 1207 | // Getters | 
|  | 1208 | int id() { return mEffect->id(); } | 
|  | 1209 | int priority() { return mPriority; } | 
|  | 1210 | bool hasControl() { return mHasControl; } | 
|  | 1211 | sp<EffectModule> effect() { return mEffect; } | 
|  | 1212 |  | 
|  | 1213 | void dump(char* buffer, size_t size); | 
|  | 1214 |  | 
|  | 1215 | protected: | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 1216 | friend class AudioFlinger; | 
|  | 1217 | friend class EffectModule; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1218 | EffectHandle(const EffectHandle&); | 
|  | 1219 | EffectHandle& operator =(const EffectHandle&); | 
|  | 1220 |  | 
|  | 1221 | sp<EffectModule> mEffect;           // pointer to controlled EffectModule | 
|  | 1222 | sp<IEffectClient> mEffectClient;    // callback interface for client notifications | 
|  | 1223 | sp<Client>          mClient;        // client for shared memory allocation | 
|  | 1224 | sp<IMemory>         mCblkMemory;    // shared memory for control block | 
|  | 1225 | effect_param_cblk_t* mCblk;         // control block for deferred parameter setting via shared memory | 
|  | 1226 | uint8_t*            mBuffer;        // pointer to parameter area in shared memory | 
|  | 1227 | int mPriority;                      // client application priority to control the effect | 
|  | 1228 | bool mHasControl;                   // true if this handle is controlling the effect | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1229 | bool mEnabled;                      // cached enable state: needed when the effect is | 
|  | 1230 | // restored after being suspended | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1231 | }; | 
|  | 1232 |  | 
|  | 1233 | // the EffectChain class represents a group of effects associated to one audio session. | 
|  | 1234 | // There can be any number of EffectChain objects per output mixer thread (PlaybackThread). | 
|  | 1235 | // The EffecChain with session ID 0 contains global effects applied to the output mix. | 
|  | 1236 | // Effects in this chain can be insert or auxiliary. Effects in other chains (attached to tracks) | 
|  | 1237 | // are insert only. The EffectChain maintains an ordered list of effect module, the order corresponding | 
|  | 1238 | // in the effect process order. When attached to a track (session ID != 0), it also provide it's own | 
|  | 1239 | // input buffer used by the track as accumulation buffer. | 
|  | 1240 | class EffectChain: public RefBase { | 
|  | 1241 | public: | 
|  | 1242 | EffectChain(const wp<ThreadBase>& wThread, int sessionId); | 
|  | 1243 | ~EffectChain(); | 
|  | 1244 |  | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1245 | // special key used for an entry in mSuspendedEffects keyed vector | 
|  | 1246 | // corresponding to a suspend all request. | 
|  | 1247 | static const int        kKeyForSuspendAll = 0; | 
|  | 1248 |  | 
| Eric Laurent | 544fe9b | 2011-11-11 15:42:52 -0800 | [diff] [blame] | 1249 | // minimum duration during which we force calling effect process when last track on | 
|  | 1250 | // a session is stopped or removed to allow effect tail to be rendered | 
|  | 1251 | static const int        kProcessTailDurationMs = 1000; | 
|  | 1252 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1253 | void process_l(); | 
|  | 1254 |  | 
|  | 1255 | void lock() { | 
|  | 1256 | mLock.lock(); | 
|  | 1257 | } | 
|  | 1258 | void unlock() { | 
|  | 1259 | mLock.unlock(); | 
|  | 1260 | } | 
|  | 1261 |  | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 1262 | status_t addEffect_l(const sp<EffectModule>& handle); | 
| Eric Laurent | cab1124 | 2010-07-15 12:50:15 -0700 | [diff] [blame] | 1263 | size_t removeEffect_l(const sp<EffectModule>& handle); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1264 |  | 
| Eric Laurent | 7c7f10b | 2011-06-17 21:29:58 -0700 | [diff] [blame] | 1265 | int sessionId() { return mSessionId; } | 
|  | 1266 | void setSessionId(int sessionId) { mSessionId = sessionId; } | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 1267 |  | 
| Eric Laurent | cab1124 | 2010-07-15 12:50:15 -0700 | [diff] [blame] | 1268 | sp<EffectModule> getEffectFromDesc_l(effect_descriptor_t *descriptor); | 
|  | 1269 | sp<EffectModule> getEffectFromId_l(int id); | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1270 | sp<EffectModule> getEffectFromType_l(const effect_uuid_t *type); | 
| Eric Laurent | cab1124 | 2010-07-15 12:50:15 -0700 | [diff] [blame] | 1271 | bool setVolume_l(uint32_t *left, uint32_t *right); | 
|  | 1272 | void setDevice_l(uint32_t device); | 
| Glenn Kasten | f78aee7 | 2012-01-04 11:00:47 -0800 | [diff] [blame] | 1273 | void setMode_l(audio_mode_t mode); | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1274 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1275 | void setInBuffer(int16_t *buffer, bool ownsBuffer = false) { | 
|  | 1276 | mInBuffer = buffer; | 
|  | 1277 | mOwnInBuffer = ownsBuffer; | 
|  | 1278 | } | 
|  | 1279 | int16_t *inBuffer() { | 
|  | 1280 | return mInBuffer; | 
|  | 1281 | } | 
|  | 1282 | void setOutBuffer(int16_t *buffer) { | 
|  | 1283 | mOutBuffer = buffer; | 
|  | 1284 | } | 
|  | 1285 | int16_t *outBuffer() { | 
|  | 1286 | return mOutBuffer; | 
|  | 1287 | } | 
|  | 1288 |  | 
| Eric Laurent | b469b94 | 2011-05-09 12:09:06 -0700 | [diff] [blame] | 1289 | void incTrackCnt() { android_atomic_inc(&mTrackCnt); } | 
|  | 1290 | void decTrackCnt() { android_atomic_dec(&mTrackCnt); } | 
|  | 1291 | int32_t trackCnt() { return mTrackCnt;} | 
|  | 1292 |  | 
| Eric Laurent | 544fe9b | 2011-11-11 15:42:52 -0800 | [diff] [blame] | 1293 | void incActiveTrackCnt() { android_atomic_inc(&mActiveTrackCnt); | 
|  | 1294 | mTailBufferCount = mMaxTailBuffers; } | 
| Eric Laurent | b469b94 | 2011-05-09 12:09:06 -0700 | [diff] [blame] | 1295 | void decActiveTrackCnt() { android_atomic_dec(&mActiveTrackCnt); } | 
|  | 1296 | int32_t activeTrackCnt() { return mActiveTrackCnt;} | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1297 |  | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 1298 | uint32_t strategy() { return mStrategy; } | 
|  | 1299 | void setStrategy(uint32_t strategy) | 
|  | 1300 | { mStrategy = strategy; } | 
|  | 1301 |  | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1302 | // suspend effect of the given type | 
|  | 1303 | void setEffectSuspended_l(const effect_uuid_t *type, | 
|  | 1304 | bool suspend); | 
|  | 1305 | // suspend all eligible effects | 
|  | 1306 | void setEffectSuspendedAll_l(bool suspend); | 
|  | 1307 | // check if effects should be suspend or restored when a given effect is enable or disabled | 
| Eric Laurent | a85a74a | 2011-10-19 11:44:54 -0700 | [diff] [blame] | 1308 | void checkSuspendOnEffectEnabled(const sp<EffectModule>& effect, | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1309 | bool enabled); | 
|  | 1310 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1311 | status_t dump(int fd, const Vector<String16>& args); | 
|  | 1312 |  | 
|  | 1313 | protected: | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 1314 | friend class AudioFlinger; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1315 | EffectChain(const EffectChain&); | 
|  | 1316 | EffectChain& operator =(const EffectChain&); | 
|  | 1317 |  | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1318 | class SuspendedEffectDesc : public RefBase { | 
|  | 1319 | public: | 
|  | 1320 | SuspendedEffectDesc() : mRefCount(0) {} | 
|  | 1321 |  | 
|  | 1322 | int mRefCount; | 
|  | 1323 | effect_uuid_t mType; | 
|  | 1324 | wp<EffectModule> mEffect; | 
|  | 1325 | }; | 
|  | 1326 |  | 
|  | 1327 | // get a list of effect modules to suspend when an effect of the type | 
|  | 1328 | // passed is enabled. | 
|  | 1329 | Vector< sp<EffectModule> > getSuspendEligibleEffects(); | 
|  | 1330 | // get an effect module if it is currently enable | 
|  | 1331 | sp<EffectModule> getEffectIfEnabled(const effect_uuid_t *type); | 
| Eric Laurent | db7c079 | 2011-08-10 10:37:50 -0700 | [diff] [blame] | 1332 | // true if the effect whose descriptor is passed can be suspended | 
|  | 1333 | // OEMs can modify the rules implemented in this method to exclude specific effect | 
|  | 1334 | // types or implementations from the suspend/restore mechanism. | 
|  | 1335 | bool isEffectEligibleForSuspend(const effect_descriptor_t& desc); | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1336 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1337 | wp<ThreadBase> mThread;     // parent mixer thread | 
|  | 1338 | Mutex mLock;                // mutex protecting effect list | 
|  | 1339 | Vector<sp<EffectModule> > mEffects; // list of effect modules | 
|  | 1340 | int mSessionId;             // audio session ID | 
|  | 1341 | int16_t *mInBuffer;         // chain input buffer | 
|  | 1342 | int16_t *mOutBuffer;        // chain output buffer | 
| Eric Laurent | b469b94 | 2011-05-09 12:09:06 -0700 | [diff] [blame] | 1343 | volatile int32_t mActiveTrackCnt;  // number of active tracks connected | 
|  | 1344 | volatile int32_t mTrackCnt;        // number of tracks connected | 
| Eric Laurent | 544fe9b | 2011-11-11 15:42:52 -0800 | [diff] [blame] | 1345 | int32_t mTailBufferCount;   // current effect tail buffer count | 
|  | 1346 | int32_t mMaxTailBuffers;    // maximum effect tail buffers | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1347 | bool mOwnInBuffer;          // true if the chain owns its input buffer | 
| Eric Laurent | cab1124 | 2010-07-15 12:50:15 -0700 | [diff] [blame] | 1348 | int mVolumeCtrlIdx;         // index of insert effect having control over volume | 
|  | 1349 | uint32_t mLeftVolume;       // previous volume on left channel | 
|  | 1350 | uint32_t mRightVolume;      // previous volume on right channel | 
| Eric Laurent | f997cab | 2010-07-19 06:24:46 -0700 | [diff] [blame] | 1351 | uint32_t mNewLeftVolume;       // new volume on left channel | 
|  | 1352 | uint32_t mNewRightVolume;      // new volume on right channel | 
| Eric Laurent | de07013 | 2010-07-13 04:45:46 -0700 | [diff] [blame] | 1353 | uint32_t mStrategy; // strategy for this effect chain | 
| Eric Laurent | 59255e4 | 2011-07-27 19:49:51 -0700 | [diff] [blame] | 1354 | // mSuspendedEffects lists all effect currently suspended in the chain | 
|  | 1355 | // use effect type UUID timelow field as key. There is no real risk of identical | 
|  | 1356 | // timeLow fields among effect type UUIDs. | 
|  | 1357 | KeyedVector< int, sp<SuspendedEffectDesc> > mSuspendedEffects; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1358 | }; | 
|  | 1359 |  | 
| Glenn Kasten | aed850d | 2012-01-26 09:46:34 -0800 | [diff] [blame^] | 1360 | // AudioStreamOut and AudioStreamIn are immutable, so their fields are const. | 
|  | 1361 | // For emphasis, we could also make all pointers to them be "const *", | 
|  | 1362 | // but that would clutter the code unnecessarily. | 
|  | 1363 |  | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 1364 | struct AudioStreamOut { | 
| Glenn Kasten | aed850d | 2012-01-26 09:46:34 -0800 | [diff] [blame^] | 1365 | audio_hw_device_t*  const hwDev; | 
|  | 1366 | audio_stream_out_t* const stream; | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 1367 |  | 
|  | 1368 | AudioStreamOut(audio_hw_device_t *dev, audio_stream_out_t *out) : | 
|  | 1369 | hwDev(dev), stream(out) {} | 
|  | 1370 | }; | 
|  | 1371 |  | 
|  | 1372 | struct AudioStreamIn { | 
| Glenn Kasten | aed850d | 2012-01-26 09:46:34 -0800 | [diff] [blame^] | 1373 | audio_hw_device_t* const hwDev; | 
|  | 1374 | audio_stream_in_t* const stream; | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 1375 |  | 
|  | 1376 | AudioStreamIn(audio_hw_device_t *dev, audio_stream_in_t *in) : | 
|  | 1377 | hwDev(dev), stream(in) {} | 
|  | 1378 | }; | 
|  | 1379 |  | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 1380 | struct AudioSessionRef { | 
|  | 1381 | int sessionid; | 
|  | 1382 | pid_t pid; | 
|  | 1383 | int cnt; | 
|  | 1384 | }; | 
|  | 1385 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1386 | friend class RecordThread; | 
|  | 1387 | friend class PlaybackThread; | 
|  | 1388 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1389 | mutable     Mutex                               mLock; | 
|  | 1390 |  | 
|  | 1391 | DefaultKeyedVector< pid_t, wp<Client> >     mClients; | 
|  | 1392 |  | 
|  | 1393 | mutable     Mutex                   mHardwareLock; | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 1394 | audio_hw_device_t*                  mPrimaryHardwareDev; | 
|  | 1395 | Vector<audio_hw_device_t*>          mAudioHwDevs; | 
| Glenn Kasten | a4454b4 | 2012-01-04 11:02:33 -0800 | [diff] [blame] | 1396 | mutable     hardware_call_state                 mHardwareStatus;    // for dump only | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1397 |  | 
|  | 1398 |  | 
|  | 1399 | DefaultKeyedVector< int, sp<PlaybackThread> >  mPlaybackThreads; | 
| Dima Zavin | fce7a47 | 2011-04-19 22:30:36 -0700 | [diff] [blame] | 1400 | PlaybackThread::stream_type_t       mStreamTypes[AUDIO_STREAM_CNT]; | 
| Glenn Kasten | 9806710 | 2011-12-13 11:47:54 -0800 | [diff] [blame] | 1401 |  | 
|  | 1402 | // both are protected by mLock | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1403 | float                               mMasterVolume; | 
|  | 1404 | bool                                mMasterMute; | 
|  | 1405 |  | 
|  | 1406 | DefaultKeyedVector< int, sp<RecordThread> >    mRecordThreads; | 
|  | 1407 |  | 
|  | 1408 | DefaultKeyedVector< pid_t, sp<NotificationClient> >    mNotificationClients; | 
|  | 1409 | volatile int32_t                    mNextUniqueId; | 
| Glenn Kasten | f78aee7 | 2012-01-04 11:00:47 -0800 | [diff] [blame] | 1410 | audio_mode_t                        mMode; | 
| Eric Laurent | bee5337 | 2011-08-29 12:42:48 -0700 | [diff] [blame] | 1411 | bool                                mBtNrecIsOff; | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1412 |  | 
| Marco Nelissen | 3a34bef | 2011-08-02 13:33:41 -0700 | [diff] [blame] | 1413 | Vector<AudioSessionRef*> mAudioSessionRefs; | 
| Glenn Kasten | 9806710 | 2011-12-13 11:47:54 -0800 | [diff] [blame] | 1414 |  | 
|  | 1415 | float       masterVolume_l() const  { return mMasterVolume; } | 
|  | 1416 | bool        masterMute_l() const    { return mMasterMute; } | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1417 | }; | 
|  | 1418 |  | 
| Dima Zavin | 799a70e | 2011-04-18 16:57:27 -0700 | [diff] [blame] | 1419 |  | 
| Mathias Agopian | 65ab471 | 2010-07-14 17:59:35 -0700 | [diff] [blame] | 1420 | // ---------------------------------------------------------------------------- | 
|  | 1421 |  | 
|  | 1422 | }; // namespace android | 
|  | 1423 |  | 
|  | 1424 | #endif // ANDROID_AUDIO_FLINGER_H |