ACE/ace/Message_Queue_NT.inl

   1 // -*- C++ -*-
   2 #if defined (ACE_HAS_WIN32_OVERLAPPED_IO)
   3 #  include "ace/Guard_T.h"
   4 #endif /* ACE_HAS_WIN32_OVERLAPPED_IO */
   5
   6 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   7
   8 #if defined (ACE_HAS_WIN32_OVERLAPPED_IO)
   9
  10 ACE_INLINE int
  11 ACE_Message_Queue_NT::enqueue_tail (ACE_Message_Block *new_item,
  12                                     ACE_Time_Value *timeout)
  13 {
  14   ACE_TRACE ("ACE_Message_Queue_NT::enqueue_tail");
  15   return this->enqueue (new_item, timeout);
  16 }
  17
  18 ACE_INLINE int
  19 ACE_Message_Queue_NT::dequeue_head (ACE_Message_Block *&first_item,
  20                                     ACE_Time_Value *timeout)
  21 {
  22   ACE_TRACE ("ACE_Message_Queue_NT::dequeue_head");
  23   return this->dequeue (first_item, timeout);
  24 }
  25
  26 ACE_INLINE bool
  27 ACE_Message_Queue_NT::is_full ()
  28 {
  29   ACE_TRACE ("ACE_Message_Queue_NT::is_full");
  30   return false; // Always not full.
  31 }
  32
  33 ACE_INLINE bool
  34 ACE_Message_Queue_NT::is_empty ()
  35 {
  36   ACE_TRACE ("ACE_Message_Queue_NT::is_empty");
  37   ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, ace_mon, this->lock_, false);
  38
  39   return this->cur_bytes_ > 0 || this->cur_count_ > 0 ? false : true;
  40 }
  41
  42 ACE_INLINE size_t
  43 ACE_Message_Queue_NT::message_bytes ()
  44 {
  45   ACE_TRACE ("ACE_Message_Queue_NT::message_bytes");
  46   // Accessing to size_t must be atomic.
  47   return this->cur_bytes_;
  48 }
  49
  50 ACE_INLINE size_t
  51 ACE_Message_Queue_NT::message_length ()
  52 {
  53   ACE_TRACE ("ACE_Message_Queue_NT::message_length");
  54   // Accessing to size_t must be atomic.
  55   return this->cur_length_;
  56 }
  57
  58 ACE_INLINE size_t
  59 ACE_Message_Queue_NT::message_count ()
  60 {
  61   ACE_TRACE ("ACE_Message_Queue_NT::message_count");
  62   // Accessing to size_t must be atomic.
  63   return this->cur_count_;
  64 }
  65
  66 ACE_INLINE void
  67 ACE_Message_Queue_NT::message_bytes (size_t new_value)
  68 {
  69   ACE_TRACE ("ACE_Message_Queue_NT::message_bytes");
  70   ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, this->lock_);
  71
  72   this->cur_bytes_ = new_value;
  73 }
  74
  75 ACE_INLINE void
  76 ACE_Message_Queue_NT::message_length (size_t new_value)
  77 {
  78   ACE_TRACE ("ACE_Message_Queue_NT::message_length");
  79   ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, this->lock_);
  80
  81   this->cur_length_ = new_value;
  82 }
  83
  84 ACE_INLINE DWORD
  85 ACE_Message_Queue_NT::max_threads ()
  86 {
  87   ACE_TRACE ("ACE_Message_Queue_NT::max_threads");
  88   return this->max_cthrs_;
  89 }
  90
  91 ACE_INLINE int
  92 ACE_Message_Queue_NT::deactivated ()
  93 {
  94   ACE_TRACE ("ACE_Message_Queue_NT::deactivated");
  95   // Accessing to int must be atomic.
  96   return this->state_ == ACE_Message_Queue_Base::DEACTIVATED;
  97 }
  98
  99 ACE_INLINE ACE_HANDLE
 100 ACE_Message_Queue_NT::completion_port ()
 101 {
 102   ACE_TRACE ("ACE_Message_Queue_NT::completion_port");
 103   return this->completion_port_;
 104 }
 105
 106 ACE_INLINE int
 107 ACE_Message_Queue_NT::peek_dequeue_head (ACE_Message_Block *&first_item,
 108                                          ACE_Time_Value *timeout)
 109 {
 110   ACE_UNUSED_ARG(first_item);
 111   ACE_UNUSED_ARG(timeout);
 112   ACE_NOTSUP_RETURN (-1);
 113 }
 114
 115 ACE_INLINE ACE_Notification_Strategy *
 116 ACE_Message_Queue_NT::notification_strategy ()
 117 {
 118   ACE_NOTSUP_RETURN (0);
 119 }
 120
 121 ACE_INLINE void
 122 ACE_Message_Queue_NT::notification_strategy (ACE_Notification_Strategy *)
 123 {
 124 }
 125
 126 #endif /* ACE_HAS_WIN32_OVERLAPPED_IO */
 127
 128 ACE_END_VERSIONED_NAMESPACE_DECL