1 files changed, 0 insertions, 98 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.cpp b/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.cpp
deleted file mode 100644
index 5f459e9af84..00000000000
--- a/TAO/orbsvcs/orbsvcs/Event/EC_Dispatching_Task.cpp
+++ /dev/null
@@ -1,98 +0,0 @@
-// $Id$
-
-#include "EC_Dispatching_Task.h"
-#include "EC_ProxySupplier.h"
-
-#if ! defined (__ACE_INLINE__)
-#include "EC_Dispatching_Task.i"
-#endif /* __ACE_INLINE__ */
-
-ACE_RCSID(Event, EC_Dispatching, "$Id$")
-
-int
-TAO_EC_Dispatching_Task::svc (void)
-{
-  int done = 0;
-  while (!done)
-    {
-      ACE_TRY_NEW_ENV
-        {
-          ACE_Message_Block *mb;
-          if (this->getq (mb) == -1)
-            if (ACE_OS::last_error () == ESHUTDOWN)
-              return 0;
-          else
-            ACE_ERROR ((LM_ERROR,
-                        "EC (%P|%t) getq error in Dispatching Queue\n"));
-
-          TAO_EC_Dispatch_Command *command =
-            ACE_dynamic_cast(TAO_EC_Dispatch_Command*, mb);
-
-          if (command == 0)
-            {
-              ACE_Message_Block::release (mb);
-              continue;
-            }
-
-          int result = command->execute (ACE_TRY_ENV);
-          ACE_TRY_CHECK;
-
-          ACE_Message_Block::release (mb);
-
-          if (result == -1)
-            done = 1;
-        }
-      ACE_CATCHANY
-        {
-          ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
-                               "EC (%P|%t) exception in dispatching queue");
-        }
-      ACE_ENDTRY;
-    }
-  return 0;
-}
-
-void
-TAO_EC_Dispatching_Task::push (TAO_EC_ProxyPushSupplier *proxy,
-                               RtecEventComm::EventSet& event,
-                               CORBA::Environment &ACE_TRY_ENV)
-{
-  if (this->allocator_ == 0)
-    this->allocator_ = ACE_Allocator::instance ();
-
-  void* buf = this->allocator_->malloc (sizeof (TAO_EC_Push_Command));
-
-  if (buf == 0)
-    ACE_THROW (CORBA::NO_MEMORY (TAO_DEFAULT_MINOR_CODE,
-                                 CORBA::COMPLETED_NO));
-
-  ACE_Message_Block *mb =
-    new (buf) TAO_EC_Push_Command (proxy,
-                                   event,
-                                   this->data_block_.duplicate (),
-                                   this->allocator_);
-  this->putq (mb);
-}
-
-// ****************************************************************
-
-TAO_EC_Dispatch_Command::~TAO_EC_Dispatch_Command (void)
-{
-}
-
-// ****************************************************************
-
-int
-TAO_EC_Shutdown_Command::execute (CORBA::Environment&)
-{
-  return -1;
-}
-
-// ****************************************************************
-
-int
-TAO_EC_Push_Command::execute (CORBA::Environment& ACE_TRY_ENV)
-{
-  this->proxy_->push_to_consumer (this->event_, ACE_TRY_ENV);
-  return 0;
-}