AudioIO.h

Go to the documentation of this file.

/**********************************************************************
 
  Audacity: A Digital Audio Editor
 
  AudioIO.h
 
  Dominic Mazzoni
 
  Use the PortAudio library to play and record sound
 
**********************************************************************/
 
#ifndef __AUDACITY_AUDIO_IO__
#define __AUDACITY_AUDIO_IO__
 
#include "AudioIOBase.h" // to inherit
#include "AudioIOSequences.h"
#include "PlaybackSchedule.h" // member variable
 
#include <functional>
#include <memory>
#include <mutex>
#include <thread>
#include <utility>
#include <wx/atomic.h> // member variable
 
#include "PluginProvider.h" // for PluginID
#include "Observer.h"
#include "SampleCount.h"
#include "SampleFormat.h"
 
class wxArrayString;
class AudioIOBase;
class AudioIO;
class RingBuffer;
class Mixer;
class OtherPlayableSequence;
class RealtimeEffectState;
class Resample;
 
class AudacityProject;
 
struct PaStreamCallbackTimeInfo;
typedef unsigned long PaStreamCallbackFlags;
typedef int PaError;
 
namespace RealtimeEffects {
   class ProcessingScope;
}
 
bool ValidateDeviceNames();
 
enum class Acknowledge { eNone = 0, eStart, eStop };
 
struct AudioIOEvent {
   AudacityProject *pProject;
   enum Type {
      PLAYBACK,
      CAPTURE,
      MONITOR,
      PAUSE,
   } type;
   bool on;
};
 
struct AUDIO_IO_API TransportSequences final {
   ConstPlayableSequences playbackSequences;
   RecordableSequences captureSequences;
   std::vector<std::shared_ptr<const OtherPlayableSequence>>
      otherPlayableSequences;
 
   // This is a subset of playbackSequences
   ConstPlayableSequences prerollSequences;
};
 
int audacityAudioCallback(
   const void *inputBuffer, void *outputBuffer,
   unsigned long framesPerBuffer,
   const PaStreamCallbackTimeInfo *timeInfo,
   PaStreamCallbackFlags statusFlags, void *userData );
 
class AudioIOExt;
 
class AUDIO_IO_API AudioIoCallback /* not final */
   : public AudioIOBase
{
public:
   AudioIoCallback();
   ~AudioIoCallback();
 
public:
   // This function executes in a thread spawned by the PortAudio library
   int AudioCallback(
      constSamplePtr inputBuffer, float *outputBuffer,
      unsigned long framesPerBuffer,
      const PaStreamCallbackTimeInfo *timeInfo,
      const PaStreamCallbackFlags statusFlags, void *userData);
 
   class AUDIO_IO_API AudioIOExtIterator {
   public:
      using difference_type = ptrdiff_t;
      using value_type = AudioIOExt &;
      using pointer = AudioIOExt *;
      using reference = AudioIOExt &;
      using iterator_category = std::forward_iterator_tag;
 
      explicit AudioIOExtIterator( AudioIoCallback &audioIO, bool end )
         : mIterator{ end
            ? audioIO.mAudioIOExt.end()
            : audioIO.mAudioIOExt.begin() }
      {}
      AudioIOExtIterator &operator ++ () { ++mIterator; return *this; }
      auto operator *() const -> AudioIOExt &;
      friend inline bool operator == (
         const AudioIOExtIterator &xx, const AudioIOExtIterator &yy)
      {
         return xx.mIterator == yy.mIterator;
      }
      friend inline bool operator != (
         const AudioIOExtIterator &xx, const AudioIOExtIterator &yy)
      {
         return !(xx == yy);
      }
   private:
      std::vector<std::unique_ptr<AudioIOExtBase>>::const_iterator mIterator;
   };
   struct AudioIOExtRange {
      AudioIOExtIterator first;
      AudioIOExtIterator second;
      AudioIOExtIterator begin() const { return first; }
      AudioIOExtIterator end() const { return second; }
   };
 
   AudioIOExtRange Extensions() {
      return {
         AudioIOExtIterator{ *this, false },
         AudioIOExtIterator{ *this, true }
      };
   }
 
   std::shared_ptr< AudioIOListener > GetListener() const
      { return mListener.lock(); }
   void SetListener( const std::shared_ptr< AudioIOListener > &listener);
 
   // Part of the callback
   int CallbackDoSeek();
 
   // Part of the callback
   void CallbackCheckCompletion(
      int &callbackReturn, unsigned long len);
 
   int mbHasSoloSequences;
   int mCallbackReturn;
   // Helpers to determine if sequences have already been faded out.
   unsigned  CountSoloingSequences();
 
   bool SequenceShouldBeSilent(const PlayableSequence &ps);
 
   void CheckSoundActivatedRecordingLevel(
      float *inputSamples,
      unsigned long framesPerBuffer
   );
 
   bool FillOutputBuffers(
      float *outputFloats,
      unsigned long framesPerBuffer,
      float *outputMeterFloats
   );
   void DrainInputBuffers(
      constSamplePtr inputBuffer,
      unsigned long framesPerBuffer,
      const PaStreamCallbackFlags statusFlags,
      float * tempFloats
   );
   void UpdateTimePosition(
      unsigned long framesPerBuffer
   );
   void DoPlaythrough(
      constSamplePtr inputBuffer,
      float *outputBuffer,
      unsigned long framesPerBuffer,
      float *outputMeterFloats
   );
   void SendVuInputMeterData(
      const float *inputSamples,
      unsigned long framesPerBuffer
   );
   void SendVuOutputMeterData(
      const float *outputMeterFloats,
      unsigned long framesPerBuffer
   );
 
   size_t GetCommonlyReadyPlayback();
 
   size_t GetCommonlyWrittenForPlayback();
 
   long    mNumPauseFrames;
 
#ifdef EXPERIMENTAL_AUTOMATED_INPUT_LEVEL_ADJUSTMENT
   bool           mAILAActive;
   bool           mAILAClipped;
   int            mAILATotalAnalysis;
   int            mAILAAnalysisCounter;
   double         mAILAMax;
   double         mAILAGoalPoint;
   double         mAILAGoalDelta;
   double         mAILAAnalysisTime;
   double         mAILALastStartTime;
   double         mAILAChangeFactor;
   double         mAILATopLevel;
   double         mAILAAnalysisEndTime;
   double         mAILAAbsolutStartTime;
   unsigned short mAILALastChangeType;  //0 - no change, 1 - increase change, 2 - decrease change
#endif
 
   std::thread mAudioThread;
   std::atomic<bool> mFinishAudioThread{ false };
 
   std::vector<std::unique_ptr<Resample>> mResample;
 
   using RingBuffers = std::vector<std::unique_ptr<RingBuffer>>;
   RingBuffers mCaptureBuffers;
   RecordableSequences mCaptureSequences;
   std::vector<std::vector<float>> mProcessingBuffers;
   std::vector<std::vector<float>> mMasterBuffers;
   RingBuffers mPlaybackBuffers;
   ConstPlayableSequences      mPlaybackSequences;
   // Old gain is used in playback in linearly interpolating
   // the gain.
   float mOldPlaybackGain;
   // Temporary buffers, each as large as the playback buffers
   std::vector<SampleBuffer> mScratchBuffers;
   std::vector<float *> mScratchPointers; 
 
   std::vector<std::unique_ptr<Mixer>> mPlaybackMixers;
 
   std::atomic<float>  mMixerOutputVol{ 1.0 };
   static int          mNextStreamToken;
   double              mFactor;
   unsigned long       mMaxFramesOutput; // The actual number of frames output.
   bool                mbMicroFades;
 
   double              mSeek;
   PlaybackPolicy::Duration mPlaybackRingBufferSecs;
   double              mCaptureRingBufferSecs;
 
   size_t              mPlaybackSamplesToCopy;
   size_t              mHardwarePlaybackLatencyFrames {};
   size_t              mPlaybackQueueMinimum;
 
   double              mMinCaptureSecsToCopy;
   bool                mSoftwarePlaythrough;
 
   bool                mPauseRec;
   float               mSilenceLevel;
   size_t              mNumCaptureChannels;
   size_t              mNumPlaybackChannels;
   sampleFormat        mCaptureFormat;
   double              mCaptureRate{};
   unsigned long long  mLostSamples{ 0 };
   std::atomic<bool>   mAudioThreadShouldCallSequenceBufferExchangeOnce;
   std::atomic<bool>   mAudioThreadSequenceBufferExchangeLoopRunning;
   std::atomic<bool>   mAudioThreadSequenceBufferExchangeLoopActive;
 
   std::atomic<Acknowledge>  mAudioThreadAcknowledge;
 
   // Async start/stop + wait of AudioThread processing.
   // Provided to allow more flexibility, however use with caution:
   // never call Stop between Start and the wait for Started (and the converse)
   void StartAudioThread();
   void WaitForAudioThreadStarted();
   void StopAudioThread();
   void WaitForAudioThreadStopped();
 
   void ProcessOnceAndWait( std::chrono::milliseconds sleepTime = std::chrono::milliseconds(50) );
 
 
 
   std::atomic<bool>   mForceFadeOut{ false };
 
   wxLongLong          mLastPlaybackTimeMillis;
 
   double              mLastRecordingOffset;
   PaError             mLastPaError;
 
protected:
   static size_t MinValue(
      const RingBuffers &buffers, size_t (RingBuffer::*pmf)() const);
 
   float GetMixerOutputVol() {
      return mMixerOutputVol.load(std::memory_order_relaxed); }
   void SetMixerOutputVol(float value) {
      mMixerOutputVol.store(value, std::memory_order_relaxed); }
 
   std::weak_ptr< AudioIOListener > mListener;
 
   bool mUsingAlsa { false };
   bool mUsingJack { false };
 
   // For cacheing supported sample rates
   static double mCachedBestRateOut;
   static bool mCachedBestRatePlaying;
   static bool mCachedBestRateCapturing;
 
   // Serialize main thread and PortAudio thread's attempts to pause and change
   // the state used by the third, Audio thread.
   wxMutex mSuspendAudioThread;
 
public:
   // Whether an exception (as for exhaustion of resource space) was detected
   // in recording, and not yet cleared at the end of the procedure to stop
   // recording.
   bool HasRecordingException() const
      { return mRecordingException; }
 
protected:
   // A flag tested and set in one thread, cleared in another.  Perhaps
   // this guarantee of atomicity is more cautious than necessary.
   wxAtomicInt mRecordingException {};
   void SetRecordingException()
      { wxAtomicInc( mRecordingException ); }
   void ClearRecordingException()
      { if (mRecordingException) wxAtomicDec( mRecordingException ); }
 
   std::vector< std::pair<double, double> > mLostCaptureIntervals;
   bool mDetectDropouts{ true };
 
public:
   // Pairs of starting time and duration
   const std::vector< std::pair<double, double> > &LostCaptureIntervals()
   { return mLostCaptureIntervals; }
 
   // Used only for testing purposes in alpha builds
   bool mSimulateRecordingErrors{ false };
 
   // Whether to check the error code passed to audacityAudioCallback to
   // detect more dropouts
   std::atomic<bool> mDetectUpstreamDropouts{ true };
 
protected:
   RecordingSchedule mRecordingSchedule{};
   PlaybackSchedule mPlaybackSchedule;
 
   struct TransportState;
   std::unique_ptr<TransportState> mpTransportState;
 
private:
   using AudioIOBase::mAudioIOExt;
};
 
struct PaStreamInfo;
 
class AUDIO_IO_API AudioIO final
   : public AudioIoCallback
   , public Observer::Publisher<AudioIOEvent>
{
 
   AudioIO();
   ~AudioIO();
   void StartThread();
 
public:
   // This might return null during application startup or shutdown
   static AudioIO *Get();
 
 
   std::shared_ptr<RealtimeEffectState>
   AddState(AudacityProject &project,
      ChannelGroup *pGroup, const PluginID & id);
 
 
   std::shared_ptr<RealtimeEffectState>
   ReplaceState(AudacityProject &project,
      ChannelGroup *pGroup, size_t index, const PluginID & id);
 
   void RemoveState(AudacityProject &project,
      ChannelGroup *pGroup,
      std::shared_ptr<RealtimeEffectState> pState);
 
   void StartMonitoring( const AudioIOStartStreamOptions &options );
 
   int StartStream(const TransportSequences &sequences,
      double t0, double t1,
      double mixerLimit, 
      const AudioIOStartStreamOptions &options);
 
   void StopStream() override;
   void SeekStream(double seconds) { mSeek = seconds; }
 
   using PostRecordingAction = std::function<void()>;
 
 
   void CallAfterRecording(PostRecordingAction action);
 
public:
   wxString LastPaErrorString();
 
   wxLongLong GetLastPlaybackTime() const { return mLastPlaybackTimeMillis; }
   std::shared_ptr<AudacityProject> GetOwningProject() const
   { return mOwningProject.lock(); }
 
   void SetPaused(bool state, bool publish = false);
 
   /* Mixer services are always available.  If no stream is running, these
    * methods use whatever device is specified by the preferences.  If a
    * stream *is* running, naturally they manipulate the mixer associated
    * with that stream.  If no mixer is available, output is emulated and
    * input is stuck at 1.0f (a gain is applied to output samples).
    */
   void SetMixer(int inputSource, float inputVolume,
                 float playbackVolume);
   void GetMixer(int *inputSource, float *inputVolume,
                 float *playbackVolume);
   bool InputMixerWorks();
 
   wxArrayString GetInputSourceNames();
 
   sampleFormat GetCaptureFormat() { return mCaptureFormat; }
   size_t GetNumPlaybackChannels() const { return mNumPlaybackChannels; }
   size_t GetNumCaptureChannels() const { return mNumCaptureChannels; }
 
   // Meaning really capturing, not just pre-rolling
   bool IsCapturing() const;
 
   static bool ValidateDeviceNames(const wxString &play, const wxString &rec);
 
   #ifdef EXPERIMENTAL_AUTOMATED_INPUT_LEVEL_ADJUSTMENT
      void AILAInitialize();
      void AILADisable();
      bool AILAIsActive();
      void AILAProcess(double maxPeak);
      void AILASetStartTime();
      double AILAGetLastDecisionTime();
   #endif
 
   bool IsAvailable(AudacityProject &project) const;
 
   double GetBestRate(bool capturing, bool playing, double sampleRate);
 
   double GetStreamTime();
 
   static void AudioThread(std::atomic<bool> &finish);
 
   static void Init();
   static void Deinit();
 
   void DelayActions(bool recording);
 
private:
 
   bool DelayingActions() const;
 
   void SetMeters();
 
   bool StartPortAudioStream(const AudioIOStartStreamOptions &options,
      unsigned int numPlaybackChannels, unsigned int numCaptureChannels);
 
   void SetOwningProject( const std::shared_ptr<AudacityProject> &pProject );
   void ResetOwningProject();
 
   void SequenceBufferExchange();
 
   void FillPlayBuffers();
 
   bool ProcessPlaybackSlices(
      std::optional<RealtimeEffects::ProcessingScope> &pScope,
      size_t available);
 
   void DrainRecordBuffers();
 
   size_t GetCommonlyFreePlayback();
 
   size_t GetCommonlyAvailCapture();
 
   bool AllocateBuffers(
      const AudioIOStartStreamOptions &options,
      const TransportSequences &sequences,
      double t0, double t1, double sampleRate);
 
   void StartStreamCleanup(bool bOnlyBuffers = false);
 
   std::mutex mPostRecordingActionMutex;
   PostRecordingAction mPostRecordingAction;
 
   bool mDelayingActions{ false };
};
 
AUDIO_IO_API extern BoolSetting SoundActivatedRecord;
 
#endif