def METHOD_NAME(self):
    """
       Attach the tunnel flows with UE IP address and
       send GTP and ARP traffic.
    """
    # Need to delete all default flows in table 0 before
    # install the specific flows test case.
    self.test_detach_default_tunnel_flows()
    # Attach the tunnel flows towards UE.
    seid1 = 5000
    ue_ip_addr = "192.168.128.30"
    ip_flow_dl = IPFlowDL(set_params=0)
    self.classifier_controller.add_tunnel_flows(
        65525, 1, 1000, self.EnodeB_IP,
        IPAddress(version=IPAddress.IPV4, address=ue_ip_addr.encode('utf-8')),
        seid1, True, ip_flow_dl=ip_flow_dl,
    )
    # Create a set of packets
    pkt_sender = ScapyPacketInjector(self.BRIDGE)
    eth = Ether(dst=self.MAC_1, src=self.MAC_2)
    ip = IP(src=self.Dst_nat, dst='192.168.128.30')
    o_udp = UDP(sport=2152, dport=2152)
    i_udp = UDP(sport=1111, dport=2222)
    i_tcp = TCP(seq=1, sport=1111, dport=2222)
    i_ip = IP(src='192.168.60.142', dst=self.EnodeB_IP)
    arp = ARP(hwdst=self.MAC_1, hwsrc=self.MAC_2, psrc=self.Dst_nat, pdst='192.168.128.30')
    gtp_packet_udp = eth / ip / o_udp / GTP_U_Header(teid=0x1, length=28, gtp_type=255) / i_ip / i_udp
    gtp_packet_tcp = eth / ip / o_udp / GTP_U_Header(teid=0x1, length=68, gtp_type=255) / i_ip / i_tcp
    arp_packet = eth / arp
    # Check if these flows were added (queries should return flows)
    flow_queries = [
        FlowQuery(
            self._tbl_num, self.testing_controller,
            match=MagmaMatch(tunnel_id=1, in_port=32768),
        ),
        FlowQuery(
            self._tbl_num, self.testing_controller,
            match=MagmaMatch(ipv4_dst='192.168.128.30'),
        ),
    ]
    # =========================== Verification ===========================
    # Verify 5 flows installed for classifier table (3 pkts matched)
    flow_verifier = FlowVerifier(
        [
            FlowTest(
                FlowQuery(
                    self._tbl_num,
                    self.testing_controller,
                ), 3, 5,
            ),
            FlowTest(flow_queries[0], 0, 1),
        ], lambda: wait_after_send(self.testing_controller),
    )
    snapshot_verifier = SnapshotVerifier(
        self, self.BRIDGE,
        self.service_manager,
    )
    with flow_verifier, snapshot_verifier:
        pkt_sender.send(gtp_packet_udp)
        pkt_sender.send(gtp_packet_tcp)
        pkt_sender.send(arp_packet)
    flow_verifier.verify()