TAO/examples/Content_Server/AMI_Observer/Push_Iterator_Handler.cpp

   1 // -*- C++ -*-
   2 // Ossama Othman <ossama@uci.edu>
   3
   4 #include "ace/Log_Msg.h"
   5 #include "ace/Process_Manager.h"
   6 #include "Push_Iterator_Handler.h"
   7 #include "Callback_i.h"
   8
   9 Push_Iterator_Handler::Push_Iterator_Handler (void)
  10   : callback_servant_ (0),
  11     callback_ (),
  12     ami_handler_ ()
  13 {
  14   // Nothing else
  15 }
  16
  17 Push_Iterator_Handler::~Push_Iterator_Handler (void)
  18 {
  19   // Nothing else
  20 }
  21
  22 void
  23 Push_Iterator_Handler::register_callback
  24   (const Web_Server::Metadata_Type &metadata)
  25 {
  26   this->callback_servant_->metadata (metadata);
  27
  28   // This handler is no longer needed, so deactivate it.
  29   this->deactivate ();
  30 }
  31
  32 void
  33 Push_Iterator_Handler::run (int *request_count,
  34                             const char *pathname,
  35                             Web_Server::Iterator_Factory_ptr factory)
  36 {
  37   ACE_NEW_THROW_EX (this->callback_servant_,
  38                     Callback_i (request_count),
  39                     CORBA::NO_MEMORY ());
  40
  41   // Pass ownership of the Callback servant to the POA.
  42   PortableServer::ServantBase_var tmp (this->callback_servant_);
  43
  44   // Activate the Callback.
  45   this->callback_ =
  46     this->callback_servant_->_this ();
  47
  48   // Activate this Reply Handler.
  49   this->ami_handler_ =
  50     this->_this ();
  51
  52   // Register the client callback with the server asynchronously.
  53   factory->sendc_register_callback (this->ami_handler_.in (),
  54                                     pathname,
  55                                     this->callback_.in ());
  56 }
  57
  58 void
  59 Push_Iterator_Handler::deactivate (void)
  60 {
  61   // Get the POA used when activating the Reply Handler object.
  62   PortableServer::POA_var poa = this->_default_POA ();
  63
  64   // Get the object ID associated with this servant.
  65   PortableServer::ObjectId_var oid =
  66     poa->servant_to_id (this);
  67
  68   // Now deactivate the AMI_CallbackHandler object.
  69   poa->deactivate_object (oid.in ());
  70 }