Merge lp:~axwalk/gwacl/gwacl into lp:gwacl

Proposed by Andrew Wilkins
Status: Merged
Approved by: Andrew Wilkins
Approved revision: 221
Merged at revision: 221
Proposed branch: lp:~axwalk/gwacl/gwacl
Merge into: lp:gwacl
Diff against target: 84 lines (+21/-14)
3 files modified
management.go (+1/-1)
management_base_test.go (+14/-7)
management_test.go (+6/-6)
To merge this branch: bzr merge lp:~axwalk/gwacl/gwacl
Reviewer Review Type Date Requested Status
Julian Edwards (community) Approve
Review via email: mp+182520@code.launchpad.net

Commit message

Delete OS disk blobs in DestroyDeployment

Fixes bug #1216744

Description of the change

Delete OS disk blobs in DestroyDeployment

Fixes bug #1216744

To post a comment you must log in.
Revision history for this message
Julian Edwards (julian-edwards) wrote :

Looks good, thanks.

review: Approve

Preview Diff

[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
=== modified file 'management.go'
--- management.go 2013-08-05 12:50:48 +0000
+++ management.go 2013-08-28 00:17:58 +0000
@@ -160,7 +160,7 @@
160 for _, diskName := range diskNames {160 for _, diskName := range diskNames {
161 err = api.DeleteDisk(&DeleteDiskRequest{161 err = api.DeleteDisk(&DeleteDiskRequest{
162 DiskName: diskName,162 DiskName: diskName,
163 DeleteBlob: false}) // change to true at some point?163 DeleteBlob: true})
164 if err != nil && !IsNotFoundError(err) {164 if err != nil && !IsNotFoundError(err) {
165 return err165 return err
166 }166 }
167167
=== modified file 'management_base_test.go'
--- management_base_test.go 2013-08-09 14:59:50 +0000
+++ management_base_test.go 2013-08-28 00:17:58 +0000
@@ -889,9 +889,12 @@
889 c.Check(keys.URL, Equals, url)889 c.Check(keys.URL, Equals, url)
890}890}
891891
892func assertDeleteDiskRequest(c *C, api *ManagementAPI, diskName string, httpRequest *X509Request) {892func assertDeleteDiskRequest(c *C, api *ManagementAPI, diskName string, httpRequest *X509Request, deleteBlob bool) {
893 expectedURL := fmt.Sprintf("%s%s/services/disks/%s", defaultManagement,893 expectedURL := fmt.Sprintf("%s%s/services/disks/%s", defaultManagement,
894 api.session.subscriptionId, diskName)894 api.session.subscriptionId, diskName)
895 if deleteBlob {
896 expectedURL += "?comp=media"
897 }
895 checkRequest(c, httpRequest, expectedURL, "2012-08-01", nil, "DELETE")898 checkRequest(c, httpRequest, expectedURL, "2012-08-01", nil, "DELETE")
896}899}
897900
@@ -902,13 +905,17 @@
902 // Change the polling interval to speed up the tests:905 // Change the polling interval to speed up the tests:
903 deleteDiskInterval = time.Nanosecond906 deleteDiskInterval = time.Nanosecond
904 api := makeAPI(c)907 api := makeAPI(c)
905 recordedRequests := setUpDispatcher("operationID")
906 diskName := "diskName"908 diskName := "diskName"
907 err := api.DeleteDisk(&DeleteDiskRequest{DiskName: diskName})909 for _, deleteBlob := range [...]bool{false, true} {
908910 recordedRequests := setUpDispatcher("operationID")
909 c.Assert(err, IsNil)911 err := api.DeleteDisk(&DeleteDiskRequest{
910 c.Assert(*recordedRequests, HasLen, 1)912 DiskName: diskName,
911 assertDeleteDiskRequest(c, api, diskName, (*recordedRequests)[0])913 DeleteBlob: deleteBlob,
914 })
915 c.Assert(err, IsNil)
916 c.Assert(*recordedRequests, HasLen, 1)
917 assertDeleteDiskRequest(c, api, diskName, (*recordedRequests)[0], deleteBlob)
918 }
912}919}
913920
914func (suite *managementBaseAPISuite) TestDeleteDiskWhenDiskDoesNotExist(c *C) {921func (suite *managementBaseAPISuite) TestDeleteDiskWhenDiskDoesNotExist(c *C) {
915922
=== modified file 'management_test.go'
--- management_test.go 2013-08-06 08:01:43 +0000
+++ management_test.go 2013-08-28 00:17:58 +0000
@@ -297,9 +297,9 @@
297 request.ServiceName, request.DeploymentName}, record[0])297 request.ServiceName, request.DeploymentName}, record[0])
298 assertDeleteDeploymentRequest(c, api, request.ServiceName,298 assertDeleteDeploymentRequest(c, api, request.ServiceName,
299 request.DeploymentName, record[1])299 request.DeploymentName, record[1])
300 assertDeleteDiskRequest(c, api, "disk1", record[2])300 assertDeleteDiskRequest(c, api, "disk1", record[2], true)
301 assertDeleteDiskRequest(c, api, "disk2", record[3])301 assertDeleteDiskRequest(c, api, "disk2", record[3], true)
302 assertDeleteDiskRequest(c, api, "disk3", record[4])302 assertDeleteDiskRequest(c, api, "disk3", record[4], true)
303}303}
304304
305func (suite *suiteDestroyDeployment) TestOkayWhenDeploymentNotFound(c *C) {305func (suite *suiteDestroyDeployment) TestOkayWhenDeploymentNotFound(c *C) {
@@ -343,9 +343,9 @@
343 request.ServiceName, request.DeploymentName}, record[0])343 request.ServiceName, request.DeploymentName}, record[0])
344 assertDeleteDeploymentRequest(c, api, request.ServiceName,344 assertDeleteDeploymentRequest(c, api, request.ServiceName,
345 request.DeploymentName, record[1])345 request.DeploymentName, record[1])
346 assertDeleteDiskRequest(c, api, "disk1", record[2])346 assertDeleteDiskRequest(c, api, "disk1", record[2], true)
347 assertDeleteDiskRequest(c, api, "disk2", record[3])347 assertDeleteDiskRequest(c, api, "disk2", record[3], true)
348 assertDeleteDiskRequest(c, api, "disk3", record[4])348 assertDeleteDiskRequest(c, api, "disk3", record[4], true)
349}349}
350350
351func (suite *suiteDestroyDeployment) TestFailsGettingDeployment(c *C) {351func (suite *suiteDestroyDeployment) TestFailsGettingDeployment(c *C) {

Subscribers

People subscribed via source and target branches

to all changes: