Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 1 | /* |
| 2 | * Copyright (C) 2023 The Android Open Source Project |
| 3 | * |
| 4 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 5 | * you may not use this file except in compliance with the License. |
| 6 | * You may obtain a copy of the License at |
| 7 | * |
| 8 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 9 | * |
| 10 | * Unless required by applicable law or agreed to in writing, software |
| 11 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 12 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 13 | * See the License for the specific language governing permissions and |
| 14 | * limitations under the License. |
| 15 | */ |
| 16 | |
| 17 | #pragma once |
| 18 | |
Andy Hung | c6f227f | 2023-07-18 18:31:50 -0700 | [diff] [blame] | 19 | #include <android/media/IAudioTrackCallback.h> |
| 20 | #include <android/media/IEffectClient.h> |
| 21 | #include <audiomanager/IAudioManager.h> |
| 22 | #include <audio_utils/MelProcessor.h> |
| 23 | #include <binder/MemoryDealer.h> |
| 24 | #include <datapath/AudioStreamIn.h> |
| 25 | #include <datapath/AudioStreamOut.h> |
| 26 | #include <datapath/VolumeInterface.h> |
| 27 | #include <fastpath/FastMixerDumpState.h> |
| 28 | #include <media/DeviceDescriptorBase.h> |
| 29 | #include <media/MmapStreamInterface.h> |
| 30 | #include <media/audiohal/StreamHalInterface.h> |
| 31 | #include <media/nblog/NBLog.h> |
| 32 | #include <timing/SyncEvent.h> |
| 33 | #include <utils/Mutex.h> |
| 34 | #include <utils/RefBase.h> |
| 35 | #include <vibrator/ExternalVibration.h> |
| 36 | |
| 37 | #include <optional> |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 38 | |
| 39 | namespace android { |
| 40 | |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 41 | class IAfDirectOutputThread; |
| 42 | class IAfDuplicatingThread; |
Andy Hung | 7aa7d10 | 2023-07-07 15:58:48 -0700 | [diff] [blame] | 43 | class IAfMmapCaptureThread; |
| 44 | class IAfMmapPlaybackThread; |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 45 | class IAfPlaybackThread; |
| 46 | class IAfRecordThread; |
Andy Hung | c6f227f | 2023-07-18 18:31:50 -0700 | [diff] [blame] | 47 | |
| 48 | class IAfEffectChain; |
| 49 | class IAfEffectHandle; |
| 50 | class IAfEffectModule; |
| 51 | class IAfPatchPanel; |
| 52 | class IAfPatchRecord; |
| 53 | class IAfPatchTrack; |
| 54 | class IAfRecordTrack; |
| 55 | class IAfTrack; |
| 56 | class IAfTrackBase; |
| 57 | class Client; |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 58 | class MelReporter; |
| 59 | |
| 60 | // Note this is exposed through IAfThreadBase::afThreadCallback() |
| 61 | // and hence may be used by the Effect / Track framework. |
| 62 | class IAfThreadCallback : public virtual RefBase { |
| 63 | public: |
| 64 | virtual Mutex& mutex() const = 0; |
| 65 | virtual bool isNonOffloadableGlobalEffectEnabled_l() const = 0; // Tracks |
| 66 | virtual audio_unique_id_t nextUniqueId(audio_unique_id_use_t use) = 0; |
| 67 | virtual bool btNrecIsOff() const = 0; |
| 68 | virtual float masterVolume_l() const = 0; |
| 69 | virtual bool masterMute_l() const = 0; |
| 70 | virtual float getMasterBalance_l() const = 0; |
| 71 | virtual bool streamMute_l(audio_stream_type_t stream) const = 0; |
| 72 | virtual audio_mode_t getMode() const = 0; |
| 73 | virtual bool isLowRamDevice() const = 0; |
| 74 | virtual bool isAudioPolicyReady() const = 0; // Effects |
Andy Hung | 1d2d2aea | 2023-07-19 16:22:58 -0700 | [diff] [blame] | 75 | virtual uint32_t getScreenState() const = 0; |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 76 | virtual std::optional<media::AudioVibratorInfo> getDefaultVibratorInfo_l() const = 0; |
| 77 | virtual const sp<IAfPatchPanel>& getPatchPanel() const = 0; |
| 78 | virtual const sp<MelReporter>& getMelReporter() const = 0; |
| 79 | virtual const sp<EffectsFactoryHalInterface>& getEffectsFactoryHal() const = 0; |
| 80 | virtual sp<IAudioManager> getOrCreateAudioManager() = 0; // Tracks |
| 81 | |
| 82 | virtual bool updateOrphanEffectChains(const sp<IAfEffectModule>& effect) = 0; |
| 83 | virtual status_t moveEffectChain_l(audio_session_t sessionId, |
| 84 | IAfPlaybackThread* srcThread, IAfPlaybackThread* dstThread) = 0; |
| 85 | |
| 86 | virtual void requestLogMerge() = 0; |
| 87 | virtual sp<NBLog::Writer> newWriter_l(size_t size, const char *name) = 0; |
| 88 | virtual void unregisterWriter(const sp<NBLog::Writer>& writer) = 0; |
| 89 | |
| 90 | virtual sp<audioflinger::SyncEvent> createSyncEvent(AudioSystem::sync_event_t type, |
| 91 | audio_session_t triggerSession, |
| 92 | audio_session_t listenerSession, |
| 93 | const audioflinger::SyncEventCallback& callBack, |
| 94 | const wp<IAfTrackBase>& cookie) = 0; |
| 95 | |
| 96 | virtual void ioConfigChanged(audio_io_config_event_t event, |
| 97 | const sp<AudioIoDescriptor>& ioDesc, |
| 98 | pid_t pid = 0) = 0; |
| 99 | virtual void onNonOffloadableGlobalEffectEnable() = 0; |
| 100 | virtual void onSupportedLatencyModesChanged( |
| 101 | audio_io_handle_t output, const std::vector<audio_latency_mode_t>& modes) = 0; |
| 102 | }; |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 103 | |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 104 | class IAfThreadBase : public virtual RefBase { |
| 105 | public: |
| 106 | enum type_t { |
| 107 | MIXER, // Thread class is MixerThread |
| 108 | DIRECT, // Thread class is DirectOutputThread |
| 109 | DUPLICATING, // Thread class is DuplicatingThread |
| 110 | RECORD, // Thread class is RecordThread |
| 111 | OFFLOAD, // Thread class is OffloadThread |
| 112 | MMAP_PLAYBACK, // Thread class for MMAP playback stream |
| 113 | MMAP_CAPTURE, // Thread class for MMAP capture stream |
| 114 | SPATIALIZER, // |
| 115 | BIT_PERFECT, // Thread class for BitPerfectThread |
| 116 | // When adding a value, also update IAfThreadBase::threadTypeToString() |
| 117 | }; |
| 118 | |
| 119 | static const char* threadTypeToString(type_t type); |
Andy Hung | 81994d6 | 2023-07-20 21:44:14 -0700 | [diff] [blame^] | 120 | static bool isValidPcmSinkChannelMask(audio_channel_mask_t channelMask); |
| 121 | static bool isValidPcmSinkFormat(audio_format_t format); |
| 122 | |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 123 | virtual status_t readyToRun() = 0; |
| 124 | virtual void clearPowerManager() = 0; |
| 125 | virtual status_t initCheck() const = 0; |
| 126 | virtual type_t type() const = 0; |
| 127 | virtual bool isDuplicating() const = 0; |
| 128 | virtual audio_io_handle_t id() const = 0; |
| 129 | virtual uint32_t sampleRate() const = 0; |
| 130 | virtual audio_channel_mask_t channelMask() const = 0; |
| 131 | virtual audio_channel_mask_t mixerChannelMask() const = 0; |
| 132 | virtual audio_format_t format() const = 0; |
| 133 | virtual uint32_t channelCount() const = 0; |
| 134 | |
| 135 | // Called by AudioFlinger::frameCount(audio_io_handle_t output) and effects, |
| 136 | // and returns the [normal mix] buffer's frame count. |
| 137 | virtual size_t frameCount() const = 0; |
| 138 | virtual audio_channel_mask_t hapticChannelMask() const = 0; |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 139 | virtual uint32_t hapticChannelCount() const = 0; |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 140 | virtual uint32_t latency_l() const = 0; |
| 141 | virtual void setVolumeForOutput_l(float left, float right) const = 0; |
| 142 | |
| 143 | // Return's the HAL's frame count i.e. fast mixer buffer size. |
| 144 | virtual size_t frameCountHAL() const = 0; |
| 145 | virtual size_t frameSize() const = 0; |
| 146 | // Should be "virtual status_t requestExitAndWait()" and override same |
| 147 | // method in Thread, but Thread::requestExitAndWait() is not yet virtual. |
| 148 | virtual void exit() = 0; |
| 149 | virtual bool checkForNewParameter_l(const String8& keyValuePair, status_t& status) = 0; |
| 150 | virtual status_t setParameters(const String8& keyValuePairs) = 0; |
| 151 | virtual String8 getParameters(const String8& keys) = 0; |
| 152 | virtual void ioConfigChanged( |
| 153 | audio_io_config_event_t event, pid_t pid = 0, |
| 154 | audio_port_handle_t portId = AUDIO_PORT_HANDLE_NONE) = 0; |
| 155 | |
| 156 | // sendConfigEvent_l() must be called with ThreadBase::mLock held |
| 157 | // Can temporarily release the lock if waiting for a reply from |
| 158 | // processConfigEvents_l(). |
| 159 | // status_t sendConfigEvent_l(sp<ConfigEvent>& event); |
| 160 | virtual void sendIoConfigEvent( |
| 161 | audio_io_config_event_t event, pid_t pid = 0, |
| 162 | audio_port_handle_t portId = AUDIO_PORT_HANDLE_NONE) = 0; |
| 163 | virtual void sendIoConfigEvent_l( |
| 164 | audio_io_config_event_t event, pid_t pid = 0, |
| 165 | audio_port_handle_t portId = AUDIO_PORT_HANDLE_NONE) = 0; |
| 166 | virtual void sendPrioConfigEvent(pid_t pid, pid_t tid, int32_t prio, bool forApp) = 0; |
| 167 | virtual void sendPrioConfigEvent_l(pid_t pid, pid_t tid, int32_t prio, bool forApp) = 0; |
| 168 | virtual status_t sendSetParameterConfigEvent_l(const String8& keyValuePair) = 0; |
| 169 | virtual status_t sendCreateAudioPatchConfigEvent( |
| 170 | const struct audio_patch* patch, audio_patch_handle_t* handle) = 0; |
| 171 | virtual status_t sendReleaseAudioPatchConfigEvent(audio_patch_handle_t handle) = 0; |
| 172 | virtual status_t sendUpdateOutDeviceConfigEvent( |
| 173 | const DeviceDescriptorBaseVector& outDevices) = 0; |
| 174 | virtual void sendResizeBufferConfigEvent_l(int32_t maxSharedAudioHistoryMs) = 0; |
| 175 | virtual void sendCheckOutputStageEffectsEvent() = 0; |
| 176 | virtual void sendCheckOutputStageEffectsEvent_l() = 0; |
| 177 | virtual void sendHalLatencyModesChangedEvent_l() = 0; |
| 178 | |
| 179 | virtual void processConfigEvents_l() = 0; |
| 180 | virtual void setCheckOutputStageEffects() = 0; |
| 181 | virtual void cacheParameters_l() = 0; |
| 182 | virtual status_t createAudioPatch_l( |
| 183 | const struct audio_patch* patch, audio_patch_handle_t* handle) = 0; |
| 184 | virtual status_t releaseAudioPatch_l(const audio_patch_handle_t handle) = 0; |
| 185 | virtual void updateOutDevices(const DeviceDescriptorBaseVector& outDevices) = 0; |
| 186 | virtual void toAudioPortConfig(struct audio_port_config* config) = 0; |
| 187 | virtual void resizeInputBuffer_l(int32_t maxSharedAudioHistoryMs) = 0; |
| 188 | |
| 189 | // see note at declaration of mStandby, mOutDevice and mInDevice |
| 190 | virtual bool inStandby() const = 0; |
| 191 | virtual const DeviceTypeSet outDeviceTypes() const = 0; |
| 192 | virtual audio_devices_t inDeviceType() const = 0; |
| 193 | virtual DeviceTypeSet getDeviceTypes() const = 0; |
| 194 | virtual const AudioDeviceTypeAddrVector& outDeviceTypeAddrs() const = 0; |
| 195 | virtual const AudioDeviceTypeAddr& inDeviceTypeAddr() const = 0; |
| 196 | virtual bool isOutput() const = 0; |
| 197 | virtual bool isOffloadOrMmap() const = 0; |
| 198 | virtual sp<StreamHalInterface> stream() const = 0; |
| 199 | virtual sp<IAfEffectHandle> createEffect_l( |
| 200 | const sp<Client>& client, |
| 201 | const sp<media::IEffectClient>& effectClient, |
| 202 | int32_t priority, |
| 203 | audio_session_t sessionId, |
| 204 | effect_descriptor_t* desc, |
| 205 | int* enabled, |
| 206 | status_t* status /*non-NULL*/, |
| 207 | bool pinned, |
| 208 | bool probe, |
| 209 | bool notifyFramesProcessed) = 0; |
| 210 | |
| 211 | // return values for hasAudioSession (bit field) |
| 212 | enum effect_state { |
| 213 | EFFECT_SESSION = 0x1, // the audio session corresponds to at least one |
| 214 | // effect |
| 215 | TRACK_SESSION = 0x2, // the audio session corresponds to at least one |
| 216 | // track |
| 217 | FAST_SESSION = 0x4, // the audio session corresponds to at least one |
| 218 | // fast track |
| 219 | SPATIALIZED_SESSION = 0x8, // the audio session corresponds to at least one |
| 220 | // spatialized track |
| 221 | BIT_PERFECT_SESSION = 0x10 // the audio session corresponds to at least one |
| 222 | // bit-perfect track |
| 223 | }; |
| 224 | |
| 225 | // get effect chain corresponding to session Id. |
| 226 | virtual sp<IAfEffectChain> getEffectChain(audio_session_t sessionId) const = 0; |
| 227 | // same as getEffectChain() but must be called with ThreadBase mutex locked |
| 228 | virtual sp<IAfEffectChain> getEffectChain_l(audio_session_t sessionId) const = 0; |
| 229 | virtual std::vector<int> getEffectIds_l(audio_session_t sessionId) const = 0; |
| 230 | // add an effect chain to the chain list (mEffectChains) |
| 231 | virtual status_t addEffectChain_l(const sp<IAfEffectChain>& chain) = 0; |
| 232 | // remove an effect chain from the chain list (mEffectChains) |
| 233 | virtual size_t removeEffectChain_l(const sp<IAfEffectChain>& chain) = 0; |
| 234 | // lock all effect chains Mutexes. Must be called before releasing the |
| 235 | // ThreadBase mutex before processing the mixer and effects. This guarantees the |
| 236 | // integrity of the chains during the process. |
| 237 | // Also sets the parameter 'effectChains' to current value of mEffectChains. |
| 238 | virtual void lockEffectChains_l(Vector<sp<IAfEffectChain>>& effectChains) = 0; |
| 239 | // unlock effect chains after process |
| 240 | virtual void unlockEffectChains(const Vector<sp<IAfEffectChain>>& effectChains) = 0; |
| 241 | // get a copy of mEffectChains vector |
| 242 | virtual Vector<sp<IAfEffectChain>> getEffectChains_l() const = 0; |
| 243 | // set audio mode to all effect chains |
| 244 | virtual void setMode(audio_mode_t mode) = 0; |
| 245 | // get effect module with corresponding ID on specified audio session |
| 246 | virtual sp<IAfEffectModule> getEffect(audio_session_t sessionId, int effectId) const = 0; |
| 247 | virtual sp<IAfEffectModule> getEffect_l(audio_session_t sessionId, int effectId) const = 0; |
| 248 | // add and effect module. Also creates the effect chain is none exists for |
| 249 | // the effects audio session. Only called in a context of moving an effect |
| 250 | // from one thread to another |
| 251 | virtual status_t addEffect_l(const sp<IAfEffectModule>& effect) = 0; |
| 252 | // remove and effect module. Also removes the effect chain is this was the last |
| 253 | // effect |
| 254 | virtual void removeEffect_l(const sp<IAfEffectModule>& effect, bool release = false) = 0; |
| 255 | // disconnect an effect handle from module and destroy module if last handle |
| 256 | virtual void disconnectEffectHandle(IAfEffectHandle* handle, bool unpinIfLast) = 0; |
| 257 | // detach all tracks connected to an auxiliary effect |
| 258 | virtual void detachAuxEffect_l(int effectId) = 0; |
| 259 | // returns a combination of: |
| 260 | // - EFFECT_SESSION if effects on this audio session exist in one chain |
| 261 | // - TRACK_SESSION if tracks on this audio session exist |
| 262 | // - FAST_SESSION if fast tracks on this audio session exist |
| 263 | // - SPATIALIZED_SESSION if spatialized tracks on this audio session exist |
| 264 | virtual uint32_t hasAudioSession_l(audio_session_t sessionId) const = 0; |
| 265 | virtual uint32_t hasAudioSession(audio_session_t sessionId) const = 0; |
| 266 | |
| 267 | // the value returned by default implementation is not important as the |
| 268 | // strategy is only meaningful for PlaybackThread which implements this method |
| 269 | virtual product_strategy_t getStrategyForSession_l(audio_session_t sessionId) const = 0; |
| 270 | |
| 271 | // check if some effects must be suspended/restored when an effect is enabled |
| 272 | // or disabled |
| 273 | virtual void checkSuspendOnEffectEnabled( |
| 274 | bool enabled, audio_session_t sessionId, bool threadLocked) = 0; |
| 275 | |
| 276 | virtual status_t setSyncEvent(const sp<audioflinger::SyncEvent>& event) = 0; |
| 277 | virtual bool isValidSyncEvent(const sp<audioflinger::SyncEvent>& event) const = 0; |
| 278 | |
| 279 | // Return a reference to a per-thread heap which can be used to allocate IMemory |
| 280 | // objects that will be read-only to client processes, read/write to mediaserver, |
| 281 | // and shared by all client processes of the thread. |
| 282 | // The heap is per-thread rather than common across all threads, because |
| 283 | // clients can't be trusted not to modify the offset of the IMemory they receive. |
| 284 | // If a thread does not have such a heap, this method returns 0. |
| 285 | virtual sp<MemoryDealer> readOnlyHeap() const = 0; |
| 286 | |
| 287 | virtual sp<IMemory> pipeMemory() const = 0; |
| 288 | |
| 289 | virtual void systemReady() = 0; |
| 290 | |
| 291 | // checkEffectCompatibility_l() must be called with ThreadBase::mLock held |
| 292 | virtual status_t checkEffectCompatibility_l( |
| 293 | const effect_descriptor_t* desc, audio_session_t sessionId) = 0; |
| 294 | |
| 295 | virtual void broadcast_l() = 0; |
| 296 | |
| 297 | virtual bool isTimestampCorrectionEnabled() const = 0; |
| 298 | |
| 299 | virtual bool isMsdDevice() const = 0; |
| 300 | |
| 301 | virtual void dump(int fd, const Vector<String16>& args) = 0; |
| 302 | |
| 303 | // deliver stats to mediametrics. |
| 304 | virtual void sendStatistics(bool force) = 0; |
| 305 | |
| 306 | virtual Mutex& mutex() const = 0; |
| 307 | |
| 308 | virtual void onEffectEnable(const sp<IAfEffectModule>& effect) = 0; |
| 309 | virtual void onEffectDisable() = 0; |
| 310 | |
| 311 | // invalidateTracksForAudioSession_l must be called with holding mLock. |
| 312 | virtual void invalidateTracksForAudioSession_l(audio_session_t sessionId) const = 0; |
| 313 | // Invalidate all the tracks with the given audio session. |
| 314 | virtual void invalidateTracksForAudioSession(audio_session_t sessionId) const = 0; |
| 315 | |
| 316 | virtual bool isStreamInitialized() const = 0; |
| 317 | virtual void startMelComputation_l(const sp<audio_utils::MelProcessor>& processor) = 0; |
| 318 | virtual void stopMelComputation_l() = 0; |
| 319 | |
| 320 | virtual product_strategy_t getStrategyForStream(audio_stream_type_t stream) const = 0; |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 321 | |
| 322 | virtual void setEffectSuspended_l( |
| 323 | const effect_uuid_t* type, bool suspend, audio_session_t sessionId) = 0; |
| 324 | |
| 325 | // Dynamic cast to derived interface |
| 326 | virtual sp<IAfDirectOutputThread> asIAfDirectOutputThread() { return nullptr; } |
| 327 | virtual sp<IAfDuplicatingThread> asIAfDuplicatingThread() { return nullptr; } |
| 328 | virtual sp<IAfPlaybackThread> asIAfPlaybackThread() { return nullptr; } |
| 329 | virtual sp<IAfRecordThread> asIAfRecordThread() { return nullptr; } |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 330 | virtual IAfThreadCallback* afThreadCallback() const = 0; |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 331 | }; |
| 332 | |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 333 | class IAfPlaybackThread : public virtual IAfThreadBase, public virtual VolumeInterface { |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 334 | public: |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 335 | static sp<IAfPlaybackThread> createBitPerfectThread( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 336 | const sp<IAfThreadCallback>& afThreadCallback, AudioStreamOut* output, |
| 337 | audio_io_handle_t id, bool systemReady); |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 338 | |
| 339 | static sp<IAfPlaybackThread> createDirectOutputThread( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 340 | const sp<IAfThreadCallback>& afThreadCallback, AudioStreamOut* output, |
| 341 | audio_io_handle_t id, bool systemReady, const audio_offload_info_t& offloadInfo); |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 342 | |
| 343 | static sp<IAfPlaybackThread> createMixerThread( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 344 | const sp<IAfThreadCallback>& afThreadCallback, AudioStreamOut* output, |
| 345 | audio_io_handle_t id, bool systemReady, type_t type = MIXER, |
| 346 | audio_config_base_t* mixerConfig = nullptr); |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 347 | |
| 348 | static sp<IAfPlaybackThread> createOffloadThread( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 349 | const sp<IAfThreadCallback>& afThreadCallback, AudioStreamOut* output, |
| 350 | audio_io_handle_t id, bool systemReady, const audio_offload_info_t& offloadInfo); |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 351 | |
| 352 | static sp<IAfPlaybackThread> createSpatializerThread( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 353 | const sp<IAfThreadCallback>& afThreadCallback, AudioStreamOut* output, |
| 354 | audio_io_handle_t id, bool systemReady, audio_config_base_t* mixerConfig); |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 355 | |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 356 | static constexpr int8_t kMaxTrackStopRetriesOffload = 2; |
| 357 | |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 358 | enum mixer_state { |
| 359 | MIXER_IDLE, // no active tracks |
| 360 | MIXER_TRACKS_ENABLED, // at least one active track, but no track has any data ready |
| 361 | MIXER_TRACKS_READY, // at least one active track, and at least one track has data |
| 362 | MIXER_DRAIN_TRACK, // drain currently playing track |
| 363 | MIXER_DRAIN_ALL, // fully drain the hardware |
| 364 | // standby mode does not have an enum value |
| 365 | // suspend by audio policy manager is orthogonal to mixer state |
| 366 | }; |
| 367 | |
| 368 | // return estimated latency in milliseconds, as reported by HAL |
| 369 | virtual uint32_t latency() const = 0; // should be in IAfThreadBase? |
| 370 | |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 371 | virtual uint32_t& fastTrackAvailMask_l() = 0; |
| 372 | |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 373 | virtual sp<IAfTrack> createTrack_l( |
| 374 | const sp<Client>& client, |
| 375 | audio_stream_type_t streamType, |
| 376 | const audio_attributes_t& attr, |
| 377 | uint32_t* sampleRate, |
| 378 | audio_format_t format, |
| 379 | audio_channel_mask_t channelMask, |
| 380 | size_t* pFrameCount, |
| 381 | size_t* pNotificationFrameCount, |
| 382 | uint32_t notificationsPerBuffer, |
| 383 | float speed, |
| 384 | const sp<IMemory>& sharedBuffer, |
| 385 | audio_session_t sessionId, |
| 386 | audio_output_flags_t* flags, |
| 387 | pid_t creatorPid, |
| 388 | const AttributionSourceState& attributionSource, |
| 389 | pid_t tid, |
| 390 | status_t* status /*non-NULL*/, |
| 391 | audio_port_handle_t portId, |
| 392 | const sp<media::IAudioTrackCallback>& callback, |
| 393 | bool isSpatialized, |
| 394 | bool isBitPerfect) = 0; |
| 395 | |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 396 | virtual status_t addTrack_l(const sp<IAfTrack>& track) = 0; |
| 397 | virtual bool destroyTrack_l(const sp<IAfTrack>& track) = 0; |
| 398 | virtual bool isTrackActive(const sp<IAfTrack>& track) const = 0; |
| 399 | virtual void addOutputTrack_l(const sp<IAfTrack>& track) = 0; |
| 400 | |
| 401 | virtual AudioStreamOut* getOutput_l() const = 0; |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 402 | virtual AudioStreamOut* getOutput() const = 0; |
| 403 | virtual AudioStreamOut* clearOutput() = 0; |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 404 | |
| 405 | // a very large number of suspend() will eventually wraparound, but unlikely |
| 406 | virtual void suspend() = 0; |
| 407 | virtual void restore() = 0; |
| 408 | virtual bool isSuspended() const = 0; |
| 409 | virtual status_t getRenderPosition(uint32_t* halFrames, uint32_t* dspFrames) const = 0; |
| 410 | // Consider also removing and passing an explicit mMainBuffer initialization |
| 411 | // parameter to AF::IAfTrack::Track(). |
| 412 | virtual float* sinkBuffer() const = 0; |
| 413 | |
| 414 | virtual status_t attachAuxEffect(const sp<IAfTrack>& track, int EffectId) = 0; |
| 415 | virtual status_t attachAuxEffect_l(const sp<IAfTrack>& track, int EffectId) = 0; |
| 416 | |
| 417 | // called with AudioFlinger lock held |
| 418 | virtual bool invalidateTracks_l(audio_stream_type_t streamType) = 0; |
| 419 | virtual bool invalidateTracks_l(std::set<audio_port_handle_t>& portIds) = 0; |
| 420 | virtual void invalidateTracks(audio_stream_type_t streamType) = 0; |
| 421 | // Invalidate tracks by a set of port ids. The port id will be removed from |
| 422 | // the given set if the corresponding track is found and invalidated. |
| 423 | virtual void invalidateTracks(std::set<audio_port_handle_t>& portIds) = 0; |
| 424 | |
| 425 | virtual status_t getTimestamp_l(AudioTimestamp& timestamp) = 0; |
| 426 | virtual void addPatchTrack(const sp<IAfPatchTrack>& track) = 0; |
| 427 | virtual void deletePatchTrack(const sp<IAfPatchTrack>& track) = 0; |
| 428 | |
| 429 | // Return the asynchronous signal wait time. |
| 430 | virtual int64_t computeWaitTimeNs_l() const = 0; |
| 431 | // returns true if the track is allowed to be added to the thread. |
| 432 | virtual bool isTrackAllowed_l( |
| 433 | audio_channel_mask_t channelMask, audio_format_t format, audio_session_t sessionId, |
| 434 | uid_t uid) const = 0; |
| 435 | |
| 436 | virtual bool supportsHapticPlayback() const = 0; |
| 437 | |
| 438 | virtual void setDownStreamPatch(const struct audio_patch* patch) = 0; |
| 439 | |
| 440 | virtual IAfTrack* getTrackById_l(audio_port_handle_t trackId) = 0; |
| 441 | |
| 442 | virtual bool hasMixer() const = 0; |
| 443 | |
| 444 | virtual status_t setRequestedLatencyMode(audio_latency_mode_t mode) = 0; |
| 445 | |
| 446 | virtual status_t getSupportedLatencyModes(std::vector<audio_latency_mode_t>* modes) = 0; |
| 447 | |
| 448 | virtual status_t setBluetoothVariableLatencyEnabled(bool enabled) = 0; |
| 449 | |
| 450 | virtual void setStandby() = 0; |
| 451 | virtual void setStandby_l() = 0; |
| 452 | virtual bool waitForHalStart() = 0; |
| 453 | |
| 454 | virtual bool hasFastMixer() const = 0; |
| 455 | virtual FastTrackUnderruns getFastTrackUnderruns(size_t fastIndex) const = 0; |
| 456 | virtual const std::atomic<int64_t>& framesWritten() const = 0; |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 457 | |
| 458 | virtual bool usesHwAvSync() const = 0; |
| 459 | }; |
| 460 | |
| 461 | class IAfDirectOutputThread : public virtual IAfPlaybackThread { |
| 462 | public: |
| 463 | virtual status_t selectPresentation(int presentationId, int programId) = 0; |
| 464 | }; |
| 465 | |
| 466 | class IAfDuplicatingThread : public virtual IAfPlaybackThread { |
| 467 | public: |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 468 | static sp<IAfDuplicatingThread> create( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 469 | const sp<IAfThreadCallback>& afThreadCallback, IAfPlaybackThread* mainThread, |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 470 | audio_io_handle_t id, bool systemReady); |
| 471 | |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 472 | virtual void addOutputTrack(IAfPlaybackThread* thread) = 0; |
| 473 | virtual uint32_t waitTimeMs() const = 0; |
| 474 | virtual void removeOutputTrack(IAfPlaybackThread* thread) = 0; |
| 475 | }; |
| 476 | |
| 477 | class IAfRecordThread : public virtual IAfThreadBase { |
| 478 | public: |
| 479 | static sp<IAfRecordThread> create( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 480 | const sp<IAfThreadCallback>& afThreadCallback, AudioStreamIn* input, |
| 481 | audio_io_handle_t id, bool systemReady); |
Andy Hung | 87c693c | 2023-07-06 20:56:16 -0700 | [diff] [blame] | 482 | |
| 483 | virtual sp<IAfRecordTrack> createRecordTrack_l( |
| 484 | const sp<Client>& client, |
| 485 | const audio_attributes_t& attr, |
| 486 | uint32_t* pSampleRate, |
| 487 | audio_format_t format, |
| 488 | audio_channel_mask_t channelMask, |
| 489 | size_t* pFrameCount, |
| 490 | audio_session_t sessionId, |
| 491 | size_t* pNotificationFrameCount, |
| 492 | pid_t creatorPid, |
| 493 | const AttributionSourceState& attributionSource, |
| 494 | audio_input_flags_t* flags, |
| 495 | pid_t tid, |
| 496 | status_t* status /*non-NULL*/, |
| 497 | audio_port_handle_t portId, |
| 498 | int32_t maxSharedAudioHistoryMs) = 0; |
| 499 | virtual void destroyTrack_l(const sp<IAfRecordTrack>& track) = 0; |
| 500 | virtual void removeTrack_l(const sp<IAfRecordTrack>& track) = 0; |
| 501 | |
| 502 | virtual status_t start( |
| 503 | IAfRecordTrack* recordTrack, AudioSystem::sync_event_t event, |
| 504 | audio_session_t triggerSession) = 0; |
| 505 | |
| 506 | // ask the thread to stop the specified track, and |
| 507 | // return true if the caller should then do it's part of the stopping process |
| 508 | virtual bool stop(IAfRecordTrack* recordTrack) = 0; |
| 509 | |
| 510 | virtual AudioStreamIn* getInput() const = 0; |
| 511 | virtual AudioStreamIn* clearInput() = 0; |
| 512 | |
| 513 | virtual status_t getActiveMicrophones( |
| 514 | std::vector<media::MicrophoneInfoFw>* activeMicrophones) const = 0; |
| 515 | virtual status_t setPreferredMicrophoneDirection(audio_microphone_direction_t direction) = 0; |
| 516 | virtual status_t setPreferredMicrophoneFieldDimension(float zoom) = 0; |
| 517 | |
| 518 | virtual void addPatchTrack(const sp<IAfPatchRecord>& record) = 0; |
| 519 | virtual void deletePatchTrack(const sp<IAfPatchRecord>& record) = 0; |
| 520 | virtual bool fastTrackAvailable() const = 0; |
| 521 | virtual void setFastTrackAvailable(bool available) = 0; |
| 522 | |
| 523 | virtual void setRecordSilenced(audio_port_handle_t portId, bool silenced) = 0; |
| 524 | virtual bool hasFastCapture() const = 0; |
| 525 | |
| 526 | virtual void checkBtNrec() = 0; |
| 527 | virtual uint32_t getInputFramesLost() const = 0; |
| 528 | |
| 529 | virtual status_t shareAudioHistory( |
| 530 | const std::string& sharedAudioPackageName, |
| 531 | audio_session_t sharedSessionId = AUDIO_SESSION_NONE, |
| 532 | int64_t sharedAudioStartMs = -1) = 0; |
| 533 | virtual void resetAudioHistory_l() = 0; |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 534 | }; |
| 535 | |
Andy Hung | 7aa7d10 | 2023-07-07 15:58:48 -0700 | [diff] [blame] | 536 | class IAfMmapThread : public virtual IAfThreadBase { |
| 537 | public: |
| 538 | // createIAudioTrackAdapter() is a static constructor which creates an |
| 539 | // MmapStreamInterface AIDL interface adapter from the MmapThread object that |
| 540 | // may be passed back to the client. |
| 541 | // |
| 542 | // Only one AIDL MmapStreamInterface interface adapter should be created per MmapThread. |
| 543 | static sp<MmapStreamInterface> createMmapStreamInterfaceAdapter( |
| 544 | const sp<IAfMmapThread>& mmapThread); |
| 545 | |
| 546 | virtual void configure( |
| 547 | const audio_attributes_t* attr, |
| 548 | audio_stream_type_t streamType, |
| 549 | audio_session_t sessionId, |
| 550 | const sp<MmapStreamCallback>& callback, |
| 551 | audio_port_handle_t deviceId, |
| 552 | audio_port_handle_t portId) = 0; |
| 553 | virtual void disconnect() = 0; |
| 554 | |
| 555 | // MmapStreamInterface handling (see adapter) |
| 556 | virtual status_t createMmapBuffer( |
| 557 | int32_t minSizeFrames, struct audio_mmap_buffer_info* info) = 0; |
| 558 | virtual status_t getMmapPosition(struct audio_mmap_position* position) const = 0; |
| 559 | virtual status_t start( |
| 560 | const AudioClient& client, const audio_attributes_t* attr, |
| 561 | audio_port_handle_t* handle) = 0; |
| 562 | virtual status_t stop(audio_port_handle_t handle) = 0; |
| 563 | virtual status_t standby() = 0; |
| 564 | virtual status_t getExternalPosition(uint64_t* position, int64_t* timeNanos) const = 0; |
| 565 | virtual status_t reportData(const void* buffer, size_t frameCount) = 0; |
| 566 | |
Andy Hung | 99b1ba6 | 2023-07-14 11:00:08 -0700 | [diff] [blame] | 567 | // TODO(b/291317898) move to IAfThreadBase? |
Andy Hung | 7aa7d10 | 2023-07-07 15:58:48 -0700 | [diff] [blame] | 568 | virtual void invalidateTracks(std::set<audio_port_handle_t>& portIds) = 0; |
| 569 | |
Andy Hung | 99b1ba6 | 2023-07-14 11:00:08 -0700 | [diff] [blame] | 570 | // Sets the UID records silence - TODO(b/291317898) move to IAfMmapCaptureThread |
Andy Hung | 7aa7d10 | 2023-07-07 15:58:48 -0700 | [diff] [blame] | 571 | virtual void setRecordSilenced(audio_port_handle_t portId, bool silenced) = 0; |
| 572 | |
| 573 | virtual sp<IAfMmapPlaybackThread> asIAfMmapPlaybackThread() { return nullptr; } |
| 574 | virtual sp<IAfMmapCaptureThread> asIAfMmapCaptureThread() { return nullptr; } |
| 575 | }; |
| 576 | |
| 577 | class IAfMmapPlaybackThread : public virtual IAfMmapThread, public virtual VolumeInterface { |
| 578 | public: |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 579 | static sp<IAfMmapPlaybackThread> create( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 580 | const sp<IAfThreadCallback>& afThreadCallback, audio_io_handle_t id, |
| 581 | AudioHwDevice* hwDev, AudioStreamOut* output, bool systemReady); |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 582 | |
Andy Hung | 7aa7d10 | 2023-07-07 15:58:48 -0700 | [diff] [blame] | 583 | virtual AudioStreamOut* clearOutput() = 0; |
| 584 | }; |
| 585 | |
| 586 | class IAfMmapCaptureThread : public virtual IAfMmapThread { |
| 587 | public: |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 588 | static sp<IAfMmapCaptureThread> create( |
Andy Hung | 583043b | 2023-07-17 17:05:00 -0700 | [diff] [blame] | 589 | const sp<IAfThreadCallback>& afThreadCallback, audio_io_handle_t id, |
| 590 | AudioHwDevice* hwDev, AudioStreamIn* input, bool systemReady); |
Andy Hung | ee58e4a | 2023-07-07 13:47:37 -0700 | [diff] [blame] | 591 | |
Andy Hung | 7aa7d10 | 2023-07-07 15:58:48 -0700 | [diff] [blame] | 592 | virtual AudioStreamIn* clearInput() = 0; |
| 593 | }; |
| 594 | |
Andy Hung | 440901d | 2023-06-29 21:19:25 -0700 | [diff] [blame] | 595 | } // namespace android |