¡@
OpenStack Study: bittorrent.py**** CubicPower OpenStack Study ****
# Copyright 2013 OpenStack Foundation # All Rights Reserved. # # Licensed under the Apache License, Version 2.0 (the "License"); you may # not use this file except in compliance with the License. You may obtain # a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, WITHOUT # WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the # License for the specific language governing permissions and limitations # under the License. import pkg_resources from oslo.config import cfg import six.moves.urllib.parse as urlparse from nova.openstack.common.gettextutils import _ import nova.openstack.common.log as logging from nova.virt.xenapi import vm_utils LOG = logging.getLogger(__name__) xenapi_torrent_opts = [ cfg.StrOpt('torrent_base_url', deprecated_name='xenapi_torrent_base_url', deprecated_group='DEFAULT', help='Base URL for torrent files.'), cfg.FloatOpt('torrent_seed_chance', default=1.0, deprecated_name='xenapi_torrent_seed_chance', deprecated_group='DEFAULT', help='Probability that peer will become a seeder.' ' (1.0 = 100%)'), cfg.IntOpt('torrent_seed_duration', default=3600, deprecated_name='xenapi_torrent_seed_duration', deprecated_group='DEFAULT', help='Number of seconds after downloading an image via' ' BitTorrent that it should be seeded for other peers.'), cfg.IntOpt('torrent_max_last_accessed', default=86400, deprecated_name='xenapi_torrent_max_last_accessed', deprecated_group='DEFAULT', help='Cached torrent files not accessed within this number of' ' seconds can be reaped'), cfg.IntOpt('torrent_listen_port_start', default=6881, deprecated_name='xenapi_torrent_listen_port_start', deprecated_group='DEFAULT', help='Beginning of port range to listen on'), cfg.IntOpt('torrent_listen_port_end', default=6891, deprecated_name='xenapi_torrent_listen_port_end', deprecated_group='DEFAULT', help='End of port range to listen on'), cfg.IntOpt('torrent_download_stall_cutoff', default=600, deprecated_name='xenapi_torrent_download_stall_cutoff', deprecated_group='DEFAULT', help='Number of seconds a download can remain at the same' ' progress percentage w/o being considered a stall'), cfg.IntOpt('torrent_max_seeder_processes_per_host', default=1, deprecated_name='xenapi_torrent_max_seeder_processes_per_host', deprecated_group='DEFAULT', help='Maximum number of seeder processes to run concurrently' ' within a given dom0. (-1 = no limit)') ] CONF = cfg.CONF # xenapi_torrent options in the DEFAULT group were deprecated in Icehouse CONF.register_opts(xenapi_torrent_opts, 'xenserver')
**** CubicPower OpenStack Study **** class BittorrentStore(object): @staticmethod
**** CubicPower OpenStack Study **** def _lookup_torrent_url_fn(): """Load a "fetcher" func to get the right torrent URL via entrypoints. """ if CONF.xenserver.torrent_base_url: def _default_torrent_url_fn(instance, image_id): return urlparse.urljoin(CONF.xenserver.torrent_base_url, "%s.torrent" % image_id) return _default_torrent_url_fn matches = [ep for ep in pkg_resources.iter_entry_points('nova.virt.xenapi.vm_utils') if ep.name == 'torrent_url'] if not matches: raise RuntimeError(_('Cannot create default bittorrent URL' ' without torrent_base_url set or' ' torrent URL fetcher extension')) elif len(matches) > 1: raise RuntimeError(_("Multiple torrent URL fetcher extensions" " found. Failing.")) else: ep = matches[0] LOG.debug(_("Loading torrent URL fetcher from entry points" " %(ep)s"), {'ep': ep}) fn = ep.load() return fn
**** CubicPower OpenStack Study **** def download_image(self, context, session, instance, image_id): params = {} params['image_id'] = image_id params['uuid_stack'] = vm_utils._make_uuid_stack() params['sr_path'] = vm_utils.get_sr_path(session) params['torrent_seed_duration'] = CONF.xenserver.torrent_seed_duration params['torrent_seed_chance'] = CONF.xenserver.torrent_seed_chance params['torrent_max_last_accessed'] = \ CONF.xenserver.torrent_max_last_accessed params['torrent_listen_port_start'] = \ CONF.xenserver.torrent_listen_port_start params['torrent_listen_port_end'] = \ CONF.xenserver.torrent_listen_port_end params['torrent_download_stall_cutoff'] = \ CONF.xenserver.torrent_download_stall_cutoff params['torrent_max_seeder_processes_per_host'] = \ CONF.xenserver.torrent_max_seeder_processes_per_host lookup_fn = self._lookup_torrent_url_fn() params['torrent_url'] = lookup_fn(instance, image_id) vdis = session.call_plugin_serialized( 'bittorrent', 'download_vhd', **params) return vdis
**** CubicPower OpenStack Study **** def upload_image(self, context, session, instance, vdi_uuids, image_id): raise NotImplementedError
|