Skip to content

Commit 3f9ca0a

Browse files
committed
fix: use force detach for azure disk
revert attach disk change revert some change fix: should not filter out disk in attach azure disk
1 parent cf36d9b commit 3f9ca0a

File tree

2 files changed

+10
-6
lines changed

2 files changed

+10
-6
lines changed

staging/src/k8s.io/legacy-cloud-providers/azure/azure_controller_standard.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,8 @@ func (as *availabilitySet) AttachDisk(isManagedDisk bool, diskName, diskURI stri
4444
return err
4545
}
4646

47-
disks := filterDetachingDisks(*vm.StorageProfile.DataDisks)
47+
disks := make([]compute.DataDisk, len(*vm.StorageProfile.DataDisks))
48+
copy(disks, *vm.StorageProfile.DataDisks)
4849

4950
if isManagedDisk {
5051
managedDisk := &compute.ManagedDiskParameters{ID: &diskURI}
@@ -131,7 +132,8 @@ func (as *availabilitySet) DetachDisk(diskName, diskURI string, nodeName types.N
131132
return err
132133
}
133134

134-
disks := filterDetachingDisks(*vm.StorageProfile.DataDisks)
135+
disks := make([]compute.DataDisk, len(*vm.StorageProfile.DataDisks))
136+
copy(disks, *vm.StorageProfile.DataDisks)
135137

136138
bFoundDisk := false
137139
for i, disk := range disks {
@@ -140,7 +142,7 @@ func (as *availabilitySet) DetachDisk(diskName, diskURI string, nodeName types.N
140142
(disk.ManagedDisk != nil && diskURI != "" && strings.EqualFold(*disk.ManagedDisk.ID, diskURI)) {
141143
// found the disk
142144
klog.V(2).Infof("azureDisk - detach disk: name %q uri %q", diskName, diskURI)
143-
disks = append(disks[:i], disks[i+1:]...)
145+
disks[i].ToBeDetached = to.BoolPtr(true)
144146
bFoundDisk = true
145147
break
146148
}

staging/src/k8s.io/legacy-cloud-providers/azure/azure_controller_vmss.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,8 @@ func (ss *scaleSet) AttachDisk(isManagedDisk bool, diskName, diskURI string, nod
4646

4747
disks := []compute.DataDisk{}
4848
if vm.StorageProfile != nil && vm.StorageProfile.DataDisks != nil {
49-
disks = filterDetachingDisks(*vm.StorageProfile.DataDisks)
49+
disks = make([]compute.DataDisk, len(*vm.StorageProfile.DataDisks))
50+
copy(disks, *vm.StorageProfile.DataDisks)
5051
}
5152
if isManagedDisk {
5253
managedDisk := &compute.ManagedDiskParameters{ID: &diskURI}
@@ -136,7 +137,8 @@ func (ss *scaleSet) DetachDisk(diskName, diskURI string, nodeName types.NodeName
136137

137138
disks := []compute.DataDisk{}
138139
if vm.StorageProfile != nil && vm.StorageProfile.DataDisks != nil {
139-
disks = filterDetachingDisks(*vm.StorageProfile.DataDisks)
140+
disks = make([]compute.DataDisk, len(*vm.StorageProfile.DataDisks))
141+
copy(disks, *vm.StorageProfile.DataDisks)
140142
}
141143
bFoundDisk := false
142144
for i, disk := range disks {
@@ -145,7 +147,7 @@ func (ss *scaleSet) DetachDisk(diskName, diskURI string, nodeName types.NodeName
145147
(disk.ManagedDisk != nil && diskURI != "" && strings.EqualFold(*disk.ManagedDisk.ID, diskURI)) {
146148
// found the disk
147149
klog.V(2).Infof("azureDisk - detach disk: name %q uri %q", diskName, diskURI)
148-
disks = append(disks[:i], disks[i+1:]...)
150+
disks[i].ToBeDetached = to.BoolPtr(true)
149151
bFoundDisk = true
150152
break
151153
}

0 commit comments

Comments
 (0)