From: Nachi Ueno <nachi@nttmcl.com>
Date: Wed, 6 Mar 2013 04:52:22 +0000 (-0800)
Subject: Create quantum client for each api request in metadata agent
X-Git-Url: https://review.fuel-infra.org/gitweb?a=commitdiff_plain;h=84ed1079c87717ddd279597fb7b41f5ea29599c8;p=openstack-build%2Fneutron-build.git

Create quantum client for each api request in metadata agent

Fixes bug 1148017

Change-Id: I6f9263f01d17dcc44a4deb42cdaa348164ac4819
---

diff --git a/quantum/agent/metadata/agent.py b/quantum/agent/metadata/agent.py
index 773f31a4c..4163be853 100644
--- a/quantum/agent/metadata/agent.py
+++ b/quantum/agent/metadata/agent.py
@@ -66,14 +66,16 @@ class MetadataProxyHandler(object):
     def __init__(self, conf):
         self.conf = conf
 
-        self.qclient = client.Client(
+    def _get_quantum_client(self):
+        qclient = client.Client(
             username=self.conf.admin_user,
             password=self.conf.admin_password,
             tenant_name=self.conf.admin_tenant_name,
             auth_url=self.conf.auth_url,
             auth_strategy=self.conf.auth_strategy,
-            region_name=self.conf.auth_region
+            region_name=self.conf.auth_region,
         )
+        return qclient
 
     @webob.dec.wsgify(RequestClass=wsgi.Request)
     def __call__(self, req):
@@ -93,6 +95,8 @@ class MetadataProxyHandler(object):
             return webob.exc.HTTPInternalServerError(explanation=unicode(msg))
 
     def _get_instance_id(self, req):
+        qclient = self._get_quantum_client()
+
         remote_address = req.headers.get('X-Forwarded-For')
         network_id = req.headers.get('X-Quantum-Network-ID')
         router_id = req.headers.get('X-Quantum-Router-ID')
@@ -100,13 +104,13 @@ class MetadataProxyHandler(object):
         if network_id:
             networks = [network_id]
         else:
-            internal_ports = self.qclient.list_ports(
+            internal_ports = qclient.list_ports(
                 device_id=router_id,
                 device_owner=DEVICE_OWNER_ROUTER_INTF)['ports']
 
             networks = [p['network_id'] for p in internal_ports]
 
-        ports = self.qclient.list_ports(
+        ports = qclient.list_ports(
             network_id=networks,
             fixed_ips=['ip_address=%s' % remote_address])['ports']