1 files changed, 61 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/Update_Manager.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/Update_Manager.cpp
new file mode 100644
index 00000000000..c207baefd16
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/EventChannel/Update_Manager.cpp
@@ -0,0 +1,61 @@
+// $Id$
+
+#include "orbsvcs/FtRtEvent/EventChannel/Update_Manager.h"
+
+ACE_RCSID (EventChannel,
+           Update_Manager,
+           "$Id$")
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+Update_Manager::Update_Manager(ACE_Auto_Event& evt,
+                               int num_backups,
+                               int transaction_depth,
+                               bool& success)
+  : evt_(evt)
+  , replied_(num_backups)
+  , suicide_condition_(num_backups)
+  , num_backups_(num_backups)
+  , transaction_level_(transaction_depth)
+  , success_(success)
+{
+  suicide_condition_.flip();
+  signal_condition_.resize(transaction_depth, true);
+  signal_condition_.resize(num_backups);
+}
+
+Update_Manager::~Update_Manager()
+{
+}
+
+void Update_Manager::handle_reply(int id)
+{
+  ACE_Guard<ACE_SYNCH_MUTEX> guard(mutex_);
+  replied_[id] = true;
+
+  if ((replied_ & signal_condition_) == signal_condition_) {
+    success_ = true;
+    evt_.signal();
+  }
+  if (replied_ == suicide_condition_)
+    delete this;
+}
+
+void Update_Manager::handle_exception(int id)
+{
+  ACE_Guard<ACE_SYNCH_MUTEX> guard(mutex_);
+  replied_[id] = true;
+  ++transaction_level_;
+
+  if (num_backups_ > transaction_level_) {
+    signal_condition_[transaction_level_]=true;
+  }
+  else {
+    success_ = false;
+    evt_.signal();
+  }
+  if (replied_ == suicide_condition_)
+    delete this;
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL