summaryrefslogtreecommitdiffhomepage
path: root/internal/pkg/table/adj.go
diff options
context:
space:
mode:
authorFUJITA Tomonori <fujita.tomonori@gmail.com>2019-08-26 10:26:07 +0900
committerFUJITA Tomonori <fujita.tomonori@gmail.com>2019-08-26 10:26:07 +0900
commit5856fe44297cb4248356671bc7a7f9c3bf17b699 (patch)
tree7a296d2057b0bbc03467e6417a3db20950281ef0 /internal/pkg/table/adj.go
parenta472a4964087989814740ac175d12b2759394c85 (diff)
table: kill GetPathListByPeer()
when a peer is down, use paths in its adj table instead of searching for the global table. Signed-off-by: FUJITA Tomonori <fujita.tomonori@gmail.com>
Diffstat (limited to 'internal/pkg/table/adj.go')
-rw-r--r--internal/pkg/table/adj.go7
1 files changed, 6 insertions, 1 deletions
diff --git a/internal/pkg/table/adj.go b/internal/pkg/table/adj.go
index 95fbf6af..acb2c07b 100644
--- a/internal/pkg/table/adj.go
+++ b/internal/pkg/table/adj.go
@@ -106,13 +106,18 @@ func (adj *AdjRib) Accepted(rfList []bgp.RouteFamily) int {
return count
}
-func (adj *AdjRib) Drop(rfList []bgp.RouteFamily) {
+func (adj *AdjRib) Drop(rfList []bgp.RouteFamily) []*Path {
+ l := make([]*Path, 0, adj.Count(rfList))
for _, rf := range rfList {
if _, ok := adj.table[rf]; ok {
+ for _, p := range adj.table[rf] {
+ l = append(l, p.Clone(true))
+ }
adj.table[rf] = make(map[string]*Path)
adj.accepted[rf] = 0
}
}
+ return l
}
func (adj *AdjRib) DropStale(rfList []bgp.RouteFamily) []*Path {