summaryrefslogtreecommitdiffhomepage
path: root/table/table_manager_test.go
diff options
context:
space:
mode:
authorFUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>2018-07-07 13:48:38 +0900
committerFUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>2018-07-07 20:44:25 +0900
commitc4775c42510d1f1ddd55036dc19e982712fa6a0b (patch)
tree6ec8b61d4338c809e239e3003a2d32d480898e22 /table/table_manager_test.go
parentb3079759aa13172fcb548a83da9a9653d8d5fed4 (diff)
follow Standard Go Project Layout
https://github.com/golang-standards/project-layout Now you can see clearly what are private and public library code. Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
Diffstat (limited to 'table/table_manager_test.go')
-rw-r--r--table/table_manager_test.go2281
1 files changed, 0 insertions, 2281 deletions
diff --git a/table/table_manager_test.go b/table/table_manager_test.go
deleted file mode 100644
index 11a7b066..00000000
--- a/table/table_manager_test.go
+++ /dev/null
@@ -1,2281 +0,0 @@
-// Copyright (C) 2014 Nippon Telegraph and Telephone Corporation.
-//
-// Licensed under the Apache License, Version 2.0 (the "License");
-// you may not use this file except in compliance with the License.
-// You may obtain a copy of the License at
-//
-// http://www.apache.org/licenses/LICENSE-2.0
-//
-// Unless required by applicable law or agreed to in writing, software
-// distributed under the License is distributed on an "AS IS" BASIS,
-// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or
-// implied.
-// See the License for the specific language governing permissions and
-// limitations under the License.
-
-package table
-
-import (
- _ "fmt"
- "net"
- "testing"
- "time"
-
- "github.com/osrg/gobgp/packet/bgp"
- "github.com/stretchr/testify/assert"
-)
-
-// process BGPUpdate message
-// this function processes only BGPUpdate
-func (manager *TableManager) ProcessUpdate(fromPeer *PeerInfo, message *bgp.BGPMessage) ([]*Path, error) {
- pathList := make([]*Path, 0)
- dsts := make([]*Update, 0)
- for _, path := range ProcessMessage(message, fromPeer, time.Now()) {
- dsts = append(dsts, manager.Update(path)...)
- }
- for _, d := range dsts {
- b, _, _ := d.GetChanges(GLOBAL_RIB_NAME, 0, false)
- pathList = append(pathList, b)
- }
- return pathList, nil
-}
-
-func peerR1() *PeerInfo {
- peer := &PeerInfo{
- AS: 65000,
- LocalAS: 65000,
- ID: net.ParseIP("10.0.0.3").To4(),
- LocalID: net.ParseIP("10.0.0.1").To4(),
- Address: net.ParseIP("10.0.0.1").To4(),
- }
- return peer
-}
-
-func peerR2() *PeerInfo {
- peer := &PeerInfo{
- AS: 65100,
- LocalAS: 65000,
- Address: net.ParseIP("10.0.0.2").To4(),
- }
- return peer
-}
-
-func peerR3() *PeerInfo {
- peer := &PeerInfo{
- AS: 65000,
- LocalAS: 65000,
- ID: net.ParseIP("10.0.0.2").To4(),
- LocalID: net.ParseIP("10.0.0.1").To4(),
- Address: net.ParseIP("10.0.0.3").To4(),
- }
- return peer
-}
-
-// test best path calculation and check the result path is from R1
-func TestProcessBGPUpdate_0_select_onlypath_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- bgpMessage := update_fromR1()
- peer := peerR1()
- pList, err := tm.ProcessUpdate(peer, bgpMessage)
- assert.Equal(t, len(pList), 1)
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 4, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.50.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test best path calculation and check the result path is from R1
-func TestProcessBGPUpdate_0_select_onlypath_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- bgpMessage := update_fromR1_ipv6()
- peer := peerR1()
- pList, err := tm.ProcessUpdate(peer, bgpMessage)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 4, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:50:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test: compare localpref
-func TestProcessBGPUpdate_1_select_high_localpref_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- // low localpref message
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(0)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // high localpref message
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- nexthop2 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med2 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref2 := bgp.NewPathAttributeLocalPref(200)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin2, aspath2, nexthop2, med2, localpref2,
- }
- nlri2 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes2), len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.50.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-func TestProcessBGPUpdate_1_select_high_localpref_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- mp_reach2 := createMpReach("2001::192:168:100:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med2 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref2 := bgp.NewPathAttributeLocalPref(200)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- mp_reach2, origin2, aspath2, med2, localpref2,
- }
-
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 5, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:100:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test: compare localOrigin
-func TestProcessBGPUpdate_2_select_local_origin_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- // low localpref message
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(0)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // high localpref message
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{})
- nexthop2 := bgp.NewPathAttributeNextHop("0.0.0.0")
- med2 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin2, aspath2, nexthop2, med2, localpref2,
- }
- nlri2 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- var peer2 *PeerInfo = &PeerInfo{
- Address: net.ParseIP("0.0.0.0"),
- }
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes2), len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "0.0.0.0"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-func TestProcessBGPUpdate_2_select_local_origin_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{})
- mp_reach2 := createMpReach("::",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med2 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- mp_reach2, origin2, aspath2, med2, localpref2,
- }
-
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- var peer2 *PeerInfo = &PeerInfo{
- Address: net.ParseIP("0.0.0.0"),
- }
-
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 5, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "::"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test: compare AS_PATH
-func TestProcessBGPUpdate_3_select_aspath_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- bgpMessage1 := update_fromR2viaR1()
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
- bgpMessage2 := update_fromR2()
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 4, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "20.20.20.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.100.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-func TestProcessBGPUpdate_3_select_aspath_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- bgpMessage1 := update_fromR2viaR1_ipv6()
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
- bgpMessage2 := update_fromR2_ipv6()
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 4, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "2002:223:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:100:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test: compare Origin
-func TestProcessBGPUpdate_4_select_low_origin_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- // low origin message
- origin1 := bgp.NewPathAttributeOrigin(1)
- aspath1 := createAsPathAttribute([]uint32{65200, 65000})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // high origin message
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
- med2 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin2, aspath2, nexthop2, med2, localpref2,
- }
- nlri2 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes2), len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.100.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-func TestProcessBGPUpdate_4_select_low_origin_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(1)
- aspath1 := createAsPathAttribute([]uint32{65200, 65000})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- mp_reach2 := createMpReach("2001::192:168:100:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med2 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref2 := bgp.NewPathAttributeLocalPref(200)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- mp_reach2, origin2, aspath2, med2, localpref2,
- }
-
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 5, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:100:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test: compare MED
-func TestProcessBGPUpdate_5_select_low_med_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- // low origin message
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65200, 65000})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(500)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // high origin message
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
- med2 := bgp.NewPathAttributeMultiExitDisc(100)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin2, aspath2, nexthop2, med2, localpref2,
- }
- nlri2 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes2), len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.100.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-func TestProcessBGPUpdate_5_select_low_med_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65200, 65000})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(500)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- mp_reach2 := createMpReach("2001::192:168:100:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- mp_reach2, origin2, aspath2, med2, localpref2,
- }
-
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 5, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:100:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test: compare AS_NUMBER(prefer eBGP path)
-func TestProcessBGPUpdate_6_select_ebgp_path_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- // low origin message
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000, 65200})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // high origin message
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin2, aspath2, nexthop2, med2, localpref2,
- }
- nlri2 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes2), len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.100.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-func TestProcessBGPUpdate_6_select_ebgp_path_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000, 65200})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65200})
- mp_reach2 := createMpReach("2001::192:168:100:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- mp_reach2, origin2, aspath2, med2, localpref2,
- }
-
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 5, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:100:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test: compare IGP cost -> N/A
-
-// test: compare Router ID
-func TestProcessBGPUpdate_7_select_low_routerid_path_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
- SelectionOptions.ExternalCompareRouterId = true
-
- // low origin message
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000, 65200})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // high origin message
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65000, 65100})
- nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin2, aspath2, nexthop2, med2, localpref2,
- }
- nlri2 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer3 := peerR3()
- pList, err = tm.ProcessUpdate(peer3, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes2), len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.100.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-func TestProcessBGPUpdate_7_select_low_routerid_path_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000, 65200})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65200})
- mp_reach2 := createMpReach("2001::192:168:100:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- mp_reach2, origin2, aspath2, med2, localpref2,
- }
-
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer3 := peerR3()
- pList, err = tm.ProcessUpdate(peer3, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, 5, len(path.GetPathAttrs()))
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:100:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// test: withdraw and mpunreach path
-func TestProcessBGPUpdate_8_withdraw_path_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- // path1
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // path 2
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(200)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin2, aspath2, nexthop2, med2, localpref2,
- }
- nlri2 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- checkPattr := func(expected *bgp.BGPMessage, actual *Path) {
- pathAttributes := expected.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := actual.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes), len(path.GetPathAttrs()))
- }
- checkPattr(bgpMessage2, path)
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.100.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
- //withdraw path
- w1 := bgp.NewIPAddrPrefix(24, "10.10.10.0")
- w := []*bgp.IPAddrPrefix{w1}
- bgpMessage3 := bgp.NewBGPUpdateMessage(w, nil, nil)
-
- pList, err = tm.ProcessUpdate(peer2, bgpMessage3)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- path = pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- checkPattr(bgpMessage1, path)
- // check destination
- expectedPrefix = "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop = "192.168.50.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-}
-
-// TODO MP_UNREACH
-func TestProcessBGPUpdate_8_mpunreach_path_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65100, 65000})
- mp_reach2 := createMpReach("2001::192:168:100:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(200)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- mp_reach2, origin2, aspath2, med2, localpref2,
- }
-
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- peer2 := peerR2()
- pList, err = tm.ProcessUpdate(peer2, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute
- checkPattr := func(expected *bgp.BGPMessage, actual *Path) {
- pathAttributes := expected.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes), len(path.GetPathAttrs()))
- }
-
- checkPattr(bgpMessage2, path)
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:100:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
- //mpunreach path
- mp_unreach := createMpUNReach("2001:123:123:1::", 64)
- bgpMessage3 := bgp.NewBGPUpdateMessage(nil, []bgp.PathAttributeInterface{mp_unreach}, nil)
-
- pList, err = tm.ProcessUpdate(peer2, bgpMessage3)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- path = pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- checkPattr(bgpMessage1, path)
- // check destination
- expectedPrefix = "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop = "2001::192:168:50:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// handle bestpath lost
-func TestProcessBGPUpdate_bestpath_lost_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- // path1
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // path 1 withdraw
- w1 := bgp.NewIPAddrPrefix(24, "10.10.10.0")
- w := []*bgp.IPAddrPrefix{w1}
- bgpMessage1_w := bgp.NewBGPUpdateMessage(w, nil, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage1_w)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, true)
- assert.NoError(t, err)
-
- // check old best path
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- checkPattr := func(expected *bgp.BGPMessage, actual *Path) {
- pathAttributes := expected.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := actual.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes), len(path.GetPathAttrs()))
- }
-
- checkPattr(bgpMessage1, path)
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
-}
-
-func TestProcessBGPUpdate_bestpath_lost_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // path1 mpunreach
- mp_unreach := createMpUNReach("2001:123:123:1::", 64)
- bgpMessage1_w := bgp.NewBGPUpdateMessage(nil, []bgp.PathAttributeInterface{mp_unreach}, nil)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage1_w)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, true)
- assert.NoError(t, err)
-
- // check old best path
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- checkPattr := func(expected *bgp.BGPMessage, actual *Path) {
- pathAttributes := expected.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := actual.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes), len(path.GetPathAttrs()))
- }
-
- checkPattr(bgpMessage1, path)
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
-}
-
-// test: implicit withdrawal case
-func TestProcessBGPUpdate_implicit_withdrwal_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- // path1
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000, 65100, 65200})
- nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- origin1, aspath1, nexthop1, med1, localpref1,
- }
- nlri1 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // path 1 from same peer but short AS_PATH
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65000, 65100})
- nexthop2 := bgp.NewPathAttributeNextHop("192.168.50.1")
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(100)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin2, aspath2, nexthop2, med2, localpref2,
- }
- nlri2 := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv4_UC)
-
- // check PathAttribute
- checkPattr := func(expected *bgp.BGPMessage, actual *Path) {
- pathAttributes := expected.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := actual.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes), len(path.GetPathAttrs()))
- }
- checkPattr(bgpMessage2, path)
- // check destination
- expectedPrefix := "10.10.10.0/24"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "192.168.50.1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-func TestProcessBGPUpdate_implicit_withdrwal_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint32{65000, 65100, 65200})
- mp_reach1 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med1 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref1 := bgp.NewPathAttributeLocalPref(200)
-
- pathAttributes1 := []bgp.PathAttributeInterface{
- mp_reach1, origin1, aspath1, med1, localpref1,
- }
-
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint32{65000, 65100})
- mp_reach2 := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
- med2 := bgp.NewPathAttributeMultiExitDisc(200)
- localpref2 := bgp.NewPathAttributeLocalPref(200)
-
- pathAttributes2 := []bgp.PathAttributeInterface{
- mp_reach2, origin2, aspath2, med2, localpref2,
- }
-
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage2)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check type
- path := pList[0]
- assert.Equal(t, path.GetRouteFamily(), bgp.RF_IPv6_UC)
-
- // check PathAttribute
- pathAttributes := bgpMessage2.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute
- checkPattr := func(expected *bgp.BGPMessage, actual *Path) {
- pathAttributes := expected.Body.(*bgp.BGPUpdate).PathAttributes
-
- expectedNexthopAttr := pathAttributes[0]
- attr := actual.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- pathNexthop := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[1]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[2]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[3]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes), len(path.GetPathAttrs()))
- }
-
- checkPattr(bgpMessage2, path)
-
- // check destination
- expectedPrefix := "2001:123:123:1::/64"
- assert.Equal(t, expectedPrefix, path.getPrefix())
- // check nexthop
- expectedNexthop := "2001::192:168:50:1"
- assert.Equal(t, expectedNexthop, path.GetNexthop().String())
-
-}
-
-// check multiple paths
-func TestProcessBGPUpdate_multiple_nlri_ipv4(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC})
-
- createPathAttr := func(aspaths []uint32, nh string) []bgp.PathAttributeInterface {
- origin := bgp.NewPathAttributeOrigin(0)
- aspath := createAsPathAttribute(aspaths)
- nexthop := bgp.NewPathAttributeNextHop(nh)
- med := bgp.NewPathAttributeMultiExitDisc(200)
- localpref := bgp.NewPathAttributeLocalPref(100)
- pathAttr := []bgp.PathAttributeInterface{
- origin, aspath, nexthop, med, localpref,
- }
- return pathAttr
- }
-
- // check PathAttribute
- checkPattr := func(expected *bgp.BGPMessage, actual *Path) {
- pathAttributes := expected.Body.(*bgp.BGPUpdate).PathAttributes
- expectedOrigin := pathAttributes[0]
- attr := actual.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedNexthopAttr := pathAttributes[2]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_NEXT_HOP)
- pathNexthop := attr.(*bgp.PathAttributeNextHop)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedMed := pathAttributes[3]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes), len(actual.GetPathAttrs()))
- }
-
- checkBestPathResult := func(rf bgp.RouteFamily, prefix, nexthop string, p *Path, m *bgp.BGPMessage) {
- assert.Equal(t, p.GetRouteFamily(), rf)
- checkPattr(m, p)
- // check destination
- assert.Equal(t, prefix, p.getPrefix())
- // check nexthop
- assert.Equal(t, nexthop, p.GetNexthop().String())
- }
-
- // path1
- pathAttributes1 := createPathAttr([]uint32{65000, 65100, 65200}, "192.168.50.1")
- nlri1 := []*bgp.IPAddrPrefix{
- bgp.NewIPAddrPrefix(24, "10.10.10.0"),
- bgp.NewIPAddrPrefix(24, "20.20.20.0"),
- bgp.NewIPAddrPrefix(24, "30.30.30.0"),
- bgp.NewIPAddrPrefix(24, "40.40.40.0"),
- bgp.NewIPAddrPrefix(24, "50.50.50.0")}
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nlri1)
-
- // path2
- pathAttributes2 := createPathAttr([]uint32{65000, 65100, 65300}, "192.168.50.1")
- nlri2 := []*bgp.IPAddrPrefix{
- bgp.NewIPAddrPrefix(24, "11.11.11.0"),
- bgp.NewIPAddrPrefix(24, "22.22.22.0"),
- bgp.NewIPAddrPrefix(24, "33.33.33.0"),
- bgp.NewIPAddrPrefix(24, "44.44.44.0"),
- bgp.NewIPAddrPrefix(24, "55.55.55.0")}
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri2)
-
- // path3
- pathAttributes3 := createPathAttr([]uint32{65000, 65100, 65400}, "192.168.50.1")
- nlri3 := []*bgp.IPAddrPrefix{
- bgp.NewIPAddrPrefix(24, "77.77.77.0"),
- bgp.NewIPAddrPrefix(24, "88.88.88.0"),
- }
- bgpMessage3 := bgp.NewBGPUpdateMessage(nil, pathAttributes3, nlri3)
-
- // path4
- pathAttributes4 := createPathAttr([]uint32{65000, 65100, 65500}, "192.168.50.1")
- nlri4 := []*bgp.IPAddrPrefix{
- bgp.NewIPAddrPrefix(24, "99.99.99.0"),
- }
- bgpMessage4 := bgp.NewBGPUpdateMessage(nil, pathAttributes4, nlri4)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 5, len(pList))
- for _, p := range pList {
- assert.Equal(t, p.IsWithdraw, false)
- }
- assert.NoError(t, err)
-
- checkBestPathResult(bgp.RF_IPv4_UC, "10.10.10.0/24", "192.168.50.1", pList[0], bgpMessage1)
- checkBestPathResult(bgp.RF_IPv4_UC, "20.20.20.0/24", "192.168.50.1", pList[1], bgpMessage1)
- checkBestPathResult(bgp.RF_IPv4_UC, "30.30.30.0/24", "192.168.50.1", pList[2], bgpMessage1)
- checkBestPathResult(bgp.RF_IPv4_UC, "40.40.40.0/24", "192.168.50.1", pList[3], bgpMessage1)
- checkBestPathResult(bgp.RF_IPv4_UC, "50.50.50.0/24", "192.168.50.1", pList[4], bgpMessage1)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage2)
- assert.Equal(t, 5, len(pList))
- for _, p := range pList {
- assert.Equal(t, p.IsWithdraw, false)
- }
- assert.NoError(t, err)
-
- checkBestPathResult(bgp.RF_IPv4_UC, "11.11.11.0/24", "192.168.50.1", pList[0], bgpMessage2)
- checkBestPathResult(bgp.RF_IPv4_UC, "22.22.22.0/24", "192.168.50.1", pList[1], bgpMessage2)
- checkBestPathResult(bgp.RF_IPv4_UC, "33.33.33.0/24", "192.168.50.1", pList[2], bgpMessage2)
- checkBestPathResult(bgp.RF_IPv4_UC, "44.44.44.0/24", "192.168.50.1", pList[3], bgpMessage2)
- checkBestPathResult(bgp.RF_IPv4_UC, "55.55.55.0/24", "192.168.50.1", pList[4], bgpMessage2)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage3)
- assert.Equal(t, 2, len(pList))
- for _, p := range pList {
- assert.Equal(t, p.IsWithdraw, false)
- }
- assert.NoError(t, err)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage4)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check table
- table := tm.Tables[bgp.RF_IPv4_UC]
- assert.Equal(t, 13, len(table.GetDestinations()))
-
-}
-
-// check multiple paths
-func TestProcessBGPUpdate_multiple_nlri_ipv6(t *testing.T) {
-
- tm := NewTableManager([]bgp.RouteFamily{bgp.RF_IPv6_UC})
-
- createPathAttr := func(aspaths []uint32) []bgp.PathAttributeInterface {
- origin := bgp.NewPathAttributeOrigin(0)
- aspath := createAsPathAttribute(aspaths)
- med := bgp.NewPathAttributeMultiExitDisc(100)
- localpref := bgp.NewPathAttributeLocalPref(100)
- pathAttr := []bgp.PathAttributeInterface{
- origin, aspath, med, localpref,
- }
- return pathAttr
- }
-
- // check PathAttribute
- checkPattr := func(expected *bgp.BGPMessage, actual *Path) {
- pathAttributes := expected.Body.(*bgp.BGPUpdate).PathAttributes
- pathNexthop := pathAttributes[4]
- attr := actual.getPathAttr(bgp.BGP_ATTR_TYPE_MP_REACH_NLRI)
- expectedNexthopAttr := attr.(*bgp.PathAttributeMpReachNLRI)
- assert.Equal(t, expectedNexthopAttr, pathNexthop)
-
- expectedOrigin := pathAttributes[0]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_ORIGIN)
- pathOrigin := attr.(*bgp.PathAttributeOrigin)
- assert.Equal(t, expectedOrigin, pathOrigin)
-
- expectedAsPath := pathAttributes[1]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
- pathAspath := attr.(*bgp.PathAttributeAsPath)
- assert.Equal(t, expectedAsPath, pathAspath)
-
- expectedMed := pathAttributes[2]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_MULTI_EXIT_DISC)
- pathMed := attr.(*bgp.PathAttributeMultiExitDisc)
- assert.Equal(t, expectedMed, pathMed)
-
- expectedLocalpref := pathAttributes[3]
- attr = actual.getPathAttr(bgp.BGP_ATTR_TYPE_LOCAL_PREF)
- localpref := attr.(*bgp.PathAttributeLocalPref)
- assert.Equal(t, expectedLocalpref, localpref)
-
- // check PathAttribute length
- assert.Equal(t, len(pathAttributes), len(actual.GetPathAttrs()))
-
- }
-
- checkBestPathResult := func(rf bgp.RouteFamily, prefix, nexthop string, p *Path, m *bgp.BGPMessage) {
- assert.Equal(t, p.GetRouteFamily(), rf)
- checkPattr(m, p)
- // check destination
- assert.Equal(t, prefix, p.getPrefix())
- // check nexthop
- assert.Equal(t, nexthop, p.GetNexthop().String())
- }
-
- // path1
- pathAttributes1 := createPathAttr([]uint32{65000, 65100, 65200})
- mpreach1 := createMpReach("2001::192:168:50:1", []bgp.AddrPrefixInterface{
- bgp.NewIPv6AddrPrefix(64, "2001:123:1210:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1220:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1230:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1240:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1250:11::"),
- })
- pathAttributes1 = append(pathAttributes1, mpreach1)
- bgpMessage1 := bgp.NewBGPUpdateMessage(nil, pathAttributes1, nil)
-
- // path2
- pathAttributes2 := createPathAttr([]uint32{65000, 65100, 65300})
- mpreach2 := createMpReach("2001::192:168:50:1", []bgp.AddrPrefixInterface{
- bgp.NewIPv6AddrPrefix(64, "2001:123:1211:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1222:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1233:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1244:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1255:11::"),
- })
- pathAttributes2 = append(pathAttributes2, mpreach2)
- bgpMessage2 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nil)
-
- // path3
- pathAttributes3 := createPathAttr([]uint32{65000, 65100, 65400})
- mpreach3 := createMpReach("2001::192:168:50:1", []bgp.AddrPrefixInterface{
- bgp.NewIPv6AddrPrefix(64, "2001:123:1277:11::"),
- bgp.NewIPv6AddrPrefix(64, "2001:123:1288:11::"),
- })
- pathAttributes3 = append(pathAttributes3, mpreach3)
- bgpMessage3 := bgp.NewBGPUpdateMessage(nil, pathAttributes3, nil)
-
- // path4
- pathAttributes4 := createPathAttr([]uint32{65000, 65100, 65500})
- mpreach4 := createMpReach("2001::192:168:50:1", []bgp.AddrPrefixInterface{
- bgp.NewIPv6AddrPrefix(64, "2001:123:1299:11::"),
- })
- pathAttributes4 = append(pathAttributes4, mpreach4)
- bgpMessage4 := bgp.NewBGPUpdateMessage(nil, pathAttributes4, nil)
-
- peer1 := peerR1()
- pList, err := tm.ProcessUpdate(peer1, bgpMessage1)
- assert.Equal(t, 5, len(pList))
- for _, p := range pList {
- assert.Equal(t, p.IsWithdraw, false)
- }
- assert.NoError(t, err)
-
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1210:11::/64", "2001::192:168:50:1", pList[0], bgpMessage1)
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1220:11::/64", "2001::192:168:50:1", pList[1], bgpMessage1)
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1230:11::/64", "2001::192:168:50:1", pList[2], bgpMessage1)
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1240:11::/64", "2001::192:168:50:1", pList[3], bgpMessage1)
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1250:11::/64", "2001::192:168:50:1", pList[4], bgpMessage1)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage2)
- assert.Equal(t, 5, len(pList))
- for _, p := range pList {
- assert.Equal(t, p.IsWithdraw, false)
- }
- assert.NoError(t, err)
-
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1211:11::/64", "2001::192:168:50:1", pList[0], bgpMessage2)
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1222:11::/64", "2001::192:168:50:1", pList[1], bgpMessage2)
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1233:11::/64", "2001::192:168:50:1", pList[2], bgpMessage2)
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1244:11::/64", "2001::192:168:50:1", pList[3], bgpMessage2)
- checkBestPathResult(bgp.RF_IPv6_UC, "2001:123:1255:11::/64", "2001::192:168:50:1", pList[4], bgpMessage2)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage3)
- assert.Equal(t, 2, len(pList))
- for _, p := range pList {
- assert.Equal(t, p.IsWithdraw, false)
- }
- assert.NoError(t, err)
-
- pList, err = tm.ProcessUpdate(peer1, bgpMessage4)
- assert.Equal(t, 1, len(pList))
- assert.Equal(t, pList[0].IsWithdraw, false)
- assert.NoError(t, err)
-
- // check table
- table := tm.Tables[bgp.RF_IPv6_UC]
- assert.Equal(t, 13, len(table.GetDestinations()))
-
-}
-
-func TestProcessBGPUpdate_Timestamp(t *testing.T) {
- origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65000})}
- aspath := bgp.NewPathAttributeAsPath(aspathParam)
- nexthop := bgp.NewPathAttributeNextHop("192.168.50.1")
- med := bgp.NewPathAttributeMultiExitDisc(0)
-
- pathAttributes := []bgp.PathAttributeInterface{
- origin,
- aspath,
- nexthop,
- med,
- }
-
- nlri := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
-
- adjRib := NewAdjRib([]bgp.RouteFamily{bgp.RF_IPv4_UC, bgp.RF_IPv6_UC})
- m1 := bgp.NewBGPUpdateMessage(nil, pathAttributes, nlri)
- peer := peerR1()
- pList1 := ProcessMessage(m1, peer, time.Now())
- path1 := pList1[0]
- t1 := path1.GetTimestamp()
- adjRib.Update(pList1)
-
- m2 := bgp.NewBGPUpdateMessage(nil, pathAttributes, nlri)
- pList2 := ProcessMessage(m2, peer, time.Now())
- //path2 := pList2[0].(*IPv4Path)
- //t2 = path2.timestamp
- adjRib.Update(pList2)
-
- inList := adjRib.PathList([]bgp.RouteFamily{bgp.RF_IPv4_UC}, false)
- assert.Equal(t, len(inList), 1)
- assert.Equal(t, inList[0].GetTimestamp(), t1)
-
- med2 := bgp.NewPathAttributeMultiExitDisc(1)
- pathAttributes2 := []bgp.PathAttributeInterface{
- origin,
- aspath,
- nexthop,
- med2,
- }
-
- m3 := bgp.NewBGPUpdateMessage(nil, pathAttributes2, nlri)
- pList3 := ProcessMessage(m3, peer, time.Now())
- t3 := pList3[0].GetTimestamp()
- adjRib.Update(pList3)
-
- inList = adjRib.PathList([]bgp.RouteFamily{bgp.RF_IPv4_UC}, false)
- assert.Equal(t, len(inList), 1)
- assert.Equal(t, inList[0].GetTimestamp(), t3)
-}
-
-func update_fromR1() *bgp.BGPMessage {
-
- origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65000})}
- aspath := bgp.NewPathAttributeAsPath(aspathParam)
- nexthop := bgp.NewPathAttributeNextHop("192.168.50.1")
- med := bgp.NewPathAttributeMultiExitDisc(0)
-
- pathAttributes := []bgp.PathAttributeInterface{
- origin,
- aspath,
- nexthop,
- med,
- }
-
- nlri := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "10.10.10.0")}
-
- return bgp.NewBGPUpdateMessage(nil, pathAttributes, nlri)
-}
-
-func update_fromR1_ipv6() *bgp.BGPMessage {
-
- origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65000})}
- aspath := bgp.NewPathAttributeAsPath(aspathParam)
-
- mp_nlri := []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")}
- mp_reach := bgp.NewPathAttributeMpReachNLRI("2001::192:168:50:1", mp_nlri)
- med := bgp.NewPathAttributeMultiExitDisc(0)
-
- pathAttributes := []bgp.PathAttributeInterface{
- mp_reach,
- origin,
- aspath,
- med,
- }
- return bgp.NewBGPUpdateMessage(nil, pathAttributes, nil)
-}
-
-func update_fromR2() *bgp.BGPMessage {
-
- origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65100})}
- aspath := bgp.NewPathAttributeAsPath(aspathParam)
- nexthop := bgp.NewPathAttributeNextHop("192.168.100.1")
- med := bgp.NewPathAttributeMultiExitDisc(100)
-
- pathAttributes := []bgp.PathAttributeInterface{
- origin,
- aspath,
- nexthop,
- med,
- }
-
- nlri := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "20.20.20.0")}
- return bgp.NewBGPUpdateMessage(nil, pathAttributes, nlri)
-}
-
-func update_fromR2_ipv6() *bgp.BGPMessage {
-
- origin := bgp.NewPathAttributeOrigin(0)
- aspath := createAsPathAttribute([]uint32{65100})
- mp_reach := createMpReach("2001::192:168:100:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2002:223:123:1::")})
- med := bgp.NewPathAttributeMultiExitDisc(100)
-
- pathAttributes := []bgp.PathAttributeInterface{
- mp_reach,
- origin,
- aspath,
- med,
- }
- return bgp.NewBGPUpdateMessage(nil, pathAttributes, nil)
-}
-
-func createAsPathAttribute(ases []uint32) *bgp.PathAttributeAsPath {
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, ases)}
- aspath := bgp.NewPathAttributeAsPath(aspathParam)
- return aspath
-}
-
-func createMpReach(nexthop string, prefix []bgp.AddrPrefixInterface) *bgp.PathAttributeMpReachNLRI {
- mp_reach := bgp.NewPathAttributeMpReachNLRI(nexthop, prefix)
- return mp_reach
-}
-
-func createMpUNReach(nlri string, len uint8) *bgp.PathAttributeMpUnreachNLRI {
- mp_nlri := []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(len, nlri)}
- mp_unreach := bgp.NewPathAttributeMpUnreachNLRI(mp_nlri)
- return mp_unreach
-}
-
-func update_fromR2viaR1() *bgp.BGPMessage {
-
- origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65000, 65100})}
- aspath := bgp.NewPathAttributeAsPath(aspathParam)
- nexthop := bgp.NewPathAttributeNextHop("192.168.50.1")
-
- pathAttributes := []bgp.PathAttributeInterface{
- origin,
- aspath,
- nexthop,
- }
-
- nlri := []*bgp.IPAddrPrefix{bgp.NewIPAddrPrefix(24, "20.20.20.0")}
- return bgp.NewBGPUpdateMessage(nil, pathAttributes, nlri)
-}
-
-func update_fromR2viaR1_ipv6() *bgp.BGPMessage {
-
- origin := bgp.NewPathAttributeOrigin(0)
- aspath := createAsPathAttribute([]uint32{65000, 65100})
- mp_reach := createMpReach("2001::192:168:50:1",
- []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2002:223:123:1::")})
- med := bgp.NewPathAttributeMultiExitDisc(100)
-
- pathAttributes := []bgp.PathAttributeInterface{
- mp_reach,
- origin,
- aspath,
- med,
- }
- return bgp.NewBGPUpdateMessage(nil, pathAttributes, nil)
-
-}