1 files changed, 71 insertions, 0 deletions
diff --git a/CIAO/DAnCE/LocalityManager/Scheduler/Deployment_Completion.cpp b/CIAO/DAnCE/LocalityManager/Scheduler/Deployment_Completion.cpp
new file mode 100644
index 00000000000..5ec39122a6d
--- /dev/null
+++ b/CIAO/DAnCE/LocalityManager/Scheduler/Deployment_Completion.cpp
@@ -0,0 +1,71 @@
+// $Id$
+#include "Deployment_Completion.h"
+
+#include "Logger/Log_Macros.h"
+
+namespace DAnCE
+{
+  Deployment_Completion::Deployment_Completion (void)
+    : Completion_Counter_Base< TAO_SYNCH_MUTEX > (0, 0),
+      mutex_ (),
+      condition_ (this->mutex_)
+  {
+  }
+    
+  Deployment_Completion::~Deployment_Completion (void)
+  {
+  }
+  
+  void
+  Deployment_Completion::accept (Event_Future &future)
+  {
+    future.attach (this);
+    this->increment_exec_count ();
+  }
+
+  void 
+  Deployment_Completion::update (const Event_Future &future)
+  {
+    this->decrement_exec_count ();
+  }
+    
+  bool
+  Deployment_Completion::wait_on_completion (ACE_Time_Value *tv)
+  {
+    ACE_GUARD_RETURN (TAO_SYNCH_MUTEX,
+                      guard,
+                      this->mutex_, false);
+    
+    while (!this->all_completed ())
+      {
+        int retval = this->condition_.wait (tv);
+        
+        if (retval == -1)
+          {
+            DANCE_ERROR (2, (LM_ERROR, DLINFO
+                             ACE_TEXT ("Deployment_Completion::wait_on_completion - ")
+                             ACE_TEXT ("Timed out waiting on event completion\n")));
+            return false;
+          }
+      }
+    
+    DANCE_DEBUG (8, (LM_DEBUG, DLINFO
+                     ACE_TEXT ("Deployment_Completion::wait_on_completion - ")
+                     ACE_TEXT ("All events completed\n")));
+
+    return true;
+  }
+  
+  void
+  Deployment_Completion::on_all_completed ()
+  {
+    this->condition_.broadcast ();
+  }
+  
+  void 
+  Deployment_Completion::on_all_completed_with_failure ()
+  {
+    this->condition_.broadcast ();
+  }
+}
+