Skip to content

Commit e3bc8f5

Browse files
committed
cleanup conflicting key
1 parent e2d790c commit e3bc8f5

File tree

5 files changed

+13
-69
lines changed

5 files changed

+13
-69
lines changed

api/src/main/java/org/apache/cloudstack/vm/UnmanagedVMsManager.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,15 @@ public interface UnmanagedVMsManager extends VmImportService, UnmanageVMService,
7070
ConfigKey.Scope.Global,
7171
null);
7272

73+
ConfigKey<Boolean> AllowImportVolumeWithBackingFile = new ConfigKey<>(Boolean.class,
74+
"allow.import.volume.with.backing.file",
75+
"Advanced",
76+
"false",
77+
"If enabled, allows QCOW2 volumes with backing files to be imported or unmanaged",
78+
true,
79+
ConfigKey.Scope.Global,
80+
null);
81+
7382
static boolean isSupported(Hypervisor.HypervisorType hypervisorType) {
7483
return hypervisorType == VMware || hypervisorType == KVM;
7584
}

server/src/main/java/org/apache/cloudstack/storage/volume/VolumeImportUnmanageManagerImpl.java

Lines changed: 3 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,8 @@
1717

1818
package org.apache.cloudstack.storage.volume;
1919

20+
import static org.apache.cloudstack.vm.UnmanagedVMsManager.AllowImportVolumeWithBackingFile;
21+
2022
import com.cloud.agent.AgentManager;
2123
import com.cloud.agent.api.Answer;
2224
import com.cloud.agent.api.GetVolumesOnStorageAnswer;
@@ -73,8 +75,6 @@
7375
import org.apache.cloudstack.storage.datastore.db.StoragePoolVO;
7476
import org.apache.cloudstack.utils.bytescale.ByteScaleUtils;
7577
import org.apache.commons.collections.CollectionUtils;
76-
import org.apache.cloudstack.framework.config.ConfigKey;
77-
import org.apache.cloudstack.framework.config.Configurable;
7878
import org.apache.commons.lang3.StringUtils;
7979
import org.apache.logging.log4j.LogManager;
8080
import org.apache.logging.log4j.Logger;
@@ -86,7 +86,7 @@
8686
import java.util.List;
8787
import java.util.Map;
8888

89-
public class VolumeImportUnmanageManagerImpl implements VolumeImportUnmanageService, Configurable {
89+
public class VolumeImportUnmanageManagerImpl implements VolumeImportUnmanageService {
9090
protected Logger logger = LogManager.getLogger(VolumeImportUnmanageManagerImpl.class);
9191

9292
@Inject
@@ -125,15 +125,6 @@ public class VolumeImportUnmanageManagerImpl implements VolumeImportUnmanageServ
125125
static final String DISK_OFFERING_NAME_SUFFIX_LOCAL = " - Local Storage";
126126
static final String DISK_OFFERING_UNIQUE_NAME_SUFFIX_LOCAL = "-Local";
127127

128-
ConfigKey<Boolean> AllowImportVolumeWithBackingFile = new ConfigKey<>(Boolean.class,
129-
"allow.import.volume.with.backing.file",
130-
"Advanced",
131-
"false",
132-
"If enabled, allows QCOW2 volumes with backing files to be imported or unmanaged",
133-
true,
134-
ConfigKey.Scope.Global,
135-
null);
136-
137128
protected void logFailureAndThrowException(String msg) {
138129
logger.error(msg);
139130
throw new CloudRuntimeException(msg);
@@ -524,14 +515,4 @@ private void unmanageVolumeFromDatabase(VolumeVO volume) {
524515
volume.setRemoved(new Date());
525516
volumeDao.update(volume.getId(), volume);
526517
}
527-
528-
@Override
529-
public String getConfigComponentName() {
530-
return VolumeImportUnmanageManagerImpl.class.getSimpleName();
531-
}
532-
533-
@Override
534-
public ConfigKey<?>[] getConfigKeys() {
535-
return new ConfigKey<?>[]{ AllowImportVolumeWithBackingFile };
536-
}
537518
}

server/src/main/java/org/apache/cloudstack/vm/UnmanagedVMsManagerImpl.java

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -220,15 +220,6 @@ public class UnmanagedVMsManagerImpl implements UnmanagedVMsManager {
220220
ConfigKey.Scope.Global,
221221
null);
222222

223-
ConfigKey<Boolean> AllowImportVolumeWithBackingFile = new ConfigKey<>(Boolean.class,
224-
"allow.import.volume.with.backing.file",
225-
"Advanced",
226-
"false",
227-
"If enabled, allows QCOW2 volumes with backing files to be imported or unmanaged",
228-
true,
229-
ConfigKey.Scope.Global,
230-
null);
231-
232223
ConfigKey<String> ConvertVmwareInstanceToKvmExtraParamsAllowedList = new ConfigKey<>(ConfigKey.CATEGORY_ADVANCED,
233224
String.class,
234225
"convert.vmware.instance.to.kvm.extra.params.allowed.list",
@@ -2898,7 +2889,7 @@ private UserVm importKvmVirtualMachineFromDisk(final ImportSource importSource,
28982889
return userVm;
28992890
}
29002891

2901-
protected void checkVolume(Map<VolumeOnStorageTO.Detail, String> volumeDetails) {
2892+
private void checkVolume(Map<VolumeOnStorageTO.Detail, String> volumeDetails) {
29022893
if (MapUtils.isEmpty(volumeDetails)) {
29032894
return;
29042895
}

server/src/test/java/org/apache/cloudstack/storage/volume/VolumeImportUnmanageManagerImplTest.java

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,6 @@
6161
import org.apache.cloudstack.api.response.VolumeForImportResponse;
6262
import org.apache.cloudstack.api.response.VolumeResponse;
6363
import org.apache.cloudstack.context.CallContext;
64-
import org.apache.cloudstack.framework.config.ConfigKey;
6564
import org.apache.cloudstack.engine.orchestration.service.VolumeOrchestrationService;
6665
import org.apache.cloudstack.storage.datastore.db.PrimaryDataStoreDao;
6766
import org.apache.cloudstack.storage.datastore.db.SnapshotDataStoreDao;
@@ -135,8 +134,6 @@ public class VolumeImportUnmanageManagerImplTest {
135134
private VolumeApiService volumeApiService;
136135
@Mock
137136
private SnapshotDataStoreDao snapshotDataStoreDao;
138-
@Mock
139-
private ConfigKey<Boolean> mockAllowImportVolumeWithBackingFile;
140137

141138
@Mock
142139
StoragePoolVO storagePoolVO;
@@ -346,8 +343,6 @@ public void testCheckIfVolumeIsEncrypted() {
346343

347344
@Test
348345
public void testCheckIfVolumeHasBackingFile() {
349-
volumeImportUnmanageManager.AllowImportVolumeWithBackingFile = mockAllowImportVolumeWithBackingFile;
350-
Mockito.when(mockAllowImportVolumeWithBackingFile.value()).thenReturn(false);
351346
try {
352347
VolumeOnStorageTO volumeOnStorageTO = new VolumeOnStorageTO(hypervisorType, path, name, fullPath,
353348
format, size, virtualSize);
@@ -361,17 +356,6 @@ public void testCheckIfVolumeHasBackingFile() {
361356
}
362357
}
363358

364-
@Test
365-
public void testCheckIfVolumeHasBackingFileAllowEnabled() {
366-
volumeImportUnmanageManager.AllowImportVolumeWithBackingFile = mockAllowImportVolumeWithBackingFile;
367-
Mockito.when(mockAllowImportVolumeWithBackingFile.value()).thenReturn(true);
368-
VolumeOnStorageTO volumeOnStorageTO = new VolumeOnStorageTO(hypervisorType, path, name, fullPath,
369-
format, size, virtualSize);
370-
volumeOnStorageTO.addDetail(VolumeOnStorageTO.Detail.BACKING_FILE, BACKING_FILE);
371-
volumeOnStorageTO.addDetail(VolumeOnStorageTO.Detail.BACKING_FILE_FORMAT, BACKING_FILE_FORMAT);
372-
volumeImportUnmanageManager.checkIfVolumeHasBackingFile(volumeOnStorageTO);
373-
}
374-
375359
@Test
376360
public void testUnmanageVolume() {
377361
when(volumeVO.getState()).thenReturn(Volume.State.Ready);

server/src/test/java/org/apache/cloudstack/vm/UnmanagedVMsManagerImplTest.java

Lines changed: 0 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -171,7 +171,6 @@
171171
import com.cloud.vm.dao.UserVmDao;
172172
import com.cloud.vm.dao.VMInstanceDao;
173173
import com.cloud.vm.dao.VMInstanceDetailsDao;
174-
import org.apache.cloudstack.storage.volume.VolumeOnStorageTO;
175174

176175
@RunWith(MockitoJUnitRunner.class)
177176
public class UnmanagedVMsManagerImplTest {
@@ -258,8 +257,6 @@ public class UnmanagedVMsManagerImplTest {
258257
private ConfigKey<Boolean> configKeyMockParamsAllowed;
259258
@Mock
260259
private ConfigKey<String> configKeyMockParamsAllowedList;
261-
@Mock
262-
private ConfigKey<Boolean> configKeyMockAllowBackingFile;
263260

264261
private static final long virtualMachineId = 1L;
265262

@@ -1354,22 +1351,4 @@ public void testAddServiceOfferingDetailsToParamsCustomUnconstrainedOffering() {
13541351
Assert.assertFalse(params.containsKey(VmDetailConstants.CPU_SPEED));
13551352
Assert.assertFalse(params.containsKey(VmDetailConstants.MEMORY));
13561353
}
1357-
1358-
@Test(expected = CloudRuntimeException.class)
1359-
public void testCheckVolumeWithBackingFileSettingDisabled() {
1360-
unmanagedVMsManager.AllowImportVolumeWithBackingFile = configKeyMockAllowBackingFile;
1361-
Mockito.when(configKeyMockAllowBackingFile.value()).thenReturn(false);
1362-
Map<VolumeOnStorageTO.Detail, String> details = new HashMap<>();
1363-
details.put(VolumeOnStorageTO.Detail.BACKING_FILE, "backing.qcow2");
1364-
unmanagedVMsManager.checkVolume(details);
1365-
}
1366-
1367-
@Test
1368-
public void testCheckVolumeWithBackingFileSettingEnabled() {
1369-
unmanagedVMsManager.AllowImportVolumeWithBackingFile = configKeyMockAllowBackingFile;
1370-
Mockito.when(configKeyMockAllowBackingFile.value()).thenReturn(true);
1371-
Map<VolumeOnStorageTO.Detail, String> details = new HashMap<>();
1372-
details.put(VolumeOnStorageTO.Detail.BACKING_FILE, "backing.qcow2");
1373-
unmanagedVMsManager.checkVolume(details);
1374-
}
13751354
}

0 commit comments

Comments
 (0)