# Path: networking_vsphere/_i18n.py
# _LE = _translators.log_error
# 
# _LW = _translators.log_warning
# 
# Path: networking_vsphere/utils/vim_session.py
# LOG = log.getLogger(__name__)
# class ConnectionHandler(object):
# class VMWareAPISession(api.VMwareAPISession):
#     def set_vc_details(cls, host_ip, host_username, host_password,
#                        api_retry_count, wsdl_url, ca_cert,
#                        https_port=443, scheme="https"):
#     def stop(cls):
#     def start(cls):
#     def create_connection(cls):
#     def get_connection(cls, create=False):
#     def try_connection(cls):
#     def __init__(self, host_ip, host_username, host_password,
#                  api_retry_count, wsdl_url, scheme="https", https_port=443,
#                  create_session=True, ca_cert=None):
#     def __del__(self):
#     def _is_vim_object(self, module):
#     def _call_method(self, module, method, *args, **kwargs):
#     def _get_vim(self):


import eventlet
import greenlet
import os
from oslo_config import cfg
from oslo_log import log
from networking_vsphere._i18n import _LE, _LW
from networking_vsphere.drivers import base_manager
from networking_vsphere.drivers import dvs_driver
from networking_vsphere.utils import vim_session
                self.connection_thread.wait()
            except greenlet.GreenletExit:
                LOG.warning(_LW("Thread waiting on vCenter connection "
                                "exited."))
                return
        else:
            LOG.error(_LE("Must specify vcenter_ip, vcenter_username, "
                          "vcenter_password and wsdl_location."))
            return
        self.driver = dvs_driver.DvsNetworkDriver()
        self.driver.set_callback(self.netcallback)
        for mapping in cfg.CONF.VMWARE.cluster_dvs_mapping:
            cluster_dvs_list = self._parse_mapping(mapping)
            for cluster, vds in cluster_dvs_list:
                self._add_cluster(cluster, vds)

    def start(self):
        """Start the driver event monitoring."""
        if self.driver:
            eventlet.spawn_n(self.driver.monitor_events)

    def pause(self):
        """Pause the driver."""
        if self.driver:
            self.driver.pause()

    def stop(self):
        """Stop driver and connection."""
        if self.driver:
            self.driver.stop()

# Path: networking_vsphere/_i18n.py
# _LE = _translators.log_error
# 
# _LW = _translators.log_warning
# 
# Path: networking_vsphere/utils/vim_session.py
# LOG = log.getLogger(__name__)
# class ConnectionHandler(object):
# class VMWareAPISession(api.VMwareAPISession):
#     def set_vc_details(cls, host_ip, host_username, host_password,
#                        api_retry_count, wsdl_url, ca_cert,
#                        https_port=443, scheme="https"):
#     def stop(cls):
#     def start(cls):
#     def create_connection(cls):
#     def get_connection(cls, create=False):
#     def try_connection(cls):
#     def __init__(self, host_ip, host_username, host_password,
#                  api_retry_count, wsdl_url, scheme="https", https_port=443,
#                  create_session=True, ca_cert=None):
#     def __del__(self):
#     def _is_vim_object(self, module):
#     def _call_method(self, module, method, *args, **kwargs):
#     def _get_vim(self):


# Path: networking_vsphere/drivers/manager.py
import eventlet
import greenlet
import os
from oslo_config import cfg
from oslo_log import log
from networking_vsphere._i18n import _LE, _LW
from networking_vsphere.drivers import base_manager
from networking_vsphere.drivers import dvs_driver
from networking_vsphere.utils import vim_session

                self.connection_thread.wait()
            except greenlet.GreenletExit:
                LOG.warning(_LW("Thread waiting on vCenter connection "
                                "exited."))
                return
        else:
            LOG.error(_LE("Must specify vcenter_ip, vcenter_username, "
                          "vcenter_password and wsdl_location."))
            return
        self.driver = dvs_driver.DvsNetworkDriver()
        self.driver.set_callback(self.netcallback)
        for mapping in cfg.CONF.VMWARE.cluster_dvs_mapping:
            cluster_dvs_list = self._parse_mapping(mapping)
            for cluster, vds in cluster_dvs_list:
                self._add_cluster(cluster, vds)

    def start(self):
        """Start the driver event monitoring."""
        if self.driver:
            eventlet.spawn_n(self.driver.monitor_events)

    def pause(self):
        """Pause the driver."""
        if self.driver:
            self.driver.pause()

    def stop(self):
        """Stop driver and connection."""
        if self.driver:
            self.driver.stop()

        vim_session.ConnectionHandler.stop()