1 files changed, 35 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Notify/Method_Request_Shutdown.cpp b/TAO/orbsvcs/orbsvcs/Notify/Method_Request_Shutdown.cpp
new file mode 100644
index 00000000000..cc52c47852f
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/Notify/Method_Request_Shutdown.cpp
@@ -0,0 +1,35 @@
+// $Id$
+
+#include "Method_Request_Shutdown.h"
+#include "ThreadPool_Task.h"
+
+#if ! defined (__ACE_INLINE__)
+#include "Method_Request_Shutdown.inl"
+#endif /* __ACE_INLINE__ */
+
+ACE_RCSID(RT_Notify, TAO_NS_Method_Request_Shutdown, "$Id$")
+
+TAO_NS_Method_Request_Shutdown::TAO_NS_Method_Request_Shutdown (TAO_NS_ThreadPool_Task* task)
+  : task_ (task)
+{
+}
+
+TAO_NS_Method_Request_Shutdown::~TAO_NS_Method_Request_Shutdown ()
+{
+}
+
+TAO_NS_Method_Request*
+TAO_NS_Method_Request_Shutdown::copy (void)
+{
+  return new TAO_NS_Method_Request_Shutdown (this->task_);
+}
+
+int
+TAO_NS_Method_Request_Shutdown::execute (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+{
+  // Shut down the scheduler by deactivating the activation queue's
+  // underlying message queue - should pop all worker threads off their
+  // wait and they'll exit.
+  this->task_->msg_queue ()->deactivate ();
+  return -1;
+}