AudioFlinger.h revision 88cbea8a918bbaf5e06e48aadd5af5e81d58d232
1/*
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 <common_time/cc_helper.h>
26
27#include <media/IAudioFlinger.h>
28#include <media/IAudioFlingerClient.h>
29#include <media/IAudioTrack.h>
30#include <media/IAudioRecord.h>
31#include <media/AudioSystem.h>
32#include <media/AudioTrack.h>
33
34#include <utils/Atomic.h>
35#include <utils/Errors.h>
36#include <utils/threads.h>
37#include <utils/SortedVector.h>
38#include <utils/TypeHelpers.h>
39#include <utils/Vector.h>
40
41#include <binder/BinderService.h>
42#include <binder/MemoryDealer.h>
43
44#include <system/audio.h>
45#include <hardware/audio.h>
46#include <hardware/audio_policy.h>
47
48#include "AudioBufferProvider.h"
49#include "ExtendedAudioBufferProvider.h"
50#include "FastMixer.h"
51#include "NBAIO.h"
52
53#include <powermanager/IPowerManager.h>
54
55namespace android {
56
57class audio_track_cblk_t;
58class effect_param_cblk_t;
59class AudioMixer;
60class AudioBuffer;
61class AudioResampler;
62class FastMixer;
63
64// ----------------------------------------------------------------------------
65
66// AudioFlinger has a hard-coded upper limit of 2 channels for capture and playback.
67// There is support for > 2 channel tracks down-mixed to 2 channel output via a down-mix effect.
68// Adding full support for > 2 channel capture or playback would require more than simply changing
69// this #define.  There is an independent hard-coded upper limit in AudioMixer;
70// removing that AudioMixer limit would be necessary but insufficient to support > 2 channels.
71// The macro FCC_2 highlights some (but not all) places where there is are 2-channel assumptions.
72// Search also for "2", "left", "right", "[0]", "[1]", ">> 16", "<< 16", etc.
73#define FCC_2 2     // FCC_2 = Fixed Channel Count 2
74
75static const nsecs_t kDefaultStandbyTimeInNsecs = seconds(3);
76
77class AudioFlinger :
78    public BinderService<AudioFlinger>,
79    public BnAudioFlinger
80{
81    friend class BinderService<AudioFlinger>;   // for AudioFlinger()
82public:
83    static const char* getServiceName() { return "media.audio_flinger"; }
84
85    virtual     status_t    dump(int fd, const Vector<String16>& args);
86
87    // IAudioFlinger interface, in binder opcode order
88    virtual sp<IAudioTrack> createTrack(
89                                pid_t pid,
90                                audio_stream_type_t streamType,
91                                uint32_t sampleRate,
92                                audio_format_t format,
93                                uint32_t channelMask,
94                                int frameCount,
95                                IAudioFlinger::track_flags_t flags,
96                                const sp<IMemory>& sharedBuffer,
97                                audio_io_handle_t output,
98                                pid_t tid,
99                                int *sessionId,
100                                status_t *status);
101
102    virtual sp<IAudioRecord> openRecord(
103                                pid_t pid,
104                                audio_io_handle_t input,
105                                uint32_t sampleRate,
106                                audio_format_t format,
107                                uint32_t channelMask,
108                                int frameCount,
109                                IAudioFlinger::track_flags_t flags,
110                                int *sessionId,
111                                status_t *status);
112
113    virtual     uint32_t    sampleRate(audio_io_handle_t output) const;
114    virtual     int         channelCount(audio_io_handle_t output) const;
115    virtual     audio_format_t format(audio_io_handle_t output) const;
116    virtual     size_t      frameCount(audio_io_handle_t output) const;
117    virtual     uint32_t    latency(audio_io_handle_t output) const;
118
119    virtual     status_t    setMasterVolume(float value);
120    virtual     status_t    setMasterMute(bool muted);
121
122    virtual     float       masterVolume() const;
123    virtual     float       masterVolumeSW() const;
124    virtual     bool        masterMute() const;
125
126    virtual     status_t    setStreamVolume(audio_stream_type_t stream, float value,
127                                            audio_io_handle_t output);
128    virtual     status_t    setStreamMute(audio_stream_type_t stream, bool muted);
129
130    virtual     float       streamVolume(audio_stream_type_t stream,
131                                         audio_io_handle_t output) const;
132    virtual     bool        streamMute(audio_stream_type_t stream) const;
133
134    virtual     status_t    setMode(audio_mode_t mode);
135
136    virtual     status_t    setMicMute(bool state);
137    virtual     bool        getMicMute() const;
138
139    virtual     status_t    setParameters(audio_io_handle_t ioHandle, const String8& keyValuePairs);
140    virtual     String8     getParameters(audio_io_handle_t ioHandle, const String8& keys) const;
141
142    virtual     void        registerClient(const sp<IAudioFlingerClient>& client);
143
144    virtual     size_t      getInputBufferSize(uint32_t sampleRate, audio_format_t format, int channelCount) const;
145
146    virtual audio_io_handle_t openOutput(audio_module_handle_t module,
147                                         audio_devices_t *pDevices,
148                                         uint32_t *pSamplingRate,
149                                         audio_format_t *pFormat,
150                                         audio_channel_mask_t *pChannelMask,
151                                         uint32_t *pLatencyMs,
152                                         audio_output_flags_t flags);
153
154    virtual audio_io_handle_t openDuplicateOutput(audio_io_handle_t output1,
155                                                  audio_io_handle_t output2);
156
157    virtual status_t closeOutput(audio_io_handle_t output);
158
159    virtual status_t suspendOutput(audio_io_handle_t output);
160
161    virtual status_t restoreOutput(audio_io_handle_t output);
162
163    virtual audio_io_handle_t openInput(audio_module_handle_t module,
164                                        audio_devices_t *pDevices,
165                                        uint32_t *pSamplingRate,
166                                        audio_format_t *pFormat,
167                                        audio_channel_mask_t *pChannelMask);
168
169    virtual status_t closeInput(audio_io_handle_t input);
170
171    virtual status_t setStreamOutput(audio_stream_type_t stream, audio_io_handle_t output);
172
173    virtual status_t setVoiceVolume(float volume);
174
175    virtual status_t getRenderPosition(uint32_t *halFrames, uint32_t *dspFrames,
176                                       audio_io_handle_t output) const;
177
178    virtual     unsigned int  getInputFramesLost(audio_io_handle_t ioHandle) const;
179
180    virtual int newAudioSessionId();
181
182    virtual void acquireAudioSessionId(int audioSession);
183
184    virtual void releaseAudioSessionId(int audioSession);
185
186    virtual status_t queryNumberEffects(uint32_t *numEffects) const;
187
188    virtual status_t queryEffect(uint32_t index, effect_descriptor_t *descriptor) const;
189
190    virtual status_t getEffectDescriptor(const effect_uuid_t *pUuid,
191                                         effect_descriptor_t *descriptor) const;
192
193    virtual sp<IEffect> createEffect(pid_t pid,
194                        effect_descriptor_t *pDesc,
195                        const sp<IEffectClient>& effectClient,
196                        int32_t priority,
197                        audio_io_handle_t io,
198                        int sessionId,
199                        status_t *status,
200                        int *id,
201                        int *enabled);
202
203    virtual status_t moveEffects(int sessionId, audio_io_handle_t srcOutput,
204                        audio_io_handle_t dstOutput);
205
206    virtual audio_module_handle_t loadHwModule(const char *name);
207
208    virtual     status_t    onTransact(
209                                uint32_t code,
210                                const Parcel& data,
211                                Parcel* reply,
212                                uint32_t flags);
213
214    // end of IAudioFlinger interface
215
216    class SyncEvent;
217
218    typedef void (*sync_event_callback_t)(const wp<SyncEvent>& event) ;
219
220    class SyncEvent : public RefBase {
221    public:
222        SyncEvent(AudioSystem::sync_event_t type,
223                  int triggerSession,
224                  int listenerSession,
225                  sync_event_callback_t callBack,
226                  void *cookie)
227        : mType(type), mTriggerSession(triggerSession), mListenerSession(listenerSession),
228          mCallback(callBack), mCookie(cookie)
229        {}
230
231        virtual ~SyncEvent() {}
232
233        void trigger() { Mutex::Autolock _l(mLock); if (mCallback) mCallback(this); }
234        bool isCancelled() { Mutex::Autolock _l(mLock); return (mCallback == NULL); }
235        void cancel() {Mutex::Autolock _l(mLock); mCallback = NULL; }
236        AudioSystem::sync_event_t type() const { return mType; }
237        int triggerSession() const { return mTriggerSession; }
238        int listenerSession() const { return mListenerSession; }
239        void *cookie() const { return mCookie; }
240
241    private:
242          const AudioSystem::sync_event_t mType;
243          const int mTriggerSession;
244          const int mListenerSession;
245          sync_event_callback_t mCallback;
246          void * const mCookie;
247          Mutex mLock;
248    };
249
250    sp<SyncEvent> createSyncEvent(AudioSystem::sync_event_t type,
251                                        int triggerSession,
252                                        int listenerSession,
253                                        sync_event_callback_t callBack,
254                                        void *cookie);
255private:
256               audio_mode_t getMode() const { return mMode; }
257
258                bool        btNrecIsOff() const { return mBtNrecIsOff; }
259
260                            AudioFlinger();
261    virtual                 ~AudioFlinger();
262
263    // call in any IAudioFlinger method that accesses mPrimaryHardwareDev
264    status_t                initCheck() const { return mPrimaryHardwareDev == NULL ? NO_INIT : NO_ERROR; }
265
266    // RefBase
267    virtual     void        onFirstRef();
268
269    audio_hw_device_t*      findSuitableHwDev_l(audio_module_handle_t module, uint32_t devices);
270    void                    purgeStaleEffects_l();
271
272    // standby delay for MIXER and DUPLICATING playback threads is read from property
273    // ro.audio.flinger_standbytime_ms or defaults to kDefaultStandbyTimeInNsecs
274    static nsecs_t          mStandbyTimeInNsecs;
275
276    // Internal dump utilites.
277    status_t dumpPermissionDenial(int fd, const Vector<String16>& args);
278    status_t dumpClients(int fd, const Vector<String16>& args);
279    status_t dumpInternals(int fd, const Vector<String16>& args);
280
281    // --- Client ---
282    class Client : public RefBase {
283    public:
284                            Client(const sp<AudioFlinger>& audioFlinger, pid_t pid);
285        virtual             ~Client();
286        sp<MemoryDealer>    heap() const;
287        pid_t               pid() const { return mPid; }
288        sp<AudioFlinger>    audioFlinger() const { return mAudioFlinger; }
289
290        bool reserveTimedTrack();
291        void releaseTimedTrack();
292
293    private:
294                            Client(const Client&);
295                            Client& operator = (const Client&);
296        const sp<AudioFlinger> mAudioFlinger;
297        const sp<MemoryDealer> mMemoryDealer;
298        const pid_t         mPid;
299
300        Mutex               mTimedTrackLock;
301        int                 mTimedTrackCount;
302    };
303
304    // --- Notification Client ---
305    class NotificationClient : public IBinder::DeathRecipient {
306    public:
307                            NotificationClient(const sp<AudioFlinger>& audioFlinger,
308                                                const sp<IAudioFlingerClient>& client,
309                                                pid_t pid);
310        virtual             ~NotificationClient();
311
312                sp<IAudioFlingerClient> audioFlingerClient() const { return mAudioFlingerClient; }
313
314                // IBinder::DeathRecipient
315                virtual     void        binderDied(const wp<IBinder>& who);
316
317    private:
318                            NotificationClient(const NotificationClient&);
319                            NotificationClient& operator = (const NotificationClient&);
320
321        const sp<AudioFlinger>  mAudioFlinger;
322        const pid_t             mPid;
323        const sp<IAudioFlingerClient> mAudioFlingerClient;
324    };
325
326    class TrackHandle;
327    class RecordHandle;
328    class RecordThread;
329    class PlaybackThread;
330    class MixerThread;
331    class DirectOutputThread;
332    class DuplicatingThread;
333    class Track;
334    class RecordTrack;
335    class EffectModule;
336    class EffectHandle;
337    class EffectChain;
338    struct AudioStreamOut;
339    struct AudioStreamIn;
340
341    class ThreadBase : public Thread {
342    public:
343
344        enum type_t {
345            MIXER,              // Thread class is MixerThread
346            DIRECT,             // Thread class is DirectOutputThread
347            DUPLICATING,        // Thread class is DuplicatingThread
348            RECORD              // Thread class is RecordThread
349        };
350
351        ThreadBase (const sp<AudioFlinger>& audioFlinger, audio_io_handle_t id, uint32_t device, type_t type);
352        virtual             ~ThreadBase();
353
354        status_t dumpBase(int fd, const Vector<String16>& args);
355        status_t dumpEffectChains(int fd, const Vector<String16>& args);
356
357        void clearPowerManager();
358
359        // base for record and playback
360        class TrackBase : public ExtendedAudioBufferProvider, public RefBase {
361
362        public:
363            enum track_state {
364                IDLE,
365                TERMINATED,
366                FLUSHED,
367                STOPPED,
368                // next 2 states are currently used for fast tracks only
369                STOPPING_1,     // waiting for first underrun
370                STOPPING_2,     // waiting for presentation complete
371                RESUMING,
372                ACTIVE,
373                PAUSING,
374                PAUSED
375            };
376
377                                TrackBase(ThreadBase *thread,
378                                        const sp<Client>& client,
379                                        uint32_t sampleRate,
380                                        audio_format_t format,
381                                        uint32_t channelMask,
382                                        int frameCount,
383                                        const sp<IMemory>& sharedBuffer,
384                                        int sessionId);
385            virtual             ~TrackBase();
386
387            virtual status_t    start(AudioSystem::sync_event_t event = AudioSystem::SYNC_EVENT_NONE,
388                                     int triggerSession = 0) = 0;
389            virtual void        stop() = 0;
390                    sp<IMemory> getCblk() const { return mCblkMemory; }
391                    audio_track_cblk_t* cblk() const { return mCblk; }
392                    int         sessionId() const { return mSessionId; }
393            virtual status_t    setSyncEvent(const sp<SyncEvent>& event);
394
395        protected:
396                                TrackBase(const TrackBase&);
397                                TrackBase& operator = (const TrackBase&);
398
399            // AudioBufferProvider interface
400            virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer, int64_t pts) = 0;
401            virtual void releaseBuffer(AudioBufferProvider::Buffer* buffer);
402
403            // ExtendedAudioBufferProvider interface is only needed for Track,
404            // but putting it in TrackBase avoids the complexity of virtual inheritance
405            virtual size_t  framesReady() const { return SIZE_MAX; }
406
407            audio_format_t format() const {
408                return mFormat;
409            }
410
411            int channelCount() const { return mChannelCount; }
412
413            uint32_t channelMask() const { return mChannelMask; }
414
415            int sampleRate() const; // FIXME inline after cblk sr moved
416
417            void* getBuffer(uint32_t offset, uint32_t frames) const;
418
419            bool isStopped() const {
420                return (mState == STOPPED || mState == FLUSHED);
421            }
422
423            // for fast tracks only
424            bool isStopping() const {
425                return mState == STOPPING_1 || mState == STOPPING_2;
426            }
427            bool isStopping_1() const {
428                return mState == STOPPING_1;
429            }
430            bool isStopping_2() const {
431                return mState == STOPPING_2;
432            }
433
434            bool isTerminated() const {
435                return mState == TERMINATED;
436            }
437
438            bool step();
439            void reset();
440
441            const wp<ThreadBase> mThread;
442            /*const*/ sp<Client> mClient;   // see explanation at ~TrackBase() why not const
443            sp<IMemory>         mCblkMemory;
444            audio_track_cblk_t* mCblk;
445            void*               mBuffer;
446            void*               mBufferEnd;
447            uint32_t            mFrameCount;
448            // we don't really need a lock for these
449            track_state         mState;
450            const uint32_t      mSampleRate;    // initial sample rate only; for tracks which
451                                // support dynamic rates, the current value is in control block
452            const audio_format_t mFormat;
453            bool                mStepServerFailed;
454            const int           mSessionId;
455            uint8_t             mChannelCount;
456            uint32_t            mChannelMask;
457            Vector < sp<SyncEvent> >mSyncEvents;
458        };
459
460        class ConfigEvent {
461        public:
462            ConfigEvent() : mEvent(0), mParam(0) {}
463
464            int mEvent;
465            int mParam;
466        };
467
468        class PMDeathRecipient : public IBinder::DeathRecipient {
469        public:
470                        PMDeathRecipient(const wp<ThreadBase>& thread) : mThread(thread) {}
471            virtual     ~PMDeathRecipient() {}
472
473            // IBinder::DeathRecipient
474            virtual     void        binderDied(const wp<IBinder>& who);
475
476        private:
477                        PMDeathRecipient(const PMDeathRecipient&);
478                        PMDeathRecipient& operator = (const PMDeathRecipient&);
479
480            wp<ThreadBase> mThread;
481        };
482
483        virtual     status_t    initCheck() const = 0;
484                    type_t      type() const { return mType; }
485                    uint32_t    sampleRate() const { return mSampleRate; }
486                    int         channelCount() const { return mChannelCount; }
487                    audio_format_t format() const { return mFormat; }
488                    // Called by AudioFlinger::frameCount(audio_io_handle_t output) and effects,
489                    // and returns the normal mix buffer's frame count.  No API for HAL frame count.
490                    size_t      frameCount() const { return mNormalFrameCount; }
491                    void        wakeUp()    { mWaitWorkCV.broadcast(); }
492        // Should be "virtual status_t requestExitAndWait()" and override same
493        // method in Thread, but Thread::requestExitAndWait() is not yet virtual.
494                    void        exit();
495        virtual     bool        checkForNewParameters_l() = 0;
496        virtual     status_t    setParameters(const String8& keyValuePairs);
497        virtual     String8     getParameters(const String8& keys) = 0;
498        virtual     void        audioConfigChanged_l(int event, int param = 0) = 0;
499                    void        sendConfigEvent(int event, int param = 0);
500                    void        sendConfigEvent_l(int event, int param = 0);
501                    void        processConfigEvents();
502                    audio_io_handle_t id() const { return mId;}
503                    bool        standby() const { return mStandby; }
504                    uint32_t    device() const { return mDevice; }
505        virtual     audio_stream_t* stream() const = 0;
506
507                    sp<EffectHandle> createEffect_l(
508                                        const sp<AudioFlinger::Client>& client,
509                                        const sp<IEffectClient>& effectClient,
510                                        int32_t priority,
511                                        int sessionId,
512                                        effect_descriptor_t *desc,
513                                        int *enabled,
514                                        status_t *status);
515                    void disconnectEffect(const sp< EffectModule>& effect,
516                                          const wp<EffectHandle>& handle,
517                                          bool unpinIfLast);
518
519                    // return values for hasAudioSession (bit field)
520                    enum effect_state {
521                        EFFECT_SESSION = 0x1,   // the audio session corresponds to at least one
522                                                // effect
523                        TRACK_SESSION = 0x2     // the audio session corresponds to at least one
524                                                // track
525                    };
526
527                    // get effect chain corresponding to session Id.
528                    sp<EffectChain> getEffectChain(int sessionId);
529                    // same as getEffectChain() but must be called with ThreadBase mutex locked
530                    sp<EffectChain> getEffectChain_l(int sessionId);
531                    // add an effect chain to the chain list (mEffectChains)
532        virtual     status_t addEffectChain_l(const sp<EffectChain>& chain) = 0;
533                    // remove an effect chain from the chain list (mEffectChains)
534        virtual     size_t removeEffectChain_l(const sp<EffectChain>& chain) = 0;
535                    // lock all effect chains Mutexes. Must be called before releasing the
536                    // ThreadBase mutex before processing the mixer and effects. This guarantees the
537                    // integrity of the chains during the process.
538                    // Also sets the parameter 'effectChains' to current value of mEffectChains.
539                    void lockEffectChains_l(Vector< sp<EffectChain> >& effectChains);
540                    // unlock effect chains after process
541                    void unlockEffectChains(const Vector< sp<EffectChain> >& effectChains);
542                    // set audio mode to all effect chains
543                    void setMode(audio_mode_t mode);
544                    // get effect module with corresponding ID on specified audio session
545                    sp<AudioFlinger::EffectModule> getEffect_l(int sessionId, int effectId);
546                    // add and effect module. Also creates the effect chain is none exists for
547                    // the effects audio session
548                    status_t addEffect_l(const sp< EffectModule>& effect);
549                    // remove and effect module. Also removes the effect chain is this was the last
550                    // effect
551                    void removeEffect_l(const sp< EffectModule>& effect);
552                    // detach all tracks connected to an auxiliary effect
553        virtual     void detachAuxEffect_l(int effectId) {}
554                    // returns either EFFECT_SESSION if effects on this audio session exist in one
555                    // chain, or TRACK_SESSION if tracks on this audio session exist, or both
556                    virtual uint32_t hasAudioSession(int sessionId) = 0;
557                    // the value returned by default implementation is not important as the
558                    // strategy is only meaningful for PlaybackThread which implements this method
559                    virtual uint32_t getStrategyForSession_l(int sessionId) { return 0; }
560
561                    // suspend or restore effect according to the type of effect passed. a NULL
562                    // type pointer means suspend all effects in the session
563                    void setEffectSuspended(const effect_uuid_t *type,
564                                            bool suspend,
565                                            int sessionId = AUDIO_SESSION_OUTPUT_MIX);
566                    // check if some effects must be suspended/restored when an effect is enabled
567                    // or disabled
568                    void checkSuspendOnEffectEnabled(const sp<EffectModule>& effect,
569                                                     bool enabled,
570                                                     int sessionId = AUDIO_SESSION_OUTPUT_MIX);
571                    void checkSuspendOnEffectEnabled_l(const sp<EffectModule>& effect,
572                                                       bool enabled,
573                                                       int sessionId = AUDIO_SESSION_OUTPUT_MIX);
574
575                    virtual status_t    setSyncEvent(const sp<SyncEvent>& event) = 0;
576                    virtual bool        isValidSyncEvent(const sp<SyncEvent>& event) = 0;
577
578
579        mutable     Mutex                   mLock;
580
581    protected:
582
583                    // entry describing an effect being suspended in mSuspendedSessions keyed vector
584                    class SuspendedSessionDesc : public RefBase {
585                    public:
586                        SuspendedSessionDesc() : mRefCount(0) {}
587
588                        int mRefCount;          // number of active suspend requests
589                        effect_uuid_t mType;    // effect type UUID
590                    };
591
592                    void        acquireWakeLock();
593                    void        acquireWakeLock_l();
594                    void        releaseWakeLock();
595                    void        releaseWakeLock_l();
596                    void setEffectSuspended_l(const effect_uuid_t *type,
597                                              bool suspend,
598                                              int sessionId = AUDIO_SESSION_OUTPUT_MIX);
599                    // updated mSuspendedSessions when an effect suspended or restored
600                    void        updateSuspendedSessions_l(const effect_uuid_t *type,
601                                                          bool suspend,
602                                                          int sessionId);
603                    // check if some effects must be suspended when an effect chain is added
604                    void checkSuspendOnAddEffectChain_l(const sp<EffectChain>& chain);
605
606        friend class AudioFlinger;      // for mEffectChains
607
608                    const type_t            mType;
609
610                    // Used by parameters, config events, addTrack_l, exit
611                    Condition               mWaitWorkCV;
612
613                    const sp<AudioFlinger>  mAudioFlinger;
614                    uint32_t                mSampleRate;
615                    size_t                  mFrameCount;       // output HAL, direct output, record
616                    size_t                  mNormalFrameCount; // normal mixer and effects
617                    uint32_t                mChannelMask;
618                    uint16_t                mChannelCount;
619                    size_t                  mFrameSize;
620                    audio_format_t          mFormat;
621
622                    // Parameter sequence by client: binder thread calling setParameters():
623                    //  1. Lock mLock
624                    //  2. Append to mNewParameters
625                    //  3. mWaitWorkCV.signal
626                    //  4. mParamCond.waitRelative with timeout
627                    //  5. read mParamStatus
628                    //  6. mWaitWorkCV.signal
629                    //  7. Unlock
630                    //
631                    // Parameter sequence by server: threadLoop calling checkForNewParameters_l():
632                    // 1. Lock mLock
633                    // 2. If there is an entry in mNewParameters proceed ...
634                    // 2. Read first entry in mNewParameters
635                    // 3. Process
636                    // 4. Remove first entry from mNewParameters
637                    // 5. Set mParamStatus
638                    // 6. mParamCond.signal
639                    // 7. mWaitWorkCV.wait with timeout (this is to avoid overwriting mParamStatus)
640                    // 8. Unlock
641                    Condition               mParamCond;
642                    Vector<String8>         mNewParameters;
643                    status_t                mParamStatus;
644
645                    Vector<ConfigEvent>     mConfigEvents;
646                    bool                    mStandby;
647                    const audio_io_handle_t mId;
648                    Vector< sp<EffectChain> > mEffectChains;
649                    uint32_t                mDevice;    // output device for PlaybackThread
650                                                        // input + output devices for RecordThread
651                    static const int        kNameLength = 16;   // prctl(PR_SET_NAME) limit
652                    char                    mName[kNameLength];
653                    sp<IPowerManager>       mPowerManager;
654                    sp<IBinder>             mWakeLockToken;
655                    const sp<PMDeathRecipient> mDeathRecipient;
656                    // list of suspended effects per session and per type. The first vector is
657                    // keyed by session ID, the second by type UUID timeLow field
658                    KeyedVector< int, KeyedVector< int, sp<SuspendedSessionDesc> > >  mSuspendedSessions;
659    };
660
661    struct  stream_type_t {
662        stream_type_t()
663            :   volume(1.0f),
664                mute(false)
665        {
666        }
667        float       volume;
668        bool        mute;
669    };
670
671    // --- PlaybackThread ---
672    class PlaybackThread : public ThreadBase {
673    public:
674
675        enum mixer_state {
676            MIXER_IDLE,             // no active tracks
677            MIXER_TRACKS_ENABLED,   // at least one active track, but no track has any data ready
678            MIXER_TRACKS_READY      // at least one active track, and at least one track has data
679            // standby mode does not have an enum value
680            // suspend by audio policy manager is orthogonal to mixer state
681        };
682
683        // playback track
684        class Track : public TrackBase, public VolumeProvider {
685        public:
686                                Track(  PlaybackThread *thread,
687                                        const sp<Client>& client,
688                                        audio_stream_type_t streamType,
689                                        uint32_t sampleRate,
690                                        audio_format_t format,
691                                        uint32_t channelMask,
692                                        int frameCount,
693                                        const sp<IMemory>& sharedBuffer,
694                                        int sessionId,
695                                        IAudioFlinger::track_flags_t flags);
696            virtual             ~Track();
697
698            static  void        appendDumpHeader(String8& result);
699                    void        dump(char* buffer, size_t size);
700            virtual status_t    start(AudioSystem::sync_event_t event = AudioSystem::SYNC_EVENT_NONE,
701                                     int triggerSession = 0);
702            virtual void        stop();
703                    void        pause();
704
705                    void        flush();
706                    void        destroy();
707                    void        mute(bool);
708                    int name() const {
709                        return mName;
710                    }
711
712                    audio_stream_type_t streamType() const {
713                        return mStreamType;
714                    }
715                    status_t    attachAuxEffect(int EffectId);
716                    void        setAuxBuffer(int EffectId, int32_t *buffer);
717                    int32_t     *auxBuffer() const { return mAuxBuffer; }
718                    void        setMainBuffer(int16_t *buffer) { mMainBuffer = buffer; }
719                    int16_t     *mainBuffer() const { return mMainBuffer; }
720                    int         auxEffectId() const { return mAuxEffectId; }
721
722        // implement FastMixerState::VolumeProvider interface
723            virtual uint32_t    getVolumeLR();
724            virtual status_t    setSyncEvent(const sp<SyncEvent>& event);
725
726        protected:
727            // for numerous
728            friend class PlaybackThread;
729            friend class MixerThread;
730            friend class DirectOutputThread;
731
732                                Track(const Track&);
733                                Track& operator = (const Track&);
734
735            // AudioBufferProvider interface
736            virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer, int64_t pts = kInvalidPTS);
737            // releaseBuffer() not overridden
738
739            virtual size_t framesReady() const;
740
741            bool isMuted() const { return mMute; }
742            bool isPausing() const {
743                return mState == PAUSING;
744            }
745            bool isPaused() const {
746                return mState == PAUSED;
747            }
748            bool isResuming() const {
749                return mState == RESUMING;
750            }
751            bool isReady() const;
752            void setPaused() { mState = PAUSED; }
753            void reset();
754
755            bool isOutputTrack() const {
756                return (mStreamType == AUDIO_STREAM_CNT);
757            }
758
759            sp<IMemory> sharedBuffer() const { return mSharedBuffer; }
760
761            bool presentationComplete(size_t framesWritten, size_t audioHalFrames);
762
763        public:
764            void triggerEvents(AudioSystem::sync_event_t type);
765            virtual bool isTimedTrack() const { return false; }
766            bool isFastTrack() const { return (mFlags & IAudioFlinger::TRACK_FAST) != 0; }
767        protected:
768
769            // we don't really need a lock for these
770            volatile bool       mMute;
771            // FILLED state is used for suppressing volume ramp at begin of playing
772            enum {FS_INVALID, FS_FILLING, FS_FILLED, FS_ACTIVE};
773            mutable uint8_t     mFillingUpStatus;
774            int8_t              mRetryCount;
775            const sp<IMemory>   mSharedBuffer;
776            bool                mResetDone;
777            const audio_stream_type_t mStreamType;
778            int                 mName;      // track name on the normal mixer,
779                                            // allocated statically at track creation time,
780                                            // and is even allocated (though unused) for fast tracks
781            int16_t             *mMainBuffer;
782            int32_t             *mAuxBuffer;
783            int                 mAuxEffectId;
784            bool                mHasVolumeController;
785            size_t              mPresentationCompleteFrames; // number of frames written to the audio HAL
786                                                       // when this track will be fully rendered
787        private:
788            IAudioFlinger::track_flags_t mFlags;
789
790            // The following fields are only for fast tracks, and should be in a subclass
791            int                 mFastIndex; // index within FastMixerState::mFastTracks[];
792                                            // either mFastIndex == -1
793                                            // or 0 < mFastIndex < FastMixerState::kMaxFast because
794                                            // index 0 is reserved for normal mixer's submix;
795                                            // index is allocated statically at track creation time
796                                            // but the slot is only used if track is active
797            FastTrackUnderruns  mObservedUnderruns; // Most recently observed value of
798                                            // mFastMixerDumpState.mTracks[mFastIndex].mUnderruns
799            uint32_t            mUnderrunCount; // Counter of total number of underruns, never reset
800            volatile float      mCachedVolume;  // combined master volume and stream type volume;
801                                                // 'volatile' means accessed without lock or
802                                                // barrier, but is read/written atomically
803        };  // end of Track
804
805        class TimedTrack : public Track {
806          public:
807            static sp<TimedTrack> create(PlaybackThread *thread,
808                                         const sp<Client>& client,
809                                         audio_stream_type_t streamType,
810                                         uint32_t sampleRate,
811                                         audio_format_t format,
812                                         uint32_t channelMask,
813                                         int frameCount,
814                                         const sp<IMemory>& sharedBuffer,
815                                         int sessionId);
816            ~TimedTrack();
817
818            class TimedBuffer {
819              public:
820                TimedBuffer();
821                TimedBuffer(const sp<IMemory>& buffer, int64_t pts);
822                const sp<IMemory>& buffer() const { return mBuffer; }
823                int64_t pts() const { return mPTS; }
824                uint32_t position() const { return mPosition; }
825                void setPosition(uint32_t pos) { mPosition = pos; }
826              private:
827                sp<IMemory> mBuffer;
828                int64_t     mPTS;
829                uint32_t    mPosition;
830            };
831
832            // Mixer facing methods.
833            virtual bool isTimedTrack() const { return true; }
834            virtual size_t framesReady() const;
835
836            // AudioBufferProvider interface
837            virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer,
838                                           int64_t pts);
839            virtual void releaseBuffer(AudioBufferProvider::Buffer* buffer);
840
841            // Client/App facing methods.
842            status_t    allocateTimedBuffer(size_t size,
843                                            sp<IMemory>* buffer);
844            status_t    queueTimedBuffer(const sp<IMemory>& buffer,
845                                         int64_t pts);
846            status_t    setMediaTimeTransform(const LinearTransform& xform,
847                                              TimedAudioTrack::TargetTimeline target);
848
849          private:
850            TimedTrack(PlaybackThread *thread,
851                       const sp<Client>& client,
852                       audio_stream_type_t streamType,
853                       uint32_t sampleRate,
854                       audio_format_t format,
855                       uint32_t channelMask,
856                       int frameCount,
857                       const sp<IMemory>& sharedBuffer,
858                       int sessionId);
859
860            void timedYieldSamples_l(AudioBufferProvider::Buffer* buffer);
861            void timedYieldSilence_l(uint32_t numFrames,
862                                     AudioBufferProvider::Buffer* buffer);
863            void trimTimedBufferQueue_l();
864            void trimTimedBufferQueueHead_l(const char* logTag);
865            void updateFramesPendingAfterTrim_l(const TimedBuffer& buf,
866                                                const char* logTag);
867
868            uint64_t            mLocalTimeFreq;
869            LinearTransform     mLocalTimeToSampleTransform;
870            LinearTransform     mMediaTimeToSampleTransform;
871            sp<MemoryDealer>    mTimedMemoryDealer;
872
873            Vector<TimedBuffer> mTimedBufferQueue;
874            bool                mQueueHeadInFlight;
875            bool                mTrimQueueHeadOnRelease;
876            uint32_t            mFramesPendingInQueue;
877
878            uint8_t*            mTimedSilenceBuffer;
879            uint32_t            mTimedSilenceBufferSize;
880            mutable Mutex       mTimedBufferQueueLock;
881            bool                mTimedAudioOutputOnTime;
882            CCHelper            mCCHelper;
883
884            Mutex               mMediaTimeTransformLock;
885            LinearTransform     mMediaTimeTransform;
886            bool                mMediaTimeTransformValid;
887            TimedAudioTrack::TargetTimeline mMediaTimeTransformTarget;
888        };
889
890
891        // playback track
892        class OutputTrack : public Track {
893        public:
894
895            class Buffer: public AudioBufferProvider::Buffer {
896            public:
897                int16_t *mBuffer;
898            };
899
900                                OutputTrack(PlaybackThread *thread,
901                                        DuplicatingThread *sourceThread,
902                                        uint32_t sampleRate,
903                                        audio_format_t format,
904                                        uint32_t channelMask,
905                                        int frameCount);
906            virtual             ~OutputTrack();
907
908            virtual status_t    start(AudioSystem::sync_event_t event = AudioSystem::SYNC_EVENT_NONE,
909                                     int triggerSession = 0);
910            virtual void        stop();
911                    bool        write(int16_t* data, uint32_t frames);
912                    bool        bufferQueueEmpty() const { return mBufferQueue.size() == 0; }
913                    bool        isActive() const { return mActive; }
914            const wp<ThreadBase>& thread() const { return mThread; }
915
916        private:
917
918            enum {
919                NO_MORE_BUFFERS = 0x80000001,   // same in AudioTrack.h, ok to be different value
920            };
921
922            status_t            obtainBuffer(AudioBufferProvider::Buffer* buffer, uint32_t waitTimeMs);
923            void                clearBufferQueue();
924
925            // Maximum number of pending buffers allocated by OutputTrack::write()
926            static const uint8_t kMaxOverFlowBuffers = 10;
927
928            Vector < Buffer* >          mBufferQueue;
929            AudioBufferProvider::Buffer mOutBuffer;
930            bool                        mActive;
931            DuplicatingThread* const mSourceThread; // for waitTimeMs() in write()
932        };  // end of OutputTrack
933
934        PlaybackThread (const sp<AudioFlinger>& audioFlinger, AudioStreamOut* output,
935                        audio_io_handle_t id, uint32_t device, type_t type);
936        virtual             ~PlaybackThread();
937
938                    status_t    dump(int fd, const Vector<String16>& args);
939
940        // Thread virtuals
941        virtual     status_t    readyToRun();
942        virtual     bool        threadLoop();
943
944        // RefBase
945        virtual     void        onFirstRef();
946
947protected:
948        // Code snippets that were lifted up out of threadLoop()
949        virtual     void        threadLoop_mix() = 0;
950        virtual     void        threadLoop_sleepTime() = 0;
951        virtual     void        threadLoop_write();
952        virtual     void        threadLoop_standby();
953        virtual     void        threadLoop_removeTracks(const Vector< sp<Track> >& tracksToRemove);
954
955                    // prepareTracks_l reads and writes mActiveTracks, and returns
956                    // the pending set of tracks to remove via Vector 'tracksToRemove'.  The caller
957                    // is responsible for clearing or destroying this Vector later on, when it
958                    // is safe to do so. That will drop the final ref count and destroy the tracks.
959        virtual     mixer_state prepareTracks_l(Vector< sp<Track> > *tracksToRemove) = 0;
960
961public:
962
963        virtual     status_t    initCheck() const { return (mOutput == NULL) ? NO_INIT : NO_ERROR; }
964
965                    // return estimated latency in milliseconds, as reported by HAL
966                    uint32_t    latency() const;
967
968                    void        setMasterVolume(float value);
969                    void        setMasterMute(bool muted);
970
971                    void        setStreamVolume(audio_stream_type_t stream, float value);
972                    void        setStreamMute(audio_stream_type_t stream, bool muted);
973
974                    float       streamVolume(audio_stream_type_t stream) const;
975
976                    sp<Track>   createTrack_l(
977                                    const sp<AudioFlinger::Client>& client,
978                                    audio_stream_type_t streamType,
979                                    uint32_t sampleRate,
980                                    audio_format_t format,
981                                    uint32_t channelMask,
982                                    int frameCount,
983                                    const sp<IMemory>& sharedBuffer,
984                                    int sessionId,
985                                    IAudioFlinger::track_flags_t flags,
986                                    pid_t tid,
987                                    status_t *status);
988
989                    AudioStreamOut* getOutput() const;
990                    AudioStreamOut* clearOutput();
991                    virtual audio_stream_t* stream() const;
992
993                    void        suspend() { mSuspended++; }
994                    void        restore() { if (mSuspended > 0) mSuspended--; }
995                    bool        isSuspended() const { return (mSuspended > 0); }
996        virtual     String8     getParameters(const String8& keys);
997        virtual     void        audioConfigChanged_l(int event, int param = 0);
998                    status_t    getRenderPosition(uint32_t *halFrames, uint32_t *dspFrames);
999                    int16_t     *mixBuffer() const { return mMixBuffer; };
1000
1001        virtual     void detachAuxEffect_l(int effectId);
1002                    status_t attachAuxEffect(const sp<AudioFlinger::PlaybackThread::Track> track,
1003                            int EffectId);
1004                    status_t attachAuxEffect_l(const sp<AudioFlinger::PlaybackThread::Track> track,
1005                            int EffectId);
1006
1007                    virtual status_t addEffectChain_l(const sp<EffectChain>& chain);
1008                    virtual size_t removeEffectChain_l(const sp<EffectChain>& chain);
1009                    virtual uint32_t hasAudioSession(int sessionId);
1010                    virtual uint32_t getStrategyForSession_l(int sessionId);
1011
1012
1013                    virtual status_t setSyncEvent(const sp<SyncEvent>& event);
1014                    virtual bool     isValidSyncEvent(const sp<SyncEvent>& event);
1015
1016    protected:
1017        int16_t*                        mMixBuffer;
1018        uint32_t                        mSuspended;     // suspend count, > 0 means suspended
1019        int                             mBytesWritten;
1020    private:
1021        // mMasterMute is in both PlaybackThread and in AudioFlinger.  When a
1022        // PlaybackThread needs to find out if master-muted, it checks it's local
1023        // copy rather than the one in AudioFlinger.  This optimization saves a lock.
1024        bool                            mMasterMute;
1025                    void        setMasterMute_l(bool muted) { mMasterMute = muted; }
1026    protected:
1027        SortedVector< wp<Track> >       mActiveTracks;  // FIXME check if this could be sp<>
1028
1029        // Allocate a track name for a given channel mask.
1030        //   Returns name >= 0 if successful, -1 on failure.
1031        virtual int             getTrackName_l(audio_channel_mask_t channelMask) = 0;
1032        virtual void            deleteTrackName_l(int name) = 0;
1033
1034        // Time to sleep between cycles when:
1035        virtual uint32_t        activeSleepTimeUs() const;      // mixer state MIXER_TRACKS_ENABLED
1036        virtual uint32_t        idleSleepTimeUs() const = 0;    // mixer state MIXER_IDLE
1037        virtual uint32_t        suspendSleepTimeUs() const = 0; // audio policy manager suspended us
1038        // No sleep when mixer state == MIXER_TRACKS_READY; relies on audio HAL stream->write()
1039        // No sleep in standby mode; waits on a condition
1040
1041        // Code snippets that are temporarily lifted up out of threadLoop() until the merge
1042                    void        checkSilentMode_l();
1043
1044        // Non-trivial for DUPLICATING only
1045        virtual     void        saveOutputTracks() { }
1046        virtual     void        clearOutputTracks() { }
1047
1048        // Cache various calculated values, at threadLoop() entry and after a parameter change
1049        virtual     void        cacheParameters_l();
1050
1051    private:
1052
1053        friend class AudioFlinger;      // for numerous
1054
1055        PlaybackThread(const Client&);
1056        PlaybackThread& operator = (const PlaybackThread&);
1057
1058        status_t    addTrack_l(const sp<Track>& track);
1059        void        destroyTrack_l(const sp<Track>& track);
1060        void        removeTrack_l(const sp<Track>& track);
1061
1062        void        readOutputParameters();
1063
1064        virtual status_t    dumpInternals(int fd, const Vector<String16>& args);
1065        status_t    dumpTracks(int fd, const Vector<String16>& args);
1066
1067        SortedVector< sp<Track> >       mTracks;
1068        // mStreamTypes[] uses 1 additional stream type internally for the OutputTrack used by DuplicatingThread
1069        stream_type_t                   mStreamTypes[AUDIO_STREAM_CNT + 1];
1070        AudioStreamOut                  *mOutput;
1071        float                           mMasterVolume;
1072        nsecs_t                         mLastWriteTime;
1073        int                             mNumWrites;
1074        int                             mNumDelayedWrites;
1075        bool                            mInWrite;
1076
1077        // FIXME rename these former local variables of threadLoop to standard "m" names
1078        nsecs_t                         standbyTime;
1079        size_t                          mixBufferSize;
1080
1081        // cached copies of activeSleepTimeUs() and idleSleepTimeUs() made by cacheParameters_l()
1082        uint32_t                        activeSleepTime;
1083        uint32_t                        idleSleepTime;
1084
1085        uint32_t                        sleepTime;
1086
1087        // mixer status returned by prepareTracks_l()
1088        mixer_state                     mMixerStatus; // current cycle
1089                                                      // previous cycle when in prepareTracks_l()
1090        mixer_state                     mMixerStatusIgnoringFastTracks;
1091                                                      // FIXME or a separate ready state per track
1092
1093        // FIXME move these declarations into the specific sub-class that needs them
1094        // MIXER only
1095        bool                            longStandbyExit;
1096        uint32_t                        sleepTimeShift;
1097
1098        // same as AudioFlinger::mStandbyTimeInNsecs except for DIRECT which uses a shorter value
1099        nsecs_t                         standbyDelay;
1100
1101        // MIXER only
1102        nsecs_t                         maxPeriod;
1103
1104        // DUPLICATING only
1105        uint32_t                        writeFrames;
1106
1107    private:
1108        // The HAL output sink is treated as non-blocking, but current implementation is blocking
1109        sp<NBAIO_Sink>          mOutputSink;
1110        // If a fast mixer is present, the blocking pipe sink, otherwise clear
1111        sp<NBAIO_Sink>          mPipeSink;
1112        // The current sink for the normal mixer to write it's (sub)mix, mOutputSink or mPipeSink
1113        sp<NBAIO_Sink>          mNormalSink;
1114    public:
1115        virtual     bool        hasFastMixer() const = 0;
1116        virtual     FastTrackUnderruns getFastTrackUnderruns(size_t fastIndex) const
1117                                    { FastTrackUnderruns dummy; return dummy; }
1118
1119    protected:
1120                    // accessed by both binder threads and within threadLoop(), lock on mutex needed
1121                    unsigned    mFastTrackAvailMask;    // bit i set if fast track [i] is available
1122
1123    };
1124
1125    class MixerThread : public PlaybackThread {
1126    public:
1127        MixerThread (const sp<AudioFlinger>& audioFlinger,
1128                     AudioStreamOut* output,
1129                     audio_io_handle_t id,
1130                     uint32_t device,
1131                     type_t type = MIXER);
1132        virtual             ~MixerThread();
1133
1134        // Thread virtuals
1135
1136                    void        invalidateTracks(audio_stream_type_t streamType);
1137        virtual     bool        checkForNewParameters_l();
1138        virtual     status_t    dumpInternals(int fd, const Vector<String16>& args);
1139
1140    protected:
1141        virtual     mixer_state prepareTracks_l(Vector< sp<Track> > *tracksToRemove);
1142        virtual     int         getTrackName_l(audio_channel_mask_t channelMask);
1143        virtual     void        deleteTrackName_l(int name);
1144        virtual     uint32_t    idleSleepTimeUs() const;
1145        virtual     uint32_t    suspendSleepTimeUs() const;
1146        virtual     void        cacheParameters_l();
1147
1148        // threadLoop snippets
1149        virtual     void        threadLoop_write();
1150        virtual     void        threadLoop_standby();
1151        virtual     void        threadLoop_mix();
1152        virtual     void        threadLoop_sleepTime();
1153        virtual     void        threadLoop_removeTracks(const Vector< sp<Track> >& tracksToRemove);
1154
1155                    AudioMixer* mAudioMixer;    // normal mixer
1156    private:
1157#ifdef SOAKER
1158                    Thread*     mSoaker;
1159#endif
1160                    // one-time initialization, no locks required
1161                    FastMixer*  mFastMixer;         // non-NULL if there is also a fast mixer
1162
1163                    // contents are not guaranteed to be consistent, no locks required
1164                    FastMixerDumpState mFastMixerDumpState;
1165
1166                    // accessible only within the threadLoop(), no locks required
1167                    //          mFastMixer->sq()    // for mutating and pushing state
1168                    int32_t     mFastMixerFutex;    // for cold idle
1169
1170    public:
1171        virtual     bool        hasFastMixer() const { return mFastMixer != NULL; }
1172        virtual     FastTrackUnderruns getFastTrackUnderruns(size_t fastIndex) const {
1173                                  ALOG_ASSERT(fastIndex < FastMixerState::kMaxFastTracks);
1174                                  return mFastMixerDumpState.mTracks[fastIndex].mUnderruns;
1175                                }
1176    };
1177
1178    class DirectOutputThread : public PlaybackThread {
1179    public:
1180
1181        DirectOutputThread (const sp<AudioFlinger>& audioFlinger, AudioStreamOut* output,
1182                            audio_io_handle_t id, uint32_t device);
1183        virtual                 ~DirectOutputThread();
1184
1185        // Thread virtuals
1186
1187        virtual     bool        checkForNewParameters_l();
1188
1189    protected:
1190        virtual     int         getTrackName_l(audio_channel_mask_t channelMask);
1191        virtual     void        deleteTrackName_l(int name);
1192        virtual     uint32_t    activeSleepTimeUs() const;
1193        virtual     uint32_t    idleSleepTimeUs() const;
1194        virtual     uint32_t    suspendSleepTimeUs() const;
1195        virtual     void        cacheParameters_l();
1196
1197        // threadLoop snippets
1198        virtual     mixer_state prepareTracks_l(Vector< sp<Track> > *tracksToRemove);
1199        virtual     void        threadLoop_mix();
1200        virtual     void        threadLoop_sleepTime();
1201
1202        // volumes last sent to audio HAL with stream->set_volume()
1203        // FIXME use standard representation and names
1204        float mLeftVolFloat;
1205        float mRightVolFloat;
1206        uint16_t mLeftVolShort;
1207        uint16_t mRightVolShort;
1208
1209        // FIXME rename these former local variables of threadLoop to standard names
1210        // next 3 were local to the while !exitingPending loop
1211        bool rampVolume;
1212        uint16_t leftVol;
1213        uint16_t rightVol;
1214
1215private:
1216        // prepareTracks_l() tells threadLoop_mix() the name of the single active track
1217        sp<Track>               mActiveTrack;
1218    public:
1219        virtual     bool        hasFastMixer() const { return false; }
1220    };
1221
1222    class DuplicatingThread : public MixerThread {
1223    public:
1224        DuplicatingThread (const sp<AudioFlinger>& audioFlinger, MixerThread* mainThread,
1225                           audio_io_handle_t id);
1226        virtual                 ~DuplicatingThread();
1227
1228        // Thread virtuals
1229                    void        addOutputTrack(MixerThread* thread);
1230                    void        removeOutputTrack(MixerThread* thread);
1231                    uint32_t    waitTimeMs() const { return mWaitTimeMs; }
1232    protected:
1233        virtual     uint32_t    activeSleepTimeUs() const;
1234
1235    private:
1236                    bool        outputsReady(const SortedVector< sp<OutputTrack> > &outputTracks);
1237    protected:
1238        // threadLoop snippets
1239        virtual     void        threadLoop_mix();
1240        virtual     void        threadLoop_sleepTime();
1241        virtual     void        threadLoop_write();
1242        virtual     void        threadLoop_standby();
1243        virtual     void        cacheParameters_l();
1244
1245    private:
1246        // called from threadLoop, addOutputTrack, removeOutputTrack
1247        virtual     void        updateWaitTime_l();
1248    protected:
1249        virtual     void        saveOutputTracks();
1250        virtual     void        clearOutputTracks();
1251    private:
1252
1253                    uint32_t    mWaitTimeMs;
1254        SortedVector < sp<OutputTrack> >  outputTracks;
1255        SortedVector < sp<OutputTrack> >  mOutputTracks;
1256    public:
1257        virtual     bool        hasFastMixer() const { return false; }
1258    };
1259
1260              PlaybackThread *checkPlaybackThread_l(audio_io_handle_t output) const;
1261              MixerThread *checkMixerThread_l(audio_io_handle_t output) const;
1262              RecordThread *checkRecordThread_l(audio_io_handle_t input) const;
1263              // no range check, AudioFlinger::mLock held
1264              bool streamMute_l(audio_stream_type_t stream) const
1265                                { return mStreamTypes[stream].mute; }
1266              // no range check, doesn't check per-thread stream volume, AudioFlinger::mLock held
1267              float streamVolume_l(audio_stream_type_t stream) const
1268                                { return mStreamTypes[stream].volume; }
1269              void audioConfigChanged_l(int event, audio_io_handle_t ioHandle, const void *param2);
1270
1271              // allocate an audio_io_handle_t, session ID, or effect ID
1272              uint32_t nextUniqueId();
1273
1274              status_t moveEffectChain_l(int sessionId,
1275                                     PlaybackThread *srcThread,
1276                                     PlaybackThread *dstThread,
1277                                     bool reRegister);
1278              // return thread associated with primary hardware device, or NULL
1279              PlaybackThread *primaryPlaybackThread_l() const;
1280              uint32_t primaryOutputDevice_l() const;
1281
1282    // server side of the client's IAudioTrack
1283    class TrackHandle : public android::BnAudioTrack {
1284    public:
1285                            TrackHandle(const sp<PlaybackThread::Track>& track);
1286        virtual             ~TrackHandle();
1287        virtual sp<IMemory> getCblk() const;
1288        virtual status_t    start();
1289        virtual void        stop();
1290        virtual void        flush();
1291        virtual void        mute(bool);
1292        virtual void        pause();
1293        virtual status_t    attachAuxEffect(int effectId);
1294        virtual status_t    allocateTimedBuffer(size_t size,
1295                                                sp<IMemory>* buffer);
1296        virtual status_t    queueTimedBuffer(const sp<IMemory>& buffer,
1297                                             int64_t pts);
1298        virtual status_t    setMediaTimeTransform(const LinearTransform& xform,
1299                                                  int target);
1300        virtual status_t onTransact(
1301            uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags);
1302    private:
1303        const sp<PlaybackThread::Track> mTrack;
1304    };
1305
1306                void        removeClient_l(pid_t pid);
1307                void        removeNotificationClient(pid_t pid);
1308
1309
1310    // record thread
1311    class RecordThread : public ThreadBase, public AudioBufferProvider
1312    {
1313    public:
1314
1315        // record track
1316        class RecordTrack : public TrackBase {
1317        public:
1318                                RecordTrack(RecordThread *thread,
1319                                        const sp<Client>& client,
1320                                        uint32_t sampleRate,
1321                                        audio_format_t format,
1322                                        uint32_t channelMask,
1323                                        int frameCount,
1324                                        int sessionId);
1325            virtual             ~RecordTrack();
1326
1327            virtual status_t    start(AudioSystem::sync_event_t event = AudioSystem::SYNC_EVENT_NONE,
1328                                     int triggerSession = 0);
1329            virtual void        stop();
1330
1331                    bool        overflow() { bool tmp = mOverflow; mOverflow = false; return tmp; }
1332                    bool        setOverflow() { bool tmp = mOverflow; mOverflow = true; return tmp; }
1333
1334                    void        dump(char* buffer, size_t size);
1335
1336        private:
1337            friend class AudioFlinger;  // for mState
1338
1339                                RecordTrack(const RecordTrack&);
1340                                RecordTrack& operator = (const RecordTrack&);
1341
1342            // AudioBufferProvider interface
1343            virtual status_t getNextBuffer(AudioBufferProvider::Buffer* buffer, int64_t pts = kInvalidPTS);
1344            // releaseBuffer() not overridden
1345
1346            bool                mOverflow;
1347        };
1348
1349
1350                RecordThread(const sp<AudioFlinger>& audioFlinger,
1351                        AudioStreamIn *input,
1352                        uint32_t sampleRate,
1353                        uint32_t channels,
1354                        audio_io_handle_t id,
1355                        uint32_t device);
1356                virtual     ~RecordThread();
1357
1358        // Thread
1359        virtual bool        threadLoop();
1360        virtual status_t    readyToRun();
1361
1362        // RefBase
1363        virtual void        onFirstRef();
1364
1365        virtual status_t    initCheck() const { return (mInput == NULL) ? NO_INIT : NO_ERROR; }
1366                sp<AudioFlinger::RecordThread::RecordTrack>  createRecordTrack_l(
1367                        const sp<AudioFlinger::Client>& client,
1368                        uint32_t sampleRate,
1369                        audio_format_t format,
1370                        int channelMask,
1371                        int frameCount,
1372                        int sessionId,
1373                        status_t *status);
1374
1375                status_t    start(RecordTrack* recordTrack,
1376                                  AudioSystem::sync_event_t event,
1377                                  int triggerSession);
1378                void        stop(RecordTrack* recordTrack);
1379                status_t    dump(int fd, const Vector<String16>& args);
1380                AudioStreamIn* getInput() const;
1381                AudioStreamIn* clearInput();
1382                virtual audio_stream_t* stream() const;
1383
1384        // AudioBufferProvider interface
1385        virtual status_t    getNextBuffer(AudioBufferProvider::Buffer* buffer, int64_t pts);
1386        virtual void        releaseBuffer(AudioBufferProvider::Buffer* buffer);
1387
1388        virtual bool        checkForNewParameters_l();
1389        virtual String8     getParameters(const String8& keys);
1390        virtual void        audioConfigChanged_l(int event, int param = 0);
1391                void        readInputParameters();
1392        virtual unsigned int  getInputFramesLost();
1393
1394        virtual status_t addEffectChain_l(const sp<EffectChain>& chain);
1395        virtual size_t removeEffectChain_l(const sp<EffectChain>& chain);
1396        virtual uint32_t hasAudioSession(int sessionId);
1397                RecordTrack* track();
1398
1399        virtual status_t setSyncEvent(const sp<SyncEvent>& event);
1400        virtual bool     isValidSyncEvent(const sp<SyncEvent>& event);
1401
1402        static void syncStartEventCallback(const wp<SyncEvent>& event);
1403               void handleSyncStartEvent(const sp<SyncEvent>& event);
1404
1405    private:
1406                void clearSyncStartEvent();
1407
1408                RecordThread();
1409                AudioStreamIn                       *mInput;
1410                RecordTrack*                        mTrack;
1411                sp<RecordTrack>                     mActiveTrack;
1412                Condition                           mStartStopCond;
1413                AudioResampler                      *mResampler;
1414                int32_t                             *mRsmpOutBuffer;
1415                int16_t                             *mRsmpInBuffer;
1416                size_t                              mRsmpInIndex;
1417                size_t                              mInputBytes;
1418                const int                           mReqChannelCount;
1419                const uint32_t                      mReqSampleRate;
1420                ssize_t                             mBytesRead;
1421                // sync event triggering actual audio capture. Frames read before this event will
1422                // be dropped and therefore not read by the application.
1423                sp<SyncEvent>                       mSyncStartEvent;
1424                // number of captured frames to drop after the start sync event has been received.
1425                // when < 0, maximum frames to drop before starting capture even if sync event is
1426                // not received
1427                ssize_t                             mFramestoDrop;
1428    };
1429
1430    // server side of the client's IAudioRecord
1431    class RecordHandle : public android::BnAudioRecord {
1432    public:
1433        RecordHandle(const sp<RecordThread::RecordTrack>& recordTrack);
1434        virtual             ~RecordHandle();
1435        virtual sp<IMemory> getCblk() const;
1436        virtual status_t    start(int event, int triggerSession);
1437        virtual void        stop();
1438        virtual status_t onTransact(
1439            uint32_t code, const Parcel& data, Parcel* reply, uint32_t flags);
1440    private:
1441        const sp<RecordThread::RecordTrack> mRecordTrack;
1442    };
1443
1444    //--- Audio Effect Management
1445
1446    // EffectModule and EffectChain classes both have their own mutex to protect
1447    // state changes or resource modifications. Always respect the following order
1448    // if multiple mutexes must be acquired to avoid cross deadlock:
1449    // AudioFlinger -> ThreadBase -> EffectChain -> EffectModule
1450
1451    // The EffectModule class is a wrapper object controlling the effect engine implementation
1452    // in the effect library. It prevents concurrent calls to process() and command() functions
1453    // from different client threads. It keeps a list of EffectHandle objects corresponding
1454    // to all client applications using this effect and notifies applications of effect state,
1455    // control or parameter changes. It manages the activation state machine to send appropriate
1456    // reset, enable, disable commands to effect engine and provide volume
1457    // ramping when effects are activated/deactivated.
1458    // When controlling an auxiliary effect, the EffectModule also provides an input buffer used by
1459    // the attached track(s) to accumulate their auxiliary channel.
1460    class EffectModule: public RefBase {
1461    public:
1462        EffectModule(ThreadBase *thread,
1463                        const wp<AudioFlinger::EffectChain>& chain,
1464                        effect_descriptor_t *desc,
1465                        int id,
1466                        int sessionId);
1467        virtual ~EffectModule();
1468
1469        enum effect_state {
1470            IDLE,
1471            RESTART,
1472            STARTING,
1473            ACTIVE,
1474            STOPPING,
1475            STOPPED,
1476            DESTROYED
1477        };
1478
1479        int         id() const { return mId; }
1480        void process();
1481        void updateState();
1482        status_t command(uint32_t cmdCode,
1483                         uint32_t cmdSize,
1484                         void *pCmdData,
1485                         uint32_t *replySize,
1486                         void *pReplyData);
1487
1488        void reset_l();
1489        status_t configure();
1490        status_t init();
1491        effect_state state() const {
1492            return mState;
1493        }
1494        uint32_t status() {
1495            return mStatus;
1496        }
1497        int sessionId() const {
1498            return mSessionId;
1499        }
1500        status_t    setEnabled(bool enabled);
1501        bool isEnabled() const;
1502        bool isProcessEnabled() const;
1503
1504        void        setInBuffer(int16_t *buffer) { mConfig.inputCfg.buffer.s16 = buffer; }
1505        int16_t     *inBuffer() { return mConfig.inputCfg.buffer.s16; }
1506        void        setOutBuffer(int16_t *buffer) { mConfig.outputCfg.buffer.s16 = buffer; }
1507        int16_t     *outBuffer() { return mConfig.outputCfg.buffer.s16; }
1508        void        setChain(const wp<EffectChain>& chain) { mChain = chain; }
1509        void        setThread(const wp<ThreadBase>& thread) { mThread = thread; }
1510        const wp<ThreadBase>& thread() { return mThread; }
1511
1512        status_t addHandle(const sp<EffectHandle>& handle);
1513        void disconnect(const wp<EffectHandle>& handle, bool unpinIfLast);
1514        size_t removeHandle (const wp<EffectHandle>& handle);
1515
1516        effect_descriptor_t& desc() { return mDescriptor; }
1517        wp<EffectChain>&     chain() { return mChain; }
1518
1519        status_t         setDevice(uint32_t device);
1520        status_t         setVolume(uint32_t *left, uint32_t *right, bool controller);
1521        status_t         setMode(audio_mode_t mode);
1522        status_t         start();
1523        status_t         stop();
1524        void             setSuspended(bool suspended);
1525        bool             suspended() const;
1526
1527        sp<EffectHandle> controlHandle();
1528
1529        bool             isPinned() const { return mPinned; }
1530        void             unPin() { mPinned = false; }
1531
1532        status_t         dump(int fd, const Vector<String16>& args);
1533
1534    protected:
1535        friend class AudioFlinger;      // for mHandles
1536        bool                mPinned;
1537
1538        // Maximum time allocated to effect engines to complete the turn off sequence
1539        static const uint32_t MAX_DISABLE_TIME_MS = 10000;
1540
1541        EffectModule(const EffectModule&);
1542        EffectModule& operator = (const EffectModule&);
1543
1544        status_t start_l();
1545        status_t stop_l();
1546
1547mutable Mutex               mLock;      // mutex for process, commands and handles list protection
1548        wp<ThreadBase>      mThread;    // parent thread
1549        wp<EffectChain>     mChain;     // parent effect chain
1550        int                 mId;        // this instance unique ID
1551        int                 mSessionId; // audio session ID
1552        effect_descriptor_t mDescriptor;// effect descriptor received from effect engine
1553        effect_config_t     mConfig;    // input and output audio configuration
1554        effect_handle_t  mEffectInterface; // Effect module C API
1555        status_t            mStatus;    // initialization status
1556        effect_state        mState;     // current activation state
1557        Vector< wp<EffectHandle> > mHandles;    // list of client handles
1558                    // First handle in mHandles has highest priority and controls the effect module
1559        uint32_t mMaxDisableWaitCnt;    // maximum grace period before forcing an effect off after
1560                                        // sending disable command.
1561        uint32_t mDisableWaitCnt;       // current process() calls count during disable period.
1562        bool     mSuspended;            // effect is suspended: temporarily disabled by framework
1563    };
1564
1565    // The EffectHandle class implements the IEffect interface. It provides resources
1566    // to receive parameter updates, keeps track of effect control
1567    // ownership and state and has a pointer to the EffectModule object it is controlling.
1568    // There is one EffectHandle object for each application controlling (or using)
1569    // an effect module.
1570    // The EffectHandle is obtained by calling AudioFlinger::createEffect().
1571    class EffectHandle: public android::BnEffect {
1572    public:
1573
1574        EffectHandle(const sp<EffectModule>& effect,
1575                const sp<AudioFlinger::Client>& client,
1576                const sp<IEffectClient>& effectClient,
1577                int32_t priority);
1578        virtual ~EffectHandle();
1579
1580        // IEffect
1581        virtual status_t enable();
1582        virtual status_t disable();
1583        virtual status_t command(uint32_t cmdCode,
1584                                 uint32_t cmdSize,
1585                                 void *pCmdData,
1586                                 uint32_t *replySize,
1587                                 void *pReplyData);
1588        virtual void disconnect();
1589    private:
1590                void disconnect(bool unpinIfLast);
1591    public:
1592        virtual sp<IMemory> getCblk() const { return mCblkMemory; }
1593        virtual status_t onTransact(uint32_t code, const Parcel& data,
1594                Parcel* reply, uint32_t flags);
1595
1596
1597        // Give or take control of effect module
1598        // - hasControl: true if control is given, false if removed
1599        // - signal: true client app should be signaled of change, false otherwise
1600        // - enabled: state of the effect when control is passed
1601        void setControl(bool hasControl, bool signal, bool enabled);
1602        void commandExecuted(uint32_t cmdCode,
1603                             uint32_t cmdSize,
1604                             void *pCmdData,
1605                             uint32_t replySize,
1606                             void *pReplyData);
1607        void setEnabled(bool enabled);
1608        bool enabled() const { return mEnabled; }
1609
1610        // Getters
1611        int id() const { return mEffect->id(); }
1612        int priority() const { return mPriority; }
1613        bool hasControl() const { return mHasControl; }
1614        sp<EffectModule> effect() const { return mEffect; }
1615
1616        void dump(char* buffer, size_t size);
1617
1618    protected:
1619        friend class AudioFlinger;          // for mEffect, mHasControl, mEnabled
1620        EffectHandle(const EffectHandle&);
1621        EffectHandle& operator =(const EffectHandle&);
1622
1623        sp<EffectModule> mEffect;           // pointer to controlled EffectModule
1624        sp<IEffectClient> mEffectClient;    // callback interface for client notifications
1625        /*const*/ sp<Client> mClient;       // client for shared memory allocation, see disconnect()
1626        sp<IMemory>         mCblkMemory;    // shared memory for control block
1627        effect_param_cblk_t* mCblk;         // control block for deferred parameter setting via shared memory
1628        uint8_t*            mBuffer;        // pointer to parameter area in shared memory
1629        int mPriority;                      // client application priority to control the effect
1630        bool mHasControl;                   // true if this handle is controlling the effect
1631        bool mEnabled;                      // cached enable state: needed when the effect is
1632                                            // restored after being suspended
1633    };
1634
1635    // the EffectChain class represents a group of effects associated to one audio session.
1636    // There can be any number of EffectChain objects per output mixer thread (PlaybackThread).
1637    // The EffecChain with session ID 0 contains global effects applied to the output mix.
1638    // Effects in this chain can be insert or auxiliary. Effects in other chains (attached to tracks)
1639    // are insert only. The EffectChain maintains an ordered list of effect module, the order corresponding
1640    // in the effect process order. When attached to a track (session ID != 0), it also provide it's own
1641    // input buffer used by the track as accumulation buffer.
1642    class EffectChain: public RefBase {
1643    public:
1644        EffectChain(const wp<ThreadBase>& wThread, int sessionId);
1645        EffectChain(ThreadBase *thread, int sessionId);
1646        virtual ~EffectChain();
1647
1648        // special key used for an entry in mSuspendedEffects keyed vector
1649        // corresponding to a suspend all request.
1650        static const int        kKeyForSuspendAll = 0;
1651
1652        // minimum duration during which we force calling effect process when last track on
1653        // a session is stopped or removed to allow effect tail to be rendered
1654        static const int        kProcessTailDurationMs = 1000;
1655
1656        void process_l();
1657
1658        void lock() {
1659            mLock.lock();
1660        }
1661        void unlock() {
1662            mLock.unlock();
1663        }
1664
1665        status_t addEffect_l(const sp<EffectModule>& handle);
1666        size_t removeEffect_l(const sp<EffectModule>& handle);
1667
1668        int sessionId() const { return mSessionId; }
1669        void setSessionId(int sessionId) { mSessionId = sessionId; }
1670
1671        sp<EffectModule> getEffectFromDesc_l(effect_descriptor_t *descriptor);
1672        sp<EffectModule> getEffectFromId_l(int id);
1673        sp<EffectModule> getEffectFromType_l(const effect_uuid_t *type);
1674        bool setVolume_l(uint32_t *left, uint32_t *right);
1675        void setDevice_l(uint32_t device);
1676        void setMode_l(audio_mode_t mode);
1677
1678        void setInBuffer(int16_t *buffer, bool ownsBuffer = false) {
1679            mInBuffer = buffer;
1680            mOwnInBuffer = ownsBuffer;
1681        }
1682        int16_t *inBuffer() const {
1683            return mInBuffer;
1684        }
1685        void setOutBuffer(int16_t *buffer) {
1686            mOutBuffer = buffer;
1687        }
1688        int16_t *outBuffer() const {
1689            return mOutBuffer;
1690        }
1691
1692        void incTrackCnt() { android_atomic_inc(&mTrackCnt); }
1693        void decTrackCnt() { android_atomic_dec(&mTrackCnt); }
1694        int32_t trackCnt() const { return mTrackCnt;}
1695
1696        void incActiveTrackCnt() { android_atomic_inc(&mActiveTrackCnt);
1697                                   mTailBufferCount = mMaxTailBuffers; }
1698        void decActiveTrackCnt() { android_atomic_dec(&mActiveTrackCnt); }
1699        int32_t activeTrackCnt() const { return mActiveTrackCnt;}
1700
1701        uint32_t strategy() const { return mStrategy; }
1702        void setStrategy(uint32_t strategy)
1703                { mStrategy = strategy; }
1704
1705        // suspend effect of the given type
1706        void setEffectSuspended_l(const effect_uuid_t *type,
1707                                  bool suspend);
1708        // suspend all eligible effects
1709        void setEffectSuspendedAll_l(bool suspend);
1710        // check if effects should be suspend or restored when a given effect is enable or disabled
1711        void checkSuspendOnEffectEnabled(const sp<EffectModule>& effect,
1712                                              bool enabled);
1713
1714        status_t dump(int fd, const Vector<String16>& args);
1715
1716    protected:
1717        friend class AudioFlinger;  // for mThread, mEffects
1718        EffectChain(const EffectChain&);
1719        EffectChain& operator =(const EffectChain&);
1720
1721        class SuspendedEffectDesc : public RefBase {
1722        public:
1723            SuspendedEffectDesc() : mRefCount(0) {}
1724
1725            int mRefCount;
1726            effect_uuid_t mType;
1727            wp<EffectModule> mEffect;
1728        };
1729
1730        // get a list of effect modules to suspend when an effect of the type
1731        // passed is enabled.
1732        void                       getSuspendEligibleEffects(Vector< sp<EffectModule> > &effects);
1733
1734        // get an effect module if it is currently enable
1735        sp<EffectModule> getEffectIfEnabled(const effect_uuid_t *type);
1736        // true if the effect whose descriptor is passed can be suspended
1737        // OEMs can modify the rules implemented in this method to exclude specific effect
1738        // types or implementations from the suspend/restore mechanism.
1739        bool isEffectEligibleForSuspend(const effect_descriptor_t& desc);
1740
1741        wp<ThreadBase> mThread;     // parent mixer thread
1742        Mutex mLock;                // mutex protecting effect list
1743        Vector< sp<EffectModule> > mEffects; // list of effect modules
1744        int mSessionId;             // audio session ID
1745        int16_t *mInBuffer;         // chain input buffer
1746        int16_t *mOutBuffer;        // chain output buffer
1747        volatile int32_t mActiveTrackCnt;  // number of active tracks connected
1748        volatile int32_t mTrackCnt;        // number of tracks connected
1749        int32_t mTailBufferCount;   // current effect tail buffer count
1750        int32_t mMaxTailBuffers;    // maximum effect tail buffers
1751        bool mOwnInBuffer;          // true if the chain owns its input buffer
1752        int mVolumeCtrlIdx;         // index of insert effect having control over volume
1753        uint32_t mLeftVolume;       // previous volume on left channel
1754        uint32_t mRightVolume;      // previous volume on right channel
1755        uint32_t mNewLeftVolume;       // new volume on left channel
1756        uint32_t mNewRightVolume;      // new volume on right channel
1757        uint32_t mStrategy; // strategy for this effect chain
1758        // mSuspendedEffects lists all effects currently suspended in the chain.
1759        // Use effect type UUID timelow field as key. There is no real risk of identical
1760        // timeLow fields among effect type UUIDs.
1761        // Updated by updateSuspendedSessions_l() only.
1762        KeyedVector< int, sp<SuspendedEffectDesc> > mSuspendedEffects;
1763    };
1764
1765    // AudioStreamOut and AudioStreamIn are immutable, so their fields are const.
1766    // For emphasis, we could also make all pointers to them be "const *",
1767    // but that would clutter the code unnecessarily.
1768
1769    struct AudioStreamOut {
1770        audio_hw_device_t*  const hwDev;
1771        audio_stream_out_t* const stream;
1772
1773        AudioStreamOut(audio_hw_device_t *dev, audio_stream_out_t *out) :
1774            hwDev(dev), stream(out) {}
1775    };
1776
1777    struct AudioStreamIn {
1778        audio_hw_device_t* const hwDev;
1779        audio_stream_in_t* const stream;
1780
1781        AudioStreamIn(audio_hw_device_t *dev, audio_stream_in_t *in) :
1782            hwDev(dev), stream(in) {}
1783    };
1784
1785    // for mAudioSessionRefs only
1786    struct AudioSessionRef {
1787        AudioSessionRef(int sessionid, pid_t pid) :
1788            mSessionid(sessionid), mPid(pid), mCnt(1) {}
1789        const int   mSessionid;
1790        const pid_t mPid;
1791        int         mCnt;
1792    };
1793
1794    enum master_volume_support {
1795        // MVS_NONE:
1796        // Audio HAL has no support for master volume, either setting or
1797        // getting.  All master volume control must be implemented in SW by the
1798        // AudioFlinger mixing core.
1799        MVS_NONE,
1800
1801        // MVS_SETONLY:
1802        // Audio HAL has support for setting master volume, but not for getting
1803        // master volume (original HAL design did not include a getter).
1804        // AudioFlinger needs to keep track of the last set master volume in
1805        // addition to needing to set an initial, default, master volume at HAL
1806        // load time.
1807        MVS_SETONLY,
1808
1809        // MVS_FULL:
1810        // Audio HAL has support both for setting and getting master volume.
1811        // AudioFlinger should send all set and get master volume requests
1812        // directly to the HAL.
1813        MVS_FULL,
1814    };
1815
1816    class AudioHwDevice {
1817    public:
1818        AudioHwDevice(const char *moduleName, audio_hw_device_t *hwDevice) :
1819            mModuleName(strdup(moduleName)), mHwDevice(hwDevice){}
1820        ~AudioHwDevice() { free((void *)mModuleName); }
1821
1822        const char *moduleName() const { return mModuleName; }
1823        audio_hw_device_t *hwDevice() const { return mHwDevice; }
1824    private:
1825        const char * const mModuleName;
1826        audio_hw_device_t * const mHwDevice;
1827    };
1828
1829    mutable     Mutex                               mLock;
1830
1831                DefaultKeyedVector< pid_t, wp<Client> >     mClients;   // see ~Client()
1832
1833                mutable     Mutex                   mHardwareLock;
1834                // NOTE: If both mLock and mHardwareLock mutexes must be held,
1835                // always take mLock before mHardwareLock
1836
1837                // These two fields are immutable after onFirstRef(), so no lock needed to access
1838                audio_hw_device_t*                  mPrimaryHardwareDev; // mAudioHwDevs[0] or NULL
1839                DefaultKeyedVector<audio_module_handle_t, AudioHwDevice*>  mAudioHwDevs;
1840
1841    // for dump, indicates which hardware operation is currently in progress (but not stream ops)
1842    enum hardware_call_state {
1843        AUDIO_HW_IDLE = 0,              // no operation in progress
1844        AUDIO_HW_INIT,                  // init_check
1845        AUDIO_HW_OUTPUT_OPEN,           // open_output_stream
1846        AUDIO_HW_OUTPUT_CLOSE,          // unused
1847        AUDIO_HW_INPUT_OPEN,            // unused
1848        AUDIO_HW_INPUT_CLOSE,           // unused
1849        AUDIO_HW_STANDBY,               // unused
1850        AUDIO_HW_SET_MASTER_VOLUME,     // set_master_volume
1851        AUDIO_HW_GET_ROUTING,           // unused
1852        AUDIO_HW_SET_ROUTING,           // unused
1853        AUDIO_HW_GET_MODE,              // unused
1854        AUDIO_HW_SET_MODE,              // set_mode
1855        AUDIO_HW_GET_MIC_MUTE,          // get_mic_mute
1856        AUDIO_HW_SET_MIC_MUTE,          // set_mic_mute
1857        AUDIO_HW_SET_VOICE_VOLUME,      // set_voice_volume
1858        AUDIO_HW_SET_PARAMETER,         // set_parameters
1859        AUDIO_HW_GET_INPUT_BUFFER_SIZE, // get_input_buffer_size
1860        AUDIO_HW_GET_MASTER_VOLUME,     // get_master_volume
1861        AUDIO_HW_GET_PARAMETER,         // get_parameters
1862    };
1863
1864    mutable     hardware_call_state                 mHardwareStatus;    // for dump only
1865
1866
1867                DefaultKeyedVector< audio_io_handle_t, sp<PlaybackThread> >  mPlaybackThreads;
1868                stream_type_t                       mStreamTypes[AUDIO_STREAM_CNT];
1869
1870                // both are protected by mLock
1871                float                               mMasterVolume;
1872                float                               mMasterVolumeSW;
1873                master_volume_support               mMasterVolumeSupportLvl;
1874                bool                                mMasterMute;
1875
1876                DefaultKeyedVector< audio_io_handle_t, sp<RecordThread> >    mRecordThreads;
1877
1878                DefaultKeyedVector< pid_t, sp<NotificationClient> >    mNotificationClients;
1879                volatile int32_t                    mNextUniqueId;  // updated by android_atomic_inc
1880                audio_mode_t                        mMode;
1881                bool                                mBtNrecIsOff;
1882
1883                // protected by mLock
1884                Vector<AudioSessionRef*> mAudioSessionRefs;
1885
1886                float       masterVolume_l() const;
1887                float       masterVolumeSW_l() const  { return mMasterVolumeSW; }
1888                bool        masterMute_l() const    { return mMasterMute; }
1889                audio_module_handle_t loadHwModule_l(const char *name);
1890
1891                Vector < sp<SyncEvent> > mPendingSyncEvents; // sync events awaiting for a session
1892                                                             // to be created
1893
1894private:
1895    sp<Client>  registerPid_l(pid_t pid);    // always returns non-0
1896
1897};
1898
1899
1900// ----------------------------------------------------------------------------
1901
1902}; // namespace android
1903
1904#endif // ANDROID_AUDIO_FLINGER_H
1905