From 93de8e44e0555568c5c7373f321a63ad8c4a7276 Mon Sep 17 00:00:00 2001 From: Suresh Kumar Anaparti Date: Tue, 30 Dec 2025 14:31:27 +0530 Subject: [PATCH] Event typo fix --- .../ObjectInDataStoreStateMachine.java | 6 +-- .../manager/StorageCacheManagerImpl.java | 2 +- .../motion/AncientDataMotionStrategy.java | 4 +- .../StorageSystemDataMotionStrategy.java | 12 ++--- .../image/SecondaryStorageServiceImpl.java | 4 +- .../storage/image/TemplateServiceImpl.java | 14 +++--- .../snapshot/DefaultSnapshotStrategy.java | 2 +- .../storage/snapshot/SnapshotServiceImpl.java | 12 ++--- .../datastore/DataObjectManagerImpl.java | 8 ++-- .../ObjectInDataStoreManagerImpl.java | 16 +++---- .../storage/volume/VolumeObject.java | 2 +- .../storage/volume/VolumeServiceImpl.java | 48 +++++++++---------- .../storage/volume/VolumeObjectTest.java | 4 +- .../motion/StorPoolDataMotionStrategy.java | 4 +- .../snapshot/StorPoolSnapshotStrategy.java | 2 +- 15 files changed, 68 insertions(+), 72 deletions(-) diff --git a/engine/api/src/main/java/org/apache/cloudstack/engine/subsystem/api/storage/ObjectInDataStoreStateMachine.java b/engine/api/src/main/java/org/apache/cloudstack/engine/subsystem/api/storage/ObjectInDataStoreStateMachine.java index a8e80313768d..d4ca163e4e6f 100644 --- a/engine/api/src/main/java/org/apache/cloudstack/engine/subsystem/api/storage/ObjectInDataStoreStateMachine.java +++ b/engine/api/src/main/java/org/apache/cloudstack/engine/subsystem/api/storage/ObjectInDataStoreStateMachine.java @@ -33,9 +33,9 @@ enum State { Destroying("Template is destroying"), Destroyed("Template is destroyed"), Failed("Failed to download Template"); - String _description; + final String _description; - private State(String description) { + State(String description) { _description = description; } @@ -48,7 +48,7 @@ enum Event { CreateRequested, CreateOnlyRequested, DestroyRequested, - OperationSuccessed, + OperationSucceeded, OperationFailed, CopyRequested, CopyingRequested, diff --git a/engine/storage/cache/src/main/java/org/apache/cloudstack/storage/cache/manager/StorageCacheManagerImpl.java b/engine/storage/cache/src/main/java/org/apache/cloudstack/storage/cache/manager/StorageCacheManagerImpl.java index 889d0ce14ccc..21ef851fb2f2 100644 --- a/engine/storage/cache/src/main/java/org/apache/cloudstack/storage/cache/manager/StorageCacheManagerImpl.java +++ b/engine/storage/cache/src/main/java/org/apache/cloudstack/storage/cache/manager/StorageCacheManagerImpl.java @@ -323,7 +323,7 @@ public DataObject createCacheObject(DataObject data, DataStore store) { if (result.isFailed()) { objOnCacheStore.processEvent(Event.OperationFailed); } else { - objOnCacheStore.processEvent(Event.OperationSuccessed, result.getAnswer()); + objOnCacheStore.processEvent(Event.OperationSucceeded, result.getAnswer()); objOnCacheStore.incRefCount(); return objOnCacheStore; } diff --git a/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/AncientDataMotionStrategy.java b/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/AncientDataMotionStrategy.java index 0b0065361d07..b59ee2c61660 100644 --- a/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/AncientDataMotionStrategy.java +++ b/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/AncientDataMotionStrategy.java @@ -396,7 +396,7 @@ protected Answer copyVolumeBetweenPools(DataObject srcData, DataObject destData) return answer; } - objOnImageStore.processEvent(Event.OperationSuccessed, answer); + objOnImageStore.processEvent(Event.OperationSucceeded, answer); objOnImageStore.processEvent(Event.CopyingRequested); @@ -427,7 +427,7 @@ protected Answer copyVolumeBetweenPools(DataObject srcData, DataObject destData) throw e; } - objOnImageStore.processEvent(Event.OperationSuccessed); + objOnImageStore.processEvent(Event.OperationSucceeded); deleteVolumeOnSecondaryStore(objOnImageStore); return answer; } else { diff --git a/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/StorageSystemDataMotionStrategy.java b/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/StorageSystemDataMotionStrategy.java index cdf823eaf5b5..21a8655ca86d 100644 --- a/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/StorageSystemDataMotionStrategy.java +++ b/engine/storage/datamotion/src/main/java/org/apache/cloudstack/storage/motion/StorageSystemDataMotionStrategy.java @@ -1048,7 +1048,7 @@ private void handleCopyAsyncToSecondaryStorageAdaptive(SnapshotInfo snapshotInfo //submit processEvent if (StringUtils.isEmpty(errMsg)) { - snapshotInfo.processEvent(Event.OperationSuccessed); + snapshotInfo.processEvent(Event.OperationSucceeded); } else { snapshotInfo.processEvent(Event.OperationFailed); } @@ -1211,7 +1211,7 @@ else if (HypervisorType.VMware.equals(snapshotInfo.getHypervisorType()) || Hyper // command to copy this data from cache to secondary storage. We // then clean up the cache. - destOnStore.processEvent(Event.OperationSuccessed, copyCmdAnswer); + destOnStore.processEvent(Event.OperationSucceeded, copyCmdAnswer); CopyCommand cmd = new CopyCommand(destOnStore.getTO(), destData.getTO(), primaryStorageDownloadWait, VirtualMachineManager.ExecuteInSequence.value()); @@ -1261,7 +1261,7 @@ else if (HypervisorType.VMware.equals(snapshotInfo.getHypervisorType()) || Hyper try { if (StringUtils.isEmpty(errMsg)) { - snapshotInfo.processEvent(Event.OperationSuccessed); + snapshotInfo.processEvent(Event.OperationSucceeded); } else { snapshotInfo.processEvent(Event.OperationFailed); @@ -1394,7 +1394,7 @@ private void handleCreateNonManagedVolumeFromManagedSnapshot(SnapshotInfo snapsh try { if (StringUtils.isEmpty(errMsg)) { - snapshotInfo.processEvent(Event.OperationSuccessed); + snapshotInfo.processEvent(Event.OperationSucceeded); } else { snapshotInfo.processEvent(Event.OperationFailed); @@ -2316,7 +2316,7 @@ private void handlePostMigration(boolean success, Map sr _volumeDao.update(volumeVO.getId(), volumeVO); - _volumeService.copyPoliciesBetweenVolumesAndDestroySourceVolumeAfterMigration(Event.OperationSuccessed, null, srcVolumeInfo, destVolumeInfo, false); + _volumeService.copyPoliciesBetweenVolumesAndDestroySourceVolumeAfterMigration(Event.OperationSucceeded, null, srcVolumeInfo, destVolumeInfo, false); // Update the volume ID for snapshots on secondary storage @@ -2639,7 +2639,7 @@ private void handleCreateTemplateFromManagedVolume(VolumeInfo volumeInfo, Templa try { if (StringUtils.isEmpty(errMsg)) { - volumeInfo.processEvent(Event.OperationSuccessed); + volumeInfo.processEvent(Event.OperationSucceeded); } else { volumeInfo.processEvent(Event.OperationFailed); diff --git a/engine/storage/image/src/main/java/org/apache/cloudstack/storage/image/SecondaryStorageServiceImpl.java b/engine/storage/image/src/main/java/org/apache/cloudstack/storage/image/SecondaryStorageServiceImpl.java index 502bbaf9e49e..641a2a40dcd5 100644 --- a/engine/storage/image/src/main/java/org/apache/cloudstack/storage/image/SecondaryStorageServiceImpl.java +++ b/engine/storage/image/src/main/java/org/apache/cloudstack/storage/image/SecondaryStorageServiceImpl.java @@ -257,9 +257,9 @@ protected Void migrateDataCallBack(AsyncCallbackDispatcher getMapOfEvents( } mapOfEvents.put(ObjectInDataStoreStateMachine.Event.DestroyRequested, Volume.Event.DestroyRequested); mapOfEvents.put(ObjectInDataStoreStateMachine.Event.ExpungeRequested, Volume.Event.ExpungingRequested); - mapOfEvents.put(ObjectInDataStoreStateMachine.Event.OperationSuccessed, Volume.Event.OperationSucceeded); + mapOfEvents.put(ObjectInDataStoreStateMachine.Event.OperationSucceeded, Volume.Event.OperationSucceeded); mapOfEvents.put(ObjectInDataStoreStateMachine.Event.MigrationCopySucceeded, Volume.Event.MigrationCopySucceeded); mapOfEvents.put(ObjectInDataStoreStateMachine.Event.OperationFailed, Volume.Event.OperationFailed); mapOfEvents.put(ObjectInDataStoreStateMachine.Event.MigrationCopyFailed, Volume.Event.MigrationCopyFailed); diff --git a/engine/storage/volume/src/main/java/org/apache/cloudstack/storage/volume/VolumeServiceImpl.java b/engine/storage/volume/src/main/java/org/apache/cloudstack/storage/volume/VolumeServiceImpl.java index 9de56035aa26..eeac55be1412 100644 --- a/engine/storage/volume/src/main/java/org/apache/cloudstack/storage/volume/VolumeServiceImpl.java +++ b/engine/storage/volume/src/main/java/org/apache/cloudstack/storage/volume/VolumeServiceImpl.java @@ -324,7 +324,7 @@ protected Void createVolumeCallback(AsyncCallbackDispatcher copyManagedVolume(VolumeInfo srcVolume, logger.debug("Failed to create dest volume {}, volume can be removed", destVolume); destroyVolume(destVolume.getId()); destVolume.processEvent(Event.ExpungeRequested); - destVolume.processEvent(Event.OperationSuccessed); + destVolume.processEvent(Event.OperationSucceeded); volDao.remove(destVolume.getId()); throw new CloudRuntimeException("Creation of a dest volume failed: " + createVolumeResult.getResult()); } @@ -2156,7 +2156,7 @@ protected Void copyManagedVolumeCallBack(AsyncCallbackDispatcher entry : volumeToPool.entrySet()) { VolumeInfo volume = entry.getKey(); snapshotMgr.cleanupSnapshotsByVolume(volume.getId()); - volume.processEvent(Event.OperationSuccessed); + volume.processEvent(Event.OperationSucceeded); } future.complete(res); } @@ -2431,7 +2431,7 @@ protected Void registerVolumeCallback(AsyncCallbackDispatcher 0) { diff --git a/engine/storage/volume/src/test/java/org/apache/cloudstack/storage/volume/VolumeObjectTest.java b/engine/storage/volume/src/test/java/org/apache/cloudstack/storage/volume/VolumeObjectTest.java index 58f47a5db64e..5701bc49e15a 100644 --- a/engine/storage/volume/src/test/java/org/apache/cloudstack/storage/volume/VolumeObjectTest.java +++ b/engine/storage/volume/src/test/java/org/apache/cloudstack/storage/volume/VolumeObjectTest.java @@ -147,7 +147,7 @@ public void validateGetMapOfEventsDataStoreIsImage(){ expectedResult.put(ObjectInDataStoreStateMachine.Event.MigrationRequested, Volume.Event.CopyRequested); expectedResult.put(ObjectInDataStoreStateMachine.Event.DestroyRequested, Volume.Event.DestroyRequested); expectedResult.put(ObjectInDataStoreStateMachine.Event.ExpungeRequested, Volume.Event.ExpungingRequested); - expectedResult.put(ObjectInDataStoreStateMachine.Event.OperationSuccessed, Volume.Event.OperationSucceeded); + expectedResult.put(ObjectInDataStoreStateMachine.Event.OperationSucceeded, Volume.Event.OperationSucceeded); expectedResult.put(ObjectInDataStoreStateMachine.Event.MigrationCopySucceeded, Volume.Event.MigrationCopySucceeded); expectedResult.put(ObjectInDataStoreStateMachine.Event.OperationFailed, Volume.Event.OperationFailed); expectedResult.put(ObjectInDataStoreStateMachine.Event.MigrationCopyFailed, Volume.Event.MigrationCopyFailed); @@ -168,7 +168,7 @@ public void validateGetMapOfEventsDataStoreIsNotImage(){ expectedResult.put(ObjectInDataStoreStateMachine.Event.MigrationCopyRequested, Volume.Event.MigrationCopyRequested); expectedResult.put(ObjectInDataStoreStateMachine.Event.DestroyRequested, Volume.Event.DestroyRequested); expectedResult.put(ObjectInDataStoreStateMachine.Event.ExpungeRequested, Volume.Event.ExpungingRequested); - expectedResult.put(ObjectInDataStoreStateMachine.Event.OperationSuccessed, Volume.Event.OperationSucceeded); + expectedResult.put(ObjectInDataStoreStateMachine.Event.OperationSucceeded, Volume.Event.OperationSucceeded); expectedResult.put(ObjectInDataStoreStateMachine.Event.MigrationCopySucceeded, Volume.Event.MigrationCopySucceeded); expectedResult.put(ObjectInDataStoreStateMachine.Event.OperationFailed, Volume.Event.OperationFailed); expectedResult.put(ObjectInDataStoreStateMachine.Event.MigrationCopyFailed, Volume.Event.MigrationCopyFailed); diff --git a/plugins/storage/volume/storpool/src/main/java/org/apache/cloudstack/storage/motion/StorPoolDataMotionStrategy.java b/plugins/storage/volume/storpool/src/main/java/org/apache/cloudstack/storage/motion/StorPoolDataMotionStrategy.java index aa972d44343a..5a4802ab2640 100644 --- a/plugins/storage/volume/storpool/src/main/java/org/apache/cloudstack/storage/motion/StorPoolDataMotionStrategy.java +++ b/plugins/storage/volume/storpool/src/main/java/org/apache/cloudstack/storage/motion/StorPoolDataMotionStrategy.java @@ -453,8 +453,8 @@ private void handlePostMigration(boolean success, Map sr VolumeInfo destVolumeInfo = entry.getValue(); if (success) { - srcVolumeInfo.processEvent(Event.OperationSuccessed); - destVolumeInfo.processEvent(Event.OperationSuccessed); + srcVolumeInfo.processEvent(Event.OperationSucceeded); + destVolumeInfo.processEvent(Event.OperationSucceeded); _volumeDao.updateUuid(srcVolumeInfo.getId(), destVolumeInfo.getId()); diff --git a/plugins/storage/volume/storpool/src/main/java/org/apache/cloudstack/storage/snapshot/StorPoolSnapshotStrategy.java b/plugins/storage/volume/storpool/src/main/java/org/apache/cloudstack/storage/snapshot/StorPoolSnapshotStrategy.java index 5ec86df91e17..8a51e2672eab 100644 --- a/plugins/storage/volume/storpool/src/main/java/org/apache/cloudstack/storage/snapshot/StorPoolSnapshotStrategy.java +++ b/plugins/storage/volume/storpool/src/main/java/org/apache/cloudstack/storage/snapshot/StorPoolSnapshotStrategy.java @@ -201,7 +201,7 @@ private boolean deleteSnapshotChain(SnapshotInfo snapshot) { if (parent.getPath() != null && parent.getPath().equalsIgnoreCase(snapshot.getPath())) { logger.debug("for empty delta snapshot, only mark it as destroyed in db"); snapshot.processEvent(Event.DestroyRequested); - snapshot.processEvent(Event.OperationSuccessed); + snapshot.processEvent(Event.OperationSucceeded); deleted = true; if (!resultIsSet) { result = true;