TAO/examples/Advanced/ch_12/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 <ace/streams.h>
  15 #include <strstream>
  16 #include "server.h"
  17 #include <algorithm>
  18 #include "icp.h"
  19
  20 // The following headers are #included automatically by ACE+TAO.
  21 // Therefore, they don't need to be included explicitly.
  22 // #include <fstream.h>
  23 // #include <iostream.h>
  24
  25 const char *Controller_oid = "Controller";
  26 const unsigned int           DeviceLocator_impl::MAX_EQ_SIZE = 100;
  27 // Generic ostream inserter for exceptions. Inserts the exception
  28 // name, if available, and the repository ID otherwise.
  29
  30 #if 0   // This inserter may or may not be needed for your ORB.
  31
  32 static ostream &
  33 operator<< (ostream & os, const CORBA::Exception & e)
  34 {
  35   CORBA::Any tmp;
  36   tmp <<= e;
  37
  38   CORBA::TypeCode_var tc = tmp.type ();
  39   const char * p = tc->name ();
  40   if  (*p != '\0')
  41     os << p;
  42   else
  43     os << tc->id ();
  44   return os;
  45 }
  46
  47 #endif
  48
  49 // Helper function to create object references.
  50
  51 static CCS::Thermometer_ptr
  52 make_dref (PortableServer::POA_ptr poa, CCS::AssetType anum)
  53 {
  54   // Convert asset number to OID.
  55   ostrstream ostr;
  56   ostr << anum << ends;
  57   char * anum_str = ostr.str ();
  58   PortableServer::ObjectId_var oid
  59     = PortableServer::string_to_ObjectId (anum_str);
  60   delete[] anum_str;
  61
  62   // Look at the model via the network to determine
  63   // the repository ID.
  64   char buf[32];
  65   assert (ICP_get (anum, "model", buf, sizeof (buf)) == 0);
  66   const char * rep_id = ACE_OS::strcmp (buf, "Sens-A-Temp") == 0
  67     ? "IDL:acme.com/CCS/Thermometer:1.0"
  68     : "IDL:acme.com/CCS/Thermostat:1.0";
  69
  70   // Make a new reference.
  71   CORBA::Object_var obj
  72     = poa->create_reference_with_id (oid.in (), rep_id);
  73   return CCS::Thermometer::_narrow (obj.in ());
  74 }
  75
  76 Controller_impl * Thermometer_impl::m_ctrl;     // static member
  77
  78 // Helper function to read the model string from a device.
  79
  80 CCS::ModelType
  81 Thermometer_impl::
  82 get_model ()
  83 {
  84   char buf[32];
  85   assert (ICP_get (m_anum, "model", buf, sizeof (buf)) == 0);
  86   return CORBA::string_dup (buf);
  87 }
  88
  89 // Helper function to read the temperature from a device.
  90
  91 CCS::TempType
  92 Thermometer_impl::
  93 get_temp ()
  94 {
  95   short temp;
  96   assert (ICP_get (m_anum, "temperature", &temp, sizeof (temp)) == 0);
  97   return temp;
  98 }
  99
 100 // Helper function to read the location from a device.
 101
 102 CCS::LocType
 103 Thermometer_impl::
 104 get_loc ()
 105 {
 106   char buf[32];
 107   assert (ICP_get (m_anum, "location", buf, sizeof (buf)) == 0);
 108   return CORBA::string_dup (buf);
 109 }
 110
 111 // Helper function to set the location of a device.
 112
 113 void
 114 Thermometer_impl::
 115 set_loc (const char * loc)
 116 {
 117   assert (ICP_set (m_anum, "location", loc) == 0);
 118 }
 119
 120 // Constructor.
 121
 122 Thermometer_impl::
 123 Thermometer_impl (CCS::AssetType anum) : m_anum (anum)
 124 {
 125   m_ctrl->add_impl (anum, this);   // Add self to controller's set
 126 }
 127
 128 // Destructor.
 129
 130 Thermometer_impl::
 131 ~Thermometer_impl ()
 132 {
 133   if  (m_ctrl->exists (m_anum))
 134     m_ctrl->add_impl (m_anum, 0);    // Clear servant pointer
 135 }
 136
 137 // IDL model attribute.
 138
 139 CCS::ModelType
 140 Thermometer_impl::model ()
 141 {
 142   return get_model ();
 143 }
 144
 145 // IDL asset_num attribute.
 146
 147 CCS::AssetType
 148 Thermometer_impl::asset_num ()
 149 {
 150   return m_anum;
 151 }
 152
 153 // IDL temperature attribute.
 154
 155 CCS::TempType
 156 Thermometer_impl::temperature ()
 157 {
 158   return get_temp ();
 159 }
 160
 161 // IDL location attribute accessor.
 162
 163 CCS::LocType
 164 Thermometer_impl::location ()
 165 {
 166   return get_loc ();
 167 }
 168
 169 // IDL remove operation.
 170
 171 void
 172 Thermometer_impl::remove ()
 173 {
 174   m_ctrl->remove_impl (m_anum);
 175   assert (ICP_offline (m_anum) == 0);
 176   // delete this;
 177 }
 178
 179 // IDL location attribute modifier.
 180
 181 void
 182 Thermometer_impl::location (const char *loc)
 183 {
 184   set_loc (loc);
 185 }
 186
 187 //----------------------------------------------------------------
 188
 189 // Helper function to get a thermostat's nominal temperature.
 190
 191 CCS::TempType
 192 Thermostat_impl::
 193 get_nominal_temp ()
 194 {
 195   short temp;
 196   assert (ICP_get (m_anum, "nominal_temp", &temp, sizeof (temp)) == 0);
 197   return temp;
 198 }
 199
 200 // Helper function to set a thermostat's nominal temperature.
 201
 202 CCS::TempType
 203 Thermostat_impl::
 204 set_nominal_temp (CCS::TempType new_temp)
 205 {
 206   short old_temp;
 207
 208   // We need to return the previous nominal temperature,
 209   // so we first read the current nominal temperature before
 210   // changing it.
 211   assert (ICP_get (m_anum, "nominal_temp", &old_temp, sizeof (old_temp)) == 0);
 212
 213   // Now set the nominal temperature to the new value.
 214   if  (ICP_set (m_anum, "nominal_temp", &new_temp) != 0)
 215     {
 216       // If ICP_set () failed, read this thermostat's minimum and
 217       // maximum so we can initialize the BadTemp exception.
 218       CCS::Thermostat::BtData btd;
 219       ICP_get (m_anum, "MIN_TEMP",
 220                &btd.min_permitted, sizeof (btd.min_permitted));
 221       ICP_get (m_anum, "MAX_TEMP",
 222                &btd.max_permitted, sizeof (btd.max_permitted));
 223       btd.requested = new_temp;
 224       btd.error_msg = CORBA::string_dup (new_temp > btd.max_permitted ? "Too hot" : "Too cold");
 225       throw CCS::Thermostat::BadTemp (btd);
 226     }
 227   return old_temp;
 228 }
 229
 230 // Constructor.
 231
 232 Thermostat_impl::
 233 Thermostat_impl (CCS::AssetType anum) : Thermometer_impl (anum)
 234 {
 235   // Intentionally empty.
 236 }
 237
 238 // Destructor.
 239
 240 Thermostat_impl::
 241 ~Thermostat_impl ()
 242 {
 243   // Intentionally empty.
 244 }
 245
 246 // IDL get_nominal operation.
 247
 248 CCS::TempType
 249 Thermostat_impl::get_nominal ()
 250 {
 251   return get_nominal_temp ();
 252 }
 253
 254 // IDL set_nominal operation.
 255
 256 CCS::TempType
 257 Thermostat_impl::
 258 set_nominal (CCS::TempType new_temp)
 259 {
 260   return set_nominal_temp (new_temp);
 261 }
 262
 263 // Helper function to add an entry to the asset map.
 264
 265 void
 266 Controller_impl::
 267 add_impl (CCS::AssetType anum, Thermometer_impl * tip)
 268 {
 269   m_assets[anum] = tip;
 270 }
 271
 272 // Helper function to remove an entry from the asset map.
 273
 274 void
 275 Controller_impl::
 276 remove_impl (CCS::AssetType anum)
 277 {
 278   m_assets.erase (anum);
 279 }
 280
 281 // Helper function to locate a servant in the asset map.
 282
 283 bool
 284 Controller_impl::
 285 exists (CCS::AssetType anum)
 286 {
 287   return m_assets.find (anum) != m_assets.end ();
 288 }
 289
 290 // Constructor
 291
 292 Controller_impl::
 293 Controller_impl (PortableServer::POA_ptr poa,
 294                  const char *asset_file)
 295     : m_poa (PortableServer::POA::_duplicate (poa)),
 296       m_asset_file (asset_file)
 297 {
 298   std::ifstream afile (m_asset_file.in (), std::ios::in|std::ios::out);//, 0666);
 299   if  (!afile)
 300     {
 301       std::cerr << "Cannot open " << m_asset_file.in () << std::endl;
 302       throw 0;
 303     }
 304   CCS::AssetType anum;
 305
 306   while  (afile >> anum)
 307     m_assets[anum] = 0;
 308
 309   //afile.close ();
 310   //if  (!afile) {
 311   //    cerr << "Cannot close " << m_asset_file << endl;
 312   //    throw 0;
 313   //}
 314 }
 315
 316 // Destructor
 317
 318 Controller_impl::
 319 ~Controller_impl ()
 320 {
 321   // Write out the current set of asset numbers
 322   // and clean up all servant instances.
 323   std::ofstream afile (m_asset_file.in ());
 324   if  (!afile)
 325     {
 326       std::cerr << "Cannot open " << m_asset_file.in () << std::endl;
 327       assert (0);
 328     }
 329   AssetMap::iterator i;
 330
 331   for  (i = m_assets.begin (); i != m_assets.end (); i++)
 332     {
 333       afile << i->first << std::endl;
 334       if  (!afile)
 335         {
 336           std::cerr << "Cannot update " << m_asset_file.in () << std::endl;
 337           assert (0);
 338         }
 339       delete i->second;
 340     }
 341   afile.close ();
 342   if  (!afile)
 343     {
 344       std::cerr << "Cannot close " << m_asset_file.in () << std::endl;
 345       assert (0);
 346     }
 347 }
 348
 349 CCS::Thermometer_ptr
 350 Controller_impl::
 351 create_thermometer (CCS::AssetType anum, const char *loc)
 352 {
 353   if  (anum % 2 == 0)
 354     throw CORBA::BAD_PARAM ();  // Thermometers have odd numbers
 355   if  (exists (anum))
 356     throw CCS::Controller::DuplicateAsset ();
 357
 358   assert (ICP_online (anum) == 0);
 359   assert (ICP_set (anum, "location", loc) == 0);
 360   add_impl (anum, 0);
 361   return make_dref (m_poa.in (), anum);
 362 }
 363
 364 CCS::Thermostat_ptr
 365 Controller_impl::
 366 create_thermostat (CCS::AssetType anum,
 367                    const char *loc,
 368                    CCS::TempType temp)
 369 {
 370   if  (anum % 2 != 0)
 371     throw CORBA::BAD_PARAM ();   // Thermostats have even numbers
 372   if  (exists (anum))
 373     throw CCS::Controller::DuplicateAsset ();
 374
 375   assert (ICP_online (anum) == 0);
 376   assert (ICP_set (anum, "location", loc) == 0);
 377   // Set the nominal temperature.
 378   if  (ICP_set (anum, "nominal_temp", &temp) != 0)
 379     {
 380       // If ICP_set () failed, read this thermostat's minimum
 381       // and maximum so we can initialize the BadTemp exception.
 382       CCS::Thermostat::BtData btd;
 383       ICP_get (anum, "MIN_TEMP",
 384                &btd.min_permitted, sizeof (btd.min_permitted));
 385       ICP_get (anum, "MAX_TEMP", &btd.max_permitted, sizeof (btd.max_permitted));
 386       btd.requested = temp;
 387       btd.error_msg = CORBA::string_dup (temp > btd.max_permitted ? "Too hot" : "Too cold");
 388       ICP_offline (anum);
 389       throw CCS::Thermostat::BadTemp (btd);
 390     }
 391
 392   add_impl (anum, 0);
 393   CORBA::Object_var obj = make_dref (m_poa.in (), anum);
 394   return CCS::Thermostat::_narrow (obj.in ());
 395 }
 396
 397 // IDL list operation.
 398
 399 CCS::Controller::ThermometerSeq *
 400 Controller_impl::list ()
 401 {
 402   // Create a new thermometer sequence. Because we know
 403   // the number of elements we will put onto the sequence,
 404   // we use the maximum constructor.
 405   CCS::Controller::ThermometerSeq_var listv
 406     = new CCS::Controller::ThermometerSeq (m_assets.size ());
 407   listv->length (m_assets.size ());
 408
 409   // Loop over the m_assets set and create a
 410   // reference for each device.
 411   CORBA::ULong count = 0;
 412   AssetMap::iterator i;
 413
 414   for  (i = m_assets.begin (); i != m_assets.end (); i++)
 415     listv[count++] = make_dref (m_poa.in (), i->first);
 416
 417   return listv._retn ();
 418 }
 419
 420 // IDL change operation.
 421
 422 void
 423 Controller_impl::
 424 change (const CCS::Controller::ThermostatSeq &  tlist,
 425         CORBA::Short delta)
 426 {
 427   CCS::Controller::EChange ec;    // Just in case we need it
 428
 429   // We cannot add a delta value to a thermostat's temperature
 430   // directly, so for each thermostat, we read the nominal
 431   // temperature, add the delta value to it, and write
 432   // it back again.
 433   for  (CORBA::ULong i = 0; i < tlist.length (); i++)
 434     {
 435       if  (CORBA::is_nil (tlist[i]))
 436         continue;                       // Skip nil references
 437
 438       // Read nominal temp and update it.
 439       CCS::TempType tnom = tlist[i]->get_nominal ();
 440       tnom += delta;
 441       try
 442         {
 443           tlist[i]->set_nominal (tnom);
 444         }
 445       catch  (const CCS::Thermostat::BadTemp &bt)
 446         {
 447           // If the update failed because the temperature
 448           // is out of range, we add the thermostat's info
 449           // to the errors sequence.
 450           CORBA::ULong len = ec.errors.length ();
 451           ec.errors.length (len + 1);
 452           ec.errors[len].tmstat_ref = tlist[i].in ();
 453           ec.errors[len].info = bt.details;
 454         }
 455     }
 456
 457   // If we encountered errors in the above loop, we will have added
 458   // elements to the errors sequence.
 459   if  (ec.errors.length () != 0)
 460     throw ec;
 461 }
 462
 463 // IDL find operation
 464
 465 void
 466 Controller_impl::
 467 find (CCS::Controller::SearchSeq & slist)
 468 {
 469   // Loop over input list and lookup each device.
 470   CORBA::ULong listlen = slist.length ();
 471   for  (CORBA::ULong i = 0; i < listlen; i++)
 472     {
 473       AssetMap::iterator where;   // Iterator for asset set
 474       int num_found = 0;          // Num matched per iteration
 475
 476       // Assume we will not find a matching device.
 477       slist[i].device = CCS::Thermometer::_nil ();
 478
 479       // Work out whether we are searching by asset,
 480       // model, or location.
 481       CCS::Controller::SearchCriterion sc = slist[i].key._d ();
 482       if  (sc == CCS::Controller::ASSET)
 483         {
 484           // Search for matching asset number.
 485           where = m_assets.find (slist[i].key.asset_num ());
 486           if  (where != m_assets.end ())
 487             slist[i].device = make_dref (m_poa.in (), where->first);
 488         }
 489       else
 490         {
 491           // Search for model or location string.
 492           const char *search_str;
 493           if  (sc == CCS::Controller::LOCATION)
 494             search_str = slist[i].key.loc ();
 495           else
 496             search_str = slist[i].key.model_desc ();
 497
 498           // Find first matching device  (if any).
 499           where = find_if (m_assets.begin (), m_assets.end (),
 500                            StrFinder (sc, search_str));
 501
 502           // While there are matches...
 503           while  (where != m_assets.end ())
 504             {
 505               if  (num_found == 0)
 506                 {
 507                   // First match overwrites reference
 508                   // in search record.
 509                   slist[i].device = make_dref (m_poa.in (), where->first);
 510                 }
 511               else
 512                 {
 513                   // Further matches each append a new
 514                   // element to the search sequence.
 515                   CORBA::ULong len = slist.length ();
 516                   slist.length (len + 1);
 517                   slist[len].key = slist[i].key;
 518                   slist[len].device = make_dref (m_poa.in (), where->first);
 519                 }
 520               num_found++;
 521
 522               // Find next matching device with this key.
 523               where = find_if (++where, m_assets.end (),
 524                                StrFinder (sc, search_str));
 525             }
 526         }
 527     }
 528 }
 529
 530 DeviceLocator_impl::
 531 DeviceLocator_impl (Controller_impl * ctrl) : m_ctrl (ctrl)
 532 {
 533   // Intentionally empty
 534 }
 535
 536 PortableServer::Servant
 537 DeviceLocator_impl::
 538 preinvoke (const PortableServer::ObjectId & oid,
 539            PortableServer::POA_ptr          /*poa*/,
 540            const char *                     operation,
 541            void * &                         /*cookie*/)
 542 {
 543   // Convert object id into asset number.
 544   CORBA::String_var oid_string;
 545   try
 546     {
 547       oid_string = PortableServer::ObjectId_to_string (oid);
 548     }
 549   catch  (const CORBA::BAD_PARAM &)
 550     {
 551       throw CORBA::OBJECT_NOT_EXIST ();
 552     }
 553
 554   if  (ACE_OS::strcmp (oid_string.in (), Controller_oid) == 0)
 555     return m_ctrl;
 556
 557   istrstream istr (oid_string.in ());
 558   CCS::AssetType anum;
 559   istr >> anum;
 560   if  (istr.fail ())
 561     throw CORBA::OBJECT_NOT_EXIST ();
 562
 563   // Check whether the device is known.
 564   if  (!m_ctrl->exists (anum))
 565     throw CORBA::OBJECT_NOT_EXIST ();
 566
 567   // Look at the object map to find out whether
 568   // we have a servant in memory.
 569   Thermometer_impl * servant;
 570   ActiveObjectMap::iterator servant_pos = m_aom.find (anum);
 571   if  (servant_pos  == m_aom.end ())
 572     {
 573       // No servant in memory. If evictor queue is full,
 574       // evict servant at head of queue.
 575       if  (m_eq.size () == MAX_EQ_SIZE)
 576         {
 577           servant = m_eq.back ();
 578           m_aom.erase (servant->m_anum);
 579           m_eq.pop_back ();
 580           delete servant;
 581         }
 582       // Instantiate correct type of servant.
 583       char buf[32];
 584       assert (ICP_get (anum, "model", buf, sizeof (buf)) == 0);
 585       if  (ACE_OS::strcmp (buf, "Sens-A-Temp") == 0)
 586         servant = new Thermometer_impl (anum);
 587       else
 588         servant = new Thermostat_impl (anum);
 589     }
 590   else
 591     {
 592       // Servant already in memory.
 593       servant = * (servant_pos->second);   // Remember servant
 594       m_eq.erase (servant_pos->second);    // Remove from queue
 595
 596       // If operation is "remove", also remove entry from
 597       // active object map -- the object is about to be deleted.
 598       if (ACE_OS::strcmp (operation, "remove") == 0)
 599         m_aom.erase (servant_pos);
 600     }
 601
 602   // We found a servant, or just instantiated it.  If the operation is
 603   // not a remove, move the servant to the tail of the evictor queue
 604   // and update its queue position in the map.
 605   if  (ACE_OS::strcmp (operation, "remove") != 0)
 606     {
 607       m_eq.push_front (servant);
 608       m_aom[anum] = m_eq.begin ();
 609     }
 610
 611   return servant;
 612 }
 613
 614 int
 615 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
 616 {
 617   CORBA::ORB_var orb;
 618
 619   try
 620     {
 621       // Initialize orb
 622       orb = CORBA::ORB_init (argc, argv);
 623
 624       // Get reference to Root POA.
 625       CORBA::Object_var obj
 626         = orb->resolve_initial_references ("RootPOA");
 627       PortableServer::POA_var poa
 628         = PortableServer::POA::_narrow (obj.in ());
 629
 630       // Get POA manager
 631       PortableServer::POAManager_var poa_mgr = poa->the_POAManager ();
 632
 633       // Create a policy list. We use persistent objects with
 634       // user-assigned IDs, and explicit activation.
 635       CORBA::PolicyList policy_list;
 636       policy_list.length (6);
 637       policy_list[0] = poa->create_lifespan_policy (PortableServer::TRANSIENT);   // REVISIT
 638       policy_list[1] = poa->create_id_assignment_policy (PortableServer::USER_ID);
 639       policy_list[2] = poa->create_implicit_activation_policy (PortableServer::NO_IMPLICIT_ACTIVATION);
 640       policy_list[3] = poa->create_request_processing_policy (PortableServer::USE_SERVANT_MANAGER);
 641       policy_list[4] = poa->create_servant_retention_policy (PortableServer::NON_RETAIN);
 642       policy_list[5] = poa->create_thread_policy (PortableServer::SINGLE_THREAD_MODEL);
 643
 644       // Create a POA for all CCS elements.
 645       PortableServer::POA_var ccs_poa
 646         = poa->create_POA ("CCS_POA", poa_mgr.in (), policy_list);
 647
 648       // Create a controller and set static m_ctrl member
 649       // for thermostats and thermometers.
 650       Controller_impl ctrl_servant (ccs_poa.in (), "/tmp/CCS_assets");
 651       Thermometer_impl::m_ctrl = &ctrl_servant;
 652
 653       // Create a reference for the controller and
 654       // create the corresponding CORBA object.
 655       PortableServer::ObjectId_var oid
 656         = PortableServer::string_to_ObjectId (Controller_oid);
 657       obj = ccs_poa->create_reference_with_id (oid.in (), "IDL:acme.com/CCS/Controller:1.0");
 658
 659       // Write a reference for the controller to stdout.
 660       CORBA::String_var str = orb->object_to_string (obj.in ());
 661       cout << str.in () << std::endl << std::endl;
 662
 663       // Instantiate the servant locator for devices.
 664       PortableServer::ServantManager_var locator =
 665         new DeviceLocator_impl (&ctrl_servant);
 666
 667       // Set servant locator.
 668       ccs_poa->set_servant_manager (locator.in ());
 669
 670       // Activate the POA manager.
 671       poa_mgr->activate ();
 672
 673       // Accept requests
 674       orb->run ();
 675     }
 676   catch  (const CORBA::Exception & e)
 677     {
 678       std::cerr << "Uncaught CORBA exception: "
 679                 << e
 680                 << std::endl;
 681       return 1;
 682     }
 683   catch  (...)
 684     {
 685       assert (0);  // Uncaught exception, dump core
 686     }
 687   return 0;
 688 }