diff options
Diffstat (limited to 'examples/IPC_SAP/TLI_SAP/CPP-ATM-server.cpp')
-rw-r--r-- | examples/IPC_SAP/TLI_SAP/CPP-ATM-server.cpp | 87 |
1 files changed, 87 insertions, 0 deletions
diff --git a/examples/IPC_SAP/TLI_SAP/CPP-ATM-server.cpp b/examples/IPC_SAP/TLI_SAP/CPP-ATM-server.cpp new file mode 100644 index 00000000000..8e3e13286b8 --- /dev/null +++ b/examples/IPC_SAP/TLI_SAP/CPP-ATM-server.cpp @@ -0,0 +1,87 @@ +// $Id$ + +#include "ace/TLI_Acceptor.h" +#include "ace/ATM_Addr.h" + +ACE_RCSID(TLI_SAP, CPP_ATM_server, "$Id$") + +#if defined (ACE_HAS_FORE_ATM_XTI) +// ACE_TLI Server + +int +main (int argc, char *argv[]) +{ + ACE_Time_Value timeout (argc > 1 ? ACE_OS::atoi (argv[2]) : ACE_DEFAULT_TIMEOUT); + + // Create a server address. + ACE_ATM_Addr addr; + + // Create a server, reuse the addr. + ACE_TLI_Acceptor peer_acceptor; + + // Not sure why but reuse_addr set to true/1 causes problems for + // FORE/XTI/ATM - this is now handled in ACE_TLI_Acceptor::open() + if (peer_acceptor.open (addr, 1) == -1) + ACE_ERROR_RETURN ((LM_ERROR, + "%p\n", + "open"), + -1); + + ACE_TLI_Stream new_stream; + + ACE_DEBUG ((LM_DEBUG, + "starting server at address %s\n", + addr.addr_to_string ())); + + + // Performs the iterative server activities + + for (;;) + { + char buf[BUFSIZ]; + + // Create a new ACE_TLI_Stream endpoint (note automatic restart + // if errno == EINTR). + if (peer_acceptor.accept (new_stream, + &addr, + &timeout) == -1) + { + ACE_ERROR ((LM_ERROR, + "%p\n", + "accept")); + continue; + } + + ACE_DEBUG ((LM_DEBUG, + "client %s connected\n", + addr.addr_to_string ())); + + // Read data from client (terminate on error). + + for (int r_bytes; + (r_bytes = new_stream.recv (buf, sizeof buf)) > 0; ) + if (ACE_OS::write (ACE_STDOUT, + buf, + r_bytes) != r_bytes) + ACE_ERROR ((LM_ERROR, + "%p\n", + "ACE::send_n")); + + // Close new endpoint (listening endpoint stays open). + if (new_stream.close () == -1) + ACE_ERROR ((LM_ERROR, + "%p\n", + "close")); + + } + /* NOTREACHED */ + return 0; +} +#else +int main (int, char *[]) +{ + ACE_ERROR_RETURN ((LM_ERROR, + "your platform isn't configured to support XTI/ATM\n"), + 1); +} +#endif /* ACE_HAS_TLI */ |