]> git-server-git.apps.pok.os.sepia.ceph.com Git - s3-tests.git/commitdiff
gevent: bump to >=1.0 104/head
authorYuan Zhou <yuan.zhou@intel.com>
Fri, 28 Aug 2015 01:07:21 +0000 (09:07 +0800)
committerYuan Zhou <yuan.zhou@intel.com>
Mon, 11 Apr 2016 08:01:34 +0000 (16:01 +0800)
There are some DNS resolving issue on 0.13.6.
Bumping to >=1.0 fixes the issues for me.

Fixes: #13885
Signed-off-by: Yuan Zhou <yuan.zhou@intel.com>
requirements.txt
s3tests/readwrite.py
s3tests/roundtrip.py
setup.py

index 9c294dcd3c1fecdb0de7e7d1fe3d74694fb0fd3d..7f1348a47640fc7587df037c33b252c1d449496c 100644 (file)
@@ -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
index 8e59f7efac6583f2d2f1955be248f50ab742b2e3..64f490e182c1e16b5214a61262a7b8230744394e 100644 (file)
@@ -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,
index 0279ad7f215cb66893e1f999e16dc23db0ba1bcc..e73f8db6f5ad15845ad1bcc960c1c0e4256d75de 100644 (file)
@@ -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,
index e8ead2970b1e79540efc4ffb77c7d7b4d2e18f52..b514d0e913bbfbefd6784372410fe98f23698d6f 100644 (file)
--- a/setup.py
+++ b/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',
         ],