Skip to content

Commit 151444c

Browse files
update filter, log and test
1 parent 47a6a81 commit 151444c

File tree

2 files changed

+8
-4
lines changed

2 files changed

+8
-4
lines changed

server/src/main/java/com/cloud/storage/StorageManagerImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1558,7 +1558,7 @@ private boolean deleteDataStoreInternal(StoragePoolVO sPool, boolean forced) {
15581558

15591559
protected String getStoragePoolNonDestroyedVolumesLog(long storagePoolId) {
15601560
StringBuilder sb = new StringBuilder();
1561-
List<VolumeVO> nonDestroyedVols = volumeDao.findByPoolId(storagePoolId, null);
1561+
List<VolumeVO> nonDestroyedVols = volumeDao.findByPoolId(storagePoolId, null).stream().filter(vol -> vol.getState() != Volume.State.Destroy).collect(Collectors.toList());
15621562
VMInstanceVO volInstance;
15631563
List<String> logMessageInfo = new ArrayList<>();
15641564

@@ -1569,7 +1569,7 @@ protected String getStoragePoolNonDestroyedVolumesLog(long storagePoolId) {
15691569
if (volInstance != null) {
15701570
logMessageInfo.add(String.format("Volume [%s] (attached to VM [%s])", vol.getUuid(), volInstance.getUuid()));
15711571
} else {
1572-
logMessageInfo.add(String.format("Volume [%s]", vol.getUuid()));
1572+
logMessageInfo.add(String.format("Volume [%s] (attached VM with ID [%d] doesn't exists)", vol.getUuid(), vol.getInstanceId()));
15731573
}
15741574
} else {
15751575
logMessageInfo.add(String.format("Volume [%s] (not attached to any VM)", vol.getUuid()));

server/src/test/java/com/cloud/storage/StorageManagerImplTest.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -583,17 +583,21 @@ public void getStoragePoolNonDestroyedVolumesLogTestNonDestroyedVolumes_NotAttac
583583
}
584584

585585
@Test
586-
public void getStoragePoolNonDestroyedVolumesLogTestNonDestroyedVolumes_NoLog() {
586+
public void getStoragePoolNonDestroyedVolumesLogTestNonDestroyedVolumes_VMNotExistsLog() {
587587
Mockito.doReturn(1L).when(storagePoolVOMock).getId();
588588
Mockito.doReturn(1L).when(volume1VOMock).getInstanceId();
589+
Mockito.doReturn("786633d1-a942-4374-9d56-322dd4b0d202").when(volume1VOMock).getUuid();
589590
Mockito.doReturn(1L).when(volume2VOMock).getInstanceId();
591+
Mockito.doReturn("ffb46333-e983-4c21-b5f0-51c5877a3805").when(volume2VOMock).getUuid();
590592

591593
Mockito.when(_volumeDao.findByPoolId(storagePoolVOMock.getId(), null)).thenReturn(List.of(volume1VOMock, volume2VOMock));
592594
Mockito.doReturn(null).when(vmInstanceDao).findById(Mockito.anyLong());
593595

594596
String log = storageManagerImpl.getStoragePoolNonDestroyedVolumesLog(storagePoolVOMock.getId());
597+
String expected = String.format("[Volume [%s] (attached VM with ID [%d] doesn't exists), Volume [%s] (attached VM with ID [%d] doesn't exists)]",
598+
volume1VOMock.getUuid(), volume1VOMock.getInstanceId(), volume2VOMock.getUuid(), volume2VOMock.getInstanceId());
595599

596-
Assert.assertEquals("[]", log);
600+
Assert.assertEquals(expected, log);
597601
}
598602

599603
private ChangeStoragePoolScopeCmd mockChangeStoragePooolScopeCmd(String newScope) {

0 commit comments

Comments
 (0)