

def __init__(self, node, network, tunnel_handlers=None):
    super(CalvinProto, self).__init__({
        'ACTOR_NEW': [CalvinCB(self.actor_new_handler)],
        'ACTOR_MIGRATE': [CalvinCB(self.actor_migrate_handler)],
        'APP_DESTROY': [CalvinCB(self.app_destroy_handler)],
        'PORT_CONNECT': [CalvinCB(self.port_connect_handler)],
        'PORT_DISCONNECT': [CalvinCB(self.port_disconnect_handler)],
        'PORT_PENDING_MIGRATE': [CalvinCB(self.not_impl_handler)],
        'PORT_COMMIT_MIGRATE': [CalvinCB(self.not_impl_handler)],
        'PORT_CANCEL_MIGRATE': [CalvinCB(self.not_impl_handler)],
        'TUNNEL_NEW': [CalvinCB(self.tunnel_new_handler)],
        'TUNNEL_DESTROY': [CalvinCB(self.tunnel_destroy_handler)],
        'TUNNEL_DATA': [CalvinCB(self.tunnel_data_handler)],
        'REPLY': [CalvinCB(self.reply_handler)],
    })
    self.rt_id = node.id
    self.node = node
    self.network = network
    self.network.register_recv(CalvinCB(self.recv_handler))
    self.tunnel_handlers = (tunnel_handlers if isinstance(tunnel_handlers, dict) else {
        
    })
    self.tunnels = {
        
    }

dataset/ETHPy150Open EricssonResearch/calvin-base/calvin/runtime/north/calvin_proto.py CalvinProto.__init__/original