mirror of
https://github.com/mangosfour/server.git
synced 2025-12-13 13:37:05 +00:00
131 lines
3.1 KiB
C++
131 lines
3.1 KiB
C++
// -*- C++ -*-
|
|
//
|
|
// $Id: Message_Queue_NT.inl 80826 2008-03-04 14:51:23Z wotte $
|
|
|
|
#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
|