X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=test%2Ftemplate_bd.py;h=291f4684db9b332697f712ca93e8105aa49f5f79;hb=fc7344f;hp=473c42282b972d24f3ce8bc837affecaf52a5a45;hpb=f56b77a0764222cc45a9df572df901067a273356;p=vpp.git diff --git a/test/template_bd.py b/test/template_bd.py index 473c42282b9..291f4684db9 100644 --- a/test/template_bd.py +++ b/test/template_bd.py @@ -1,106 +1,162 @@ #!/usr/bin/env python -from abc import abstractmethod +from abc import abstractmethod, ABCMeta from scapy.layers.l2 import Ether, Raw from scapy.layers.inet import IP, UDP +from util import ip4_range + class BridgeDomain(object): - def __init__(self): - ## Ethernet frame which is send to pg0 interface and is forwarded to pg1 - self.payload_0_1 = ( - Ether(src='00:00:00:00:00:01', dst='00:00:00:00:00:02') / - IP(src='1.2.3.4', dst='4.3.2.1') / - UDP(sport=10000, dport=20000) / - Raw('\xa5' * 100)) - - ## Ethernet frame which is send to pg1 interface and is forwarded to pg0 - self.payload_1_0 = ( - Ether(src='00:00:00:00:00:02', dst='00:00:00:00:00:01') / - IP(src='4.3.2.1', dst='1.2.3.4') / - UDP(sport=20000, dport=10000) / - Raw('\xa5' * 100)) - - ## Test case must implement this method, so template known how to send - # encapsulated frame. + """ Bridge domain abstraction """ + __metaclass__ = ABCMeta + + @property + def frame_request(self): + """ Ethernet frame modeling a generic request """ + return (Ether(src='00:00:00:00:00:01', dst='00:00:00:00:00:02') / + IP(src='1.2.3.4', dst='4.3.2.1') / + UDP(sport=10000, dport=20000) / + Raw('\xa5' * 100)) + + @property + def frame_reply(self): + """ Ethernet frame modeling a generic reply """ + return (Ether(src='00:00:00:00:00:02', dst='00:00:00:00:00:01') / + IP(src='4.3.2.1', dst='1.2.3.4') / + UDP(sport=20000, dport=10000) / + Raw('\xa5' * 100)) + + @abstractmethod + def ip_range(self, start, end): + """ range of remote ip's """ + pass + + @abstractmethod + def encap_mcast(self, pkt, src_ip, src_mac, vni): + """ Encapsulate mcast packet """ + pass + @abstractmethod - def encapsulate(self, pkt): + def encapsulate(self, pkt, vni): + """ Encapsulate packet """ pass - ## Test case must implement this method, so template known how to get - # original payload. @abstractmethod def decapsulate(self, pkt): + """ Decapsulate packet """ pass - ## Test case must implement this method, so template known how if the - # received frame is corectly encapsulated. @abstractmethod - def check_encapsulation(self, pkt): + def check_encapsulation(self, pkt, vni, local_only=False): + """ Verify the encapsulation """ pass - ## On pg0 interface are encapsulated frames, on pg1 are testing frames - # without encapsulation + def assert_eq_pkts(self, pkt1, pkt2): + """ Verify the Ether, IP, UDP, payload are equal in both + packets + """ + self.assertEqual(pkt1[Ether].src, pkt2[Ether].src) + self.assertEqual(pkt1[Ether].dst, pkt2[Ether].dst) + self.assertEqual(pkt1[IP].src, pkt2[IP].src) + self.assertEqual(pkt1[IP].dst, pkt2[IP].dst) + self.assertEqual(pkt1[UDP].sport, pkt2[UDP].sport) + self.assertEqual(pkt1[UDP].dport, pkt2[UDP].dport) + self.assertEqual(pkt1[Raw], pkt2[Raw]) + def test_decap(self): - ## Prepare Ethernet frame that will be send encapsulated. - pkt_to_send = self.encapsulate(self.payload_0_1) + """ Decapsulation test + Send encapsulated frames from pg0 + Verify receipt of decapsulated frames on pg1 + """ - ## Add packet to list of packets. - self.pg_add_stream(0, [pkt_to_send, ]) + encapsulated_pkt = self.encapsulate(self.frame_request, + self.single_tunnel_bd) - ## Enable Packet Capture on both ports. - self.pg_enable_capture([0, 1]) + self.pg0.add_stream([encapsulated_pkt, ]) + + self.pg1.enable_capture() - ## Start all streams self.pg_start() - ## Pick first received frame and check if is same as non-encapsulated - # frame. - out = self.pg_get_capture(1) - self.assertEqual(len(out), 1, - 'Invalid number of packets on ' - 'output: {}'.format(len(out))) + # Pick first received frame and check if it's the non-encapsulated + # frame + out = self.pg1.get_capture(1) pkt = out[0] + self.assert_eq_pkts(pkt, self.frame_request) - # TODO: add error messages - self.assertEqual(pkt[Ether].src, self.payload_0_1[Ether].src) - self.assertEqual(pkt[Ether].dst, self.payload_0_1[Ether].dst) - self.assertEqual(pkt[IP].src, self.payload_0_1[IP].src) - self.assertEqual(pkt[IP].dst, self.payload_0_1[IP].dst) - self.assertEqual(pkt[UDP].sport, self.payload_0_1[UDP].sport) - self.assertEqual(pkt[UDP].dport, self.payload_0_1[UDP].dport) - self.assertEqual(pkt[Raw], self.payload_0_1[Raw]) - - ## Send non-encapsulated Ethernet frame from pg1 interface and expect - # encapsulated frame on pg0. On pg0 interface are encapsulated frames, - # on pg1 are testing frames without encapsulation. def test_encap(self): - ## Create packet generator stream. - self.pg_add_stream(1, [self.payload_1_0]) + """ Encapsulation test + Send frames from pg1 + Verify receipt of encapsulated frames on pg0 + """ + self.pg1.add_stream([self.frame_reply]) + + self.pg0.enable_capture() + + self.pg_start() + + # Pick first received frame and check if it's corectly encapsulated. + out = self.pg0.get_capture(1) + pkt = out[0] + self.check_encapsulation(pkt, self.single_tunnel_bd) + + payload = self.decapsulate(pkt) + self.assert_eq_pkts(payload, self.frame_reply) + + def test_ucast_flood(self): + """ Unicast flood test + Send frames from pg3 + Verify receipt of encapsulated frames on pg0 + """ + self.pg3.add_stream([self.frame_reply]) + + self.pg0.enable_capture() - ## Enable Packet Capture on both ports. - self.pg_enable_capture([0, 1]) + self.pg_start() + + # Get packet from each tunnel and assert it's corectly encapsulated. + out = self.pg0.get_capture(self.n_ucast_tunnels) + for pkt in out: + self.check_encapsulation(pkt, self.ucast_flood_bd, True) + payload = self.decapsulate(pkt) + self.assert_eq_pkts(payload, self.frame_reply) + + def test_mcast_flood(self): + """ Multicast flood test + Send frames from pg2 + Verify receipt of encapsulated frames on pg0 + """ + self.pg2.add_stream([self.frame_reply]) + + self.pg0.enable_capture() - ## Start all streams. self.pg_start() - ## Pick first received frame and check if is corectly encapsulated. - out = self.pg_get_capture(0) - self.assertEqual(len(out), 1, - 'Invalid number of packets on ' - 'output: {}'.format(len(out))) - rcvd = out[0] - self.check_encapsulation(rcvd) - - ## Get original frame from received packet and check if is same as - # sended frame. - rcvd_payload = self.decapsulate(rcvd) - # TODO: add error messages - self.assertEqual(rcvd_payload[Ether].src, self.payload_1_0[Ether].src) - self.assertEqual(rcvd_payload[Ether].dst, self.payload_1_0[Ether].dst) - self.assertEqual(rcvd_payload[IP].src, self.payload_1_0[IP].src) - self.assertEqual(rcvd_payload[IP].dst, self.payload_1_0[IP].dst) - self.assertEqual(rcvd_payload[UDP].sport, self.payload_1_0[UDP].sport) - self.assertEqual(rcvd_payload[UDP].dport, self.payload_1_0[UDP].dport) - self.assertEqual(rcvd_payload[Raw], self.payload_1_0[Raw]) + # Pick first received frame and check if it's corectly encapsulated. + out = self.pg0.get_capture(1) + pkt = out[0] + self.check_encapsulation(pkt, self.mcast_flood_bd, + local_only=False, mcast_pkt=True) + + payload = self.decapsulate(pkt) + self.assert_eq_pkts(payload, self.frame_reply) + + def test_mcast_rcv(self): + """ Multicast receive test + Send 20 encapsulated frames from pg0 only 10 match unicast tunnels + Verify receipt of 10 decap frames on pg2 + """ + mac = self.pg0.remote_mac + ip_range_start = 10 + ip_range_end = 30 + mcast_stream = [ + self.encap_mcast(self.frame_request, ip, mac, self.mcast_flood_bd) + for ip in self.ip_range(ip_range_start, ip_range_end)] + self.pg0.add_stream(mcast_stream) + self.pg2.enable_capture() + self.pg_start() + out = self.pg2.get_capture(10) + for pkt in out: + self.assert_eq_pkts(pkt, self.frame_request)