mirror of
https://github.com/ceph/s3-tests.git
synced 2024-11-27 13:58:09 +00:00
gevent: bump to >=1.0
There are some DNS resolving issue on 0.13.6. Bumping to >=1.0 fixes the issues for me. Signed-off-by: Yuan Zhou <yuan.zhou@intel.com>
This commit is contained in:
parent
7d26245b3a
commit
3b1b4638f4
4 changed files with 8 additions and 8 deletions
|
@ -3,7 +3,7 @@ nose >=1.0.0
|
|||
boto >=2.6.0
|
||||
bunch >=1.0.0
|
||||
# 0.14 switches to libev, that means bootstrap needs to change too
|
||||
gevent ==0.13.6
|
||||
gevent >=1.0
|
||||
isodate >=0.4.4
|
||||
requests ==0.14.0
|
||||
pytz >=2011k
|
||||
|
|
|
@ -195,7 +195,7 @@ def main():
|
|||
warmup_pool = gevent.pool.Pool(size=100)
|
||||
for file_name in file_names:
|
||||
fp = next(files)
|
||||
warmup_pool.spawn_link_exception(
|
||||
warmup_pool.spawn(
|
||||
write_file,
|
||||
bucket=bucket,
|
||||
file_name=file_name,
|
||||
|
@ -214,7 +214,7 @@ def main():
|
|||
if not config.readwrite.get('deterministic_file_names'):
|
||||
for x in xrange(config.readwrite.writers):
|
||||
this_rand = random.Random(rand_writer.randrange(2**32))
|
||||
group.spawn_link_exception(
|
||||
group.spawn(
|
||||
writer,
|
||||
bucket=bucket,
|
||||
worker_id=x,
|
||||
|
@ -231,7 +231,7 @@ def main():
|
|||
rand_reader = random.Random(seeds['reader'])
|
||||
for x in xrange(config.readwrite.readers):
|
||||
this_rand = random.Random(rand_reader.randrange(2**32))
|
||||
group.spawn_link_exception(
|
||||
group.spawn(
|
||||
reader,
|
||||
bucket=bucket,
|
||||
worker_id=x,
|
||||
|
|
|
@ -161,7 +161,7 @@ def main():
|
|||
)
|
||||
q = gevent.queue.Queue()
|
||||
|
||||
logger_g = gevent.spawn_link_exception(yaml.safe_dump_all, q, stream=real_stdout)
|
||||
logger_g = gevent.spawn(yaml.safe_dump_all, q, stream=real_stdout)
|
||||
|
||||
print "Writing {num} objects with {w} workers...".format(
|
||||
num=config.roundtrip.files.num,
|
||||
|
@ -171,7 +171,7 @@ def main():
|
|||
start = time.time()
|
||||
for objname in objnames:
|
||||
fp = next(files)
|
||||
pool.spawn_link_exception(
|
||||
pool.spawn(
|
||||
writer,
|
||||
bucket=bucket,
|
||||
objname=objname,
|
||||
|
@ -195,7 +195,7 @@ def main():
|
|||
pool = gevent.pool.Pool(size=config.roundtrip.readers)
|
||||
start = time.time()
|
||||
for objname in objnames:
|
||||
pool.spawn_link_exception(
|
||||
pool.spawn(
|
||||
reader,
|
||||
bucket=bucket,
|
||||
objname=objname,
|
||||
|
|
2
setup.py
2
setup.py
|
@ -16,7 +16,7 @@ setup(
|
|||
'boto >=2.0b4',
|
||||
'PyYAML',
|
||||
'bunch >=1.0.0',
|
||||
'gevent ==0.13.6',
|
||||
'gevent >=1.0',
|
||||
'isodate >=0.4.4',
|
||||
],
|
||||
|
||||
|
|
Loading…
Reference in a new issue