1 files changed, 117 insertions, 0 deletions
diff --git a/TAO/tao/CSD_Framework/CSD_POA.cpp b/TAO/tao/CSD_Framework/CSD_POA.cpp
new file mode 100644
index 00000000000..d2f8656b11b
--- /dev/null
+++ b/TAO/tao/CSD_Framework/CSD_POA.cpp
@@ -0,0 +1,117 @@
+// $Id$
+
+#include "tao/CSD_Framework/CSD_POA.h"
+#include "tao/CSD_Framework/CSD_Strategy_Repository.h"
+#include "tao/CSD_Framework/CSD_Strategy_Base.h"
+
+#include "ace/Dynamic_Service.h"
+
+ACE_RCSID (CSD_Framework,
+           CSD_POA,
+           "$Id$")
+
+#if !defined (__ACE_INLINE__)
+# include "tao/CSD_Framework/CSD_POA.inl"
+#endif /* ! __ACE_INLINE__ */
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+// Implementation skeleton constructor
+TAO_CSD_POA::TAO_CSD_POA (const String &name,
+                          PortableServer::POAManager_ptr poa_manager,
+                          const TAO_POA_Policy_Set &policies,
+                          TAO_Root_POA *parent,
+                          ACE_Lock &lock,
+                          TAO_SYNCH_MUTEX &thread_lock,
+                          TAO_ORB_Core &orb_core,
+                          TAO_Object_Adapter *object_adapter)
+: TAO_Regular_POA (name,
+                   poa_manager,
+                   policies,
+                   parent,
+                   lock,
+                   thread_lock,
+                   orb_core,
+                   object_adapter)
+{
+  ACE_NEW_THROW_EX (this->sds_proxy_,
+                    TAO::CSD::Strategy_Proxy (),
+                    CORBA::NO_MEMORY ());
+}
+
+
+// Implementation skeleton destructor
+TAO_CSD_POA::~TAO_CSD_POA (void)
+{
+  delete this->sds_proxy_;
+}
+
+void TAO_CSD_POA::set_csd_strategy (::CSD_Framework::Strategy_ptr strategy)
+{
+  if (CORBA::is_nil (strategy))
+    {
+      throw ::CORBA::BAD_PARAM ();
+    }
+  this->sds_proxy_->custom_strategy (strategy);
+}
+
+TAO_Root_POA *
+TAO_CSD_POA::new_POA (const String &name,
+                      PortableServer::POAManager_ptr poa_manager,
+                      const TAO_POA_Policy_Set &policies,
+                      TAO_Root_POA *parent,
+                      ACE_Lock &lock,
+                      TAO_SYNCH_MUTEX &thread_lock,
+                      TAO_ORB_Core &orb_core,
+                      TAO_Object_Adapter *object_adapter)
+{
+  TAO_CSD_POA *poa = 0;
+
+  ACE_NEW_THROW_EX (poa,
+                    TAO_CSD_POA (name,
+                             poa_manager,
+                             policies,
+                             parent,
+                             lock,
+                             thread_lock,
+                             orb_core,
+                             object_adapter
+                            ),
+                    CORBA::NO_MEMORY ());
+
+  TAO_CSD_Strategy_Repository *repo =
+    ACE_Dynamic_Service<TAO_CSD_Strategy_Repository>::instance ("TAO_CSD_Strategy_Repository");
+
+  CSD_Framework::Strategy_var strategy = repo->find (name);
+
+  if (! ::CORBA::is_nil (strategy.in ()))
+    {
+      poa->set_csd_strategy (strategy.in ());
+    }
+
+  return poa;
+}
+
+void TAO_CSD_POA::poa_activated_hook ()
+{
+  this->sds_proxy_->poa_activated_event ();
+}
+
+void TAO_CSD_POA::poa_deactivated_hook ()
+{
+  this->sds_proxy_->poa_deactivated_event ();
+}
+
+void TAO_CSD_POA::servant_activated_hook (PortableServer::Servant servant,
+                               const PortableServer::ObjectId& oid)
+{
+  this->sds_proxy_->servant_activated_event (servant, oid);
+}
+
+void TAO_CSD_POA::servant_deactivated_hook (PortableServer::Servant servant,
+                                 const PortableServer::ObjectId& oid)
+{
+  this->sds_proxy_->servant_deactivated_event (servant, oid);
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL