ACE/ace/SV_Message_Queue.inl

   1 // -*- C++ -*-
   2 #include "ace/Global_Macros.h"
   3 #include "ace/OS_NS_sys_msg.h"
   4
   5 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
   6
   7 // Open a message queue using the <external_id>.
   8
   9 ACE_INLINE int
  10 ACE_SV_Message_Queue::open (key_t external_id, int create, int perms)
  11 {
  12   ACE_TRACE ("ACE_SV_Message_Queue::open");
  13   return this->internal_id_ = ACE_OS::msgget (external_id, create | perms);
  14 }
  15
  16 // What does it mean to close a message queue?!
  17
  18 ACE_INLINE int
  19 ACE_SV_Message_Queue::close ()
  20 {
  21   ACE_TRACE ("ACE_SV_Message_Queue::close");
  22   this->internal_id_ = -1;
  23   return 1;
  24 }
  25
  26 ACE_INLINE int
  27 ACE_SV_Message_Queue::control (int option, void *arg)
  28 {
  29   ACE_TRACE ("ACE_SV_Message_Queue::control");
  30   return ACE_OS::msgctl (this->internal_id_, option,
  31                          (struct msqid_ds *) arg);
  32 }
  33
  34 ACE_INLINE int
  35 ACE_SV_Message_Queue::remove ()
  36 {
  37   ACE_TRACE ("ACE_SV_Message_Queue::remove");
  38   int const result = this->control (IPC_RMID);
  39   this->internal_id_ = -1;
  40   return result;
  41 }
  42
  43 ACE_INLINE int
  44 ACE_SV_Message_Queue::get_id () const
  45 {
  46   ACE_TRACE ("ACE_SV_Message_Queue::get_id");
  47   return this->internal_id_;
  48 }
  49
  50 ACE_INLINE void
  51 ACE_SV_Message_Queue::set_id (int id)
  52 {
  53   ACE_TRACE ("ACE_SV_Message_Queue::set_id");
  54   this->internal_id_ = id;
  55 }
  56
  57 ACE_INLINE ssize_t
  58 ACE_SV_Message_Queue::recv (ACE_SV_Message &mb,
  59                             int length,
  60                             long type,
  61                             int mflags)
  62 {
  63   ACE_TRACE ("ACE_SV_Message_Queue::recv");
  64   return ACE_OS::msgrcv (this->internal_id_, (void *) &mb,
  65                          length, type, mflags);
  66 }
  67
  68 ACE_INLINE int
  69 ACE_SV_Message_Queue::send (const ACE_SV_Message &mb,
  70                             int length,
  71                             int mflags)
  72 {
  73   ACE_TRACE ("ACE_SV_Message_Queue::send");
  74   return ACE_OS::msgsnd (this->internal_id_, (void *) &mb,
  75                          length, mflags);
  76 }
  77
  78 ACE_END_VERSIONED_NAMESPACE_DECL