[Date Prev][Date Next]   [Thread Prev][Thread Next]   [Thread Index] [Date Index] [Author Index]

[Libguestfs] [PATCH v3 4/7] v2v: rhv-upload-plugin: Get imageio connections limits



In imageio >= 2.0 the server reports the maximum number of readers and
writers. We will use these limits when creating a connection pool to the
server.

Signed-off-by: Nir Soffer <nsoffer redhat com>
---
 v2v/rhv-upload-plugin.py | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/v2v/rhv-upload-plugin.py b/v2v/rhv-upload-plugin.py
index 1c6f0603..20477c91 100644
--- a/v2v/rhv-upload-plugin.py
+++ b/v2v/rhv-upload-plugin.py
@@ -135,7 +135,8 @@ def open(readonly):
         raise
 
     debug("imageio features: flush=%(can_flush)r "
-          "zero=%(can_zero)r unix_socket=%(unix_socket)r"
+          "zero=%(can_zero)r unix_socket=%(unix_socket)r "
+          "max_readers=%(max_readers)r max_writers=%(max_writers)r"
           % options)
 
     # Save everything we need to make requests in the handle.
@@ -712,6 +713,8 @@ def get_options(http, url):
             "can_flush": "flush" in features,
             "can_zero": "zero" in features,
             "unix_socket": j.get('unix_socket'),
+            "max_readers": j.get("max_readers", 1),
+            "max_writers": j.get("max_writers", 1),
         }
 
     elif r.status == 405 or r.status == 204:
@@ -721,6 +724,8 @@ def get_options(http, url):
             "can_flush": False,
             "can_zero": False,
             "unix_socket": None,
+            "max_readers": 1,
+            "max_writers": 1,
         }
     else:
         raise RuntimeError("could not use OPTIONS request: %d: %s" %
-- 
2.26.2


[Date Prev][Date Next]   [Thread Prev][Thread Next]   [Thread Index] [Date Index] [Author Index]