Arik Hadas has uploaded a new change for review. Change subject: core: return locks state in vm search ......................................................................
core: return locks state in vm search Changing the search for VMs to return VM objects that contain the locks state each VM. By "locks state" we mean whether the lock is exclusive or shared, and the messages that are attached to the locks. Change-Id: I693a223b47dadb13f38fefadadc0ff778fe5ab9b Signed-off-by: Arik Hadas <aha...@redhat.com> --- M backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/SearchQuery.java M backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/VmHandler.java M backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/businessentities/VM.java 3 files changed, 18 insertions(+), 0 deletions(-) git pull ssh://gerrit.ovirt.org:29418/ovirt-engine refs/changes/47/38247/1 diff --git a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/SearchQuery.java b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/SearchQuery.java index 3e68c84..62f6b57 100644 --- a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/SearchQuery.java +++ b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/SearchQuery.java @@ -154,6 +154,7 @@ List<VM> vms = getDbFacade().getVmDao().getAllUsingQuery(data.getQuery()); for (VM vm : vms) { VmHandler.updateVmGuestAgentVersion(vm); + VmHandler.updateVmLock(vm); } return vms; } diff --git a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/VmHandler.java b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/VmHandler.java index 3b21c03..7f55607 100644 --- a/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/VmHandler.java +++ b/backend/manager/modules/bll/src/main/java/org/ovirt/engine/core/bll/VmHandler.java @@ -62,6 +62,7 @@ import org.ovirt.engine.core.common.errors.VdcBLLException; import org.ovirt.engine.core.common.errors.VdcBllErrors; import org.ovirt.engine.core.common.errors.VdcBllMessages; +import org.ovirt.engine.core.common.locks.LockingGroup; import org.ovirt.engine.core.common.osinfo.OsRepository; import org.ovirt.engine.core.common.utils.Pair; import org.ovirt.engine.core.common.utils.SimpleDependecyInjector; @@ -80,6 +81,7 @@ import org.ovirt.engine.core.utils.ObjectIdentityChecker; import org.ovirt.engine.core.utils.linq.LinqUtils; import org.ovirt.engine.core.utils.linq.Predicate; +import org.ovirt.engine.core.utils.lock.LockManagerFactory; import org.ovirt.engine.core.utils.transaction.TransactionMethod; import org.ovirt.engine.core.utils.transaction.TransactionSupport; import org.slf4j.Logger; @@ -464,6 +466,10 @@ } } + public static void updateVmLock(final VM vm) { + vm.setLock(LockManagerFactory.getLockManager().query(vm.getId().toString() + LockingGroup.VM)); + } + /** * Checks the validity of the given memory size according to OS type. * diff --git a/backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/businessentities/VM.java b/backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/businessentities/VM.java index 0e29dcd..35a4890 100644 --- a/backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/businessentities/VM.java +++ b/backend/manager/modules/common/src/main/java/org/ovirt/engine/core/common/businessentities/VM.java @@ -14,6 +14,7 @@ import org.ovirt.engine.core.common.businessentities.network.VmNetworkInterface; import org.ovirt.engine.core.common.config.Config; import org.ovirt.engine.core.common.config.ConfigValues; +import org.ovirt.engine.core.common.locks.Lock; import org.ovirt.engine.core.common.osinfo.OsRepository; import org.ovirt.engine.core.common.utils.SimpleDependecyInjector; import org.ovirt.engine.core.compat.Guid; @@ -49,6 +50,8 @@ private boolean nextRunConfigurationExists; private String hibernationVolHandle; + + private Lock lock; public String getUserDefinedProperties() { return vmStatic.getUserDefinedProperties(); @@ -1867,4 +1870,12 @@ public void setMigrateCompressed(Boolean migrateCompressed) { vmStatic.setMigrateCompressed(migrateCompressed); } + + public Lock getLock() { + return lock; + } + + public void setLock(Lock lock) { + this.lock = lock; + } } -- To view, visit https://gerrit.ovirt.org/38247 To unsubscribe, visit https://gerrit.ovirt.org/settings Gerrit-MessageType: newchange Gerrit-Change-Id: I693a223b47dadb13f38fefadadc0ff778fe5ab9b Gerrit-PatchSet: 1 Gerrit-Project: ovirt-engine Gerrit-Branch: master Gerrit-Owner: Arik Hadas <aha...@redhat.com> _______________________________________________ Engine-patches mailing list Engine-patches@ovirt.org http://lists.ovirt.org/mailman/listinfo/engine-patches