From 7ea3ed1ac16c01d9c52ed005113d059dc24d07af Mon Sep 17 00:00:00 2001 From: Abdullah Sowayan Date: Mon, 16 Jun 2008 16:57:12 +0000 Subject: Mon Jun 16 16:54:25 UTC 2008 Abdullah Sowayan --- .../IPC-tests/client/broadcast_client_test.cpp | 8 ++-- .../IPC-tests/client/local_dgram_client_test.cpp | 2 +- .../IPC-tests/client/local_pipe_client_test.cpp | 8 ++-- .../IPC-tests/client/local_stream_client_test.cpp | 12 ++--- .../IPC-tests/server/Handle_L_CODgram.inl | 37 +++++++-------- .../IPC-tests/server/Handle_L_Dgram.inl | 34 ++++++------- .../IPC-tests/server/Handle_L_FIFO.inl | 19 ++++---- .../IPC-tests/server/Handle_L_Pipe.inl | 21 ++++----- .../IPC-tests/server/Handle_L_SPIPE.inl | 10 ++-- .../IPC-tests/server/Handle_L_Stream.inl | 55 +++++++++++----------- .../IPC-tests/server/Handle_R_Dgram.inl | 35 +++++++------- .../IPC-tests/server/Handle_Thr_Stream.cpp | 39 ++++++++------- 12 files changed, 139 insertions(+), 141 deletions(-) (limited to 'ACE/examples/Service_Configurator/IPC-tests') diff --git a/ACE/examples/Service_Configurator/IPC-tests/client/broadcast_client_test.cpp b/ACE/examples/Service_Configurator/IPC-tests/client/broadcast_client_test.cpp index 4cbb964cd74..4895d326b8d 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/client/broadcast_client_test.cpp +++ b/ACE/examples/Service_Configurator/IPC-tests/client/broadcast_client_test.cpp @@ -37,11 +37,11 @@ parse_args (int argc, ACE_TCHAR *argv[]) switch (c) { case 'p': - broadcast_port_number = ACE_OS::atoi (get_opt.opt_arg ()); - break; + broadcast_port_number = ACE_OS::atoi (get_opt.opt_arg ()); + break; default: - print_usage_and_die (); - break; + print_usage_and_die (); + break; } } diff --git a/ACE/examples/Service_Configurator/IPC-tests/client/local_dgram_client_test.cpp b/ACE/examples/Service_Configurator/IPC-tests/client/local_dgram_client_test.cpp index 3f8ed3db866..2a125a4a5f4 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/client/local_dgram_client_test.cpp +++ b/ACE/examples/Service_Configurator/IPC-tests/client/local_dgram_client_test.cpp @@ -32,7 +32,7 @@ print_usage_and_die (void) ACE_ERROR ((LM_ERROR, ACE_TEXT ("usage: %s [-r rendezvous_dgram] ") ACE_TEXT ("[-c rendezvous_codgram] [-f file]\n"), - program_name)); + program_name)); ACE_OS::exit (1); } diff --git a/ACE/examples/Service_Configurator/IPC-tests/client/local_pipe_client_test.cpp b/ACE/examples/Service_Configurator/IPC-tests/client/local_pipe_client_test.cpp index 7193440b440..694406647fd 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/client/local_pipe_client_test.cpp +++ b/ACE/examples/Service_Configurator/IPC-tests/client/local_pipe_client_test.cpp @@ -29,7 +29,7 @@ print_usage_and_die (void) { ACE_ERROR ((LM_ERROR, ACE_TEXT ("usage: %s [-r rendezvous] [-f file]\n"), - program_name)); + program_name)); ACE_OS::exit (1); } @@ -86,21 +86,21 @@ do_client_processing (ACE_LSOCK_Stream &sc) if (ACE_OS::write (fd_write[1], buf, n) == -1) - ACE_ERROR_RETURN ((LM_ERROR, + ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("write")), -1); if ((n = ACE_OS::read (fd_read[0], buf, sizeof buf)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, + ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("read")), -1); if (ACE_OS::write (ACE_STDOUT, buf, n) == -1) - return -1; + return -1; } if (ACE_OS::close (fd_read[0]) == -1 diff --git a/ACE/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp b/ACE/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp index 390b14e19b8..3b27f3db67a 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp +++ b/ACE/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp @@ -41,14 +41,14 @@ parse_args (int argc, ACE_TCHAR *argv[]) switch (c) { case 'f': - file_name = get_opt.opt_arg (); - break; + file_name = get_opt.opt_arg (); + break; case 'r': - rendezvous = get_opt.opt_arg (); - break; + rendezvous = get_opt.opt_arg (); + break; default: - print_usage_and_die (); - break; + print_usage_and_die (); + break; } } diff --git a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.inl b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.inl index a77d75e1fa8..5eff78a4bea 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.inl +++ b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.inl @@ -22,7 +22,7 @@ Handle_L_CODgram::open (const ACE_UNIX_Addr &suad, int async) return 0; } -ACE_INLINE int +ACE_INLINE int Handle_L_CODgram::info (ACE_TCHAR **strp, size_t length) const { ACE_TCHAR buf[BUFSIZ]; @@ -30,7 +30,7 @@ Handle_L_CODgram::info (ACE_TCHAR **strp, size_t length) const if (ACE_LSOCK_CODgram::get_local_addr (sa) == -1) return -1; - + ACE_OS::strcpy (buf, ACE_TEXT_CHAR_TO_TCHAR (sa.get_path_name ())); ACE_OS::strcat (buf, ACE_TEXT (" # tests local connected datagram\n")); @@ -49,42 +49,41 @@ Handle_L_CODgram::init (int argc, ACE_TCHAR *argv[]) const ACE_TCHAR *r = Handle_L_CODgram::DEFAULT_RENDEZVOUS; for (int c; (c = get_opt ()) != -1; ) - switch (c) - { - case 'r': - r = get_opt.opt_arg (); - break; - default: - break; - } + switch (c) + { + case 'r': + r = get_opt.opt_arg (); + break; + default: + break; + } ACE_OS::strncpy (this->rendezvous, r, MAXPATHLEN); ACE_OS::unlink (this->rendezvous); sucd.set (this->rendezvous); if (this->open (sucd) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1); - else if (ACE_Reactor::instance ()->register_handler - (this, ACE_Event_Handler::ACCEPT_MASK) == -1) + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), - ACE_TEXT ("registering service with ACE_Reactor")), + ACE_TEXT ("registering service with ACE_Reactor")), -1); return 0; } -ACE_INLINE int -Handle_L_CODgram::fini(void) +ACE_INLINE int +Handle_L_CODgram::fini(void) { - return ACE_Reactor::instance ()->remove_handler + return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } ACE_INLINE ACE_HANDLE Handle_L_CODgram::get_handle (void) const -{ +{ return ACE_LSOCK_CODgram::get_handle (); } -ACE_INLINE int +ACE_INLINE int Handle_L_CODgram::handle_input (ACE_HANDLE) { ACE_HANDLE handle = ACE_INVALID_HANDLE; @@ -102,7 +101,7 @@ Handle_L_CODgram::handle_input (ACE_HANDLE) ssize_t n = ACE_OS::read (handle, buf, sizeof buf); if (n <= 0) - break; + break; ACE_OS::write (ACE_STDOUT, buf, n); } diff --git a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.inl b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.inl index 3b2ab29331f..110a6e1cb3b 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.inl +++ b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.inl @@ -18,11 +18,11 @@ Handle_L_Dgram::open (const ACE_UNIX_Addr &suad, int async) return -1; else if (async && this->ACE_LSOCK_Dgram::enable (ACE_SIGIO) == -1) return -1; - else + else return 0; } -ACE_INLINE int +ACE_INLINE int Handle_L_Dgram::info (ACE_TCHAR **strp, size_t length) const { ACE_TCHAR buf[BUFSIZ]; @@ -49,22 +49,22 @@ Handle_L_Dgram::init (int argc, ACE_TCHAR *argv[]) const ACE_TCHAR *r = Handle_L_Dgram::DEFAULT_RENDEZVOUS; for (int c; (c = get_opt ()) != -1; ) - switch (c) - { - case 'r': - r = get_opt.opt_arg (); - break; - default: - break; - } - + switch (c) + { + case 'r': + r = get_opt.opt_arg (); + break; + default: + break; + } + ACE_OS::strncpy (this->rendezvous, r, MAXPATHLEN); ACE_OS::unlink (this->rendezvous); sudg.set (this->rendezvous); if (this->open (sudg) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1); else if (ACE_Reactor::instance ()->register_handler (this, - ACE_Event_Handler::ACCEPT_MASK) == -1) + ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("registering service with ACE_Reactor")), @@ -72,19 +72,19 @@ Handle_L_Dgram::init (int argc, ACE_TCHAR *argv[]) return 0; } -ACE_INLINE int -Handle_L_Dgram::fini (void) +ACE_INLINE int +Handle_L_Dgram::fini (void) { return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); } -ACE_INLINE int +ACE_INLINE int Handle_L_Dgram::get_handle (void) const -{ +{ return this->ACE_LSOCK_Dgram::get_handle (); } -ACE_INLINE int +ACE_INLINE int Handle_L_Dgram::handle_input (int) { ACE_UNIX_Addr sa; diff --git a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.inl b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.inl index f6cd0cda734..d1559ad0359 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.inl +++ b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.inl @@ -46,20 +46,19 @@ Handle_L_FIFO::init (int argc, ACE_TCHAR *argv[]) ACE_Get_Opt get_opt (argc, argv, ACE_TEXT("r:"), 0); for (int c; (c = get_opt ()) != -1; ) - switch (c) - { - case 'r': - rendezvous_fifo = get_opt.opt_arg (); - break; - default: - break; - } + switch (c) + { + case 'r': + rendezvous_fifo = get_opt.opt_arg (); + break; + default: + break; + } ACE_OS::unlink (rendezvous_fifo); if (this->open (rendezvous_fifo) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1); - else if (ACE_Reactor::instance ()->register_handler - (this, ACE_Event_Handler::READ_MASK) == -1) + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::READ_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("registering service with ACE_Reactor")), -1); diff --git a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.inl b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.inl index ce978aa85ea..6ab9f96128d 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.inl +++ b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.inl @@ -54,24 +54,23 @@ Handle_L_Pipe::init (int argc, ACE_TCHAR *argv[]) ACE_Get_Opt get_opt (argc, argv, ACE_TEXT ("r:"), 0); for (int c; (c = get_opt ()) != -1; ) - switch (c) - { - case 'r': - r = get_opt.opt_arg (); - break; - default: - break; - } + switch (c) + { + case 'r': + r = get_opt.opt_arg (); + break; + default: + break; + } ACE_OS::strncpy (this->rendezvous, r, MAXPATHLEN); ACE_OS::unlink (this->rendezvous); sup.set (this->rendezvous); if (this->open (sup) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1); - else if (ACE_Reactor::instance ()->register_handler - (this, ACE_Event_Handler::ACCEPT_MASK) == -1) + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), - ACE_TEXT ("registering service with ACE_Reactor")), -1); + ACE_TEXT ("registering service with ACE_Reactor")), -1); return 0; } diff --git a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.inl b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.inl index 910938d8648..50c0456893f 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.inl +++ b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.inl @@ -71,9 +71,9 @@ Handle_L_SPIPE::init (int argc, ACE_TCHAR *argv[]) else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, - ACE_TEXT ("%p\n"), - ACE_TEXT ("registering service with ACE_Reactor")), - -1); + ACE_TEXT ("%p\n"), + ACE_TEXT ("registering service with ACE_Reactor")), + -1); return 0; } @@ -108,8 +108,8 @@ Handle_L_SPIPE::handle_input (int) new_spipe.get_remote_addr (sa); ACE_DEBUG ((LM_INFO, - ACE_TEXT ("accepted request from %s (gid = %d, uid = %d)\n"), - sa.get_path_name (), sa.group_id (), sa.user_id ())); + ACE_TEXT ("accepted request from %s (gid = %d, uid = %d)\n"), + sa.get_path_name (), sa.group_id (), sa.user_id ())); } while (new_spipe.recv ((ACE_Str_Buf *) 0, &msg, &flags) >= 0) diff --git a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.inl b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.inl index 80b21852293..03b87ef905c 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.inl +++ b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.inl @@ -20,8 +20,8 @@ Handle_L_Stream::Handle_L_Stream (void) } ACE_INLINE int -Handle_L_Stream::open (const ACE_UNIX_Addr &suas, - int async) +Handle_L_Stream::open (const ACE_UNIX_Addr &suas, + int async) { if (this->ACE_LSOCK_Acceptor::open (suas) == -1) return -1; @@ -31,7 +31,7 @@ Handle_L_Stream::open (const ACE_UNIX_Addr &suas, return 0; } -ACE_INLINE int +ACE_INLINE int Handle_L_Stream::info (ACE_TCHAR **strp, size_t length) const { ACE_TCHAR buf[BUFSIZ]; @@ -39,7 +39,7 @@ Handle_L_Stream::info (ACE_TCHAR **strp, size_t length) const if (this->get_local_addr (sa) == -1) return -1; - + ACE_OS::strcpy (buf, ACE_TEXT_CHAR_TO_TCHAR (sa.get_path_name ())); ACE_OS::strcat (buf, ACE_TEXT (" # tests local ACE_Stream\n")); @@ -58,30 +58,29 @@ Handle_L_Stream::init (int argc, ACE_TCHAR *argv[]) ACE_Get_Opt get_opt (argc, argv, ACE_TEXT ("r:"), 0); for (int c; (c = get_opt ()) != -1; ) - switch (c) - { - case 'r': - r = get_opt.opt_arg (); - break; - default: - break; - } - + switch (c) + { + case 'r': + r = get_opt.opt_arg (); + break; + default: + break; + } + ACE_OS::strncpy (this->rendezvous, r, MAXPATHLEN); ACE_OS::unlink (this->rendezvous); sus.set (this->rendezvous); if (this->open (sus) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1); - else if (ACE_Reactor::instance ()->register_handler - (this, ACE_Event_Handler::ACCEPT_MASK) == -1) + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), - ACE_TEXT ("registering service with ACE_Reactor")), -1); + ACE_TEXT ("registering service with ACE_Reactor")), -1); return 0; } -ACE_INLINE int -Handle_L_Stream::fini (void) +ACE_INLINE int +Handle_L_Stream::fini (void) { return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); @@ -89,11 +88,11 @@ Handle_L_Stream::fini (void) ACE_INLINE ACE_HANDLE Handle_L_Stream::get_handle (void) const -{ +{ return ACE_LSOCK_Acceptor::get_handle (); } -ACE_INLINE int +ACE_INLINE int Handle_L_Stream::handle_input (ACE_HANDLE) { ACE_LSOCK_Stream new_local_stream; @@ -106,9 +105,9 @@ Handle_L_Stream::handle_input (ACE_HANDLE) else if (new_local_stream.recv_handle (handle) == -1) return -1; else - ACE_DEBUG ((LM_INFO, - ACE_TEXT ("received file descriptor %d on ACE_Stream %s\n"), - handle, sa.get_path_name ())); + ACE_DEBUG ((LM_INFO, + ACE_TEXT ("received file descriptor %d on ACE_Stream %s\n"), + handle, sa.get_path_name ())); ACE_OS::puts ("----------------------------------------"); @@ -117,7 +116,7 @@ Handle_L_Stream::handle_input (ACE_HANDLE) ssize_t n = ACE_OS::read (handle, buf, sizeof buf); if (n <= 0) - break; + break; ACE_OS::write (ACE_STDOUT, buf, n); } @@ -128,10 +127,10 @@ Handle_L_Stream::handle_input (ACE_HANDLE) ACE_TCHAR *cs = ACE_OS::ctime (&t); if (new_local_stream.send (4, - Handle_L_Stream::login_name, - ACE_OS::strlen (Handle_L_Stream::login_name), - ACE_TEXT_ALWAYS_CHAR (cs), - ACE_OS::strlen (cs)) == -1) + Handle_L_Stream::login_name, + ACE_OS::strlen (Handle_L_Stream::login_name), + ACE_TEXT_ALWAYS_CHAR (cs), + ACE_OS::strlen (cs)) == -1) return -1; else if (ACE_OS::close (handle) == -1) return -1; diff --git a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.inl b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.inl index 88212a988f0..68a6bb9a967 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.inl +++ b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.inl @@ -22,7 +22,7 @@ Handle_R_Dgram::open (const ACE_INET_Addr &r, int async) return 0; } -ACE_INLINE int +ACE_INLINE int Handle_R_Dgram::info (ACE_TCHAR **strp, size_t length) const { ACE_TCHAR buf[BUFSIZ]; @@ -30,7 +30,7 @@ Handle_R_Dgram::info (ACE_TCHAR **strp, size_t length) const if (this->get_local_addr (sa) == -1) return -1; - + ACE_OS::sprintf (buf, ACE_TEXT ("%d/"), sa.get_port_number ()); ACE_OS::strcat (buf, ACE_TEXT ("udp # tests remote dgram\n")); @@ -48,26 +48,25 @@ Handle_R_Dgram::init (int argc, ACE_TCHAR *argv[]) ACE_Get_Opt get_opt (argc, argv, ACE_TEXT ("p:"), 0); for (int c; (c = get_opt ()) != -1; ) - switch (c) - { - case 'p': - sidg.set (ACE_OS::atoi (get_opt.opt_arg ())); - break; - default: - break; - } - + switch (c) + { + case 'p': + sidg.set (ACE_OS::atoi (get_opt.opt_arg ())); + break; + default: + break; + } + if (this->open (sidg) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1); - else if (ACE_Reactor::instance ()->register_handler - (this, ACE_Event_Handler::ACCEPT_MASK) == -1) + else if (ACE_Reactor::instance ()->register_handler (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("registering service with ACE_Reactor")), -1); return 0; } -ACE_INLINE int -Handle_R_Dgram::fini (void) +ACE_INLINE int +Handle_R_Dgram::fini (void) { return ACE_Reactor::instance ()->remove_handler (this, ACE_Event_Handler::ACCEPT_MASK); @@ -75,11 +74,11 @@ Handle_R_Dgram::fini (void) ACE_INLINE ACE_HANDLE Handle_R_Dgram::get_handle (void) const -{ - return ACE_SOCK_Dgram::get_handle (); +{ + return ACE_SOCK_Dgram::get_handle (); } -ACE_INLINE int +ACE_INLINE int Handle_R_Dgram::handle_input (ACE_HANDLE) { ACE_INET_Addr sa; diff --git a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp index fb53c0f8d70..3598b6f87f6 100644 --- a/ACE/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp +++ b/ACE/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp @@ -67,28 +67,28 @@ Handle_Thr_Acceptor::init (int argc, ACE_TCHAR *argv[]) switch (c) { case 'p': - local_addr.set (ACE_OS::atoi (get_opt.opt_arg ())); - break; + local_addr.set (ACE_OS::atoi (get_opt.opt_arg ())); + break; case 't': - n_threads = ACE_OS::atoi (get_opt.opt_arg ()); - break; + n_threads = ACE_OS::atoi (get_opt.opt_arg ()); + break; default: - break; + break; } // Initialize the threading strategy. if (this->thr_strategy_.open (&this->thr_mgr_, - this->thr_flags_, - n_threads) == -1) + this->thr_flags_, + n_threads) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1); // Initialize the Acceptor base class, passing in the desired // concurrency strategy. else if (this->open (local_addr, - ACE_Reactor::instance (), - 0, - 0, - &this->thr_strategy_) == -1) + ACE_Reactor::instance (), + 0, + 0, + &this->thr_strategy_) == -1) ACE_ERROR_RETURN ((LM_ERROR, ACE_TEXT ("%p\n"), ACE_TEXT ("open")), -1); else return 0; @@ -124,14 +124,16 @@ CLI_Stream::open (void *) { ACE_INET_Addr sa; - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) client handle = %d\n"), - this->peer ().get_handle ())); + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("(%t) client handle = %d\n"), + this->peer ().get_handle ())); if (this->peer ().get_remote_addr (sa) == -1) return -1; - ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%t) accepted at port %d\n"), - sa.get_port_number ())); + ACE_DEBUG ((LM_DEBUG, + ACE_TEXT ("(%t) accepted at port %d\n"), + sa.get_port_number ())); return 0; } @@ -152,9 +154,10 @@ CLI_Stream::svc (void) time_t t = ACE_OS::time (0L); ACE_OS::cuserid (login_name); - ACE_OS::sprintf (buf, "user %s %s", - login_name, - ACE_TEXT_ALWAYS_CHAR (ACE_OS::ctime ((const time_t *) &t))); + ACE_OS::sprintf (buf, + "user %s %s", + login_name, + ACE_TEXT_ALWAYS_CHAR (ACE_OS::ctime ((const time_t *) &t))); if (this->peer ().send_n (buf, ACE_OS::strlen (buf) + 1) == -1) return -1; -- cgit v1.2.1