Skip to content

Commit 15c2f37

Browse files
authored
Merge pull request #20 from Leaseweb/fix_detach
revert passing vmID to DetachVolume
2 parents cfe10a4 + bb47b14 commit 15c2f37

File tree

4 files changed

+5
-9
lines changed

4 files changed

+5
-9
lines changed

pkg/cloud/cloud.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ type Interface interface {
2121
CreateVolume(ctx context.Context, diskOfferingID, zoneID, name string, sizeInGB int64) (string, error)
2222
DeleteVolume(ctx context.Context, id string) error
2323
AttachVolume(ctx context.Context, volumeID, vmID string) (string, error)
24-
DetachVolume(ctx context.Context, volumeID string, vmID string) error
24+
DetachVolume(ctx context.Context, volumeID string) error
2525
}
2626

2727
// Volume represents a CloudStack volume.

pkg/cloud/fake/fake.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -100,6 +100,6 @@ func (f *fakeConnector) AttachVolume(ctx context.Context, volumeID, vmID string)
100100
return "1", nil
101101
}
102102

103-
func (f *fakeConnector) DetachVolume(ctx context.Context, volumeID string, vmID string) error {
103+
func (f *fakeConnector) DetachVolume(ctx context.Context, volumeID string) error {
104104
return nil
105105
}

pkg/cloud/volumes.go

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -111,15 +111,11 @@ func (c *client) AttachVolume(ctx context.Context, volumeID, vmID string) (strin
111111
return strconv.FormatInt(r.Deviceid, 10), nil
112112
}
113113

114-
func (c *client) DetachVolume(ctx context.Context, volumeID string, vmID string) error {
114+
func (c *client) DetachVolume(ctx context.Context, volumeID string) error {
115115
p := c.Volume.NewDetachVolumeParams()
116116
p.SetId(volumeID)
117-
if vmID != "" {
118-
p.SetVirtualmachineid(vmID)
119-
}
120117
ctxzap.Extract(ctx).Sugar().Infow("CloudStack API call", "command", "DetachVolume", "params", map[string]string{
121-
"id": volumeID,
122-
"virtualmachineid": vmID,
118+
"id": volumeID,
123119
})
124120
_, err := c.Volume.DetachVolume(p)
125121
return err

pkg/driver/controller.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -308,7 +308,7 @@ func (cs *controllerServer) ControllerUnpublishVolume(ctx context.Context, req *
308308
return nil, status.Errorf(codes.Internal, "Error %v", err)
309309
}
310310

311-
err := cs.connector.DetachVolume(ctx, volumeID, nodeID)
311+
err := cs.connector.DetachVolume(ctx, volumeID)
312312
if err != nil {
313313
return nil, status.Errorf(codes.Internal, "Cannot detach volume %s: %s", volumeID, err.Error())
314314
}

0 commit comments

Comments
 (0)