summaryrefslogtreecommitdiffhomepage
diff options
context:
space:
mode:
-rw-r--r--table/table.go16
-rw-r--r--table/table_manager_test.go104
2 files changed, 68 insertions, 52 deletions
diff --git a/table/table.go b/table/table.go
index 1f4058f0..0be4c75f 100644
--- a/table/table.go
+++ b/table/table.go
@@ -145,7 +145,23 @@ func (td *TableDefault) validatePath(path Path) {
if path == nil || path.GetRouteFamily() != td.ROUTE_FAMILY {
log.Errorf("Invalid path. Expected instance of %s route family path, got %s.", td.ROUTE_FAMILY, path)
}
+ _, attr := path.getPathAttr(bgp.BGP_ATTR_TYPE_AS_PATH)
+ if attr != nil {
+ pathParam := attr.(*bgp.PathAttributeAsPath).Value
+ for _, as := range pathParam {
+ _, y := as.(*bgp.As4PathParam)
+ if !y {
+ log.Fatal("AsPathParam must be converted to As4PathParam, ", as)
+ }
+ }
+ }
+
+ _, attr = path.getPathAttr(bgp.BGP_ATTR_TYPE_AS4_PATH)
+ if attr != nil {
+ log.Fatal("AS4_PATH must be converted to AS_PATH")
+ }
}
+
func (td *TableDefault) validateNlri(nlri bgp.AddrPrefixInterface) {
if nlri == nil {
log.Error("Invalid Vpnv4 prefix given.")
diff --git a/table/table_manager_test.go b/table/table_manager_test.go
index 60caa267..63d114f3 100644
--- a/table/table_manager_test.go
+++ b/table/table_manager_test.go
@@ -175,7 +175,7 @@ func TestProcessBGPUpdate_1_select_high_localpref_ipv4(t *testing.T) {
// low localpref message
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000})
+ aspath1 := createAsPathAttribute([]uint32{65000})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(0)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -189,7 +189,7 @@ func TestProcessBGPUpdate_1_select_high_localpref_ipv4(t *testing.T) {
// high localpref message
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ aspath2 := createAsPathAttribute([]uint32{65100, 65000})
nexthop2 := bgp.NewPathAttributeNextHop("192.168.50.1")
med2 := bgp.NewPathAttributeMultiExitDisc(100)
localpref2 := bgp.NewPathAttributeLocalPref(200)
@@ -258,7 +258,7 @@ func TestProcessBGPUpdate_1_select_high_localpref_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000})
+ 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)
@@ -273,7 +273,7 @@ func TestProcessBGPUpdate_1_select_high_localpref_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage(withdrawnRoutes1, pathAttributes1, nlri1)
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ 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)
@@ -347,7 +347,7 @@ func TestProcessBGPUpdate_2_select_local_origin_ipv4(t *testing.T) {
// low localpref message
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000})
+ aspath1 := createAsPathAttribute([]uint32{65000})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(0)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -361,7 +361,7 @@ func TestProcessBGPUpdate_2_select_local_origin_ipv4(t *testing.T) {
// high localpref message
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{})
+ aspath2 := createAsPathAttribute([]uint32{})
nexthop2 := bgp.NewPathAttributeNextHop("0.0.0.0")
med2 := bgp.NewPathAttributeMultiExitDisc(100)
localpref2 := bgp.NewPathAttributeLocalPref(100)
@@ -430,7 +430,7 @@ func TestProcessBGPUpdate_2_select_local_origin_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000})
+ 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)
@@ -445,7 +445,7 @@ func TestProcessBGPUpdate_2_select_local_origin_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage(withdrawnRoutes1, pathAttributes1, nlri1)
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{})
+ aspath2 := createAsPathAttribute([]uint32{})
mp_reach2 := createMpReach("::",
[]bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")})
med2 := bgp.NewPathAttributeMultiExitDisc(100)
@@ -635,7 +635,7 @@ func TestProcessBGPUpdate_4_select_low_origin_ipv4(t *testing.T) {
// low origin message
origin1 := bgp.NewPathAttributeOrigin(1)
- aspath1 := createAsPathAttribute([]uint16{65200, 65000})
+ aspath1 := createAsPathAttribute([]uint32{65200, 65000})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(100)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -649,7 +649,7 @@ func TestProcessBGPUpdate_4_select_low_origin_ipv4(t *testing.T) {
// high origin message
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ aspath2 := createAsPathAttribute([]uint32{65100, 65000})
nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
med2 := bgp.NewPathAttributeMultiExitDisc(100)
localpref2 := bgp.NewPathAttributeLocalPref(100)
@@ -718,7 +718,7 @@ func TestProcessBGPUpdate_4_select_low_origin_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(1)
- aspath1 := createAsPathAttribute([]uint16{65200, 65000})
+ 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)
@@ -733,7 +733,7 @@ func TestProcessBGPUpdate_4_select_low_origin_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage(withdrawnRoutes1, pathAttributes1, nlri1)
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ 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)
@@ -807,7 +807,7 @@ func TestProcessBGPUpdate_5_select_low_med_ipv4(t *testing.T) {
// low origin message
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65200, 65000})
+ aspath1 := createAsPathAttribute([]uint32{65200, 65000})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(500)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -821,7 +821,7 @@ func TestProcessBGPUpdate_5_select_low_med_ipv4(t *testing.T) {
// high origin message
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ aspath2 := createAsPathAttribute([]uint32{65100, 65000})
nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
med2 := bgp.NewPathAttributeMultiExitDisc(100)
localpref2 := bgp.NewPathAttributeLocalPref(100)
@@ -890,7 +890,7 @@ func TestProcessBGPUpdate_5_select_low_med_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65200, 65000})
+ 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)
@@ -905,7 +905,7 @@ func TestProcessBGPUpdate_5_select_low_med_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage(withdrawnRoutes1, pathAttributes1, nlri1)
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ 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)
@@ -981,7 +981,7 @@ func TestProcessBGPUpdate_6_select_ebgp_path_ipv4(t *testing.T) {
// low origin message
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000, 65200})
+ aspath1 := createAsPathAttribute([]uint32{65000, 65200})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(200)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -995,7 +995,7 @@ func TestProcessBGPUpdate_6_select_ebgp_path_ipv4(t *testing.T) {
// high origin message
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ aspath2 := createAsPathAttribute([]uint32{65100, 65000})
nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
med2 := bgp.NewPathAttributeMultiExitDisc(200)
localpref2 := bgp.NewPathAttributeLocalPref(100)
@@ -1065,7 +1065,7 @@ func TestProcessBGPUpdate_6_select_ebgp_path_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000, 65200})
+ 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)
@@ -1080,7 +1080,7 @@ func TestProcessBGPUpdate_6_select_ebgp_path_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage(withdrawnRoutes1, pathAttributes1, nlri1)
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65200})
+ 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)
@@ -1158,7 +1158,7 @@ func TestProcessBGPUpdate_7_select_low_routerid_path_ipv4(t *testing.T) {
// low origin message
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000, 65200})
+ aspath1 := createAsPathAttribute([]uint32{65000, 65200})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(200)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -1172,7 +1172,7 @@ func TestProcessBGPUpdate_7_select_low_routerid_path_ipv4(t *testing.T) {
// high origin message
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65000, 65100})
+ aspath2 := createAsPathAttribute([]uint32{65000, 65100})
nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
med2 := bgp.NewPathAttributeMultiExitDisc(200)
localpref2 := bgp.NewPathAttributeLocalPref(100)
@@ -1242,7 +1242,7 @@ func TestProcessBGPUpdate_7_select_low_routerid_path_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000, 65200})
+ 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)
@@ -1257,7 +1257,7 @@ func TestProcessBGPUpdate_7_select_low_routerid_path_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage(withdrawnRoutes1, pathAttributes1, nlri1)
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65200})
+ 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)
@@ -1332,7 +1332,7 @@ func TestProcessBGPUpdate_8_withdraw_path_ipv4(t *testing.T) {
// path1
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000})
+ aspath1 := createAsPathAttribute([]uint32{65000})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(200)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -1346,7 +1346,7 @@ func TestProcessBGPUpdate_8_withdraw_path_ipv4(t *testing.T) {
// path 2
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ aspath2 := createAsPathAttribute([]uint32{65100, 65000})
nexthop2 := bgp.NewPathAttributeNextHop("192.168.100.1")
med2 := bgp.NewPathAttributeMultiExitDisc(200)
localpref2 := bgp.NewPathAttributeLocalPref(200)
@@ -1439,7 +1439,7 @@ func TestProcessBGPUpdate_8_mpunreach_path_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000})
+ 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)
@@ -1454,7 +1454,7 @@ func TestProcessBGPUpdate_8_mpunreach_path_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage(withdrawnRoutes1, pathAttributes1, nlri1)
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65100, 65000})
+ 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)
@@ -1577,7 +1577,7 @@ func TestProcessBGPUpdate_bestpath_lost_ipv4(t *testing.T) {
// path1
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000})
+ aspath1 := createAsPathAttribute([]uint32{65000})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(200)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -1648,7 +1648,7 @@ func TestProcessBGPUpdate_bestpath_lost_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000})
+ 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)
@@ -1726,7 +1726,7 @@ func TestProcessBGPUpdate_implicit_withdrwal_ipv4(t *testing.T) {
// path1
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000, 65100, 65200})
+ aspath1 := createAsPathAttribute([]uint32{65000, 65100, 65200})
nexthop1 := bgp.NewPathAttributeNextHop("192.168.50.1")
med1 := bgp.NewPathAttributeMultiExitDisc(200)
localpref1 := bgp.NewPathAttributeLocalPref(100)
@@ -1740,7 +1740,7 @@ func TestProcessBGPUpdate_implicit_withdrwal_ipv4(t *testing.T) {
// path 1 from same peer but short AS_PATH
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65000, 65100})
+ aspath2 := createAsPathAttribute([]uint32{65000, 65100})
nexthop2 := bgp.NewPathAttributeNextHop("192.168.50.1")
med2 := bgp.NewPathAttributeMultiExitDisc(200)
localpref2 := bgp.NewPathAttributeLocalPref(100)
@@ -1810,7 +1810,7 @@ func TestProcessBGPUpdate_implicit_withdrwal_ipv6(t *testing.T) {
var err error
origin1 := bgp.NewPathAttributeOrigin(0)
- aspath1 := createAsPathAttribute([]uint16{65000, 65100, 65200})
+ 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)
@@ -1825,7 +1825,7 @@ func TestProcessBGPUpdate_implicit_withdrwal_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage(withdrawnRoutes1, pathAttributes1, nlri1)
origin2 := bgp.NewPathAttributeOrigin(0)
- aspath2 := createAsPathAttribute([]uint16{65000, 65100})
+ 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)
@@ -1923,7 +1923,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv4(t *testing.T) {
//setLogger(getLogger(log.DebugLevel))
var err error
- createPathAttr := func(aspaths []uint16, nh string) []bgp.PathAttributeInterface {
+ createPathAttr := func(aspaths []uint32, nh string) []bgp.PathAttributeInterface {
origin := bgp.NewPathAttributeOrigin(0)
aspath := createAsPathAttribute(aspaths)
nexthop := bgp.NewPathAttributeNextHop(nh)
@@ -1973,7 +1973,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv4(t *testing.T) {
}
// path1
- pathAttributes1 := createPathAttr([]uint16{65000, 65100, 65200}, "192.168.50.1")
+ pathAttributes1 := createPathAttr([]uint32{65000, 65100, 65200}, "192.168.50.1")
nlri1 := []bgp.NLRInfo{
*bgp.NewNLRInfo(24, "10.10.10.0"),
*bgp.NewNLRInfo(24, "20.20.20.0"),
@@ -1983,7 +1983,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv4(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage([]bgp.WithdrawnRoute{}, pathAttributes1, nlri1)
// path2
- pathAttributes2 := createPathAttr([]uint16{65000, 65100, 65300}, "192.168.50.1")
+ pathAttributes2 := createPathAttr([]uint32{65000, 65100, 65300}, "192.168.50.1")
nlri2 := []bgp.NLRInfo{
*bgp.NewNLRInfo(24, "11.11.11.0"),
*bgp.NewNLRInfo(24, "22.22.22.0"),
@@ -1993,7 +1993,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv4(t *testing.T) {
bgpMessage2 := bgp.NewBGPUpdateMessage([]bgp.WithdrawnRoute{}, pathAttributes2, nlri2)
// path3
- pathAttributes3 := createPathAttr([]uint16{65000, 65100, 65400}, "192.168.50.1")
+ pathAttributes3 := createPathAttr([]uint32{65000, 65100, 65400}, "192.168.50.1")
nlri3 := []bgp.NLRInfo{
*bgp.NewNLRInfo(24, "77.77.77.0"),
*bgp.NewNLRInfo(24, "88.88.88.0"),
@@ -2001,7 +2001,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv4(t *testing.T) {
bgpMessage3 := bgp.NewBGPUpdateMessage([]bgp.WithdrawnRoute{}, pathAttributes3, nlri3)
// path4
- pathAttributes4 := createPathAttr([]uint16{65000, 65100, 65500}, "192.168.50.1")
+ pathAttributes4 := createPathAttr([]uint32{65000, 65100, 65500}, "192.168.50.1")
nlri4 := []bgp.NLRInfo{
*bgp.NewNLRInfo(24, "99.99.99.0"),
}
@@ -2053,7 +2053,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv6(t *testing.T) {
//setLogger(getLogger(log.DebugLevel))
var err error
- createPathAttr := func(aspaths []uint16) []bgp.PathAttributeInterface {
+ createPathAttr := func(aspaths []uint32) []bgp.PathAttributeInterface {
origin := bgp.NewPathAttributeOrigin(0)
aspath := createAsPathAttribute(aspaths)
med := bgp.NewPathAttributeMultiExitDisc(100)
@@ -2108,7 +2108,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv6(t *testing.T) {
}
// path1
- pathAttributes1 := createPathAttr([]uint16{65000, 65100, 65200})
+ 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::"),
@@ -2120,7 +2120,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv6(t *testing.T) {
bgpMessage1 := bgp.NewBGPUpdateMessage([]bgp.WithdrawnRoute{}, pathAttributes1, []bgp.NLRInfo{})
// path2
- pathAttributes2 := createPathAttr([]uint16{65000, 65100, 65300})
+ 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::"),
@@ -2132,7 +2132,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv6(t *testing.T) {
bgpMessage2 := bgp.NewBGPUpdateMessage([]bgp.WithdrawnRoute{}, pathAttributes2, []bgp.NLRInfo{})
// path3
- pathAttributes3 := createPathAttr([]uint16{65000, 65100, 65400})
+ 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::"),
@@ -2141,7 +2141,7 @@ func TestProcessBGPUpdate_multiple_nlri_ipv6(t *testing.T) {
bgpMessage3 := bgp.NewBGPUpdateMessage([]bgp.WithdrawnRoute{}, pathAttributes3, []bgp.NLRInfo{})
// path4
- pathAttributes4 := createPathAttr([]uint16{65000, 65100, 65500})
+ pathAttributes4 := createPathAttr([]uint32{65000, 65100, 65500})
mpreach4 := createMpReach("2001::192:168:50:1", []bgp.AddrPrefixInterface{
bgp.NewIPv6AddrPrefix(64, "2001:123:1299:11::"),
})
@@ -2224,7 +2224,7 @@ func TestModifyPathAttribute(t *testing.T) {
func update_fromR1() *bgp.BGPMessage {
origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAsPathParam(2, []uint16{65000})}
+ aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65000})}
aspath := bgp.NewPathAttributeAsPath(aspathParam)
nexthop := bgp.NewPathAttributeNextHop("192.168.50.1")
med := bgp.NewPathAttributeMultiExitDisc(0)
@@ -2245,7 +2245,7 @@ func update_fromR1() *bgp.BGPMessage {
func update_fromR1_ipv6() *bgp.BGPMessage {
origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAsPathParam(2, []uint16{65000})}
+ aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65000})}
aspath := bgp.NewPathAttributeAsPath(aspathParam)
mp_nlri := []bgp.AddrPrefixInterface{bgp.NewIPv6AddrPrefix(64, "2001:123:123:1::")}
@@ -2266,7 +2266,7 @@ func update_fromR1_ipv6() *bgp.BGPMessage {
func update_fromR2() *bgp.BGPMessage {
origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAsPathParam(2, []uint16{65100})}
+ aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65100})}
aspath := bgp.NewPathAttributeAsPath(aspathParam)
nexthop := bgp.NewPathAttributeNextHop("192.168.100.1")
med := bgp.NewPathAttributeMultiExitDisc(100)
@@ -2286,7 +2286,7 @@ func update_fromR2() *bgp.BGPMessage {
func update_fromR2_ipv6() *bgp.BGPMessage {
origin := bgp.NewPathAttributeOrigin(0)
- aspath := createAsPathAttribute([]uint16{65100})
+ 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)
@@ -2302,8 +2302,8 @@ func update_fromR2_ipv6() *bgp.BGPMessage {
return bgp.NewBGPUpdateMessage(withdrawnRoutes, pathAttributes, nlri)
}
-func createAsPathAttribute(ases []uint16) *bgp.PathAttributeAsPath {
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAsPathParam(2, ases)}
+func createAsPathAttribute(ases []uint32) *bgp.PathAttributeAsPath {
+ aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, ases)}
aspath := bgp.NewPathAttributeAsPath(aspathParam)
return aspath
}
@@ -2322,7 +2322,7 @@ func createMpUNReach(nlri string, len uint8) *bgp.PathAttributeMpUnreachNLRI {
func update_fromR2viaR1() *bgp.BGPMessage {
origin := bgp.NewPathAttributeOrigin(0)
- aspathParam := []bgp.AsPathParamInterface{bgp.NewAsPathParam(2, []uint16{65000, 65100})}
+ aspathParam := []bgp.AsPathParamInterface{bgp.NewAs4PathParam(2, []uint32{65000, 65100})}
aspath := bgp.NewPathAttributeAsPath(aspathParam)
nexthop := bgp.NewPathAttributeNextHop("192.168.50.1")
@@ -2340,7 +2340,7 @@ func update_fromR2viaR1() *bgp.BGPMessage {
func update_fromR2viaR1_ipv6() *bgp.BGPMessage {
origin := bgp.NewPathAttributeOrigin(0)
- aspath := createAsPathAttribute([]uint16{65000, 65100})
+ 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)