Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-4-0-patch / contego deb
Repository URL to install this package:
|
Version:
4.0.109 ▾
|
ó
±EYc @ sù d Z d d l Z d d l Z d d l Z e j d k rH d d l Z n d d l m Z d d l m Z
d d l m Z d d l
m Z d d l Z d d l m Z d d l m Z d d
l m Z d d l m Z d d l m Z d d
l m Z d d
l m Z d d l m Z d d l m Z e
j! e" Z# e j$ j% Z% i Z& d Z( d Z) d Z* d Z+ d Z, d Z- d Z. e) e* e+ f Z/ e. Z0 i e+ d 6e- d 6Z1 xQ e% j2 D]F Z3 e3 j4 d d \ Z5 Z6 e5 rÓe6 e& e5 <n e5 d k r¢e6 Z( q¢q¢Wd Z7 d d Z8 e9 d d Z: e; e; d Z< d Z= d Z> d! Z? d" Z@ d# eA f d$ YZB d d d d d d d3 d% ZC d& ZD d d' ZE d( ZF d4 d) ZG d* ZH e; d+ ZI d, ZJ d- ZK d. ZL d/ ZM d0 ZN d1 ZO d2 ZP d S(5 s
Utility methods to resize, repartition, and modify disk images.
Includes injection of SSH PGP keys into authorized_keys file.
iÿÿÿÿNt nt( t processutils( t log( t jsonutils( t units( t exception( t _( t _LE( t _LW( t utils( t api( t model( t imagest ext2t ext3t ext4t xfst ntfst vfatt linuxt windowst =i t defaultc C s t j | r | Sd S( NR ( t
_MKFS_COMMANDt get( t os_type( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt get_fs_type_for_os_typeS s c C se t j | t } | r! | } n3 | sN t j } | sN t j | t } qN n | } t j | d S( Ni ( R R t _DEFAULT_MKFS_COMMANDt CONFt default_ephemeral_formatt _DEFAULT_FS_BY_OSTYPEt _DEFAULT_FILE_SYSTEMR t get_hash_str( R t specified_fst mkfs_commandt extension( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt get_file_extension_for_os_typeW s c C s t j | t p d i | d 6| d 6} | rL t j d | | j nF | sy t j } | sy t j | t } qy n t j
| | | d | d S( s Format a file or block device using
a user provided command for each os type.
If user has not provided any configuration,
format type will be used according to a
default_ephemeral_format configuration
or a system defaults.
t t fs_labelt targett run_as_rootN( R R R R t executet splitR R R R t mkfs( R R& R' R( R! R" ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR+ e s c C su y, t j d d | d d d d g d | Wn& t j k
rT } t j d | n Xt j d | d | d | d S(
Nt e2fscks -fpt check_exit_codei i i R( sQ Checking the file system with e2fsck has failed, the resize will be aborted. (%s)t resize2fs( R R) R t ProcessExecutionErrort LOGt debug( t imageR- R( t exc( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR. | s c C s t j | j S( s Get the (virtual) size of a disk image
:param path: Path to the disk image
:returns: Size (in bytes) of the given disk image as it would be seen
by a virtual machine.
( R t
qemu_img_infot virtual_size( t path( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt
get_disk_size s c
C sO t | t j s d S| j t j k ru t | j | s> d St j d d d d | t j
d d | j d t d St | j | s d St j d d | j | | j t j k rÄ t
j rÄ d St | sÔ d St d
d } | j t j k r>t j j | d d } | j rK| | j d t d | j qKn
| | j d S(
s| Increase image to size.
:param image: instance of nova.virt.image.model.Image
:param size: image size in bytes
Nt
prl_disk_toolt resizes --sizes %dMs --resize_partitions --hddR( s qemu-imgc S s d S( N( t None( ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt <lambda>¹ s c S sY zJ y t | d | d d g Wn& t j k
rH } t j d | n XWd | Xd S( NR( R- i sA Resizing the file system with resize2fs has failed with error: %s( R. R R/ R0 R1 ( t devR( t finally_callR3 ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt safe_resize2fs¹ s R= ( t
isinstancet imgmodelt
LocalImaget formatt FORMAT_PLOOPt can_resize_imageR6 R R) R t Mit Truet
FORMAT_RAWR t resize_fs_using_block_devicet is_image_extendablet Falset mountt Mountt instance_for_formatR: t get_devt devicet unget_dev( R2 t sizeR> t mounter( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt extend s6
c C sN t j d i | d 6| d 6 t | } | | k rJ t j d | t St S( s Check whether we can resize the container image file.
:param image: path to local image file
:param size: the image size in bytes
s8 Checking if we can resize image %(image)s. size=%(size)sR2 RQ s) Cannot resize image %s to a smaller size.( R0 R1 R7 RJ RF ( R2 RQ t virt_size( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyRD Ð s c C s6 t j d i | d 6 t | t j s< | j t j k rã d } z y? t j j
| d } | j d t | j
t k r t SWn: t j k
rÀ } t j t d i | d 6| d 6 n XWd | d k rÞ | j n Xt Sy t j d | j Wn5 t j k
r1} t j d i | d 6| d 6 t SXt S( s& Check whether we can extend the image.s6 Checking if we can extend filesystem inside %(image)s.R2 RK sD Unable to mount image %(image)s with error %(error)s. Cannot resize.t errorNt e2labelsR Unable to determine label for image %(image)s with error %(error)s. Cannot resize.( R0 R1 R? R@ RA RB RG R: t vfst VFSt instance_for_imaget setupRJ t get_image_fst SUPPORTED_FS_TO_EXTENDRF R t
NovaExceptiont warningR t teardownR R) R6 R R/ ( R2 t fst e( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyRI á s2
t
_DiskImagec B se e Z d Z d Z d d d Z e d Z d Z e d Z
d Z d Z d Z
RS(
s( Provide operations on a disk image file.s openstack-disk-mount-tmpc C sx | | _ | | _ | | _ t | _ d | _ g | _ | rt | j | } | ra | j | qt t
j d | n d S( sí Create a new _DiskImage object instance
:param image: instance of nova.virt.image.model.Image
:param partition: the partition number within the image
:param mount_dir: the directory to mount the image on
s No device found for path: %sN( t partitiont mount_dirR2 RJ t _mkdirR: t _mountert _errorst _device_for_patht _resetR0 R1 ( t selfR2 Rc Rd RO ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt __init__ s c C so d } t j j | } t d d B } x8 | D]0 } | j } | d | k r1 | d } Pq1 q1 WWd QX| S( Ns /proc/mountst ri i ( R: t osR6 t realpatht openR* ( R6 RO t ifpt linet fields( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyRh * s
c C s[ t j j | j | j | j | | _ t j j | j p< d } | j
| j | _ d S( s8 Reset internal state for a previously mounted directory.R% N(
RK RL t instance_for_deviceR2 Rd Rc Rf Rm R6 t basenamet
startswitht
tmp_prefixRe ( Rj RO t
mount_name( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyRi 6 s c C s d j d g | j S( s/ Return the collated errors from all operations.s
--
R% ( t joinRg ( Rj ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt errors@ s c C s¹ | j r! t j t d n | j sN t j d | j | _ t | _ n t
j j | j
| j | j } | j r | | _ | j j St j | j | j j | j d Sd S( sä Mount a disk image, using the object attributes.
The first supported means provided by the mount classes is used.
True, or False is returned and the 'errors' attribute
contains any diagnostics.
s image already mountedt prefixN( Rf R R] R Rd t tempfilet mkdtempRv RF Re RK RL RM R2 Rc t do_mountRO R0 R1 RU Rg t appendR: ( Rj RR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyRK E s
c C s& | j r" | j j d | _ n d S( s) Umount a mount point from the filesystem.N( Rf t do_umountR: ( Rj ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt umount` s
c C sJ z& | j r% | j j d | _ n Wd | j rE t j | j n Xd S( s) Remove a disk image from the file system.N( Rf t do_teardownR: Re Rm t rmdirRd ( Rj ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR_ f s
N( t __name__t
__module__t __doc__Rv R: Rk t staticmethodRh Ri t propertyRy RK R R_ ( ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyRb s
c
C s÷ i | d 6| d 6| d 6| d 6| d 6| d 6} t j d | y# t j j | | } | j Wn_ t k
rÄ }
x$ | D] } | | } | r| q| q| Wt j t d i | d 6|
d 6 t SXz t
| | | | | | | SWd
| j Xd
S( sÓ Inject the specified items into a disk image.
:param image: instance of nova.virt.image.model.Image
:param key: the SSH public key to inject
:param net: the network configuration to inject
:param metadata: the user metadata to inject
:param admin_password: the root password to set
:param files: the files to copy into the image
:param partition: the partition number to access
:param mandatory: the list of parameters which must not fail to inject
If an item name is not specified in the MANDATORY iterable, then a warning
is logged on failure to inject that item, rather than raising an exception.
it will mount the image as a fully partitioned disk and attempt to inject
into the specified partition number.
If PARTITION is not specified the image is mounted as a single partition.
Returns True if all requested operations completed without issue.
Raises an exception if a mandatory item can't be injected.
R2 t keyt nett metadatat filesRc s Inject data image=%(image)s key=%(key)s net=%(net)s metadata=%(metadata)s admin_password=<SANITIZED> files=%(files)s partition=%(partition)ss: Ignoring error injecting data into image %(image)s (%(e)s)Ra N( R0 R1 RW RX RY RZ t ExceptionR^ R RJ t inject_data_into_fsR_ (
R2 R R R t admin_passwordR Rc t mandatoryt itemsR` Ra t injectt
inject_val( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt inject_datas s&
c C st t d | d | } | j } | d k rp t j t d i | d 6| d 6| j d 6 t j | j n | S( s` Setup the LXC container.
:param image: instance of nova.virt.image.model.Image
:param container_dir: directory to mount the image at
It will mount the loopback image to the container directory in order
to create the root filesystem for the container.
Returns path of image device which is mounted to the container directory.
R2 Rd sL Failed to mount container filesystem '%(image)s' on '%(target)s': %(errors)sR' Ry N( Rb RK R: R0 RU R Ry R R] ( R2 t
container_dirt imgR< ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt setup_container¥ s c C sÞ y³ t d d d | } | j | r² d | k rf t j d | t j d d | d t d d q² d
| k r t j d | t j d d
| d t q² t j d | n Wn$ t k
rÙ t j t
d n Xd S( s Teardown the container rootfs mounting once it is spawned.
It will umount the container that is mounted,
and delete any linked devices.
R2 Rd t loops Release loop device %st losetups --detachR( t attemptsi t nbds Release nbd device %ss qemu-nbds -ds( No release necessary for block device %ss' Failed to teardown container filesystemN( Rb R: R_ R0 R1 R R) RF R R R ( R t container_root_deviceR ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt teardown_container¼ s
c C sN y# t d d d | } | j Wn$ t k
rI t j t d n Xd S( s¡ Clean up the container namespace rootfs mounting one spawned.
It will umount the mounted names that are mounted
but leave the linked devices alone.
R2 Rd s% Failed to umount container filesystemN( Rb R: R R R0 R R ( R R ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt clean_lxc_namespace× s
c C sï i | d 6| d 6| d 6| d 6| d 6} i t d 6t d 6t d 6t d 6t d 6} t } x | j D] \ }
} | re y | |
} | | | Wqç t k
rã }
|
| k r¶ n t j t
d i |
d 6|
d 6 t } qç Xqe qe W| S( sÒ Injects data into a filesystem already mounted by the caller.
Virt connections can call this directly if they mount their fs
in a different way to inject_data.
If an item name is not specified in the MANDATORY iterable, then a warning
is logged on failure to inject that item, rather than raising an exception.
Returns True if all requested operations completed without issue.
Raises an exception if a mandatory item can't be injected.
R R R R R s6 Ignoring error injecting %(inject)s into image (%(e)s)R Ra ( t _inject_key_into_fst _inject_net_into_fst _inject_metadata_into_fst _inject_admin_password_into_fst _inject_files_into_fsRF R R R0 R^ R RJ ( R` R R R R R R R t functionst statusR R t inject_funcRa ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR ä s*
c C s x | D] \ } } t j j | } t | d k r | d k r | j | r | j | | j | d d | j | d n t | | | q Wd S( Ni t /t rootiä ( Rm R6 t dirnamet lent has_filet make_patht
set_ownershipt set_permissionst _inject_file_into_fs( R R` R6 t contentst
parent_dir( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR¢ s
c C sR t j d i | d 6| d 6| d 6 | r> | j | | n | j | | d S( Ns5 Inject file fs=%(fs)s path=%(path)s append=%(append)sR` R6 R~ ( R0 R1 t append_filet replace_file( R` R6 R¯ R~ ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR® s
c C s; t j d i | d 6| d 6 t | d t j | d S( Ns/ Inject metadata fs=%(fs)s metadata=%(metadata)sR` R s meta.js( R0 R1 R® R t dumps( R R` ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR s c C së | j t j j d d s" d St j j d d } t j j d d } | j | r | j | r t j j | d } n d d d | g } | j | s¸ | j d d
n t | | d j | d t | j | d
d S( s> Get selinux guests to ensure correct context on injected keys.t etct selinuxNs rc.locals rc.ds
sC # Added by Nova to ensure injected ssh keys have the right context
s# restorecon -RF %s 2>/dev/null || :
i s #!/bin/shR% R~ iÀ ( Rª Rm R6 Rx t insertR® RF R ( R` t sshdirt rclocalt rc_dt
restorecon( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt _setup_selinux_for_keys# s
c C sÓ t j d i | d 6| d 6 t j j d d } | j | | j | d d | j | d t j j | d } d j d d
d | j d g } t | | | d t
| j | d t | | d
S( sª Add the given public ssh key to root's authorized_keys.
key is an ssh key string.
fs is the path to the base of the filesystem into which to inject the key.
s Inject key fs=%(fs)s key=%(key)sR` R R§ s .sshiÀ t authorized_keysR% s
s, # The following ssh key was injected by NovaR~ i N( R0 R1 Rm R6 Rx R« R¬ R t stripR® RF R» ( R R` R· t keyfilet key_data( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR ? s
c C s t j d i | d 6| d 6 t j j d d } | j | | j | d d | j | d t j j d d d } t | | | d S(
sz Inject /etc/network/interfaces into the filesystem rooted at fs.
net is the contents of /etc/network/interfaces.
s Inject key fs=%(fs)s net=%(net)sR` R R´ t networkR§ iä t
interfacesN( R0 R1 Rm R6 Rx R« R¬ R R® ( R R` t netdirt netfile( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR \ s
c C s t j d i | d 6 d } t j j d d } t j j d d } | j | } | j | } t | | | | } | j | | d S( s! Set the root password to admin_passwd
admin_password is a root password
fs is the path to the base of the filesystem into which to inject
the key.
This method modifies the instance filesystem directly,
and does not require a guest agent running in the instance.
s8 Inject admin password fs=%(fs)s admin_passwd=<SANITIZED>R` R§ R´ t passwdt shadowN( R0 R1 Rm R6 Rx t read_filet _set_passwdR² ( t admin_passwdR` t
admin_usert passwd_patht shadow_patht passwd_datat shadow_datat new_shadow_data( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyR¡ l s c C s5 d } d } d j g | D] } t j | ^ q S( Ns@ abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789./i t R% s ( Rx t randomt choice( t salt_sett saltt c( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt _generate_salt s c C s¯ t j d k r' t j t d n i d d 6d d 6d d 6d d
6} t } t j | | d | } t | d k r t j | | d
| } n | j d } | j d } xP | D]) } | j d
}
|
d | k rÀ PqÀ qÀ Wt d } t j | | t } t
}
x\ | D]T } | j d
}
|
d | k rZ| |
d <t }
n d
j |
} | j
| q"W|
s¢t d } t j | | n d j | S( s¾ set the password for username to admin_passwd
The passwd_file is not modified. The shadow_file is updated.
if the username is not found in both files, an exception is raised.
:param username: the username
:param admin_passwd: the admin password
:param passwd_data: path to the passwd file
:param shadow_data: path to the shadow password file
:returns: nothing
:raises: exception.NovaException(), IOError()
R s Not implemented on Windowss $6$s SHA-512s $5$s SHA-256s $1$t MD5R% t DESi
s
t :i s- User %(username)s not found in password file.i s+ User %(username)s not found in shadow file.( Rm t nameR R] R RÕ t cryptR© R* t listRJ RF Rx R~ ( t usernameRÈ RÌ RÍ t algosRÓ t encrypted_passwdt p_filet s_filet entryt split_entryt msgt
new_shadowt foundt new_entry( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyRÇ s8 "
( ( (Q R
Rm RÐ R{ RÙ RÚ t oslo_concurrencyR t oslo_logR t loggingt oslo_serializationR t
oslo_utilsR t nova.conft novaR t nova.i18nR R R R t nova.virt.disk.mountR
RK t nova.virt.disk.vfsRW t nova.virt.imageR R@ t nova.virtR t getLoggerR R0 t confR R R: R t FS_FORMAT_EXT2t FS_FORMAT_EXT3t FS_FORMAT_EXT4t
FS_FORMAT_XFSt FS_FORMAT_NTFSt FS_FORMAT_VFATR\ R R t virt_mkfst sR* R R" R R$ RF R+ RJ R. R7 RS RD RI t objectRb R R R R R R¢ R® R R» R R R¡ RÕ RÇ ( ( ( sG /home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/disk/api.pyt <module> s
9 +g 1 #