http://git-wip-us.apache.org/repos/asf/cloudstack/blob/8bc02940/server/src/com/cloud/storage/StorageManagerImpl.java ---------------------------------------------------------------------- diff --git a/server/src/com/cloud/storage/StorageManagerImpl.java b/server/src/com/cloud/storage/StorageManagerImpl.java index ffcbf86..ba39e1f 100644 --- a/server/src/com/cloud/storage/StorageManagerImpl.java +++ b/server/src/com/cloud/storage/StorageManagerImpl.java @@ -43,6 +43,7 @@ import javax.naming.ConfigurationException; import com.cloud.hypervisor.Hypervisor; +import org.apache.log4j.Logger; import org.springframework.stereotype.Component; import org.apache.cloudstack.api.command.admin.storage.CancelPrimaryStorageMaintenanceCmd; import org.apache.cloudstack.api.command.admin.storage.CreateSecondaryStagingStoreCmd; @@ -190,6 +191,7 @@ import com.cloud.vm.dao.VMInstanceDao; @Component @Local(value = {StorageManager.class, StorageService.class}) public class StorageManagerImpl extends ManagerBase implements StorageManager, ClusterManagerListener { + private static final Logger s_logger = Logger.getLogger(StorageManagerImpl.class); protected String _name; @Inject @@ -323,7 +325,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C // available for (VolumeVO vol : vols) { if (vol.getRemoved() != null) { - logger.warn("Volume id:" + vol.getId() + " is removed, cannot share on this instance"); + s_logger.warn("Volume id:" + vol.getId() + " is removed, cannot share on this instance"); // not ok to share return false; } @@ -456,7 +458,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C Map<String, String> configs = _configDao.getConfiguration("management-server", params); _storagePoolAcquisitionWaitSeconds = NumbersUtil.parseInt(configs.get("pool.acquisition.wait.seconds"), 1800); - logger.info("pool.acquisition.wait.seconds is configured as " + _storagePoolAcquisitionWaitSeconds + " seconds"); + s_logger.info("pool.acquisition.wait.seconds is configured as " + _storagePoolAcquisitionWaitSeconds + " seconds"); _agentMgr.registerForHostEvents(new StoragePoolMonitor(this, _storagePoolDao), true, false, true); @@ -469,7 +471,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C String time = configs.get("storage.cleanup.interval"); _storageCleanupInterval = NumbersUtil.parseInt(time, 86400); - logger.info("Storage cleanup enabled: " + _storageCleanupEnabled + ", interval: " + _storageCleanupInterval + ", template cleanup enabled: " + + s_logger.info("Storage cleanup enabled: " + _storageCleanupEnabled + ", interval: " + _storageCleanupInterval + ", template cleanup enabled: " + _templateCleanupEnabled); String cleanupInterval = configs.get("extract.url.cleanup.interval"); @@ -528,7 +530,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C int initialDelay = generator.nextInt(_storageCleanupInterval); _executor.scheduleWithFixedDelay(new StorageGarbageCollector(), initialDelay, _storageCleanupInterval, TimeUnit.SECONDS); } else { - logger.debug("Storage cleanup is not enabled, so the storage cleanup thread is not being scheduled."); + s_logger.debug("Storage cleanup is not enabled, so the storage cleanup thread is not being scheduled."); } _executor.scheduleWithFixedDelay(new DownloadURLGarbageCollector(), _downloadUrlCleanupInterval, _downloadUrlCleanupInterval, TimeUnit.SECONDS); @@ -582,7 +584,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C pool = _storagePoolDao.findPoolByHostPath(host.getDataCenterId(), host.getPodId(), hostAddress, null, pInfo.getUuid()); if (pool != null) { - logger.debug("Found a storage pool: " + pInfo.getUuid() + ", but with different hostpath " + pInfo.getHostPath() + ", still treat it as the same pool"); + s_logger.debug("Found a storage pool: " + pInfo.getUuid() + ", but with different hostpath " + pInfo.getHostPath() + ", still treat it as the same pool"); } } @@ -613,7 +615,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } } catch (Exception e) { - logger.warn("Unable to setup the local storage pool for " + host, e); + s_logger.warn("Unable to setup the local storage pool for " + host, e); throw new ConnectionException(true, "Unable to setup the local storage pool for " + host, e); } @@ -709,7 +711,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C lifeCycle.attachZone(store, zoneScope, hypervisorType); } } catch (Exception e) { - logger.debug("Failed to add data store: "+e.getMessage(), e); + s_logger.debug("Failed to add data store: "+e.getMessage(), e); try { // clean up the db, just absorb the exception thrown in deletion with error logged, so that user can get error for adding data store // not deleting data store. @@ -717,7 +719,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C lifeCycle.deleteDataStore(store); } } catch (Exception ex) { - logger.debug("Failed to clean up storage pool: " + ex.getMessage()); + s_logger.debug("Failed to clean up storage pool: " + ex.getMessage()); } throw new CloudRuntimeException("Failed to add data store: "+e.getMessage(), e); } @@ -882,15 +884,15 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C StoragePoolVO sPool = _storagePoolDao.findById(id); if (sPool == null) { - logger.warn("Unable to find pool:" + id); + s_logger.warn("Unable to find pool:" + id); throw new InvalidParameterValueException("Unable to find pool by id " + id); } if (sPool.getStatus() != StoragePoolStatus.Maintenance) { - logger.warn("Unable to delete storage id: " + id + " due to it is not in Maintenance state"); + s_logger.warn("Unable to delete storage id: " + id + " due to it is not in Maintenance state"); throw new InvalidParameterValueException("Unable to delete storage due to it is not in Maintenance state, id: " + id); } if (sPool.isLocal()) { - logger.warn("Unable to delete local storage id:" + id); + s_logger.warn("Unable to delete local storage id:" + id); throw new InvalidParameterValueException("Unable to delete local storage id: " + id); } @@ -908,9 +910,9 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C try { future.get(); } catch (InterruptedException e) { - logger.debug("expunge volume failed:" + vol.getId(), e); + s_logger.debug("expunge volume failed:" + vol.getId(), e); } catch (ExecutionException e) { - logger.debug("expunge volume failed:" + vol.getId(), e); + s_logger.debug("expunge volume failed:" + vol.getId(), e); } } } @@ -926,14 +928,14 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C StoragePoolVO lock = _storagePoolDao.acquireInLockTable(sPool.getId()); if (lock == null) { - if (logger.isDebugEnabled()) { - logger.debug("Failed to acquire lock when deleting PrimaryDataStoreVO with ID: " + sPool.getId()); + if (s_logger.isDebugEnabled()) { + s_logger.debug("Failed to acquire lock when deleting PrimaryDataStoreVO with ID: " + sPool.getId()); } return false; } _storagePoolDao.releaseFromLockTable(lock.getId()); - logger.trace("Released lock for storage pool " + id); + s_logger.trace("Released lock for storage pool " + id); DataStoreProvider storeProvider = _dataStoreProviderMgr.getDataStoreProvider(sPool.getStorageProviderName()); DataStoreLifeCycle lifeCycle = storeProvider.getDataStoreLifeCycle(); @@ -945,7 +947,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C public void connectHostToSharedPool(long hostId, long poolId) throws StorageUnavailableException, StorageConflictException { StoragePool pool = (StoragePool)_dataStoreMgr.getDataStore(poolId, DataStoreRole.Primary); assert (pool.isShared()) : "Now, did you actually read the name of this method?"; - logger.debug("Adding pool " + pool.getName() + " to host " + hostId); + s_logger.debug("Adding pool " + pool.getName() + " to host " + hostId); DataStoreProvider provider = _dataStoreProviderMgr.getDataStoreProvider(pool.getStorageProviderName()); HypervisorHostListener listener = hostListeners.get(provider.getName()); @@ -971,15 +973,15 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C // All this is for the inaccuracy of floats for big number multiplication. BigDecimal overProvFactor = getStorageOverProvisioningFactor(storagePool.getId()); totalOverProvCapacity = overProvFactor.multiply(new BigDecimal(storagePool.getCapacityBytes())).longValue(); - logger.debug("Found storage pool " + storagePool.getName() + " of type " + storagePool.getPoolType().toString() + " with overprovisioning factor " + s_logger.debug("Found storage pool " + storagePool.getName() + " of type " + storagePool.getPoolType().toString() + " with overprovisioning factor " + overProvFactor.toString()); - logger.debug("Total over provisioned capacity calculated is " + overProvFactor + " * " + storagePool.getCapacityBytes()); + s_logger.debug("Total over provisioned capacity calculated is " + overProvFactor + " * " + storagePool.getCapacityBytes()); } else { - logger.debug("Found storage pool " + storagePool.getName() + " of type " + storagePool.getPoolType().toString()); + s_logger.debug("Found storage pool " + storagePool.getName() + " of type " + storagePool.getPoolType().toString()); totalOverProvCapacity = storagePool.getCapacityBytes(); } - logger.debug("Total over provisioned capacity of the pool " + storagePool.getName() + " id: " + storagePool.getId() + " is " + totalOverProvCapacity); + s_logger.debug("Total over provisioned capacity of the pool " + storagePool.getName() + " id: " + storagePool.getId() + " is " + totalOverProvCapacity); CapacityState capacityState = CapacityState.Enabled; if (storagePool.getScope() == ScopeType.ZONE) { DataCenterVO dc = ApiDBUtils.findZoneById(storagePool.getDataCenterId()); @@ -1009,7 +1011,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C _capacityDao.update(capacity.getId(), capacity); } } - logger.debug("Successfully set Capacity - " + totalOverProvCapacity + " for capacity type - " + capacityType + " , DataCenterId - " + + s_logger.debug("Successfully set Capacity - " + totalOverProvCapacity + " for capacity type - " + capacityType + " , DataCenterId - " + storagePool.getDataCenterId() + ", HostOrPoolId - " + storagePool.getId() + ", PodId " + storagePool.getPodId()); } @@ -1052,9 +1054,9 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } return new Pair<Long, Answer[]>(hostId, answers.toArray(new Answer[answers.size()])); } catch (AgentUnavailableException e) { - logger.debug("Unable to send storage pool command to " + pool + " via " + hostId, e); + s_logger.debug("Unable to send storage pool command to " + pool + " via " + hostId, e); } catch (OperationTimedoutException e) { - logger.debug("Unable to send storage pool command to " + pool + " via " + hostId, e); + s_logger.debug("Unable to send storage pool command to " + pool + " via " + hostId, e); } } @@ -1082,11 +1084,11 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C try { List<VMTemplateStoragePoolVO> unusedTemplatesInPool = _tmpltMgr.getUnusedTemplatesInPool(pool); - logger.debug("Storage pool garbage collector found " + unusedTemplatesInPool.size() + " templates to clean up in storage pool: " + + s_logger.debug("Storage pool garbage collector found " + unusedTemplatesInPool.size() + " templates to clean up in storage pool: " + pool.getName()); for (VMTemplateStoragePoolVO templatePoolVO : unusedTemplatesInPool) { if (templatePoolVO.getDownloadState() != VMTemplateStorageResourceAssoc.Status.DOWNLOADED) { - logger.debug("Storage pool garbage collector is skipping template with ID: " + templatePoolVO.getTemplateId() + + s_logger.debug("Storage pool garbage collector is skipping template with ID: " + templatePoolVO.getTemplateId() + " on pool " + templatePoolVO.getPoolId() + " because it is not completely downloaded."); continue; } @@ -1094,7 +1096,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C if (!templatePoolVO.getMarkedForGC()) { templatePoolVO.setMarkedForGC(true); _vmTemplatePoolDao.update(templatePoolVO.getId(), templatePoolVO); - logger.debug("Storage pool garbage collector has marked template with ID: " + templatePoolVO.getTemplateId() + + s_logger.debug("Storage pool garbage collector has marked template with ID: " + templatePoolVO.getTemplateId() + " on pool " + templatePoolVO.getPoolId() + " for garbage collection."); continue; } @@ -1102,7 +1104,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C _tmpltMgr.evictTemplateFromStoragePool(templatePoolVO); } } catch (Exception e) { - logger.warn("Problem cleaning up primary storage pool " + pool, e); + s_logger.warn("Problem cleaning up primary storage pool " + pool, e); } } } @@ -1114,7 +1116,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C try { volService.expungeVolumeAsync(volFactory.getVolume(vol.getId())); } catch (Exception e) { - logger.warn("Unable to destroy volume " + vol.getUuid(), e); + s_logger.warn("Unable to destroy volume " + vol.getUuid(), e); } } @@ -1128,7 +1130,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } _snapshotDao.expunge(snapshotVO.getId()); } catch (Exception e) { - logger.warn("Unable to destroy snapshot " + snapshotVO.getUuid(), e); + s_logger.warn("Unable to destroy snapshot " + snapshotVO.getUuid(), e); } } @@ -1137,21 +1139,21 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C for (VolumeDataStoreVO volumeDataStore : volumeDataStores) { VolumeVO volume = _volumeDao.findById(volumeDataStore.getVolumeId()); if (volume == null) { - logger.warn("Uploaded volume with id " + volumeDataStore.getVolumeId() + " not found, so cannot be destroyed"); + s_logger.warn("Uploaded volume with id " + volumeDataStore.getVolumeId() + " not found, so cannot be destroyed"); continue; } try { DataStore dataStore = _dataStoreMgr.getDataStore(volumeDataStore.getDataStoreId(), DataStoreRole.Image); EndPoint ep = _epSelector.select(dataStore, volumeDataStore.getExtractUrl()); if (ep == null) { - logger.warn("There is no secondary storage VM for image store " + dataStore.getName() + ", cannot destroy uploaded volume " + volume.getUuid()); + s_logger.warn("There is no secondary storage VM for image store " + dataStore.getName() + ", cannot destroy uploaded volume " + volume.getUuid()); continue; } Host host = _hostDao.findById(ep.getId()); if (host != null && host.getManagementServerId() != null) { if (_serverId == host.getManagementServerId().longValue()) { if (!volService.destroyVolume(volume.getId())) { - logger.warn("Unable to destroy uploaded volume " + volume.getUuid()); + s_logger.warn("Unable to destroy uploaded volume " + volume.getUuid()); continue; } // decrement volume resource count @@ -1159,17 +1161,17 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C // expunge volume from secondary if volume is on image store VolumeInfo volOnSecondary = volFactory.getVolume(volume.getId(), DataStoreRole.Image); if (volOnSecondary != null) { - logger.info("Expunging volume " + volume.getUuid() + " uploaded using HTTP POST from secondary data store"); + s_logger.info("Expunging volume " + volume.getUuid() + " uploaded using HTTP POST from secondary data store"); AsyncCallFuture<VolumeApiResult> future = volService.expungeVolumeAsync(volOnSecondary); VolumeApiResult result = future.get(); if (!result.isSuccess()) { - logger.warn("Failed to expunge volume " + volume.getUuid() + " from the image store " + dataStore.getName() + " due to: " + result.getResult()); + s_logger.warn("Failed to expunge volume " + volume.getUuid() + " from the image store " + dataStore.getName() + " due to: " + result.getResult()); } } } } } catch (Throwable th) { - logger.warn("Unable to destroy uploaded volume " + volume.getUuid() + ". Error details: " + th.getMessage()); + s_logger.warn("Unable to destroy uploaded volume " + volume.getUuid() + ". Error details: " + th.getMessage()); } } @@ -1178,14 +1180,14 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C for (TemplateDataStoreVO templateDataStore : templateDataStores) { VMTemplateVO template = _templateDao.findById(templateDataStore.getTemplateId()); if (template == null) { - logger.warn("Uploaded template with id " + templateDataStore.getTemplateId() + " not found, so cannot be destroyed"); + s_logger.warn("Uploaded template with id " + templateDataStore.getTemplateId() + " not found, so cannot be destroyed"); continue; } try { DataStore dataStore = _dataStoreMgr.getDataStore(templateDataStore.getDataStoreId(), DataStoreRole.Image); EndPoint ep = _epSelector.select(dataStore, templateDataStore.getExtractUrl()); if (ep == null) { - logger.warn("There is no secondary storage VM for image store " + dataStore.getName() + ", cannot destroy uploaded template " + template.getUuid()); + s_logger.warn("There is no secondary storage VM for image store " + dataStore.getName() + ", cannot destroy uploaded template " + template.getUuid()); continue; } Host host = _hostDao.findById(ep.getId()); @@ -1194,7 +1196,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C AsyncCallFuture<TemplateApiResult> future = _imageSrv.deleteTemplateAsync(tmplFactory.getTemplate(template.getId(), dataStore)); TemplateApiResult result = future.get(); if (!result.isSuccess()) { - logger.warn("Failed to delete template " + template.getUuid() + " from the image store " + dataStore.getName() + " due to: " + result.getResult()); + s_logger.warn("Failed to delete template " + template.getUuid() + " from the image store " + dataStore.getName() + " due to: " + result.getResult()); continue; } // remove from template_zone_ref @@ -1218,7 +1220,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } } } catch (Throwable th) { - logger.warn("Unable to destroy uploaded template " + template.getUuid() + ". Error details: " + th.getMessage()); + s_logger.warn("Unable to destroy uploaded template " + template.getUuid() + ". Error details: " + th.getMessage()); } } } finally { @@ -1246,7 +1248,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } return list; } catch (Exception e) { - logger.debug("failed to get all volumes who has snapshots in secondary storage " + storeId + " due to " + e.getMessage()); + s_logger.debug("failed to get all volumes who has snapshots in secondary storage " + storeId + " due to " + e.getMessage()); return null; } @@ -1267,7 +1269,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } return list; } catch (Exception e) { - logger.debug("failed to get all snapshots for a volume " + volumeId + " due to " + e.getMessage()); + s_logger.debug("failed to get all snapshots for a volume " + volumeId + " due to " + e.getMessage()); return null; } } @@ -1284,16 +1286,16 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C try { long storeId = store.getId(); List<TemplateDataStoreVO> destroyedTemplateStoreVOs = _templateStoreDao.listDestroyed(storeId); - logger.debug("Secondary storage garbage collector found " + destroyedTemplateStoreVOs.size() + + s_logger.debug("Secondary storage garbage collector found " + destroyedTemplateStoreVOs.size() + " templates to cleanup on template_store_ref for store: " + store.getName()); for (TemplateDataStoreVO destroyedTemplateStoreVO : destroyedTemplateStoreVOs) { - if (logger.isDebugEnabled()) { - logger.debug("Deleting template store DB entry: " + destroyedTemplateStoreVO); + if (s_logger.isDebugEnabled()) { + s_logger.debug("Deleting template store DB entry: " + destroyedTemplateStoreVO); } _templateStoreDao.remove(destroyedTemplateStoreVO.getId()); } } catch (Exception e) { - logger.warn("problem cleaning up templates in template_store_ref for store: " + store.getName(), e); + s_logger.warn("problem cleaning up templates in template_store_ref for store: " + store.getName(), e); } } @@ -1301,18 +1303,18 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C for (DataStore store : imageStores) { try { List<SnapshotDataStoreVO> destroyedSnapshotStoreVOs = _snapshotStoreDao.listDestroyed(store.getId()); - logger.debug("Secondary storage garbage collector found " + destroyedSnapshotStoreVOs.size() + + s_logger.debug("Secondary storage garbage collector found " + destroyedSnapshotStoreVOs.size() + " snapshots to cleanup on snapshot_store_ref for store: " + store.getName()); for (SnapshotDataStoreVO destroyedSnapshotStoreVO : destroyedSnapshotStoreVOs) { // check if this snapshot has child SnapshotInfo snap = snapshotFactory.getSnapshot(destroyedSnapshotStoreVO.getSnapshotId(), store); if (snap.getChild() != null) { - logger.debug("Skip snapshot on store: " + destroyedSnapshotStoreVO + " , because it has child"); + s_logger.debug("Skip snapshot on store: " + destroyedSnapshotStoreVO + " , because it has child"); continue; } - if (logger.isDebugEnabled()) { - logger.debug("Deleting snapshot store DB entry: " + destroyedSnapshotStoreVO); + if (s_logger.isDebugEnabled()) { + s_logger.debug("Deleting snapshot store DB entry: " + destroyedSnapshotStoreVO); } _snapshotDao.remove(destroyedSnapshotStoreVO.getSnapshotId()); @@ -1324,7 +1326,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } } catch (Exception e2) { - logger.warn("problem cleaning up snapshots in snapshot_store_ref for store: " + store.getName(), e2); + s_logger.warn("problem cleaning up snapshots in snapshot_store_ref for store: " + store.getName(), e2); } } @@ -1333,21 +1335,21 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C for (DataStore store : imageStores) { try { List<VolumeDataStoreVO> destroyedStoreVOs = _volumeStoreDao.listDestroyed(store.getId()); - logger.debug("Secondary storage garbage collector found " + destroyedStoreVOs.size() + " volumes to cleanup on volume_store_ref for store: " + + s_logger.debug("Secondary storage garbage collector found " + destroyedStoreVOs.size() + " volumes to cleanup on volume_store_ref for store: " + store.getName()); for (VolumeDataStoreVO destroyedStoreVO : destroyedStoreVOs) { - if (logger.isDebugEnabled()) { - logger.debug("Deleting volume store DB entry: " + destroyedStoreVO); + if (s_logger.isDebugEnabled()) { + s_logger.debug("Deleting volume store DB entry: " + destroyedStoreVO); } _volumeStoreDao.remove(destroyedStoreVO.getId()); } } catch (Exception e2) { - logger.warn("problem cleaning up volumes in volume_store_ref for store: " + store.getName(), e2); + s_logger.warn("problem cleaning up volumes in volume_store_ref for store: " + store.getName(), e2); } } } catch (Exception e3) { - logger.warn("problem cleaning up secondary storage DB entries. ", e3); + s_logger.warn("problem cleaning up secondary storage DB entries. ", e3); } } @@ -1371,7 +1373,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C if (primaryStorage == null) { String msg = "Unable to obtain lock on the storage pool record in preparePrimaryStorageForMaintenance()"; - logger.error(msg); + s_logger.error(msg); throw new InvalidParameterValueException(msg); } @@ -1398,7 +1400,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C if (primaryStorage == null) { String msg = "Unable to obtain lock on the storage pool in cancelPrimaryStorageForMaintenance()"; - logger.error(msg); + s_logger.error(msg); throw new InvalidParameterValueException(msg); } @@ -1424,12 +1426,12 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C @Override protected void runInContext() { try { - logger.trace("Storage Garbage Collection Thread is running."); + s_logger.trace("Storage Garbage Collection Thread is running."); cleanupStorage(true); } catch (Exception e) { - logger.error("Caught the following Exception", e); + s_logger.error("Caught the following Exception", e); } } } @@ -1444,7 +1446,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C public void onManagementNodeLeft(List<? extends ManagementServerHost> nodeList, long selfNodeId) { for (ManagementServerHost vo : nodeList) { if (vo.getMsid() == _serverId) { - logger.info("Cleaning up storage maintenance jobs associated with Management server: " + vo.getMsid()); + s_logger.info("Cleaning up storage maintenance jobs associated with Management server: " + vo.getMsid()); List<Long> poolIds = _storagePoolWorkDao.searchForPoolIdsForPendingWorkJobs(vo.getMsid()); if (poolIds.size() > 0) { for (Long poolId : poolIds) { @@ -1608,7 +1610,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C throw new InvalidParameterValueException("can not change old scheme:" + oldUri.getScheme() + " to " + uri.getScheme()); } } catch (URISyntaxException e) { - logger.debug("Failed to get uri from " + oldUrl); + s_logger.debug("Failed to get uri from " + oldUrl); } secHost.setStorageUrl(newUrl); @@ -1651,13 +1653,13 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } if (stats != null) { double usedPercentage = ((double)stats.getByteUsed() / (double)totalSize); - if (logger.isDebugEnabled()) { - logger.debug("Checking pool " + pool.getId() + " for storage, totalSize: " + pool.getCapacityBytes() + ", usedBytes: " + stats.getByteUsed() + + if (s_logger.isDebugEnabled()) { + s_logger.debug("Checking pool " + pool.getId() + " for storage, totalSize: " + pool.getCapacityBytes() + ", usedBytes: " + stats.getByteUsed() + ", usedPct: " + usedPercentage + ", disable threshold: " + storageUsedThreshold); } if (usedPercentage >= storageUsedThreshold) { - if (logger.isDebugEnabled()) { - logger.debug("Insufficient space on pool: " + pool.getId() + " since its usage percentage: " + usedPercentage + + if (s_logger.isDebugEnabled()) { + s_logger.debug("Insufficient space on pool: " + pool.getId() + " since its usage percentage: " + usedPercentage + " has crossed the pool.storage.capacity.disablethreshold: " + storageUsedThreshold); } return false; @@ -1677,7 +1679,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C // Only IOPS guaranteed primary storage like SolidFire is using/setting IOPS. // This check returns true for storage that does not specify IOPS. if (pool.getCapacityIops() == null ) { - logger.info("Storage pool " + pool.getName() + " (" + pool.getId() + ") does not supply IOPS capacity, assuming enough capacity"); + s_logger.info("Storage pool " + pool.getName() + " (" + pool.getId() + ") does not supply IOPS capacity, assuming enough capacity"); return true; } @@ -1743,26 +1745,26 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C if (pool.getPoolType() == StoragePoolType.NetworkFilesystem || pool.getPoolType() == StoragePoolType.VMFS || pool.getPoolType() == StoragePoolType.Filesystem) { BigDecimal overProvFactor = getStorageOverProvisioningFactor(pool.getId()); totalOverProvCapacity = overProvFactor.multiply(new BigDecimal(pool.getCapacityBytes())).longValue(); - logger.debug("Found storage pool " + poolVO.getName() + " of type " + pool.getPoolType().toString() + " with overprovisioning factor " + s_logger.debug("Found storage pool " + poolVO.getName() + " of type " + pool.getPoolType().toString() + " with overprovisioning factor " + overProvFactor.toString()); - logger.debug("Total over provisioned capacity calculated is " + overProvFactor + " * " + pool.getCapacityBytes()); + s_logger.debug("Total over provisioned capacity calculated is " + overProvFactor + " * " + pool.getCapacityBytes()); } else { totalOverProvCapacity = pool.getCapacityBytes(); - logger.debug("Found storage pool " + poolVO.getName() + " of type " + pool.getPoolType().toString()); + s_logger.debug("Found storage pool " + poolVO.getName() + " of type " + pool.getPoolType().toString()); } - logger.debug("Total capacity of the pool " + poolVO.getName() + " id: " + pool.getId() + " is " + totalOverProvCapacity); + s_logger.debug("Total capacity of the pool " + poolVO.getName() + " id: " + pool.getId() + " is " + totalOverProvCapacity); double storageAllocatedThreshold = CapacityManager.StorageAllocatedCapacityDisableThreshold.valueIn(pool.getDataCenterId()); - if (logger.isDebugEnabled()) { - logger.debug("Checking pool: " + pool.getId() + " for volume allocation " + volumes.toString() + ", maxSize : " + totalOverProvCapacity + + if (s_logger.isDebugEnabled()) { + s_logger.debug("Checking pool: " + pool.getId() + " for volume allocation " + volumes.toString() + ", maxSize : " + totalOverProvCapacity + ", totalAllocatedSize : " + allocatedSizeWithtemplate + ", askingSize : " + totalAskingSize + ", allocated disable threshold: " + storageAllocatedThreshold); } double usedPercentage = (allocatedSizeWithtemplate + totalAskingSize) / (double)(totalOverProvCapacity); if (usedPercentage > storageAllocatedThreshold) { - if (logger.isDebugEnabled()) { - logger.debug("Insufficient un-allocated capacity on: " + pool.getId() + " for volume allocation: " + volumes.toString() + + if (s_logger.isDebugEnabled()) { + s_logger.debug("Insufficient un-allocated capacity on: " + pool.getId() + " for volume allocation: " + volumes.toString() + " since its allocated percentage: " + usedPercentage + " has crossed the allocated pool.storage.allocated.capacity.disablethreshold: " + storageAllocatedThreshold + ", skipping this pool"); } @@ -1770,8 +1772,8 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C } if (totalOverProvCapacity < (allocatedSizeWithtemplate + totalAskingSize)) { - if (logger.isDebugEnabled()) { - logger.debug("Insufficient un-allocated capacity on: " + pool.getId() + " for volume allocation: " + volumes.toString() + + if (s_logger.isDebugEnabled()) { + s_logger.debug("Insufficient un-allocated capacity on: " + pool.getId() + " for volume allocation: " + volumes.toString() + ", not enough storage, maxSize : " + totalOverProvCapacity + ", totalAllocatedSize : " + allocatedSizeWithtemplate + ", askingSize : " + totalAskingSize); } @@ -1913,7 +1915,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C try { store = lifeCycle.initialize(params); } catch (Exception e) { - logger.debug("Failed to add data store: " + e.getMessage(), e); + s_logger.debug("Failed to add data store: " + e.getMessage(), e); throw new CloudRuntimeException("Failed to add data store: " + e.getMessage(), e); } @@ -2113,7 +2115,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C try { store = lifeCycle.initialize(params); } catch (Exception e) { - logger.debug("Failed to add data store: "+e.getMessage(), e); + s_logger.debug("Failed to add data store: "+e.getMessage(), e); throw new CloudRuntimeException("Failed to add data store: "+e.getMessage(), e); } @@ -2172,12 +2174,12 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C @Override public void run() { try { - logger.trace("Download URL Garbage Collection Thread is running."); + s_logger.trace("Download URL Garbage Collection Thread is running."); cleanupDownloadUrls(); } catch (Exception e) { - logger.error("Caught the following Exception", e); + s_logger.error("Caught the following Exception", e); } } } @@ -2195,7 +2197,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C continue; } - logger.debug("Removing download url " + volumeOnImageStore.getExtractUrl() + " for volume id " + volumeOnImageStore.getVolumeId()); + s_logger.debug("Removing download url " + volumeOnImageStore.getExtractUrl() + " for volume id " + volumeOnImageStore.getVolumeId()); // Remove it from image store ImageStoreEntity secStore = (ImageStoreEntity) _dataStoreMgr.getDataStore(volumeOnImageStore.getDataStoreId(), DataStoreRole.Image); @@ -2204,7 +2206,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C // Now expunge it from DB since this entry was created only for download purpose _volumeStoreDao.expunge(volumeOnImageStore.getId()); }catch(Throwable th){ - logger.warn("Caught exception while deleting download url " +volumeOnImageStore.getExtractUrl() + + s_logger.warn("Caught exception while deleting download url " +volumeOnImageStore.getExtractUrl() + " for volume id " + volumeOnImageStore.getVolumeId(), th); } } @@ -2219,7 +2221,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C continue; } - logger.debug("Removing download url " + templateOnImageStore.getExtractUrl() + " for template id " + templateOnImageStore.getTemplateId()); + s_logger.debug("Removing download url " + templateOnImageStore.getExtractUrl() + " for template id " + templateOnImageStore.getTemplateId()); // Remove it from image store ImageStoreEntity secStore = (ImageStoreEntity) _dataStoreMgr.getDataStore(templateOnImageStore.getDataStoreId(), DataStoreRole.Image); @@ -2230,7 +2232,7 @@ public class StorageManagerImpl extends ManagerBase implements StorageManager, C templateOnImageStore.setExtractUrlCreated(null); _templateStoreDao.update(templateOnImageStore.getId(), templateOnImageStore); }catch(Throwable th){ - logger.warn("caught exception while deleting download url " +templateOnImageStore.getExtractUrl() + + s_logger.warn("caught exception while deleting download url " +templateOnImageStore.getExtractUrl() + " for template id " +templateOnImageStore.getTemplateId(), th); } }
http://git-wip-us.apache.org/repos/asf/cloudstack/blob/8bc02940/server/src/com/cloud/storage/VolumeApiServiceImpl.java ---------------------------------------------------------------------- diff --git a/server/src/com/cloud/storage/VolumeApiServiceImpl.java b/server/src/com/cloud/storage/VolumeApiServiceImpl.java index 3ea625d..d4e8c99 100644 --- a/server/src/com/cloud/storage/VolumeApiServiceImpl.java +++ b/server/src/com/cloud/storage/VolumeApiServiceImpl.java @@ -39,6 +39,7 @@ import org.apache.cloudstack.engine.subsystem.api.storage.DataObject; import org.apache.cloudstack.engine.subsystem.api.storage.EndPoint; import org.apache.cloudstack.storage.command.TemplateOrVolumePostUploadCommand; import org.apache.cloudstack.utils.imagestore.ImageStoreUtil; +import org.apache.log4j.Logger; import org.apache.cloudstack.api.command.user.volume.AttachVolumeCmd; import org.apache.cloudstack.api.command.user.volume.CreateVolumeCmd; import org.apache.cloudstack.api.command.user.volume.DetachVolumeCmd; @@ -169,6 +170,7 @@ import org.joda.time.DateTime; import org.joda.time.DateTimeZone; public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiService, VmWorkJobHandler { + private final static Logger s_logger = Logger.getLogger(VolumeApiServiceImpl.class); public static final String VM_WORK_JOB_HANDLER = VolumeApiServiceImpl.class.getSimpleName(); @Inject @@ -398,7 +400,7 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic try { ImageFormat.valueOf(format.toUpperCase()); } catch (IllegalArgumentException e) { - logger.debug("ImageFormat IllegalArgumentException: " + e.getMessage()); + s_logger.debug("ImageFormat IllegalArgumentException: " + e.getMessage()); throw new IllegalArgumentException("Image format: " + format + " is incorrect. Supported formats are " + EnumUtils.listValues(ImageFormat.values())); } @@ -759,8 +761,8 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic message.append(cmd.getVirtualMachineId()); message.append(" due to error: "); message.append(ex.getMessage()); - if (logger.isDebugEnabled()) { - logger.debug(message, ex); + if (s_logger.isDebugEnabled()) { + s_logger.debug(message, ex); } throw new CloudRuntimeException(message.toString()); } @@ -774,7 +776,7 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic throw new CloudRuntimeException("Failed to create volume: " + volume.getId(), e); } finally { if (!created) { - logger.trace("Decrementing volume resource count for account id=" + volume.getAccountId() + " as volume failed to create on the backend"); + s_logger.trace("Decrementing volume resource count for account id=" + volume.getAccountId() + " as volume failed to create on the backend"); _resourceLimitMgr.decrementResourceCount(volume.getAccountId(), ResourceType.volume, cmd.getDisplayVolume()); _resourceLimitMgr.recalculateResourceCount(volume.getAccountId(), volume.getDomainId(), ResourceType.primary_storage.getOrdinal()); } @@ -977,7 +979,7 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic /* If this volume has never been beyond allocated state, short circuit everything and simply update the database. */ if (volume.getState() == Volume.State.Allocated) { - logger.debug("Volume is in the allocated state, but has never been created. Simply updating database with new size and IOPS."); + s_logger.debug("Volume is in the allocated state, but has never been created. Simply updating database with new size and IOPS."); volume.setSize(newSize); volume.setMinIops(newMinIops); @@ -1143,7 +1145,7 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic VolumeApiResult result = future.get(); if (result.isFailed()) { - logger.warn("Failed to resize the volume " + volume); + s_logger.warn("Failed to resize the volume " + volume); String details = ""; if (result.getResult() != null && !result.getResult().isEmpty()) { details = result.getResult(); @@ -1167,13 +1169,13 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic } return volume; } catch (InterruptedException e) { - logger.warn("failed get resize volume result", e); + s_logger.warn("failed get resize volume result", e); throw new CloudRuntimeException(e.getMessage()); } catch (ExecutionException e) { - logger.warn("failed get resize volume result", e); + s_logger.warn("failed get resize volume result", e); throw new CloudRuntimeException(e.getMessage()); } catch (Exception e) { - logger.warn("failed get resize volume result", e); + s_logger.warn("failed get resize volume result", e); throw new CloudRuntimeException(e.getMessage()); } } @@ -1238,26 +1240,26 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic // expunge volume from primary if volume is on primary VolumeInfo volOnPrimary = volFactory.getVolume(volume.getId(), DataStoreRole.Primary); if (volOnPrimary != null) { - logger.info("Expunging volume " + volume.getId() + " from primary data store"); + s_logger.info("Expunging volume " + volume.getId() + " from primary data store"); AsyncCallFuture<VolumeApiResult> future = volService.expungeVolumeAsync(volOnPrimary); future.get(); } // expunge volume from secondary if volume is on image store VolumeInfo volOnSecondary = volFactory.getVolume(volume.getId(), DataStoreRole.Image); if (volOnSecondary != null) { - logger.info("Expunging volume " + volume.getId() + " from secondary data store"); + s_logger.info("Expunging volume " + volume.getId() + " from secondary data store"); AsyncCallFuture<VolumeApiResult> future2 = volService.expungeVolumeAsync(volOnSecondary); future2.get(); } // delete all cache entries for this volume List<VolumeInfo> cacheVols = volFactory.listVolumeOnCache(volume.getId()); for (VolumeInfo volOnCache : cacheVols) { - logger.info("Delete volume from image cache store: " + volOnCache.getDataStore().getName()); + s_logger.info("Delete volume from image cache store: " + volOnCache.getDataStore().getName()); volOnCache.delete(); } } catch (Exception e) { - logger.warn("Failed to expunge volume:", e); + s_logger.warn("Failed to expunge volume:", e); return false; } @@ -1318,7 +1320,7 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic try { newVolumeOnPrimaryStorage = _volumeMgr.createVolumeOnPrimaryStorage(vm, volumeToAttach, rootDiskHyperType, destPrimaryStorage); } catch (NoTransitionException e) { - logger.debug("Failed to create volume on primary storage", e); + s_logger.debug("Failed to create volume on primary storage", e); throw new CloudRuntimeException("Failed to create volume on primary storage", e); } } @@ -1339,10 +1341,10 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic newVolumeOnPrimaryStorage = _volumeMgr.moveVolume(newVolumeOnPrimaryStorage, vmRootVolumePool.getDataCenterId(), vmRootVolumePool.getPodId(), vmRootVolumePool.getClusterId(), volumeToAttachHyperType); } catch (ConcurrentOperationException e) { - logger.debug("move volume failed", e); + s_logger.debug("move volume failed", e); throw new CloudRuntimeException("move volume failed", e); } catch (StorageUnavailableException e) { - logger.debug("move volume failed", e); + s_logger.debug("move volume failed", e); throw new CloudRuntimeException("move volume failed", e); } } @@ -1462,8 +1464,8 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic if (asyncExecutionContext != null) { AsyncJob job = asyncExecutionContext.getJob(); - if (logger.isInfoEnabled()) { - logger.info("Trying to attaching volume " + volumeId + " to vm instance:" + vm.getId() + ", update async job-" + job.getId() + " progress status"); + if (s_logger.isInfoEnabled()) { + s_logger.info("Trying to attaching volume " + volumeId + " to vm instance:" + vm.getId() + ", update async job-" + job.getId() + " progress status"); } _jobMgr.updateAsyncJobAttachment(job.getId(), "Volume", volumeId); @@ -1670,8 +1672,8 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic if (asyncExecutionContext != null) { AsyncJob job = asyncExecutionContext.getJob(); - if (logger.isInfoEnabled()) { - logger.info("Trying to attaching volume " + volumeId + "to vm instance:" + vm.getId() + ", update async job-" + job.getId() + " progress status"); + if (s_logger.isInfoEnabled()) { + s_logger.info("Trying to attaching volume " + volumeId + "to vm instance:" + vm.getId() + ", update async job-" + job.getId() + " progress status"); } _jobMgr.updateAsyncJobAttachment(job.getId(), "Volume", volumeId); @@ -1963,10 +1965,10 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic newVol = _volumeMgr.migrateVolume(vol, destPool); } } catch (StorageUnavailableException e) { - logger.debug("Failed to migrate volume", e); + s_logger.debug("Failed to migrate volume", e); throw new CloudRuntimeException(e.getMessage()); } catch (Exception e) { - logger.debug("Failed to migrate volume", e); + s_logger.debug("Failed to migrate volume", e); throw new CloudRuntimeException(e.getMessage()); } return newVol; @@ -1979,15 +1981,15 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic try { VolumeApiResult result = future.get(); if (result.isFailed()) { - logger.debug("migrate volume failed:" + result.getResult()); + s_logger.debug("migrate volume failed:" + result.getResult()); throw new StorageUnavailableException("Migrate volume failed: " + result.getResult(), destPool.getId()); } return result.getVolume(); } catch (InterruptedException e) { - logger.debug("migrate volume failed", e); + s_logger.debug("migrate volume failed", e); throw new CloudRuntimeException(e.getMessage()); } catch (ExecutionException e) { - logger.debug("migrate volume failed", e); + s_logger.debug("migrate volume failed", e); throw new CloudRuntimeException(e.getMessage()); } } @@ -2158,7 +2160,7 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic // Extract activity only for detached volumes or for volumes whose // instance is stopped if (volume.getInstanceId() != null && ApiDBUtils.findVMInstanceById(volume.getInstanceId()).getState() != State.Stopped) { - logger.debug("Invalid state of the volume with ID: " + volumeId + ". It should be either detached or the VM should be in stopped state."); + s_logger.debug("Invalid state of the volume with ID: " + volumeId + ". It should be either detached or the VM should be in stopped state."); PermissionDeniedException ex = new PermissionDeniedException( "Invalid state of the volume with specified ID. It should be either detached or the VM should be in stopped state."); ex.addProxyObject(volume.getUuid(), "volumeId"); @@ -2262,10 +2264,10 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic try { cvResult = cvAnswer.get(); } catch (InterruptedException e1) { - logger.debug("failed copy volume", e1); + s_logger.debug("failed copy volume", e1); throw new CloudRuntimeException("Failed to copy volume", e1); } catch (ExecutionException e1) { - logger.debug("failed copy volume", e1); + s_logger.debug("failed copy volume", e1); throw new CloudRuntimeException("Failed to copy volume", e1); } if (cvResult == null || cvResult.isFailed()) { @@ -2652,7 +2654,7 @@ public class VolumeApiServiceImpl extends ManagerBase implements VolumeApiServic _jobMgr.submitAsyncJob(workJob, VmWorkConstants.VM_WORK_QUEUE, vm.getId()); AsyncJobVO jobVo = _jobMgr.getAsyncJob(workJob.getId()); - logger.debug("New job " + workJob.getId() + ", result field: " + jobVo.getResult()); + s_logger.debug("New job " + workJob.getId() + ", result field: " + jobVo.getResult()); AsyncJobExecutionContext.getCurrentExecutionContext().joinJob(workJob.getId()); http://git-wip-us.apache.org/repos/asf/cloudstack/blob/8bc02940/server/src/com/cloud/storage/download/DownloadMonitorImpl.java ---------------------------------------------------------------------- diff --git a/server/src/com/cloud/storage/download/DownloadMonitorImpl.java b/server/src/com/cloud/storage/download/DownloadMonitorImpl.java index 64c35b0..f1937f8 100644 --- a/server/src/com/cloud/storage/download/DownloadMonitorImpl.java +++ b/server/src/com/cloud/storage/download/DownloadMonitorImpl.java @@ -26,6 +26,7 @@ import java.util.Timer; import javax.ejb.Local; import javax.inject.Inject; +import org.apache.log4j.Logger; import org.springframework.stereotype.Component; import org.apache.cloudstack.engine.subsystem.api.storage.DataObject; @@ -66,6 +67,7 @@ import com.cloud.utils.exception.CloudRuntimeException; @Component @Local(value = {DownloadMonitor.class}) public class DownloadMonitorImpl extends ManagerBase implements DownloadMonitor { + static final Logger s_logger = Logger.getLogger(DownloadMonitorImpl.class); @Inject private TemplateDataStoreDao _vmTemplateStoreDao; @@ -94,7 +96,7 @@ public class DownloadMonitorImpl extends ManagerBase implements DownloadMonitor String cert = configs.get("secstorage.ssl.cert.domain"); if (!"realhostip.com".equalsIgnoreCase(cert)) { - logger.warn("Only realhostip.com ssl cert is supported, ignoring self-signed and other certs"); + s_logger.warn("Only realhostip.com ssl cert is supported, ignoring self-signed and other certs"); } _copyAuthPasswd = configs.get("secstorage.copy.password"); @@ -153,7 +155,7 @@ public class DownloadMonitorImpl extends ManagerBase implements DownloadMonitor EndPoint ep = _epSelector.select(template); if (ep == null) { String errMsg = "There is no secondary storage VM for downloading template to image store " + store.getName(); - logger.warn(errMsg); + s_logger.warn(errMsg); throw new CloudRuntimeException(errMsg); } DownloadListener dl = new DownloadListener(ep, store, template, _timer, this, dcmd, callback); @@ -164,14 +166,14 @@ public class DownloadMonitorImpl extends ManagerBase implements DownloadMonitor // DownloadListener to use // new ObjectInDataStore.State transition. TODO: fix this later // to be able to remove downloadState from template_store_ref. - logger.info("found existing download job"); + s_logger.info("found existing download job"); dl.setCurrState(vmTemplateStore.getDownloadState()); } try { ep.sendMessageAsync(dcmd, new UploadListener.Callback(ep.getId(), dl)); } catch (Exception e) { - logger.warn("Unable to start /resume download of template " + template.getId() + " to " + store.getName(), e); + s_logger.warn("Unable to start /resume download of template " + template.getId() + " to " + store.getName(), e); dl.setDisconnected(); dl.scheduleStatusCheck(RequestType.GET_OR_RESTART); } @@ -187,12 +189,12 @@ public class DownloadMonitorImpl extends ManagerBase implements DownloadMonitor if (template.getUri() != null) { initiateTemplateDownload(template, callback); } else { - logger.info("Template url is null, cannot download"); + s_logger.info("Template url is null, cannot download"); DownloadAnswer ans = new DownloadAnswer("Template url is null", Status.UNKNOWN); callback.complete(ans); } } else { - logger.info("Template download is already in progress or already downloaded"); + s_logger.info("Template download is already in progress or already downloaded"); DownloadAnswer ans = new DownloadAnswer("Template download is already in progress or already downloaded", Status.UNKNOWN); callback.complete(ans); @@ -237,7 +239,7 @@ public class DownloadMonitorImpl extends ManagerBase implements DownloadMonitor EndPoint ep = _epSelector.select(volume); if (ep == null) { - logger.warn("There is no secondary storage VM for image store " + store.getName()); + s_logger.warn("There is no secondary storage VM for image store " + store.getName()); return; } DownloadListener dl = new DownloadListener(ep, store, volume, _timer, this, dcmd, callback); @@ -250,7 +252,7 @@ public class DownloadMonitorImpl extends ManagerBase implements DownloadMonitor try { ep.sendMessageAsync(dcmd, new UploadListener.Callback(ep.getId(), dl)); } catch (Exception e) { - logger.warn("Unable to start /resume download of volume " + volume.getId() + " to " + store.getName(), e); + s_logger.warn("Unable to start /resume download of volume " + volume.getId() + " to " + store.getName(), e); dl.setDisconnected(); dl.scheduleStatusCheck(RequestType.GET_OR_RESTART); } http://git-wip-us.apache.org/repos/asf/cloudstack/blob/8bc02940/server/src/com/cloud/storage/snapshot/SnapshotManagerImpl.java ---------------------------------------------------------------------- diff --git a/server/src/com/cloud/storage/snapshot/SnapshotManagerImpl.java b/server/src/com/cloud/storage/snapshot/SnapshotManagerImpl.java index 87346d9..bc66130 100644 --- a/server/src/com/cloud/storage/snapshot/SnapshotManagerImpl.java +++ b/server/src/com/cloud/storage/snapshot/SnapshotManagerImpl.java @@ -26,6 +26,7 @@ import javax.ejb.Local; import javax.inject.Inject; import javax.naming.ConfigurationException; +import org.apache.log4j.Logger; import org.springframework.stereotype.Component; import org.apache.cloudstack.api.command.user.snapshot.CreateSnapshotPolicyCmd; @@ -131,6 +132,7 @@ import com.cloud.vm.snapshot.dao.VMSnapshotDao; @Component @Local(value = {SnapshotManager.class, SnapshotApiService.class}) public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, SnapshotApiService { + private static final Logger s_logger = Logger.getLogger(SnapshotManagerImpl.class); @Inject private VMTemplateDao _templateDao; @Inject @@ -207,25 +209,25 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, if (result.second().getResult()) { return result.second(); } - if (logger.isDebugEnabled()) { - logger.debug("The result for " + cmd.getClass().getName() + " is " + result.second().getDetails() + " through " + result.first()); + if (s_logger.isDebugEnabled()) { + s_logger.debug("The result for " + cmd.getClass().getName() + " is " + result.second().getDetails() + " through " + result.first()); } hostIdsToAvoid.add(result.first()); } catch (StorageUnavailableException e1) { - logger.warn("Storage unavailable ", e1); + s_logger.warn("Storage unavailable ", e1); return null; } try { Thread.sleep(_pauseInterval * 1000); } catch (InterruptedException e) { - logger.debug("[ignored] interupted while retry cmd."); + s_logger.debug("[ignored] interupted while retry cmd."); } - logger.debug("Retrying..."); + s_logger.debug("Retrying..."); } - logger.warn("After " + _totalRetries + " retries, the command " + cmd.getClass().getName() + " did not succeed."); + s_logger.warn("After " + _totalRetries + " retries, the command " + cmd.getClass().getName() + " did not succeed."); return null; } @@ -265,7 +267,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, SnapshotStrategy snapshotStrategy = _storageStrategyFactory.getSnapshotStrategy(snapshot, SnapshotOperation.REVERT); if (snapshotStrategy == null) { - logger.error("Unable to find snaphot strategy to handle snapshot with id '" + snapshotId + "'"); + s_logger.error("Unable to find snaphot strategy to handle snapshot with id '" + snapshotId + "'"); return false; } @@ -316,7 +318,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, SnapshotInfo snapshot = snapshotFactory.getSnapshot(snapshotId, DataStoreRole.Primary); if(snapshot == null) { - logger.debug("Failed to create snapshot"); + s_logger.debug("Failed to create snapshot"); throw new CloudRuntimeException("Failed to create snapshot"); } try { @@ -330,7 +332,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, _resourceLimitMgr.incrementResourceCount(snapshotOwner.getId(), ResourceType.snapshot); } catch (Exception e) { - logger.debug("Failed to create snapshot", e); + s_logger.debug("Failed to create snapshot", e); throw new CloudRuntimeException("Failed to create snapshot", e); } @@ -397,7 +399,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, SnapshotVO oldestSnapshot = snaps.get(0); long oldSnapId = oldestSnapshot.getId(); if (policy != null) { - logger.debug("Max snaps: " + policy.getMaxSnaps() + " exceeded for snapshot policy with Id: " + policyId + ". Deleting oldest snapshot: " + oldSnapId); + s_logger.debug("Max snaps: " + policy.getMaxSnaps() + " exceeded for snapshot policy with Id: " + policyId + ". Deleting oldest snapshot: " + oldSnapId); } if (deleteSnapshot(oldSnapId)) { //log Snapshot delete event @@ -426,7 +428,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, SnapshotStrategy snapshotStrategy = _storageStrategyFactory.getSnapshotStrategy(snapshotCheck, SnapshotOperation.DELETE); if (snapshotStrategy == null) { - logger.error("Unable to find snaphot strategy to handle snapshot with id '" + snapshotId + "'"); + s_logger.error("Unable to find snaphot strategy to handle snapshot with id '" + snapshotId + "'"); return false; } @@ -455,7 +457,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, return result; } catch (Exception e) { - logger.debug("Failed to delete snapshot: " + snapshotCheck.getId() + ":" + e.toString()); + s_logger.debug("Failed to delete snapshot: " + snapshotCheck.getId() + ":" + e.toString()); throw new CloudRuntimeException("Failed to delete snapshot:" + e.toString()); } @@ -612,18 +614,18 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, Answer answer = null; if (ep == null) { String errMsg = "No remote endpoint to send command, check if host or ssvm is down?"; - logger.error(errMsg); + s_logger.error(errMsg); answer = new Answer(cmd, false, errMsg); } else { answer = ep.sendMessage(cmd); } if ((answer != null) && answer.getResult()) { - logger.debug("Deleted all snapshots for volume: " + volumeId + " under account: " + accountId); + s_logger.debug("Deleted all snapshots for volume: " + volumeId + " under account: " + accountId); } else { success = false; if (answer != null) { - logger.warn("Failed to delete all snapshot for volume " + volumeId + " on secondary storage " + ssHost.getUri()); - logger.error(answer.getDetails()); + s_logger.warn("Failed to delete all snapshot for volume " + volumeId + " on secondary storage " + ssHost.getUri()); + s_logger.error(answer.getDetails()); } } } @@ -633,7 +635,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, for (SnapshotVO snapshot : snapshots) { SnapshotStrategy snapshotStrategy = _storageStrategyFactory.getSnapshotStrategy(snapshot, SnapshotOperation.DELETE); if (snapshotStrategy == null) { - logger.error("Unable to find snaphot strategy to handle snapshot with id '" + snapshot.getId() + "'"); + s_logger.error("Unable to find snaphot strategy to handle snapshot with id '" + snapshot.getId() + "'"); continue; } SnapshotDataStoreVO snapshotStoreRef = _snapshotStoreDao.findBySnapshot(snapshot.getId(), DataStoreRole.Image); @@ -701,7 +703,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, TimeZone timeZone = TimeZone.getTimeZone(cmd.getTimezone()); String timezoneId = timeZone.getID(); if (!timezoneId.equals(cmd.getTimezone())) { - logger.warn("Using timezone: " + timezoneId + " for running this snapshot policy as an equivalent of " + cmd.getTimezone()); + s_logger.warn("Using timezone: " + timezoneId + " for running this snapshot policy as an equivalent of " + cmd.getTimezone()); } try { DateUtil.getNextRunTime(intvType, cmd.getSchedule(), timezoneId, null); @@ -893,7 +895,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, if (vm.getState() != VirtualMachine.State.Stopped && vm.getState() != VirtualMachine.State.Destroyed) { boolean snapshotEnabled = Boolean.parseBoolean(_configDao.getValue("kvm.snapshot.enabled")); if (!snapshotEnabled) { - logger.debug("Snapshot is not supported on host " + host + " for the volume " + volume + " attached to the vm " + vm); + s_logger.debug("Snapshot is not supported on host " + host + " for the volume " + volume + " attached to the vm " + vm); return false; } } @@ -996,10 +998,10 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, // Correct the resource count of snapshot in case of delta snapshots. _resourceLimitMgr.decrementResourceCount(snapshotOwner.getId(), ResourceType.secondary_storage, new Long(volume.getSize() - snapshotStoreRef.getPhysicalSize())); } catch (Exception e) { - logger.debug("post process snapshot failed", e); + s_logger.debug("post process snapshot failed", e); } } catch (Exception e) { - logger.debug("Failed to create snapshot", e); + s_logger.debug("Failed to create snapshot", e); _resourceLimitMgr.decrementResourceCount(snapshotOwner.getId(), ResourceType.snapshot); _resourceLimitMgr.decrementResourceCount(snapshotOwner.getId(), ResourceType.secondary_storage, new Long(volume.getSize())); throw new CloudRuntimeException("Failed to create snapshot", e); @@ -1019,7 +1021,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, _totalRetries = NumbersUtil.parseInt(_configDao.getValue("total.retries"), 4); _pauseInterval = 2 * NumbersUtil.parseInt(_configDao.getValue("ping.interval"), 60); - logger.info("Snapshot Manager is configured."); + s_logger.info("Snapshot Manager is configured."); return true; } @@ -1074,7 +1076,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, for (Long pId : policyIds) { if (!deletePolicy(userId, pId)) { success = false; - logger.warn("Failed to delete snapshot policy with Id: " + policyId); + s_logger.warn("Failed to delete snapshot policy with Id: " + policyId); return success; } } @@ -1108,7 +1110,7 @@ public class SnapshotManagerImpl extends ManagerBase implements SnapshotManager, } catch (ResourceAllocationException e) { if (snapshotType != Type.MANUAL) { String msg = "Snapshot resource limit exceeded for account id : " + owner.getId() + ". Failed to create recurring snapshots"; - logger.warn(msg); + s_logger.warn(msg); _alertMgr.sendAlert(AlertManager.AlertType.ALERT_TYPE_UPDATE_RESOURCE_COUNT, 0L, 0L, msg, "Snapshot resource limit exceeded for account id : " + owner.getId() + ". Failed to create recurring snapshots; please use updateResourceLimit to increase the limit"); http://git-wip-us.apache.org/repos/asf/cloudstack/blob/8bc02940/server/src/com/cloud/storage/snapshot/SnapshotSchedulerImpl.java ---------------------------------------------------------------------- diff --git a/server/src/com/cloud/storage/snapshot/SnapshotSchedulerImpl.java b/server/src/com/cloud/storage/snapshot/SnapshotSchedulerImpl.java index 93fb4a3..4ce2bba 100644 --- a/server/src/com/cloud/storage/snapshot/SnapshotSchedulerImpl.java +++ b/server/src/com/cloud/storage/snapshot/SnapshotSchedulerImpl.java @@ -27,6 +27,7 @@ import javax.ejb.Local; import javax.inject.Inject; import javax.naming.ConfigurationException; +import org.apache.log4j.Logger; import org.springframework.stereotype.Component; import org.apache.cloudstack.api.ApiConstants; @@ -68,6 +69,7 @@ import com.cloud.utils.db.TransactionLegacy; @Component @Local(value = {SnapshotScheduler.class}) public class SnapshotSchedulerImpl extends ManagerBase implements SnapshotScheduler { + private static final Logger s_logger = Logger.getLogger(SnapshotSchedulerImpl.class); @Inject protected AsyncJobDao _asyncJobDao; @@ -115,7 +117,7 @@ public class SnapshotSchedulerImpl extends ManagerBase implements SnapshotSchedu nextTimestamp = DateUtil.getNextRunTime(type, schedule, timezone, currentTimestamp); final String currentTime = DateUtil.displayDateInTimezone(DateUtil.GMT_TIMEZONE, currentTimestamp); final String nextScheduledTime = DateUtil.displayDateInTimezone(DateUtil.GMT_TIMEZONE, nextTimestamp); - logger.debug("Current time is " + currentTime + ". NextScheduledTime of policyId " + policyId + " is " + nextScheduledTime); + s_logger.debug("Current time is " + currentTime + ". NextScheduledTime of policyId " + policyId + " is " + nextScheduledTime); } return nextTimestamp; } @@ -222,10 +224,10 @@ public class SnapshotSchedulerImpl extends ManagerBase implements SnapshotSchedu @DB protected void scheduleSnapshots() { String displayTime = DateUtil.displayDateInTimezone(DateUtil.GMT_TIMEZONE, _currentTimestamp); - logger.debug("Snapshot scheduler.poll is being called at " + displayTime); + s_logger.debug("Snapshot scheduler.poll is being called at " + displayTime); final List<SnapshotScheduleVO> snapshotsToBeExecuted = _snapshotScheduleDao.getSchedulesToExecute(_currentTimestamp); - logger.debug("Got " + snapshotsToBeExecuted.size() + " snapshots to be executed at " + displayTime); + s_logger.debug("Got " + snapshotsToBeExecuted.size() + " snapshots to be executed at " + displayTime); for (final SnapshotScheduleVO snapshotToBeExecuted : snapshotsToBeExecuted) { SnapshotScheduleVO tmpSnapshotScheduleVO = null; @@ -241,18 +243,18 @@ public class SnapshotSchedulerImpl extends ManagerBase implements SnapshotSchedu Account volAcct = _acctDao.findById(volume.getAccountId()); if (volAcct == null || volAcct.getState() == Account.State.disabled) { // this account has been removed, so don't trigger recurring snapshot - if (logger.isDebugEnabled()) { - logger.debug("Skip snapshot for volume " + volume.getUuid() + " since its account has been removed or disabled"); + if (s_logger.isDebugEnabled()) { + s_logger.debug("Skip snapshot for volume " + volume.getUuid() + " since its account has been removed or disabled"); } continue; } if (_snapshotPolicyDao.findById(policyId) == null) { _snapshotScheduleDao.remove(snapshotToBeExecuted.getId()); } - if (logger.isDebugEnabled()) { + if (s_logger.isDebugEnabled()) { final Date scheduledTimestamp = snapshotToBeExecuted.getScheduledTimestamp(); displayTime = DateUtil.displayDateInTimezone(DateUtil.GMT_TIMEZONE, scheduledTimestamp); - logger.debug("Scheduling 1 snapshot for volume id " + volumeId + " (volume name:" + + s_logger.debug("Scheduling 1 snapshot for volume id " + volumeId + " (volume name:" + volume.getName() + ") for schedule id: " + snapshotToBeExecuted.getId() + " at " + displayTime); } @@ -285,7 +287,7 @@ public class SnapshotSchedulerImpl extends ManagerBase implements SnapshotSchedu _snapshotScheduleDao.update(snapshotScheId, tmpSnapshotScheduleVO); } catch (final Exception e) { // TODO Logging this exception is enough? - logger.warn("Scheduling snapshot failed due to " + e.toString()); + s_logger.warn("Scheduling snapshot failed due to " + e.toString()); } finally { if (tmpSnapshotScheduleVO != null) { _snapshotScheduleDao.releaseFromLockTable(snapshotScheId); @@ -377,7 +379,7 @@ public class SnapshotSchedulerImpl extends ManagerBase implements SnapshotSchedu success = _snapshotScheduleDao.remove(schedule.getId()); } if (!success) { - logger.debug("Error while deleting Snapshot schedule with Id: " + schedule.getId()); + s_logger.debug("Error while deleting Snapshot schedule with Id: " + schedule.getId()); } return success; } @@ -400,7 +402,7 @@ public class SnapshotSchedulerImpl extends ManagerBase implements SnapshotSchedu } _currentTimestamp = new Date(); - logger.info("Snapshot Scheduler is configured."); + s_logger.info("Snapshot Scheduler is configured."); return true; } @@ -428,7 +430,7 @@ public class SnapshotSchedulerImpl extends ManagerBase implements SnapshotSchedu final Date currentTimestamp = new Date(); poll(currentTimestamp); } catch (final Throwable t) { - logger.warn("Catch throwable in snapshot scheduler ", t); + s_logger.warn("Catch throwable in snapshot scheduler ", t); } } }; http://git-wip-us.apache.org/repos/asf/cloudstack/blob/8bc02940/server/src/com/cloud/storage/upload/UploadMonitorImpl.java ---------------------------------------------------------------------- diff --git a/server/src/com/cloud/storage/upload/UploadMonitorImpl.java b/server/src/com/cloud/storage/upload/UploadMonitorImpl.java index 3dc47ab..35cb665 100644 --- a/server/src/com/cloud/storage/upload/UploadMonitorImpl.java +++ b/server/src/com/cloud/storage/upload/UploadMonitorImpl.java @@ -32,6 +32,7 @@ import javax.ejb.Local; import javax.inject.Inject; import javax.naming.ConfigurationException; +import org.apache.log4j.Logger; import org.springframework.stereotype.Component; import org.apache.cloudstack.engine.subsystem.api.storage.DataStore; @@ -83,6 +84,7 @@ import com.cloud.vm.dao.SecondaryStorageVmDao; @Local(value = {UploadMonitor.class}) public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { + static final Logger s_logger = Logger.getLogger(UploadMonitorImpl.class); @Inject private UploadDao _uploadDao; @@ -159,12 +161,12 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { EndPoint ep = _epSelector.select(secStore); if (ep == null) { String errMsg = "No remote endpoint to send command, check if host or ssvm is down?"; - logger.error(errMsg); + s_logger.error(errMsg); return; } ep.sendMessageAsync(ucmd, new UploadListener.Callback(ep.getId(), ul)); } catch (Exception e) { - logger.warn("Unable to start upload of volume " + volume.getName() + " from " + secStore.getName() + " to " + url, e); + s_logger.warn("Unable to start upload of volume " + volume.getName() + " from " + secStore.getName() + " to " + url, e); ul.setDisconnected(); ul.scheduleStatusCheck(RequestType.GET_OR_RESTART); } @@ -192,12 +194,12 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { EndPoint ep = _epSelector.select(secStore); if (ep == null) { String errMsg = "No remote endpoint to send command, check if host or ssvm is down?"; - logger.error(errMsg); + s_logger.error(errMsg); return null; } ep.sendMessageAsync(ucmd, new UploadListener.Callback(ep.getId(), ul)); } catch (Exception e) { - logger.warn("Unable to start upload of " + template.getUniqueName() + " from " + secStore.getName() + " to " + url, e); + s_logger.warn("Unable to start upload of " + template.getUniqueName() + " from " + secStore.getName() + " to " + url, e); ul.setDisconnected(); ul.scheduleStatusCheck(RequestType.GET_OR_RESTART); } @@ -218,7 +220,7 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { EndPoint ep = _epSelector.select(store); if (ep == null) { String errMsg = "No remote endpoint to send command, check if host or ssvm is down?"; - logger.error(errMsg); + s_logger.error(errMsg); return null; } @@ -261,7 +263,7 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { Answer ans = ep.sendMessage(cmd); if (ans == null || !ans.getResult()) { errorString = "Unable to create a link for " + type + " id:" + template.getId() + "," + (ans == null ? "" : ans.getDetails()); - logger.error(errorString); + s_logger.error(errorString); throw new CloudRuntimeException(errorString); } @@ -317,7 +319,7 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { Answer ans = ep.sendMessage(cmd); if (ans == null || !ans.getResult()) { errorString = "Unable to create a link for " + type + " id:" + entityId + "," + (ans == null ? "" : ans.getDetails()); - logger.warn(errorString); + s_logger.warn(errorString); throw new CloudRuntimeException(errorString); } @@ -326,7 +328,7 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { SecondaryStorageVmVO ssVm = ssVms.get(0); if (ssVm.getPublicIpAddress() == null) { errorString = "A running secondary storage vm has a null public ip?"; - logger.error(errorString); + s_logger.error(errorString); throw new CloudRuntimeException(errorString); } //Construct actual URL locally now that the symlink exists at SSVM @@ -376,7 +378,7 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { String cert = configs.get("secstorage.secure.copy.cert"); if ("realhostip.com".equalsIgnoreCase(cert)) { - logger.warn("Only realhostip.com ssl cert is supported, ignoring self-signed and other certs"); + s_logger.warn("Only realhostip.com ssl cert is supported, ignoring self-signed and other certs"); } _ssvmUrlDomain = configs.get("secstorage.ssl.cert.domain"); @@ -423,10 +425,10 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { HostVO storageHost = _serverDao.findById(sserverId); if (storageHost == null) { - logger.warn("Huh? Agent id " + sserverId + " does not correspond to a row in hosts table?"); + s_logger.warn("Huh? Agent id " + sserverId + " does not correspond to a row in hosts table?"); return; } - logger.debug("Handling upload sserverId " + sserverId); + s_logger.debug("Handling upload sserverId " + sserverId); List<UploadVO> uploadsInProgress = new ArrayList<UploadVO>(); uploadsInProgress.addAll(_uploadDao.listByHostAndUploadStatus(sserverId, UploadVO.Status.UPLOAD_IN_PROGRESS)); uploadsInProgress.addAll(_uploadDao.listByHostAndUploadStatus(sserverId, UploadVO.Status.COPY_IN_PROGRESS)); @@ -464,7 +466,7 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { } } catch (Exception e) { - logger.error("Caught the following Exception", e); + s_logger.error("Caught the following Exception", e); } } } @@ -492,17 +494,17 @@ public class UploadMonitorImpl extends ManagerBase implements UploadMonitor { new DeleteEntityDownloadURLCommand(path, extractJob.getType(), extractJob.getUploadUrl(), ((ImageStoreVO)secStore).getParent()); EndPoint ep = _epSelector.select(secStore); if (ep == null) { - logger.warn("UploadMonitor cleanup: There is no secondary storage VM for secondary storage host " + extractJob.getDataStoreId()); + s_logger.warn("UploadMonitor cleanup: There is no secondary storage VM for secondary storage host " + extractJob.getDataStoreId()); continue; //TODO: why continue? why not break? } - if (logger.isDebugEnabled()) { - logger.debug("UploadMonitor cleanup: Sending deletion of extract URL " + extractJob.getUploadUrl() + " to ssvm " + ep.getHostAddr()); + if (s_logger.isDebugEnabled()) { + s_logger.debug("UploadMonitor cleanup: Sending deletion of extract URL " + extractJob.getUploadUrl() + " to ssvm " + ep.getHostAddr()); } Answer ans = ep.sendMessage(cmd); if (ans != null && ans.getResult()) { _uploadDao.remove(extractJob.getId()); } else { - logger.warn("UploadMonitor cleanup: Unable to delete the link for " + extractJob.getType() + " id=" + extractJob.getTypeId() + " url=" + + s_logger.warn("UploadMonitor cleanup: Unable to delete the link for " + extractJob.getType() + " id=" + extractJob.getTypeId() + " url=" + extractJob.getUploadUrl() + " on ssvm " + ep.getHostAddr()); } }
