1 files changed, 87 insertions, 0 deletions
diff --git a/trunk/TAO/tao/Thread_Per_Connection_Handler.cpp b/trunk/TAO/tao/Thread_Per_Connection_Handler.cpp
new file mode 100644
index 00000000000..9cf61f3bfc2
--- /dev/null
+++ b/trunk/TAO/tao/Thread_Per_Connection_Handler.cpp
@@ -0,0 +1,87 @@
+//$Id$
+#include "tao/Thread_Per_Connection_Handler.h"
+#include "tao/Connection_Handler.h"
+#include "tao/debug.h"
+#include "tao/Transport.h"
+#include "tao/ORB_Core.h"
+#include "ace/Flag_Manip.h"
+
+ACE_RCSID (tao,
+           Thread_Per_Connection_Handler,
+           "$Id$")
+
+TAO_BEGIN_VERSIONED_NAMESPACE_DECL
+
+TAO_Thread_Per_Connection_Handler::TAO_Thread_Per_Connection_Handler (
+    TAO_Connection_Handler *ch,
+    TAO_ORB_Core *oc)
+  : TAO_TPC_BASE (oc->thr_mgr ())
+  , ch_ (ch)
+{
+  this->ch_->transport ()->add_reference ();
+}
+
+TAO_Thread_Per_Connection_Handler::~TAO_Thread_Per_Connection_Handler (void)
+{
+  this->ch_->close_connection ();
+  this->ch_->transport ()->remove_reference ();
+}
+
+int
+TAO_Thread_Per_Connection_Handler::activate (long flags,
+                                             int n_threads,
+                                             int force_active,
+                                             long priority,
+                                             int grp_id,
+                                             ACE_Task_Base *task,
+                                             ACE_hthread_t thread_handles[],
+                                             void *stack[],
+                                             size_t stack_size[],
+                                             ACE_thread_t  thread_names[])
+{
+  if (TAO_debug_level)
+    {
+      ACE_DEBUG  ((LM_DEBUG,
+                   ACE_TEXT ("TAO (%P|%t) - Thread_Per_Connection_Handler::")
+                   ACE_TEXT ("activate %d threads, flags = %d\n"),
+                   n_threads,
+                   flags));
+    }
+
+  return TAO_TPC_BASE::activate (flags,
+                                 n_threads,
+                                 force_active,
+                                 priority,
+                                 grp_id,
+                                 task,
+                                 thread_handles,
+                                 stack,
+                                 stack_size,
+                                 thread_names);
+}
+
+int
+TAO_Thread_Per_Connection_Handler::svc (void)
+{
+  ACE::clr_flags (this->ch_->transport ()->event_handler_i ()->get_handle (),
+                  ACE_NONBLOCK);
+
+  // Call the implementation here
+  return this->ch_->svc_i ();
+}
+
+int
+TAO_Thread_Per_Connection_Handler::open (void*v)
+{
+  return this->ch_->open_handler (v);
+}
+
+int
+TAO_Thread_Per_Connection_Handler::close (u_long)
+{
+  delete this;
+
+  return 0;
+}
+
+TAO_END_VERSIONED_NAMESPACE_DECL