ACE/protocols/ace/TMCast/Messaging.hpp

   1 // author    : Boris Kolpackov <boris@dre.vanderbilt.edu>
   2
   3 #ifndef TMCAST_MESSAGING_HPP
   4 #define TMCAST_MESSAGING_HPP
   5
   6 #include <ace/Synch.h>
   7 #include <ace/Bound_Ptr.h>
   8
   9 #include "MTQueue.hpp"
  10
  11 namespace ACE_TMCast
  12 {
  13   class Message
  14   {
  15   public:
  16     virtual
  17     ~Message () {}
  18   };
  19
  20   typedef
  21   ACE_Strong_Bound_Ptr<Message, ACE_SYNCH_MUTEX>
  22   MessagePtr;
  23
  24   typedef
  25   MTQueue<MessagePtr, ACE_Thread_Mutex, ACE_Condition<ACE_Thread_Mutex> >
  26   MessageQueue;
  27
  28   struct MessageQueueAutoLock
  29   {
  30     MessageQueueAutoLock (MessageQueue& q)
  31         : q_ (q)
  32     {
  33       q_.lock ();
  34     }
  35
  36     void
  37     unlock ()
  38     {
  39       q_.unlock ();
  40     }
  41
  42     ~MessageQueueAutoLock ()
  43     {
  44     q_.unlock ();
  45     }
  46
  47   private:
  48     MessageQueue& q_;
  49   };
  50 }
  51
  52 #endif // TMCAST_MESSAGING_HPP