blob: 144b4cf0a145fffb151f669a56d56d6d6f58384f [file] [log] [blame]
class SRMulticast:
def __init__( self ):
self.default = ''
def CASE1( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Create a Multicast flow between a source and sink on the same dual-tor leaf
Verify flows and groups
Verify traffic
Remove sink
Verify flows and groups
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Create a Multicast flow between a source and sink on the same dual-tor leaf" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=1, onosNodes=3 )
verifyMcastRoutes( main )
verifyMcastSinkRemoval( main, "ipv4", 0, False )
verifyMcastSourceRemoval( main, "ipv4", 0, False )
lib.cleanup( main, copyKarafLog=False )
def CASE2( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Create a Multicast flow between a source and sink on different dual-tor leaves
Verify flows and groups
Verify traffic
Remove sink
Verify flows and groups
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Create a Multicast flow between a source and sink on different dual-tor leaves" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 1 ] } }
setupTest( main, test_idx=2, onosNodes=3 )
verifyMcastRoutes( main )
verifyMcastSinkRemoval( main, "ipv4", 1, False )
verifyMcastSourceRemoval( main, "ipv4", 0, False )
lib.cleanup( main, copyKarafLog=False )
def CASE3( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Create a Multicast flow between a source and sink on different leaves (sink on single-tor)
Verify flows and groups
Verify traffic
Remove sink
Verify flows and groups
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Create a Multicast flow between a source and sink on different leaves (sink on single-tor)" )
main.mcastRoutes = { "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=3, onosNodes=3 )
verifyMcastRoutes( main )
verifyMcastRouteRemoval( main, "ipv6" )
lib.cleanup( main, copyKarafLog=False )
def CASE4( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE1 and CASE2
Verify flows and groups
Verify traffic
Remove sinks
Verify flows and groups
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE1 and CASE2" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1 ] } }
setupTest( main, test_idx=4, onosNodes=3 )
verifyMcastRoutes( main )
verifyMcastSinkRemoval( main, "ipv4", 0, [ False, True ] )
verifyMcastSinkRemoval( main, "ipv4", 1, False )
verifyMcastSourceRemoval( main, "ipv4", 0, False )
lib.cleanup( main, copyKarafLog=False )
def CASE5( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE2 and CASE3
Verify flows and groups
Verify traffic
Remove sinks
Verify flows and groups
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE2 and CASE3" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 1 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=5, onosNodes=3 )
verifyMcastRoutes( main )
verifyMcastRouteRemoval( main, "ipv6" )
verifyMcastSinkRemoval( main, "ipv4", 1, False )
verifyMcastSourceRemoval( main, "ipv4", 0, False )
lib.cleanup( main, copyKarafLog=False )
def CASE6( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE1 and CASE3
Verify flows and groups
Verify traffic
Remove sinks
Verify flows and groups
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE1 and CASE3" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=6, onosNodes=3 )
verifyMcastRoutes( main )
verifyMcastRouteRemoval( main, "ipv6" )
verifyMcastSinkRemoval( main, "ipv4", 0, False )
verifyMcastSourceRemoval( main, "ipv4", 0, False )
lib.cleanup( main, copyKarafLog=False )
def CASE7( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE1, CASE2 and CASE3
Verify flows and groups
Verify traffic
Remove sinks
Verify flows and groups
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE1, CASE2 and CASE3" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=7, onosNodes=3 )
verifyMcastRoutes( main )
verifyMcastRouteRemoval( main, "ipv6" )
verifyMcastSinkRemoval( main, "ipv4", 0, [ False, True ] )
verifyMcastSinkRemoval( main, "ipv4", 1, False )
verifyMcastSourceRemoval( main, "ipv4", 0, False )
lib.cleanup( main, copyKarafLog=False )
def CASE8( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Use all of the four sinks
Verify flows and groups
Verify traffic
Remove sinks
Verify flows and groups
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Use all of the four sinks" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=8, onosNodes=3 )
verifyMcastRoutes( main )
verifyMcastRemoval( main )
lib.cleanup( main, copyKarafLog=False )
def CASE101( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with a link failure (link ingress-spine)
Verify flows and groups
Verify traffic
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with a link failure (link ingress-spine)" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=101, onosNodes=3 )
verifyMcastRoutes( main )
verifyLinkDown( main, [ "leaf2", "spine101" ], 4 )
verifyMcastRemoval( main )
lib.cleanup( main, copyKarafLog=False )
def CASE102( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with a link failure (link spine-egress-dt-leaf)
Verify flows and groups
Verify traffic
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with a link failure (link spine-engress-dt-leaf)" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=102, onosNodes=3 )
verifyMcastRoutes( main )
verifyLinkDown( main, [ "leaf5", "spine101" ], 4 )
verifyMcastRemoval( main )
lib.cleanup( main, copyKarafLog=False )
def CASE103( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with a link failure (link spine-egress-st-leaf)
Verify flows and groups
Verify traffic
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with a link failure (link spine-engress-st-leaf)" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=103, onosNodes=3 )
verifyMcastRoutes( main )
verifyLinkDown( main, [ "spine103", "spine101" ], 4 )
verifyMcastRemoval( main )
lib.cleanup( main, copyKarafLog=False )
def CASE104( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with a link failure (link spine-egress-st-leaf-2)
Verify flows and groups
Verify traffic
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with a link failure (link spine-engress-st-leaf-2)" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=104, onosNodes=3 )
verifyMcastRoutes( main )
verifyLinkDown( main, [ "leaf4", "spine101" ], 4 )
verifyMcastRemoval( main )
lib.cleanup( main, copyKarafLog=False )
def CASE105( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with a link failure (link dt-leaf-sink)
Verify flows and groups
Verify traffic
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with a link failure (link dt-leaf-sink)" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=105, onosNodes=3 )
verifyMcastRoutes( main )
verifyLinkDown( main, [ "leaf2", "h4v4" ], 0 )
verifyMcastRemoval( main )
lib.cleanup( main, copyKarafLog=False )
def CASE106( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with a link failure (link dt-leaf-sink-2)
Verify flows and groups
Verify traffic
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with a link failure (link dt-leaf-sink-2)" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=106, onosNodes=3 )
verifyMcastRoutes( main )
verifyLinkDown( main, [ "leaf5", "h10v4" ], 0 )
verifyMcastRemoval( main )
lib.cleanup( main, copyKarafLog=False )
def CASE201( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with spine failure
Verify flows and groups
Verify traffic
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with spine failure" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=201, onosNodes=3 )
verifyMcastRoutes( main )
verifySwitchDown( main, "spine101", 18 )
verifySwitchDown( main, "spine102", 18 )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE202( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with ingress failure and recovery
Verify flows and groups are removed (failure)
Verify flows and groups (recovery)
Verify traffic (recovery)
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with ingress failure and recovery" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=202, onosNodes=3 )
verifyMcastRoutes( main )
verifySwitchDown( main, "leaf2", 10, { "ipv4": False, "ipv6": False }, [ "h4v4" ] )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE203( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with egress-dt-leaf failure and recovery
Verify flows and groups are removed for the failing sink (failure)
Verify traffic on remaining sinks (failure)
Verify flows and groups (recovery)
Verify traffic (recovery)
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with egress-dt-leaf failure and recovery" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=203, onosNodes=3 )
verifyMcastRoutes( main )
verifySwitchDown( main, "leaf5", 10, hostsToDiscover=[ "h10v4" ] )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE204( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with egress-st-leaf failure and recovery
Verify flows and groups are removed for the failing sink (failure)
Verify traffic on remaining sinks (failure)
Verify flows and groups (recovery)
Verify traffic (recovery)
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with egress-st-leaf failure and recovery" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=204, onosNodes=3 )
verifyMcastRoutes( main )
verifySwitchDown( main, "leaf4", 10, { "ipv4": [ True, False, True ], "ipv6": True }, [ "h8v4", "h10v4" ] )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE205( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with egress leaves failure and recovery
Verify flows and groups are removed for the failing sinks (failure)
Verify traffic on remaining sink (failure)
Verify flows and groups (recovery)
Verify traffic (recovery)
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with leaves failure and recovery" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=205, onosNodes=3 )
verifyMcastRoutes( main )
verifySwitchDown( main, [ "leaf1", "leaf3", "leaf4", "leaf5" ], 32, { "ipv4": [ True, False, False ], "ipv6": False }, [ "h4v4", "h8v4", "h10v4", "h1v6"] )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE301( self, main ):
"""
Sets up 3 ONOS instances, start H-AGG topology
Combines CASE8 with ONOS failure and recovery
Verify flows and groups (failure)
Verify traffic (failure)
Verify flows and groups (recovery)
Verify traffic (recovery)
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Combines CASE8 with leaves failure and recovery" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=205, onosNodes=3 )
verifyMcastRoutes( main )
verifyOnosDown( main )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE401( self, main ):
"""
Extends MCAST105
Create sinks and verify traffic is working
Bring down host port and verify traffic is still working for all sinks
Bring up host port again and start ping from DTH1 to STS
Verify host has both location and stop the ping
Kill LEAFA and verify traffic is still working for all sinks
Remove IPv6 route
Remove DTH2 sink
Remove STH2 sink
Remove STS
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Extends MCAST105" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=401, onosNodes=3 )
verifyMcastRoutes( main )
# Verify killing one link of dual-homed host h4
verifyPortDown( main, "of:0000000000000002", 10, hostsToDiscover=[ "h4v4" ], hostLocations={ "h4v4": ["of:0000000000000002/10", "of:0000000000000003/10"] } )
verifyPortDown( main, "of:0000000000000003", 10, hostsToDiscover=[ "h4v4" ], hostLocations={ "h4v4": ["of:0000000000000002/10", "of:0000000000000003/10"] } )
# Verify killing one link of dual-homed host h10
verifyPortDown( main, "of:0000000000000004", 11, hostsToDiscover=[ "h10v4" ], hostLocations={ "h10v4": ["of:0000000000000004/11", "of:0000000000000005/10"] } )
verifyPortDown( main, "of:0000000000000005", 10, hostsToDiscover=[ "h10v4" ], hostLocations={ "h10v4": ["of:0000000000000004/11", "of:0000000000000005/10"] } )
verifySwitchDown( main, "leaf3", 10, hostsToDiscover=[ "h4v4" ] )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE402( self, main ):
"""
No downstream path for DTH2
Create sinks and verify traffic is working
Kill all up-links of the LEAFB and verify traffic is still working
Remove IPv6 route
Remove DTH2 sink
Remove STH2 sink
Remove STS
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "No downstream path for DTH2" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=402, onosNodes=3 )
verifyMcastRoutes( main )
verifyLinkDown( main, [ [ "leaf5", "spine101" ], [ "leaf5", "spine102" ] ], 8 )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE403( self, main ):
"""
No downstream path for DTH1
Create sinks and verify traffic is working
Bring down host port and verify traffic is still working for all sinks
Bring up host port again and start ping from DTH1 to STS
Verify host has both location and stop the ping
Kill all up-links of the LEAFA and verify traffic is still working
Remove IPv6 route
Remove DTH2 sink
Remove STH2 sink
Remove STS
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "No downstream path for DTH1" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=403, onosNodes=3 )
verifyMcastRoutes( main )
# Verify killing one link of dual-homed host h4
verifyPortDown( main, "of:0000000000000002", 10, hostsToDiscover=[ "h4v4" ], hostLocations={ "h4v4": ["of:0000000000000002/10", "of:0000000000000003/10"] } )
verifyPortDown( main, "of:0000000000000003", 10, hostsToDiscover=[ "h4v4" ], hostLocations={ "h4v4": ["of:0000000000000002/10", "of:0000000000000003/10"] } )
# Verify killing one link of dual-homed host h10
verifyPortDown( main, "of:0000000000000004", 11, hostsToDiscover=[ "h10v4" ], hostLocations={ "h10v4": ["of:0000000000000004/11", "of:0000000000000005/10"] } )
verifyPortDown( main, "of:0000000000000005", 10, hostsToDiscover=[ "h10v4" ], hostLocations={ "h10v4": ["of:0000000000000004/11", "of:0000000000000005/10"] } )
verifyLinkDown( main, [ [ "leaf3", "spine101" ], [ "leaf3", "spine102" ] ], 8 )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )
def CASE404( self, main ):
"""
Extends MCAST 403
Create sinks and verify traffic is working
Bring down host port and verify traffic is still working for all sinks
Bring up host port again and start ping from DTH1 to STS
Verify host has both location and stop the ping
Kill up-links of the LEAFA towards SPINEA, kill up-links of the SOURCE LEAF towards SPINEC and verify traffic is still working for all sinks
Remove IPv6 route
Remove DTH2 sink
Remove STH2 sink
Remove STS
"""
import time
from tests.USECASE.SegmentRouting.SRMulticast.dependencies.SRMulticastTest import *
from tests.USECASE.SegmentRouting.dependencies.Testcaselib import Testcaselib as lib
main.case( "Extends MCASR 403" )
main.mcastRoutes = { "ipv4": { "src": [ 0 ], "dst": [ 0, 1, 2 ] }, "ipv6": { "src": [ 0 ], "dst": [ 0 ] } }
setupTest( main, test_idx=404, onosNodes=3 )
verifyMcastRoutes( main )
# Verify killing one link of dual-homed host h4
verifyPortDown( main, "of:0000000000000002", 10, hostsToDiscover=[ "h4v4" ], hostLocations={ "h4v4": ["of:0000000000000002/10", "of:0000000000000003/10"] } )
verifyPortDown( main, "of:0000000000000003", 10, hostsToDiscover=[ "h4v4" ], hostLocations={ "h4v4": ["of:0000000000000002/10", "of:0000000000000003/10"] } )
# Verify killing one link of dual-homed host h10
verifyPortDown( main, "of:0000000000000004", 11, hostsToDiscover=[ "h10v4" ], hostLocations={ "h10v4": ["of:0000000000000004/11", "of:0000000000000005/10"] } )
verifyPortDown( main, "of:0000000000000005", 10, hostsToDiscover=[ "h10v4" ], hostLocations={ "h10v4": ["of:0000000000000004/11", "of:0000000000000005/10"] } )
verifyLinkDown( main, [ [ "leaf3", "spine101" ], [ "leaf2", "spine102" ] ], 8 )
verifyMcastRemoval( main, removeDHT1=False )
lib.cleanup( main, copyKarafLog=False )