TAO/orbsvcs/examples/RtEC/Simple/Service.cpp

   1 #include "orbsvcs/Event/EC_Event_Channel.h"
   2 #include "orbsvcs/Event/EC_Default_Factory.h"
   3 #include "ace/Get_Opt.h"
   4 #include "orbsvcs/CosNamingC.h"
   5 #include "ace/OS_NS_stdio.h"
   6
   7 const ACE_TCHAR *ior_output_file = ACE_TEXT("ec.ior");
   8
   9 int parse_args (int argc, ACE_TCHAR *argv[]);
  10
  11 int
  12 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  13 {
  14   TAO_EC_Default_Factory::init_svcs ();
  15
  16   try
  17     {
  18       // ORB initialization boiler plate...
  19       CORBA::ORB_var orb =
  20         CORBA::ORB_init (argc, argv);
  21
  22       CORBA::Object_var object =
  23         orb->resolve_initial_references ("RootPOA");
  24       PortableServer::POA_var poa =
  25         PortableServer::POA::_narrow (object.in ());
  26       PortableServer::POAManager_var poa_manager =
  27         poa->the_POAManager ();
  28       poa_manager->activate ();
  29
  30       // Obtain the naming service
  31       CORBA::Object_var naming_obj =
  32         orb->resolve_initial_references ("NameService");
  33
  34       if (CORBA::is_nil (naming_obj.in ()))
  35         ACE_ERROR_RETURN ((LM_ERROR,
  36                            " (%P|%t) Unable to get the Naming Service.\n"),
  37                           1);
  38
  39       CosNaming::NamingContext_var naming_context =
  40         CosNaming::NamingContext::_narrow (naming_obj.in ());
  41
  42       TAO_EC_Event_Channel_Attributes attributes (poa.in (),
  43                                                   poa.in ());
  44
  45       TAO_EC_Event_Channel ec_impl (attributes);
  46       ec_impl.activate ();
  47
  48       RtecEventChannelAdmin::EventChannel_var event_channel =
  49         ec_impl._this ();
  50
  51       // Create a name.
  52       CosNaming::Name name;
  53       name.length (1);
  54       name[0].id = CORBA::string_dup ("EventService");
  55       name[0].kind = CORBA::string_dup ("");
  56
  57       // Register with the name server
  58       naming_context->bind (name, event_channel.in ());
  59
  60       // Example code: How to write ior to file
  61       CORBA::String_var ior =
  62         orb->object_to_string (event_channel.in ());
  63       ACE_DEBUG ((LM_DEBUG, "Activated as <%C>\n", ior.in ()));
  64       // If the ior_output_file exists, output the ior to it
  65       if (ior_output_file != 0)
  66         {
  67           FILE *output_file= ACE_OS::fopen (ior_output_file, "w");
  68           if (output_file == 0)
  69             ACE_ERROR_RETURN ((LM_ERROR,
  70                                "Cannot open output file for writing IOR: %s",
  71                                ior_output_file),
  72                               1);
  73           ACE_OS::fprintf (output_file, "%s", ior.in ());
  74           ACE_OS::fclose (output_file);
  75         }
  76
  77       // Wait for events, using work_pending()/perform_work() may help
  78       // or using another thread, this example is too simple for that.
  79       orb->run ();
  80
  81       // We don't do any cleanup, it is hard to do it after shutdown,
  82       // and would complicate the example; plus it is almost
  83       // impossible to do cleanup after ORB->run() because the POA is
  84       // in the holding state.  Applications should use
  85       // work_pending()/perform_work() to do more interesting stuff.
  86       // Check the supplier for the proper way to do cleanup.
  87     }
  88   catch (const CORBA::Exception& ex)
  89     {
  90       ex._tao_print_exception ("Service");
  91       return 1;
  92     }
  93   return 0;
  94 }
  95
  96 // ****************************************************************
  97
  98 int parse_args (int argc, ACE_TCHAR *argv[])
  99 {
 100   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("o:"));
 101   int c;
 102
 103   while ((c = get_opts ()) != -1)
 104     switch (c)
 105       {
 106       case 'o':
 107         ior_output_file = get_opts.opt_arg ();
 108         break;
 109
 110       case '?':
 111       default:
 112         ACE_ERROR_RETURN ((LM_ERROR,
 113                            "usage:  %s "
 114                            "-o <iorfile>"
 115                            "\n",
 116                            argv [0]),
 117                           -1);
 118       }
 119   // Indicates successful parsing of the command line
 120   return 0;
 121 }
 122