From 71a62b2cbc489470c96ac771392270b6058ddaa1 Mon Sep 17 00:00:00 2001 From: Simo Sorce Date: Tue, 13 Aug 2013 12:13:23 -0400 Subject: Adjust KDS communication protocol The KDS review process has determined some changes to the API. This patch fixes KDSClient to interoperate properly. Change-Id: I888e8a41573f171048356a9d277de1d7610537ce --- openstack/common/rpc/securemessage.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/openstack/common/rpc/securemessage.py b/openstack/common/rpc/securemessage.py index c5530a6..a935f9b 100644 --- a/openstack/common/rpc/securemessage.py +++ b/openstack/common/rpc/securemessage.py @@ -209,7 +209,7 @@ class _KDSClient(object): else: self.timeout = None - def _do_get(self, url, request): + def _do_post(self, url, request): req_kwargs = dict() req_kwargs['headers'] = dict() req_kwargs['headers']['User-Agent'] = self.USER_AGENT @@ -219,7 +219,7 @@ class _KDSClient(object): req_kwargs['timeout'] = self.timeout try: - resp = requests.get(url, **req_kwargs) + resp = requests.post(url, **req_kwargs) except requests.ConnectionError as e: err = "Unable to establish connection. %s" % e raise CommunicationError(url, err) @@ -248,10 +248,10 @@ class _KDSClient(object): if url is None: if not self._endpoint: raise CommunicationError(url, 'Endpoint not configured') - url = self._endpoint + '/kds/ticket' + url = self._endpoint + '/kds/ticket/' + request['signature'] while redirects: - resp = self._do_get(url, request) + resp = self._do_post(url, request) if resp.status_code in (301, 302, 305): # Redirected. Reissue the request to the new location. url = resp.headers['location'] -- cgit