MpAlsa.h

Go to the documentation of this file.

//
// Copyright (C) 2007-2017 SIPez LLC.  All rights reserved.
//
// $$


#ifndef _MpAlsa_h_
#define _MpAlsa_h_

// SYSTEM INCLUDES
#include <pthread.h>
#include <semaphore.h>

#include <sys/types.h>
#include <sys/soundcard.h>
#include <alsa/asoundlib.h>
#include <alsa/pcm_plugin.h>

// APPLICATION INCLUDES
#include "mp/MpInputDeviceDriver.h"
#include "mp/MpOutputDeviceDriver.h"
#include "mp/MpAlsaContainer.h"
#include "utl/UtlVoidPtr.h"

class MpidAlsa;
class MpodAlsa;

class MpAlsa : public UtlVoidPtr
{
   friend class MpidAlsa;
   friend class MpodAlsa;
   /* //////////////////////////// PUBLIC //////////////////////////////////// */
public:

   /* ============================ CREATORS ================================== */


   MpAlsa();

   ~MpAlsa();


   /* ============================ MANIPULATORS ============================== */


   OsStatus setInputDevice(MpidAlsa* pIDD);
   OsStatus setOutputDevice(MpodAlsa* pODD);

   OsStatus freeInputDevice();
   OsStatus freeOutputDevice();

   OsStatus attachReader();
   OsStatus attachWriter();

   OsStatus detachReader();
   OsStatus detachWriter();


   /* ============================ ACCESSORS ================================= */

   static int getDeviceNames(UtlContainer& deviceNames, bool capture);

   /* ============================ INQUIRY =================================== */


   inline UtlBoolean isDeviceValid();

   inline UtlBoolean isReaderAttached();

   inline UtlBoolean isWriterAttached();
   inline UtlBoolean isDevCapBatch();
   inline UtlBoolean isDevCapDuplex();
   inline UtlBoolean isDevCapMmap();
   inline UtlBoolean isDevCapTrigger();

   inline UtlBoolean isNotUsed();


   /* //////////////////////////// PROTECTED ///////////////////////////////// */
protected:
   UtlBoolean mbReadCap;        
   UtlBoolean mbWriteCap;       

   MpidAlsa* mReader;          
   MpodAlsa* mWriter;          

   int mDeviceCap;              

   volatile UtlBoolean mStReader;        
   volatile UtlBoolean mStWriter;        
   volatile UtlBoolean mStShutdown;      
   volatile UtlBoolean mModeChanged;     

   unsigned mUsedSamplesPerSec;          
   unsigned mUsedSamplesPerFrame;        

   MpAudioSample* mResamplerBuffer;      
   UtlBoolean mStereoOps;                

   pthread_t mIoThread;                  
   sem_t mSleepSem;      
   sem_t mSignalSem;     

   OsStatus initDevice(const char* devname, int samplesPerSecond);
   OsStatus initDeviceFinal(unsigned samplesPerSec, unsigned samplerPerFrame);

   OsStatus setSampleRate(unsigned samplesPerSec, unsigned samplerPerFrame);

   OsStatus doInput(char* buffer, int size);
   OsStatus doOutput(const char* buffer, int size);

   OsStatus doInputRs(MpAudioSample* buffer, unsigned size);
   OsStatus doOutputRs(const MpAudioSample* buffer, unsigned size);

   void noMoreNeeded();

   void soundIoThread();

   // MER additions for ALSA devices
   snd_pcm_t*  pPcmOut;
   snd_pcm_t*  pPcmIn;
   int writeBufSize;
   int readBufSize;

   /* //////////////////////////// PRIVATE /////////////////////////////////// */
private:

   void threadIoStatusChanged();
   void threadWakeUp();
   void threadKill();

   UtlBoolean alsaSetTrigger(bool turnOn);
   UtlBoolean alsaReset();

   static void* soundCardIoWrapper(void* arg);
   int alsaSetupPcmDevice(const char* devname, bool capture, unsigned& suggestedRate);
   int alsaSetupWarning(const char* devname, int err, bool cap, const char* pLogString);
};

/* ============================ INLINE METHODS ============================ */

UtlBoolean MpAlsa::isDeviceValid()
{
   return (pPcmIn != NULL && pPcmOut != NULL);
}

UtlBoolean MpAlsa::isReaderAttached()
{
   return (mReader != NULL);
}

UtlBoolean MpAlsa::isWriterAttached()
{
   return (mWriter != NULL);
}

UtlBoolean MpAlsa::isDevCapBatch()
{
   return (mDeviceCap & DSP_CAP_BATCH);
}

UtlBoolean MpAlsa::isDevCapDuplex()
{
   return (mDeviceCap & DSP_CAP_DUPLEX);
}

UtlBoolean MpAlsa::isDevCapMmap()
{
   return (mDeviceCap & DSP_CAP_MMAP);
}

UtlBoolean MpAlsa::isDevCapTrigger()
{
   return (mDeviceCap & DSP_CAP_TRIGGER);
}

UtlBoolean MpAlsa::isNotUsed()
{
   return ((mReader == NULL) && (mWriter == NULL));
}


#endif // _MpAlsa_h_