diff options
Diffstat (limited to 'examples/Connection/non_blocking/CPP-acceptor.cpp')
| -rw-r--r-- | examples/Connection/non_blocking/CPP-acceptor.cpp | 66 |
1 files changed, 31 insertions, 35 deletions
diff --git a/examples/Connection/non_blocking/CPP-acceptor.cpp b/examples/Connection/non_blocking/CPP-acceptor.cpp index 8dce9c948be..12c80c1d939 100644 --- a/examples/Connection/non_blocking/CPP-acceptor.cpp +++ b/examples/Connection/non_blocking/CPP-acceptor.cpp @@ -27,8 +27,7 @@ Svc_Handler<PR_ST_2>::Svc_Handler (ACE_Reactor *r) template <PR_ST_1> int Svc_Handler<PR_ST_2>::close (u_long) { - ACE_DEBUG ((LM_DEBUG, - "calling Svc_Handler close\n")); + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("calling Svc_Handler close\n"))); // Free up the handle. this->peer ().close (); @@ -39,22 +38,22 @@ template <PR_ST_1> int Svc_Handler<PR_ST_2>::open (void *) { PR_AD client_addr; - char buf[BUFSIZ]; + ACE_TCHAR buf[BUFSIZ]; if (this->peer ().get_remote_addr (client_addr) == -1) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "get_remote_addr"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("get_remote_addr")), -1); else if (client_addr.addr_to_string (buf, sizeof buf) == -1) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "addr_to_string"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("addr_to_string")), -1); else ACE_DEBUG ((LM_DEBUG, - "client addr %s on handle %d\n", + ACE_TEXT ("client addr %s on handle %d\n"), buf, this->peer ().get_handle ())); @@ -72,8 +71,7 @@ Svc_Handler<PR_ST_2>::handle_input (ACE_HANDLE) // Read data from client (terminate on error). - ACE_DEBUG ((LM_DEBUG, - "(%t) in handle_input\n")); + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) in handle_input\n"))); for (ssize_t r_bytes; (r_bytes = this->peer ().recv (buf, @@ -83,33 +81,31 @@ Svc_Handler<PR_ST_2>::handle_input (ACE_HANDLE) buf, r_bytes) != r_bytes) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "ACE::send_n"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("ACE::send_n")), -1); // Send back ack. if (this->peer ().send_n ("", 1) != 1) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "send_n"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("send_n")), -1); return 0; } template <PR_ST_1> int Svc_Handler<PR_ST_2>::handle_timeout (const ACE_Time_Value &, - const void *) + const void *) { - ACE_DEBUG ((LM_DEBUG, - "%p\n", - "handle_timeout")); + ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("%p\n"), ACE_TEXT ("handle_timeout"))); return 0; } template <class SVH, PR_AC_1> int -IPC_Server<SVH, PR_AC_2>::init (int argc, char *argv[]) +IPC_Server<SVH, PR_AC_2>::init (int argc, ACE_TCHAR *argv[]) { - const char *local_addr = argc > 1 + const ACE_TCHAR *local_addr = argc > 1 ? argv[1] : ACE_DEFAULT_SERVER_PORT_STR; ACE_Time_Value timeout (argc > 2 @@ -124,8 +120,8 @@ IPC_Server<SVH, PR_AC_2>::init (int argc, char *argv[]) if (this->server_addr_.set (local_addr) == -1) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "set"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("set")), -1); // Call down to the ACCEPTOR's <open> method to do the // initialization. @@ -134,16 +130,16 @@ IPC_Server<SVH, PR_AC_2>::init (int argc, char *argv[]) ? ACE_Reactor::instance () : 0) == -1) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "open"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("open")), -1); // Handle the SIGINT signal through the <ACE_Reactor>. else if (ACE_Reactor::instance ()->register_handler (SIGINT, &this->done_handler_) == -1) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "register_handler"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("register_handler")), -1); #if !defined (ACE_WIN32) // Handle the SIGPIPE signal through the <ACE_Reactor>. @@ -151,8 +147,8 @@ IPC_Server<SVH, PR_AC_2>::init (int argc, char *argv[]) (SIGPIPE, &this->done_handler_) == -1) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "register_handler"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("register_handler")), -1); #endif /* ACE_WIN32 */ else @@ -184,7 +180,7 @@ IPC_Server<SVH, PR_AC_2>::handle_close (ACE_HANDLE handle, ACE_UNUSED_ARG (mask); ACE_DEBUG ((LM_DEBUG, - "calling IPC_Server handle_close, but accept handle stays open!\n")); + ACE_TEXT ("calling IPC_Server handle_close, but accept handle stays open!\n"))); return 0; } @@ -193,17 +189,17 @@ IPC_Server<SVH, PR_AC_2>::handle_close (ACE_HANDLE handle, template <class SVH, PR_AC_1> int IPC_Server<SVH, PR_AC_2>::svc (void) { - char buf[BUFSIZ]; + ACE_TCHAR buf[BUFSIZ]; if (this->server_addr_.addr_to_string (buf, sizeof buf) == -1) ACE_ERROR_RETURN ((LM_ERROR, - "%p\n", - "addr_to_string"), + ACE_TEXT ("%p\n"), + ACE_TEXT ("addr_to_string")), -1); else ACE_DEBUG ((LM_DEBUG, - "starting server addr %s on handle %d\n", + ACE_TEXT ("starting server addr %s on handle %d\n"), buf, this->get_handle ())); @@ -229,8 +225,8 @@ IPC_Server<SVH, PR_AC_2>::svc (void) else // We've probably timed out... ACE_ERROR ((LM_ERROR, - "%p on handle %d\n", - "accept", + ACE_TEXT ("%p on handle %d\n"), + ACE_TEXT ("accept"), this->acceptor ().get_handle ())); } |