File: //lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyo
�
d�bc @ s d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l j j Z d d l
m Z d d l j j
Z
d d l m Z m Z d d l j j j Z d d l j j j Z d d l m Z d d l m Z d d l m Z d Z d Z d
e f d � � YZ d S( i����N( t sleep( t ustr( t add_eventt WALAEventOperation( t ResourceDiskError( t
get_osutil( t
AGENT_NAMEs DATALOSS_WARNING_README.txtsM WARNING: THIS IS A TEMPORARY DISK.
Any data stored on this drive is SUBJECT TO LOSS and THERE IS NO WAY TO RECOVER IT.
Please do not use this disk for storing any personal or application data.
For additional details to please refer to the MSDN documentation at :
http://msdn.microsoft.com/en-us/library/windowsazure/jj672979.aspx
t ResourceDiskHandlerc B sz e Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z d � Z
e d � � Z d
� Z
d � Z RS( c C s t � | _ t j � | _ d S( N( R t osutilt conft get_resourcedisk_filesystemt fs( t self( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyt __init__1 s c C s# t j d | j � } | j � d S( Nt target( t threadingt Threadt runt start( R t disk_thread( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyt start_activate_resource_disk5 s c C sM d } t j � r! | j � } n | d k rI t j � rI | j | � n d S( N( t NoneR t get_resourcedisk_formatt activate_resource_diskt get_resourcedisk_enable_swapt enable_swap( R t mount_point( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyR 9 s c C s� t j d � yr t j � } | j | � } t j j | t � } y t j
| t � Wn# t k
ry } t j
d | � n X| SWnK t k
r� } t j d | � t d t d t d t | � d t j � n Xd S( Ns Activate resource disks% Failed to write data loss warning:{0}s! Failed to mount resource disk {0}t namet
is_successt messaget op( t loggert infoR t get_resourcedisk_mountpointt mount_resource_diskt ost patht joint DATALOSS_WARNING_FILE_NAMEt fileutilt
write_filet DATA_LOSS_WARNINGt IOErrort warnR t errorR R t FalseR R t ActivateResourceDiskR ( R R t warning_filet e( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyR A s
c C sW t j d � y t j � } | j | | � Wn# t k
rR } t j d | � n Xd S( Ns Enable swaps Failed to enable swap {0}( R R R t get_resourcedisk_swap_size_mbt create_swap_spaceR R, ( R R t size_mbR0 ( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyR S s
c C sA t j d j | � d t �r= t j d j | � d t �n d S( Ns
sfdisk -R {0}t chk_errs blockdev --rereadpt {0}( t shellutilR t formatR- ( R t device( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyt reread_partition_table[ s c C s | j j d � } | d k r- t d � � n d j | � } | d } t j d � d } | j j | | � } | r� t j d | | � | Sy t
j | d d �WnG t k
r� } d j | | � } t j
| � t d
| d | � � n Xt j d � t j d
j | � � } | d r:t d j | | d � � � n d } | j d k rXd } n d j | j | | � }
d | d k r�t j d � g | d j d � D] } t j d | � r�| ^ q�} t j d t | � � t | � d k rOt j d � xJ t d t | � d � D]/ }
t j d |
� t j d j | |
� � qWt j d � t j d j | � � t j d |
� t j |
� qOn� t j d � | j d t d! d" j | � � } | d j � } | d# k r?| j d$ k r?t j d% � | j d t d! d& j | � � | j | � t j d |
� t j |
� n t j d' | � t j � } | j | | | � } d( } xJ t j j | � r�| d k r�t j d) | | � t d( � | d 8} qyWt j j | � s�t d* j | � � � n t j d+ | � t j | d, t �\ } } | d- k rL| j! d. � d/ k rLt j" d0 | � n� | d k r�t j" d1 � | j | � t j | d, t �\ } } | r�t j" d2 | � t j |
� t j | � \ } } | r�t d3 j | | | � � � q�q�n t j d4 | | | j � | S(5 Ni s unable to detect disk topologys /dev/{0}t 1t mounts, Resource disk [{0}] is already mounted [{1}]t modei� s1 Failed to create mount point directory [{0}]: {1}t msgt inners Examining partition tables parted {0} printi s/ Could not determine partition info for {0}: {1}t Ft xfst fs mkfs.{0} -{2} {1}t gpts GPT detected, finding partitionss
s
^\s*[0-9]+s Found {0} GPT partition(s).s Removing old GPT partitionss Remove partition {0}s parted {0} rm {1}s Creating new GPT partitions! parted {0} mkpart primary 0% 100%s Format partition [{0}]s( GPT not detected, determining filesystemt suppress_messaget
option_strs {0} 1 -nt 7t ntfssC The partition is formatted with ntfs, updating partition type to 83s {0} 1 83s The partition type is {0}i s3 Waiting for partition [{0}], {1} attempts remainings Partition was not created [{0}]s Mount resource disk [{0}]R4 i s is already mountedi����s" Could not mount resource disk: {0}sN Failed to mount resource disk. Retry mounting after re-reading partition info.sJ Failed to mount resource disk. Attempting to format and retry mount. [{0}]s< Could not mount {0} after syncing partition table: [{1}] {2}s, Resource disk {0} is mounted at {1} with {2}(# R t device_for_ide_portR R R6 R5 t run_get_outputt get_mount_pointR R R' t mkdirt OSErrorR, R t splitt ret matcht lent rangeR t change_partition_typet Truet stripR- R8 R t get_resourcedisk_mountoptionst get_mount_stringR# R$ t existsR t findR+ ( R R R7 t partitiont
mount_listt existingt oseR< t rett force_optiont mkfs_stringt xt partst it ptypet
mount_optionst mount_stringt attemptst output( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyR" ` s�
"
!
c C s� d } d j | | r d n d | � } t j | d t d t �\ } } | d k r� t j d | � d } d j | | r d n d | � } t j | d t �\ } } n | d k r� t j d
| � n t j d | | | � | | f S( s|
use sfdisk to change partition type.
First try with --part-type; if fails, fall back to -c
s --part-types sfdisk {0} {1} {2}s -ft R4 t log_cmdi s6 sfdisk with --part-type failed [{0}], retrying with -cs -cs
{0} succeededs {0} failed [{1}: {2}]( R6 R5 RG R- RQ R R R, ( R RB RC t
option_to_uset commandt err_codeRe ( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyRP � s*
c C s? | d k r% d j | j | | | � Sd j | j | | � Sd S( Ns mount -t {0} -o {1} {2} {3}s mount -t {0} {1} {2}( R R6 R ( R Rb RW R ( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyRT � s c C s� | | k r� t j j | � r� t j j | � | k r� t j d � t j | � j } | t j t j B@r� | t j t j B@} t j d j
| | � � t j | | � n t St
S( Ns Swap already enableds Changing mode of {0} to {1:o}( R# R$ t isfilet getsizeR R t statt st_modet S_IRWXGt S_IRWXOR6 t chmodRQ R- ( t swapfilet swaplistt sizet
swapfile_mode( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyt check_existing_swap_file s !
c C sQ | d } | d } t j j | d � } t j d � d } | j | | | � rU d St j j | � r� t j j | � | k r� t j d � t j
d j | � d t �t j
| � n t j j | � st j d � | j | | d � t j
d j | � � n t j
d
j | � � r4t d j | � � � n t j d j | | � � d S(
Ni Rr s swapon -si s Remove old swap files swapoff {0}R4 s Create swap files
mkswap {0}s
swapon {0}s {0}s Enabled {0}KB of swap at {1}( R# R$ R% R5 RG Rv Rk Rl R R R R6 R- t removet mkfileR ( R R R3 t size_kbRt Rr Rs ( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyR2 s"
*
c
C s t | t � s t | � } n | d k rB t d j | � � � n t j j | � rd t j | � n d } t j | f � } | j
d k rat j d k r&d } zc yK t j | t j t j Bt j Bt j t j B� } t j | d | � d SWn t k
rn XWd | d k r"t j | � n Xn t j d j | | � � } | d k rQ| St j d � n d d } d } t | | � } | d k r�t j | j | | | � � d
>} n t | | � } | d k r�| t j | j | d | � � 7} n | d k rt j d � n
t j d � | S( s�
Create a non-sparse file of that size. Deletes and replaces existing
file.
To allow efficient execution, fallocate will be tried first. This
includes
``os.posix_fallocate`` on Python 3.3+ (unix) and the ``fallocate``
command
in the popular ``util-linux{,-ng}`` package.
A dd fallback will be tried too. When size < 64M, perform
single-pass dd.
Otherwise do two-pass dd.
i s Invalid swap size [{0}]R? t ext4i Nu" umask 0077 && fallocate -l {0} {1}s* fallocate unsuccessful, falling back to ddi@ i i sB umask 0077 && dd if=/dev/zero bs={0} count={1} conv=notrunc of={2}i i s
dd successfuls dd unsuccessful( s xfsRz ( i i i ( t
isinstancet intR R6 R# R$ Rk Rw R5 t quoteR t syst version_infoR t opent O_CREATt O_WRONLYt O_EXCLRm t S_IRUSRt S_IWUSRt posix_fallocatet
BaseExceptiont closeR R R R, (
R t filenamet nbytesR[ t fn_sht fdt dd_maxbst dd_cmdt blockst remains( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyRx 3 sP
% %
( t __name__t
__module__R
R R R R R8 R" RP RT t staticmethodRv R2 Rx ( ( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyR 0 s | ! ( R# RL Rm R~ R t timeR t azurelinuxagent.common.loggert commonR t azurelinuxagent.common.futureR t azurelinuxagent.common.confR t azurelinuxagent.common.eventR R t% azurelinuxagent.common.utils.fileutilt utilsR' t& azurelinuxagent.common.utils.shellutilR5 t azurelinuxagent.common.exceptionR t azurelinuxagent.common.osutilR t azurelinuxagent.common.versionR R& R) t objectR ( ( ( sO /usr/lib/python2.7/site-packages/azurelinuxagent/daemon/resourcedisk/default.pyt <module> s"