ACE/ace/FIFO.cpp

   1 #include "ace/FIFO.h"
   2
   3 #if !defined (__ACE_INLINE__)
   4 #include "ace/FIFO.inl"
   5 #endif /* __ACE_INLINE__ */
   6
   7 #include "ace/Log_Category.h"
   8 #include "ace/OS_NS_string.h"
   9 #include "ace/OS_NS_errno.h"
  10 #include "ace/OS_NS_sys_stat.h"
  11 #include "ace/OS_NS_fcntl.h"
  12 #if defined (ACE_HAS_ALLOC_HOOKS)
  13 # include "ace/Malloc_Base.h"
  14 #endif /* ACE_HAS_ALLOC_HOOKS */
  15
  16 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  17
  18 ACE_ALLOC_HOOK_DEFINE(ACE_FIFO)
  19
  20 void
  21 ACE_FIFO::dump () const
  22 {
  23 #if defined (ACE_HAS_DUMP)
  24   ACE_TRACE ("ACE_FIFO::dump");
  25
  26   ACELIB_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this));
  27   ACELIB_DEBUG ((LM_DEBUG, ACE_TEXT ("rendezvous_ = %s"), this->rendezvous_));
  28   ACELIB_DEBUG ((LM_DEBUG, ACE_END_DUMP));
  29 #endif /* ACE_HAS_DUMP */
  30 }
  31
  32 int
  33 ACE_FIFO::open (const ACE_TCHAR *r, int flags, mode_t perms,
  34                 LPSECURITY_ATTRIBUTES sa)
  35 {
  36   ACE_TRACE ("ACE_FIFO::open");
  37   ACE_OS::strsncpy (this->rendezvous_, r, MAXPATHLEN);
  38
  39   if ((flags & O_CREAT) != 0
  40       && ACE_OS::mkfifo (this->rendezvous_, perms) == -1
  41       && !(errno == EEXIST))
  42     return -1;
  43
  44   this->set_handle (ACE_OS::open (this->rendezvous_, flags, 0, sa));
  45   return this->get_handle () == ACE_INVALID_HANDLE ? -1 : 0;
  46 }
  47
  48 ACE_FIFO::ACE_FIFO (const ACE_TCHAR *fifo_name,
  49                     int flags,
  50                     mode_t perms,
  51                     LPSECURITY_ATTRIBUTES sa)
  52 {
  53   ACE_TRACE ("ACE_FIFO::ACE_FIFO");
  54   if (this->open (fifo_name, flags, perms, sa) == -1)
  55     ACELIB_ERROR ((LM_ERROR,  ACE_TEXT ("%p\n"),  ACE_TEXT ("ACE_FIFO")));
  56 }
  57
  58 ACE_FIFO::ACE_FIFO ()
  59 {
  60 //  ACE_TRACE ("ACE_FIFO::ACE_FIFO");
  61 }
  62
  63 int
  64 ACE_FIFO::close ()
  65 {
  66   ACE_TRACE ("ACE_FIFO::close");
  67   int result = 0;
  68
  69   if (this->get_handle () != ACE_INVALID_HANDLE)
  70     {
  71       result = ACE_OS::close (this->get_handle ());
  72       this->set_handle (ACE_INVALID_HANDLE);
  73     }
  74  return result;
  75 }
  76
  77 ACE_END_VERSIONED_NAMESPACE_DECL