/usr/share/gocode/src/github.com/Azure/azure-sdk-for-go/management/vmutils/rolestate.go is in golang-github-azure-azure-sdk-for-go-dev 2.1.1~beta-3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 | package vmutils
import (
"time"
"github.com/Azure/azure-sdk-for-go/management"
vm "github.com/Azure/azure-sdk-for-go/management/virtualmachine"
)
// WaitForDeploymentPowerState blocks until all role instances in deployment
// reach desired power state.
func WaitForDeploymentPowerState(client management.Client, cloudServiceName, deploymentName string, desiredPowerstate vm.PowerState) error {
for {
deployment, err := vm.NewClient(client).GetDeployment(cloudServiceName, deploymentName)
if err != nil {
return err
}
if allInstancesInPowerState(deployment.RoleInstanceList, desiredPowerstate) {
return nil
}
time.Sleep(2 * time.Second)
}
}
func allInstancesInPowerState(instances []vm.RoleInstance, desiredPowerstate vm.PowerState) bool {
for _, r := range instances {
if r.PowerState != desiredPowerstate {
return false
}
}
return true
}
// WaitForDeploymentInstanceStatus blocks until all role instances in deployment
// reach desired InstanceStatus.
func WaitForDeploymentInstanceStatus(client management.Client, cloudServiceName, deploymentName string, desiredInstanceStatus vm.InstanceStatus) error {
for {
deployment, err := vm.NewClient(client).GetDeployment(cloudServiceName, deploymentName)
if err != nil {
return err
}
if allInstancesInInstanceStatus(deployment.RoleInstanceList, desiredInstanceStatus) {
return nil
}
time.Sleep(2 * time.Second)
}
}
func allInstancesInInstanceStatus(instances []vm.RoleInstance, desiredInstancestatus vm.InstanceStatus) bool {
for _, r := range instances {
if r.InstanceStatus != desiredInstancestatus {
return false
}
}
return true
}
|