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