Skip to content

Commit d508994

Browse files
author
Daan Hoogland
committed
merge forward error
1 parent edb62b4 commit d508994

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

server/src/main/java/com/cloud/resource/ResourceManagerImpl.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2366,7 +2366,7 @@ public void updateStoragePoolConnectionsOnHosts(Long poolId, List<String> storag
23662366
List<Long> conflictingHostIds = new ArrayList<>(CollectionUtils.intersection(hostIdsToDisconnect, hostIdsUsingTheStoragePool));
23672367
if (CollectionUtils.isNotEmpty(conflictingHostIds)) {
23682368
Map<HostVO, List<VolumeVO>> hostVolumeMap = new HashMap<>();
2369-
List<VolumeVO> volumesInPool = volumeDao.findByPoolId(poolId);
2369+
List<VolumeVO> volumesInPool = volumeDao.findNonDestroyedVolumesByPoolId(poolId);
23702370
Map<Long, VMInstanceVO> vmInstanceCache = new HashMap<>();
23712371

23722372
for (Long hostId : conflictingHostIds) {

server/src/test/java/com/cloud/resource/ResourceManagerImplTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -944,7 +944,7 @@ public void testUpdateStoragePoolConnectionsOnHosts_ConflictWithHostIdsAndVolume
944944
Mockito.when(volume2.getInstanceId()).thenReturn(101L);
945945

946946
List<VolumeVO> volumesInPool = Arrays.asList(volume1, volume2);
947-
Mockito.doReturn(volumesInPool).when(volumeDao).findByPoolId(poolId);
947+
Mockito.doReturn(volumesInPool).when(volumeDao).findNonDestroyedVolumesByPoolId(poolId);
948948

949949
VMInstanceVO vmInstance1 = Mockito.mock(VMInstanceVO.class);
950950
VMInstanceVO vmInstance2 = Mockito.mock(VMInstanceVO.class);

0 commit comments

Comments
 (0)