diff --git a/api/src/com/cloud/agent/api/to/VolumeTO.java b/api/src/com/cloud/agent/api/to/VolumeTO.java index b95aa1d3500..0f1f9af4940 100644 --- a/api/src/com/cloud/agent/api/to/VolumeTO.java +++ b/api/src/com/cloud/agent/api/to/VolumeTO.java @@ -137,7 +137,7 @@ public class VolumeTO implements InternalIdentity { public String toString() { return new StringBuilder("Vol[").append(id).append("|").append(type).append("|").append(path).append("|").append(size).append("]").toString(); } - + public void setBytesReadRate(long bytesReadRate) { this.bytesReadRate = bytesReadRate; } diff --git a/api/src/com/cloud/offering/DiskOffering.java b/api/src/com/cloud/offering/DiskOffering.java index 0c119fc5add..4f87dc5bd16 100644 --- a/api/src/com/cloud/offering/DiskOffering.java +++ b/api/src/com/cloud/offering/DiskOffering.java @@ -52,7 +52,7 @@ public interface DiskOffering extends InfrastructureEntity, Identity, InternalId boolean isCustomized(); void setDiskSize(long diskSize); - + void setBytesReadRate(long bytesReadRate); long getBytesReadRate(); diff --git a/api/src/org/apache/cloudstack/api/command/admin/offering/CreateDiskOfferingCmd.java b/api/src/org/apache/cloudstack/api/command/admin/offering/CreateDiskOfferingCmd.java index 47ec365de35..8ffc4a701c1 100644 --- a/api/src/org/apache/cloudstack/api/command/admin/offering/CreateDiskOfferingCmd.java +++ b/api/src/org/apache/cloudstack/api/command/admin/offering/CreateDiskOfferingCmd.java @@ -61,7 +61,7 @@ public class CreateDiskOfferingCmd extends BaseCmd { @Parameter(name=ApiConstants.STORAGE_TYPE, type=CommandType.STRING, description="the storage type of the disk offering. Values are local and shared.") private String storageType = ServiceOffering.StorageType.shared.toString(); - + @Parameter(name=ApiConstants.BYTES_READ_RATE, type=CommandType.LONG, required=false, description="bytes read rate of the disk offering") private Long bytesReadRate; @@ -104,10 +104,9 @@ public class CreateDiskOfferingCmd extends BaseCmd { public Long getDomainId(){ return domainId; } - + public long getBytesReadRate() { - return bytesReadRate; - //return (bytesReadRate == null) || (bytesReadRate < 0) ? 0 : bytesReadRate; + return (bytesReadRate == null) || (bytesReadRate < 0) ? 0 : bytesReadRate; } public long getBytesWriteRate() { @@ -143,7 +142,7 @@ public class CreateDiskOfferingCmd extends BaseCmd { public long getEntityOwnerId() { return Account.ACCOUNT_ID_SYSTEM; } - + @Override public void execute(){ DiskOffering offering = _configService.createDiskOffering(this); diff --git a/api/src/org/apache/cloudstack/api/response/DiskOfferingResponse.java b/api/src/org/apache/cloudstack/api/response/DiskOfferingResponse.java index 9cd2918d253..fd00f4e862c 100644 --- a/api/src/org/apache/cloudstack/api/response/DiskOfferingResponse.java +++ b/api/src/org/apache/cloudstack/api/response/DiskOfferingResponse.java @@ -57,7 +57,7 @@ public class DiskOfferingResponse extends BaseResponse { @SerializedName("storagetype") @Param(description="the storage type for this disk offering") private String storageType; - + @SerializedName("diskBytesReadRate") @Param(description="bytes read rate of the disk offering") private Long bytesReadRate; @@ -176,5 +176,5 @@ public class DiskOfferingResponse extends BaseResponse { public void setIopsWriteRate(long iopsWriteRate) { this.iopsWriteRate = iopsWriteRate; - } + } } diff --git a/api/src/org/apache/cloudstack/api/response/ServiceOfferingResponse.java b/api/src/org/apache/cloudstack/api/response/ServiceOfferingResponse.java index a56e91abe8d..f12f35af602 100644 --- a/api/src/org/apache/cloudstack/api/response/ServiceOfferingResponse.java +++ b/api/src/org/apache/cloudstack/api/response/ServiceOfferingResponse.java @@ -86,7 +86,7 @@ public class ServiceOfferingResponse extends BaseResponse { @SerializedName(ApiConstants.NETWORKRATE) @Param(description="data transfer rate in megabits per second allowed.") private Integer networkRate; - + @SerializedName("diskBytesReadRate") @Param(description="bytes read rate of the service offering") private Long bytesReadRate; @@ -260,7 +260,7 @@ public class ServiceOfferingResponse extends BaseResponse { public void setVolatileVm(boolean isVolatile) { this.isVolatile = isVolatile; } - + public void setBytesReadRate(long bytesReadRate) { this.bytesReadRate = bytesReadRate; } diff --git a/core/src/com/cloud/agent/api/AttachVolumeCommand.java b/core/src/com/cloud/agent/api/AttachVolumeCommand.java index 74480cc479e..987bb2172be 100644 --- a/core/src/com/cloud/agent/api/AttachVolumeCommand.java +++ b/core/src/com/cloud/agent/api/AttachVolumeCommand.java @@ -100,7 +100,7 @@ public class AttachVolumeCommand extends Command { public String getChainInfo() { return chainInfo; } - + public void setBytesReadRate(long bytesReadRate) { this.bytesReadRate = bytesReadRate; } diff --git a/engine/schema/src/com/cloud/storage/DiskOfferingVO.java b/engine/schema/src/com/cloud/storage/DiskOfferingVO.java index 16e11afaae3..1554f18fc3a 100755 --- a/engine/schema/src/com/cloud/storage/DiskOfferingVO.java +++ b/engine/schema/src/com/cloud/storage/DiskOfferingVO.java @@ -99,7 +99,7 @@ public class DiskOfferingVO implements DiskOffering { @Column(name="sort_key") int sortKey; - + @Column(name="bytes_read_rate") long bytesReadRate; diff --git a/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtComputingResource.java b/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtComputingResource.java index 690c15f6eec..02e0a887b40 100755 --- a/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtComputingResource.java +++ b/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtComputingResource.java @@ -3498,7 +3498,7 @@ ServerResource { } } - + if (volume.getBytesReadRate() > 0) disk.setBytesReadRate(volume.getBytesReadRate()); if (volume.getBytesWriteRate() > 0) diff --git a/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtDomainXMLParser.java b/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtDomainXMLParser.java index c364cd43dca..8514a5bd270 100644 --- a/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtDomainXMLParser.java +++ b/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtDomainXMLParser.java @@ -105,7 +105,7 @@ public class LibvirtDomainXMLParser { DiskDef.diskBus.valueOf(bus.toUpperCase())); } } - + NodeList iotune = disk.getElementsByTagName("iotune"); if ((iotune != null) && (iotune.getLength() !=0)) { String bytesReadRateStr = getTagValue("read_bytes_sec", (Element)iotune.item(0)); diff --git a/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtVMDef.java b/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtVMDef.java index a347fee57eb..aee14097e66 100644 --- a/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtVMDef.java +++ b/plugins/hypervisors/kvm/src/com/cloud/hypervisor/kvm/resource/LibvirtVMDef.java @@ -589,7 +589,7 @@ public class LibvirtVMDef { char suffix = this._diskLabel.charAt(this._diskLabel.length() - 1); return suffix - 'a'; } - + public void setBytesReadRate(long bytesReadRate) { _bytesReadRate = bytesReadRate; } @@ -649,7 +649,7 @@ public class LibvirtVMDef { diskBuilder.append(" bus='" + _bus + "'"); } diskBuilder.append("/>\n"); - + String libvirtVersion = Script.runSimpleBashScript("virsh version |grep API | awk '{print $4}'"); String qemuVersion = Script.runSimpleBashScript("virsh version |grep hypervisor | awk '{print $4}'"); if ((_deviceType != deviceType.CDROM) && (libvirtVersion != null) && (qemuVersion != null) @@ -675,7 +675,7 @@ public class LibvirtVMDef { diskBuilder.append("\n"); } } - + diskBuilder.append("\n"); return diskBuilder.toString(); } diff --git a/server/src/com/cloud/configuration/ConfigurationManagerImpl.java b/server/src/com/cloud/configuration/ConfigurationManagerImpl.java index e5dbf3a8090..170625f449d 100755 --- a/server/src/com/cloud/configuration/ConfigurationManagerImpl.java +++ b/server/src/com/cloud/configuration/ConfigurationManagerImpl.java @@ -2169,8 +2169,6 @@ public class ConfigurationManagerImpl extends ManagerBase implements Configurati newDiskOffering.setIopsReadRate(iopsReadRate); if (iopsWriteRate != null && (iopsWriteRate > 0)) newDiskOffering.setIopsWriteRate(iopsWriteRate); - s_logger.warn("bytesReadRate =" + bytesReadRate); - s_logger.warn("newDiskOffering.getBytesReadRate" + newDiskOffering.getBytesReadRate()); UserContext.current().setEventDetails("Disk offering id=" + newDiskOffering.getId()); DiskOfferingVO offering = _diskOfferingDao.persist(newDiskOffering); diff --git a/server/src/com/cloud/storage/VolumeManagerImpl.java b/server/src/com/cloud/storage/VolumeManagerImpl.java index f3c94abd944..2fc8b1e8de5 100644 --- a/server/src/com/cloud/storage/VolumeManagerImpl.java +++ b/server/src/com/cloud/storage/VolumeManagerImpl.java @@ -678,7 +678,7 @@ public class VolumeManagerImpl extends ManagerBase implements VolumeManager { } dskCh.setHyperType(hyperType); - + final HashSet avoidPools = new HashSet( avoids); diff --git a/ui/scripts/configuration.js b/ui/scripts/configuration.js index 6a9765e4a31..e813c66721d 100644 --- a/ui/scripts/configuration.js +++ b/ui/scripts/configuration.js @@ -110,28 +110,28 @@ } }, diskBytesReadRate: { - label: 'label.disk.bytes.read.rate', + label: 'label.disk.bytes.read.rate', validation: { required: false, //optional number: true } }, diskBytesWriteRate: { - label: 'label.disk.bytes.write.rate', + label: 'label.disk.bytes.write.rate', validation: { required: false, //optional number: true } }, diskIopsReadRate: { - label: 'label.disk.iops.read.rate', + label: 'label.disk.iops.read.rate', validation: { required: false, //optional number: true } }, diskIopsWriteRate: { - label: 'label.disk.iops.write.rate', + label: 'label.disk.iops.write.rate', validation: { required: false, //optional number: true @@ -586,28 +586,28 @@ } }, diskBytesReadRate: { - label: 'label.disk.bytes.read.rate', + label: 'label.disk.bytes.read.rate', validation: { required: false, //optional number: true } }, diskBytesWriteRate: { - label: 'label.disk.bytes.write.rate', + label: 'label.disk.bytes.write.rate', validation: { required: false, //optional number: true } }, diskIopsReadRate: { - label: 'label.disk.iops.read.rate', + label: 'label.disk.iops.read.rate', validation: { required: false, //optional number: true } }, diskIopsWriteRate: { - label: 'label.disk.iops.write.rate', + label: 'label.disk.iops.write.rate', validation: { required: false, //optional number: true @@ -1043,28 +1043,28 @@ validation: { required: true, number: true } }, diskBytesReadRate: { - label: 'label.disk.bytes.read.rate', + label: 'label.disk.bytes.read.rate', validation: { required: false, //optional number: true } }, diskBytesWriteRate: { - label: 'label.disk.bytes.write.rate', + label: 'label.disk.bytes.write.rate', validation: { required: false, //optional number: true } }, diskIopsReadRate: { - label: 'label.disk.iops.read.rate', + label: 'label.disk.iops.read.rate', validation: { required: false, //optional number: true } }, diskIopsWriteRate: { - label: 'label.disk.iops.write.rate', + label: 'label.disk.iops.write.rate', validation: { required: false, //optional number: true