MpOss.h

Go to the documentation of this file.

//
// Copyright (C) 2007 SIPez LLC.
// Licensed to SIPfoundry under a Contributor Agreement.
//
// Copyright (C) 2007 SIPfoundry Inc.
// Licensed by SIPfoundry under the LGPL license.
//
// $$

// Author: Sergey Kostanbaev <Sergey DOT Kostanbaev AT sipez DOT com>

#ifndef _MpOss_h_
#define _MpOss_h_

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

#include <sys/types.h>
#include <sys/soundcard.h>

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

class MpidOss;
class MpodOss;

class MpOss : public UtlVoidPtr
{
   friend class MpidOss;
   friend class MpodOss;
   /* //////////////////////////// PUBLIC //////////////////////////////////// */
public:

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


   MpOss();

   ~MpOss();


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


   OsStatus setInputDevice(MpidOss* pIDD);
   OsStatus setOutputDevice(MpodOss* pODD);

   OsStatus freeInputDevice();
   OsStatus freeOutputDevice();

   OsStatus attachReader();
   OsStatus attachWriter();

   OsStatus detachReader();
   OsStatus detachWriter();


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




   /* ============================ 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:
   int mfdDevice;               
   UtlBoolean mbReadCap;        
   UtlBoolean mbWriteCap;       

   MpidOss* mReader;          
   MpodOss* 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);
   OsStatus initDeviceFinal(unsigned samplesPerSec, unsigned samplerPerFrame);
   OsStatus freeDevice();

   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();

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

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

   UtlBoolean ossSetTrigger(bool turnOn);
   UtlBoolean ossReset();

   static void* soundCardIoWrapper(void* arg);
};

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

UtlBoolean MpOss::isDeviceValid()
{
   return (mfdDevice != -1);
}

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

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

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

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

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

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

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


#endif // _MpOss_h_