summaryrefslogtreecommitdiff
path: root/examples/IPC_SAP/TLI_SAP/ftp-server.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/IPC_SAP/TLI_SAP/ftp-server.cpp')
-rw-r--r--examples/IPC_SAP/TLI_SAP/ftp-server.cpp74
1 files changed, 0 insertions, 74 deletions
diff --git a/examples/IPC_SAP/TLI_SAP/ftp-server.cpp b/examples/IPC_SAP/TLI_SAP/ftp-server.cpp
deleted file mode 100644
index 1111cdbc664..00000000000
--- a/examples/IPC_SAP/TLI_SAP/ftp-server.cpp
+++ /dev/null
@@ -1,74 +0,0 @@
-// $Id$
-/* Simple file transfer example */
-
-#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_TLI_Stream stream;
- char buf[BUFSIZ];
- int flags = 0;
- int n;
-
- // Cast the arg to a long, first, because a pointer is the same
- // size as a long on all current ACE platforms.
- stream.set_handle ((int) (long) 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_UNUSED_ARG (n);
-
- 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;
-
- // 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");
- }
-
- ACE_NOTREACHED (return 0);
-}
-#else
-#include <stdio.h>
-int main (int, char *[])
-{
- ACE_ERROR_RETURN ((LM_ERROR, "your platform must support ACE_TLI\n"), 1);
-}
-#endif /* ACE_HAS_THREADS */