

def _install_flow_send_to_output_table(self, network_id, dst_ip):
    parser = self.get_datapath().ofproto_parser
    if (netaddr.IPAddress(dst_ip).version == 4):
        match = parser.OFPMatch(eth_type=ether.ETH_TYPE_IP, metadata=network_id, ipv4_dst=dst_ip)
    else:
        match = parser.OFPMatch(eth_type=ether.ETH_TYPE_IPV6, metadata=network_id, ipv6_dst=dst_ip)
    goto_inst = parser.OFPInstructionGotoTable(const.EGRESS_TABLE)
    inst = [goto_inst]
    self.mod_flow(self.get_datapath(), inst=inst, table_id=const.L3_PROACTIVE_LOOKUP_TABLE, priority=const.PRIORITY_HIGH, match=match)

dataset/ETHPy150Open openstack/dragonflow/dragonflow/controller/l3_proactive_app.py L3ProactiveApp._install_flow_send_to_output_table/original