TAO/tests/MT_NoUpcall_Connect/client.cpp

   1 #include "SharedIntfC.h"
   2 #include "SharedIntfS.h"
   3
   4 #include "ace/SString.h"
   5 #include "ace/Get_Opt.h"
   6 #include "ace/Task.h"
   7 #include "ace/OS_NS_unistd.h"
   8 #include "ace/OS_NS_time.h"
   9
  10 Test_Idl::SharedIntf_var intf;
  11
  12 ACE_Time_Value upcall_start (0,0);
  13 ACE_Time_Value upcall_end (0,0);
  14 ACE_Time_Value ping_start (0,0);
  15 ACE_Time_Value ping_end (0,0);
  16
  17 class SharedIntfCB : public POA_Test_Idl::AMI_SharedIntfHandler
  18 {
  19 public:
  20   void ping ()
  21   {
  22     ACE_DEBUG ((LM_DEBUG, "ping returned\n"));
  23     ping_end = ping_end.now ();
  24   }
  25
  26   void ping_excep (::Messaging::ExceptionHolder * )
  27   {
  28     ACE_DEBUG ((LM_DEBUG, "exception caught on ping req\n"));
  29     ping_end = ping_end.now ();
  30   }
  31
  32   void do_upcall ()
  33   {
  34     ACE_DEBUG ((LM_DEBUG, "upcall returned\n"));
  35     upcall_end = upcall_end.now ();
  36   }
  37
  38   void do_upcall_excep (::Messaging::ExceptionHolder * excep )
  39   {
  40     try
  41       {
  42         excep->raise_exception ();
  43       }
  44     catch (const CORBA::Exception &)
  45       {
  46       }
  47     ACE_DEBUG ((LM_DEBUG, "exception caught on upcall req\n"));
  48     upcall_end = upcall_end.now ();
  49   }
  50 };
  51
  52
  53 int
  54 parse_args (int argc, ACE_TCHAR *argv[])
  55 {
  56   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("t:"));
  57   int c;
  58
  59   while ((c = get_opts ()) != -1)
  60     switch (c)
  61       {
  62       case '?':
  63       default:
  64         ACE_ERROR_RETURN ((LM_ERROR,
  65                            "usage:  %s "
  66                            "-t threads "
  67                            "\n",
  68                            argv [0]),
  69                           -1);
  70       }
  71   // Indicates successful parsing of the command line
  72   return 0;
  73 }
  74
  75 int
  76 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  77 {
  78   CORBA::ORB_var orb_;
  79   int result = 0;
  80
  81   try
  82   {
  83     ACE_DEBUG((LM_INFO,"(%P|%t) START OF CLIENT TEST\n"));
  84
  85     orb_ = CORBA::ORB_init (argc, argv);
  86
  87     if (parse_args (argc, argv) != 0)
  88       return 1;
  89
  90     CORBA::Object_var obj = orb_->resolve_initial_references ("RootPOA");
  91     PortableServer::POA_var root_poa =
  92       PortableServer::POA::_narrow (obj.in());
  93
  94     PortableServer::POAManager_var poa_manager =
  95       root_poa->the_POAManager ();
  96     PortableServer::POA_var poa = root_poa;
  97
  98     poa_manager->activate ();
  99
 100     PortableServer::ServantBase_var cb_serv = new SharedIntfCB;
 101     PortableServer::ObjectId_var oid = root_poa->activate_object (cb_serv.in());
 102     obj = root_poa->id_to_reference (oid.in());
 103
 104     Test_Idl::AMI_SharedIntfHandler_var cb =
 105       Test_Idl::AMI_SharedIntfHandler::_narrow (obj.in());
 106
 107     obj = orb_->string_to_object ("file://server.ior");
 108     intf = Test_Idl::SharedIntf::_narrow(obj.in());
 109
 110     ACE_DEBUG((LM_INFO,"(%P|%t) invoking async upcall.\n"));
 111
 112     upcall_start = upcall_start.now ();
 113     intf->sendc_do_upcall (cb.in());
 114     ACE_DEBUG((LM_INFO,"(%P|%t) invoking ping\n"));
 115
 116     ping_start = ping_start.now ();
 117     intf->ping ();
 118     ACE_DEBUG((LM_INFO,"(%P|%t) sync ping returned\n"));
 119     ping_end = ping_end.now ();
 120
 121     result = (upcall_end > ACE_Time_Value::zero && upcall_end <= ping_end) ? 0 : 1;
 122
 123     intf->farewell ();
 124     intf = Test_Idl::SharedIntf::_nil ();
 125     orb_->destroy ();
 126
 127     ACE_DEBUG ((LM_INFO,"(%P|%t) Client Test %C\n",
 128                 (result == 0 ? "succeeded":"failed")));
 129   }
 130   catch (const CORBA::Exception& ex)
 131   {
 132     ex._tao_print_exception ("Error: Exception caught:");
 133   }
 134
 135   return result;
 136 }
 137