diff options
author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1997-11-19 10:03:58 +0000 |
---|---|---|
committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1997-11-19 10:03:58 +0000 |
commit | 6738258e75bd0632915538ffb51aa57d4103f89f (patch) | |
tree | 14d7becdb242a11e55a2d87bdda8eff4eb226b1f /tests | |
parent | 8dc8d85108388646a6edecc26887c0edc114f83c (diff) | |
download | ATCD-6738258e75bd0632915538ffb51aa57d4103f89f.tar.gz |
*** empty log message ***
Diffstat (limited to 'tests')
-rw-r--r-- | tests/Process_Strategy_Test.cpp | 8 | ||||
-rw-r--r-- | tests/Reactor_Exceptions_Test.cpp | 3 |
2 files changed, 5 insertions, 6 deletions
diff --git a/tests/Process_Strategy_Test.cpp b/tests/Process_Strategy_Test.cpp index b30b792a658..8e18f778932 100644 --- a/tests/Process_Strategy_Test.cpp +++ b/tests/Process_Strategy_Test.cpp @@ -316,7 +316,7 @@ Counting_Service::handle_input (ACE_HANDLE) { ACE_DEBUG ((LM_DEBUG, "(%P|%t) %d bytes of input on %d is %*s\n", - bytes, this->peer ().get_handle (), buf)); + bytes, this->peer ().get_handle (), bytes, buf)); // Read and return the current value in the file. if (ACE_OS::strncmp (buf, "read", 4) == 0) @@ -353,9 +353,9 @@ Counting_Service::open (void *) if (OPTIONS::instance ()->concurrency_type () == Options::PROCESS) { - // We need to rerun the event loop here since we ended up here due - // to being fork'd and we can't just return to our context since - // it's in the wrong location in the process. + // We need to rerun the event loop here since we ended up here + // due to being fork'd and we can't just return to our context + // since it's in the wrong location in the process. while (this->handle_input () >= 0) continue; diff --git a/tests/Reactor_Exceptions_Test.cpp b/tests/Reactor_Exceptions_Test.cpp index 51c8c3afc1f..c6d3405ccb5 100644 --- a/tests/Reactor_Exceptions_Test.cpp +++ b/tests/Reactor_Exceptions_Test.cpp @@ -120,7 +120,6 @@ main (int argc, char *argv[]) u_short port = argc > 1 ? ACE_OS::atoi (argv[1]) : ACE_DEFAULT_SERVER_PORT; ACE_DEBUG ((LM_DEBUG, "Starting tracing\n")); ACE_LOG_MSG->start_tracing (); - // ACE_Reactor::instance(new My_Reactor); ACE_Reactor::instance (&reactor); ACE_Thread_Manager *thr_mgr = ACE_Thread_Manager::instance (); @@ -129,7 +128,7 @@ main (int argc, char *argv[]) ACE_DEFAULT_SERVER_HOST); MemoryEx ex (local_addr); - if (ACE_Reactor::instance()->register_handler + if (ACE_Reactor::instance ()->register_handler (&ex, ACE_Event_Handler::READ_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n%a", "register_handler", 1), -1); |