TrueCloudLab/s3-tests
7
0
Fork 1
mirror of https://github.com/ceph/s3-tests.git synced 2024-12-25 13:56:37 +00:00
Code Issues 1 Projects Releases Packages Wiki Activity

Code layout cleanup.

Browse source
This commit is contained in:
Tommi Virtanen 2011-07-20 10:54:17 -07:00
parent deb8be9957
commit 9ecaf63fbe
1 changed files with 15 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
s3tests/rand_readwrite.py
View file

@ -119,18 +119,22 @@ def main():
print "Spawning {r} readers and {w} writers...".format(r=options.num_readers, w=options.num_writers) print "Spawning {r} readers and {w} writers...".format(r=options.num_readers, w=options.num_writers)
group = gevent.pool.Group() group = gevent.pool.Group()
for x in xrange(options.num_writers): for x in xrange(options.num_writers):
group.spawn(writer, bucket, group.spawn(
name=x, writer,
queue=q, bucket=bucket,
file_size=options.file_size, name=x,
file_stddev=options.stddev, queue=q,
file_name_seed=r, file_size=options.file_size,
) file_stddev=options.stddev,
file_name_seed=r,
)
for x in xrange(options.num_readers): for x in xrange(options.num_readers):
group.spawn(reader, bucket, group.spawn(
name=x, reader,
queue=q, bucket=bucket,
) name=x,
queue=q,
)
def stop(): def stop():
group.kill(block=True) group.kill(block=True)
q.put(StopIteration) q.put(StopIteration)