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.cpp75
1 files changed, 0 insertions, 75 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 046f4dc0464..00000000000
--- a/examples/IPC_SAP/TLI_SAP/ftp-server.cpp
+++ /dev/null
@@ -1,75 +0,0 @@
-/* Simple file transfer example */
-// $Id$
-
-
-#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 */