*** empty log message ***

1 files changed, 141 insertions, 0 deletions

diff --git a/docs/tutorials/004/client.cpp b/docs/tutorials/004/client.cpp
new file mode 100644
index 00000000000..295d8131f8f
--- /dev/null
+++ b/docs/tutorials/004/client.cpp
@@ -0,0 +1,141 @@
+// $Id$
+
+#include "ace/SOCK_Connector.h"
+#include "ace/SString.h"
+
+class Client : private ACE_SOCK_Stream
+{
+public:
+  ACE_SOCK_Stream::close;	// promote to public
+
+  Client(void);
+  Client( const char * server, u_short port );
+
+  int open( const char * server, u_short port );
+
+  inline int initialized(void) { return mInitialized; }
+  inline int error(void)       { return mError; }
+
+  Client & operator<<( ACE_SString & str );
+  Client & operator<<( char * str );
+  Client & operator<<( int  n );
+
+  class Error {};
+
+protected:
+
+private:
+  unsigned char mInitialized;
+  unsigned char mError;
+};
+
+Client::Client(void)
+{
+  mInitialized = 0;
+  mError = 0;
+}
+
+Client::Client( const char * server, u_short port )
+{
+  mInitialized = 0;
+  mError = 0;
+  (void)open(server,port);
+}
+
+int Client::open( const char * server, u_short port )
+{
+  ACE_SOCK_Connector connector;
+  ACE_INET_Addr addr (port, server);
+
+  if (connector.connect (*this, addr) == -1)
+  {
+    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), -1);
+  }
+
+  mInitialized = 1;
+
+  return(0);
+}
+
+Client & Client::operator<<( ACE_SString & str )
+{
+	if( initialized() )
+	{
+		if( error() )
+		{
+			throw Error();
+		}
+
+		char * cp = str.rep();
+
+		mError = 0;
+
+		if( this->send_n(cp,strlen(cp)) == -1 )
+		{
+			mError = 1;
+			throw Error();
+		}
+	}
+	else
+	{
+		mError = 2;
+		throw Error();
+	}
+
+	return *this ;
+}
+
+Client & Client::operator<< ( char * str )
+{
+	ACE_SString newStr(str);
+
+	*this << newStr;
+
+	return *this ;
+}
+
+Client & Client::operator<< ( int n )
+{
+	char buf[1024];
+	sprintf(buf,"(%d)\n",n);
+	ACE_SString newStr(buf);
+
+	*this << newStr;
+
+	return *this;
+}
+
+int main (int argc, char *argv[])
+{
+  const char *server_host = argc > 1 ? argv[1]                : ACE_DEFAULT_SERVER_HOST;
+  u_short server_port     = argc > 2 ? ACE_OS::atoi (argv[2]) : ACE_DEFAULT_SERVER_PORT;
+  int max_iterations      = argc > 3 ? ACE_OS::atoi (argv[3]) : 4;
+
+  Client server(server_host,server_port);
+
+  if( ! server.initialized() )
+  {
+    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "intialization"), -1);
+  }
+
+  
+  for (int i = 0; i < max_iterations; i++)
+    {
+      try
+      {
+      	server << "message = " << i+1;
+        ACE_OS::sleep (1);
+      }
+      catch ( Client::Error & e )
+      {
+	cout << "There was an error sending the data\n";
+      }
+    }
+
+  if (server.close () == -1)
+  {
+    ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "close"), -1);
+  }
+
+  return 0;
+}