diff options
| author | Radoslav Gerganov <rgerganov@vmware.com> | 2016-08-30 17:16:28 +0300 |
|---|---|---|
| committer | Radoslav Gerganov <rgerganov@vmware.com> | 2016-08-30 17:16:28 +0300 |
| commit | 53c7c370bcaaecab527184516d5cc8c8dfe5ad89 (patch) | |
| tree | f292e11f53794e1e6aeb8486ebac7911cd0313ae | |
| parent | 6bf58463e0f11cd0a3a868d74ef7db3973da2912 (diff) | |
| download | oslo-vmware-53c7c370bcaaecab527184516d5cc8c8dfe5ad89.tar.gz | |
Set pool size for HTTPS connections
Setting the pool size was done only for the 'file' protocol which has no
effect when communicating with vCenter over HTTPS. This patch sets the
pool size for HTTPS connections as well.
Change-Id: I1bb72d27a6861b4a2cf327bfd6705d58a31d49c5
Closes-Bug: #1618477
| -rw-r--r-- | oslo_vmware/service.py | 2 | ||||
| -rw-r--r-- | oslo_vmware/tests/test_service.py | 3 |
2 files changed, 5 insertions, 0 deletions
diff --git a/oslo_vmware/service.py b/oslo_vmware/service.py index 10b7fa6..477a6c3 100644 --- a/oslo_vmware/service.py +++ b/oslo_vmware/service.py @@ -143,6 +143,8 @@ class RequestsTransport(transport.Transport): self.session = requests.Session() self.session.mount('file:///', LocalFileAdapter(pool_maxsize=pool_maxsize)) + self.session.mount('https://', requests.adapters.HTTPAdapter( + pool_connections=pool_maxsize, pool_maxsize=pool_maxsize)) self.cookiejar = self.session.cookies self._connection_timeout = connection_timeout diff --git a/oslo_vmware/tests/test_service.py b/oslo_vmware/tests/test_service.py index d533989..d11b38c 100644 --- a/oslo_vmware/tests/test_service.py +++ b/oslo_vmware/tests/test_service.py @@ -445,6 +445,9 @@ class RequestsTransportTest(base.TestCase): local_file_adapter = transport.session.adapters['file:///'] self.assertEqual(100, local_file_adapter._pool_connections) self.assertEqual(100, local_file_adapter._pool_maxsize) + https_adapter = transport.session.adapters['https://'] + self.assertEqual(100, https_adapter._pool_connections) + self.assertEqual(100, https_adapter._pool_maxsize) @mock.patch('os.path.getsize') def test_send_with_local_file_url(self, get_size_mock): |