TAO/tests/Bug_1568_Regression/server.cpp

   1 /**
   2  * @file server.cpp
   3  *
   4  * @author Carlos O'Ryan <coryan@atdesk.com>
   5  */
   6 #include "TestS.h"
   7
   8 #include "tao/corba.h"
   9 #include "tao/ORB_Core.h"
  10 #include "ace/Get_Opt.h"
  11 #include "ace/Reactor.h"
  12
  13 /**
  14  * @class Simple_C
  15  *
  16  * @brief A simple implementation of the 'C' object.
  17  */
  18 class Simple_C
  19   : public virtual POA_Baz::AMH_C
  20 {
  21 public:
  22   Simple_C (CORBA::ORB_ptr orb);
  23
  24   void op1 (Foo::Bar::AMH_AResponseHandler_ptr _tao_rh);
  25   void op2 (Foo::Bar::AMH_AResponseHandler_ptr _tao_rh);
  26   void op3 (Foo::Bar::AMH_BResponseHandler_ptr _tao_rh);
  27   void op4 (Baz::AMH_CResponseHandler_ptr _tao_rh);
  28   void shutdown (Baz::AMH_CResponseHandler_ptr _tao_rh);
  29 protected:
  30   CORBA::ORB_var orb_;
  31 };
  32
  33
  34 /***************************/
  35 /*** Servant Definition ***/
  36
  37 Simple_C::Simple_C (CORBA::ORB_ptr orb)
  38   : orb_ (CORBA::ORB::_duplicate (orb))
  39 {
  40 }
  41
  42 void
  43 Simple_C::op1(Foo::Bar::AMH_AResponseHandler_ptr _tao_rh)
  44 {
  45   _tao_rh->op1();
  46 }
  47
  48 void
  49 Simple_C::op2(Foo::Bar::AMH_AResponseHandler_ptr _tao_rh)
  50 {
  51   _tao_rh->op2();
  52 }
  53
  54 void
  55 Simple_C::op3(Foo::Bar::AMH_BResponseHandler_ptr _tao_rh)
  56 {
  57   _tao_rh->op3();
  58 }
  59
  60 void
  61 Simple_C::op4(Baz::AMH_CResponseHandler_ptr _tao_rh)
  62 {
  63   _tao_rh->op4();
  64 }
  65
  66 void
  67 Simple_C::shutdown (Baz::AMH_CResponseHandler_ptr)
  68 {
  69   this->orb_->shutdown (0);
  70 }
  71
  72 // ****************************************************************
  73
  74 const ACE_TCHAR *ior_output_file = ACE_TEXT("test.ior");
  75
  76 int
  77 parse_args (int argc, ACE_TCHAR *argv[])
  78 {
  79   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("o:"));
  80   int c;
  81
  82   while ((c = get_opts ()) != -1)
  83     switch (c)
  84       {
  85       case 'o':
  86         ior_output_file = get_opts.opt_arg ();
  87         break;
  88
  89       case '?':
  90       default:
  91         ACE_ERROR_RETURN ((LM_ERROR,
  92                            "usage:  %s "
  93                            "-o <iorfile>"
  94                            "\n",
  95                            argv [0]),
  96                           -1);
  97       }
  98   // Indicates successful parsing of the command line
  99   return 0;
 100 }
 101
 102 int
 103 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
 104 {
 105   try
 106     {
 107       CORBA::ORB_var orb =
 108         CORBA::ORB_init (argc, argv);
 109
 110       CORBA::Object_var poa_object =
 111         orb->resolve_initial_references("RootPOA");
 112
 113       PortableServer::POA_var root_poa =
 114         PortableServer::POA::_narrow (poa_object.in ());
 115
 116       if (CORBA::is_nil (root_poa.in ()))
 117         ACE_ERROR_RETURN ((LM_ERROR,
 118                            " (%P|%t) Panic: nil RootPOA\n"),
 119                           1);
 120
 121       PortableServer::POAManager_var poa_manager =
 122         root_poa->the_POAManager ();
 123
 124       if (parse_args (argc, argv) != 0)
 125         return 1;
 126
 127       PortableServer::Servant_var<Simple_C> simple_c_impl(
 128           new Simple_C(orb.in()));
 129
 130       PortableServer::ObjectId_var id =
 131         root_poa->activate_object (simple_c_impl.in ());
 132
 133       CORBA::Object_var object = root_poa->id_to_reference (id.in ());
 134
 135       Baz::C_var simple_c =
 136         Baz::C::_narrow (object.in ());
 137
 138       CORBA::String_var ior =
 139         orb->object_to_string (simple_c.in ());
 140
 141       // Output the IOR to the <ior_output_file>
 142       FILE *output_file= ACE_OS::fopen (ior_output_file, "w");
 143       if (output_file == 0)
 144         ACE_ERROR_RETURN ((LM_ERROR,
 145                            "Cannot open output file for writing IOR: %s",
 146                            ior_output_file),
 147                               1);
 148       ACE_OS::fprintf (output_file, "%s", ior.in ());
 149       ACE_OS::fclose (output_file);
 150
 151       poa_manager->activate ();
 152
 153       orb->run ();
 154
 155       ACE_DEBUG ((LM_DEBUG, "(%P|%t) server - event loop finished\n"));
 156
 157       root_poa->destroy (1, 1);
 158
 159       orb->destroy ();
 160     }
 161   catch (const CORBA::Exception& ex)
 162     {
 163       ex._tao_print_exception ("Exception caught:");
 164       return 1;
 165     }
 166
 167   return 0;
 168 }