1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114
|
// $Id: CPP-ATM-server.cpp 91671 2010-09-08 18:39:23Z johnnyw $
#include "ace/TLI_Acceptor.h"
#include "ace/ATM_Addr.h"
#include "ace/Log_Msg.h"
#if defined (ACE_HAS_FORE_ATM_XTI)
// ACE_TLI Server
int
ACE_TMAIN (int argc, ACE_TCHAR *argv[])
{
ACE_Time_Value timeout (ACE_DEFAULT_TIMEOUT);
unsigned char selector = ACE_ATM_Addr::DEFAULT_SELECTOR;
int selector_specified = 0;
int opt;
while ((opt = ACE_OS::getopt (argc, argv, "s:?h")) != EOF)
{
switch(opt)
{
case 's':
selector = ACE_OS::atoi (optarg);
selector_specified = 1;
break;
case '?':
case 'h':
ACE_ERROR_RETURN ((LM_ERROR,
"Usage: %s [-s selector]\n", argv[0]),
1);
} // switch
} // while getopt
// Create a server address.
ACE_ATM_Addr addr;
if (selector_specified)
addr.set_selector(selector);
// 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,
O_RDWR,
0,
5,
ACE_XTI_ATM_DEVICE) == -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)) > 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 ACE_TMAIN (int, ACE_TCHAR *[])
{
ACE_ERROR_RETURN ((LM_ERROR,
"your platform isn't configured to support XTI/ATM\n"),
1);
}
#endif /* ACE_HAS_TLI */
|