0f081398cf0eef8cc7c66a535d450110a92dc8aefielding

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding

24b534291150023e6b68eca89ddd33e475ccddc0wrowe#define AP_AB_BASEREVISION "2.0.40-dev"

24b534291150023e6b68eca89ddd33e475ccddc0wrowe

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

3568de757bac0b47256647504c186d17ca272f85rbb

3568de757bac0b47256647504c186d17ca272f85rbb#if 'A' != 0x41

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz#define NOT_ASCII

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz#endif

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

3568de757bac0b47256647504c186d17ca272f85rbb#define BSD_COMP

3568de757bac0b47256647504c186d17ca272f85rbb

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_signal.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_strings.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_network_io.h"

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz#include "apr_file_io.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_time.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_getopt.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_general.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_lib.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_portable.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "ap_release.h"

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_poll.h"

3568de757bac0b47256647504c186d17ca272f85rbb

3568de757bac0b47256647504c186d17ca272f85rbb#define APR_WANT_STRFUNC

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding#include "apr_want.h"

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding

3568de757bac0b47256647504c186d17ca272f85rbb#include "apr_base64.h"

239f998fbee5ac5b114b965bb76e217cce0003edstoddard#ifdef NOT_ASCII

78ae889ffe0fdfab72f56c6993b0f302cb48da55rbb#include "apr_xlate.h"

3568de757bac0b47256647504c186d17ca272f85rbb#endif

6653a33e820463abd4f81915b7a1eba0f602e200brianp#if APR_HAVE_STDIO_H

6653a33e820463abd4f81915b7a1eba0f602e200brianp#include <stdio.h>

6653a33e820463abd4f81915b7a1eba0f602e200brianp#endif

41634f717c623556a16b27b25d7d909a66fe20f8wrowe#if APR_HAVE_STDLIB_H

41634f717c623556a16b27b25d7d909a66fe20f8wrowe#include <stdlib.h>

6653a33e820463abd4f81915b7a1eba0f602e200brianp

3568de757bac0b47256647504c186d17ca272f85rbb#ifdef USE_SSL

ad83978f20c7d1a4323059d9af122e56fcd353bdstoddard#if ((!(RSAREF)) && (!(SYSSSL)))

7cd5419264796cfeaf8215383cf0f89130a81fectrawick#include <openssl/rsa.h>

3568de757bac0b47256647504c186d17ca272f85rbb#include <openssl/crypto.h>

6653a33e820463abd4f81915b7a1eba0f602e200brianp#include <openssl/x509.h>

6653a33e820463abd4f81915b7a1eba0f602e200brianp#include <openssl/pem.h>

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm#include <openssl/err.h>

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm#include <openssl/ssl.h>

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick#include <openssl/rand.h>

36c8049de63c446926139936c3d195330a0539cetrawick#else

dd028aa8111afb6534fece555e8c2d408894671etrawick#include <rsa.h>

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding#include <crypto.h>

e8f95a682820a599fe41b22977010636be5c2717jim#include <x509.h>

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz#include <pem.h>

ca53a74f4012a45cbad48e940eddf27d866981f9dougm#include <err.h>

ca53a74f4012a45cbad48e940eddf27d866981f9dougm#include <ssl.h>

ca53a74f4012a45cbad48e940eddf27d866981f9dougm#include <rand.h>

dd028aa8111afb6534fece555e8c2d408894671etrawick#endif

dd028aa8111afb6534fece555e8c2d408894671etrawick#endif

6653a33e820463abd4f81915b7a1eba0f602e200brianp

6653a33e820463abd4f81915b7a1eba0f602e200brianp#include <math.h>

6653a33e820463abd4f81915b7a1eba0f602e200brianp#endif

6653a33e820463abd4f81915b7a1eba0f602e200brianp#if APR_HAVE_CTYPE_H

6653a33e820463abd4f81915b7a1eba0f602e200brianp#include <ctype.h>

6653a33e820463abd4f81915b7a1eba0f602e200brianp#endif

6653a33e820463abd4f81915b7a1eba0f602e200brianp

6653a33e820463abd4f81915b7a1eba0f602e200brianp

6653a33e820463abd4f81915b7a1eba0f602e200brianp#ifndef LLONG_MAX

6653a33e820463abd4f81915b7a1eba0f602e200brianp#define AB_MAX APR_INT64_C(0x7fffffffffffffff)

6653a33e820463abd4f81915b7a1eba0f602e200brianp#else

6653a33e820463abd4f81915b7a1eba0f602e200brianp#define AB_MAX LLONG_MAX

6653a33e820463abd4f81915b7a1eba0f602e200brianp#endif

6653a33e820463abd4f81915b7a1eba0f602e200brianp

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick#define MAX_REQUESTS 50000

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick

239f998fbee5ac5b114b965bb76e217cce0003edstoddard#define STATE_UNCONNECTED 0

3568de757bac0b47256647504c186d17ca272f85rbb#define STATE_CONNECTING 1

3568de757bac0b47256647504c186d17ca272f85rbb#define STATE_READ 2

3568de757bac0b47256647504c186d17ca272f85rbb

12901074f5d6b36d08be84d8637b6f2c21e0da26trawick#define CBUFFSIZE (2048)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardstruct connection {

3568de757bac0b47256647504c186d17ca272f85rbb apr_pool_t *ctx;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz apr_socket_t *aprsock;

48d2edbfb84e5559b5da0f8d614ccab805cc67a8rbb int state;

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding apr_size_t read; /* amount of bytes read */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_size_t bread; /* amount of body read */

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding apr_size_t rwrite, rwrote; /* keep pointers in what we write - across

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding apr_size_t length; /* Content-Length value used for keep-alive */

3568de757bac0b47256647504c186d17ca272f85rbb char cbuff[CBUFFSIZE]; /* a buffer to store server response header */

3568de757bac0b47256647504c186d17ca272f85rbb int cbx; /* offset in cbuffer */

3568de757bac0b47256647504c186d17ca272f85rbb int keepalive; /* non-zero if a keep-alive request */

3568de757bac0b47256647504c186d17ca272f85rbb int gotheader; /* non-zero if we have the entire header in

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_time_t start, /* Start of connection */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard connect, /* Connected, start writing */

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz endwrite, /* Request written */

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz beginread, /* First byte of input */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard done; /* Connection closed */

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem int socknum;

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem#ifdef USE_SSL

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem SSL *ssl;

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem#endif

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem};

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluemstruct data {

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem#ifdef USE_SSL

83a5021aef5ebb67395b93f75df4fd0f0b4fc8c8fuankg /* XXXX insert SSL timings */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard#endif

9f979f5c8061f6f6f560d1824e0e378ff5b91931rpluem int read; /* number of bytes read */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_time_t starttime; /* start time of connection in seconds since

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_interval_time_t waittime; /* Between writing request and reading

f2e009134c7e279f99dfca5bd421f721bf1f7840jorton apr_interval_time_t ctime; /* time in ms to connect */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_interval_time_t time; /* time in ms for connection */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard};

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard#define ap_min(a,b) ((a)<(b))?(a):(b)

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz#define ap_max(a,b) ((a)>(b))?(a):(b)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

3568de757bac0b47256647504c186d17ca272f85rbb

3568de757bac0b47256647504c186d17ca272f85rbbint verbosity = 0; /* no verbosity by default */

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawickint posting = 0; /* GET by default */

7cd5419264796cfeaf8215383cf0f89130a81fectrawickint requests = 1; /* Number of requests to make */

7cd5419264796cfeaf8215383cf0f89130a81fectrawickint heartbeatres = 100; /* How often do we say we're alive */

7cd5419264796cfeaf8215383cf0f89130a81fectrawickint concurrency = 1; /* Number of multiple requests to make */

7cd5419264796cfeaf8215383cf0f89130a81fectrawickint percentile = 1; /* Show percentile served */

e8f95a682820a599fe41b22977010636be5c2717jimint confidence = 1; /* Show confidence estimator and warnings */

98cd3186185bb28ae6c95a3f159899fcf56a663ftrawickint tlimit = 0; /* time limit in secs */

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawickint keepalive = 0; /* try and do keepalive connections */

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawickchar servername[1024]; /* name that server reports */

3568de757bac0b47256647504c186d17ca272f85rbbchar *hostname; /* host name from URL */

a72ba68ecbbc61e4b513e50d6000245c33f753dcwrowechar *host_field; /* value of "Host:" header field */

64c351fd973428b5bb4c28e983fa86875ea4e60fdougmchar *path; /* path name */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardchar postfile[1024]; /* name of file containing post data */

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantzchar *postdata; /* *buffer containing data from postfile */

64c351fd973428b5bb4c28e983fa86875ea4e60fdougmapr_size_t postlen = 0; /* length of data to be POSTed */

64c351fd973428b5bb4c28e983fa86875ea4e60fdougmchar content_type[1024]; /* content type to put in POST header */

3cbd177a6c885562f9ad0cf11695f044489c881dgregameschar *cookie, /* optional cookie line */

dd028aa8111afb6534fece555e8c2d408894671etrawick *auth, /* optional (basic/uuencoded) auhentication */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard *hdrs; /* optional arbitrary headers */

3cbd177a6c885562f9ad0cf11695f044489c881dgregamesapr_port_t port; /* port number */

3cbd177a6c885562f9ad0cf11695f044489c881dgregameschar proxyhost[1024]; /* proxy host name */

3cbd177a6c885562f9ad0cf11695f044489c881dgregamesint proxyport = 0; /* proxy port */

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardchar *connecthost;

5a0f707b48da7703cbe6bc087f13a6735b1c742dgregamesapr_port_t connectport;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantzchar *gnuplot; /* GNUplot file */

5a0f707b48da7703cbe6bc087f13a6735b1c742dgregameschar *csvperc; /* CSV Percentile file */

5a0f707b48da7703cbe6bc087f13a6735b1c742dgregameschar url[1024];

5a0f707b48da7703cbe6bc087f13a6735b1c742dgregameschar * fullurl, * colonhost;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardint isproxy = 0;

64c351fd973428b5bb4c28e983fa86875ea4e60fdougmapr_interval_time_t aprtimeout = apr_time_from_sec(30); /* timeout value */

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm /*

ad83978f20c7d1a4323059d9af122e56fcd353bdstoddard

7cd5419264796cfeaf8215383cf0f89130a81fectrawickint use_html = 0; /* use html in the report */

7cd5419264796cfeaf8215383cf0f89130a81fectrawickconst char *tablestring;

7cd5419264796cfeaf8215383cf0f89130a81fectrawickconst char *trstring;

7cd5419264796cfeaf8215383cf0f89130a81fectrawickconst char *tdstring;

7cd5419264796cfeaf8215383cf0f89130a81fectrawick

7cd5419264796cfeaf8215383cf0f89130a81fectrawickapr_size_t doclen = 0; /* the length the document should be */

7cd5419264796cfeaf8215383cf0f89130a81fectrawicklong started = 0; /* number of requests started, so no excess */

7cd5419264796cfeaf8215383cf0f89130a81fectrawicklong totalread = 0; /* total number of bytes read */

7cd5419264796cfeaf8215383cf0f89130a81fectrawicklong totalbread = 0; /* totoal amount of entity body read */

7cd5419264796cfeaf8215383cf0f89130a81fectrawicklong totalposted = 0; /* total number of bytes posted, inc. headers */

7cd5419264796cfeaf8215383cf0f89130a81fectrawicklong done = 0; /* number of requests we have done */

7cd5419264796cfeaf8215383cf0f89130a81fectrawicklong doneka = 0; /* number of keep alive connections done */

7cd5419264796cfeaf8215383cf0f89130a81fectrawicklong good = 0, bad = 0; /* number of good and bad requests */

7cd5419264796cfeaf8215383cf0f89130a81fectrawicklong epipe = 0; /* number of broken pipe writes */

7cd5419264796cfeaf8215383cf0f89130a81fectrawick

7cd5419264796cfeaf8215383cf0f89130a81fectrawick#ifdef USE_SSL

7cd5419264796cfeaf8215383cf0f89130a81fectrawickint ssl = 0;

7cd5419264796cfeaf8215383cf0f89130a81fectrawickSSL_CTX *ctx;

7cd5419264796cfeaf8215383cf0f89130a81fectrawickBIO *bio_out,*bio_err;

7cd5419264796cfeaf8215383cf0f89130a81fectrawickstatic void write_request(struct connection * c);

7cd5419264796cfeaf8215383cf0f89130a81fectrawick#endif

7cd5419264796cfeaf8215383cf0f89130a81fectrawick

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantzint err_length = 0, err_conn = 0, err_except = 0;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardint err_response = 0;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantzapr_time_t start, endtime;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardchar _request[512];

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardchar *request = _request;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardapr_size_t reqlen;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

7cd5419264796cfeaf8215383cf0f89130a81fectrawickchar buffer[8192];

7cd5419264796cfeaf8215383cf0f89130a81fectrawick

7cd5419264796cfeaf8215383cf0f89130a81fectrawickint percs[] = {50, 66, 75, 80, 90, 95, 98, 99, 100};

7cd5419264796cfeaf8215383cf0f89130a81fectrawick

7cd5419264796cfeaf8215383cf0f89130a81fectrawickstruct connection *con; /* connection array */

64c351fd973428b5bb4c28e983fa86875ea4e60fdougmstruct data *stats; /* date for each request */

3568de757bac0b47256647504c186d17ca272f85rbbapr_pool_t *cntxt;

3568de757bac0b47256647504c186d17ca272f85rbb

74fd6d9aeadb9022086259c5c1ae00bc0dda9c9astoddardapr_pollset_t *readbits;

72b6f1cf3e616473e1c26464b3193b13c2c09e87brianp

72b6f1cf3e616473e1c26464b3193b13c2c09e87brianpapr_sockaddr_t *destsa;

3568de757bac0b47256647504c186d17ca272f85rbb

3568de757bac0b47256647504c186d17ca272f85rbb#ifdef NOT_ASCII

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardapr_xlate_t *from_ascii, *to_ascii;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard#endif

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardstatic void close_connection(struct connection * c);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardstatic void err(char *s)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard{

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz fprintf(stderr, "%s\n", s);

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz if (done)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard printf("Total of %ld requests completed\n" , done);

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz exit(1);

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz}

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

dd028aa8111afb6534fece555e8c2d408894671etrawickstatic void apr_err(char *s, apr_status_t rv)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard{

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard char buf[120];

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

3568de757bac0b47256647504c186d17ca272f85rbb fprintf(stderr,

3568de757bac0b47256647504c186d17ca272f85rbb "%s: %s (%d)\n",

3568de757bac0b47256647504c186d17ca272f85rbb s, apr_strerror(rv, buf, sizeof buf), rv);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard if (done)

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz printf("Total of %ld requests completed\n" , done);

f714f1a7002928d785e53e70349700a7f595fee3trawick exit(rv);

f714f1a7002928d785e53e70349700a7f595fee3trawick}

3568de757bac0b47256647504c186d17ca272f85rbb

ad83978f20c7d1a4323059d9af122e56fcd353bdstoddard#if defined(USE_SSL) && USE_THREADS

4a13940dc2990df0a798718d3a3f9cf1566c2217bjh

3568de757bac0b47256647504c186d17ca272f85rbbstatic apr_thread_mutex_t **lock_cs;

3568de757bac0b47256647504c186d17ca272f85rbbstatic int lock_num_locks;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

663237d6bcc59ac0997d71d48a1baa55fa29a3d8jimstatic void ssl_util_thr_lock(int mode, int type,

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard const char *file, int line)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard{

3568de757bac0b47256647504c186d17ca272f85rbb if (type < lock_num_locks) {

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard if (mode & CRYPTO_LOCK) {

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_thread_mutex_lock(lock_cs[type]);

663237d6bcc59ac0997d71d48a1baa55fa29a3d8jim }

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard else {

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_thread_mutex_unlock(lock_cs[type]);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard }

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard }

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz}

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardstatic unsigned long ssl_util_thr_id(void)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard{

3568de757bac0b47256647504c186d17ca272f85rbb /* OpenSSL needs this to return an unsigned long. On OS/390, the pthread

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard#ifdef __MVS__

3568de757bac0b47256647504c186d17ca272f85rbb struct PSA {

4a13940dc2990df0a798718d3a3f9cf1566c2217bjh char unmapped[540];

4a13940dc2990df0a798718d3a3f9cf1566c2217bjh unsigned long PSATOLD;

4a13940dc2990df0a798718d3a3f9cf1566c2217bjh } *psaptr = 0;

3568de757bac0b47256647504c186d17ca272f85rbb

3568de757bac0b47256647504c186d17ca272f85rbb return psaptr->PSATOLD;

663237d6bcc59ac0997d71d48a1baa55fa29a3d8jim#else

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard return (unsigned long) apr_os_thread_current();

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard#endif

3568de757bac0b47256647504c186d17ca272f85rbb}

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardstatic apr_status_t ssl_util_thread_cleanup(void *data)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard{

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard CRYPTO_set_locking_callback(NULL);

3568de757bac0b47256647504c186d17ca272f85rbb

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard /* Let the registered mutex cleanups do their own thing

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard return APR_SUCCESS;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard}

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

3568de757bac0b47256647504c186d17ca272f85rbbvoid ssl_util_thread_setup(apr_pool_t *p)

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard{

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz int i;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

3568de757bac0b47256647504c186d17ca272f85rbb lock_num_locks = CRYPTO_num_locks();

3568de757bac0b47256647504c186d17ca272f85rbb lock_cs = apr_palloc(p, lock_num_locks * sizeof(*lock_cs));

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz for (i = 0; i < lock_num_locks; i++) {

3568de757bac0b47256647504c186d17ca272f85rbb apr_thread_mutex_create(&(lock_cs[i]), APR_THREAD_MUTEX_DEFAULT, p);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard }

3568de757bac0b47256647504c186d17ca272f85rbb

3568de757bac0b47256647504c186d17ca272f85rbb CRYPTO_set_id_callback(ssl_util_thr_id);

3568de757bac0b47256647504c186d17ca272f85rbb

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard CRYPTO_set_locking_callback(ssl_util_thr_lock);

3568de757bac0b47256647504c186d17ca272f85rbb

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_pool_cleanup_register(p, NULL, ssl_util_thread_cleanup,

3568de757bac0b47256647504c186d17ca272f85rbb apr_pool_cleanup_null);

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick}

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick#endif

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick

fe6baec9bbcd36f932b71a355120cd7b5a685d6cfielding#ifdef USE_SSL

3568de757bac0b47256647504c186d17ca272f85rbblong ssl_print_cb(BIO *bio,int cmd,const char *argp,int argi,long argl,long ret)

3568de757bac0b47256647504c186d17ca272f85rbb{

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard BIO *out;

3568de757bac0b47256647504c186d17ca272f85rbb

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard out=(BIO *)BIO_get_callback_arg(bio);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard if (out == NULL) return(ret);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard if (cmd == (BIO_CB_READ|BIO_CB_RETURN))

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard {

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard BIO_printf(out,"read from %08X [%08lX] (%d bytes => %ld (0x%X))\n",

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard bio,argp,argi,ret,ret);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard BIO_dump(out,(char *)argp,(int)ret);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard return(ret);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard }

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard else if (cmd == (BIO_CB_WRITE|BIO_CB_RETURN))

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe {

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard BIO_printf(out,"write to %08X [%08lX] (%d bytes => %ld (0x%X))\n",

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard bio,argp,argi,ret,ret);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard BIO_dump(out,(char *)argp,(int)ret);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard }

8e9734d1a4af74c141e2a0f880bb51bb061fa03atrawick return(ret);

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard}

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard#ifndef RAND_MAX

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick#include <limits.h>

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick#define RAND_MAX INT_MAX

3568de757bac0b47256647504c186d17ca272f85rbb#endif

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

cb97ae2ff6969c2789b8e03f1bc4187fa73b6bafwrowestatic int ssl_rand_choosenum(int l, int h)

0f113d7123e8bd3e3e2e9b6373461a1a773bfccatrawick{

0f113d7123e8bd3e3e2e9b6373461a1a773bfccatrawick int i;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz char buf[50];

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard srand((unsigned int)time(NULL));

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard apr_snprintf(buf, sizeof(buf), "%.0f",

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard (((double)(rand()%RAND_MAX)/RAND_MAX)*(h-l)));

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard i = atoi(buf)+1;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard if (i < l) i = l;

3568de757bac0b47256647504c186d17ca272f85rbb if (i > h) i = h;

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard return i;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz}

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddardvoid ssl_rand_seed()

c0659e61002e9d6ff77b2dca72540e0af1b2ca64stoddard{

3568de757bac0b47256647504c186d17ca272f85rbb int nDone = 0;

3568de757bac0b47256647504c186d17ca272f85rbb int n, l;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick time_t t;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick pid_t pid;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick unsigned char stackdata[256];

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick /*

f886987cd0bd4220c14043c4d9be77ec22902e73trawick t = time(NULL);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick l = sizeof(time_t);

f886987cd0bd4220c14043c4d9be77ec22902e73trawick RAND_seed((unsigned char *)&t, l);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick nDone += l;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick /*

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz pid = getpid();

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz l = sizeof(pid_t);

a72ba68ecbbc61e4b513e50d6000245c33f753dcwrowe RAND_seed((unsigned char *)&pid, l);

2e7f1d7da527c09e717251e186deffe55e6fbd0ftrawick nDone += l;

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm /*

2e7f1d7da527c09e717251e186deffe55e6fbd0ftrawick n = ssl_rand_choosenum(0, sizeof(stackdata)-128-1);

2e7f1d7da527c09e717251e186deffe55e6fbd0ftrawick RAND_seed(stackdata+n, 128);

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm nDone += 128;

3568de757bac0b47256647504c186d17ca272f85rbb}

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantzint ssl_print_connection_info(bio,ssl)

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantzBIO *bio;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantzSSL *ssl;

e8f95a682820a599fe41b22977010636be5c2717jim{

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm SSL_CIPHER *c;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz int alg_bits,bits;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz c=SSL_get_current_cipher(ssl);

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm BIO_printf(bio,"Cipher Suite Protocol :%s\n", SSL_CIPHER_get_version(c));

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm BIO_printf(bio,"Cipher Suite Name :%s\n",SSL_CIPHER_get_name(c));

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm bits=SSL_CIPHER_get_bits(c,&alg_bits);

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm BIO_printf(bio,"Cipher Suite Cipher Bits:%d (%d)\n",bits,alg_bits);

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm

36c8049de63c446926139936c3d195330a0539cetrawick return(1);

36c8049de63c446926139936c3d195330a0539cetrawick}

36c8049de63c446926139936c3d195330a0539cetrawick

36c8049de63c446926139936c3d195330a0539cetrawickint ssl_print_cert_info(bio,x509cert)

36c8049de63c446926139936c3d195330a0539cetrawickBIO *bio;

36c8049de63c446926139936c3d195330a0539cetrawickX509 *x509cert;

36c8049de63c446926139936c3d195330a0539cetrawick{

36c8049de63c446926139936c3d195330a0539cetrawick X509_NAME *dn;

e8f95a682820a599fe41b22977010636be5c2717jim char buf[64];

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm BIO_printf(bio,"Certificate version: %d\n",X509_get_version(x509cert)+1);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio,"Valid from: ");

36c8049de63c446926139936c3d195330a0539cetrawick ASN1_UTCTIME_print(bio, X509_get_notBefore(x509cert));

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio,"\n");

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio,"Valid to : ");

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick ASN1_UTCTIME_print(bio, X509_get_notAfter(x509cert));

cb97ae2ff6969c2789b8e03f1bc4187fa73b6bafwrowe BIO_printf(bio,"\n");

36c8049de63c446926139936c3d195330a0539cetrawick

36c8049de63c446926139936c3d195330a0539cetrawick BIO_printf(bio,"Public key is %d bits\n",

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick EVP_PKEY_bits(X509_get_pubkey(x509cert)));

e8f95a682820a599fe41b22977010636be5c2717jim

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm dn=X509_get_issuer_name(x509cert);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick X509_NAME_oneline(dn, buf, BUFSIZ);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio,"The issuer name is %s\n", buf);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick dn=X509_get_subject_name(x509cert);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick X509_NAME_oneline(dn, buf, BUFSIZ);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio,"The subject name is %s\n", buf);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick /* dump the extension list too */

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio,"Extension Count: %d\n",X509_get_ext_count(x509cert));

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick return(1);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick}

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawickvoid ssl_start_connect(struct connection * c)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick{

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO *bio;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick X509 *x509cert;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#ifdef RSAREF

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick STACK *sk;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#else

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick STACK_OF(X509) *sk;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#endif

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick int i, count, hdone = 0;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick char ssl_hostname[80];

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick /* XXX - Verify if it's okay - TBD */

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if (requests < concurrency)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick requests = concurrency;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if (!(started < requests))

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick return;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick c->read = 0;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick c->bread = 0;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick c->keepalive = 0;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick c->cbx = 0;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick c->gotheader = 0;

e8f95a682820a599fe41b22977010636be5c2717jim c->rwrite = 0;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if (c->ctx)

f886987cd0bd4220c14043c4d9be77ec22902e73trawick apr_pool_destroy(c->ctx);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick apr_pool_create(&c->ctx, cntxt);

f886987cd0bd4220c14043c4d9be77ec22902e73trawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if ((c->ssl=SSL_new(ctx)) == NULL)

f886987cd0bd4220c14043c4d9be77ec22902e73trawick {

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm BIO_printf(bio_err,"SSL_new failed\n");

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm exit(1);

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm }

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm

3568de757bac0b47256647504c186d17ca272f85rbb ssl_rand_seed();

72b6f1cf3e616473e1c26464b3193b13c2c09e87brianp

72b6f1cf3e616473e1c26464b3193b13c2c09e87brianp c->start = apr_time_now();

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick memset(ssl_hostname, 0, 80);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick sprintf(ssl_hostname, "%s:%d", hostname, port);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if ((bio = BIO_new_connect(ssl_hostname)) == NULL)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick {

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio_err,"BIO_new_connect failed\n");

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick exit(1);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick }

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick SSL_set_bio(c->ssl,bio,bio);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick SSL_set_connect_state(c->ssl);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm if (verbosity >= 4)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick {

f2e009134c7e279f99dfca5bd421f721bf1f7840jorton BIO_set_callback(bio,ssl_print_cb);

f2e009134c7e279f99dfca5bd421f721bf1f7840jorton BIO_set_callback_arg(bio,(void*)bio_err);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick }

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick while (!hdone)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick {

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm i = SSL_do_handshake(c->ssl);

2e7f1d7da527c09e717251e186deffe55e6fbd0ftrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick switch (SSL_get_error(c->ssl,i))

36c8049de63c446926139936c3d195330a0539cetrawick {

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick case SSL_ERROR_NONE:

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick hdone=1;

f886987cd0bd4220c14043c4d9be77ec22902e73trawick break;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick case SSL_ERROR_SSL:

cb97ae2ff6969c2789b8e03f1bc4187fa73b6bafwrowe case SSL_ERROR_SYSCALL:

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio_err,"SSL connection failed\n");

36c8049de63c446926139936c3d195330a0539cetrawick err_conn++;

36c8049de63c446926139936c3d195330a0539cetrawick c->state = STATE_UNCONNECTED;

36c8049de63c446926139936c3d195330a0539cetrawick if (bad++ > 10) {

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick SSL_free (c->ssl);

e8f95a682820a599fe41b22977010636be5c2717jim BIO_printf(bio_err,"\nTest aborted after 10 failures\n\n");

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm exit (1);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick }

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick break;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick case SSL_ERROR_WANT_READ:

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick case SSL_ERROR_WANT_WRITE:

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick case SSL_ERROR_WANT_CONNECT:

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio_err, "Waiting .. sleep(1)\n");

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick apr_sleep(apr_time_from_sec(1));

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick c->state = STATE_CONNECTING;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick c->rwrite = 0;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick break;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick case SSL_ERROR_ZERO_RETURN:

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio_err,"socket closed\n");

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick break;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick }

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick }

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if (verbosity >= 2)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick {

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio_err, "\n");

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick sk = SSL_get_peer_cert_chain(c->ssl);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#ifdef RSAREF

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if ((count = sk_num(sk)) > 0)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#else

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if ((count = sk_X509_num(sk)) > 0)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#endif

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick {

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick for (i=1; i<count; i++)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick {

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#ifdef RSAREF

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick x509cert = (X509 *)sk_value(sk,i);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#else

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick x509cert = (X509 *)sk_X509_value(sk,i);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#endif

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick ssl_print_cert_info(bio_out,x509cert);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick X509_free(x509cert);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick }

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick }

e8f95a682820a599fe41b22977010636be5c2717jim

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick x509cert = SSL_get_peer_certificate(c->ssl);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick if (x509cert == NULL)

f886987cd0bd4220c14043c4d9be77ec22902e73trawick BIO_printf(bio_out, "Anon DH\n");

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick else

f886987cd0bd4220c14043c4d9be77ec22902e73trawick {

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick BIO_printf(bio_out, "Peer certificate\n");

f886987cd0bd4220c14043c4d9be77ec22902e73trawick ssl_print_cert_info(bio_out,x509cert);

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm X509_free(x509cert);

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm }

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm

64c351fd973428b5bb4c28e983fa86875ea4e60fdougm ssl_print_connection_info(bio_err,c->ssl);

3568de757bac0b47256647504c186d17ca272f85rbb SSL_SESSION_print(bio_err,SSL_get_session(c->ssl));

72b6f1cf3e616473e1c26464b3193b13c2c09e87brianp }

72b6f1cf3e616473e1c26464b3193b13c2c09e87brianp

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick /* connected first time */

e8f95a682820a599fe41b22977010636be5c2717jim started++;

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick write_request(c);

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick}

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#endif /* USE_SSL */

e8f95a682820a599fe41b22977010636be5c2717jim

44d2e75323651320b480d8bc2f098448a08de4fcwrowestatic void write_request(struct connection * c)

44d2e75323651320b480d8bc2f098448a08de4fcwrowe{

44d2e75323651320b480d8bc2f098448a08de4fcwrowe do {

44d2e75323651320b480d8bc2f098448a08de4fcwrowe apr_time_t tnow = apr_time_now();

44d2e75323651320b480d8bc2f098448a08de4fcwrowe apr_size_t l = c->rwrite;

44d2e75323651320b480d8bc2f098448a08de4fcwrowe apr_status_t e;

44d2e75323651320b480d8bc2f098448a08de4fcwrowe

44d2e75323651320b480d8bc2f098448a08de4fcwrowe /*

2e7f1d7da527c09e717251e186deffe55e6fbd0ftrawick if (c->rwrite == 0) {

2e7f1d7da527c09e717251e186deffe55e6fbd0ftrawick#ifdef USE_SSL

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz if (ssl != 1)

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick#endif

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz apr_socket_timeout_set(c->aprsock, 0);

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe c->connect = tnow;

3568de757bac0b47256647504c186d17ca272f85rbb c->rwrite = reqlen;

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe c->rwrote = 0;

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe if (posting)

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe c->rwrite += postlen;

f886987cd0bd4220c14043c4d9be77ec22902e73trawick }

f886987cd0bd4220c14043c4d9be77ec22902e73trawick else if (tnow > c->connect + aprtimeout) {

f886987cd0bd4220c14043c4d9be77ec22902e73trawick printf("Send request timed out!\n");

f886987cd0bd4220c14043c4d9be77ec22902e73trawick close_connection(c);

f886987cd0bd4220c14043c4d9be77ec22902e73trawick return;

f886987cd0bd4220c14043c4d9be77ec22902e73trawick }

f886987cd0bd4220c14043c4d9be77ec22902e73trawick

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe#ifdef USE_SSL

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe if (ssl == 1) {

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe apr_size_t e_ssl;

1ec8bd0373f11c07688ec9afbbf778cf78a0bc52wrowe e_ssl = SSL_write(c->ssl,request + c->rwrote, l);

3568de757bac0b47256647504c186d17ca272f85rbb if (e_ssl != l)

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz {

8bfe865d8d61be4ba4a89e45427a3c4211ebabdctrawick printf("SSL write failed - closing connection\n");

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz close_connection (c);

3568de757bac0b47256647504c186d17ca272f85rbb return;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz }

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz l = e_ssl;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz }

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz else

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz#endif

3568de757bac0b47256647504c186d17ca272f85rbb e = apr_send(c->aprsock, request + c->rwrote, &l);

3568de757bac0b47256647504c186d17ca272f85rbb

98fb535f829e2a95aabd82420931f476661fa8e3jorton /*

e8f95a682820a599fe41b22977010636be5c2717jim if (l == c->rwrite)

98fb535f829e2a95aabd82420931f476661fa8e3jorton break;

98fb535f829e2a95aabd82420931f476661fa8e3jorton

e8f95a682820a599fe41b22977010636be5c2717jim#ifdef USE_SSL

98fb535f829e2a95aabd82420931f476661fa8e3jorton if (ssl != 1)

98fb535f829e2a95aabd82420931f476661fa8e3jorton if (e != APR_SUCCESS) {

98fb535f829e2a95aabd82420931f476661fa8e3jorton /*

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz if (!APR_STATUS_IS_EAGAIN(e)) {

3568de757bac0b47256647504c186d17ca272f85rbb epipe++;

3568de757bac0b47256647504c186d17ca272f85rbb printf("Send request failed!\n");

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding close_connection(c);

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding }

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding return;

85c5af648e9f414bd4f157490766d2fd5515a9f5rpluem }

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe#endif

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe c->rwrote += l;

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe c->rwrite -= l;

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe } while (1);

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe totalposted += c->rwrite;

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe c->state = STATE_READ;

85c5af648e9f414bd4f157490766d2fd5515a9f5rpluem c->endwrite = apr_time_now();

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe#ifdef USE_SSL

3568de757bac0b47256647504c186d17ca272f85rbb if (ssl != 1)

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz#endif

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz {

3568de757bac0b47256647504c186d17ca272f85rbb apr_pollfd_t new_pollfd;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz new_pollfd.desc_type = APR_POLL_SOCKET;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz new_pollfd.reqevents = APR_POLLIN;

3568de757bac0b47256647504c186d17ca272f85rbb new_pollfd.desc.s = c->aprsock;

3568de757bac0b47256647504c186d17ca272f85rbb new_pollfd.client_data = c;

3568de757bac0b47256647504c186d17ca272f85rbb apr_pollset_add(readbits, &new_pollfd);

3568de757bac0b47256647504c186d17ca272f85rbb }

3568de757bac0b47256647504c186d17ca272f85rbb}

3568de757bac0b47256647504c186d17ca272f85rbb

3568de757bac0b47256647504c186d17ca272f85rbb

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawick

cd8f8c995d415473f3bfb0b329b2450f2a722c3atrawickstatic int compradre(struct data * a, struct data * b)

9d0665da83d1e22c0ea0e5f6f940f70f75bf5237ianh{

3568de757bac0b47256647504c186d17ca272f85rbb if ((a->ctime) < (b->ctime))

3568de757bac0b47256647504c186d17ca272f85rbb return -1;

7cd5419264796cfeaf8215383cf0f89130a81fectrawick if ((a->ctime) > (b->ctime))

7cd5419264796cfeaf8215383cf0f89130a81fectrawick return +1;

7cd5419264796cfeaf8215383cf0f89130a81fectrawick return 0;

7cd5419264796cfeaf8215383cf0f89130a81fectrawick}

7cd5419264796cfeaf8215383cf0f89130a81fectrawick

7cd5419264796cfeaf8215383cf0f89130a81fectrawickstatic int comprando(struct data * a, struct data * b)

7cd5419264796cfeaf8215383cf0f89130a81fectrawick{

73e8b26287de5c06fa470d36162e103dbac9c7e5wrowe if ((a->time) < (b->time))

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding return -1;

b980ad7fdc218b4855cde9f75a747527f50c554dwrowe if ((a->time) > (b->time))

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe return +1;

3568de757bac0b47256647504c186d17ca272f85rbb return 0;

7cd5419264796cfeaf8215383cf0f89130a81fectrawick}

7cd5419264796cfeaf8215383cf0f89130a81fectrawick

7cd5419264796cfeaf8215383cf0f89130a81fectrawickstatic int compri(struct data * a, struct data * b)

ca53a74f4012a45cbad48e940eddf27d866981f9dougm{

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding apr_interval_time_t p = a->time - a->ctime;

3d96ee83babeec32482c9082c9426340cee8c44dwrowe apr_interval_time_t q = b->time - b->ctime;

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding if (p < q)

302dc1f7b3feee23a91ad8f3cf3cb2edd95a557bmanoj return -1;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz if (p > q)

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz return +1;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz return 0;

28c170ac8e99644de58cad454c6e0f9b4b359be6jerenkrantz}

0cb6873985efbf0cc9644114925df6baa4b32d5awrowe

3568de757bac0b47256647504c186d17ca272f85rbbstatic int compwait(struct data * a, struct data * b)

0f081398cf0eef8cc7c66a535d450110a92dc8aefielding{

3568de757bac0b47256647504c186d17ca272f85rbb if ((a->waittime) < (b->waittime))

return -1;

if ((a->waittime) > (b->waittime))

return 1;

return 0;

}

static void output_results(void)

{

apr_interval_time_t timetakenusec;

float timetaken;

endtime = apr_time_now();

timetakenusec = endtime - start;

timetaken = ((float)apr_time_sec(timetakenusec)) +

((float)apr_time_usec(timetakenusec)) / 1000000.0F;

printf("\n\n");

printf("Server Software: %s\n", servername);

printf("Server Hostname: %s\n", hostname);

printf("Server Port: %hd\n", port);

printf("\n");

printf("Document Path: %s\n", path);

printf("Document Length: %" APR_SIZE_T_FMT " bytes\n", doclen);

printf("\n");

printf("Concurrency Level: %d\n", concurrency);

printf("Time taken for tests: %ld.%03ld seconds\n",

(long) apr_time_sec(timetakenusec),

(long) apr_time_usec(timetakenusec));

printf("Complete requests: %ld\n", done);

printf("Failed requests: %ld\n", bad);

if (bad)

printf(" (Connect: %d, Length: %d, Exceptions: %d)\n",

err_conn, err_length, err_except);

printf("Write errors: %ld\n", epipe);

if (err_response)

printf("Non-2xx responses: %d\n", err_response);

if (keepalive)

printf("Keep-Alive requests: %ld\n", doneka);

printf("Total transferred: %ld bytes\n", totalread);

if (posting > 0)

printf("Total POSTed: %ld\n", totalposted);

printf("HTML transferred: %ld bytes\n", totalbread);

/* avoid divide by zero */

if (timetaken) {

printf("Requests per second: %.2f [#/sec] (mean)\n",

(float) (done / timetaken));

printf("Time per request: %.3f [ms] (mean)\n",

(float) (1000 * concurrency * timetaken / done));

printf("Time per request: %.3f [ms] (mean, across all concurrent requests)\n",

(float) (1000 * timetaken / done));

printf("Transfer rate: %.2f [Kbytes/sec] received\n",

(float) (totalread / 1024 / timetaken));

if (posting > 0) {

printf(" %.2f kb/s sent\n",

(float) (totalposted / timetaken / 1024));

printf(" %.2f kb/s total\n",

(float) ((totalread + totalposted) / timetaken / 1024));

}

}

if (requests) {

/* work out connection times */

long i;

apr_time_t totalcon = 0, total = 0, totald = 0, totalwait = 0;

apr_interval_time_t mincon = AB_MAX, mintot = AB_MAX, mind = AB_MAX,

minwait = AB_MAX;

apr_interval_time_t maxcon = 0, maxtot = 0, maxd = 0, maxwait = 0;

apr_interval_time_t meancon = 0, meantot = 0, meand = 0, meanwait = 0;

double sdtot = 0, sdcon = 0, sdd = 0, sdwait = 0;

for (i = 0; i < requests; i++) {

struct data s = stats[i];

mincon = ap_min(mincon, s.ctime);

mintot = ap_min(mintot, s.time);

mind = ap_min(mind, s.time - s.ctime);

minwait = ap_min(minwait, s.waittime);

maxcon = ap_max(maxcon, s.ctime);

maxtot = ap_max(maxtot, s.time);

maxd = ap_max(maxd, s.time - s.ctime);

maxwait = ap_max(maxwait, s.waittime);

totalcon += s.ctime;

total += s.time;

totald += s.time - s.ctime;

totalwait += s.waittime;

}

totalcon /= requests;

total /= requests;

totald /= requests;

totalwait /= requests;

for (i = 0; i < requests; i++) {

struct data s = stats[i];

double a;

a = ((double)s.time - total);

sdtot += a * a;

a = ((double)s.ctime - totalcon);

sdcon += a * a;

a = ((double)s.time - (double)s.ctime - totald);

sdd += a * a;

a = ((double)s.waittime - totalwait);

sdwait += a * a;

}

sdtot = (requests > 1) ? sqrt(sdtot / (requests - 1)) : 0;

sdcon = (requests > 1) ? sqrt(sdcon / (requests - 1)) : 0;

sdd = (requests > 1) ? sqrt(sdd / (requests - 1)) : 0;

sdwait = (requests > 1) ? sqrt(sdwait / (requests - 1)) : 0;

if (gnuplot) {

FILE *out = fopen(gnuplot, "w");

long i;

apr_time_t sttime;

char tmstring[1024];/* XXXX */

if (!out) {

perror("Cannot open gnuplot output file");

exit(1);

}

fprintf(out, "starttime\tseconds\tctime\tdtime\tttime\twait\n");

for (i = 0; i < requests; i++) {

apr_time_t diff = stats[i].time - stats[i].ctime;

sttime = stats[i].starttime;

(void) apr_ctime(tmstring, sttime);

fprintf(out, "%s\t%" APR_TIME_T_FMT "\t%" APR_TIME_T_FMT "\t%" APR_TIME_T_FMT "\t%" APR_TIME_T_FMT "\t%" APR_TIME_T_FMT "\n",

tmstring,

sttime,

stats[i].ctime,

diff,

stats[i].time,

stats[i].waittime);

}

fclose(out);

}

/*

qsort(stats, requests, sizeof(struct data),

(int (*) (const void *, const void *)) compradre);

if ((requests > 1) && (requests % 2))

meancon = (stats[requests / 2].ctime + stats[requests / 2 + 1].ctime) / 2;

else

meancon = stats[requests / 2].ctime;

qsort(stats, requests, sizeof(struct data),

(int (*) (const void *, const void *)) compri);

if ((requests > 1) && (requests % 2))

meand = (stats[requests / 2].time + stats[requests / 2 + 1].time \

-stats[requests / 2].ctime - stats[requests / 2 + 1].ctime) / 2;

else

meand = stats[requests / 2].time - stats[requests / 2].ctime;

qsort(stats, requests, sizeof(struct data),

(int (*) (const void *, const void *)) compwait);

if ((requests > 1) && (requests % 2))

meanwait = (stats[requests / 2].waittime + stats[requests / 2 + 1].waittime) / 2;

else

meanwait = stats[requests / 2].waittime;

qsort(stats, requests, sizeof(struct data),

(int (*) (const void *, const void *)) comprando);

if ((requests > 1) && (requests % 2))

meantot = (stats[requests / 2].time + stats[requests / 2 + 1].time) / 2;

else

meantot = stats[requests / 2].time;

printf("\nConnection Times (ms)\n");

if (confidence) {

#define CONF_FMT_STRING "%5" APR_TIME_T_FMT " %4d %5.1f %6" APR_TIME_T_FMT " %7" APR_TIME_T_FMT "\n"

printf(" min mean[+/-sd] median max\n");

printf("Connect: " CONF_FMT_STRING,

mincon, (int) (totalcon + 0.5), sdcon, meancon, maxcon);

printf("Processing: " CONF_FMT_STRING,

mind, (int) (totald + 0.5), sdd, meand, maxd);

printf("Waiting: " CONF_FMT_STRING,

minwait, (int) (totalwait + 0.5), sdwait, meanwait, maxwait);

printf("Total: " CONF_FMT_STRING,

mintot, (int) (total + 0.5), sdtot, meantot, maxtot);

#undef CONF_FMT_STRING

#define SANE(what,avg,mean,sd) \

{ \

double d = (double)avg - mean; \

if (d < 0) d = -d; \

if (d > 2 * sd ) \

printf("ERROR: The median and mean for " what " are more than twice the standard\n" \

" deviation apart. These results are NOT reliable.\n"); \

else if (d > sd ) \

printf("WARNING: The median and mean for " what " are not within a normal deviation\n" \

" These results are probably not that reliable.\n"); \

}

SANE("the initial connection time", totalcon, meancon, sdcon);

SANE("the processing time", totald, meand, sdd);

SANE("the waiting time", totalwait, meanwait, sdwait);

SANE("the total time", total, meantot, sdtot);

}

else {

printf(" min avg max\n");

#define CONF_FMT_STRING "%5" APR_TIME_T_FMT " %5" APR_TIME_T_FMT "%5" APR_TIME_T_FMT "\n"

printf("Connect: " CONF_FMT_STRING,

mincon, totalcon / requests, maxcon);

printf("Processing: " CONF_FMT_STRING, mintot - mincon,

(total / requests) - (totalcon / requests),

maxtot - maxcon);

printf("Total: " CONF_FMT_STRING,

mintot, total / requests, maxtot);

#undef CONF_FMT_STRING

}

/* Sorted on total connect times */

if (percentile && (requests > 1)) {

printf("\nPercentage of the requests served within a certain time (ms)\n");

for (i = 0; i < sizeof(percs) / sizeof(int); i++)

if (percs[i] <= 0)

printf(" 0%% <0> (never)\n");

else if (percs[i] >= 100)

printf(" 100%% %5" APR_TIME_T_FMT " (longest request)\n",

stats[requests - 1].time);

else

printf(" %d%% %5" APR_TIME_T_FMT "\n", percs[i],

stats[(int) (requests * percs[i] / 100)].time);

}

if (csvperc) {

FILE *out = fopen(csvperc, "w");

int i;

if (!out) {

perror("Cannot open CSV output file");

exit(1);

}

fprintf(out, "" "Percentage served" "," "Time in ms" "\n");

for (i = 0; i < 100; i++) {

apr_time_t t;

if (i == 0)

t = stats[0].time;

else if (i == 100)

t = stats[requests - 1].time;

else

t = stats[(int) (0.5 + requests * i / 100.0)].time;

fprintf(out, "%d,%e\n", i, (double)t);

}

fclose(out);

}

}

}

static void output_html_results(void)

{

long timetaken;

endtime = apr_time_now();

timetaken = (long)((endtime - start) / 1000);

printf("\n\n<table %s>\n", tablestring);

printf("<tr %s><th colspan=2 %s>Server Software:</th>"

"<td colspan=2 %s>%s</td></tr>\n",

trstring, tdstring, tdstring, servername);

printf("<tr %s><th colspan=2 %s>Server Hostname:</th>"

"<td colspan=2 %s>%s</td></tr>\n",

trstring, tdstring, tdstring, hostname);

printf("<tr %s><th colspan=2 %s>Server Port:</th>"

"<td colspan=2 %s>%hd</td></tr>\n",

trstring, tdstring, tdstring, port);

printf("<tr %s><th colspan=2 %s>Document Path:</th>"

"<td colspan=2 %s>%s</td></tr>\n",

trstring, tdstring, tdstring, path);

printf("<tr %s><th colspan=2 %s>Document Length:</th>"

"<td colspan=2 %s>%" APR_SIZE_T_FMT " bytes</td></tr>\n",

trstring, tdstring, tdstring, doclen);

printf("<tr %s><th colspan=2 %s>Concurrency Level:</th>"

"<td colspan=2 %s>%d</td></tr>\n",

trstring, tdstring, tdstring, concurrency);

printf("<tr %s><th colspan=2 %s>Time taken for tests:</th>"

"<td colspan=2 %s>%" APR_INT64_T_FMT ".%03ld seconds</td></tr>\n",

trstring, tdstring, tdstring, apr_time_sec(timetaken),

(long)apr_time_usec(timetaken));

printf("<tr %s><th colspan=2 %s>Complete requests:</th>"

"<td colspan=2 %s>%ld</td></tr>\n",

trstring, tdstring, tdstring, done);

printf("<tr %s><th colspan=2 %s>Failed requests:</th>"

"<td colspan=2 %s>%ld</td></tr>\n",

trstring, tdstring, tdstring, bad);

if (bad)

printf("<tr %s><td colspan=4 %s > (Connect: %d, Length: %d, Exceptions: %d)</td></tr>\n",

trstring, tdstring, err_conn, err_length, err_except);

if (err_response)

printf("<tr %s><th colspan=2 %s>Non-2xx responses:</th>"

"<td colspan=2 %s>%d</td></tr>\n",

trstring, tdstring, tdstring, err_response);

if (keepalive)

printf("<tr %s><th colspan=2 %s>Keep-Alive requests:</th>"

"<td colspan=2 %s>%ld</td></tr>\n",

trstring, tdstring, tdstring, doneka);

printf("<tr %s><th colspan=2 %s>Total transferred:</th>"

"<td colspan=2 %s>%ld bytes</td></tr>\n",

trstring, tdstring, tdstring, totalread);

if (posting > 0)

printf("<tr %s><th colspan=2 %s>Total POSTed:</th>"

"<td colspan=2 %s>%ld</td></tr>\n",

trstring, tdstring, tdstring, totalposted);

printf("<tr %s><th colspan=2 %s>HTML transferred:</th>"

"<td colspan=2 %s>%ld bytes</td></tr>\n",

trstring, tdstring, tdstring, totalbread);

/* avoid divide by zero */

if (timetaken) {

printf("<tr %s><th colspan=2 %s>Requests per second:</th>"

"<td colspan=2 %s>%.2f</td></tr>\n",

trstring, tdstring, tdstring, 1000 * (float) (done) / timetaken);

printf("<tr %s><th colspan=2 %s>Transfer rate:</th>"

"<td colspan=2 %s>%.2f kb/s received</td></tr>\n",

trstring, tdstring, tdstring, (float) (totalread) / timetaken);

if (posting > 0) {

printf("<tr %s><td colspan=2 %s>&nbsp;</td>"

"<td colspan=2 %s>%.2f kb/s sent</td></tr>\n",

trstring, tdstring, tdstring,

(float) (totalposted) / timetaken);

printf("<tr %s><td colspan=2 %s>&nbsp;</td>"

"<td colspan=2 %s>%.2f kb/s total</td></tr>\n",

trstring, tdstring, tdstring,

(float) (totalread + totalposted) / timetaken);

}

} {

/* work out connection times */

long i;

apr_interval_time_t totalcon = 0, total = 0;

apr_interval_time_t mincon = AB_MAX, mintot = AB_MAX;

apr_interval_time_t maxcon = 0, maxtot = 0;

for (i = 0; i < requests; i++) {

struct data s = stats[i];

mincon = ap_min(mincon, s.ctime);

mintot = ap_min(mintot, s.time);

maxcon = ap_max(maxcon, s.ctime);

maxtot = ap_max(maxtot, s.time);

totalcon += s.ctime;

total += s.time;

}

if (requests > 0) { /* avoid division by zero (if 0 requests) */

printf("<tr %s><th %s colspan=4>Connnection Times (ms)</th></tr>\n",

trstring, tdstring);

printf("<tr %s><th %s>&nbsp;</th> <th %s>min</th> <th %s>avg</th> <th %s>max</th></tr>\n",

trstring, tdstring, tdstring, tdstring, tdstring);

printf("<tr %s><th %s>Connect:</th>"

"<td %s>%5" APR_TIME_T_FMT "</td>"

"<td %s>%5" APR_TIME_T_FMT "</td>"

"<td %s>%5" APR_TIME_T_FMT "</td></tr>\n",

trstring, tdstring, tdstring, mincon, tdstring, totalcon / requests, tdstring, maxcon);

printf("<tr %s><th %s>Processing:</th>"

"<td %s>%5" APR_TIME_T_FMT "</td>"

"<td %s>%5" APR_TIME_T_FMT "</td>"

"<td %s>%5" APR_TIME_T_FMT "</td></tr>\n",

trstring, tdstring, tdstring, mintot - mincon, tdstring,

(total / requests) - (totalcon / requests), tdstring, maxtot - maxcon);

printf("<tr %s><th %s>Total:</th>"

"<td %s>%5" APR_TIME_T_FMT "</td>"

"<td %s>%5" APR_TIME_T_FMT "</td>"

"<td %s>%5" APR_TIME_T_FMT "</td></tr>\n",

trstring, tdstring, tdstring, mintot, tdstring, total / requests, tdstring, maxtot);

}

printf("</table>\n");

}

}

static void start_connect(struct connection * c)

{

apr_status_t rv;

#ifdef USE_SSL

if (ssl == 1) {

ssl_start_connect(c);

return;

}

#endif

if (!(started < requests))

return;

c->read = 0;

c->bread = 0;

c->keepalive = 0;

c->cbx = 0;

c->gotheader = 0;

c->rwrite = 0;

if (c->ctx)

apr_pool_destroy(c->ctx);

apr_pool_create(&c->ctx, cntxt);

if ((rv = apr_socket_create(&c->aprsock, destsa->family,

SOCK_STREAM, c->ctx)) != APR_SUCCESS) {

apr_err("socket", rv);

}

if ((rv = apr_socket_opt_set(c->aprsock, APR_SO_NONBLOCK, 1))

!= APR_SUCCESS) {

apr_err("socket nonblock", rv);

}

c->start = apr_time_now();

if ((rv = apr_connect(c->aprsock, destsa)) != APR_SUCCESS) {

if (APR_STATUS_IS_EINPROGRESS(rv)) {

apr_pollfd_t new_pollfd;

c->state = STATE_CONNECTING;

c->rwrite = 0;

new_pollfd.desc_type = APR_POLL_SOCKET;

new_pollfd.reqevents = APR_POLLIN;

new_pollfd.desc.s = c->aprsock;

new_pollfd.client_data = c;

apr_pollset_add(readbits, &new_pollfd);

return;

}

else {

apr_pollfd_t remove_pollfd;

remove_pollfd.desc_type = APR_POLL_SOCKET;

remove_pollfd.desc.s = c->aprsock;

apr_pollset_remove(readbits, &remove_pollfd);

apr_socket_close(c->aprsock);

err_conn++;

if (bad++ > 10) {

fprintf(stderr,

"\nTest aborted after 10 failures\n\n");

apr_err("apr_connect()", rv);

}

c->state = STATE_UNCONNECTED;

start_connect(c);

return;

}

}

/* connected first time */

started++;

write_request(c);

}

static void close_connection(struct connection * c)

{

if (c->read == 0 && c->keepalive) {

/*

if (good)

good--; /* connection never happened */

}

else {

if (good == 1) {

/* first time here */

doclen = c->bread;

}

else if (c->bread != doclen) {

bad++;

err_length++;

}

/* save out time */

if (done < requests) {

struct data s;

if ((done) && heartbeatres && !(done % heartbeatres)) {

fprintf(stderr, "Completed %ld requests\n", done);

fflush(stderr);

}

c->done = apr_time_now();

s.read = c->read;

s.starttime = c->start;

s.ctime = (c->connect - c->start) / 1000;

s.time = (c->done - c->start) / 1000;

s.waittime = (c->beginread - c->endwrite) / 1000;

stats[done++] = s;

}

}