summaryrefslogtreecommitdiff
path: root/ACE/examples/Service_Configurator/IPC-tests
diff options
context:
space:
mode:
authorAbdullah Sowayan <sowayan@users.noreply.github.com>2008-06-16 16:57:12 +0000
committerAbdullah Sowayan <sowayan@users.noreply.github.com>2008-06-16 16:57:12 +0000
commit7ea3ed1ac16c01d9c52ed005113d059dc24d07af (patch)
treedfd4a24631aa25ed30db07a2a5adb23df086b1d9 /ACE/examples/Service_Configurator/IPC-tests
parentd34535e5f988ba2387ef762cb8477dc585109acc (diff)
downloadATCD-7ea3ed1ac16c01d9c52ed005113d059dc24d07af.tar.gz
Mon Jun 16 16:54:25 UTC 2008 Abdullah Sowayan <abdullah.sowayan@lmco.com>
Diffstat (limited to 'ACE/examples/Service_Configurator/IPC-tests')
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/client/broadcast_client_test.cpp8
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/client/local_dgram_client_test.cpp2
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/client/local_pipe_client_test.cpp8
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp12
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_CODgram.inl37
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Dgram.inl34
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_FIFO.inl19
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Pipe.inl21
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_SPIPE.inl10
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/server/Handle_L_Stream.inl55
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/server/Handle_R_Dgram.inl35
-rw-r--r--ACE/examples/Service_Configurator/IPC-tests/server/Handle_Thr_Stream.cpp39
12 files changed, 139 insertions, 141 deletions
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<SVH, PR_AC_2>::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<PR_ST_2>::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<PR_ST_2>::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;