<reponame>Frankiamme/uProxy-p2p<gh_stars>100-1000
#!/usr/bin/python3

import argparse
import csv
import io
import subprocess
import sys
import time
import urllib.parse

FLOOD_SIZE_MB = 64
FLOOD_MAX_SPEED_MB = 5

parser = argparse.ArgumentParser(
    description='Compare transformer throughput.')
parser.add_argument('clone_path', help='path to pre-built uproxy-lib repo')
args = parser.parse_args()

# Where is flood server?
flood_ip = subprocess.check_output(['./flood.sh', str(FLOOD_SIZE_MB) + 'M',
    str(FLOOD_MAX_SPEED_MB) + 'M'], universal_newlines=True).strip()
print('** using flood server at ' + str(flood_ip))

browser_spec = 'chrome-stable'
# See churn pipe source for the full list.
transformers = [
  'none',
  'caesar',
  'fragmentationShaper',
  'encryptionShaper',
  'decompressionShaper',
  'sequenceShaper',
  'protean'
]

# Run the benchmarks.
throughput = {}
for transformer in transformers:
  print('** ' + transformer)

  result = 0
  try:
    # Start the relevant config.
    run_pair = subprocess.Popen(['./run_pair.sh',
        '-p', args.clone_path,
        browser_spec, browser_spec],
        universal_newlines=True,
        stdin=subprocess.PIPE)

    run_pair.stdin.write('transform with ' + transformer + '\n')
    run_pair.stdin.close()
    run_pair.wait(30)

    # time.time is good for Unix-like systems.
    start = time.time()
    if subprocess.call(['nc', '-X', '5', '-x', 'localhost:9999',
        flood_ip, '1224']) != 0:
      raise Exception('nc failed, proxy probably did not start')
    end = time.time()

    print('** benchmarking...')

    elapsed = round(end - start, 2)
    result = int((FLOOD_SIZE_MB / elapsed) * 1000)

    print('** throughput for ' + transformer + ': ' + str(result) + 'KB/sec')
  except Exception as e:
    print('** failed to test ' + transformer + ': ' + str(e))

  throughput[transformer] = result

# Raw summary.
print('** raw numbers: ' + str(throughput))

# CSV, e.g.:
#   transformer,none,caesar,protean
#   throughput,500,300,100
stringio = io.StringIO()
writer = csv.writer(stringio)
headers = ['transformer']
headers.extend(transformers)
writer.writerow(headers)
figures = ['throughput']
for transformer in transformers:
  figures.append(throughput[transformer])
writer.writerow(figures)
print('** CSV')
print(stringio.getvalue())

# URL which uses Datacopia's oh-so-simple GET-based API:
print('** http://www.datacopia.com/?data=' + urllib.parse.quote(
    stringio.getvalue()))

#!/usr/bin/python3

import argparse
import csv
import io
import subprocess
import sys
import time
import urllib.parse

FLOOD_SIZE_MB = 64
FLOOD_MAX_SPEED_MB = 5

parser = argparse.ArgumentParser(
    description='Compare transformer throughput.')
parser.add_argument('clone_path', help='path to pre-built uproxy-lib repo')
args = parser.parse_args()

# Where is flood server?
flood_ip = subprocess.check_output(['./flood.sh', str(FLOOD_SIZE_MB) + 'M',
    str(FLOOD_MAX_SPEED_MB) + 'M'], universal_newlines=True).strip()
print('** using flood server at ' + str(flood_ip))

browser_spec = 'chrome-stable'
# See churn pipe source for the full list.
transformers = [
  'none',
  'caesar',
  'fragmentationShaper',
  'encryptionShaper',
  'decompressionShaper',
  'sequenceShaper',
  'protean'
]

# Run the benchmarks.
throughput = {}
for transformer in transformers:
  print('** ' + transformer)

  result = 0
  try:
    # Start the relevant config.
    run_pair = subprocess.Popen(['./run_pair.sh',
        '-p', args.clone_path,
        browser_spec, browser_spec],
        universal_newlines=True,
        stdin=subprocess.PIPE)

    run_pair.stdin.write('transform with ' + transformer + '\n')
    run_pair.stdin.close()
    run_pair.wait(30)

    # time.time is good for Unix-like systems.
    start = time.time()
    if subprocess.call(['nc', '-X', '5', '-x', 'localhost:9999',
        flood_ip, '1224']) != 0:
      raise Exception('nc failed, proxy probably did not start')
    end = time.time()

    print('** benchmarking...')

    elapsed = round(end - start, 2)
    result = int((FLOOD_SIZE_MB / elapsed) * 1000)

    print('** throughput for ' + transformer + ': ' + str(result) + 'KB/sec')
  except Exception as e:
    print('** failed to test ' + transformer + ': ' + str(e))

  throughput[transformer] = result

# Raw summary.
print('** raw numbers: ' + str(throughput))

# CSV, e.g.:
#   transformer,none,caesar,protean
#   throughput,500,300,100
stringio = io.StringIO()
writer = csv.writer(stringio)
headers = ['transformer']
headers.extend(transformers)
writer.writerow(headers)
figures = ['throughput']
for transformer in transformers:
  figures.append(throughput[transformer])
writer.writerow(figures)
print('** CSV')
print(stringio.getvalue())

# URL which uses Datacopia's oh-so-simple GET-based API:
print('** http://www.datacopia.com/?data=' + urllib.parse.quote(
    stringio.getvalue()))
#!/usr/bin/python3 # Where is flood server? # See churn pipe source for the full list. # Run the benchmarks. # Start the relevant config. # time.time is good for Unix-like systems. # Raw summary. # CSV, e.g.: #   transformer,none,caesar,protean #   throughput,500,300,100 # URL which uses Datacopia's oh-so-simple GET-based API: