-def run_test():
- print "==== S3 ===="
- c = S3TestConnection()
- for repeat in range(4):
- for size in SIZES:
- #c.put_object('file-%d-%d' % (size, repeat), size)
- pass
+def run_test(size, threads, num):
+ connections = [S3TestConnection() for _ in range(threads)]
+ for i in range(num):
+ res = parallel_get('file-%d-%d' % (size, i), connections)
+ print res
+ time.sleep(1.0)