TAO/tests/Bug_1869_Regression/client.cpp

   1 #include "AMIS.h"
   2 #include "ace/Task.h"
   3 #include "ace/OS_NS_unistd.h"
   4 #include "ace/Get_Opt.h"
   5
   6 const ACE_TCHAR *hostname = ACE_TEXT ("localhost");
   7 const ACE_TCHAR *port = ACE_TEXT ("12345");
   8
   9 class AdderCallback
  10   : public POA_AMI_test::AMI_adderHandler,
  11     public ACE_Task_Base {
  12   public:
  13     AdderCallback(CORBA::ORB_ptr orb)
  14       : orb(CORBA::ORB::_duplicate(orb)) {
  15       activate();
  16     }
  17
  18     virtual void add (
  19         CORBA::Long ami_return_val
  20       )
  21       {
  22         ACE_DEBUG ((LM_DEBUG, "Return value: %d\n", ami_return_val));
  23       }
  24
  25     virtual void add_excep (
  26         ::Messaging::ExceptionHolder *
  27       )
  28       {
  29         ACE_DEBUG ((LM_DEBUG, "Caught exception in _excep\n"));
  30       }
  31
  32     virtual int svc() {
  33       orb->run();
  34
  35       return 0;
  36     }
  37
  38     CORBA::ORB_var orb;
  39 };
  40
  41 int
  42 parse_args (int argc, ACE_TCHAR *argv[])
  43 {
  44     ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("h:p:"));
  45     int c;
  46
  47     while ((c = get_opts ()) != -1)
  48       switch (c)
  49         {
  50         case 'h':
  51             hostname = get_opts.opt_arg ();
  52             break;
  53         case 'p':
  54             port = get_opts.opt_arg ();
  55             break;
  56         case '?':
  57         default:
  58           ACE_ERROR_RETURN ((LM_ERROR,
  59                              "usage:  %s "
  60                              "-h <hostname> "
  61                              "-p <port> "
  62                              "\n",
  63                              argv [0]),
  64                             -1);
  65         }
  66     // Indicates successful parsing of the command line
  67     return 0;
  68   }
  69
  70
  71 int ACE_TMAIN (int argc, ACE_TCHAR* argv[]) {
  72 ACE_TCHAR address_servant[1000];
  73
  74   try {
  75     CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  76
  77     if (parse_args (argc, argv) != 0)
  78         return 1;
  79     // Get reference to Root POA
  80     CORBA::Object_var obj
  81       = orb->resolve_initial_references ("RootPOA");
  82
  83     PortableServer::POA_var rootPOA = PortableServer::POA::_narrow (obj.in ());
  84
  85     // Activate POA manager
  86     PortableServer::POAManager_var mgr
  87       = rootPOA->the_POAManager ();
  88
  89     mgr->activate();
  90
  91     ACE_OS::sprintf(address_servant, ACE_TEXT("corbaloc:iiop:%s:%s/Adder"), hostname, port);
  92
  93     // Resolve Adder Reference
  94     obj = orb->string_to_object(ACE_TEXT_ALWAYS_CHAR(address_servant));
  95     AMI_test::adder_var adder = AMI_test::adder::_narrow(obj.in ());
  96
  97     AdderCallback cb_servant(orb.in ());
  98
  99     while(true) {
 100       try
 101       {
 102         adder->sendc_add(cb_servant._this(), 3, 2);
 103       }
 104       catch(...)
 105       {
 106         ACE_ERROR ((LM_ERROR, "ERROR: Caught exception after sendc_add\n"));
 107       }
 108       ACE_OS::sleep (1);
 109     }
 110   }
 111   catch(...)
 112   {
 113     ACE_ERROR ((LM_ERROR, "ERROR: Caught exception in main\n"));
 114     return 1;
 115   }
 116
 117   return 0;
 118 }
 119
 120