diff options
Diffstat (limited to 'tests/Reactor_Performance_Test.cpp')
| -rw-r--r-- | tests/Reactor_Performance_Test.cpp | 78 |
1 files changed, 39 insertions, 39 deletions
diff --git a/tests/Reactor_Performance_Test.cpp b/tests/Reactor_Performance_Test.cpp index 54d8b68da78..b655fd1385b 100644 --- a/tests/Reactor_Performance_Test.cpp +++ b/tests/Reactor_Performance_Test.cpp @@ -64,16 +64,16 @@ Read_Handler::open (void *) { if (this->peer ().enable (ACE_NONBLOCK) == -1) ACE_ERROR_RETURN ((LM_ERROR, - ASYS_TEXT ("(%t) Read_Handler::open, cannot set non blocking mode\n")), + ACE_TEXT ("(%t) Read_Handler::open, cannot set non blocking mode\n")), -1); if (reactor ()->register_handler (this, READ_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, - ASYS_TEXT ("(%t) Read_Handler::open, cannot register handler\n")), + ACE_TEXT ("(%t) Read_Handler::open, cannot register handler\n")), -1); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) created svc_handler for handle %d\n"), + ACE_TEXT ("(%t) created svc_handler for handle %d\n"), get_handle ())); return 0; } @@ -95,7 +95,7 @@ Read_Handler::handle_input (ACE_HANDLE handle) { buf[result] = 0; ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) Read_Handler::handle_input: %s\n"), + ACE_TEXT ("(%t) Read_Handler::handle_input: %s\n"), buf)); } } @@ -105,8 +105,8 @@ Read_Handler::handle_input (ACE_HANDLE handle) return 0; else { - ACE_ERROR ((LM_ERROR, ASYS_TEXT ("handle_input: %p (errno: %d)\n"), - ASYS_TEXT ("recv"), errno)); + ACE_ERROR ((LM_ERROR, ACE_TEXT ("handle_input: %p (errno: %d)\n"), + ACE_TEXT ("recv"), errno)); // This will cause handle_close to get called. return -1; @@ -139,7 +139,7 @@ Read_Handler::handle_close (ACE_HANDLE handle, ACE_Reactor::instance ()->end_event_loop (); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) Read_Handler::handle_close closing down\n"))); + ACE_TEXT ("(%t) Read_Handler::handle_close closing down\n"))); // Shutdown this->destroy (); @@ -160,8 +160,8 @@ Write_Handler::send_data (void) if (this->peer ().send_n (ACE_ALPHABET, send_size) != send_size) ACE_ERROR_RETURN ((LM_ERROR, - ASYS_TEXT ("(%t) %p\n"), - ASYS_TEXT ("send_n")), + ACE_TEXT ("(%t) %p\n"), + ACE_TEXT ("send_n")), -1); return 0; } @@ -175,7 +175,7 @@ void * client (void *arg) { ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) running client\n"))); + ACE_TEXT ("(%t) running client\n"))); ACE_INET_Addr *connection_addr = ACE_reinterpret_cast (ACE_INET_Addr *, arg); @@ -190,11 +190,11 @@ client (void *arg) 0); ACE_Auto_Basic_Array_Ptr <Write_Handler *> writers (temp_writers); - ASYS_TCHAR *temp_failed; + ACE_TCHAR *temp_failed; ACE_NEW_RETURN (temp_failed, - ASYS_TCHAR[opt_nconnections], + ACE_TCHAR[opt_nconnections], 0); - ACE_Auto_Basic_Array_Ptr <ASYS_TCHAR> failed_svc_handlers (temp_failed); + ACE_Auto_Basic_Array_Ptr <ACE_TCHAR> failed_svc_handlers (temp_failed); // Automagic memory cleanup. ACE_INET_Addr *temp_addresses; @@ -223,7 +223,7 @@ client (void *arg) { ACE_INET_Addr failed_addr = addresses.get()[i]; ACE_ERROR ((LM_ERROR, - ASYS_TEXT ("(%t) connection failed to %s, %d\n"), + ACE_TEXT ("(%t) connection failed to %s, %d\n"), failed_addr.get_host_name (), failed_addr.get_port_number ())); } @@ -237,15 +237,15 @@ client (void *arg) for (i = 0; i < opt_nconnections; i++) if (writers[i]->send_data () == -1) ACE_ERROR_RETURN ((LM_ERROR, - ASYS_TEXT ("(%t) %p\n"), - ASYS_TEXT ("writer::send_data")), + ACE_TEXT ("(%t) %p\n"), + ACE_TEXT ("writer::send_data")), 0); // Cleanup for (i = 0; i < opt_nconnections; i++) writers[i]->destroy (); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) finishing client\n"))); + ACE_TEXT ("(%t) finishing client\n"))); return 0; } @@ -278,42 +278,42 @@ create_reactor (void) void print_results (ACE_Profile_Timer::ACE_Elapsed_Time &et) { - const ASYS_TCHAR *reactor_type = 0; + const ACE_TCHAR *reactor_type = 0; if (opt_wfmo_reactor) - reactor_type = ASYS_TEXT ("WFMO_Reactor"); + reactor_type = ACE_TEXT ("WFMO_Reactor"); else if (opt_select_reactor) - reactor_type = ASYS_TEXT ("Select_Reactor"); + reactor_type = ACE_TEXT ("Select_Reactor"); else - reactor_type = ASYS_TEXT ("Platform's default Reactor"); + reactor_type = ACE_TEXT ("Platform's default Reactor"); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("\n\tReactor_Performance Test statistics:\n\n"))); + ACE_TEXT ("\n\tReactor_Performance Test statistics:\n\n"))); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("\tReactor Type: %s\n"), + ACE_TEXT ("\tReactor Type: %s\n"), reactor_type)); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("\tConnections: %d\n"), + ACE_TEXT ("\tConnections: %d\n"), opt_nconnections)); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("\tIteration per connection: %d\n"), + ACE_TEXT ("\tIteration per connection: %d\n"), opt_nloops)); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("\n\tTiming results:\n"))); + ACE_TEXT ("\n\tTiming results:\n"))); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("\t\treal time = %f secs \n\t\tuser time = %f secs \n\t\tsystem time = %f secs\n\n"), + ACE_TEXT ("\t\treal time = %f secs \n\t\tuser time = %f secs \n\t\tsystem time = %f secs\n\n"), et.real_time, et.user_time, et.system_time)); } int -main (int argc, ASYS_TCHAR *argv[]) +main (int argc, ACE_TCHAR *argv[]) { - ACE_START_TEST (ASYS_TEXT ("Reactor_Performance_Test")); + ACE_START_TEST (ACE_TEXT ("Reactor_Performance_Test")); - ACE_Get_Opt getopt (argc, argv, ASYS_TEXT ("dswc:l:"), 1); + ACE_Get_Opt getopt (argc, argv, ACE_TEXT ("dswc:l:"), 1); for (int c; (c = getopt ()) != -1; ) switch (c) { @@ -359,12 +359,12 @@ main (int argc, ASYS_TCHAR *argv[]) if (acceptor.open (ACE_sap_any_cast (const ACE_INET_Addr &)) == -1 || acceptor.acceptor ().get_local_addr (server_addr) == -1) ACE_ERROR_RETURN ((LM_ERROR, - ASYS_TEXT ("(%t) %p\n"), - ASYS_TEXT ("open")), + ACE_TEXT ("(%t) %p\n"), + ACE_TEXT ("open")), -1); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) starting server at port %d\n"), + ACE_TEXT ("(%t) starting server at port %d\n"), server_addr.get_port_number ())); ACE_INET_Addr connection_addr (server_addr.get_port_number (), @@ -375,8 +375,8 @@ main (int argc, ASYS_TCHAR *argv[]) (void *) &connection_addr, THR_NEW_LWP | THR_DETACHED) == -1) ACE_ERROR ((LM_ERROR, - ASYS_TEXT ("(%t) %p\n"), - ASYS_TEXT ("thread create failed"))); + ACE_TEXT ("(%t) %p\n"), + ACE_TEXT ("thread create failed"))); ACE_Time_Value run_limit (opt_nloops / 10); @@ -392,7 +392,7 @@ main (int argc, ASYS_TCHAR *argv[]) print_results (et); ACE_DEBUG ((LM_DEBUG, - ASYS_TEXT ("(%t) waiting for the client thread...\n"))); + ACE_TEXT ("(%t) waiting for the client thread...\n"))); ACE_Thread_Manager::instance ()->wait (); @@ -438,12 +438,12 @@ template class ACE_Auto_Array_Ptr <ACE_INET_Addr>; #else int -main (int, ASYS_TCHAR *[]) +main (int, ACE_TCHAR *[]) { - ACE_START_TEST (ASYS_TEXT ("Reactor_Performance_Test")); + ACE_START_TEST (ACE_TEXT ("Reactor_Performance_Test")); ACE_ERROR ((LM_INFO, - ASYS_TEXT ("threads not supported on this platform\n"))); + ACE_TEXT ("threads not supported on this platform\n"))); ACE_END_TEST; return 0; |