MpMMTimerPosix.h

Go to the documentation of this file.

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

// Author: Sergey Kostanbaev <sergey DOT kostanbaev AT SIPez DOT com>

#ifndef _MpMMTimerPosix_h_
#define _MpMMTimerPosix_h_

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


// APPLICATION INCLUDES
#include <utl/UtlDefs.h>
#include "mp/MpMMTimer.h"
#include <os/OsMutex.h>

#ifdef __APPLE__
#warning PosixTimer is not implimented in MacOS X
#define timer_t     int
#endif

class MpMMTimerPosix : public MpMMTimer
{
/* //////////////////////////////// PUBLIC //////////////////////////////// */
public:
   class PosixSignalReg; // Forward declaration

   static const char * const TYPE;

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


   MpMMTimerPosix(MpMMTimer::MMTimerType type);

   ~MpMMTimerPosix();


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


   OsStatus setNotification(OsNotification* notification);

   OsStatus run(unsigned usecPeriodic);

   OsStatus stop();

   OsStatus waitForNextTick();


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


   OsStatus getResolution(unsigned& resolution);

   OsStatus getPeriodRange(unsigned* pMinUSecs, unsigned* pMaxUSecs = NULL);

   OsTime getAbsFireTime() const;


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


   static PosixSignalReg* getSignalDescriptor();



   class PosixSignalReg
   {
   public:
      PosixSignalReg(int sigNum, void (*)(int, siginfo_t *, void *));
      ~PosixSignalReg();

      int getSignalNum() const;

      int blockThreadSig();
      int unblockThreadSig();

   private:
      struct sigaction mOldAction; 
      int mSigNum;                 
      sigset_t mBlockSigMask;      
   };

   static
   void signalHandler(int signum, siginfo_t *siginfo, void *context);

/* ////////////////////////////// PROTECTED /////////////////////////////// */
protected:
   OsNotification* mpNotification; 
   UtlBoolean mbTimerStarted;      
   timer_t mTimer;                 
   sem_t mSyncSemaphore;           

   void callback();


/* /////////////////////////////// PRIVATE //////////////////////////////// */
private:   
   static PosixSignalReg sPosixTimerReg;
   pthread_t mThread;              
   sem_t mIoSem;                   
   UtlBoolean mbTerminate;         

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

/* ============================ INLINE METHODS ============================ */
#endif //_MpMMTimerPosix_h_