diff options
Diffstat (limited to 'ACE/ace/IPC_SAP.cpp')
| -rw-r--r-- | ACE/ace/IPC_SAP.cpp | 193 |
1 files changed, 193 insertions, 0 deletions
diff --git a/ACE/ace/IPC_SAP.cpp b/ACE/ace/IPC_SAP.cpp new file mode 100644 index 00000000000..dbcdaf41977 --- /dev/null +++ b/ACE/ace/IPC_SAP.cpp @@ -0,0 +1,193 @@ +// $Id$ + +#include "ace/IPC_SAP.h" + +#include "ace/Log_Msg.h" +#include "ace/OS_NS_unistd.h" +#include "ace/os_include/os_signal.h" +#include "ace/OS_NS_errno.h" +#include "ace/OS_NS_fcntl.h" + +#if !defined (__ACE_INLINE__) +#include "ace/IPC_SAP.inl" +#endif /* __ACE_INLINE__ */ + + + +ACE_BEGIN_VERSIONED_NAMESPACE_DECL + +ACE_ALLOC_HOOK_DEFINE(ACE_IPC_SAP) + +void +ACE_IPC_SAP::dump (void) const +{ +#if defined (ACE_HAS_DUMP) + ACE_TRACE ("ACE_IPC_SAP::dump"); + + ACE_DEBUG ((LM_DEBUG, ACE_BEGIN_DUMP, this)); + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("handle_ = %d"), this->handle_)); + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("\npid_ = %d"), this->pid_)); + ACE_DEBUG ((LM_DEBUG, ACE_END_DUMP)); +#endif /* ACE_HAS_DUMP */ +} + +// Cache for the process ID. +pid_t ACE_IPC_SAP::pid_ = 0; + +// This is the do-nothing constructor. It does not perform a +// ACE_OS::socket system call. + +ACE_IPC_SAP::ACE_IPC_SAP (void) + : handle_ (ACE_INVALID_HANDLE) +{ + // ACE_TRACE ("ACE_IPC_SAP::ACE_IPC_SAP"); +} + +int +ACE_IPC_SAP::enable (int value) const +{ + ACE_TRACE ("ACE_IPC_SAP::enable"); + + // First-time in initialization. + if (ACE_IPC_SAP::pid_ == 0) + ACE_IPC_SAP::pid_ = ACE_OS::getpid (); + +#if defined (ACE_WIN32) || defined (ACE_VXWORKS) + switch (value) + { + case ACE_NONBLOCK: + { + // nonblocking argument (1) + // blocking: (0) + int nonblock = 1; + return ACE_OS::ioctl (this->handle_, + FIONBIO, + &nonblock); + } + default: + ACE_NOTSUP_RETURN (-1); + } +#else /* ! ACE_WIN32 && ! ACE_VXWORKS */ + switch (value) + { +#if defined (SIGURG) + case SIGURG: + case ACE_SIGURG: +#if defined (F_SETOWN) + return ACE_OS::fcntl (this->handle_, + F_SETOWN, + ACE_IPC_SAP::pid_); +#else + ACE_NOTSUP_RETURN (-1); +#endif /* F_SETOWN */ +#endif /* SIGURG */ +#if defined (SIGIO) + case SIGIO: + case ACE_SIGIO: +#if defined (F_SETOWN) && defined (FASYNC) + if (ACE_OS::fcntl (this->handle_, + F_SETOWN, + ACE_IPC_SAP::pid_) == -1 + || ACE::set_flags (this->handle_, + FASYNC) == -1) + return -1; + break; +#else + ACE_NOTSUP_RETURN (-1); +#endif /* F_SETOWN && FASYNC */ +#endif /* SIGIO <== */ +#if defined (F_SETFD) + case ACE_CLOEXEC: + // Enables the close-on-exec flag. + if (ACE_OS::fcntl (this->handle_, + F_SETFD, + 1) == -1) + return -1; + break; +#endif /* F_SETFD */ + case ACE_NONBLOCK: + if (ACE::set_flags (this->handle_, + ACE_NONBLOCK) == ACE_INVALID_HANDLE) + return -1; + break; + default: + return -1; + } + return 0; +#endif /* ! ACE_WIN32 && ! ACE_VXWORKS */ + + /* NOTREACHED */ +} + +int +ACE_IPC_SAP::disable (int value) const +{ + ACE_TRACE ("ACE_IPC_SAP::disable"); + +#if defined (ACE_WIN32) || defined (ACE_VXWORKS) + switch (value) + { + case ACE_NONBLOCK: + // nonblocking argument (1) + // blocking: (0) + { + int nonblock = 0; + return ACE_OS::ioctl (this->handle_, + FIONBIO, + &nonblock); + } + default: + ACE_NOTSUP_RETURN (-1); + } +#else /* ! ACE_WIN32 && ! ACE_VXWORKS */ + switch (value) + { +#if defined (SIGURG) + case SIGURG: + case ACE_SIGURG: +#if defined (F_SETOWN) + return ACE_OS::fcntl (this->handle_, + F_SETOWN, + 0); +#else + ACE_NOTSUP_RETURN (-1); +#endif /* F_SETOWN */ +#endif /* SIGURG */ +#if defined (SIGIO) + case SIGIO: + case ACE_SIGIO: +#if defined (F_SETOWN) && defined (FASYNC) + if (ACE_OS::fcntl (this->handle_, + F_SETOWN, + 0) == -1 + || ACE::clr_flags (this->handle_, + FASYNC) == -1) + return -1; + break; +#else + ACE_NOTSUP_RETURN (-1); +#endif /* F_SETOWN && FASYNC */ +#endif /* SIGIO <== */ +#if defined (F_SETFD) + case ACE_CLOEXEC: + // Disables the close-on-exec flag. + if (ACE_OS::fcntl (this->handle_, + F_SETFD, + 0) == -1) + return -1; + break; +#endif /* F_SETFD */ + case ACE_NONBLOCK: + if (ACE::clr_flags (this->handle_, + ACE_NONBLOCK) == -1) + return -1; + break; + default: + return -1; + } + return 0; +#endif /* ! ACE_WIN32 && ! ACE_VXWORKS */ + /* NOTREACHED */ +} + +ACE_END_VERSIONED_NAMESPACE_DECL |