summaryrefslogtreecommitdiff
path: root/examples/Reactor/ReactorEx/test_removals.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/Reactor/ReactorEx/test_removals.cpp')
-rw-r--r--examples/Reactor/ReactorEx/test_removals.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/examples/Reactor/ReactorEx/test_removals.cpp b/examples/Reactor/ReactorEx/test_removals.cpp
index fda33df704a..3f24213e561 100644
--- a/examples/Reactor/ReactorEx/test_removals.cpp
+++ b/examples/Reactor/ReactorEx/test_removals.cpp
@@ -10,9 +10,9 @@
//
// = DESCRIPTION
//
-// Tests the ReactorEx's ability to handle simultaneous events. If
+// Tests the Reactor's ability to handle simultaneous events. If
// you pass anything on the command-line, then each handler
-// requests to be removed from the ReactorEx after each event.
+// requests to be removed from the Reactor after each event.
//
// = AUTHOR
// Tim Harrison
@@ -20,7 +20,7 @@
//
// ============================================================================
-#include "ace/ReactorEx.h"
+#include "ace/Reactor.h"
#include "ace/Service_Config.h"
#include "ace/Synch.h"
@@ -30,7 +30,7 @@ class Event_Handler : public ACE_Event_Handler
//
// = DESCRIPTION
//
-// Creates event. Registers with ReactorEx. Signals event. If
+// Creates event. Registers with Reactor. Signals event. If
// created with -close_down- it returns -1 from handle signal.
{
public:
@@ -39,9 +39,9 @@ public:
: event_number_ (event_number),
close_down_ (close_down)
{
- if (ACE_ReactorEx::instance ()->register_handler (this,
- this->event_.handle ()) == -1)
- ACE_ERROR ((LM_ERROR, "%p\tevent handler %d cannot be added to ReactorEx\n", "", event_number_));
+ if (ACE_Reactor::instance ()->register_handler (this,
+ this->event_.handle ()) == -1)
+ ACE_ERROR ((LM_ERROR, "%p\tevent handler %d cannot be added to Reactor\n", "", event_number_));
this->event_.signal ();
}
@@ -83,14 +83,14 @@ main (int argc, char *argv[])
{
int close_down = argc > 1 ? 1 : 0;
- for (int i = 1; i <= ACE_ReactorEx::DEFAULT_SIZE; i++)
+ for (int i = 1; i <= ACE_Reactor::instance ()->size (); i++)
new Event_Handler (i, close_down);
int result = 0;
ACE_Time_Value time (1);
while (1)
{
- result = ACE_ReactorEx::instance ()->handle_events (time);
+ result = ACE_Reactor::instance ()->handle_events (time);
if (result == 0 && errno == ETIME)
{
ACE_DEBUG ((LM_DEBUG, "No more work left: timing out\n"));