Merge "AudioFlinger: Use audio_utils::mutex" into main am: 467a9f80

#include "PatchCommandThread.h"

// External classes

#include <audio_utils/mutex.h>

#include <audio_utils/FdToString.h>

#include <audio_utils/SimpleLog.h>

#include <media/IAudioFlinger.h>

    // ---- begin IAfClientCallback interface

    Mutex& clientMutex() const final { return mClientLock; }

    audio_utils::mutex& clientMutex() const final { return mClientMutex; }

    void removeClient_l(pid_t pid) final;

    void removeNotificationClient(pid_t pid) final;

    status_t moveAuxEffectToIo(

    // ---- begin IAfMelReporterCallback interface

    // below also used by IAfThreadCallback

    Mutex& mutex() const final { return mLock; }

    sp<IAfThreadBase> checkOutputThread_l(audio_io_handle_t ioHandle) const final REQUIRES(mLock);

    audio_utils::mutex& mutex() const final { return mMutex; }

    sp<IAfThreadBase> checkOutputThread_l(audio_io_handle_t ioHandle) const final

            REQUIRES(mutex());

    // ---- end of IAfMelReporterCallback interface

    IAfPlaybackThread* checkPlaybackThread_l(audio_io_handle_t output) const final;

    IAfRecordThread* checkRecordThread_l(audio_io_handle_t input) const final;

    IAfMmapThread* checkMmapThread_l(audio_io_handle_t io) const final;

    void lock() const final ACQUIRE(mLock) { mLock.lock(); }

    void unlock() const final RELEASE(mLock) { mLock.unlock(); }

    sp<IAfThreadBase> openInput_l(audio_module_handle_t module,

            audio_io_handle_t* input,

            audio_config_t* config,

    float masterVolume_l() const final;

    bool masterMute_l() const final;

    float getMasterBalance_l() const;

    // no range check, AudioFlinger::mLock held

    // no range check, AudioFlinger::mutex() held

    bool streamMute_l(audio_stream_type_t stream) const final { return mStreamTypes[stream].mute; }

    audio_mode_t getMode() const final { return mMode; }

    bool isLowRamDevice() const final { return mIsLowRamDevice; }

    // When a log writer is unregistered, it is done lazily so that media.log can continue to see it

    // for as long as possible.  The memory is only freed when it is needed for another log writer.

    Vector< sp<NBLog::Writer> > mUnregisteredWriters;

    Mutex               mUnregisteredWritersLock;

    audio_utils::mutex& unregisteredWritersMutex() const { return mUnregisteredWritersMutex; }

    mutable audio_utils::mutex mUnregisteredWritersMutex;

                            AudioFlinger() ANDROID_API;

    ~AudioFlinger() override;

                                                audio_devices_t deviceType);

    // incremented by 2 when screen state changes, bit 0 == 1 means "off"

    // AudioFlinger::setParameters() updates with mLock.

    // AudioFlinger::setParameters() updates with mutex().

    std::atomic_uint32_t mScreenState{};

    void dumpPermissionDenial(int fd, const Vector<String16>& args);

        bool mPendingRequests;

        // Mutex and condition variable around mPendingRequests' value

        Mutex       mMutex;

        Condition   mCond;

        audio_utils::mutex mMutex;

        audio_utils::condition_variable mCondition;

        // Duration of the sleep period after a processed request

        static const int kPostTriggerSleepPeriod = 1000000;

        int         mCnt;

    };

    mutable     Mutex                               mLock;

    mutable audio_utils::mutex mMutex;

                // protects mClients and mNotificationClients.

                // must be locked after mLock and ThreadBase::mLock if both must be locked

                // avoids acquiring AudioFlinger::mLock from inside thread loop.

                // must be locked after mutex() and ThreadBase::mutex() if both must be locked

                // avoids acquiring AudioFlinger::mutex() from inside thread loop.

    mutable Mutex mClientLock;

    mutable audio_utils::mutex mClientMutex;

                // protected by mClientLock

                // protected by mClientMutex

                DefaultKeyedVector< pid_t, wp<Client> >     mClients;   // see ~Client()

                mutable     Mutex                   mHardwareLock;

                // NOTE: If both mLock and mHardwareLock mutexes must be held,

                // always take mLock before mHardwareLock

    audio_utils::mutex& hardwareMutex() const { return mHardwareMutex; }

    mutable audio_utils::mutex mHardwareMutex;

    // NOTE: If both mMutex and mHardwareMutex mutexes must be held,

    // always take mMutex before mHardwareMutex

    std::atomic<AudioHwDevice*> mPrimaryHardwareDev = nullptr;

    DefaultKeyedVector<audio_module_handle_t, AudioHwDevice*> mAudioHwDevs{nullptr /* defValue */};

    DefaultKeyedVector<audio_io_handle_t, sp<IAfPlaybackThread>> mPlaybackThreads;

                stream_type_t                       mStreamTypes[AUDIO_STREAM_CNT];

                // member variables below are protected by mLock

                // member variables below are protected by mutex()

    float mMasterVolume = 1.f;

    bool mMasterMute = false;

    float mMasterBalance = 0.f;

                // end of variables protected by mLock

                // end of variables protected by mutex()

    DefaultKeyedVector<audio_io_handle_t, sp<IAfRecordThread>> mRecordThreads;

                // protected by mClientLock

                // protected by clientMutex()

                DefaultKeyedVector< pid_t, sp<NotificationClient> >    mNotificationClients;

                // updated by atomic_fetch_add_explicit

    std::atomic<audio_mode_t> mMode = AUDIO_MODE_INVALID;

    std::atomic<bool> mBtNrecIsOff = false;

                // protected by mLock

                // protected by mutex()

                Vector<AudioSessionRef*> mAudioSessionRefs;

                AudioHwDevice* loadHwModule_l(const char *name);

#pragma once

#include <afutils/AllocatorFactory.h>

#include <audio_utils/mutex.h>

#include <android-base/macros.h>  // DISALLOW_COPY_AND_ASSIGN

#include <utils/Mutex.h>

#include <utils/RefBase.h>        // avoid transitive dependency

// TODO(b/291318727) Move to nested namespace

class IAfClientCallback : public virtual RefBase {

public:

    virtual Mutex& clientMutex() const = 0;

    virtual audio_utils::mutex& clientMutex() const = 0;

    virtual void removeClient_l(pid_t pid) = 0;

    virtual void removeNotificationClient(pid_t pid) = 0;

    virtual status_t moveAuxEffectToIo(

        }

        mCblkMemory.clear();    // free the shared memory before releasing the heap it belongs to

        // Client destructor must run with AudioFlinger client mutex locked

        Mutex::Autolock _l2(mClient->afClientCallback()->clientMutex());

        audio_utils::lock_guard _l2(mClient->afClientCallback()->clientMutex());

        mClient.clear();

    }

}

            audio_devices_t deviceType,

            const String8& address,

            audio_output_flags_t flags) = 0;

    virtual void lock() const = 0;

    virtual void unlock() const = 0;

    virtual audio_utils::mutex& mutex() const = 0;

    virtual const DefaultKeyedVector<audio_module_handle_t, AudioHwDevice*>&

            getAudioHwDevs_l() const = 0;

    virtual audio_unique_id_t nextUniqueId(audio_unique_id_use_t use) = 0;