October 2011 - tor-commits - lists.torproject.org

[flashproxy/master] Use scrolling="no" not scrolling="0".
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit 184fd8bc464d88aa431ecc3a5faf7aaad67d11d9 Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 13:44:34 2011 -0700 Use scrolling="no" not scrolling="0". scrolling="0" doesn't work on IE, and the W3C says it's (yes|no|auto). --- README | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/README b/README index 82e881c..7f7189b 100644 --- a/README +++ b/README @@ -152,7 +152,7 @@ wait a few minutes. It can take a while to download relay descriptors. Paste in this HTML where you want the badge to appear: -<iframe src="//crypto.stanford.edu/flashproxy/embed.html" width="70px" height="23px" frameBorder="0" scrolling="0"></iframe> +<iframe src="//crypto.stanford.edu/flashproxy/embed.html" width="70px" height="23px" frameBorder="0" scrolling="no"></iframe> == For developers

1 0

[flashproxy/master] const -> var in embed.html.
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit a82c8471ed94456b392d4eab88eaaa2823968446 Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 13:34:17 2011 -0700 const -> var in embed.html. const doesn't work in IE. --- embed.html | 16 ++++++++-------- 1 files changed, 8 insertions(+), 8 deletions(-) diff --git a/embed.html b/embed.html index fc1fe6d..9b6b152 100644 --- a/embed.html +++ b/embed.html @@ -22,7 +22,7 @@ function flashproxy_should_disable() ua = window.navigator.userAgent; if (ua != null) { - const UA_LIST = [ + var UA_LIST = [ /\bmobile\b/i, /\bandroid\b/i, /\bopera mobi\b/i, @@ -49,8 +49,8 @@ function flashproxy_should_disable() */ function flashproxy_make_container(child) { - const BADGE_ID = "flashproxy-badge"; - const FLASHPROXY_INFO_URL = "https://crypto.stanford.edu/flashproxy/"; + var BADGE_ID = "flashproxy-badge"; + var FLASHPROXY_INFO_URL = "https://crypto.stanford.edu/flashproxy/"; var container; var a; @@ -74,10 +74,10 @@ function flashproxy_make_container(child) */ function flashproxy_make_badge() { - const WIDTH = 70; - const HEIGHT = 23; - const FLASHVARS = ""; - const SWFCAT_URL = "https://crypto.stanford.edu/flashproxy/swfcat.swf"; + var WIDTH = 70; + var HEIGHT = 23; + var FLASHVARS = ""; + var SWFCAT_URL = "https://crypto.stanford.edu/flashproxy/swfcat.swf"; var object; var param; @@ -111,7 +111,7 @@ function flashproxy_make_badge() */ function flashproxy_make_dummy_badge() { - const BADGE_IMAGE_URL = "https://crypto.stanford.edu/flashproxy/badge.png"; + var BADGE_IMAGE_URL = "https://crypto.stanford.edu/flashproxy/badge.png"; var img;

1 0

[flashproxy/master] Add max_clients parameter.
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit a7b64ff1dfcc9b2e8797e1753486e080d46f6f7c Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 00:52:21 2011 -0700 Add max_clients parameter. This allows controlling what was the MAX_NUM_PROXY_PAIRS constant. --- swfcat.as | 40 +++++++++++++++++++++++++++++++++++++--- 1 files changed, 37 insertions(+), 3 deletions(-) diff --git a/swfcat.as b/swfcat.as index 9fcf0db..938def9 100644 --- a/swfcat.as +++ b/swfcat.as @@ -17,6 +17,10 @@ * The address of the facilitator to use. By default it is * DEFAULT_FACILITATOR_ADDR. Both <HOST> and <PORT> must be present. * + * max_clients=<NUM> + * How many clients to serve concurrently. The default is + * DEFAULT_MAX_NUM_PROXY_PAIRS. + * * client=1 * If set (to any value), run in client RTMFP mode. In this mode, rather than * connecting to a facilitator and attempting to serve clients, swfcat starts an @@ -63,7 +67,7 @@ package port: 9002 }; - private const MAX_NUM_PROXY_PAIRS:uint = 100; + private const DEFAULT_MAX_NUM_PROXY_PAIRS:uint = 100; // Milliseconds. private const FACILITATOR_POLL_INTERVAL:int = 10000; @@ -79,11 +83,12 @@ package /* UI shown when debug is off. */ private var badge:Badge; - /* Proxy pairs currently connected (up to MAX_NUM_PROXY_PAIRS). */ + /* Proxy pairs currently connected (up to max_num_proxy_pairs). */ private var proxy_pairs:Array; public var debug:Boolean; private var fac_addr:Object; + private var max_num_proxy_pairs:uint; private var local_addr:Object; public var rate_limit:RateLimit; @@ -117,6 +122,8 @@ package private function loaderinfo_complete(e:Event):void { + var tmp:Object; + debug = this.loaderInfo.parameters["debug"]; if (debug || this.loaderInfo.parameters["client"]) { @@ -139,6 +146,13 @@ package return; } + tmp = get_param_number("max_clients", DEFAULT_MAX_NUM_PROXY_PAIRS); + if (tmp == null || tmp < 0) { + puts("Error: max_clients must be a nonnegative integer."); + return; + } + max_num_proxy_pairs = uint(tmp); + local_addr = get_param_addr("local", DEFAULT_LOCAL_TOR_CLIENT_ADDR); if (!local_addr) { puts("Error: Local spec must be in the form \"host:port\"."); @@ -164,13 +178,33 @@ package return default_addr; } + /* Get a number from the given movie parameter, or the given default. + Returns null on error. First check for a null return, and then call + uint or whatever on the return value if no error. */ + private function get_param_number(param:String, default_val:Number):Object + { + var spec:String; + var val:Number; + + spec = this.loaderInfo.parameters[param]; + if (spec) { + val = Number(spec); + if (isNaN(val)) + return null; + else + return val; + } else { + return default_val; + } + } + /* The main logic begins here, after start-up issues are taken care of. */ private function proxy_main():void { var fac_url:String; var loader:URLLoader; - if (proxy_pairs.length >= MAX_NUM_PROXY_PAIRS) { + if (proxy_pairs.length >= max_num_proxy_pairs) { setTimeout(proxy_main, FACILITATOR_POLL_INTERVAL); return; }

1 0

[flashproxy/master] Increase the connector read size from 1024 to 65536.
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit f16adf275c0bff23174a3e3cac47bef130259080 Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 04:37:49 2011 -0700 Increase the connector read size from 1024 to 65536. Since Flash doesn't provide any way of knowing if sent data was sent successfully or not, it pushes everything it can't send immediately on a buffer of unbounded size. If the receiver can't read the data fast enough, Flash will consume more and more memory until it crashes. I don't think this will matter much for Tor or even plain Internet connections, but it's crashing my high-speed localhost tests. --- connector.py | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/connector.py b/connector.py index d763303..624b776 100755 --- a/connector.py +++ b/connector.py @@ -308,7 +308,7 @@ def register(): def proxy_chunk(fd_r, fd_w, label): try: - data = fd_r.recv(1024) + data = fd_r.recv(65536) except socket.error, e: # Can be "Connection reset by peer". log(u"Socket error from %s: %s" % (label, repr(str(e)))) fd_w.close()

1 0

[flashproxy/master] Remove obsolete 00 experiment.
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit aa8e063e35b10054917625c31d0ee6a42b0fdcca Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 13:13:22 2011 -0700 Remove obsolete 00 experiment. Replaced by experiments/throughput/throughput.sh. --- experiments/00 | 78 -------------------------------------------------------- 1 files changed, 0 insertions(+), 78 deletions(-) diff --git a/experiments/00 b/experiments/00 deleted file mode 100755 index e7994df..0000000 --- a/experiments/00 +++ /dev/null @@ -1,78 +0,0 @@ -#!/bin/bash - -# Get arguments -if [ $1 ]; then - NUM_CLIENTS=$1 -else - NUM_CLIENTS=1 -fi - -# Go to flashproxy repo root dir -cd .. - -# Create 1GB dump file -echo "creating dump file..." -rm dump -dd if=/dev/null of=dump bs=1G seek=1 - -# Start http server -echo "starting http server..." -thttpd -p 1080 - -# Start crossdomain policy server -echo "starting cross domain policy server..." -sudo ./crossdomaind.py & - -# Start the facilitator -echo "starting facilitator..." -./facilitator.py 4701 -r 127.0.0.1:1080 - -# Start socat adapters -echo "starting socat adapters..." -i=1 -until [ $i -gt $NUM_CLIENTS ]; do - let local_port=2000+i - let remote_port=9000+i - socat TCP-LISTEN:${remote_port},reuseaddr,fork TCP-LISTEN:${local_port},reuseaddr & - let i=i+1 -done - -sleep 1 - -# Register with facilitator -echo "registering with facilitator..." -i=1 -until [ $i -gt $NUM_CLIENTS ]; do - let local_port=9000+i - echo $'POST / HTTP/1.0\r\n\r\nclient=127.0.0.1:'${local_port} | ncat localhost 4701 --send-only - let i=i+1 -done - -# Start the flash proxy, server side -echo "starting flash proxy server side..." -firefox --remote "openURL(http://localhost:1080/swfcat.swf?facilitator=127.0.0.1:4701)" - -let query_fac_time=NUM_CLIENTS+2 -sleep ${query_fac_time} - -# wget the dump file -echo "getting the dump file..." -i=2 -until [ $i -gt $NUM_CLIENTS ]; do - let local_port=2000+i - xterm -e "/bin/bash -c 'wget -t1 http://localhost:${local_port}/dump -O - > /dev/null; exec /bin/bash -i'" & - let i=i+1 -done - -# Use this one for delaying the termination of experiment below -wget -t1 http://localhost:2001/dump -O - > /dev/null - -echo "Press enter to continue." -read - -# Slaughter the processes -ps -ef | sed -n '/thttpd/{/grep/!p;}' | awk '{print$2}' | sudo xargs -i kill {} -ps -ef | sed -n '/crossdomaind.py/{/grep/!p;}' | awk '{print$2}' | sudo xargs -i kill {} -ps -ef | sed -n '/facilitator.py/{/grep/!p;}' | awk '{print$2}' | sudo xargs -i kill {} -ps -ef | sed -n '/socat/{/grep/!p;}' | awk '{print$2}' | sudo xargs -i kill {} -

1 0

[flashproxy/master] Add a facilitator_poll_interval parameter.
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit f600f49bf58f8249de6ff57a53a94a888677fe66 Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 01:24:43 2011 -0700 Add a facilitator_poll_interval parameter. --- swfcat.as | 29 +++++++++++++++++++++++++---- 1 files changed, 25 insertions(+), 4 deletions(-) diff --git a/swfcat.as b/swfcat.as index f02e0a0..b83dc2f 100644 --- a/swfcat.as +++ b/swfcat.as @@ -21,6 +21,10 @@ * How many clients to serve concurrently. The default is * DEFAULT_MAX_NUM_PROXY_PAIRS. * + * facilitator_poll_interval=<FLOAT> + * How often to poll the facilitator, in seconds. The default is + * DEFAULT_FACILITATOR_POLL_INTERVAL. There is a sanity-check minimum of 1.0 s. + * * client=1 * If set (to any value), run in client RTMFP mode. In this mode, rather than * connecting to a facilitator and attempting to serve clients, swfcat starts an @@ -69,8 +73,9 @@ package private const DEFAULT_MAX_NUM_PROXY_PAIRS:uint = 10; - // Milliseconds. - private const FACILITATOR_POLL_INTERVAL:int = 10000; + /* In seconds. */ + private const DEFAULT_FACILITATOR_POLL_INTERVAL:Number = 10.0; + private const MIN_FACILITATOR_POLL_INTERVAL:Number = 1.0; // Bytes per second. Set to undefined to disable limit. public static const RATE_LIMIT:Number = undefined; @@ -89,6 +94,7 @@ package public var debug:Boolean; private var fac_addr:Object; private var max_num_proxy_pairs:uint; + private var facilitator_poll_interval:Number; private var local_addr:Object; public var rate_limit:RateLimit; @@ -153,6 +159,13 @@ package } max_num_proxy_pairs = uint(tmp); + tmp = get_param_timespec("facilitator_poll_interval", DEFAULT_FACILITATOR_POLL_INTERVAL); + if (tmp == null || tmp < MIN_FACILITATOR_POLL_INTERVAL) { + puts("Error: facilitator_poll_interval must be a nonnegative number at least " + MIN_FACILITATOR_POLL_INTERVAL + "."); + return; + } + facilitator_poll_interval = Number(tmp); + local_addr = get_param_addr("local", DEFAULT_LOCAL_TOR_CLIENT_ADDR); if (!local_addr) { puts("Error: Local spec must be in the form \"host:port\"."); @@ -198,6 +211,14 @@ package } } + /* Get a floating-point number of seconds from a time specification. The + only time specification format is a decimal number of seconds. + Returns null on error. */ + private function get_param_timespec(param:String, default_val:Number):Object + { + return get_param_number(param, default_val); + } + /* The main logic begins here, after start-up issues are taken care of. */ private function proxy_main():void { @@ -205,7 +226,7 @@ package var loader:URLLoader; if (proxy_pairs.length >= max_num_proxy_pairs) { - setTimeout(proxy_main, FACILITATOR_POLL_INTERVAL); + setTimeout(proxy_main, uint(facilitator_poll_interval * 1000)); return; } @@ -233,7 +254,7 @@ package var relay_spec:String; var proxy_pair:Object; - setTimeout(proxy_main, FACILITATOR_POLL_INTERVAL); + setTimeout(proxy_main, uint(facilitator_poll_interval * 1000)); loader = e.target as URLLoader; client_spec = loader.data.client;

1 0

[flashproxy/master] Document Flash parameters (e.g. debug=1).
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit dfe72ac1ed223ccb43b9d92115a28307caf5fa7e Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 00:38:02 2011 -0700 Document Flash parameters (e.g. debug=1). --- swfcat.as | 31 +++++++++++++++++++++++++++++++ 1 files changed, 31 insertions(+), 0 deletions(-) diff --git a/swfcat.as b/swfcat.as index b1dabc1..0c2f200 100644 --- a/swfcat.as +++ b/swfcat.as @@ -1,3 +1,34 @@ +/* Flash parameters. These can change how the program runs from the outside. + * They can be set as a URL query string, for example: + * http://www.example.com/swfcat.swf?facilitator=127.0.0.1:9002&debug=1 + * or in the HTML markup for the embedding of the movie: + * <object> + * <param name="movie" value="http://www.example.com/swfcat.swf"> + * <param name="flashvars" value="facilitator=127.0.0.1:9002&debug=1"> + * <embed src="http://www.example.com/swfcat.swf" + * flashvars="facilitator=127.0.0.1:9002&debug=1"></embed> + * </object> + * + * debug=1 + * If set (to any value), show verbose terminal-like output instead of the + * badge. + * + * facilitator=<HOST>:<PORT> + * The address of the facilitator to use. By default it is + * DEFAULT_FACILITATOR_ADDR. Both <HOST> and <PORT> must be present. + * + * client=1 + * If set (to any value), run in client RTMFP mode. In this mode, rather than + * connecting to a facilitator and attempting to serve clients, swfcat starts an + * RTMFP socket and connects to a local address (to the connector, to be exact). + * See README for more on running in client RTMFP mode. No argument is required + * to use RTMFP when in the usual server mode. + * + * local=<HOST>:<PORT> + * When in client RTMFP mode (client=1), connect to this local address. The + * default is DEFAULT_LOCAL_TOR_CLIENT_ADDR. + */ + package { import flash.display.Sprite;

1 0

[flashproxy/master] Change DEFAULT_MAX_NUM_PROXY_PAIRS from 100 to 10.
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit 74dd4fbfad5aca0f4f89e61f8c43f90f86ff6897 Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 01:09:28 2011 -0700 Change DEFAULT_MAX_NUM_PROXY_PAIRS from 100 to 10. --- swfcat.as | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/swfcat.as b/swfcat.as index 938def9..f02e0a0 100644 --- a/swfcat.as +++ b/swfcat.as @@ -67,7 +67,7 @@ package port: 9002 }; - private const DEFAULT_MAX_NUM_PROXY_PAIRS:uint = 100; + private const DEFAULT_MAX_NUM_PROXY_PAIRS:uint = 10; // Milliseconds. private const FACILITATOR_POLL_INTERVAL:int = 10000;

1 0

[flashproxy/master] Light rearrangement.
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit 5c8da04943e88e9c9ebcf9810173430287c9e33b Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 00:39:54 2011 -0700 Light rearrangement. --- swfcat.as | 4 +--- 1 files changed, 1 insertions(+), 3 deletions(-) diff --git a/swfcat.as b/swfcat.as index 0c2f200..9fcf0db 100644 --- a/swfcat.as +++ b/swfcat.as @@ -82,12 +82,10 @@ package /* Proxy pairs currently connected (up to MAX_NUM_PROXY_PAIRS). */ private var proxy_pairs:Array; + public var debug:Boolean; private var fac_addr:Object; - private var local_addr:Object; - public var debug:Boolean; - public var rate_limit:RateLimit; public function puts(s:String):void

1 0

[flashproxy/master] Add throughput measurement script.
by dcf＠torproject.org 30 Oct '11

30 Oct '11

commit a239d995242dd9205f7826a29ccf793bfc7eb803 Author: David Fifield <david(a)bamsoftware.com> Date: Sun Oct 30 03:29:47 2011 -0700 Add throughput measurement script. --- experiments/README | 45 ++++++++++++- experiments/common.sh | 34 ++++++++++ experiments/throughput/throughput-all.sh | 5 ++ experiments/throughput/throughput.sh | 105 ++++++++++++++++++++++++++++++ 4 files changed, 185 insertions(+), 4 deletions(-) diff --git a/experiments/README b/experiments/README index 5d65b28..ff8b416 100644 --- a/experiments/README +++ b/experiments/README @@ -1,6 +1,43 @@ -Scripts for running experiments. +This directory contains scripts for testing and benchmarking the flash +proxy. -This README contains descriptions of each numbered experiment. +== Preparation -Experiment -00 - Includes socat, crossdomaind, swfcat, httpd, and facilitator +You need to have installed certain software before running the tests. + Firefox + socat + Wget + Python + thttpd + Flash Player +Firefox, socat, Wget, and Python are easily installed on most GNU/Linux +distributions. thttpd can be compiled from the packages at +http://acme.com/software/thttpd/. A debug version of Flash Player can be +downloaded from http://www.adobe.com/support/flashplayer/downloads.html. + +You need to create some dedicated Firefox profiles. Create profiles +named flashexp1 and flashexp2 by running + firefox -ProfileManager -no-remote +Start the browsers with + firefox -P flashexp1 -no-remote & + firefox -P flashexp2 -no-remote & +and in each one, set this about:config variable: + browser.link.open_newwindow=1 (default is 3) +This allows the scripts to clear the contents of a tab and replace them +with another page. + +Before running any tests, start the crossdomain server as root: + sudo crossdomaind.py --daemon +The tests themselves shouldn't be run as root. + +I personally run these tests in an Arch Linux VM. + useradd -m user + passwd user + pacman -Sy + pacman -Su + pacman -S firefox socat python2 xorg xorg-xinit xterm flashplugin gcc make +Download thttpd, compile it (you have to rename the getline function to +avoid a naming conflict), and install it in /usr/local/bin. Symlink +/usr/bin/python to /usr/bin/python2. Also you have to install the +ttf-ms-fonts package from the AUR for text to show up in Flash Player. +Add a window manager, run "startx", and you should be set. diff --git a/experiments/common.sh b/experiments/common.sh new file mode 100644 index 0000000..485e908 --- /dev/null +++ b/experiments/common.sh @@ -0,0 +1,34 @@ +# This file contains common variables and subroutines used by the experiment +# scripts. + +FIREFOX=firefox +SOCAT=socat +THTTPD=thttpd + +visible_sleep() { + N="$1" + echo -n "sleep $N" + while [ "$N" -gt 0 ]; do + sleep 1 + N=$((N-1)) + echo -ne "\rsleep $N" + done + echo -ne "\n" +} + +ensure_browser_started() { + local PROFILE="$1" + ("$FIREFOX" -P "$PROFILE" -remote "ping()" || "$FIREFOX" -P "$PROFILE" -no-remote & visible_sleep 5) 2>/dev/null +} + +browser_clear() { + local PROFILE="$1" + ("$FIREFOX" -P "$PROFILE" -remote "ping()" && "$FIREFOX" -P "$PROFILE" -remote "openurl(about:blank)" &) 2>/dev/null +} + +browser_goto() { + local PROFILE="$1" + local URL="$2" + ensure_browser_started "$PROFILE" + "$FIREFOX" -P "$PROFILE" -remote "openurl($URL)" 2>/dev/null +} diff --git a/experiments/throughput/throughput-all.sh b/experiments/throughput/throughput-all.sh new file mode 100755 index 0000000..015e3e1 --- /dev/null +++ b/experiments/throughput/throughput-all.sh @@ -0,0 +1,5 @@ +#!/bin/sh + +for n in $(seq 1 50); do + ./throughput.sh -n $n +done diff --git a/experiments/throughput/throughput.sh b/experiments/throughput/throughput.sh new file mode 100755 index 0000000..5e2fd4b --- /dev/null +++ b/experiments/throughput/throughput.sh @@ -0,0 +1,105 @@ +#!/bin/sh + +# Usage: ./throughput.sh [-n NUM_CLIENTS] +# +# Tests the raw throughput of a single proxy. This script starts a web server +# serving swfcat.swf and a large data file, starts a facilitator, connector, and +# socat shim, and then starts multiple downloads through the proxy at once. +# Results are saved in a file called results-NUM_CLIENTS-DATE, where DATE is the +# current date. + +. ../common.sh + +FLASHPROXY_DIR=../../../flashproxy + +NUM_CLIENTS=1 + +while getopts "n:" OPTNAME; do + if [ "$OPTNAME" == n ]; then + NUM_CLIENTS="$OPTARG" + fi +done + +PROFILE=flashexp1 +PROXY_URL="http://localhost:8000/swfcat.swf?facilitator=127.0.0.1:9002&max_clients=$NU…" +DATA_FILE_NAME="$FLASHPROXY_DIR/dump" +RESULTS_FILE_NAME="results-$NUM_CLIENTS-$(date --iso)" + +# Declare an array. +declare -a PIDS_TO_KILL +stop() { + browser_clear "$PROFILE" + if [ -n "${PIDS_TO_KILL[*]}" ]; then + echo "Kill pids ${PIDS_TO_KILL[@]}." + kill "${PIDS_TO_KILL[@]}" + fi + echo "Delete data file." + rm -f "$DATA_FILE_NAME" + exit +} +trap stop EXIT + +echo "Create data file." +dd if=/dev/null of="$DATA_FILE_NAME" bs=1M seek=100 2>/dev/null || exit + +echo "Start web server." +"$THTTPD" -D -d "$FLASHPROXY_DIR" -p 8000 & +PIDS_TO_KILL+=($!) + +echo "Start facilitator." +"$FLASHPROXY_DIR"/facilitator.py -d --relay 127.0.0.1:8000 >/dev/null & +PIDS_TO_KILL+=($!) +visible_sleep 1 + +echo "Start connector." +"$FLASHPROXY_DIR"/connector.py >/dev/null & +PIDS_TO_KILL+=($!) +visible_sleep 1 + +echo "Start browser." +browser_goto "$PROFILE" "$PROXY_URL" +visible_sleep 2 + +# Create sufficiently many client registrations. +i=0 +while [ $i -lt $NUM_CLIENTS ]; do + echo -ne "\rRegister client $((i + 1))." + echo $'POST / HTTP/1.0\r\n\r\nclient=127.0.0.1:9000' | socat STDIN TCP-CONNECT:localhost:9002 + sleep 1 + i=$((i + 1)) +done +echo +visible_sleep 2 + +echo "Start socat." +"$SOCAT" TCP-LISTEN:2000,fork,reuseaddr SOCKS4A:localhost:dummy:0,socksport=9001 & +PIDS_TO_KILL+=($!) +visible_sleep 1 + + +# Extract and parse the "real" part of "time" output and return as a count of +# seconds. +extract_real_time() { + perl -n -e '($m, $s) = ($_ =~ m/real\s+(\d+)m([\d\.]+)s/); if (defined($m)) { print $m*60 + $s . "\n"; }' +} + +> "$RESULTS_FILE_NAME" + +declare -a WAIT_PIDS +i=0 +while [ $i -lt $NUM_CLIENTS ]; do + echo "Start Wget $((i + 1))." + ( + times=$((time wget http://localhost:2000/dump -q --timeout 30 -t 1 -O /dev/null) 2>&1) + if [ $? -eq 0 ]; then + echo "$times" | extract_real_time >> "$RESULTS_FILE_NAME" + else + echo "error" >> "$RESULTS_FILE_NAME" + fi + ) & + WAIT_PIDS+=($!) + i=$((i + 1)) +done +for pid in "${WAIT_PIDS[@]}"; do + wait "$pid" +done

1 0