1 files changed, 84 insertions, 0 deletions
diff --git a/ACE/examples/IPC_SAP/SOCK_SAP/C-inclient.cpp b/ACE/examples/IPC_SAP/SOCK_SAP/C-inclient.cpp
new file mode 100644
index 00000000000..bd6926cd182
--- /dev/null
+++ b/ACE/examples/IPC_SAP/SOCK_SAP/C-inclient.cpp
@@ -0,0 +1,84 @@
+// $Id$
+
+#include "ace/OS_main.h"
+#include "ace/OS_NS_string.h"
+#include "ace/OS_NS_sys_socket.h"
+#include "ace/OS_NS_unistd.h"
+#include "ace/OS_NS_stdlib.h"
+#include "ace/OS_NS_stdio.h"
+#include "ace/OS_NS_netdb.h"
+#include "ace/Default_Constants.h"
+
+
+
+/* BSD socket client */
+
+int
+ACE_TMAIN (int argc, ACE_TCHAR *argv[])
+{
+  // Initialize WinSock DLL on Win32...
+  ACE_OS::socket_init (ACE_WSOCK_VERSION);
+
+  struct sockaddr_in saddr;
+  struct hostent *hp;
+  const ACE_TCHAR *host = argc > 1 ? argv[1] : ACE_DEFAULT_SERVER_HOST;
+  u_short port_num =
+    ACE_HTONS (argc > 2 ? ACE_OS::atoi (argv[2]) : ACE_DEFAULT_SERVER_PORT);
+  int sockbufsize = argc > 3 ? ACE_OS::atoi (argv[3]) : 0;
+  char buf[BUFSIZ];
+  ACE_HANDLE s_handle;
+  int w_bytes;
+  int r_bytes;
+  int n;
+
+  // Create a local endpoint of communication.
+  if ((s_handle = ACE_OS::socket (PF_INET, SOCK_STREAM, 0)) == ACE_INVALID_HANDLE)
+    ACE_OS::perror (ACE_TEXT("socket")), ACE_OS::exit (1);
+
+  // If a sockbufsize was specified, set it for both send and receive.
+  if (sockbufsize > 0)
+    {
+      if (ACE_OS::setsockopt (s_handle, SOL_SOCKET, SO_SNDBUF,
+                              (const char *) &sockbufsize,
+                              sizeof (sockbufsize)) != 0)
+        ACE_OS::perror (ACE_TEXT("SO_SNDBUF")), ACE_OS::exit (1);
+      if (ACE_OS::setsockopt (s_handle, SOL_SOCKET, SO_RCVBUF,
+                              (const char *) &sockbufsize,
+                              sizeof (sockbufsize)) != 0)
+        ACE_OS::perror (ACE_TEXT("SO_RCVBUF")), ACE_OS::exit (1);
+    }
+
+  // Determine IP address of the server.
+  if ((hp = ACE_OS::gethostbyname (ACE_TEXT_ALWAYS_CHAR(host))) == 0)
+    ACE_OS::perror (ACE_TEXT("gethostbyname")), ACE_OS::exit (1);
+
+  // Set up the address information to contact the server.
+  ACE_OS::memset ((void *) &saddr, 0, sizeof saddr);
+  saddr.sin_family = AF_INET;
+  saddr.sin_port = port_num;
+  ACE_OS::memcpy (&saddr.sin_addr, hp->h_addr, hp->h_length);
+
+  // Establish connection with remote server.
+  if (ACE_OS::connect (s_handle,
+                       reinterpret_cast<sockaddr *> (&saddr),
+                       sizeof saddr) == -1)
+    ACE_OS::perror (ACE_TEXT("connect")), ACE_OS::exit (1);
+
+  // Send data to server (correctly handles "incomplete writes" due to
+  // flow control).
+
+  while ((r_bytes = ACE_OS::read (ACE_STDIN, buf, sizeof buf)) > 0)
+    for (w_bytes = 0; w_bytes < r_bytes; w_bytes += n)
+      if ((n = ACE_OS::send (s_handle, buf + w_bytes,
+                      r_bytes - w_bytes)) < 0)
+        ACE_OS::perror (ACE_TEXT("write")), ACE_OS::exit (1);
+
+  if (ACE_OS::recv (s_handle, buf, 1) == 1)
+    ACE_OS::write (ACE_STDOUT, buf, 1);
+
+  // Explicitly close the connection.
+  if (ACE_OS::closesocket (s_handle) == -1)
+    ACE_OS::perror (ACE_TEXT("close")), ACE_OS::exit (1);
+
+  return 0;
+}