ACE/ace/SPIPE.cpp

   1 #include "ace/SPIPE.h"
   2
   3 #include "ace/OS_NS_unistd.h"
   4
   5 #if defined (ACE_HAS_ALLOC_HOOKS)
   6 # include "ace/Malloc_Base.h"
   7 #endif /* ACE_HAS_ALLOC_HOOKS */
   8
   9 #if !defined (__ACE_INLINE__)
  10 #include "ace/SPIPE.inl"
  11 #endif /* __ACE_INLINE__ */
  12
  13
  14
  15 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  16
  17 ACE_ALLOC_HOOK_DEFINE(ACE_SPIPE)
  18
  19 // This is the do-nothing constructor.
  20
  21 ACE_SPIPE::ACE_SPIPE (void)
  22 {
  23   // ACE_TRACE ("ACE_SPIPE::ACE_SPIPE");
  24 }
  25
  26 void
  27 ACE_SPIPE::dump (void) const
  28 {
  29 #if defined (ACE_HAS_DUMP)
  30   ACE_TRACE ("ACE_SPIPE::dump");
  31 #endif /* ACE_HAS_DUMP */
  32 }
  33
  34 // Close down a ACE_SPIPE.
  35
  36 int
  37 ACE_SPIPE::get_local_addr (ACE_SPIPE_Addr &local_sap) const
  38 {
  39   ACE_TRACE ("ACE_SPIPE::get_local_addr");
  40   local_sap = this->local_addr_;
  41   return 0;
  42 }
  43
  44 // Close down the STREAM pipe without removing the rendezvous point.
  45
  46 int
  47 ACE_SPIPE::close (void)
  48 {
  49   ACE_TRACE ("ACE_SPIPE::close");
  50   int result = 0;
  51
  52   if (this->get_handle () != ACE_INVALID_HANDLE)
  53     {
  54       result = ACE_OS::close (this->get_handle ());
  55 #if defined (ACE_HAS_STREAM_PIPES)
  56       result = (ACE_OS::close (duplex_pipe_handle_) || result);
  57 #endif /* ACE_HAS_STREAM_PIPES */
  58       this->set_handle (ACE_INVALID_HANDLE);
  59     }
  60   return result;
  61 }
  62
  63 // Close down the STREAM pipe and remove the rendezvous point from the
  64 // file system.
  65
  66 int
  67 ACE_SPIPE::remove (void)
  68 {
  69   ACE_TRACE ("ACE_SPIPE::remove");
  70   int result = this->close ();
  71   return ACE_OS::unlink (this->local_addr_.get_path_name ()) == -1 || result == -1 ? -1 : 0;
  72 }
  73
  74 #if defined (ACE_HAS_STREAM_PIPES)
  75 /// Temporary store of duplex pipe handle.
  76 void
  77 ACE_SPIPE::set_duplex_handle (ACE_HANDLE handle)
  78 {
  79   ACE_TRACE ("ACE_SPIPE::set_duplex_handle");
  80   this->duplex_pipe_handle_ = handle;
  81 }
  82 #endif /* ACE_HAS_STREAM_PIPES */
  83
  84 ACE_END_VERSIONED_NAMESPACE_DECL