diff options
author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1997-11-14 16:39:57 +0000 |
---|---|---|
committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1997-11-14 16:39:57 +0000 |
commit | e9f756cdf63f4be34fc6626d30d24f57b9d022f6 (patch) | |
tree | 03fe8e32fb25525046d8974858c29b555ed2b124 /examples | |
parent | 6d0ad8bf80e67920daa5444fd385c1cf512191cc (diff) | |
download | ATCD-e9f756cdf63f4be34fc6626d30d24f57b9d022f6.tar.gz |
*** empty log message ***
Diffstat (limited to 'examples')
-rw-r--r-- | examples/Reactor/Dgram/CODgram.cpp | 35 | ||||
-rw-r--r-- | examples/Reactor/Dgram/Dgram.cpp | 15 |
2 files changed, 27 insertions, 23 deletions
diff --git a/examples/Reactor/Dgram/CODgram.cpp b/examples/Reactor/Dgram/CODgram.cpp index 1e23aa947ef..22d394ae4ab 100644 --- a/examples/Reactor/Dgram/CODgram.cpp +++ b/examples/Reactor/Dgram/CODgram.cpp @@ -1,14 +1,13 @@ -/* Exercise the ACE_SOCK_CODgram wrapper along with the ACE_Reactor. // $Id$ - - Typical invocation sequence is: - - % CODgram 10000 localhost 10001 & - % CODgram 10001 localhost 10000 - - This will start two interacting copies of the CODgram - application. */ +// Exercise the ACE_SOCK_CODgram wrapper along with the ACE_Reactor. +// +// Typical invocation sequence is: +// +// % CODgram 10000 localhost 10001 & +// % CODgram 10001 localhost 10000 +// +// This will start two interacting copies of the CODgram application. #include "ace/Reactor.h" #include "ace/SOCK_CODgram.h" @@ -44,11 +43,13 @@ int AAL_CP::handle_input (int) { char buf[BUFSIZ]; - ssize_t n; ACE_DEBUG ((LM_DEBUG, "Activity occurred on handle %d!\n", ACE_SOCK_CODgram::get_handle ())); - if ((n = ACE_SOCK_CODgram::recv (buf, sizeof buf)) == -1) + + ssize_t n = ACE_SOCK_CODgram::recv (buf, sizeof buf); + + if (n == -1) ACE_ERROR ((LM_ERROR, "%p\n", "handle_input")); else ACE_DEBUG ((LM_DEBUG, "got buf = %*s\n", n, buf)); @@ -65,17 +66,17 @@ AAL_CP::handle_timeout (const ACE_Time_Value &, const void *) int main(int argc, char *argv[]) { - /* Estabish call backs, and socket names */ + // Estabish call backs, and socket names. if (argc != 4) ACE_ERROR_RETURN ((LM_ERROR, "usage: %s localport remotehost remoteport\n", argv[0]), -1); ACE_Reactor reactor; - char buf[128]; + char buf[BUFSIZ]; u_short localport = ACE_OS::atoi (argv[1]); u_short remoteport = ACE_OS::atoi (argv[3]); - char *remotehost = argv[2]; + char *remotehost = argv[2]; ACE_INET_Addr remote_addr (remoteport, remotehost); ACE_INET_Addr local_addr (localport); @@ -95,7 +96,7 @@ int main(int argc, char *argv[]) } } - /* read data from other side */ + // Read data from other side. if (reactor.register_handler (&aal, ACE_Event_Handler::READ_MASK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "ACE_Reactor::register_handler"), -1); @@ -108,7 +109,7 @@ int main(int argc, char *argv[]) for (;;) { - /* Wait at most two seconds */ + // Wait at most two seconds. ACE_Time_Value tv (2, 0); reactor.handle_events (tv); @@ -118,5 +119,5 @@ int main(int argc, char *argv[]) ACE_DEBUG ((LM_DEBUG, ".\n")); } - ACE_NOTREACHED(return 0); + ACE_NOTREACHED (return 0); } diff --git a/examples/Reactor/Dgram/Dgram.cpp b/examples/Reactor/Dgram/Dgram.cpp index a20804e6c40..3d441e45291 100644 --- a/examples/Reactor/Dgram/Dgram.cpp +++ b/examples/Reactor/Dgram/Dgram.cpp @@ -1,6 +1,7 @@ -// Exercise the ACE_SOCK_Dgram wrapper along with the ACE_Reactor. // $Id$ +// Exercise the ACE_SOCK_Dgram wrapper along with the ACE_Reactor. +// // Typical invocation sequence is: // // % Dgram 10000 localhost 10001 & @@ -41,12 +42,14 @@ int AAL_CP::handle_input (ACE_HANDLE) { char buf[BUFSIZ]; - ssize_t n; ACE_INET_Addr from_addr; ACE_DEBUG ((LM_DEBUG, "Activity occurred on handle %d!\n", ACE_SOCK_Dgram::get_handle ())); - if ((n = ACE_SOCK_Dgram::recv (buf, sizeof buf, from_addr)) == -1) + + ssize_t n = ACE_SOCK_Dgram::recv (buf, sizeof buf, from_addr); + + if (n == -1) ACE_ERROR ((LM_ERROR, "%p\n", "handle_input")); else ACE_DEBUG ((LM_DEBUG, "got buf = %*s\n", n, buf)); @@ -71,10 +74,10 @@ main (int argc, char *argv[]) argv[0]), -1); ACE_Reactor reactor; - char buf[128]; + char buf[BUFSIZ]; u_short localport = ACE_OS::atoi (argv[1]); u_short remoteport = ACE_OS::atoi (argv[3]); - char *remotehost = argv[2]; + char *remotehost = argv[2]; ACE_INET_Addr remote_addr (remoteport, remotehost); ACE_INET_Addr local_addr (localport); @@ -117,5 +120,5 @@ main (int argc, char *argv[]) ACE_DEBUG ((LM_DEBUG, ".\n")); } - ACE_NOTREACHED(return 0); + ACE_NOTREACHED (return 0); } |