1 files changed, 0 insertions, 321 deletions
diff --git a/ACE/tests/Bug_2540_Regression_Test.cpp b/ACE/tests/Bug_2540_Regression_Test.cpp
deleted file mode 100644
index 66f1f4f4ddb..00000000000
--- a/ACE/tests/Bug_2540_Regression_Test.cpp
+++ /dev/null
@@ -1,321 +0,0 @@
-/**
- * @file Bug_2540_Regression_Test.cpp
- *
- * $Id$
- *
- * Reproduces the problems reported in bug 2540
- *   http://deuce.doc.wustl.edu/bugzilla/show_bug.cgi?id=2540
- *
- * @author Carlos O'Ryan <coryan@atdesk.com>
- * Based on Bug_1890_Regression_Test
- */
-
-#include "test_config.h"
-
-#include "ace/Pipe.h"
-#include "ace/Event_Handler.h"
-#include "ace/Reactor.h"
-#include "ace/Select_Reactor.h"
-
-ACE_RCSID (tests,
-           Bug_2540_Regression_Test,
-           "$Id$")
-
-int const nhandlers = 3;
-
-/**
- * This class is used to create real I/O in the test.  To keep the I/O under
- * control and keep the test to a single process we use ACE_Pipe.  This class
- * is known to work with the Reactor, in fact, that is its main function.
- *
- * Handler counts how many calls to handle_input() has the reactor performed.
- * When bug 2540 is triggered the Reactor continues to call the timers, but it
- * stops calling select() and the handle_input() functions.
- */
-class Handler : public ACE_Event_Handler
-{
-public:
-    Handler();
-
-    //FUZZ: disable check_for_lack_ACE_OS
-    /// Initialize the pipe and register with the reactor
-    int open(ACE_Reactor * reactor);
-    //FUZZ: enable check_for_lack_ACE_OS
-
-    /// Return the current count
-    size_t handle_input_count() const;
-
-    /// Write some data
-    void send_dummy_data();
-
-    /// Removes itself from the reactor on the next call to handle_input()
-    void simulate_socket_closure();
-
-    /// Reactor callback
-    virtual ACE_HANDLE get_handle() const;
-    virtual int handle_input(ACE_HANDLE);
-
-private:
-    bool auto_remove_flag_;
-
-    size_t handle_input_count_;
-
-    ACE_Pipe the_pipe_;
-
-    ACE_HANDLE handles_[2];
-};
-
-/**
- * This is the main driver for the test.  This timer is called by the reactor
- * in a repeating interval.  On the first @c initial_iterations the Timer
- * writes data through all of its handlers.  On iteration @c initial_iteration
- * it triggers bug 2540 by removing two handlers from the reactor.
- * 
- */
-class Timer : public ACE_Event_Handler
-{
-public:
-    Timer();
-
-    //FUZZ: disable check_for_lack_ACE_OS
-    int open(ACE_Reactor * reactor);
-    void close();
-    //FUZZ: enable check_for_lack_ACE_OS
-
-    bool check_expected_results() const;
-
-    virtual int handle_timeout(ACE_Time_Value const &, void const*);
-
-private:
-    void send_data_through_handlers();
-    void remove_some_handlers();
-
-    Handler & special_handler();
-    Handler const & special_handler() const;
-
-private:
-    Handler handler_[nhandlers];
-    int iteration_;
-
-    size_t recorded_count_;
-};
-
-int
-run_main (int, ACE_TCHAR *[])
-{
-  ACE_START_TEST (ACE_TEXT ("Bug_2540_Regression_Test"));
-
-  // Bug 2540 is all about ACE_Select_Reactor, so run it on that reactor
-  // regardless of platform. In particular, this test relies on a handler
-  // that doesn't consume ready-to-read data being called back - this won't
-  // happen with ACE_WFMO_Reactor.
-  ACE_Select_Reactor select_reactor;
-  ACE_Reactor reactor (&select_reactor);
-
-  // Create the timer, this is the main driver for the test
-  Timer * timer = new Timer;
-
-  // Initialize the timer and register with the reactor
-  if (-1 == timer->open (&reactor))
-    {
-      ACE_ERROR_RETURN ((LM_ERROR, "Cannot initialize timer\n"), -1);
-    }
-
-  reactor.run_reactor_event_loop ();
-
-  // Verify that the results are what we expect
-  if (!timer->check_expected_results ())
-    {
-      ACE_ERROR_RETURN ((LM_ERROR, "Test failed\n"), -1);
-    }
-
-  // Cleanup
-  timer->close ();
-  delete timer;
-
-  ACE_END_TEST;
-
-  return 0;
-}
-
-Handler::Handler()
-    : auto_remove_flag_(false)
-    , handle_input_count_(0)
-    , the_pipe_()
-{
-}
-
-int Handler::open(ACE_Reactor * r)
-{
-    if(-1 == the_pipe_.open(handles_))
-    {
-      return -1;
-    }
-    if(-1 == r->register_handler(this, ACE_Event_Handler::READ_MASK))
-    {
-      return -1;
-    }
-    return 0;
-}
-
-size_t Handler::handle_input_count() const
-{
-    return handle_input_count_;
-}
-
-void Handler::send_dummy_data()
-{
-    char buf[] = "dummy";
-    (void) the_pipe_.send(buf, sizeof(buf));
-}
-
-void Handler::simulate_socket_closure()
-{
-    auto_remove_flag_ = true;
-}
-
-ACE_HANDLE Handler::get_handle() const
-{
-    return the_pipe_.read_handle();
-}
-
-int Handler::handle_input(ACE_HANDLE /* h */)
-{
-
-    ++handle_input_count_;
-    // ACE_DEBUG((LM_DEBUG, "Handler::handle_input called for %d\n", h));
-
-    if(auto_remove_flag_)
-    {
-      auto_remove_flag_ = false;
-      return -1;
-    }
-
-    return 0;
-}
-
-int const initial_iterations = 5;
-int const total_iterations = 10;
-
-int const special_handler_index = nhandlers - 1;
-
-Timer::Timer()
-    : iteration_(0)
-    , recorded_count_(0)
-{
-}
-
-int Timer::open(ACE_Reactor * r)
-{
-  this->reactor(r);
-
-  // Initialize both handles and register them with the reactor for reading.
-  for(int i = 0; i != nhandlers; ++i)
-  {
-      if (-1 == handler_[i].open(r))
-      {
-        ACE_ERROR_RETURN ((LM_ERROR, "Could not open dummy handler %d\n", i), -1);
-      }
-  }
-
-  ACE_Time_Value const interval(0, ACE_ONE_SECOND_IN_USECS / 10);
-  ACE_Time_Value const startup (0, ACE_ONE_SECOND_IN_USECS / 20);
-
-  if ( -1 == r->schedule_timer(this, 0, startup, interval))
-  {
-      ACE_ERROR_RETURN((LM_ERROR, "Could not schedule timer\n"), -1);
-  }
-
-  return 0;
-}
-
-void Timer::close()
-{
-  for(int i = 0; i != nhandlers; ++i)
-  {
-      reactor()->remove_handler(&handler_[i], ACE_Event_Handler::ALL_EVENTS_MASK);
-  }
-  reactor()->cancel_timer(this);
-}
-
-bool Timer::check_expected_results() const
-{
-    // We expect at least one more call after the other handlers are removed.
-    if(recorded_count_ + 1 < special_handler().handle_input_count() )
-    {
-      return true;
-    }
-    return false;
-}
-
-int Timer::handle_timeout(ACE_Time_Value const &, void const *)
-{
-    if (iteration_ == 0)
-    {
-      // Sending data on the first iteration makes the handles always
-      // "ready" for reading because the Handler::handle_input() function
-      // never consumes the data.
-      send_data_through_handlers();
-    }
-
-    ++iteration_;
-    if (iteration_ < initial_iterations)
-    {
-      // The first iterations are there just to prime things.
-      return 0;
-    }
-    
-    if (iteration_ == initial_iterations)
-    {
-      // We expect the special_handler() to work normally after this
-      // iteration, i.e., more calls to handle_input() should be delivered
-      // to it.
-      recorded_count_  = special_handler().handle_input_count();
-
-      // Remove the handlers the next time the loop runs
-      remove_some_handlers();
-
-      // Run the event loop, this causes the handlers to be removed from the
-      // reactor, except for special_handler()
-      ACE_Time_Value interval(0, ACE_ONE_SECOND_IN_USECS / 50);
-      reactor()->handle_events(&interval);
-
-      return 0;
-    }
-
-    if (iteration_ < total_iterations)
-    {
-      // Run a while more to make sure the special_handler() is used.
-      return 0;
-    }
-
-    reactor()->end_reactor_event_loop();
-
-    return 0;
-}
-
-void Timer::send_data_through_handlers()
-{
-    for(int i = 0; i != nhandlers; ++i)
-    {
-      handler_[i].send_dummy_data();
-    }
-}
-
-void Timer::remove_some_handlers()
-{
-    for(int i = 0; i != nhandlers - 1; ++i)
-    {
-      handler_[i].simulate_socket_closure();
-    }
-}
-
-Handler & Timer::special_handler()
-{
-    return handler_[special_handler_index];
-}
-
-Handler const & Timer::special_handler() const
-{
-    return handler_[special_handler_index];
-}