diff options
Diffstat (limited to 'ACE/ace/Message_Queue_NT.inl')
-rw-r--r-- | ACE/ace/Message_Queue_NT.inl | 131 |
1 files changed, 0 insertions, 131 deletions
diff --git a/ACE/ace/Message_Queue_NT.inl b/ACE/ace/Message_Queue_NT.inl deleted file mode 100644 index 6db82111d5b..00000000000 --- a/ACE/ace/Message_Queue_NT.inl +++ /dev/null @@ -1,131 +0,0 @@ -// -*- C++ -*- -// -// $Id$ - -#if defined (ACE_HAS_WIN32_OVERLAPPED_IO) -# include "ace/Guard_T.h" -#endif /* ACE_HAS_WIN32_OVERLAPPED_IO */ - -ACE_BEGIN_VERSIONED_NAMESPACE_DECL - -#if defined (ACE_HAS_WIN32_OVERLAPPED_IO) - -ACE_INLINE int -ACE_Message_Queue_NT::enqueue_tail (ACE_Message_Block *new_item, - ACE_Time_Value *timeout) -{ - ACE_TRACE ("ACE_Message_Queue_NT::enqueue_tail"); - return this->enqueue (new_item, timeout); -} - -ACE_INLINE int -ACE_Message_Queue_NT::dequeue_head (ACE_Message_Block *&first_item, - ACE_Time_Value *timeout) -{ - ACE_TRACE ("ACE_Message_Queue_NT::dequeue_head"); - return this->dequeue (first_item, timeout); -} - -ACE_INLINE bool -ACE_Message_Queue_NT::is_full (void) -{ - ACE_TRACE ("ACE_Message_Queue_NT::is_full"); - return false; // Always not full. -} - -ACE_INLINE bool -ACE_Message_Queue_NT::is_empty (void) -{ - ACE_TRACE ("ACE_Message_Queue_NT::is_empty"); - ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, ace_mon, this->lock_, false); - - return this->cur_bytes_ > 0 || this->cur_count_ > 0 ? false : true; -} - -ACE_INLINE size_t -ACE_Message_Queue_NT::message_bytes (void) -{ - ACE_TRACE ("ACE_Message_Queue_NT::message_bytes"); - // Accessing to size_t must be atomic. - return this->cur_bytes_; -} - -ACE_INLINE size_t -ACE_Message_Queue_NT::message_length (void) -{ - ACE_TRACE ("ACE_Message_Queue_NT::message_length"); - // Accessing to size_t must be atomic. - return this->cur_length_; -} - -ACE_INLINE size_t -ACE_Message_Queue_NT::message_count (void) -{ - ACE_TRACE ("ACE_Message_Queue_NT::message_count"); - // Accessing to size_t must be atomic. - return this->cur_count_; -} - -ACE_INLINE void -ACE_Message_Queue_NT::message_bytes (size_t new_value) -{ - ACE_TRACE ("ACE_Message_Queue_NT::message_bytes"); - ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, this->lock_); - - this->cur_bytes_ = new_value; -} - -ACE_INLINE void -ACE_Message_Queue_NT::message_length (size_t new_value) -{ - ACE_TRACE ("ACE_Message_Queue_NT::message_length"); - ACE_GUARD (ACE_SYNCH_MUTEX, ace_mon, this->lock_); - - this->cur_length_ = new_value; -} - -ACE_INLINE DWORD -ACE_Message_Queue_NT::max_threads (void) -{ - ACE_TRACE ("ACE_Message_Queue_NT::max_threads"); - return this->max_cthrs_; -} - -ACE_INLINE int -ACE_Message_Queue_NT::deactivated (void) -{ - ACE_TRACE ("ACE_Message_Queue_NT::deactivated"); - // Accessing to int must be atomic. - return this->state_ == ACE_Message_Queue_Base::DEACTIVATED; -} - -ACE_INLINE ACE_HANDLE -ACE_Message_Queue_NT::completion_port (void) -{ - ACE_TRACE ("ACE_Message_Queue_NT::completion_port"); - return this->completion_port_; -} - -ACE_INLINE int -ACE_Message_Queue_NT::peek_dequeue_head (ACE_Message_Block *&first_item, - ACE_Time_Value *timeout) -{ - ACE_UNUSED_ARG(first_item); - ACE_UNUSED_ARG(timeout); - ACE_NOTSUP_RETURN (-1); -} - -ACE_INLINE ACE_Notification_Strategy * -ACE_Message_Queue_NT::notification_strategy (void) -{ - ACE_NOTSUP_RETURN (0); -} - -ACE_INLINE void -ACE_Message_Queue_NT::notification_strategy (ACE_Notification_Strategy *) -{ -} - -#endif /* ACE_HAS_WIN32_OVERLAPPED_IO */ - -ACE_END_VERSIONED_NAMESPACE_DECL |