TAO/tests/Bug_3547_Regression/Stock_Quoter_Client.cpp

   1 #include "tao/Strategies/advanced_resource.h"
   2
   3 // Stock Quoter Stub
   4 #include "Stock_QuoterC.h"
   5 #include "UDPTestC.h"
   6 #include "ace/streams.h"
   7 #include "ace/Task.h"
   8
   9 class OrbTask : public ACE_Task_Base
  10 {
  11 public:
  12   OrbTask(const CORBA::ORB_ptr orb)
  13       : orb_(CORBA::ORB::_duplicate(orb))
  14   {
  15   }
  16
  17   virtual int svc()
  18   {
  19       try
  20         {
  21           this->orb_->run ();
  22         }
  23       catch (const CORBA::Exception&)
  24         {
  25         }
  26       return 0;
  27   }
  28
  29 private:
  30   CORBA::ORB_var orb_;
  31 };
  32
  33 static int n_threads = 1;
  34
  35 unsigned char Msg[1000] = { 0 } ;
  36
  37 int ACE_TMAIN (int argc, ACE_TCHAR *argv[])
  38 {
  39   try
  40   {
  41     // Initialize the ORB
  42     CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  43
  44     // Use a simple ObjectKey to access the Stock Quoter.
  45     // (Client ORB must be initialized with
  46     // -ORBInitRef MyStockQuoter=corbaloc:...)
  47     CORBA::Object_var udp_obj =
  48       orb->resolve_initial_references ("UDPTest");
  49
  50     CORBA::Object_var stock_quoter_obj =
  51       orb->resolve_initial_references ("MyStockQuoter");
  52
  53     OrbTask task(orb.in());
  54
  55     if (task.activate (THR_NEW_LWP | THR_JOINABLE,
  56                           n_threads) != 0)
  57        ACE_ERROR_RETURN ((LM_ERROR,
  58                           "Cannot activate threads\n"),
  59                          1);
  60
  61     UDPTestI_var server = UDPTestI::_narrow (udp_obj.in ());
  62
  63     Stock_Quoter_var quoter = Stock_Quoter::_narrow (stock_quoter_obj.in());
  64
  65     memset( Msg, 1, 1000 ) ;
  66     //UDP->send( 10 ) ;
  67
  68     server->send( Msg ) ;
  69
  70     try
  71       {
  72         CORBA::Float current_stock_price = quoter->get_quote ("BA");
  73         cout << "Stock Id: BA, Price = " << current_stock_price << endl;
  74       }
  75     catch (Bad_Ticker_Symbol& e)
  76       {
  77         cerr << "Caught a bad ticker symbol exception: "
  78              << e.symbol << endl;;
  79       }
  80
  81     quoter->shutdown ();
  82
  83     task.wait();
  84
  85     orb->destroy ();
  86   }
  87   catch (const CORBA::Exception& e)
  88   {
  89     e._tao_print_exception ("Exception caught:");
  90     return 1;
  91   }
  92
  93   return 0;
  94 }