summaryrefslogtreecommitdiff
path: root/examples/Reactor/FIFO/server.cpp
diff options
context:
space:
mode:
authornobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2003-04-10 19:59:37 +0000
committernobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2003-04-10 19:59:37 +0000
commit3df4acfa816441fc28a95dee6d0191a927145d95 (patch)
treeb5ae7ca44662cfd8e5c95f1826e4406021a606f5 /examples/Reactor/FIFO/server.cpp
parent60a5612b83d856fc0adc52b9f39fac9960ec9818 (diff)
downloadATCD-pre-subset.tar.gz
This commit was manufactured by cvs2svn to create tag 'pre-subset'.pre-subset
Diffstat (limited to 'examples/Reactor/FIFO/server.cpp')
-rw-r--r--examples/Reactor/FIFO/server.cpp85
1 files changed, 0 insertions, 85 deletions
diff --git a/examples/Reactor/FIFO/server.cpp b/examples/Reactor/FIFO/server.cpp
deleted file mode 100644
index 3147cf74a74..00000000000
--- a/examples/Reactor/FIFO/server.cpp
+++ /dev/null
@@ -1,85 +0,0 @@
-// $Id$
-
-#include "ace/Service_Config.h"
-#include "ace/FIFO_Recv_Msg.h"
-#include "ace/Log_Msg.h"
-
-ACE_RCSID(FIFO, server, "$Id$")
-
-class FIFO_Recv_Handler : public ACE_Event_Handler
-{
-public:
- FIFO_Recv_Handler (void);
- ~FIFO_Recv_Handler (void);
-
- virtual ACE_HANDLE get_handle (void) const;
- virtual int handle_input (ACE_HANDLE fd);
-
-private:
- ACE_FIFO_Recv_Msg fifo_reader_;
-};
-
-FIFO_Recv_Handler::FIFO_Recv_Handler (void)
-{
- ACE_OS::unlink (ACE_DEFAULT_RENDEZVOUS);
-
- // Make sure to open the FIFO with the "persistent" flag enabled
- // (which is the default).
- if (this->fifo_reader_.open (ACE_DEFAULT_RENDEZVOUS) == -1)
- ACE_ERROR ((LM_ERROR, "%p\n", "open"));
-
- // Register with the Reactor.
- if (ACE_Reactor::instance ()->register_handler
- (this, ACE_Event_Handler::READ_MASK) == -1)
- ACE_ERROR ((LM_ERROR, "%p\n", "register_handler"));
-}
-
-ACE_HANDLE
-FIFO_Recv_Handler::get_handle (void) const
-{
- return this->fifo_reader_.get_handle ();
-}
-
-FIFO_Recv_Handler::~FIFO_Recv_Handler (void)
-{
- this->fifo_reader_.close ();
- this->fifo_reader_.remove ();
-}
-
-int
-FIFO_Recv_Handler::handle_input (ACE_HANDLE)
-{
- char buf[BUFSIZ];
-
- ACE_DEBUG ((LM_DEBUG, "handle_input\n"));
-
- ACE_Str_Buf msg (buf, 0, sizeof buf);
-
- ssize_t n = this->fifo_reader_.recv (msg);
-
- if (n < 0)
- ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "recv"), -1);
- else
- {
- ACE_DEBUG ((LM_DEBUG, "msg.len = %d, n = %d\n", msg.len, n));
-
- if (msg.len > 0)
- {
- // Do some work in here...
- ACE_DEBUG ((LM_DEBUG, "msg.buf = %s\n", msg.buf));
- }
- return 0;
- }
-}
-
-int
-main (int, char *argv[])
-{
- ACE_Service_Config daemon (argv[0]);
-
- FIFO_Recv_Handler fr_handler;
-
- ACE_Reactor::run_event_loop ();
-
- return 0;
-}