

def __init__(self, core_service, host, port):
    super(BMPClient, self).__init__(name=('BMPClient(%s:%s)' % (host, port)))
    self._core_service = core_service
    self._core_service.signal_bus.register_listener(BgpSignalBus.BGP_ADJ_RIB_IN_CHANGED, (lambda _, data: self.on_adj_rib_in_changed(data)))
    _._core_service.signal_bus.register_listener(BgpSignalBus.BGP_ADJ_UP, (lambda _, data: self.on_adj_up(data)))
    self._core_service.signal_bus.register_listener(BgpSignalBus.BGP_ADJ_DOWN, (lambda _, data: self.on_adj_down(data)))
    self._socket = None
    self.server_address = (host, port)
    self._connect_retry_event = hub.Event()
    self._connect_retry_time = 5

dataset/ETHPy150Open osrg/ryu/ryu/services/protocols/bgp/bmp.py BMPClient.__init__/VarMisuse@71/109 `self`->`_`