Skip to content

Commit 28ac855

Browse files
committed
Align resources status checks funcs
1 parent b51df31 commit 28ac855

File tree

2 files changed

+19
-5
lines changed

2 files changed

+19
-5
lines changed

pkg/server.go

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,11 @@ var serverNormalStatuses = []string{
4646
"SHUTOFF",
4747
}
4848

49+
var portNormalStatuses = []string{
50+
"ACTIVE",
51+
"DOWN",
52+
}
53+
4954
var serverWaitStatuses = []string{
5055
"BUILD",
5156
}
@@ -77,11 +82,11 @@ func waitForServer(client *gophercloud.ServiceClient, id string, secs float64) (
7782
}
7883

7984
log.Printf("Server status: %s", server.Status)
80-
if isSliceContainsStr(serverNormalStatuses, string(server.Status)) {
85+
if isSliceContainsStr(serverNormalStatuses, server.Status) {
8186
return true, nil
8287
}
8388

84-
if !isSliceContainsStr(serverWaitStatuses, string(server.Status)) {
89+
if !isSliceContainsStr(serverWaitStatuses, server.Status) {
8590
return false, fmt.Errorf("server status is %q", server.Status)
8691
}
8792

@@ -102,7 +107,7 @@ func waitForPort(client *gophercloud.ServiceClient, id string, secs float64) (*p
102107
}
103108

104109
log.Printf("Port status: %s", port.Status)
105-
if port.Status == "ACTIVE" || port.Status == "DOWN" {
110+
if isSliceContainsStr(portNormalStatuses, port.Status) {
106111
return true, nil
107112
}
108113

pkg/volume.go

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,15 @@ var (
3838
waitForSnapshotSec float64
3939
)
4040

41+
var volumeNormalStatuses = []string{
42+
"available",
43+
"in-use",
44+
}
45+
46+
var snapshotNormalStatuses = []string{
47+
"available",
48+
}
49+
4150
func expandVolumeProperties(srcVolume *volumes.Volume) images.UpdateOpts {
4251
// set min_disk and min_ram from a source volume
4352
imgAttrUpdateOpts := images.UpdateOpts{
@@ -81,7 +90,7 @@ func waitForSnapshot(client *gophercloud.ServiceClient, id string, secs float64)
8190
}
8291

8392
log.Printf("Intermediate snapshot status: %s", snapshot.Status)
84-
if snapshot.Status == "available" {
93+
if isSliceContainsStr(snapshotNormalStatuses, snapshot.Status) {
8594
return true, nil
8695
}
8796

@@ -116,7 +125,7 @@ func waitForVolume(client *gophercloud.ServiceClient, id string, secs float64) (
116125

117126
log.Printf("Volume status: %s", volume.Status)
118127
// TODO: specify target states in func params
119-
if volume.Status == "available" || volume.Status == "in-use" {
128+
if isSliceContainsStr(volumeNormalStatuses, volume.Status) {
120129
return true, nil
121130
}
122131

0 commit comments

Comments
 (0)