diff options
Diffstat (limited to 'ACE/apps/JAWS/stress_testing/connection.cpp')
-rw-r--r-- | ACE/apps/JAWS/stress_testing/connection.cpp | 100 |
1 files changed, 100 insertions, 0 deletions
diff --git a/ACE/apps/JAWS/stress_testing/connection.cpp b/ACE/apps/JAWS/stress_testing/connection.cpp new file mode 100644 index 00000000000..c81ae2fba53 --- /dev/null +++ b/ACE/apps/JAWS/stress_testing/connection.cpp @@ -0,0 +1,100 @@ +// $Id$ + +#include "connection.h" + +ACE_RCSID(stress_testing, connection, "$Id$") + +// Make the connection to the WEB server + +int connection::connect(char *hostname_opt_port, int tcp_nodelay, int sockbufsiz) { + if(!hostname_opt_port) return 1; + + char *hostname_with_port; + // Check to see if portnumber is specified in the hostnameport + // If not, append :80 + if(!ACE_OS::strchr(hostname_opt_port,':')) { + hostname_with_port = new char[ACE_OS::strlen(hostname_opt_port) + 3]; + ACE_OS::sprintf(hostname_with_port, "%s:%d", hostname_opt_port, 80); + } + else { + hostname_with_port = hostname_opt_port; + } + + // Beyond this point, hostname_with_port is of the form hostname:port + + ACE_INET_Addr server_addr(hostname_with_port); + + // Connect to server + + ACE_SOCK_Connector con; + + if(con.connect(stream_, server_addr) == -1) { + ACE_OS::perror("ACE_SOCK_Connector::connect"); + return 1; + } + + + // tcp_nodelay processing. + + // turn off weird ack things + if(tcp_nodelay) { + struct protoent *p = ACE_OS::getprotobyname ("tcp"); + int one = 1; + + if (p && stream_.set_option (p->p_proto, + TCP_NODELAY, + (char *)& one, + sizeof (one))) + { + ACE_OS::perror("tcp_nodelay"); + return 1; + } + } + + if(sockbufsiz) + if (stream_.set_option (SOL_SOCKET, + SO_RCVBUF, + (char *) &sockbufsiz, + sizeof sockbufsiz) == -1) + { + ACE_OS::perror("socket_queue_size"); + return 1; + } + + return 0; +} + +int connection::read(void *buffer, size_t maxlen, unsigned int timeout_seconds) { + ACE_UNUSED_ARG (timeout_seconds); + return stream_.recv(buffer, maxlen); +} + +int connection::write(const void *buffer, size_t maxlen, unsigned int timeout_seconds) { + ACE_UNUSED_ARG (timeout_seconds); + return stream_.send(buffer, maxlen); +} + +int connection::write_n(const void *buffer, size_t len, unsigned int timeout_seconds) { + ACE_UNUSED_ARG (timeout_seconds); + if(stream_.send_n(buffer, len) == -1) + ACE_ERROR_RETURN((LM_ERROR, "Write failed for %s", buffer),1); + return 0; +} + +int connection::read_n(void *buffer, size_t maxlen, unsigned int timeout_seconds) { + ACE_UNUSED_ARG (timeout_seconds); + if(stream_.recv_n(buffer, maxlen) == -1) + ACE_ERROR_RETURN((LM_ERROR, "Read failed.."),1); + return 1; +} + +int connection::close(void) { + stream_.close_reader(); + stream_.close_writer(); + stream_.close(); + return 0; +} + +connection::~connection(void) { + this->close(); +} |