1 files changed, 138 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/Set_Update_Interceptor.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/Set_Update_Interceptor.cpp
new file mode 100644
index 00000000000..12d8de6e9e3
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/Set_Update_Interceptor.cpp
@@ -0,0 +1,138 @@
+// $Id$
+
+#include "Set_Update_Interceptor.h"
+#include "orbsvcs/FTRTC.h"
+#include "Request_Context_Repository.h"
+
+ACE_RCSID (EventChannel,
+           Set_Update_Intercetpor,
+           "$Id$")
+
+TAO_Set_Update_Interceptor::
+TAO_Set_Update_Interceptor ()
+: myname_ ("TAO_Set_Update_Interceptor")
+{
+}
+
+TAO_Set_Update_Interceptor::~TAO_Set_Update_Interceptor (void)
+{
+}
+
+char *
+TAO_Set_Update_Interceptor::name (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  return CORBA::string_dup (this->myname_);
+}
+
+void
+TAO_Set_Update_Interceptor::destroy (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+ACE_THROW_SPEC ((CORBA::SystemException))
+{
+}
+
+void
+TAO_Set_Update_Interceptor::send_poll (
+                                   PortableInterceptor::ClientRequestInfo_ptr
+                                   ACE_ENV_ARG_DECL_NOT_USED)
+                                   ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  // Do Nothing
+}
+
+void
+TAO_Set_Update_Interceptor::send_request (
+                                      PortableInterceptor::ClientRequestInfo_ptr ri
+                                      ACE_ENV_ARG_DECL)
+                                      ACE_THROW_SPEC ((CORBA::SystemException,
+                                      PortableInterceptor::ForwardRequest))
+{
+  CORBA::String_var operation = ri->operation (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (strcmp(operation.in(), "set_update")==0 ||
+    strcmp(operation.in(), "oneway_set_update") ==0) {
+      CORBA::Any_var a = Request_Context_Repository().get_ft_request_service_context(ri
+        ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+
+      IOP::ServiceContext* sc;
+
+      if ((*a >>= sc) ==0)
+        return;
+
+      ri->add_request_service_context (*sc, 0 ACE_ENV_ARG_PARAMETER);
+      ACE_CHECK;
+
+      FTRT::TransactionDepth transaction_depth =
+        Request_Context_Repository().get_transaction_depth(ri);
+      TAO_OutputCDR cdr;
+      ACE_Message_Block mb;
+
+      if (transaction_depth) {
+        if (!(cdr << ACE_OutputCDR::from_boolean (TAO_ENCAP_BYTE_ORDER)))
+          ACE_THROW (CORBA::MARSHAL ());
+
+        // Add Transaction Depth Context
+        if ((cdr << transaction_depth) == 0)
+          ACE_THROW (CORBA::MARSHAL ());
+        sc->context_id = FTRT::FT_TRANSACTION_DEPTH;
+
+        ACE_CDR::consolidate(&mb, cdr.begin());
+        sc->context_data.replace(mb.length(), &mb);
+
+        ri->add_request_service_context (*sc, 0 ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+
+        cdr.reset();
+      }
+
+      // Add Sequence Number Context
+
+      FTRT::SequenceNumber sequence_number =
+        Request_Context_Repository().get_sequence_number(ri ACE_ENV_ARG_PARAMETER);
+
+      ACE_DEBUG((LM_DEBUG, "send_request : sequence_number = %d\n", sequence_number));
+      if (sequence_number != 0) {
+        if (!(cdr << ACE_OutputCDR::from_boolean (TAO_ENCAP_BYTE_ORDER)))
+          ACE_THROW (CORBA::MARSHAL ());
+        if ((cdr << sequence_number) == 0)
+          ACE_THROW (CORBA::MARSHAL ());
+        sc->context_id = FTRT::FT_SEQUENCE_NUMBER;
+
+        ACE_CDR::consolidate(&mb, cdr.begin());
+        sc->context_data.replace(mb.length(), &mb);
+
+        ri->add_request_service_context (*sc, 0 ACE_ENV_ARG_PARAMETER);
+        ACE_CHECK;
+      }
+    }
+}
+
+void
+TAO_Set_Update_Interceptor::receive_reply (
+  PortableInterceptor::ClientRequestInfo_ptr ri
+  ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  ACE_UNUSED_ARG(ri);
+}
+
+void
+TAO_Set_Update_Interceptor::receive_other (
+                                       PortableInterceptor::ClientRequestInfo_ptr
+                                       ACE_ENV_ARG_DECL_NOT_USED)
+                                       ACE_THROW_SPEC ((CORBA::SystemException,
+                                       PortableInterceptor::ForwardRequest))
+{
+}
+
+void
+TAO_Set_Update_Interceptor::receive_exception (
+  PortableInterceptor::ClientRequestInfo_ptr ri
+  ACE_ENV_ARG_DECL)
+  ACE_THROW_SPEC ((CORBA::SystemException,
+  PortableInterceptor::ForwardRequest))
+{
+  ACE_UNUSED_ARG(ri);
+}