TAO/tests/Explicit_Event_Loop/server.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file    server.cpp
   5  *
   6  *  @author Source code used in TAO has been modified and adapted from thecode provided in the book
   7  *  @author "Advanced CORBA Programming with C++"by Michi Henning and Steve Vinoski. Copyright1999. Addison-Wesley
   8  *  @author Reading
   9  *  @author MA.  Used with permission ofAddison-Wesley.Modified for TAO by Mike Moran <mm4@cs.wustl.edu>
  10  */
  11 //=============================================================================
  12
  13
  14 #include "server.h"
  15 #include "tao/debug.h"
  16 #include "ace/Get_Opt.h"
  17 #include "ace/OS_NS_stdio.h"
  18 #include "ace/OS_NS_unistd.h"
  19 #include "ace/OS_NS_time.h"
  20
  21 const ACE_TCHAR *ior_output_file = ACE_TEXT("server.ior");
  22 int done = 0;
  23
  24 int
  25 parse_args (int argc, ACE_TCHAR *argv[])
  26 {
  27   ACE_Get_Opt get_opts (argc, argv, ACE_TEXT("o:d"));
  28   int c;
  29
  30   while ((c = get_opts ()) != -1)
  31     switch (c)
  32       {
  33       case 'o':
  34         ior_output_file = get_opts.opt_arg ();
  35         break;
  36       case 'd':
  37         TAO_debug_level++;
  38         break;
  39       case '?':
  40       default:
  41         ACE_ERROR_RETURN ((LM_ERROR,
  42                            "usage:  %s "
  43                            "-o <iorfile>"
  44                            "\n",
  45                            argv [0]),
  46                           -1);
  47       }
  48   // Indicates successful parsing of the command line
  49   return 0;
  50 }
  51
  52
  53 TimeOfDay
  54 Time_impl::
  55 get_gmt ()
  56 {
  57   time_t time_now = ACE_OS::time (0);
  58   struct tm *time_p = ACE_OS::gmtime (&time_now);
  59
  60   TimeOfDay tod;
  61   tod.hour = time_p->tm_hour;
  62   tod.minute = time_p->tm_min;
  63   tod.second = time_p->tm_sec;
  64
  65   done = 1;
  66
  67   return tod;
  68 }
  69
  70 void do_something_else()
  71 {
  72   // Sleep a bit so we don't eat up
  73   // a ton of cpu
  74   ACE_OS::sleep(3);
  75 }
  76
  77 int
  78 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  79 {
  80   try
  81     {
  82       // Initialize orb
  83       CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  84
  85       if (parse_args (argc, argv) != 0)
  86         {
  87           return 1;
  88         }
  89
  90       // Get reference to Root POA.
  91       CORBA::Object_var obj
  92         = orb->resolve_initial_references ("RootPOA");
  93
  94       PortableServer::POA_var poa
  95         = PortableServer::POA::_narrow (obj.in ());
  96
  97       // Activate POA manager.
  98       PortableServer::POAManager_var mgr
  99         = poa->the_POAManager ();
 100
 101       mgr->activate ();
 102
 103       // Create an object.
 104       Time_impl time_servant;
 105
 106       // Write its stringified reference to stdout.
 107       PortableServer::ObjectId_var id =
 108         poa->activate_object (&time_servant);
 109
 110       CORBA::Object_var object = poa->id_to_reference (id.in ());
 111
 112       Time_var tm = Time::_narrow (object.in ());
 113
 114       CORBA::String_var str = orb->object_to_string (tm.in ());
 115
 116       ACE_DEBUG ((LM_DEBUG,
 117                   "%s\n",
 118                   str.in ()));
 119
 120       if (ior_output_file != 0)
 121         {
 122           FILE *output_file= ACE_OS::fopen (ior_output_file, "w");
 123
 124           if (output_file == 0)
 125             {
 126               ACE_ERROR_RETURN ((
 127                   LM_ERROR,
 128                   "Cannot open output file for writing IOR: %s",
 129                   ior_output_file
 130                 ),
 131                 1);
 132             }
 133
 134           ACE_OS::fprintf (output_file,
 135                            "%s",
 136                            str.in ());
 137           ACE_OS::fclose (output_file);
 138         }
 139
 140       // Explicit Event Loop.
 141       while (!done)
 142         {
 143           CORBA::Boolean pending =
 144             orb->work_pending ();
 145
 146           if (pending)
 147             {
 148               orb->perform_work ();
 149             }
 150           do_something_else ();
 151         }
 152
 153       orb->shutdown ();
 154       orb->destroy ();
 155     }
 156
 157   catch (const CORBA::Exception& ex)
 158     {
 159       ex._tao_print_exception ("server: a CORBA exception occurred");
 160       return 1;
 161     }
 162   catch (...)
 163     {
 164       ACE_ERROR_RETURN ((LM_ERROR,
 165                          "%s\n",
 166                          "client: an unknown exception was caught\n"),
 167                          1);
 168     }
 169
 170   return 0;
 171 }