diff options
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/IPC_SAP/SOCK_SAP/CPP-inclient.cpp | 21 | ||||
| -rw-r--r-- | examples/IPC_SAP/SOCK_SAP/CPP-inserver.cpp | 4 |
2 files changed, 21 insertions, 4 deletions
diff --git a/examples/IPC_SAP/SOCK_SAP/CPP-inclient.cpp b/examples/IPC_SAP/SOCK_SAP/CPP-inclient.cpp index 9801bde8199..3cec94a92e5 100644 --- a/examples/IPC_SAP/SOCK_SAP/CPP-inclient.cpp +++ b/examples/IPC_SAP/SOCK_SAP/CPP-inclient.cpp @@ -16,32 +16,45 @@ int main (int argc, char *argv[]) char buf[BUFSIZ]; ACE_SOCK_Stream cli_stream; - ACE_INET_Addr remote_addr (r_port, host); - ACE_DEBUG ((LM_DEBUG, "starting non-blocking connect\n")); // Initiate timed, non-blocking connection with server. ACE_SOCK_Connector con; // Attempt a non-blocking connect to the server, reusing the local // addr if necessary. +#if defined (VXWORKS) + ACE_DEBUG ((LM_DEBUG, "starting connect\n")); + + fprintf (stderr, + "CPP-inclient.cpp: you'll need to hard code the hostname:port on VxWorks!!!!\n"); + ACE_INET_Addr remote_addr ("<hard-coded hostname:10002"); + if (con.connect (cli_stream, remote_addr) == -1) +#else + ACE_DEBUG ((LM_DEBUG, "starting non-blocking connect\n")); + + ACE_INET_Addr remote_addr (r_port, host); if (con.connect (cli_stream, remote_addr, (ACE_Time_Value *) &ACE_Time_Value::zero) == -1) +#endif /* VXWORKS */ { if (errno != EWOULDBLOCK) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "connection failed"), 1); ACE_DEBUG ((LM_DEBUG, "starting timed connect\n")); +#if !defined (VXWORKS) // Check if non-blocking connection is in progress, // and wait up to timeout seconds for it to complete. - if (con.complete (cli_stream, &remote_addr, &timeout) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "connection failed"), 1); + ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "complete failed"), 1); else ACE_DEBUG ((LM_DEBUG, "connected to %s\n", remote_addr.get_host_name ())); +#endif /* !VXWORKS */ } +#if !defined (VXWORKS) if (cli_stream.disable (ACE_NONBLOCK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "disable"), 1); +#endif /* !VXWORKS */ // Send data to server (correctly handles "incomplete writes"). diff --git a/examples/IPC_SAP/SOCK_SAP/CPP-inserver.cpp b/examples/IPC_SAP/SOCK_SAP/CPP-inserver.cpp index 96013f6f19f..313d1c683b6 100644 --- a/examples/IPC_SAP/SOCK_SAP/CPP-inserver.cpp +++ b/examples/IPC_SAP/SOCK_SAP/CPP-inserver.cpp @@ -29,9 +29,11 @@ main (int argc, char *argv[]) // Create a server, reuse the address. if (peer_acceptor.open (server_addr, 1) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "open"), 1); +#if !defined(VXWORKS) // Set the peer acceptor into non-blocking mode. else if (peer_acceptor.enable (ACE_NONBLOCK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "enable"), 1); +#endif /* !VXWORKS */ else if (peer_acceptor.get_local_addr (server_addr) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "get_local_addr"), 1); @@ -70,9 +72,11 @@ main (int argc, char *argv[]) ACE_DEBUG ((LM_DEBUG, "client %s connected from %d\n", cli_addr.get_host_name (), cli_addr.get_port_number ())); +#if !defined(VXWORKS) // Enable non-blocking I/O. if (new_stream.enable (ACE_NONBLOCK) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "enable"), -1); +#endif /* !VXWORKS */ handle_set.reset (); handle_set.set_bit (new_stream.get_handle ()); |