1
0
mirror of https://github.com/GNS3/gns3-server synced 2024-11-28 11:18:11 +00:00

Remote GNS3 VM support

Fix #623
This commit is contained in:
Julien Duponchelle 2016-08-30 10:19:01 +02:00
parent e0c5fdcf1c
commit 3bff094238
No known key found for this signature in database
GPG Key ID: CE8B29639E07F5E8
6 changed files with 169 additions and 15 deletions

View File

@ -21,6 +21,7 @@ import asyncio
from .vmware_gns3_vm import VMwareGNS3VM from .vmware_gns3_vm import VMwareGNS3VM
from .virtualbox_gns3_vm import VirtualBoxGNS3VM from .virtualbox_gns3_vm import VirtualBoxGNS3VM
from .remote_gns3_vm import RemoteGNS3VM
import logging import logging
log = logging.getLogger(__name__) log = logging.getLogger(__name__)
@ -48,22 +49,37 @@ class GNS3VM:
""" """
:returns: Return list of engines supported by GNS3 for the GNS3VM :returns: Return list of engines supported by GNS3 for the GNS3VM
""" """
virtualbox_informations = {
"engine_id": "virtualbox",
"name": "VirtualBox",
"description": "VirtualBox doesn't support nested virtualization, this means running Qemu based VM could be very slow."
}
vmware_informations = { vmware_informations = {
"engine_id": "vmware", "engine_id": "vmware",
"description": "VMware is the recommended choice for best performances." "description": "VMware is the recommended choice for best performances.",
"support_auto_stop": True,
"support_headless": True
} }
if sys.platform.startswith("darwin"): if sys.platform.startswith("darwin"):
vmware_informations["name"] = "VMware Fusion" vmware_informations["name"] = "VMware Fusion"
else: else:
vmware_informations["name"] = "VMware Workstation / Player" vmware_informations["name"] = "VMware Workstation / Player"
virtualbox_informations = {
"engine_id": "virtualbox",
"name": "VirtualBox",
"description": "VirtualBox doesn't support nested virtualization, this means running Qemu based VM could be very slow.",
"support_auto_stop": True,
"support_headless": True
}
remote_informations = {
"engine_id": "remote",
"name": "Remote",
"description": "Use a remote GNS3 server as the GNS3 VM.",
"support_auto_stop": False,
"support_headless": False
}
return [ return [
vmware_informations, vmware_informations,
virtualbox_informations virtualbox_informations,
remote_informations
] ]
def _current_engine(self): def _current_engine(self):
@ -166,11 +182,14 @@ class GNS3VM:
return self._engines[engine] return self._engines[engine]
if engine == "vmware": if engine == "vmware":
self._engines["vmware"] = VMwareGNS3VM() self._engines["vmware"] = VMwareGNS3VM(self._controller)
return self._engines["vmware"] return self._engines["vmware"]
elif engine == "virtualbox": elif engine == "virtualbox":
self._engines["virtualbox"] = VirtualBoxGNS3VM() self._engines["virtualbox"] = VirtualBoxGNS3VM(self._controller)
return self._engines["virtualbox"] return self._engines["virtualbox"]
elif engine == "remote":
self._engines["remote"] = RemoteGNS3VM(self._controller)
return self._engines["remote"]
raise NotImplementedError("The engine {} for the GNS3 VM is not supported".format(engine)) raise NotImplementedError("The engine {} for the GNS3 VM is not supported".format(engine))
def __json__(self): def __json__(self):
@ -211,7 +230,7 @@ class GNS3VM:
engine.vmname = self._settings["vmname"] engine.vmname = self._settings["vmname"]
yield from engine.start() yield from engine.start()
yield from self._controller.add_compute(compute_id="vm", yield from self._controller.add_compute(compute_id="vm",
name="GNS3 VM", name="GNS3 VM ({})".format(engine.vmname),
protocol=self.protocol, protocol=self.protocol,
host=self.ip_address, host=self.ip_address,
port=self.port, port=self.port,

View File

@ -24,8 +24,9 @@ log = logging.getLogger(__name__)
class BaseGNS3VM: class BaseGNS3VM:
def __init__(self): def __init__(self, controller):
self._controller = controller
self._vmname = None self._vmname = None
self._auto_stop = False self._auto_stop = False
self._ip_address = None self._ip_address = None

View File

@ -0,0 +1,71 @@
#!/usr/bin/env python
#
# Copyright (C) 2016 GNS3 Technologies Inc.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
import asyncio
from .base_gns3_vm import BaseGNS3VM
from .gns3_vm_error import GNS3VMError
import logging
log = logging.getLogger(__name__)
class RemoteGNS3VM(BaseGNS3VM):
def __init__(self, controller):
self._engine = "remote"
super().__init__(controller)
@asyncio.coroutine
def list(self):
"""
List all VMs
"""
res = []
for compute in self._controller.computes.values():
if compute.id not in ["local", "vm"]:
res.append({"vmname": compute.name})
return res
@asyncio.coroutine
def start(self):
"""
Starts the GNS3 VM.
"""
vm_compute = None
for compute in self._controller.computes.values():
if compute.name == self.vmname:
self.running = True
self.protocol = compute.protocol
self.ip_address = compute.host
self.port = compute.port
self.user = compute.user
self.password = compute.password
return
raise GNS3VMError("Can't start the GNS3 VM remote VM {} not found".format(self.vmname))
@asyncio.coroutine
def stop(self):
"""
Stops the GNS3 VM.
"""
self.running = False

View File

@ -32,9 +32,9 @@ log = logging.getLogger(__name__)
class VirtualBoxGNS3VM(BaseGNS3VM): class VirtualBoxGNS3VM(BaseGNS3VM):
def __init__(self): def __init__(self, controller):
super().__init__() super().__init__(controller)
self._engine = "virtualbox" self._engine = "virtualbox"
self._virtualbox_manager = VirtualBox() self._virtualbox_manager = VirtualBox()

View File

@ -32,10 +32,10 @@ log = logging.getLogger(__name__)
class VMwareGNS3VM(BaseGNS3VM): class VMwareGNS3VM(BaseGNS3VM):
def __init__(self): def __init__(self, controller):
self._engine = "vmware" self._engine = "vmware"
super().__init__() super().__init__(controller)
self._vmware_manager = VMware() self._vmware_manager = VMware()
self._vmx_path = None self._vmx_path = None

View File

@ -0,0 +1,63 @@
#!/usr/bin/env python
#
# Copyright (C) 2016 GNS3 Technologies Inc.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
import pytest
from gns3server.controller.gns3vm.remote_gns3_vm import RemoteGNS3VM
from gns3server.controller.gns3vm.gns3_vm_error import GNS3VMError
@pytest.fixture
def gns3vm(controller):
return RemoteGNS3VM(controller)
def test_list(async_run, gns3vm, controller):
async_run(controller.add_compute("r1", name="R1", host="r1.local", connect=False))
res = async_run(gns3vm.list())
assert res == [{"vmname": "R1"}]
def test_start(async_run, gns3vm, controller):
async_run(controller.add_compute("r1", name="R1",
protocol="https",
host="r1.local",
port=8484,
user="hello",
password="world",
connect=False))
gns3vm.vmname = "R1"
res = async_run(gns3vm.start())
assert gns3vm.running
assert gns3vm.protocol == "https"
assert gns3vm.ip_address == "r1.local"
assert gns3vm.port == 8484
assert gns3vm.user == "hello"
assert gns3vm.password == "world"
def test_start_invalid_vm(async_run, gns3vm, controller):
async_run(controller.add_compute("r1", name="R1",
protocol="https",
host="r1.local",
port=8484,
user="hello",
password="world"))
gns3vm.vmname = "R2"
with pytest.raises(GNS3VMError):
res = async_run(gns3vm.start())
assert not gns3vm.running