github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 21:47:07 +00:00
Code Issues Projects Releases Wiki Activity

Fix for panic when instance not found

Browse Source 
This removes a panic I mistakenly introduced when an instance is not
found, and also restores the exact prior behaviour for
getInstanceByName, where it returns cloudprovider.InstanceNotFound when
the instance is not found.
This commit is contained in:
Justin Santa Barbara 2016-01-21 19:15:09 -05:00
parent 4ac2f7453d
commit 2201c631b3
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
pkg/cloudprovider/providers/gce/gce.go
View File

@ -1815,6 +1815,7 @@ type gceDisk struct {
Kind string Kind string
} }
// Gets the named instances, returning cloudprovider.InstanceNotFound if any instance is not found
func (gce *GCECloud) getInstancesByNames(names []string) ([]*gceInstance, error) { func (gce *GCECloud) getInstancesByNames(names []string) ([]*gceInstance, error) {
instances := make(map[string]*gceInstance) instances := make(map[string]*gceInstance)
@ -1863,7 +1864,8 @@ func (gce *GCECloud) getInstancesByNames(names []string) ([]*gceInstance, error)
for i, name := range names { for i, name := range names {
instance := instances[name] instance := instances[name]
if instance == nil { if instance == nil {
return nil, fmt.Errorf("failed to retrieve instance: %q", name) glog.Errorf("Failed to retrieve instance: %q", name)
return nil, cloudprovider.InstanceNotFound
} }
instanceArray[i] = instances[name] instanceArray[i] = instances[name]
} }
@ -1871,6 +1873,7 @@ func (gce *GCECloud) getInstancesByNames(names []string) ([]*gceInstance, error)
return instanceArray, nil return instanceArray, nil
} }
// Gets the named instance, returning cloudprovider.InstanceNotFound if the instance is not found
func (gce *GCECloud) getInstanceByName(name string) (*gceInstance, error) { func (gce *GCECloud) getInstanceByName(name string) (*gceInstance, error) {
// Avoid changing behaviour when not managing multiple zones // Avoid changing behaviour when not managing multiple zones
if len(gce.managedZones) == 1 { if len(gce.managedZones) == 1 {
@ -1878,9 +1881,11 @@ func (gce *GCECloud) getInstanceByName(name string) (*gceInstance, error) {
zone := gce.managedZones[0] zone := gce.managedZones[0]
res, err := gce.service.Instances.Get(gce.projectID, zone, name).Do() res, err := gce.service.Instances.Get(gce.projectID, zone, name).Do()
if err != nil { if err != nil {
if !isHTTPErrorCode(err, http.StatusNotFound) { glog.Errorf("Failed to retrieve TargetInstance resource for instance: %s", name)
return nil, err if isHTTPErrorCode(err, http.StatusNotFound) {
return nil, cloudprovider.InstanceNotFound
} }
return nil, err
} }
return &gceInstance{ return &gceInstance{
Zone: lastComponent(res.Zone), Zone: lastComponent(res.Zone),
@ -1895,6 +1900,7 @@ func (gce *GCECloud) getInstanceByName(name string) (*gceInstance, error) {
return nil, err return nil, err
} }
if len(instances) != 1 || instances[0] == nil { if len(instances) != 1 || instances[0] == nil {
// getInstancesByNames not obeying its contract
return nil, fmt.Errorf("unexpected return value from getInstancesByNames: %v", instances) return nil, fmt.Errorf("unexpected return value from getInstancesByNames: %v", instances)
} }
return instances[0], nil return instances[0], nil