1 files changed, 90 insertions, 0 deletions
diff --git a/TAO/examples/Content_Server/AMI_Observer/Push_Iterator_Handler.cpp b/TAO/examples/Content_Server/AMI_Observer/Push_Iterator_Handler.cpp
new file mode 100644
index 00000000000..96a7b7c0b88
--- /dev/null
+++ b/TAO/examples/Content_Server/AMI_Observer/Push_Iterator_Handler.cpp
@@ -0,0 +1,90 @@
+// -*- C++ -*-
+// $Id$
+
+// Ossama Othman <ossama@uci.edu>
+
+#include "ace/Log_Msg.h"
+#include "ace/Process_Manager.h"
+#include "Push_Iterator_Handler.h"
+#include "Callback_i.h"
+
+ACE_RCSID (AMI_Observer, Push_Iterator_Handler, "$Id$")
+
+Push_Iterator_Handler::Push_Iterator_Handler (void)
+  : callback_servant_ (0),
+    callback_ (),
+    ami_handler_ ()
+{
+  // Nothing else
+}
+
+Push_Iterator_Handler::~Push_Iterator_Handler (void)
+{
+  // Nothing else
+}
+
+void
+Push_Iterator_Handler::register_callback
+  (const Web_Server::Metadata_Type &metadata
+   ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  this->callback_servant_->metadata (metadata);
+
+  // This handler is no longer needed, so deactivate it.
+  this->deactivate (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+void
+Push_Iterator_Handler::run (int *request_count,
+                            const char *pathname,
+                            Web_Server::Iterator_Factory_ptr factory
+                            ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException,
+                   Web_Server::Error_Result))
+{
+  ACE_NEW_THROW_EX (this->callback_servant_,
+                    Callback_i (request_count),
+                    CORBA::NO_MEMORY ());
+  ACE_CHECK;
+
+  // Pass ownership of the Callback servant to the POA.
+  PortableServer::ServantBase_var tmp (this->callback_servant_);
+
+  // Activate the Callback.
+  this->callback_ =
+    this->callback_servant_->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  // Activate this Reply Handler.
+  this->ami_handler_ =
+    this->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  // Register the client callback with the server asynchronously.
+  factory->sendc_register_callback (this->ami_handler_.in (),
+                                    pathname,
+                                    this->callback_.in ()
+                                    ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+void
+Push_Iterator_Handler::deactivate (ACE_ENV_SINGLE_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  // Get the POA used when activating the Reply Handler object.
+  PortableServer::POA_var poa = this->_default_POA (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  // Get the object ID associated with this servant.
+  PortableServer::ObjectId_var oid =
+    poa->servant_to_id (this
+                        ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  // Now deactivate the AMI_CallbackHandler object.
+  poa->deactivate_object (oid.in () ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}