diff options
author | Chris Church <chris@ninemoreminutes.com> | 2015-04-09 13:45:21 -0400 |
---|---|---|
committer | Brian Coca <brian.coca+git@gmail.com> | 2015-04-16 08:47:45 -0400 |
commit | baa6426c5752259bf19c8728e2b2dbfe5b48e810 (patch) | |
tree | 85d4b0d40e7c4ea0944a209d3e2b169fc34ddb14 | |
parent | e16e2b171c2192806477d00382c508f9cd9f9ac6 (diff) | |
download | ansible-baa6426c5752259bf19c8728e2b2dbfe5b48e810.tar.gz |
Remove winrm connection cache (only useful when running against one host). Also fixes #10391.
-rw-r--r-- | lib/ansible/runner/connection_plugins/winrm.py | 12 |
1 files changed, 0 insertions, 12 deletions
diff --git a/lib/ansible/runner/connection_plugins/winrm.py b/lib/ansible/runner/connection_plugins/winrm.py index 7a2d6d3318..8849a080bd 100644 --- a/lib/ansible/runner/connection_plugins/winrm.py +++ b/lib/ansible/runner/connection_plugins/winrm.py @@ -18,8 +18,6 @@ from __future__ import absolute_import import base64 -import hashlib -import imp import os import re import shlex @@ -44,10 +42,6 @@ try: except ImportError: pass -_winrm_cache = { - # 'user:pwhash@host:port': <protocol instance> -} - def vvvvv(msg, host=None): verbose(msg, host=host, caplevel=4) @@ -84,10 +78,6 @@ class Connection(object): vvv("ESTABLISH WINRM CONNECTION FOR USER: %s on PORT %s TO %s" % \ (self.user, port, self.host), host=self.host) netloc = '%s:%d' % (self.host, port) - cache_key = '%s:%s@%s:%d' % (self.user, hashlib.md5(self.password).hexdigest(), self.host, port) - if cache_key in _winrm_cache: - vvvv('WINRM REUSE EXISTING CONNECTION: %s' % cache_key, host=self.host) - return _winrm_cache[cache_key] exc = None for transport, scheme in self.transport_schemes['http' if port == 5985 else 'https']: if transport == 'kerberos' and not HAVE_KERBEROS: @@ -99,7 +89,6 @@ class Connection(object): username=self.user, password=self.password) try: protocol.send_message('') - _winrm_cache[cache_key] = protocol return protocol except WinRMTransportError, exc: err_msg = str(exc) @@ -111,7 +100,6 @@ class Connection(object): if code == 401: raise errors.AnsibleError("the username/password specified for this server was incorrect") elif code == 411: - _winrm_cache[cache_key] = protocol return protocol vvvv('WINRM CONNECTION ERROR: %s' % err_msg, host=self.host) continue |