diff options
author | Abdullah Sowayan <sowayan@users.noreply.github.com> | 2007-08-14 23:29:36 +0000 |
---|---|---|
committer | Abdullah Sowayan <sowayan@users.noreply.github.com> | 2007-08-14 23:29:36 +0000 |
commit | fb4b5b24dda3332ce1651f1747bd96430884d3bb (patch) | |
tree | 822cb61bac3aeeb11bad1050dfe9f78b91989436 /ACE/tests/SOCK_Dgram_Test.cpp | |
parent | d66ae065b3a38293d1926e64d6255761af852cd2 (diff) | |
download | ATCD-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.cpp | 188 |
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); |