# -*- coding: utf-8 -*- # # Copyright (C) 2013 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 . """ Interface for UNIX NIOs (Unix based OSes only). """ import asyncio from .nio import NIO import logging log = logging.getLogger(__name__) class NIOUNIX(NIO): """ Dynamips UNIX NIO. :param hypervisor: Dynamips hypervisor instance :param local_file: local UNIX socket filename :param remote_file: remote UNIX socket filename """ _instance_count = 0 def __init__(self, hypervisor, local_file, remote_file): # create an unique ID and name nio_id = NIOUNIX._instance_count NIOUNIX._instance_count += 1 name = 'nio_unix' + str(nio_id) self._local_file = local_file self._remote_file = remote_file super().__init__(name, hypervisor) @classmethod def reset(cls): """ Reset the instance count. """ cls._instance_count = 0 @asyncio.coroutine def create(self): yield from self._hypervisor.send("nio create_unix {name} {local} {remote}".format(name=self._name, local=self._local_file, remote=self._remote_file)) log.info("NIO UNIX {name} created with local file {local} and remote file {remote}".format(name=self._name, local=self._local_file, remote=self._remote_file)) @property def local_file(self): """ Returns the local UNIX socket. :returns: local UNIX socket filename """ return self._local_file @property def remote_file(self): """ Returns the remote UNIX socket. :returns: remote UNIX socket filename """ return self._remote_file def __json__(self): return {"type": "nio_unix", "local_file": self._local_file, "remote_file": self._remote_file}