summaryrefslogtreecommitdiff
path: root/examples/Connection/non_blocking/CPP-connector.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/Connection/non_blocking/CPP-connector.cpp')
-rw-r--r--examples/Connection/non_blocking/CPP-connector.cpp301
1 files changed, 0 insertions, 301 deletions
diff --git a/examples/Connection/non_blocking/CPP-connector.cpp b/examples/Connection/non_blocking/CPP-connector.cpp
deleted file mode 100644
index 04f9dacc5ce..00000000000
--- a/examples/Connection/non_blocking/CPP-connector.cpp
+++ /dev/null
@@ -1,301 +0,0 @@
-// $Id$
-
-#if !defined (CPP_CONNECTOR_C)
-#define CPP_CONNECTOR_C
-
-#include "CPP-connector.h"
-
-ACE_RCSID(non_blocking, CPP_connector, "$Id$")
-
-#define PR_ST_1 ACE_PEER_STREAM_1
-#define PR_ST_2 ACE_PEER_STREAM_2
-#define PR_CO_1 ACE_PEER_CONNECTOR_1
-#define PR_CO_2 ACE_PEER_CONNECTOR_2
-#define PR_AD ACE_PEER_CONNECTOR_ADDR
-#define SH SVC_HANDLER
-
-template <PR_ST_1>
-Peer_Handler<PR_ST_2>::Peer_Handler (ACE_Reactor *r)
- : action_ (&Peer_Handler<PR_ST_2>::uninitialized)
-{
- this->reactor (r);
-}
-
-template <PR_ST_1> int
-Peer_Handler<PR_ST_2>::open (void *)
-{
- ACE_DEBUG ((LM_DEBUG,
- "activating %d\n",
- this->peer ().get_handle ()));
- this->action_ = &Peer_Handler<PR_ST_2>::connected;
-
- ACE_DEBUG ((LM_DEBUG,
- "please enter input..: "));
-
- if (this->reactor ())
-
-#if defined (ACE_WIN32)
- // On Win32, the stdin HANDLE must be registered directly (and not
- // as a socket).
- this->reactor ()->register_handler (this,
- ACE_STDIN);
-#else
- // On non-Win32, the stdin HANDLE must be registered as a normal
- // handle with the <READ_Mask>.
- this->reactor ()->register_handler (ACE_STDIN,
- this,
- ACE_Event_Handler::READ_MASK);
-#endif /* ACE_WIN32 */
- else
- {
- while (this->connected () != -1)
- continue;
-
- this->handle_close (ACE_INVALID_HANDLE,
- ACE_Event_Handler::READ_MASK);
- }
- return 0;
-}
-
-template <PR_ST_1> int
-Peer_Handler<PR_ST_2>::uninitialized (void)
-{
- ACE_DEBUG ((LM_DEBUG,
- "uninitialized!\n"));
- return 0;
-}
-
-template <PR_ST_1> int
-Peer_Handler<PR_ST_2>::connected (void)
-{
- char buf[BUFSIZ];
-
- ssize_t n = ACE_OS::read (ACE_STDIN,
- buf,
- sizeof buf);
-
- if (n > 0
- && this->peer ().send_n (buf,
- n) != n)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "write failed"),
- -1);
- else if (n == 0)
- {
- // Explicitly close the connection.
- if (this->peer ().close () == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "close"),
- 1);
- return -1;
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG,
- "please enter input..: "));
- return 0;
- }
-}
-
-template <PR_ST_1> int
-Peer_Handler<PR_ST_2>::stdio (void)
-{
- char buf[BUFSIZ];
-
- ACE_DEBUG ((LM_DEBUG,
- "in stdio\nplease enter input..: "));
-
- ssize_t n = ACE_OS::read (ACE_STDIN,
- buf,
- sizeof buf);
- if (n > 0)
- {
- if (ACE_OS::write (ACE_STDOUT,
- buf,
- n) != n)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "write"),
- -1);
- return 0;
- }
- else
- return -1;
-}
-
-template <PR_ST_1> int
-Peer_Handler<PR_ST_2>::handle_output (ACE_HANDLE)
-{
- ACE_DEBUG ((LM_DEBUG,
- "in handle_output\n"));
-
- return (this->*action_) ();
-}
-
-template <PR_ST_1> int
-Peer_Handler<PR_ST_2>::handle_signal (int signum,
- siginfo_t *,
- ucontext_t *)
-{
- ACE_UNUSED_ARG (signum);
-
- // @@ Note that this code is not portable to all OS platforms since
- // it uses print statements within signal handler context.
- ACE_DEBUG ((LM_DEBUG,
- "in handle_signal\n"));
-
- return (this->*action_) ();
-}
-
-template <PR_ST_1> int
-Peer_Handler<PR_ST_2>::handle_input (ACE_HANDLE)
-{
- ACE_DEBUG ((LM_DEBUG,
- "in handle_input\n"));
-
- return (this->*action_) ();
-}
-
-template <PR_ST_1> int
-Peer_Handler<PR_ST_2>::handle_close (ACE_HANDLE h,
- ACE_Reactor_Mask mask)
-{
- ACE_DEBUG ((LM_DEBUG,
- "closing down handle %d with mask %d\n",
- h,
- mask));
-
- if (this->action_ == &Peer_Handler<PR_ST_2>::stdio)
- {
- ACE_DEBUG ((LM_DEBUG,
- "moving to closed state\n"));
- ACE_Reactor::end_event_loop ();
- }
- else
- {
- ACE_DEBUG ((LM_DEBUG,
- "moving to stdio state\n"));
- this->action_ = &Peer_Handler<PR_ST_2>::stdio;
- this->peer ().close ();
- ACE_OS::rewind (stdin);
-
- if (this->reactor ())
-#if defined (ACE_WIN32)
- // On Win32, the std handle must be registered directly (and not
- // as a socket)
- return this->reactor ()->register_handler (this,
- ACE_STDIN);
-#else
- // On non-Win32, the std handle must be registered as a normal
- // handle with the READ mask
- return this->reactor ()->register_handler (ACE_STDIN,
- this,
- ACE_Event_Handler::READ_MASK);
-#endif /* ACE_WIN32 */
- else
- delete this;
- }
-
- return 0;
-}
-
-template <class SH, PR_CO_1> int
-IPC_Client<SH, PR_CO_2>::svc (void)
-{
- if (this->reactor ())
- ACE_Reactor::run_event_loop ();
-
- return 0;
-}
-
-template <class SH, PR_CO_1> int
-IPC_Client<SH, PR_CO_2>::fini (void)
-{
- return 0;
-}
-
-template <class SH, PR_CO_1>
-IPC_Client<SH, PR_CO_2>::IPC_Client (void)
- : done_handler_ (ACE_Sig_Handler_Ex (ACE_Reactor::end_event_loop))
-{
-}
-
-template <class SH, PR_CO_1> int
-IPC_Client<SH, PR_CO_2>::init (int argc, char *argv[])
-{
- // Call down to the CONNECTOR's open() method to do the
- // initialization.
- this->inherited::open (ACE_Reactor::instance ());
-
- const char *r_addr = argc > 1 ? argv[1] :
- ACE_SERVER_ADDRESS (ACE_DEFAULT_SERVER_HOST,
- ACE_DEFAULT_SERVER_PORT_STR);
- ACE_Time_Value timeout (argc > 2
- ? ACE_OS::atoi (argv[2])
- : ACE_DEFAULT_TIMEOUT);
-
- // Handle signals through the ACE_Reactor.
- if (ACE_Reactor::instance ()->register_handler
- (SIGINT,
- &this->done_handler_) == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "register_handler"),
- -1);
- PR_AD remote_addr (r_addr);
- this->options_.set (ACE_Synch_Options::USE_REACTOR,
- timeout);
-
- SH *sh;
- ACE_NEW_RETURN (sh,
- SH (this->reactor ()),
- -1);
-
- // Connect to the peer.
- if (this->connect (sh,
- remote_addr,
- this->options_) == -1
- && errno != EWOULDBLOCK)
- ACE_ERROR_RETURN ((LM_ERROR,
- "%p\n",
- "connect"),
- -1);
- else
- return 0;
-}
-
-template <class SH, PR_CO_1>
-IPC_Client<SH, PR_CO_2>::~IPC_Client (void)
-{
-}
-
-template <class SH, PR_CO_1> int
-IPC_Client<SH, PR_CO_2>::handle_close (ACE_HANDLE h,
- ACE_Reactor_Mask)
-{
- if (h == ACE_INVALID_HANDLE)
- ACE_ERROR ((LM_ERROR,
- "%p on %d\n",
- "connection failed",
- h));
- else
- {
- // We are closing down the connector.
- ACE_DEBUG ((LM_DEBUG,
- "closing down IPC_Client\n"));
- this->inherited::handle_close ();
- }
-
- ACE_Reactor::end_event_loop();
- return 0;
-}
-
-#undef PR_ST_1
-#undef PR_ST_2
-#undef PR_CO_1
-#undef PR_CO_2
-#undef PR_AD
-#undef SH
-#endif /* CPP_CONNECTOR_C */
View Lorry Controller Status