summaryrefslogtreecommitdiff
path: root/ACE/tests/SOCK_Dgram_Test.cpp
diff options
context:
space:
mode:
authorAbdullah Sowayan <sowayan@users.noreply.github.com>2007-08-14 23:29:36 +0000
committerAbdullah Sowayan <sowayan@users.noreply.github.com>2007-08-14 23:29:36 +0000
commitfb4b5b24dda3332ce1651f1747bd96430884d3bb (patch)
tree822cb61bac3aeeb11bad1050dfe9f78b91989436 /ACE/tests/SOCK_Dgram_Test.cpp
parentd66ae065b3a38293d1926e64d6255761af852cd2 (diff)
downloadATCD-fb4b5b24dda3332ce1651f1747bd96430884d3bb.tar.gz
Tue Aug 14 23:28:07 UTC 2007 Abdullah Sowayan <abdullah.sowayan@lmco.com>
Diffstat (limited to 'ACE/tests/SOCK_Dgram_Test.cpp')
-rw-r--r--ACE/tests/SOCK_Dgram_Test.cpp188
1 files changed, 94 insertions, 94 deletions
diff --git a/ACE/tests/SOCK_Dgram_Test.cpp b/ACE/tests/SOCK_Dgram_Test.cpp
index e89af2c4eba..210a1be7eb5 100644
--- a/ACE/tests/SOCK_Dgram_Test.cpp
+++ b/ACE/tests/SOCK_Dgram_Test.cpp
@@ -45,93 +45,93 @@ client (void *arg)
if (remote_addr->get_type () == AF_INET)
{
server_addr.set (remote_addr->get_port_number (),
- ACE_LOCALHOST,
- 1,
- remote_addr->get_type ());
+ ACE_LOCALHOST,
+ 1,
+ remote_addr->get_type ());
}
#if defined (ACE_HAS_IPV6)
else
{
server_addr.set (remote_addr->get_port_number(),
ACE_IPV6_LOCALHOST,
- 1,
- remote_addr->get_type ());
+ 1,
+ remote_addr->get_type ());
}
#endif /* ACE_HAS_IPV6 */
server_addr.addr_to_string (hostname_string, 100);
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("(%P|%t) starting client UDP send to %s\n"),
- hostname_string));
+ ACE_TEXT ("(%P|%t) starting client UDP send to %s\n"),
+ hostname_string));
if (cli_dgram.open (ACE_Addr::sap_any, server_addr.get_type ()) == -1)
{
ACE_ERROR((LM_ERROR,
ACE_TEXT("(%P|%t) protocol %d, %p\n"),
server_addr.get_type (),
- ACE_TEXT ("SOCK_Dgram open")));
+ ACE_TEXT ("SOCK_Dgram open")));
}
else if (cli_dgram.send (TEST_DATA, sizeof (TEST_DATA), server_addr) == -1)
{
ACE_ERROR((LM_ERROR,
- ACE_TEXT("(%P|%t) UDP send to %s %p\n"),
- hostname_string,
- ACE_TEXT ("failed")));
+ ACE_TEXT("(%P|%t) UDP send to %s %p\n"),
+ hostname_string,
+ ACE_TEXT ("failed")));
}
else
{
ssize_t rcv_cnt = cli_dgram.recv (buf,
- sizeof (buf),
- peer_addr,
- 0,
- &timeout);
+ sizeof (buf),
+ peer_addr,
+ 0,
+ &timeout);
if (rcv_cnt == -1)
- {
- if (errno == ETIME)
- {
- ACE_ERROR((LM_ERROR,
- ACE_TEXT("(%P|%t) UDP recv on proto %d timed out\n"),
- server_addr.get_type ()));
- }
- else
- {
- ACE_ERROR((LM_ERROR,
- ACE_TEXT("(%P|%t) UDP recv on proto %d %p\n"),
- server_addr.get_type (),
- ACE_TEXT("failed")));
- }
- }
+ {
+ if (errno == ETIME)
+ {
+ ACE_ERROR((LM_ERROR,
+ ACE_TEXT("(%P|%t) UDP recv on proto %d timed out\n"),
+ server_addr.get_type ()));
+ }
+ else
+ {
+ ACE_ERROR((LM_ERROR,
+ ACE_TEXT("(%P|%t) UDP recv on proto %d %p\n"),
+ server_addr.get_type (),
+ ACE_TEXT("failed")));
+ }
+ }
else
- {
- // recv() ok, check data and 'from' address
- size_t rcv_siz = static_cast<size_t> (rcv_cnt);
- if (rcv_siz != sizeof (TEST_DATA))
- {
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) recv cnt %B; should be %B\n"),
- rcv_siz,
- sizeof (TEST_DATA)));
- }
- else
- {
- buf[rcv_siz] = '\0';
- if (ACE_OS::strncmp (buf, TEST_DATA, ACE_OS::strlen (TEST_DATA)))
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) recv string should be %s; ")
- ACE_TEXT (" but is %s\n"),
- TEST_DATA, buf));
- }
- if (peer_addr.get_type () != server_addr.get_type ())
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) recv addr type %d; should be %d\n"),
- peer_addr.get_type (),
- server_addr.get_type ()));
- if (peer_addr.get_size () != server_addr.get_size ())
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) recv addr size %d; should be %d\n"),
- peer_addr.get_size (),
- server_addr.get_size ()));
- }
+ {
+ // recv() ok, check data and 'from' address
+ size_t rcv_siz = static_cast<size_t> (rcv_cnt);
+ if (rcv_siz != sizeof (TEST_DATA))
+ {
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("(%P|%t) recv cnt %B; should be %B\n"),
+ rcv_siz,
+ sizeof (TEST_DATA)));
+ }
+ else
+ {
+ buf[rcv_siz] = '\0';
+ if (ACE_OS::strncmp (buf, TEST_DATA, ACE_OS::strlen (TEST_DATA)))
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("(%P|%t) recv string should be %s; ")
+ ACE_TEXT (" but is %s\n"),
+ TEST_DATA, buf));
+ }
+ if (peer_addr.get_type () != server_addr.get_type ())
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("(%P|%t) recv addr type %d; should be %d\n"),
+ peer_addr.get_type (),
+ server_addr.get_type ()));
+ if (peer_addr.get_size () != server_addr.get_size ())
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("(%P|%t) recv addr size %d; should be %d\n"),
+ peer_addr.get_size (),
+ server_addr.get_size ()));
+ }
}
cli_dgram.close();
@@ -158,38 +158,38 @@ server (void *arg)
// recv() ok, check data and 'from' address
size_t rcv_siz = static_cast<size_t> (rcv_cnt);
if (rcv_siz != sizeof (TEST_DATA))
- {
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) recv cnt %B; should be %B\n"),
- rcv_siz,
- sizeof (TEST_DATA)));
- }
+ {
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("(%P|%t) recv cnt %B; should be %B\n"),
+ rcv_siz,
+ sizeof (TEST_DATA)));
+ }
else
- {
- buf[rcv_siz / sizeof (ACE_TCHAR)] = '\0';
- if (ACE_OS::strncmp (buf, TEST_DATA, ACE_OS::strlen (TEST_DATA)))
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) recv string should be %s; ")
- ACE_TEXT (" but is %s\n"),
- TEST_DATA, buf));
- }
+ {
+ buf[rcv_siz / sizeof (ACE_TCHAR)] = '\0';
+ if (ACE_OS::strncmp (buf, TEST_DATA, ACE_OS::strlen (TEST_DATA)))
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("(%P|%t) recv string should be %s; ")
+ ACE_TEXT (" but is %s\n"),
+ TEST_DATA, buf));
+ }
if (0 == peer_addr.addr_to_string (hostname_string,
- sizeof (hostname_string)))
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("(%P|%t) Echoing data to %s\n"),
- hostname_string));
+ sizeof (hostname_string)))
+ ACE_DEBUG ((LM_DEBUG,
+ ACE_TEXT ("(%P|%t) Echoing data to %s\n"),
+ hostname_string));
else
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) %p\n"),
- ACE_TEXT ("addr_to_string")));
- if (server_dgram->send (TEST_DATA, sizeof (TEST_DATA),
- peer_addr, 0) == -1)
- {
- ACE_ERROR((LM_ERROR,
- ACE_TEXT("(%P|%t) %p\n"),
- ACE_TEXT("Server UDP send failed")));
- }
+ ACE_ERROR ((LM_ERROR,
+ ACE_TEXT ("(%P|%t) %p\n"),
+ ACE_TEXT ("addr_to_string")));
+ if (server_dgram->send (TEST_DATA, sizeof (TEST_DATA),
+ peer_addr, 0) == -1)
+ {
+ ACE_ERROR((LM_ERROR,
+ ACE_TEXT("(%P|%t) %p\n"),
+ ACE_TEXT("Server UDP send failed")));
+ }
}
server_dgram->close ();
@@ -216,21 +216,21 @@ spawn (int proto)
// Bind UDP server to the appropriate port
if (server_dgram.open (server_addr, proto) == -1)
ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("(%P|%t) %p\n"),
- ACE_TEXT ("server dgram open")));
+ ACE_TEXT ("(%P|%t) %p\n"),
+ ACE_TEXT ("server dgram open")));
else
{
ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("(%P|%t) started server at proto %d, port %d\n"),
- proto,
+ ACE_TEXT ("(%P|%t) started server at proto %d, port %d\n"),
+ proto,
server_addr.get_port_number ()));
#if !defined (ACE_LACKS_FORK)
switch (ACE_OS::fork (ACE_TEXT ("child")))
{
case -1:
ACE_ERROR_BREAK ((LM_ERROR,
- ACE_TEXT ("(%P|%t) %p\n"),
- ACE_TEXT ("fork failed")));
+ ACE_TEXT ("(%P|%t) %p\n"),
+ ACE_TEXT ("fork failed")));
/* NOTREACHED */
case 0:
client (&server_addr);