summaryrefslogtreecommitdiff
path: root/examples/APG/Sockets/Basic_Robust.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/APG/Sockets/Basic_Robust.cpp')
-rw-r--r--examples/APG/Sockets/Basic_Robust.cpp137
1 files changed, 0 insertions, 137 deletions
diff --git a/examples/APG/Sockets/Basic_Robust.cpp b/examples/APG/Sockets/Basic_Robust.cpp
deleted file mode 100644
index 361519a4486..00000000000
--- a/examples/APG/Sockets/Basic_Robust.cpp
+++ /dev/null
@@ -1,137 +0,0 @@
-// $Id$
-
-#include "ace/OS_NS_errno.h"
-#include "ace/INET_Addr.h"
-#include "ace/SOCK_Stream.h"
-#include "ace/SOCK_Connector.h"
-#include "ace/Log_Msg.h"
-#include "ace/Time_Value.h"
-
-int ACE_TMAIN (int, ACE_TCHAR *[])
-{
- /*
- * Here we will use the default ctor and the set()
- * method to configure it. After each set() we will
- * display the address as a string and then connect
- * to each respective server. We can reuse the addr
- * instance once connection has been established.
- *
- // Listing 1 code/ch06
- ACE_INET_Addr addr;
- ...
- addr.set ("HAStatus", ACE_LOCALHOST);
- ...
- addr.set ("HALog", ACE_LOCALHOST);
- // Listing 1
- *
- */
-
- ACE_INET_Addr addr;
- ACE_TCHAR peerAddress[64];
-
- // Listing 2 code/ch06
- addr.set (ACE_TEXT("HAStatus"), ACE_LOCALHOST);
- if (addr.addr_to_string (peerAddress,
- sizeof(peerAddress), 0) == 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("(%P|%t) Connecting to %s\n"),
- peerAddress));
- }
- // Listing 2
-
- // Listing 3 code/ch06
- ACE_SOCK_Stream status;
- ACE_OS::last_error(0);
- ACE_SOCK_Connector statusConnector (status, addr);
- if (ACE_OS::last_error())
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("%p\n"),
- ACE_TEXT ("status")), 100);
- // Listing 3
-
- addr.set (ACE_TEXT("HALog"), ACE_LOCALHOST);
- if (addr.addr_to_string (peerAddress,
- sizeof(peerAddress), 0) == 0)
- {
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("(%P|%t) Connecting to %s\n"),
- peerAddress ));
- }
-
- // Listing 4 code/ch06
- ACE_SOCK_Connector logConnector;
- ACE_Time_Value timeout (10);
- ACE_SOCK_Stream log;
- if (logConnector.connect (log, addr, &timeout) == -1)
- {
- if (ACE_OS::last_error() == ETIME)
- {
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("(%P|%t) Timeout while ")
- ACE_TEXT ("connecting to log server\n")));
- }
- else
- {
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("%p\n"),
- ACE_TEXT ("log")));
- }
- return (101);
- }
- // Listing 4
-
- /*
- * We generally let the OS pick our local port number but
- * if you want, you can choose that also:
- // Listing 5 code/ch06
- ACE_SOCK_Connector logConnector;
- ACE_INET_Addr local (4200, ACE_LOCALHOST);
- if (logConnector.connect (log, addr, 0, local) == -1)
- {
- ...
- // Listing 5
- }
- */
-
- char buf[64];
-
- // Listing 6 code/ch06
- ACE_Time_Value sendTimeout (0, 5);
- if (status.send_n ("uptime\n", 7, &sendTimeout) == -1)
- {
- if (ACE_OS::last_error() == ETIME)
- {
- ACE_DEBUG ((LM_DEBUG,
- ACE_TEXT ("(%P|%t) Timeout while sending ")
- ACE_TEXT ("query to status server\n")));
- }
- // Listing 6
- else
- {
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("%p\n"),
- ACE_TEXT ("send_n")));
- }
- return (102);
- }
-
- // Listing 7 code/ch06
- ssize_t bc ;
- ACE_Time_Value recvTimeout (0, 1);
- if ((bc = status.recv (buf, sizeof(buf), &recvTimeout)) == -1)
- {
- ACE_ERROR ((LM_ERROR,
- ACE_TEXT ("%p\n"),
- ACE_TEXT ("recv")));
- return (103);
- }
-
- log.send_n (buf, bc);
- // Listing 7
-
- status.close ();
- log.close ();
-
- return (0);
-}