1 files changed, 70 insertions, 0 deletions
diff --git a/trunk/TAO/tests/Portable_Interceptors/PICurrent/ClientORBInitializer.cpp b/trunk/TAO/tests/Portable_Interceptors/PICurrent/ClientORBInitializer.cpp
new file mode 100644
index 00000000000..425c916436e
--- /dev/null
+++ b/trunk/TAO/tests/Portable_Interceptors/PICurrent/ClientORBInitializer.cpp
@@ -0,0 +1,70 @@
+// -*- C++ -*-
+
+#include "ClientORBInitializer.h"
+#include "ClientRequestInterceptor.h"
+
+#include "tao/ORB_Constants.h"
+
+#include "ace/Log_Msg.h"
+
+ACE_RCSID (PICurrent,
+           ClientORBInitializer,
+           "$Id$")
+
+
+PortableInterceptor::SlotId slot_id = 2093843211;
+
+
+void
+ClientORBInitializer::pre_init (
+    PortableInterceptor::ORBInitInfo_ptr /* info */
+    ACE_ENV_ARG_DECL_NOT_USED)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+}
+
+void
+ClientORBInitializer::post_init (
+    PortableInterceptor::ORBInitInfo_ptr info
+    ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  CORBA::Object_var obj =
+    info->resolve_initial_references ("PICurrent"
+                                      ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  PortableInterceptor::Current_var pi_current =
+    PortableInterceptor::Current::_narrow (obj.in ()
+                                           ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (CORBA::is_nil (pi_current.in ()))
+    {
+      ACE_ERROR ((LM_ERROR,
+                  "(%P|%t) ERROR: Could not resolve PICurrent object.\n"));
+
+      ACE_THROW (CORBA::INTERNAL ());
+    }
+
+  ::slot_id = info->allocate_slot_id (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  PortableInterceptor::ClientRequestInterceptor_ptr foo;
+  ACE_NEW_THROW_EX (foo,
+                    ClientRequestInterceptor (::slot_id,
+                                              pi_current.in ()),
+                    CORBA::NO_MEMORY (
+                      CORBA::SystemException::_tao_minor_code (
+                        TAO::VMCID,
+                        ENOMEM),
+                      CORBA::COMPLETED_NO));
+  ACE_CHECK;
+
+  PortableInterceptor::ClientRequestInterceptor_var interceptor =
+    foo;
+
+  info->add_client_request_interceptor (interceptor.in ()
+                                        ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}