Initial revision

1 files changed, 75 insertions, 0 deletions

diff --git a/examples/IPC_SAP/TLI_SAP/ftp-server.cpp b/examples/IPC_SAP/TLI_SAP/ftp-server.cpp
new file mode 100644
index 00000000000..116af9c2942
--- /dev/null
+++ b/examples/IPC_SAP/TLI_SAP/ftp-server.cpp
@@ -0,0 +1,75 @@
+/* Simple file transfer example */
+// @(#)ftp-server.cpp	1.1	10/18/96
+
+#include "ace/Log_Msg.h"
+#include "ace/Thread_Manager.h"
+#include "ace/TLI_Acceptor.h"
+
+#if defined (ACE_HAS_THREADS) && defined (ACE_HAS_TLI)
+
+ACE_Thread_Manager thr_mgr;
+
+void *
+read_file (void *fd)
+{
+  ACE_Thread_Control   tc (&thr_mgr);
+  ACE_TLI_Stream stream;
+  char	     buf[BUFSIZ];
+  int	     flags = 0;
+  int	     n;
+
+  stream.set_handle (int (fd));
+
+  ACE_OS::printf ("start  (tid = %d, fd = %d)\n", ACE_OS::thr_self (), stream.get_handle ());
+  ACE_OS::fflush (stdout);
+
+  while ((n = stream.recv (buf, sizeof buf, &flags)) > 0)
+    continue;
+
+  ACE_OS::printf ("finish (tid = %d, fd = %d)\n", ACE_OS::thr_self (), stream.get_handle ());
+
+  if (stream.close () == -1)
+    ACE_OS::t_error ("stream.close error");
+
+  return 0;
+}
+
+int 
+main (int argc, char *argv[])
+{
+  u_short port = argc > 1 ? ACE_OS::atoi (argv[1]) : ACE_DEFAULT_SERVER_PORT;
+  ACE_TLI_Acceptor   server;
+  ACE_TLI_Stream     new_stream;
+  
+  /* Allow up to 100 simultaneous threads */
+  if (thr_mgr.open (100) == -1)
+    ACE_OS::perror ("thr_mgr.open"), ACE_OS::exit (1);
+
+  // Open the server and reuse the address if in use...
+  if (server.open (ACE_INET_Addr (port), 1) == -1)
+    ACE_OS::t_error ("server.open"), ACE_OS::exit (1);
+
+  /* Wait for a connection from a client.  This is an example of a concurrent server */
+
+  for (int count = 1; ; count++)
+    {
+      ACE_OS::fprintf (stderr, "thread %d, blocking for accept #%d\n", 
+		       ACE_OS::thr_self (), count);
+
+      if (server.accept (new_stream) == -1)
+	ACE_OS::t_error ("server.accept error");
+
+      else if (thr_mgr.spawn (ACE_THR_FUNC (read_file), 
+			      (void *) new_stream.get_handle (),
+			      THR_DETACHED | THR_BOUND) == -1)
+	ACE_OS::perror ("can't create worker thread\n");
+    }
+  return 0;
+}
+#else
+#include <stdio.h>
+int main (void)
+{
+  ACE_ERROR_RETURN ((LM_ERROR, "your platform must support ACE_TLI\n"), 1);
+}
+#endif /* ACE_HAS_THREADS */