[PATCH master 2/2] watcher: Use locks when querying for resource information

[Michael Hanselmann]

---
 lib/watcher/__init__.py |    7 ++++---
 1 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/lib/watcher/__init__.py b/lib/watcher/__init__.py
index 45e285f..a305fe4 100644
--- a/lib/watcher/__init__.py
+++ b/lib/watcher/__init__.py
@@ -629,18 +629,19 @@ def _GetGroupData(cl, uuid):
   """Retrieves instances and nodes per node group.
 
   """
-  # TODO: Implement locking
   job = [
     # Get all primary instances in group
     opcodes.OpQuery(what=constants.QR_INSTANCE,
                     fields=["name", "status", "admin_state", "snodes",
                             "pnode.group.uuid", "snodes.group.uuid"],
-                    filter=[qlang.OP_EQUAL, "pnode.group.uuid", uuid]),
+                    filter=[qlang.OP_EQUAL, "pnode.group.uuid", uuid],
+                    use_locking=True),
 
     # Get all nodes in group
     opcodes.OpQuery(what=constants.QR_NODE,
                     fields=["name", "bootid", "offline"],
-                    filter=[qlang.OP_EQUAL, "group.uuid", uuid]),
+                    filter=[qlang.OP_EQUAL, "group.uuid", uuid],
+                    use_locking=True),
     ]
 
   job_id = cl.SubmitJob(job)
-- 
1.7.6