1 files changed, 57 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/orbsvcs/Log/Log_Flush_Handler.cpp b/ACE/TAO/orbsvcs/orbsvcs/Log/Log_Flush_Handler.cpp
new file mode 100644
index 00000000000..bd4affd95c1
--- /dev/null
+++ b/ACE/TAO/orbsvcs/orbsvcs/Log/Log_Flush_Handler.cpp
@@ -0,0 +1,57 @@
+#include "orbsvcs/Log/Log_Flush_Handler.h"
+#include "orbsvcs/Log/Log_i.h"
+
+ACE_RCSID (Log,
+           Log_Flush_Handler,
+           "$Id$")
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+TAO_Log_Flush_Handler::TAO_Log_Flush_Handler (ACE_Reactor* reactor,
+                                              TAO_Log_i* log,
+                                              const ACE_Time_Value& interval)
+  : timer_id_(-1),
+    reactor_(reactor),
+    log_(log),
+    interval_(interval)
+{
+}
+
+TAO_Log_Flush_Handler::~TAO_Log_Flush_Handler ()
+{
+  this->cancel ();
+}
+
+void
+TAO_Log_Flush_Handler::schedule ()
+{
+  this->cancel ();
+  this->timer_id_ =
+    this->reactor_->schedule_timer (this, 0, this->interval_, this->interval_);
+}
+
+void
+TAO_Log_Flush_Handler::cancel ()
+{
+  if (this->timer_id_ != -1)
+    {
+      this->reactor_->cancel_timer (timer_id_);
+      this->timer_id_ = -1;
+    }
+}
+
+int
+TAO_Log_Flush_Handler::handle_timeout (const ACE_Time_Value&, const void *)
+{
+  try
+    {
+      log_->flush ();
+    }
+  catch (const CORBA::Exception&)
+    {
+    }
+
+  return 0;
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL