diff options
Diffstat (limited to 'ace/FIFO_Recv.cpp')
| -rw-r--r-- | ace/FIFO_Recv.cpp | 25 |
1 files changed, 19 insertions, 6 deletions
diff --git a/ace/FIFO_Recv.cpp b/ace/FIFO_Recv.cpp index 3add4e66072..acf85b81058 100644 --- a/ace/FIFO_Recv.cpp +++ b/ace/FIFO_Recv.cpp @@ -23,6 +23,7 @@ ACE_FIFO_Recv::close (void) { ACE_TRACE ("ACE_FIFO_Recv::close"); int result = ACE_FIFO::close (); + if (this->aux_handle_ != ACE_INVALID_HANDLE) return ACE_OS::close (this->aux_handle_); else @@ -34,29 +35,41 @@ ACE_FIFO_Recv::close (void) // aren't any writers at the moment! int -ACE_FIFO_Recv::open (const char *fifo_name, int flags, int perms, int persistent) +ACE_FIFO_Recv::open (const char *fifo_name, + int flags, + int perms, + int persistent) { ACE_TRACE ("ACE_FIFO_Recv::open"); + if (ACE_FIFO::open (fifo_name, ACE_NONBLOCK | flags, perms) == -1) return -1; else if (this->disable (ACE_NONBLOCK) == -1) return -1; - else if (persistent && (this->aux_handle_ = - ACE_OS::open (fifo_name, O_WRONLY)) == ACE_INVALID_HANDLE) + else if (persistent + && (this->aux_handle_ = ACE_OS::open (fifo_name, O_WRONLY)) == ACE_INVALID_HANDLE) return -1; else return this->get_handle () == ACE_INVALID_HANDLE ? -1 : 0; } -ACE_FIFO_Recv::ACE_FIFO_Recv (void): aux_handle_ (ACE_INVALID_HANDLE) +ACE_FIFO_Recv::ACE_FIFO_Recv (void) + : aux_handle_ (ACE_INVALID_HANDLE) { ACE_TRACE ("ACE_FIFO_Recv::ACE_FIFO_Recv"); } -ACE_FIFO_Recv::ACE_FIFO_Recv (const char *fifo_name, int flags, int perms, int persistent) +ACE_FIFO_Recv::ACE_FIFO_Recv (const char *fifo_name, + int flags, + int perms, + int persistent) { ACE_TRACE ("ACE_FIFO_Recv::ACE_FIFO_Recv"); - if (this->ACE_FIFO_Recv::open (fifo_name, flags, perms, persistent) == -1) + + if (this->ACE_FIFO_Recv::open (fifo_name, + flags, + perms, + persistent) == -1) ACE_ERROR ((LM_ERROR, "%p\n", "ACE_FIFO_Recv")); } |