diff --git a/server/src/main/java/com/cloud/server/ManagementServerImpl.java b/server/src/main/java/com/cloud/server/ManagementServerImpl.java index 1b1debb756d7..ca38545145d5 100644 --- a/server/src/main/java/com/cloud/server/ManagementServerImpl.java +++ b/server/src/main/java/com/cloud/server/ManagementServerImpl.java @@ -1164,8 +1164,8 @@ public Pair, Integer> searchForServers(final ListHostsCmd c final Object resourceState = cmd.getResourceState(); final Object haHosts = cmd.getHaHost(); - final Pair, Integer> result = searchForServers(cmd.getStartIndex(), cmd.getPageSizeVal(), name, type, state, zoneId, pod, cluster, id, keyword, resourceState, haHosts, null, - null); + final Pair, Integer> result = searchForServers(cmd.getStartIndex(), cmd.getPageSizeVal(), name, type, state, zoneId, pod, + cluster, id, keyword, resourceState, haHosts, null, null); return new Pair, Integer>(result.first(), result.second()); } @@ -1267,19 +1267,20 @@ public Ternary, Integer>, List, Map, Integer> allHostsPair = null; List allHosts = null; + List hostsForMigrationWithStorage = null; final Map requiresStorageMotion = new HashMap(); DataCenterDeployment plan = null; if (canMigrateWithStorage) { - allHostsPair = searchForServers(startIndex, pageSize, null, hostType, null, srcHost.getDataCenterId(), null, null, null, keyword, null, null, srcHost.getHypervisorType(), - srcHost.getHypervisorVersion()); + allHostsPair = searchForServers(startIndex, pageSize, null, hostType, null, srcHost.getDataCenterId(), null, null, null, keyword, + null, null, srcHost.getHypervisorType(), srcHost.getHypervisorVersion(), srcHost.getId()); allHosts = allHostsPair.first(); - allHosts.remove(srcHost); + hostsForMigrationWithStorage = new ArrayList<>(allHosts); for (final VolumeVO volume : volumes) { StoragePool storagePool = _poolDao.findById(volume.getPoolId()); Long volClusterId = storagePool.getClusterId(); - for (Iterator iterator = allHosts.iterator(); iterator.hasNext();) { + for (Iterator iterator = hostsForMigrationWithStorage.iterator(); iterator.hasNext();) { final Host host = iterator.next(); if (volClusterId != null) { @@ -1318,10 +1319,9 @@ public Ternary, Integer>, List, Map, Integer>, List, Map findAllSuitableStoragePoolsForVm(final VolumeVO volume return suitablePools; } - private Pair, Integer> searchForServers(final Long startIndex, final Long pageSize, final Object name, final Object type, final Object state, final Object zone, final Object pod, - final Object cluster, final Object id, final Object keyword, final Object resourceState, final Object haHosts, final Object hypervisorType, final Object hypervisorVersion) { + private Pair, Integer> searchForServers(final Long startIndex, final Long pageSize, final Object name, final Object type, + final Object state, final Object zone, final Object pod, final Object cluster, final Object id, final Object keyword, + final Object resourceState, final Object haHosts, final Object hypervisorType, final Object hypervisorVersion, final Object... excludes) { final Filter searchFilter = new Filter(HostVO.class, "id", Boolean.TRUE, startIndex, pageSize); final SearchBuilder sb = _hostDao.createSearchBuilder(); sb.and("id", sb.entity().getId(), SearchCriteria.Op.EQ); + sb.and("idsNotIn", sb.entity().getId(), SearchCriteria.Op.NOTIN); sb.and("name", sb.entity().getName(), SearchCriteria.Op.LIKE); sb.and("type", sb.entity().getType(), SearchCriteria.Op.LIKE); sb.and("status", sb.entity().getStatus(), SearchCriteria.Op.EQ); @@ -1588,6 +1590,10 @@ private Pair, Integer> searchForServers(final Long startIndex, fina sc.setParameters("id", id); } + if (excludes != null && excludes.length > 0) { + sc.setParameters("idsNotIn", excludes); + } + if (name != null) { sc.setParameters("name", "%" + name + "%"); }