diff options
Diffstat (limited to 'dep/ACE_wrappers/ace/FIFO.cpp')
| -rw-r--r-- | dep/ACE_wrappers/ace/FIFO.cpp | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/dep/ACE_wrappers/ace/FIFO.cpp b/dep/ACE_wrappers/ace/FIFO.cpp index 80342f65f01..c5ace7f90d9 100644 --- a/dep/ACE_wrappers/ace/FIFO.cpp +++ b/dep/ACE_wrappers/ace/FIFO.cpp @@ -1,39 +1,51 @@ // $Id: FIFO.cpp 80826 2008-03-04 14:51:23Z wotte $ + #include "ace/FIFO.h" + #if !defined (__ACE_INLINE__) #include "ace/FIFO.inl" #endif /* __ACE_INLINE__ */ + #include "ace/Log_Msg.h" #include "ace/OS_NS_string.h" #include "ace/OS_NS_errno.h" #include "ace/OS_NS_sys_stat.h" #include "ace/OS_NS_fcntl.h" + ACE_RCSID(ace, FIFO, "$Id: FIFO.cpp 80826 2008-03-04 14:51:23Z wotte $") + ACE_BEGIN_VERSIONED_NAMESPACE_DECL + ACE_ALLOC_HOOK_DEFINE(ACE_FIFO) + void ACE_FIFO::dump (void) const { #if defined (ACE_HAS_DUMP) ACE_TRACE ("ACE_FIFO::dump"); + ACE_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this)); ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("rendezvous_ = %s"), this->rendezvous_)); ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP)); #endif /* ACE_HAS_DUMP */ } + int ACE_FIFO::open (const ACE_TCHAR *r, int flags, mode_t perms, LPSECURITY_ATTRIBUTES sa) { ACE_TRACE ("ACE_FIFO::open"); ACE_OS::strsncpy (this->rendezvous_, r, MAXPATHLEN); + if ((flags & O_CREAT) != 0 && ACE_OS::mkfifo (this->rendezvous_, perms) == -1 && !(errno == EEXIST)) return -1; + this->set_handle (ACE_OS::open (this->rendezvous_, flags, 0, sa)); return this->get_handle () == ACE_INVALID_HANDLE ? -1 : 0; } + ACE_FIFO::ACE_FIFO (const ACE_TCHAR *fifo_name, int flags, mode_t perms, @@ -43,15 +55,18 @@ ACE_FIFO::ACE_FIFO (const ACE_TCHAR *fifo_name, if (this->open (fifo_name, flags, perms, sa) == -1) ACE_ERROR ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("ACE_FIFO"))); } + ACE_FIFO::ACE_FIFO (void) { // ACE_TRACE ("ACE_FIFO::ACE_FIFO"); } + int ACE_FIFO::close (void) { ACE_TRACE ("ACE_FIFO::close"); int result = 0; + if (this->get_handle () != ACE_INVALID_HANDLE) { result = ACE_OS::close (this->get_handle ()); @@ -59,5 +74,6 @@ ACE_FIFO::close (void) } return result; } + ACE_END_VERSIONED_NAMESPACE_DECL |