summaryrefslogtreecommitdiff
path: root/ace/IPC/FIFO_Recv_Msg.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ace/IPC/FIFO_Recv_Msg.cpp')
-rw-r--r--ace/IPC/FIFO_Recv_Msg.cpp61
1 files changed, 61 insertions, 0 deletions
diff --git a/ace/IPC/FIFO_Recv_Msg.cpp b/ace/IPC/FIFO_Recv_Msg.cpp
new file mode 100644
index 00000000000..714cc43986f
--- /dev/null
+++ b/ace/IPC/FIFO_Recv_Msg.cpp
@@ -0,0 +1,61 @@
+// FIFO_Recv_Msg.cpp
+// $Id$
+
+#include "ace/FIFO_Recv_Msg.h"
+#include "ace/Log_Msg.h"
+
+#if defined (ACE_LACKS_INLINE_FUNCTIONS)
+#include "ace/FIFO_Recv_Msg.i"
+#endif
+
+ACE_RCSID(ace, FIFO_Recv_Msg, "$Id$")
+
+ACE_ALLOC_HOOK_DEFINE(ACE_FIFO_Recv_Msg)
+
+void
+ACE_FIFO_Recv_Msg::dump (void) const
+{
+ ACE_TRACE ("ACE_FIFO_Recv_Msg::dump");
+ ACE_FIFO_Recv::dump ();
+}
+
+// Note that persistent means "open FIFO for writing, as well as
+// reading." This ensures that the FIFO never gets EOF, even if there
+// aren't any writers at the moment!
+
+int
+ACE_FIFO_Recv_Msg::open (const ACE_TCHAR *fifo_name,
+ int flags,
+ int perms,
+ int persistent,
+ LPSECURITY_ATTRIBUTES sa)
+{
+ ACE_TRACE ("ACE_FIFO_Recv_Msg::open");
+
+ return ACE_FIFO_Recv::open (fifo_name,
+ flags,
+ perms,
+ persistent,
+ sa);
+}
+
+ACE_FIFO_Recv_Msg::ACE_FIFO_Recv_Msg (void)
+{
+ ACE_TRACE ("ACE_FIFO_Recv_Msg::ACE_FIFO_Recv_Msg");
+}
+
+ACE_FIFO_Recv_Msg::ACE_FIFO_Recv_Msg (const ACE_TCHAR *fifo_name,
+ int flags,
+ int perms,
+ int persistent,
+ LPSECURITY_ATTRIBUTES sa)
+{
+ ACE_TRACE ("ACE_FIFO_Recv_Msg::ACE_FIFO_Recv_Msg");
+
+ if (this->ACE_FIFO_Recv_Msg::open (fifo_name,
+ flags,
+ perms,
+ persistent,
+ sa) == -1)
+ ACE_ERROR ((LM_ERROR, ACE_LIB_TEXT ("%p\n"), ACE_LIB_TEXT ("ACE_FIFO_Recv_Msg")));
+}