diff options
Diffstat (limited to 'examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp')
| -rw-r--r-- | examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp | 58 |
1 files changed, 40 insertions, 18 deletions
diff --git a/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp b/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp index 80d4915741b..0c28532906f 100644 --- a/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp +++ b/examples/Service_Configurator/IPC-tests/client/local_stream_client_test.cpp @@ -9,20 +9,22 @@ ACE_RCSID(client, local_stream_client_test, "$Id$") #if defined (ACE_HAS_MSG) && !defined (ACE_LACKS_UNIX_DOMAIN_SOCKETS) -/* Name of the program. */ +// Name of the program. static char *program_name; -/* Name of rendezvous point. */ -static char *rendezvous = "/tmp/foo_stream"; +// Name of rendezvous point. +static const char *rendezvous = "/tmp/foo_stream"; -/* Name of file to send. */ -static char *file_name = "local_data"; +// Name of file to send. +static const char *file_name = "local_data"; static void print_usage_and_die (void) { - ACE_ERROR ((LM_ERROR, "usage: %s [-r rendezvous] [-f file]%a\n", - program_name, -1)); + ACE_ERROR ((LM_ERROR, + "usage: %s [-r rendezvous] [-f file]%a\n", + program_name, + -1)); } void @@ -58,30 +60,50 @@ main (int argc, char *argv[]) ACE_LSOCK_Stream sc; ACE_LSOCK_Connector con; - if (con.connect (sc, ACE_UNIX_Addr (rendezvous)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "connect"), -1); + if (con.connect (sc, + ACE_UNIX_Addr (rendezvous)) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + "%p\n", + "connect"), + -1); - if ((fd = ACE_OS::open (file_name, O_RDONLY)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1); + if ((fd = ACE_OS::open (file_name, + O_RDONLY)) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + "%p\n", + "open"), + -1); - /* Send the open file descriptor to the server! */ + // Send the open file descriptor to the server! if (sc.send_handle (fd) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "send_handle"), -1); - - if ((n = sc.recv_n (buf, sizeof buf)) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "recv"), -1); + ACE_ERROR_RETURN ((LM_ERROR, + "%p\n", + "send_handle"), + -1); + + if ((n = sc.recv_n (buf, + sizeof buf)) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + "%p\n", + "recv"), + -1); else ACE_OS::write (ACE_STDOUT, buf, n); if (ACE_OS::close (fd) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "close"), -1); + ACE_ERROR_RETURN ((LM_ERROR, + "%p\n", + "close"), + -1); return 0; } #else int main (int, char *[]) { - ACE_ERROR_RETURN ((LM_ERROR, "your platform must support sendmsg/recvmsg to run this test\n"), -1); + ACE_ERROR_RETURN ((LM_ERROR, + "your platform must support sendmsg/recvmsg to run this test\n"), + -1); } #endif /* ACE_HAS_MSG */ |