p6lock.h

Go to the documentation of this file.

#ifndef P6LOCK_H__
#define P6LOCK_H__ 1

#include "p6com.h"
#include "p6filetypes.h"

#ifdef  __cplusplus
namespace P6R {
extern "C" {
#endif


   #undef INTERFACE
   #define INTERFACE p6ILock
   P6DECLAREIF_(p6ILock,p6ICom)
   {
      P6DECLCOMMETHOD(initialize)(P6THIS) P6PURE;
      P6DECLCOMMETHOD(lock)(P6THIS) P6PURE;
      P6DECLCOMMETHOD(unlock)(P6THIS) P6PURE;
   };
   #define IF_p6ILock  {0xD855D877,0x1196,0x4444,{0xAF,0x2B,0xA1,0x80,0x5C,0xA5,0x88,0x0B}}
   #define COMP_p6Lock {0xC6E9AC1E,0xAC4D,0x46c8,{0xAE,0xB7,0x76,0x8A,0xDD,0xD2,0x43,0x7C}}

   #undef INTERFACE
   #define INTERFACE p6IMonitor
   P6DECLAREIF_(p6IMonitor,p6ICom)
   {
      P6DECLCOMMETHOD(initialize)(P6THIS) P6PURE;

      P6DECLCOMMETHOD(lock)(P6THIS) P6PURE;

      P6DECLCOMMETHOD(unlock)(P6THIS) P6PURE;


      P6DECLCOMMETHOD(wait)(P6THIS) P6PURE;

      P6DECLCOMMETHOD(waitTimed)(P6THIS_ P6INTERVAL tTimeout) P6PURE;

      P6DECLCOMMETHOD(notify)(P6THIS) P6PURE;
      P6DECLCOMMETHOD(notifyAll)(P6THIS) P6PURE;
   };
   #define IF_p6IMonitor {0xAC0338DF,0x9B66,0x4c30,{0x89,0x4D,0x95,0x03,0x3B,0xD0,0xD6,0x82}}
   #define COMP_p6Monitor {0xDEE214DF,0xAA66,0x4c0c,{0xA2,0x11,0x41,0x4A,0xDB,0x8F,0xBF,0x8A}}


   #undef INTERFACE
   #define INTERFACE p6ICondvar
   P6DECLAREIF_(p6ICondvar,p6ICom)
   {
      P6DECLCOMMETHOD(initialize)(P6THIS_ p6ILock *pLock) P6PURE;

      P6DECLCOMMETHOD(wait)(P6THIS) P6PURE;


      P6DECLCOMMETHOD(waitTimed)(P6THIS_ P6INTERVAL tTimeout) P6PURE;

      P6DECLCOMMETHOD(notify)(P6THIS) P6PURE;

      P6DECLCOMMETHOD(notifyAll)(P6THIS) P6PURE;
   };
   // {F50FA083-1363-464C-8E25-F571966D366E}
   #define IF_p6ICondvar   {0xF50FA083,0x1363,0x464C,{0x8E,0x25,0xF5,0x71,0x96,0x6D,0x36,0x6E}}
   // {716C57F7-6A1C-41EC-8FB7-F20DC10B6D51}
   #define COMP_p6Condvar  {0x716C57F7,0x6A1C,0x41EC,{0x8F,0xB7,0xF2,0x0D,0xC1,0x0B,0x6D,0x51}}

   #undef INTERFACE
   #define INTERFACE p6IRWLock
   P6DECLAREIF_(p6IRWLock,p6ICom)
   {

      P6DECLCOMMETHOD(initialize)(P6THIS) P6PURE;
      P6DECLCOMMETHOD(readLock)(P6THIS) P6PURE;
      P6DECLCOMMETHOD(writeLock)(P6THIS) P6PURE;
      P6DECLCOMMETHOD(unlock)(P6THIS) P6PURE;
   };
   #define IF_p6IRWLock {0xE3FF0744,0x6679,0x4f90,{0xBA,0xDD,0x3A,0xB7,0xDB,0xE3,0xB6,0xEA}}
   #define COMP_p6RWLock {0x2A9246EA,0x6D01,0x42de,{0xAE,0xC9,0xDA,0x5B,0x66,0x19,0xF4,0xF5}}

   typedef enum {
      P6READ_LOCK    = 0,  
      P6WRITE_LOCK   = 1   
   } P6RWLOCKMODE;


   typedef enum {
      P6SF_NOFLAGS   = 0x00000000,
      P6SF_CREATE    = 0x00000001,
      P6SF_EXCLUSIVE = 0x00000002
   } P6SEMFLAG;

   #undef INTERFACE
   #define INTERFACE p6INamedSemaphore
   P6DECLAREIF_(p6INamedSemaphore,p6ICom)
   {
      P6DECLCOMMETHOD(initialize)(P6THIS) P6PURE;

      P6DECLCOMMETHOD(open)(P6THIS_ const P6WCHAR *pwszName,P6SEMFLAG flags,P6INT32 initialValue,P6FILEMODE nMode) P6PURE;

      P6DECLCOMMETHOD(post)(P6THIS) P6PURE;

      P6DECLCOMMETHOD(wait)(P6THIS) P6PURE;

      P6DECLCOMMETHOD(waitTimed)(P6THIS_ P6INTERVAL tTimeout) P6PURE;

      P6DECLCOMMETHOD(close)(P6THIS) P6PURE;

      P6DECLCOMMETHOD(remove)(P6THIS_ const P6WCHAR *pwszName) P6PURE;
   };

   // {C136A189-E7F4-4522-B96C-E84D40F88DC4}
   #define IF_p6INamedSemaphore {0xC136A189,0xE7F4,0x4522,{0xB9,0x6C,0xE8,0x4D,0x40,0xF8,0x8D,0xC4}}

   // {80CCAC2E-E5B1-446C-8018-039E9627BB9A}
   #define COMP_p6NamedSemaphore {0x80CCAC2E,0xE5B1,0x446C,{0x80,0x18,0x03,0x9E,0x96,0x27,0xBB,0x9A}}

#ifdef  __cplusplus
} // extern "C"
} // namespace
#endif


#ifdef  __cplusplus
namespace P6R {

   class P6NOEXPORT P6StackRWLock
   {
   public:
      P6StackRWLock(p6IRWLock *pLock,P6RWLOCKMODE mode) : m_pLock(pLock), m_mode(mode)
      {
         if(m_pLock) {
            m_pLock->addref();
            if(P6WRITE_LOCK == m_mode) {
                  m_pLock->writeLock();
            }
            else {
                  m_pLock->readLock();
            }
         }
      }
      ~P6StackRWLock()
      {
         if(m_pLock) {
            m_pLock->unlock();
            m_pLock->release();
            m_pLock = NULL;
         }
      }

   protected:
      p6IRWLock                      *m_pLock;
      P6RWLOCKMODE                   m_mode;

   private:
      P6StackRWLock& operator=(const P6StackRWLock &);
      P6StackRWLock(const P6StackRWLock &);
   };

   class P6NOEXPORT P6StackMonitor
   {
   public:
      P6StackMonitor(p6IMonitor *pLock) : m_pLock(pLock)
      { if(m_pLock) { m_pLock->addref(); m_pLock->lock();} }
      ~P6StackMonitor()
      { if(m_pLock) { m_pLock->unlock(); m_pLock->release(); } }

   protected:
      p6IMonitor                        *m_pLock;

   private:
      P6StackMonitor& operator=(const P6StackMonitor &);
      P6StackMonitor(const P6StackMonitor &);
   };

   class P6NOEXPORT P6StackLock
   {
   public:
      P6StackLock(p6ILock *pLock) : m_pLock(pLock)
      { if(m_pLock) { m_pLock->addref(); m_pLock->lock();} }
      ~P6StackLock()
      { if(m_pLock) { m_pLock->unlock(); m_pLock->release(); } }

   protected:
      p6ILock                           *m_pLock;

   private:
      P6StackLock& operator=(const P6StackLock &);
      P6StackLock(const P6StackLock &);
   };

} // namespace
#endif

#endif