+connections = [S3TestConnection() for _ in range(128)]
+logfile = open('multifetch-simulation.data', 'a')
+for s in [(1 << s) for s in range(16, 27)]:
+ print "Priming objects: %d-byte objects" % (s,)
+ run_test(s, 1, 100, open('/dev/null', 'w'), 0.0)
+
+ for blocksize in [x << 20 for x in (4, 8, 16, 32, 64, 128)]:
+ if s > blocksize: continue
+ for t in [4, 2, 1]:
+ for rep in range(10):
+ count = blocksize // s
+ print "Running tests: %d-byte blocks, %d-byte objects, %d parallel fetches" % (blocksize, s, t)
+ print "Object count:", count
+ if count * t > len(connections):
+ conns = connections
+ else:
+ conns = connections[0 : count * t]
+
+ objects = ['file-%d-%d' % (s, i % 100) for i in range(count)]
+ r = parallel_multiget(objects, conns, t)
+ print r
+ logfile.write('%s\t%s\t%s\t%s\t%s\n' % (s, blocksize >> 20, t, len(conns), r))
+ logfile.flush()
+ time.sleep(2.0)
+sys.exit(0)
+