Commit 3448701f authored by Krunal Jain's avatar Krunal Jain

Reverting commit #56600 as GCE PD is allocated in chunks of GiB instead of GBs

Fixing comments and importing constant from util Importing constant from util Fixing comment in volume_provisioning.go
parent 0016ac3a
...@@ -772,8 +772,8 @@ func (gce *GCECloud) ResizeDisk(diskToResize string, oldSize resource.Quantity, ...@@ -772,8 +772,8 @@ func (gce *GCECloud) ResizeDisk(diskToResize string, oldSize resource.Quantity,
} }
requestBytes := newSize.Value() requestBytes := newSize.Value()
// GCE resizes in chunks of GBs (not GiB) // GCE resizes in chunks of GiBs
requestGB := volumeutil.RoundUpSize(requestBytes, 1000*1000*1000) requestGB := volumeutil.RoundUpSize(requestBytes, volumeutil.GIB)
newSizeQuant := resource.MustParse(fmt.Sprintf("%dG", requestGB)) newSizeQuant := resource.MustParse(fmt.Sprintf("%dG", requestGB))
// If disk is already of size equal or greater than requested size, we simply return // If disk is already of size equal or greater than requested size, we simply return
......
...@@ -422,7 +422,7 @@ func (c *gcePersistentDiskProvisioner) Provision() (*v1.PersistentVolume, error) ...@@ -422,7 +422,7 @@ func (c *gcePersistentDiskProvisioner) Provision() (*v1.PersistentVolume, error)
PersistentVolumeReclaimPolicy: c.options.PersistentVolumeReclaimPolicy, PersistentVolumeReclaimPolicy: c.options.PersistentVolumeReclaimPolicy,
AccessModes: c.options.PVC.Spec.AccessModes, AccessModes: c.options.PVC.Spec.AccessModes,
Capacity: v1.ResourceList{ Capacity: v1.ResourceList{
v1.ResourceName(v1.ResourceStorage): resource.MustParse(fmt.Sprintf("%dG", sizeGB)), v1.ResourceName(v1.ResourceStorage): resource.MustParse(fmt.Sprintf("%dGi", sizeGB)),
}, },
PersistentVolumeSource: v1.PersistentVolumeSource{ PersistentVolumeSource: v1.PersistentVolumeSource{
GCEPersistentDisk: &v1.GCEPersistentDiskVolumeSource{ GCEPersistentDisk: &v1.GCEPersistentDiskVolumeSource{
......
...@@ -177,7 +177,7 @@ func TestPlugin(t *testing.T) { ...@@ -177,7 +177,7 @@ func TestPlugin(t *testing.T) {
} }
cap := persistentSpec.Spec.Capacity[v1.ResourceStorage] cap := persistentSpec.Spec.Capacity[v1.ResourceStorage]
size := cap.Value() size := cap.Value()
if size != 100*util.GB { if size != 100*util.GIB {
t.Errorf("Provision() returned unexpected volume size: %v", size) t.Errorf("Provision() returned unexpected volume size: %v", size)
} }
......
...@@ -86,8 +86,8 @@ func (gceutil *GCEDiskUtil) CreateVolume(c *gcePersistentDiskProvisioner) (strin ...@@ -86,8 +86,8 @@ func (gceutil *GCEDiskUtil) CreateVolume(c *gcePersistentDiskProvisioner) (strin
name := volumeutil.GenerateVolumeName(c.options.ClusterName, c.options.PVName, 63) // GCE PD name can have up to 63 characters name := volumeutil.GenerateVolumeName(c.options.ClusterName, c.options.PVName, 63) // GCE PD name can have up to 63 characters
capacity := c.options.PVC.Spec.Resources.Requests[v1.ResourceName(v1.ResourceStorage)] capacity := c.options.PVC.Spec.Resources.Requests[v1.ResourceName(v1.ResourceStorage)]
// GCE PDs are allocated in chunks of GBs (not GiBs) // GCE PDs are allocated in chunks of GiBs
requestGB := volumeutil.RoundUpToGB(capacity) requestGB := volumeutil.RoundUpToGiB(capacity)
// Apply Parameters. // Apply Parameters.
// Values for parameter "replication-type" are canonicalized to lower case. // Values for parameter "replication-type" are canonicalized to lower case.
......
...@@ -258,8 +258,8 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() { ...@@ -258,8 +258,8 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() {
"type": "pd-ssd", "type": "pd-ssd",
"zone": cloudZone, "zone": cloudZone,
}, },
claimSize: "1.5G", claimSize: "1.5Gi",
expectedSize: "2G", expectedSize: "2Gi",
pvCheck: func(volume *v1.PersistentVolume) error { pvCheck: func(volume *v1.PersistentVolume) error {
return checkGCEPD(volume, "pd-ssd") return checkGCEPD(volume, "pd-ssd")
}, },
...@@ -271,8 +271,8 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() { ...@@ -271,8 +271,8 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() {
parameters: map[string]string{ parameters: map[string]string{
"type": "pd-standard", "type": "pd-standard",
}, },
claimSize: "1.5G", claimSize: "1.5Gi",
expectedSize: "2G", expectedSize: "2Gi",
pvCheck: func(volume *v1.PersistentVolume) error { pvCheck: func(volume *v1.PersistentVolume) error {
return checkGCEPD(volume, "pd-standard") return checkGCEPD(volume, "pd-standard")
}, },
...@@ -437,8 +437,8 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() { ...@@ -437,8 +437,8 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() {
parameters: map[string]string{ parameters: map[string]string{
"type": "pd-standard", "type": "pd-standard",
}, },
claimSize: "1G", claimSize: "1Gi",
expectedSize: "1G", expectedSize: "1Gi",
pvCheck: func(volume *v1.PersistentVolume) error { pvCheck: func(volume *v1.PersistentVolume) error {
return checkGCEPD(volume, "pd-standard") return checkGCEPD(volume, "pd-standard")
}, },
...@@ -471,8 +471,8 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() { ...@@ -471,8 +471,8 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() {
parameters: map[string]string{ parameters: map[string]string{
"type": "pd-standard", "type": "pd-standard",
}, },
claimSize: "1G", claimSize: "1Gi",
expectedSize: "1G", expectedSize: "1Gi",
pvCheck: func(volume *v1.PersistentVolume) error { pvCheck: func(volume *v1.PersistentVolume) error {
return checkGCEPD(volume, "pd-standard") return checkGCEPD(volume, "pd-standard")
}, },
...@@ -522,7 +522,7 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() { ...@@ -522,7 +522,7 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() {
name: "unmanaged_zone", name: "unmanaged_zone",
provisioner: "kubernetes.io/gce-pd", provisioner: "kubernetes.io/gce-pd",
parameters: map[string]string{"zone": unmanagedZone}, parameters: map[string]string{"zone": unmanagedZone},
claimSize: "1G", claimSize: "1Gi",
} }
sc := newStorageClass(test, ns, suffix) sc := newStorageClass(test, ns, suffix)
sc, err = c.StorageV1().StorageClasses().Create(sc) sc, err = c.StorageV1().StorageClasses().Create(sc)
...@@ -716,13 +716,6 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() { ...@@ -716,13 +716,6 @@ var _ = utils.SIGDescribe("Dynamic Provisioning", func() {
claimSize: "2Gi", claimSize: "2Gi",
expectedSize: "2Gi", expectedSize: "2Gi",
} }
// gce or gke
if getDefaultPluginName() == "kubernetes.io/gce-pd" {
// using GB not GiB as e2e test unit since gce-pd returns GB,
// or expectedSize may be greater than claimSize.
test.claimSize = "2G"
test.expectedSize = "2G"
}
claim := newClaim(test, ns, "default") claim := newClaim(test, ns, "default")
testDynamicProvisioning(test, c, claim, nil) testDynamicProvisioning(test, c, claim, nil)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment