diff options
| -rw-r--r-- | server/peer.go | 2 | ||||
| -rw-r--r-- | server/server.go | 8 |
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) } |