summaryrefslogtreecommitdiff
path: root/examples/Service_Configurator
diff options
context:
space:
mode:
authorOssama Othman <ossama-othman@users.noreply.github.com>2004-07-13 02:53:39 +0000
committerOssama Othman <ossama-othman@users.noreply.github.com>2004-07-13 02:53:39 +0000
commita3b4b84046ced2d3e07c40f68edde4719d3d3e91 (patch)
tree2719c1694cc4e49d92352f35298d0f19ea8c697c /examples/Service_Configurator
parenta85cab6282ec09bed79c4b0b2958d3914bd0ea53 (diff)
downloadATCD-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.i28
-rw-r--r--examples/Service_Configurator/IPC-tests/server/Handle_R_Stream.i16
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;