summaryrefslogtreecommitdiff
path: root/tests/Reactor_Timer_Test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'tests/Reactor_Timer_Test.cpp')
-rw-r--r--tests/Reactor_Timer_Test.cpp271
1 files changed, 0 insertions, 271 deletions
diff --git a/tests/Reactor_Timer_Test.cpp b/tests/Reactor_Timer_Test.cpp
deleted file mode 100644
index 2225fd2fd31..00000000000
--- a/tests/Reactor_Timer_Test.cpp
+++ /dev/null
@@ -1,271 +0,0 @@
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// tests
-//
-// = FILENAME
-// Reactor_Timer_Test.cpp
-//
-// = DESCRIPTION
-// This is a simple test that illustrates the timer mechanism of
-// the reactor. Scheduling timers, resetting timer intervals,
-// handling expired timers and cancelling scheduled timers are
-// all exercised in this test.
-//
-// = AUTHOR
-// Prashant Jain <pjain@cs.wustl.edu> and Douglas C. Schmidt
-// <schmidt@cs.wustl.edu>
-//
-// ============================================================================
-
-#include "test_config.h"
-#include "ace/Timer_Queue.h"
-#include "ace/Reactor.h"
-#include "ace/High_Res_Timer.h"
-#include "ace/Trace.h"
-#include "ace/Recursive_Thread_Mutex.h"
-
-ACE_RCSID(tests, Reactor_Timer_Test, "$Id$")
-
-static int done = 0;
-static int count = 0;
-static int odd = 0;
-
-class Time_Handler : public ACE_Event_Handler
-{
-public:
- Time_Handler ();
- // Default constructor
-
- virtual int handle_timeout (const ACE_Time_Value &tv,
- const void *arg);
- // Handle the timeout.
-
- virtual int handle_close (ACE_HANDLE handle,
- ACE_Reactor_Mask close_mask);
- // Called when <Time_Handler> is removed.
-
- long timer_id (void) const;
- // Return our timer id.
-
- void timer_id (long);
- // Set our timer id;
-
-private:
- long timer_id_;
- // Stores the id of this timer.
-};
-
-Time_Handler::Time_Handler ()
-: timer_id_ (-1)
-{
- // Nothing
-}
-
-int
-Time_Handler::handle_close (ACE_HANDLE handle,
- ACE_Reactor_Mask close_mask)
-{
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("[%x] handle = %d, close_mask = %d, timer id = %d\n"),
- this,
- handle,
- close_mask,
- this->timer_id ()));
- return 0;
-}
-
-int
-Time_Handler::handle_timeout (const ACE_Time_Value &tv,
- const void *arg)
-{
- long current_count = static_cast<long> (reinterpret_cast<size_t> (arg));
- if (current_count >= 0)
- ACE_ASSERT (current_count == count);
-
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("[%x] Timer id %d with count #%d|%d timed out at %d!\n"),
- this,
- this->timer_id (),
- count,
- current_count,
- tv.sec ()));
-
- if (current_count == long (ACE_MAX_TIMERS - 1))
- done = 1;
- else if (count == ACE_MAX_TIMERS - 1)
- {
- done = 1;
- return -1;
- }
- else if (current_count == -1)
- {
- int result = ACE_Reactor::instance ()->reset_timer_interval (this->timer_id (),
- ACE_Time_Value (count + 1));
- if (result == -1)
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("Error resetting timer interval\n")));
- }
- count += (1 + odd);
- return 0;
-}
-
-long
-Time_Handler::timer_id (void) const
-{
- return this->timer_id_;
-}
-
-void
-Time_Handler::timer_id (long t)
-{
- this->timer_id_ = t;
-}
-
-static void
-test_registering_all_handlers (void)
-{
- ACE_Trace t (ACE_TEXT ("test_registering_all_handler"),
- __LINE__,
- ACE_TEXT_CHAR_TO_TCHAR (__FILE__));
- Time_Handler rt[ACE_MAX_TIMERS];
- long t_id[ACE_MAX_TIMERS];
-
- for (size_t i = 0; i < ACE_MAX_TIMERS; i++)
- {
- t_id[i] =
- ACE_Reactor::instance ()->schedule_timer (&rt[i],
- (const void *) i,
- ACE_Time_Value (2 * i + 1));
- ACE_ASSERT (t_id[i] != -1);
- rt[i].timer_id (t_id[i]);
- }
-
- while (!done)
- ACE_Reactor::instance ()->handle_events ();
-}
-
-static void
-test_registering_one_handler (void)
-{
- ACE_Trace t (ACE_TEXT ("test_registering_one_handler"),
- __LINE__,
- ACE_TEXT_CHAR_TO_TCHAR (__FILE__));
- Time_Handler rt[ACE_MAX_TIMERS];
- long t_id[ACE_MAX_TIMERS];
-
- done = 0;
- count = 0;
-
- for (size_t i = 0; i < ACE_MAX_TIMERS; i++)
- {
- t_id[i] =
- ACE_Reactor::instance ()->schedule_timer (&rt[0],
- (const void *) i,
- ACE_Time_Value (2 * i + 1));
- ACE_ASSERT (t_id[i] != -1);
- }
-
- while (!done)
- ACE_Reactor::instance ()->handle_events ();
-}
-
-static void
-test_canceling_odd_timers (void)
-{
- ACE_Trace t (ACE_TEXT ("test_canceling_odd_timers"),
- __LINE__,
- ACE_TEXT_CHAR_TO_TCHAR (__FILE__));
- Time_Handler rt[ACE_MAX_TIMERS];
- long t_id[ACE_MAX_TIMERS];
-
- done = 0;
- count = 1;
- odd = 1;
-
- for (size_t i = 0; i < ACE_MAX_TIMERS; i++)
- {
- t_id[i] = ACE_Reactor::instance ()->schedule_timer (&rt[i],
- (const void *) i,
- ACE_Time_Value (2 * i + 1));
- ACE_ASSERT (t_id[i] != -1);
- rt[i].timer_id (t_id[i]);
- }
-
- for (size_t j = 0; (u_long) j < ACE_MAX_TIMERS; j++)
- // Cancel handlers with odd numbered timer ids.
- if (ACE_ODD (rt[j].timer_id ()))
- {
- int result =
- ACE_Reactor::instance ()->cancel_timer (rt[j].timer_id ());
- if (result == -1)
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("Error cancelling timer\n")));
- }
-
- while (!done)
- ACE_Reactor::instance ()->handle_events ();
-}
-
-static void
-test_resetting_timer_intervals (void)
-{
- ACE_Trace t (ACE_TEXT ("test_resetting_timer_intervals"),
- __LINE__,
- ACE_TEXT_CHAR_TO_TCHAR (__FILE__));
- Time_Handler rt;
- long t_id;
-
- done = 0;
- count = 0;
- odd = 0;
-
- t_id =
- ACE_Reactor::instance ()->schedule_timer
- (&rt,
- (const void *) -1,
- ACE_Time_Value (1),
- // Start off by making this an interval timer.
- ACE_Time_Value (1));
-
- ACE_ASSERT (t_id != -1);
- rt.timer_id (t_id);
-
- while (!done)
- ACE_Reactor::instance ()->handle_events ();
-}
-
-// If any command line arg is given, run the test with high res timer
-// queue. Else run it normally.
-int
-run_main (int argc, ACE_TCHAR *[])
-{
- ACE_START_TEST (ACE_TEXT ("Reactor_Timer_Test"));
-
- if (argc > 1)
- {
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("Running with high-res timer queue\n")));
- ACE_Reactor *r = ACE_Reactor::instance ();
- (void) ACE_High_Res_Timer::global_scale_factor ();
- r->timer_queue ()->gettimeofday (&ACE_High_Res_Timer::gettimeofday_hr);
- }
-
- // Register all different handlers, i.e., one per timer.
- test_registering_all_handlers ();
-
- // Now try multiple timers for ONE event handler (should produce the
- // same result).
- test_registering_one_handler ();
-
- // Try canceling handlers with odd numbered timer ids.
- test_canceling_odd_timers ();
-
- // Make sure <reset_timer_inverval> works.
- test_resetting_timer_intervals ();
-
- ACE_END_TEST;
- return 0;
-}
View Lorry Controller Status