Skip to content
This repository was archived by the owner on Mar 22, 2018. It is now read-only.

Commit ec55d94

Browse files
committed
Merge branch 'master' into upgrade_aliases_branch
2 parents ca55453 + 588431e commit ec55d94

1 file changed

Lines changed: 4 additions & 8 deletions

File tree

pkg/cloudprovider/providers/openstack/openstack_routes.go

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ func (r *Routes) ListRoutes(clusterName string) ([]*cloudprovider.Route, error)
5353
glog.V(4).Infof("ListRoutes(%v)", clusterName)
5454

5555
nodeNamesByAddr := make(map[string]types.NodeName)
56-
err := foreachServer(r.compute, servers.ListOpts{Status: "ACTIVE"}, func(srv *servers.Server) (bool, error) {
56+
err := foreachServer(r.compute, servers.ListOpts{}, func(srv *servers.Server) (bool, error) {
5757
addrs, err := nodeAddresses(srv)
5858
if err != nil {
5959
return false, err
@@ -77,15 +77,11 @@ func (r *Routes) ListRoutes(clusterName string) ([]*cloudprovider.Route, error)
7777

7878
var routes []*cloudprovider.Route
7979
for _, item := range router.Routes {
80-
nodeName, ok := nodeNamesByAddr[item.NextHop]
81-
if !ok {
82-
// Not one of our routes?
83-
glog.V(4).Infof("Skipping route with unknown nexthop %v", item.NextHop)
84-
continue
85-
}
80+
nodeName, foundNode := nodeNamesByAddr[item.NextHop]
8681
route := cloudprovider.Route{
8782
Name: item.DestinationCIDR,
88-
TargetNode: nodeName,
83+
TargetNode: nodeName, //empty if NextHop is unknown
84+
Blackhole: !foundNode,
8985
DestinationCIDR: item.DestinationCIDR,
9086
}
9187
routes = append(routes, &route)

0 commit comments

Comments
 (0)