summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorschmidt <douglascraigschmidt@users.noreply.github.com>1997-11-14 16:39:57 +0000
committerschmidt <douglascraigschmidt@users.noreply.github.com>1997-11-14 16:39:57 +0000
commite9f756cdf63f4be34fc6626d30d24f57b9d022f6 (patch)
tree03fe8e32fb25525046d8974858c29b555ed2b124 /examples
parent6d0ad8bf80e67920daa5444fd385c1cf512191cc (diff)
downloadATCD-e9f756cdf63f4be34fc6626d30d24f57b9d022f6.tar.gz
*** empty log message ***
Diffstat (limited to 'examples')
-rw-r--r--examples/Reactor/Dgram/CODgram.cpp35
-rw-r--r--examples/Reactor/Dgram/Dgram.cpp15
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);
}