Merge "flatten distributed scheduler"

nova/db/api.py

@@ -158,6 +158,11 @@ def compute_node_get(context, compute_id, session=None):
     return IMPL.compute_node_get(context, compute_id)
 
 
+def compute_node_get_all(context, session=None):
+    """Get all computeNodes."""
+    return IMPL.compute_node_get_all(context)
+
+
 def compute_node_create(context, values):
     """Create a computeNode from the values dictionary."""
     return IMPL.compute_node_create(context, values)

nova/db/sqlalchemy/api.py

@@ -366,6 +366,16 @@ def compute_node_get(context, compute_id, session=None):
     return result
 
 
+@require_admin_context
+def compute_node_get_all(context, session=None):
+    if not session:
+        session = get_session()
+
+    return session.query(models.ComputeNode).\
+                    options(joinedload('service')).\
+                    filter_by(deleted=can_read_deleted(context))
+
+
 @require_admin_context
 def compute_node_create(context, values):
     compute_node_ref = models.ComputeNode()