Revision 5bfb1134
b/lib/watcher/__init__.py | ||
---|---|---|
629 | 629 |
"""Retrieves instances and nodes per node group. |
630 | 630 |
|
631 | 631 |
""" |
632 |
# TODO: Implement locking |
|
633 | 632 |
job = [ |
634 | 633 |
# Get all primary instances in group |
635 | 634 |
opcodes.OpQuery(what=constants.QR_INSTANCE, |
636 | 635 |
fields=["name", "status", "admin_state", "snodes", |
637 | 636 |
"pnode.group.uuid", "snodes.group.uuid"], |
638 |
filter=[qlang.OP_EQUAL, "pnode.group.uuid", uuid]), |
|
637 |
filter=[qlang.OP_EQUAL, "pnode.group.uuid", uuid], |
|
638 |
use_locking=True), |
|
639 | 639 |
|
640 | 640 |
# Get all nodes in group |
641 | 641 |
opcodes.OpQuery(what=constants.QR_NODE, |
642 | 642 |
fields=["name", "bootid", "offline"], |
643 |
filter=[qlang.OP_EQUAL, "group.uuid", uuid]), |
|
643 |
filter=[qlang.OP_EQUAL, "group.uuid", uuid], |
|
644 |
use_locking=True), |
|
644 | 645 |
] |
645 | 646 |
|
646 | 647 |
job_id = cl.SubmitJob(job) |
Also available in: Unified diff