Loading ccnode/handlers.py +5 −4 Original line number Diff line number Diff line Loading @@ -747,17 +747,18 @@ class NodeHandler(RpcHandler): jobmgr.cancel(res['jid']) @pure def vm_migrate_tunneled(self, name, tun_res): def vm_migrate_tunneled(self, name, tun_res, migtun_res): ''' ''' debug('request for tunneled migration of VM `%s`', name) # local listenning tunnel port # local listenning tunnels ports tun_port = tun_res.get('port') debug('tunnel port = `%d`', tun_port) migtun_port = migtun_res.get('port') debug('ports are: tunnel=`%d` migration=`%d`', tun_port, migtun_port) # acquire vm object vm = self._host_handle.vm_get(name) # migrate vm.migrate('127.0.0.1', tun_port) vm.migrate(('127.0.0.1', tun_port), ('127.0.0.1', migtun_port)) ################################## Loading Loading
ccnode/handlers.py +5 −4 Original line number Diff line number Diff line Loading @@ -747,17 +747,18 @@ class NodeHandler(RpcHandler): jobmgr.cancel(res['jid']) @pure def vm_migrate_tunneled(self, name, tun_res): def vm_migrate_tunneled(self, name, tun_res, migtun_res): ''' ''' debug('request for tunneled migration of VM `%s`', name) # local listenning tunnel port # local listenning tunnels ports tun_port = tun_res.get('port') debug('tunnel port = `%d`', tun_port) migtun_port = migtun_res.get('port') debug('ports are: tunnel=`%d` migration=`%d`', tun_port, migtun_port) # acquire vm object vm = self._host_handle.vm_get(name) # migrate vm.migrate('127.0.0.1', tun_port) vm.migrate(('127.0.0.1', tun_port), ('127.0.0.1', migtun_port)) ################################## Loading