This commit was manufactured by cvs2svn to create tag 'TAO-1_4_2'.TAO-1_4_2

1 files changed, 0 insertions, 247 deletions

diff --git a/examples/ASX/Event_Server/Transceiver/transceiver.cpp b/examples/ASX/Event_Server/Transceiver/transceiver.cpp
deleted file mode 100644
index 45ee10e72eb..00000000000
--- a/examples/ASX/Event_Server/Transceiver/transceiver.cpp
+++ /dev/null
@@ -1,247 +0,0 @@
-// $Id$
-
-// Test program for the event transceiver.  This program can play the
-// role of either Consumer or Supplier.  You can terminate this
-// program by typing ^C....
-
-#include "ace/OS_NS_string.h"
-#include "ace/Service_Config.h"
-#include "ace/SOCK_Connector.h"
-#include "ace/Connector.h"
-#include "ace/Get_Opt.h"
-#include "ace/Signal.h"
-
-#include "transceiver.h"
-
-ACE_RCSID(Transceiver, transceiver, "$Id$")
-
-// Handle the command-line arguments.
-
-int
-Event_Transceiver::parse_args (int argc, char *argv[])
-{
-  ACE_Get_Opt get_opt (argc, argv, "Ch:p:S");
-
-  this->port_number_ = ACE_DEFAULT_SERVER_PORT;
-  this->host_name_ = ACE_DEFAULT_SERVER_HOST;
-  this->role_ = "Supplier";
-
-  for (int c; (c = get_opt ()) != -1; )
-    switch (c)
-      {
-      case 'C':
-        this->role_ = "Consumer";
-        break;
-      case 'h':
-        this->host_name_ = get_opt.opt_arg ();
-        break;
-      case 'p':
-        this->port_number_ = ACE_OS::atoi (get_opt.opt_arg ());
-        break;
-      case 'S':
-        this->role_ = "Supplier";
-        break;
-      default:
-        ACE_ERROR_RETURN ((LM_ERROR,
-                           "usage: %n [-CS] [-h host_name] [-p portnum] \n"),
-                          -1);
-        /* NOTREACHED */
-        break;
-      }
-
-  // Increment by 1 if we're the supplier to mirror the default
-  // behavior of the Event_Server (which sets the Consumer port to
-  // ACE_DEFAULT_SERVER_PORT and the Supplier port to
-  // ACE_DEFAULT_SERVER_PORT + 1).  Note that this is kind of a
-  // hack...
-  if (ACE_OS::strcmp (this->role_, "Supplier") == 0
-      && this->port_number_ == ACE_DEFAULT_SERVER_PORT)
-    this->port_number_++;
-  return 0;
-}
-
-int
-Event_Transceiver::handle_close (ACE_HANDLE,
-                                 ACE_Reactor_Mask)
-{
-  ACE_Reactor::end_event_loop ();
-  return 0;
-}
-
-// Close down via SIGINT or SIGQUIT.
-
-int
-Event_Transceiver::handle_signal (int signum,
-                                  siginfo_t *,
-                                  ucontext_t *)
-{
-  ACE_UNUSED_ARG (signum);
-
-  ACE_Reactor::end_event_loop ();
-  return 0;
-}
-
-Event_Transceiver::Event_Transceiver (void)
-{
-}
-
-Event_Transceiver::Event_Transceiver (int argc, char *argv[])
-{
-  if (this->parse_args (argc, argv) == -1)
-    ACE_ERROR ((LM_ERROR,
-                "%p\n",
-                "parse_args"));
-  else
-    {
-      ACE_Sig_Set sig_set;
-
-      sig_set.sig_add (SIGINT);
-      sig_set.sig_add (SIGQUIT);
-
-      // Register to handle the SIGINT and SIGQUIT signals.
-      if (ACE_Reactor::instance ()->register_handler
-          (sig_set,
-           this) == -1)
-        ACE_ERROR ((LM_ERROR,
-                    "%p\n",
-                    "register_handler"));
-
-      // We need to register <this> here before we're connected since
-      // otherwise <get_handle> will return the connection socket
-      // handle for the peer.
-      else if (ACE_Event_Handler::register_stdin_handler (this,
-                                                          ACE_Reactor::instance (),
-                                                          ACE_Thread_Manager::instance ()) == -1)
-        ACE_ERROR ((LM_ERROR,
-                    "%p\n",
-                    "register_stdin_handler"));
-
-      // Address of the server.
-      ACE_INET_Addr server_addr (this->port_number_,
-                                 this->host_name_);
-
-      ACE_Connector<Event_Transceiver, ACE_SOCK_CONNECTOR> connector;
-
-      // We need a pointer here because connect takes a reference to a
-      // pointer!
-      Event_Transceiver *etp = this;
-
-      // Establish the connection to the Event Server.
-      if (connector.connect (etp,
-                             server_addr) == -1)
-        {
-          ACE_ERROR ((LM_ERROR,
-                      "%p\n",
-                      this->host_name_));
-          ACE_Reactor::instance()->remove_handler (sig_set);
-          ACE_Event_Handler::remove_stdin_handler (ACE_Reactor::instance(),
-                                                   ACE_Thread_Manager::instance());
-        }
-    }
-}
-
-int
-Event_Transceiver::open (void *)
-{
-  // Register ourselves to be notified when there's data to read on
-  // the socket.
-  if (ACE_Reactor::instance ()->register_handler
-      (this,
-       ACE_Event_Handler::READ_MASK) == -1)
-    ACE_ERROR_RETURN ((LM_ERROR,
-                       "%p\n",
-                       "register_handler"),
-                       -1);
-  return 0;
-}
-
-int
-Event_Transceiver::handle_input (ACE_HANDLE handle)
-{
-  // Determine whether we play the role of a consumer or a supplier.
-  if (handle == ACE_STDIN)
-    return this->transmitter ();
-  else
-    return this->receiver ();
-}
-
-int
-Event_Transceiver::transmitter (void)
-{
-  ACE_DEBUG ((LM_DEBUG,
-              "(%P|%t) entering %s transmitter\n",
-              this->role_));
-
-  char buf[BUFSIZ];
-  ssize_t n = ACE_OS::read (ACE_STDIN, buf, sizeof buf);
-  int result = 0;
-
-  if (n <= 0 || this->peer ().send_n (buf, n) != n)
-    result = -1;
-
-  ACE_DEBUG ((LM_DEBUG,
-              "(%P|%t) leaving %s transmitter\n",
-              this->role_));
-  return result;
-}
-
-int
-Event_Transceiver::receiver (void)
-{
-  ACE_DEBUG ((LM_DEBUG,
-              "(%P|%t) entering %s receiver\n",
-              this->role_));
-
-  char buf[BUFSIZ];
-
-  ssize_t n = this->peer ().recv (buf, sizeof buf);
-  int result = 0;
-
-  if (n <= 0
-      || ACE_OS::write (ACE_STDOUT, buf, n) != n)
-    result = -1;
-
-  ACE_DEBUG ((LM_DEBUG,
-              "(%P|%t) leaving %s receiver\n",
-              this->role_));
-  return result;
-}
-
-int
-main (int argc, char *argv[])
-{
-  if (ACE_Service_Config::open (argv[0]) == -1
-      && errno != ENOENT)
-    ACE_ERROR_RETURN ((LM_ERROR,
-                       "%p\n",
-                       "open"),
-                       -1);
-
-  // Create and initialize the transceiver.
-  Event_Transceiver transceiver (argc, argv);
-
-  // Demonstrate how we can check if a constructor failed...
-  if (ACE_LOG_MSG->op_status () == -1)
-    ACE_ERROR_RETURN ((LM_ERROR,
-                       "%p\n",
-                       "Event_Transceiver constructor failed"),
-                       -1);
-
-
-  // Run event loop until either the event server shuts down or we get
-  // a SIGINT.
-  ACE_Reactor::run_event_loop ();
-  return 0;
-}
-
-#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION)
-template class ACE_Connector_Base<Event_Transceiver>;
-template class ACE_Connector<Event_Transceiver, ACE_SOCK_CONNECTOR>;
-template class ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>;
-template class ACE_NonBlocking_Connect_Handler<Event_Transceiver>;
-#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA)
-#pragma instantiate ACE_Connector_Base<Event_Transceiver>
-#pragma instantiate ACE_Connector<Event_Transceiver, ACE_SOCK_CONNECTOR>
-#pragma instantiate ACE_Svc_Handler<ACE_SOCK_STREAM, ACE_NULL_SYNCH>
-#pragma instantiate ACE_NonBlocking_Connect_Handler<Event_Transceiver>
-#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */