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

Commit 225151e

Browse files
committed
relax server list option, set Blackhole field
1 parent aa5916d commit 225151e

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

pkg/cloudprovider/providers/openstack/openstack_routes.go

Lines changed: 4 additions & 2 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,9 +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, foundNode := nodeNamesByAddr[item.NextHop]
8081
route := cloudprovider.Route{
8182
Name: item.DestinationCIDR,
82-
TargetNode: nodeNamesByAddr[item.NextHop], //empty if NextHop is unknown
83+
TargetNode: nodeName, //empty if NextHop is unknown
84+
Blackhole: !foundNode,
8385
DestinationCIDR: item.DestinationCIDR,
8486
}
8587
routes = append(routes, &route)

0 commit comments

Comments
 (0)