OsSyncBase.h

Go to the documentation of this file.

//  
// Copyright (C) 2006 SIPez LLC. 
// Licensed to SIPfoundry under a Contributor Agreement. 
//
// Copyright (C) 2004-2006 SIPfoundry Inc.
// Licensed by SIPfoundry under the LGPL license.
//
// Copyright (C) 2004-2006 Pingtel Corp.  All rights reserved.
// Licensed to SIPfoundry under a Contributor Agreement.
//
// $$


#ifndef _OsSyncBase_h_
#define _OsSyncBase_h_

// SYSTEM INCLUDES

// APPLICATION INCLUDES
#include "os/OsDefs.h"
#include "os/OsStatus.h"
#include "os/OsTime.h"

// DEFINES
// If OS_SYNC_DEBUG, enable debugging information for binary semaphores and
// mutexes.
// #define OS_SYNC_DEBUG

#ifdef OS_SYNC_DEBUG
#  include "os/OsDateTime.h"
#endif

// MACROS
// EXTERNAL FUNCTIONS
// EXTERNAL VARIABLES
// CONSTANTS
// STRUCTS
// TYPEDEFS

// FORWARD DECLARATIONS

class OsSyncBase
{
/* //////////////////////////// PUBLIC //////////////////////////////////// */
public:

   virtual
      ~OsSyncBase() { };

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

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

   OsSyncBase& operator=(const OsSyncBase& rhs);

   virtual OsStatus acquire(const OsTime& rTimeout = OsTime::OS_INFINITY) = 0;

   virtual OsStatus tryAcquire(void) = 0;
   virtual OsStatus release(void) = 0;

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

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

/* //////////////////////////// PROTECTED ///////////////////////////////// */
protected:

#ifdef OS_SYNC_DEBUG
   typedef enum
   {
      crumbUnused,   
      crumbCreated,  
      crumbAcquired, 
      crumbReleased, 
      crumbDeleted   
   } OsSyncOperation;
#endif

#  ifdef OS_SYNC_DEBUG

   class OsSyncCrumbs
   {
#    define NUMBER_OF_CRUMBS 6

     public:

      OsSyncCrumbs() :
         mCrumb(0)
      {
         mTrail[mCrumb].operation = crumbCreated;
         mTrail[mCrumb].taskId = 0; // default; parent constructor should call dropCrumb
         for ( unsigned int crumb=1; crumb < NUMBER_OF_CRUMBS; crumb++ )
         {
            mTrail[crumb].operation = crumbUnused;
            mTrail[crumb].taskId    = 0;
         }
      }
      
      void dropCrumb(int id, OsSyncOperation op)
      {
         mCrumb = (mCrumb + 1) % NUMBER_OF_CRUMBS;
         mTrail[mCrumb].operation = op;
         mTrail[mCrumb].taskId    = id;
         OsDateTime::getCurTime(mTrail[mCrumb].time);
      }
      
      ~OsSyncCrumbs()
      {
         // better if the destructor in the object calls, but make sure there is something.
         dropCrumb(0, crumbDeleted);
      }
      
     private:

      unsigned int mCrumb;  
      struct
      {         
         OsSyncOperation operation; 
         unsigned int    taskId;    
         OsTime          time;      
      } mTrail[NUMBER_OF_CRUMBS];
   } mSyncCrumbs;
   
#  endif

   OsSyncBase() { };

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

   OsSyncBase(const OsSyncBase& rOsSyncBase);

};

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

#endif  // _OsSyncBase_h_