diff options
author | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1996-10-21 21:41:34 +0000 |
---|---|---|
committer | levine <levine@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 1996-10-21 21:41:34 +0000 |
commit | a5fdebc5f6375078ec1763850a4ca23ec7fe6458 (patch) | |
tree | bcf0a25c3d45a209a6e3ac37b233a4812f29c732 /ace/Typed_SV_Message_Queue.i | |
download | ATCD-a5fdebc5f6375078ec1763850a4ca23ec7fe6458.tar.gz |
Initial revision
Diffstat (limited to 'ace/Typed_SV_Message_Queue.i')
-rw-r--r-- | ace/Typed_SV_Message_Queue.i | 63 |
1 files changed, 63 insertions, 0 deletions
diff --git a/ace/Typed_SV_Message_Queue.i b/ace/Typed_SV_Message_Queue.i new file mode 100644 index 00000000000..9dcbb07075c --- /dev/null +++ b/ace/Typed_SV_Message_Queue.i @@ -0,0 +1,63 @@ +/* -*- C++ -*- */ +// $Id$ + +// Typed_SV_Message_Queue.i + +#include "ace/SV_Message_Queue.h" +#include "ace/Log_Msg.h" + +template <class T> ACE_INLINE int +ACE_Typed_SV_Message_Queue<T>::open (key_t external_id, + int create, + int perms) +{ + ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::open"); + return this->message_queue_.open (external_id, create, perms); +} + +/* What does it mean to close a message queue?! */ + +template <class T> ACE_INLINE int +ACE_Typed_SV_Message_Queue<T>::close (void) +{ + ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::close"); + return 1; +} + +template <class T> ACE_INLINE int +ACE_Typed_SV_Message_Queue<T>::recv (ACE_Typed_SV_Message<T> &mb, + int mflags) +{ + ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::recv"); + int length = this->message_queue_.recv ((ACE_SV_Message &) mb, + mb.max_size (), mb.type (), mflags); + + if (length != -1) + mb.length (length); + + return length; +} + +template <class T> ACE_INLINE int +ACE_Typed_SV_Message_Queue<T>::send (const ACE_Typed_SV_Message<T> &mb, + int mflags) +{ + ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::send"); + return this->message_queue_.send ((ACE_SV_Message &) mb, + mb.length (), mflags); +} + +template <class T> ACE_INLINE int +ACE_Typed_SV_Message_Queue<T>::remove (void) +{ + ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::remove"); + return this->message_queue_.remove (); +} + +template <class T> ACE_INLINE int +ACE_Typed_SV_Message_Queue<T>::control (int option, + void *arg) +{ + ACE_TRACE ("ACE_Typed_SV_Message_Queue<T>::control"); + return this->message_queue_.control (option, arg); +} |