diff options
Diffstat (limited to 'apps/JAWS/stress_testing/connection.cpp')
-rw-r--r-- | apps/JAWS/stress_testing/connection.cpp | 98 |
1 files changed, 0 insertions, 98 deletions
diff --git a/apps/JAWS/stress_testing/connection.cpp b/apps/JAWS/stress_testing/connection.cpp deleted file mode 100644 index a243fdd01d5..00000000000 --- a/apps/JAWS/stress_testing/connection.cpp +++ /dev/null @@ -1,98 +0,0 @@ -// $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) { - 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))) { - perror("tcp_nodelay"); - return 1; - } - } - - if(sockbufsiz) - if (stream_.set_option (SOL_SOCKET, - SO_RCVBUF, - (char *) &sockbufsiz, - sizeof sockbufsiz) == -1) { - 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(); -} |