You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cloudstack.apache.org by ra...@apache.org on 2015/08/31 08:01:25 UTC
[05/35] git commit: updated refs/heads/master to 8bc0294
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());
}
}