- c = S3TestConnection()
- for repeat in range(4):
- for size in SIZES:
- c.get_object('file-%d-%d' % (size, repeat))
+def run_test(size, threads, num, logfile=sys.stdout, delay=1.0):
+ connections = [S3TestConnection() for _ in range(threads)]
+ for i in range(num):
+ print " ...test", i
+ res = parallel_get('file-%d-%d' % (size, i), connections)
+ if res is not None:
+ logfile.write(str(min(res)) + "\n")
+ if delay > 0:
+ time.sleep(delay)
+
+for s in SIZES:
+ print "Priming objects: %d-byte objects" % (s,)
+ logfile = open('/dev/null', 'w')
+ run_test(s, 1, 100, logfile, 0.0)
+
+ for t in [4, 2, 1]:
+ print "Running tests: %d-byte objects, %d parallel fetches" % (s, t)
+ logfile = open('parallel-%d-%d.data' % (s, t), 'w')
+ run_test(s, t, 100, logfile)
+sys.exit(0)