summaryrefslogtreecommitdiffhomepage
path: root/server
diff options
context:
space:
mode:
Diffstat (limited to 'server')
-rw-r--r--server/peer.go2
-rw-r--r--server/server.go8
2 files changed, 5 insertions, 5 deletions
diff --git a/server/peer.go b/server/peer.go
index 1844236e..f1f73580 100644
--- a/server/peer.go
+++ b/server/peer.go
@@ -214,7 +214,7 @@ func (peer *Peer) handleBGPmessage(e *FsmMsg) ([]*table.Path, []*bgp.BGPMessage)
peer.adjRibIn.Update(e.PathList)
paths := make([]*table.Path, 0, len(e.PathList))
for _, path := range e.PathList {
- if path.Filtered(peer.TableID()) != table.POLICY_DIRECTION_IN {
+ if path.Filtered(peer.ID()) != table.POLICY_DIRECTION_IN {
paths = append(paths, path)
}
}
diff --git a/server/server.go b/server/server.go
index c8764587..8896ade2 100644
--- a/server/server.go
+++ b/server/server.go
@@ -656,7 +656,7 @@ func (server *BgpServer) propagateUpdate(peer *Peer, pathList []*table.Path) []*
rib := server.globalRib
if peer != nil && peer.isRouteServerClient() {
for _, path := range pathList {
- path.Filter(peer.TableID(), table.POLICY_DIRECTION_IMPORT)
+ path.Filter(peer.ID(), table.POLICY_DIRECTION_IMPORT)
path.Filter(table.GLOBAL_RIB_NAME, table.POLICY_DIRECTION_IMPORT)
}
moded := []*table.Path{}
@@ -667,14 +667,14 @@ func (server *BgpServer) propagateUpdate(peer *Peer, pathList []*table.Path) []*
for _, before := range pathList {
after := server.policy.ApplyPolicy(targetPeer.TableID(), table.POLICY_DIRECTION_IMPORT, before)
if after == nil {
- before.Filter(targetPeer.TableID(), table.POLICY_DIRECTION_IMPORT)
+ before.Filter(targetPeer.ID(), table.POLICY_DIRECTION_IMPORT)
} else if after != before {
- before.Filter(targetPeer.TableID(), table.POLICY_DIRECTION_IMPORT)
+ before.Filter(targetPeer.ID(), table.POLICY_DIRECTION_IMPORT)
for _, n := range server.neighborMap {
if n == targetPeer {
continue
}
- after.Filter(n.TableID(), table.POLICY_DIRECTION_IMPORT)
+ after.Filter(n.ID(), table.POLICY_DIRECTION_IMPORT)
}
moded = append(moded, after)
}