summaryrefslogtreecommitdiffhomepage
path: root/internal/pkg/table
diff options
context:
space:
mode:
Diffstat (limited to 'internal/pkg/table')
-rw-r--r--internal/pkg/table/adj.go7
-rw-r--r--internal/pkg/table/table_manager.go15
2 files changed, 6 insertions, 16 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 {
diff --git a/internal/pkg/table/table_manager.go b/internal/pkg/table/table_manager.go
index 57533322..55436369 100644
--- a/internal/pkg/table/table_manager.go
+++ b/internal/pkg/table/table_manager.go
@@ -190,21 +190,6 @@ func (tm *TableManager) update(newPath *Path) *Update {
return u
}
-func (manager *TableManager) GetPathListByPeer(info *PeerInfo, rf bgp.RouteFamily) []*Path {
- if t, ok := manager.Tables[rf]; ok {
- pathList := make([]*Path, 0, len(t.destinations))
- for _, dst := range t.destinations {
- for _, p := range dst.knownPathList {
- if p.GetSource().Equal(info) {
- pathList = append(pathList, p)
- }
- }
- }
- return pathList
- }
- return nil
-}
-
func (manager *TableManager) Update(newPath *Path) []*Update {
if newPath == nil || newPath.IsEOR() {
return nil