1 files changed, 84 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/LWFT/StateSynchronizationAgent_i_T.cpp b/TAO/orbsvcs/orbsvcs/LWFT/StateSynchronizationAgent_i_T.cpp
new file mode 100644
index 00000000000..5e088554a3d
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/LWFT/StateSynchronizationAgent_i_T.cpp
@@ -0,0 +1,84 @@
+// -*- C++ -*-
+
+//=============================================================================
+/**
+ *  @file    StateSynchronizationAgent_i_T.cpp
+ *
+ *  $Id$
+ *
+ *  @author  Friedhelm Wolf (fwolf@dre.vanderbilt.edu)
+ */
+//=============================================================================
+
+#ifndef STATE_SYNCHRONIZATION_AGENT_I_T_CPP_
+#define STATE_SYNCHRONIZATION_AGENT_I_T_CPP_
+
+#ifdef FLARE_USES_DDS
+
+#include "DDSStateUpdate_T.h"
+
+template <typename DATA_TYPE>
+void
+StateSynchronizationAgent_i::register_application_with_dds (
+  const char * object_id,
+  ReplicatedApplication_ptr app)
+{
+/*
+  ACE_DEBUG ((LM_TRACE,
+              "SSA::register_application_with_dds (%s) called.\n",
+              object_id));
+*/
+  ACE_CString oid (object_id);
+
+  if (application_map_.bind (oid,
+                             ReplicatedApplication::_duplicate (app)) != 0)
+    {
+      ACE_DEBUG ((LM_WARNING, 
+		              "(%P|%t) SSA::register_application_with_dds () "
+		              "could not bind application %s to "
+		              "the map successfully\n",
+		              object_id));
+    }
+
+  if (!use_corba_)
+    {
+      try
+        {
+        /*
+          ACE_DEBUG ((LM_TRACE,
+                      "SSA::register_application_with_dds add DDS participant"
+                      " for application %s\n",
+                      object_id));
+        */  
+          // create a new list which will have only one entry for DDS
+          ReplicaGroup replica_group;
+          replica_group.use_dds = true;
+          
+          // register a DDS participant for this application
+          replica_group.replicas.push_back (
+            typename StateSynchronizationAgent_i::STATEFUL_OBJECT_PTR (
+               new DDSStateUpdate_T <DATA_TYPE> (
+                 oid.c_str (),
+                 this->get_unique_id (oid.c_str ()),
+                 domain_participant_.in (),
+                 publisher_.in (),
+                 subscriber_.in (),
+                 app)));
+
+          ACE_CString oid (object_id);
+      
+          // this should work without doing a rebind, since there is
+          // only one application of the same type per process
+          replica_map_.bind (oid, replica_group);
+        }
+      catch (const DDSFailure & ex)
+        {
+          ACE_ERROR ((LM_ERROR,
+                      "SSA::register_application_with_dds () DDS problem : %s\n",
+                      ex.description ().c_str ()));
+        }
+    } // end !use_corba_
+}
+#endif /* FLARE_USES_DDS */
+
+#endif /* STATE_SYNCHRONIZATION_AGENT_I_T_CPP_ */