

def _install_flows_on_switch_up(self):
    for lrouter in self.db_store.get_routers():
        for router_port in lrouter.get_ports():
            local_network_id = self.db_store.get_network_id(router_port.get_lswitch_id())
            self.add_router_port(lrouter, router_port, local_network_id)
    for lport in self.db_store.get_ports():
        self._add_port(lport)

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