

def on_adj_rib_in_changed(self, data):
    peer = data['peer']
    path = data['received_route']
    msg = self._construct_route_monitoring(peer, path)
    self._send(msg)

dataset/ETHPy150Open osrg/ryu/ryu/services/protocols/bgp/bmp.py BMPClient.on_adj_rib_in_changed/original