diff options
author | Ossama Othman <ossama-othman@users.noreply.github.com> | 2004-07-13 02:53:39 +0000 |
---|---|---|
committer | Ossama Othman <ossama-othman@users.noreply.github.com> | 2004-07-13 02:53:39 +0000 |
commit | a3b4b84046ced2d3e07c40f68edde4719d3d3e91 (patch) | |
tree | 2719c1694cc4e49d92352f35298d0f19ea8c697c /examples/Service_Configurator | |
parent | a85cab6282ec09bed79c4b0b2958d3914bd0ea53 (diff) | |
download | ATCD-a3b4b84046ced2d3e07c40f68edde4719d3d3e91.tar.gz |
ChangeLogTag:Mon Jul 12 19:51:21 2004 Ossama Othman <ossama@dre.vanderbilt.edu>
Diffstat (limited to 'examples/Service_Configurator')
-rw-r--r-- | examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i | 28 | ||||
-rw-r--r-- | examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i | 16 |
2 files changed, 22 insertions, 22 deletions
diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i b/examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i index 48ee7b7404a..a9d24f1d8f4 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_Broadcast.i @@ -27,7 +27,7 @@ Handle_Broadcast::open (const ACE_INET_Addr &r, int async) return 0; } -ACE_INLINE int +ACE_INLINE int Handle_Broadcast::info (char **strp, size_t length) const { char buf[BUFSIZ]; @@ -35,7 +35,7 @@ Handle_Broadcast::info (char **strp, size_t length) const if (this->get_local_addr (sa) == -1) return -1; - + ACE_OS::sprintf (buf, "%d/%s %s", sa.get_port_number (), "udp", "# tests broadcasting\n"); if (*strp == 0 && (*strp = ACE_OS::strdup (buf)) == 0) @@ -54,35 +54,35 @@ Handle_Broadcast::init (int argc, char *argv[]) for (int c; (c = get_opt ()) != -1; ) switch (c) { - case 'p': - sba.set (ACE_OS::atoi (get_opt.opt_arg ())); - break; + case 'p': + sba.set (ACE_OS::atoi (get_opt.opt_arg ())); + break; default: - break; + break; } - + if (this->open (sba) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "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, "registering service with ACE_Reactor\n"), -1); return 0; } -ACE_INLINE int -Handle_Broadcast::fini (void) +ACE_INLINE int +Handle_Broadcast::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_Broadcast::get_handle (void) const { - return this->ACE_SOCK_Dgram::get_handle (); + return this->ACE_SOCK_Dgram::get_handle (); } -ACE_INLINE int +ACE_INLINE int Handle_Broadcast::handle_input (ACE_HANDLE) { ACE_INET_Addr sa; diff --git a/examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i b/examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i index fdd6a6a0786..8f8912c8f63 100644 --- a/examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i +++ b/examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i @@ -52,23 +52,23 @@ ACE_INLINE int Handle_R_Stream::init (int argc, char *argv[]) { ACE_INET_Addr sis (Handle_R_Stream::DEFAULT_PORT); - ACE_Get_Opt get_opt (argc, argv, "p:", 0); + ACE_Get_Opt get_opt (argc, argv, "p:", 0); for (int c; (c = get_opt ()) != -1; ) switch (c) { case 'p': - sis.set (ACE_OS::atoi (get_opt.opt_arg ())); - break; + sis.set (ACE_OS::atoi (get_opt.opt_arg ())); + break; default: - break; + break; } if (this->open (sis) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); else if (ACE_Reactor::instance ()->register_handler - (this, ACE_Event_Handler::ACCEPT_MASK) == -1) + (this, ACE_Event_Handler::ACCEPT_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "registering service with ACE_Reactor\n"), -1); @@ -111,7 +111,7 @@ Handle_R_Stream::handle_input (ACE_HANDLE) return -1; else ACE_DEBUG ((LM_INFO, "new_remote_stream fd = %d\n", - this->new_remote_stream.get_handle ())); + this->new_remote_stream.get_handle ())); ACE_INET_Addr sa; @@ -134,9 +134,9 @@ Handle_R_Stream::handle_input (ACE_HANDLE) ACE_TCHAR *cs = ACE_OS::ctime (&t); if (this->new_remote_stream.send (4, - Handle_R_Stream::login_name, + Handle_R_Stream::login_name, ACE_OS::strlen (Handle_R_Stream::login_name), - cs, + cs, ACE_OS::strlen (cs)) == -1) return -1; |