Merge pull request #123 from rd4398/rohand-issue#295

Parallelize API requests for esi-leap

Author: tzumainn

esi_leap/api/controllers/v1/lease.py

@@ -10,6 +10,7 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
+import concurrent.futures
 import datetime
 import http.client as http_client
 from oslo_utils import uuidutils
@@ -115,9 +116,17 @@ def get_all(self, project_id=None, start_time=None, end_time=None,
         leases = lease_obj.Lease.get_all(filters, request)
 
         lease_collection.leases = []
+
         if len(leases) > 0:
-            project_list = keystone.get_project_list()
-            node_list = ironic.get_node_list()
+            project_list = None
+            node_list = None
+
+            with concurrent.futures.ThreadPoolExecutor() as executor:
+                f1 = executor.submit(ironic.get_node_list)
+                f2 = executor.submit(keystone.get_project_list)
+                node_list = f1.result()
+                project_list = f2.result()
+
             leases_with_added_info = [
                 Lease(**utils.lease_get_dict_with_added_info(l, project_list,
                                                              node_list))

esi_leap/api/controllers/v1/node.py

@@ -10,6 +10,7 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
+import concurrent.futures
 from datetime import datetime
 import pecan
 from pecan import rest
@@ -63,11 +64,18 @@ class NodesController(rest.RestController):
     @wsme_pecan.wsexpose(NodeCollection)
     def get_all(self):
         context = pecan.request.context
-        nodes = ironic.get_node_list(context)
+
+        nodes = None
+        project_list = None
+
+        with concurrent.futures.ThreadPoolExecutor() as executor:
+            f1 = executor.submit(ironic.get_node_list, context)
+            f2 = executor.submit(keystone.get_project_list)
+            nodes = f1.result()
+            project_list = f2.result()
 
         node_collection = NodeCollection()
 
-        project_list = keystone.get_project_list()
         now = datetime.now()
 
         offers = offer_obj.Offer.get_all({'status': [statuses.AVAILABLE]},

esi_leap/api/controllers/v1/offer.py

@@ -10,6 +10,7 @@
 #    License for the specific language governing permissions and limitations
 #    under the License.
 
+import concurrent.futures
 import datetime
 import http.client as http_client
 from oslo_utils import uuidutils
@@ -167,9 +168,16 @@ def get_all(self, project_id=None, resource_type=None,
         offers = offer_obj.Offer.get_all(filters, request)
 
         offer_collection.offers = []
+
         if len(offers) > 0:
-            project_list = keystone.get_project_list()
-            node_list = ironic.get_node_list()
+            project_list = None
+            node_list = None
+            with concurrent.futures.ThreadPoolExecutor() as executor:
+                f1 = executor.submit(ironic.get_node_list)
+                f2 = executor.submit(keystone.get_project_list)
+                node_list = f1.result()
+                project_list = f2.result()
+
             offers_with_added_info = [
                 Offer(**utils.offer_get_dict_with_added_info(o, project_list,
                                                              node_list))