mirror/osrg-gobgp
1
0
Fork 0
mirror of https://github.com/osrg/gobgp.git synced 2024-05-11 05:55:10 +00:00
Code Issues Releases Activity

scenaio_test: add extended community test

Browse Source
This commit is contained in:
Naoto Hanaue
2015-07-15 19:12:55 +09:00
parent b73c4df339
commit b56ddd477b
3 changed files with 161 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
policy/policy.go
+1 -1
View File
@@ -719,6 +719,7 @@ func NewExtCommunityCondition(extComSetName string, defExtComSetList []config.Ex
matchAll := false
e := &ExtCommunityElement{
isRegExp: false,
comStr: c,
}
matchType, val := getECommunitySubType(c)
if !matchType {
@@ -863,7 +864,6 @@ func (c *ExtCommunityCondition) evaluate(path *table.Path) bool {
matched := false
matchStr := ""
for _, member := range c.ExtCommunityList {
for _, eCommunity := range eCommunities {
ec := eCommunity.(bgp.ExtendedCommunityInterface)
test/scenario_test/policy/policy_generator.go
+49 -1
View File
@@ -207,6 +207,14 @@ func createPolicyConfig() *config.RoutingPolicy {
CommunitySetName: "comRegExp",
CommunityMembers: []string{"6[0-9]+:[0-9]+"},
}
eComOrigin := config.ExtCommunitySet{
ExtCommunitySetName: "eComAS4",
ExtCommunityMembers: []string{"SoO:65001.65100:200"},
}
eComTarget := config.ExtCommunitySet{
ExtCommunitySetName: "eComRegExp",
ExtCommunityMembers: []string{"RT:6[0-9]+:3[0-9]+"},
}
st0 := config.Statement{
Name: "st0",
@@ -612,6 +620,34 @@ func createPolicyConfig() *config.RoutingPolicy {
},
},
}
st_eComOrigin := config.Statement{
Name: "st_eComAS4",
Conditions: config.Conditions{
MatchPrefixSet: "psExabgp",
MatchNeighborSet: "nsExabgp",
BgpConditions: config.BgpConditions{
MatchExtCommunitySet: "eComOrigin",
},
MatchSetOptions: config.MATCH_SET_OPTIONS_TYPE_ALL,
},
Actions: config.Actions{
AcceptRoute: false,
},
}
st_eComTarget := config.Statement{
Name: "st_eComRegExp",
Conditions: config.Conditions{
MatchPrefixSet: "psExabgp",
MatchNeighborSet: "nsExabgp",
BgpConditions: config.BgpConditions{
MatchExtCommunitySet: "eComTarget",
},
MatchSetOptions: config.MATCH_SET_OPTIONS_TYPE_ALL,
},
Actions: config.Actions{
AcceptRoute: false,
},
}
test_01_import_policy_initial := config.PolicyDefinition{
Name: "test_01_import_policy_initial",
@@ -833,15 +869,25 @@ func createPolicyConfig() *config.RoutingPolicy {
StatementList: []config.Statement{st_asprepend_lastas},
}
test_40_ecommunity_origin_condition_import := config.PolicyDefinition{
Name: "test_40_ecommunity_origin_condition_import",
StatementList: []config.Statement{st_eComOrigin},
}
test_41_ecommunity_target_condition_export := config.PolicyDefinition{
Name: "test_41_ecommunity_target_condition_export",
StatementList: []config.Statement{st_eComTarget},
}
ds := config.DefinedSets{
PrefixSetList: []config.PrefixSet{ps0, ps1, ps2, ps3, ps4, ps5, ps6, psExabgp},
NeighborSetList: []config.NeighborSet{nsPeer2, nsPeer2V6, nsExabgp},
BgpDefinedSets: config.BgpDefinedSets{
AsPathSetList: []config.AsPathSet{aspathFrom, aspathAny, aspathOrigin, aspathOnly},
CommunitySetList: []config.CommunitySet{comStr, comRegExp},
ExtCommunitySetList: []config.ExtCommunitySet{eComOrigin, eComTarget},
},
}
p := &config.RoutingPolicy{
DefinedSets: ds,
PolicyDefinitionList: []config.PolicyDefinition{
@@ -889,6 +935,8 @@ func createPolicyConfig() *config.RoutingPolicy {
test_37_aspath_prepend_action_export,
test_38_aspath_prepend_action_lastas_import,
test_39_aspath_prepend_action_lastas_export,
test_40_ecommunity_origin_condition_import,
test_41_ecommunity_target_condition_export,
},
}
return p
test/scenario_test/route_server_policy_test.py
+111 -3
View File
@@ -2691,6 +2691,112 @@ class GoBGPTest(GoBGPTestBase):
self.assertListEqual(path_asns, expected)
"""
import-policy test
---------------------------------------
exabgp ->(extcommunity=origin:65001.65100:200)->| -> peer1-rib -> peer1-adj-rib-out | --> peer1
| |
| ->x peer2-rib |
---------------------------------------
"""
def test_40_ecommunity_origin_condition_import(self):
# generate exabgp configuration file
prefix1 = "192.168.100.0/24"
asns = ['65100'] + [str(asn) for asn in range(65099, 65090, -1)]
extcommunity = 'origin:4259970636:200'
as_path = reduce(lambda a, b: a + " " + b, asns)
e = ExabgpConfig(EXABGP_COMMON_CONF)
e.add_route(prefix1, aspath=as_path, extcommunity=extcommunity)
e.write()
self.quagga_num = 2
peer1 = "10.0.0.1"
peer2 = "10.0.0.2"
w = self.wait_per_retry
# policy:test_40_ecommunity_origin_condition_import which rejects paths
# that have origin:4259970636:200 in its extended community attr
# is attached to peer2(10.0.0.2)'s import-policy.
self.setup_config(peer2, "test_40_ecommunity_origin_condition_import", "import", add_exabgp=True)
self.initialize()
addresses = self.get_neighbor_address(self.gobgp_config)
self.retry_routine_for_state(addresses, "BGP_FSM_ESTABLISHED")
# check local-rib in peer1
path = self.get_paths_in_localrib(peer1, prefix1, retry=self.retry_count_common)
self.assertIsNotNone(path)
# check show ip bgp on peer1(quagga1)
qpath = self.get_route(peer1, prefix1, retry=self.retry_count_common)
self.assertIsNotNone(qpath)
# check local-rib in peer2
path = self.get_paths_in_localrib(peer2, prefix1, retry=1, interval=w)
self.assertIsNone(path)
# check show ip bgp on peer2(quagga2)
qpath = self.get_route(peer2, prefix1, retry=1, interval=w)
self.assertIsNone(qpath)
"""
export-policy test
---------------------------------------
exabgp ->(extcommunity=origin:65010:320)-> | -> peer1-rib -> peer1-adj-rib-out | --> peer1
| |
| -> peer2-rib ->x peer2-adj-rib-out |
---------------------------------------
"""
def test_41_ecommunity_target_condition_export(self):
# generate exabgp configuration file
prefix1 = "192.168.100.0/24"
asns = ['65100'] + [str(asn) for asn in range(65099, 65090, -1)]
extcommunity = 'target:65010:320'
as_path = reduce(lambda a, b: a + " " + b, asns)
e = ExabgpConfig(EXABGP_COMMON_CONF)
e.add_route(prefix1, aspath=as_path, extcommunity=extcommunity)
e.write()
self.quagga_num = 2
peer1 = "10.0.0.1"
peer2 = "10.0.0.2"
w = self.wait_per_retry
# policy:test_41_ecommunity_target_condition_export which rejects paths
# that have target:65010:320 in its extended community attr
# is attached to peer2(10.0.0.2)'s export-policy.
self.setup_config(peer2, "test_41_ecommunity_target_condition_export", "export", add_exabgp=True)
self.initialize()
addresses = self.get_neighbor_address(self.gobgp_config)
self.retry_routine_for_state(addresses, "BGP_FSM_ESTABLISHED")
# check local-rib in peer1
path = self.get_paths_in_localrib(peer1, prefix1, retry=self.retry_count_common)
self.assertIsNotNone(path)
# check show ip bgp on peer1(quagga1)
qpath = self.get_route(peer1, prefix1, retry=self.retry_count_common)
self.assertIsNotNone(qpath)
# check local-rib in peer2
path = self.get_paths_in_localrib(peer2, prefix1, retry=1, interval=w)
self.assertIsNotNone(path)
# check local-rib in peer2
path = self.get_adj_rib_out(peer2, prefix1, retry=1, interval=w)
self.assertIsNone(path)
# check show ip bgp on peer2(quagga2)
qpath = self.get_route(peer2, prefix1, retry=1, interval=w)
self.assertIsNone(qpath)
class ExabgpConfig(object):
@@ -2721,12 +2827,14 @@ neighbor 10.0.255.1 {
self.config_name = config_name
print >> self.o, self.basic_conf_begin
def add_route(self, prefix, aspath='', community='', med='0'):
def add_route(self, prefix, aspath='', community='', med='0', extcommunity=''):
value = {'prefix': prefix,
'aspath': aspath,
'community': community,
'med': med}
r = "route %(prefix)s next-hop 10.0.0.100 as-path [%(aspath)s] community [%(community)s] med %(med)s;" % value
'med': med,
'extended-community': extcommunity}
r = "route %(prefix)s next-hop 10.0.0.100 as-path [%(aspath)s] community [%(community)s] " \
"med %(med)s extended-community [%(extended-community)s];" % value
print >> self.o, r
def write(self):