/usr/lib/python3/dist-packages/cloudinit/__pycache__
Edit: /usr/lib/python3/dist-packages/cloudinit/__pycache__/helpers.cpython-310.pyc (13685B)
o
th@ @ s d dl Z d dlZd dlZd dlmZmZmZ d dlmZ d dl m Z d dl
m Z m Z m
Z
mZ d dlmZmZmZmZ eeZG dd deZG d d
d
ZG d d d ZG d
d dZdd Z G dd dZ G dd dZ G dd dZ G dd dZ G dd de j!Z"G dd d eZ#dS ) N)
NoOptionErrorNoSectionErrorRawConfigParser)StringIO)time) persistencesettings
type_utilsutil) CFG_ENV_NAME
PER_ALWAYS PER_INSTANCEPER_ONCEc @ e Zd ZdS ) LockFailureN__name__
__module__ __qualname__ r r 3/usr/lib/python3/dist-packages/cloudinit/helpers.pyr r c @ r ) DummyLockNr r r r r r r r c @ s4 e Zd Zdd Zejd ddZdd Zdd Zd
S ) DummySemaphoresc C s d S Nr selfr r r __init__! zDummySemaphores.__init__Fc c s t V d S r )r )r _name_freq_clear_on_failr r r lock$ s zDummySemaphores.lockc C dS NFr r r r r r r has_run( r zDummySemaphores.has_runc C r# )NTr r% r r r clear+ r zDummySemaphores.clearNF) r r r r
contextlibcontextmanagerr" r& r' r r r r r s r c @ s e Zd Zdd Zdd ZdS )FileLockc C
|| _ d S r )fn)r r- r r r r 0
zFileLock.__init__c C s dt | | jf S )Nz<%s using file %r>)r obj_namer- r r r r __str__3 s zFileLock.__str__N)r r r r r0 r r r r r+ / s r+ c C s | ddS )N-_)replace)namer r r canon_sem_name7 s r5 c @ sD e Zd Zdd ZejdddZdd Zdd Zd
d Z d d
Z
dS )FileSemaphoresc C r, r )sem_path)r r7 r r r r < r. zFileSemaphores.__init__Fc c s@ t |}z
| ||V W d S ty |r | || w r )r5 _acquire Exceptionr' )r r4 freq
clear_on_failr r r r" ? s zFileSemaphores.lockc C sL t |}| ||}zt| W dS ttfy% ttd| Y dS w )Nz Failed deleting semaphore %sFT)r5 _get_pathr
del_fileIOErrorOSErrorlogexcLOG)r r4 r: sem_filer r r r' I s zFileSemaphores.clearc C sl | ||rd S | ||}dt t f }z t|| W t |S ttfy5 t t
d| Y d S w )Nz%s: %s
z Failed writing semaphore file %s) r& r< osgetpidr r
write_filer> r? r@ rA r+ )r r4 r: rB contentsr r r r8 S s zFileSemaphores._acquirec C s0 |r|t krdS t|}| ||}tj|S r$ )r r5 r< rC pathexists)r r4 r: cnamerB r r r r& c s
zFileSemaphores.has_runc C s6 | j }|r |tkrtj||S tj|d||f S )Nz%s.%s)r7 r
rC rG join)r r4 r: r7 r r r r< m s zFileSemaphores._get_pathNr( ) r r r r r) r* r" r' r8 r& r< r r r r r6 ; s
r6 c @ s& e Zd Zdd Zdd Zd ddZdS )
Runnersc C s || _ i | _d S r )pathssems)r rL r r r r v
zRunners.__init__c C sh |t ks|sd S d }|tkr| jd}n
|tkr | jd}|s#d S || jvr/t|| j|< | j| S )Nsem)r r
rL get_ipathr get_cpathrM r6 )r r: r7 r r r _get_semz s
zRunners._get_semNFc C s | |}|s
t }|sg }|||r td|| dS ||||,}|s-td| td|| t|trA|di |}n|| }d|fW d S 1 sSw Y d S )Nz%s already ran (freq=%s))FNz Failed to acquire lock for %szRunning %s using lock (%s)Tr ) rR r r& rA debugr" r
isinstancedict) r r4 functorargsr: r; rO lkresultsr r r run s"
$z Runners.runr$ )r r r r rR rZ r r r r rK u s rK c @ sR e Zd Z dddZdd Zdd Zd d
Zd efd d
Ze dd Z
dS ) ConfigMergerNTc C s( || _ || _|| _|| _|| _d | _d S r )_paths_ds_fns _base_cfg_include_vendor_cfg)r rL
datasourceadditional_fnsbase_cfginclude_vendorr r r r s
zConfigMerger.__init__c C sh g }| j r2z| j }|rt|tr || W |S W |S W |S ty1 ttd| j Y |S w |S )Nz2Failed loading of datasource config object from %s) r] get_config_objrT rU appendr9 r
r@ rA )r d_cfgsds_cfgr r r _get_datasource_configs s(
z$ConfigMerger._get_datasource_configsc C sV g }t tjv r)tjt }z |t| W |S ty( ttd| Y |S w |S )Nz%Failed loading of env. config from %s) r rC environrg r
read_confr9 r@ rA )r e_cfgse_fnr r r _get_env_configs s
z ConfigMerger._get_env_configsc C s g }| j s|S dg}| jr|d |d |D ]9}| j |}|rRtj|rRz
|t| W q t yB t
d| Y q t yQ t
t
d| Y qw q|S )N cloud_configvendor2_cloud_configvendor_cloud_configz5Skipped loading cloud-config from %s due to non-root.z&Failed loading of cloud-config from %s)r\ r` rg
get_ipath_currC rG isfiler
rl PermissionErrorrA rS r9 r@ )r i_cfgscc_pathscc_pcc_fnr r r _get_instance_configs s0
z"ConfigMerger._get_instance_configsreturnc C s g }| j r%| j D ] }z
|t| W q ty$ ttd| Y qw || || ||
| j rC|| j t |S )Nz'Failed loading of configuration from %s)
r^ rg r
rl r9 r@ rA extendro rz rj r_
mergemanydict)r cfgsc_fnr r r _read_cfg s
zConfigMerger._read_cfgc C s | j d u r
| | _ | j S r )ra r r r r r cfg s
zConfigMerger.cfg)NNNNT) r r r r rj ro rz rU r propertyr r r r r r[ s
r[ c @ sF e Zd Zdd Zdd Zdd Zdd Zdd d Zd
d Zdd Z dS )ContentHandlersc C s i | _ g | _d S r )
registered initializedr r r r r
rN zContentHandlers.__init__c C
| |S r )
is_registered)r itemr r r __contains__ r. z ContentHandlers.__contains__c C r r ) _get_handler)r keyr r r __getitem__ r. zContentHandlers.__getitem__c C s
|| j v S r r r content_typer r r r r. z ContentHandlers.is_registeredFTc C sj t }| D ]}|r|| q| |s|| q|D ]}|| j|< q |r3|| jvr3| j| |S r )set
list_typesaddr r r rg )r modr overwritetypestr r r register s
zContentHandlers.registerc C s
| j | S r r r r r r r ( r. z ContentHandlers._get_handlerc C s t | j S r )listr itemsr r r r r + zContentHandlers.itemsN)FT)
r r r r r r r r r r r r r r r s
r c @ st e Zd ZdZddefddZdeddfdd Zdd
d Zdd d
Z dddZ
dddZ dde fddZ
dddZdS )Paths N path_cfgsc
C s || _ |dd| _|dd| _|dtj| _tj | jd| _
tj | j
d| _ tj | jd| _ |d d
}tj |d | _
i d d d
ddddddddddddddddd d d d d d d d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1| _|| _d S )2N cloud_dirz/var/lib/clouddocs_dirz/usr/share/doc/cloud-init/run_dirinstancez
boot-finishedseed
templates_dirz/etc/cloud/templates/z%s.tmpl boothooksrp zcloud-config.txtdatahandlers
instance_datainstance-data.jsoninstance_data_sensitive instance-data-sensitive.jsoncombined_cloud_configcombined-cloud-config.jsonnetwork_configznetwork-config.json instance_idz .instance-idmanual_clean_markerz manual-cleanobj_pklzobj.pklscriptsrO userdatazuser-data.txt.i userdata_rawz
user-data.txt
vendordatazvendor-data.txt.i vendordata2zvendor-data2.txt.izvendor-data2.txtzvendor-data.txtzvendor2-cloud-config.txtzvendor-cloud-config.txtzscripts/vendorwarningshotplug.enabled
.skip-network)vendordata2_rawvendordata_rawrq rr vendor_scriptsr r r )r~ getr r r DEFAULT_RUN_DIRr rC rG rJ
instance_link
boot_finishedseed_dir template_tpllookupsrb )r r ds template_dirr r r r 2 sx
!zPaths.__init__ci_pkl_versionr{ c C sv t | dst| j| jdj| _d| jvrd| jd< d| jvr#d| jd< d| jvr-d| jd< d | jvr9d | jd < d
S d
S ) z(Perform deserialization fixes for Paths.r )r r r r r r r r r N)hasattrr r~ rb r r )r r r r r _unpickleg s"
zPaths._unpicklec C | | j|S r )r< r r r4 r r r rs r zPaths.get_ipath_curc C r r )r< r r r r r rQ r zPaths.get_cpathc C sf | j sd S | j }|d u rd S t|tjd}tj| jd|}| j
|}|r1tj||}|S )Nr2 instances) rb get_instance_idstrr3 rC seprG rJ r r r )r r4 iid
path_safe_iidipathadd_onr r r
_get_ipath s
zPaths._get_ipathc C s | |}|std d S |S )Nz?No per instance data available, is there an datasource/iid set?)r rA warning)r r4 r r r r rP s
zPaths.get_ipathbasec C s |d u r|S t j|| j| S r )rC rG rJ r )r r r4 r r r r< s zPaths._get_pathc C r r )r< r r r r r get_runpath r zPaths.get_runpathr )r r r _ci_pkl_versionrU r intr rs rQ r rP r r< r r r r r r / s 5
r c @ sX e Zd ZdZdZdZdZdd ZdddZd d
Z d d Z
d
d Z dd Z dddZ
dS )DefaultingConfigParserr g FNc C sB | j }z
t| ||}W |S ty Y |S ty Y |S w r )DEF_BASEr r r r r sectionoptionvaluer r r r s zDefaultingConfigParser.getc C s4 | |s| dkr| | t| ||| d S )Ndefault) has_sectionlower add_sectionr r r r r r r s
zDefaultingConfigParser.setc C s" | ||rt| || d S d S r )
has_optionr
remove_optionr r r r r r r s z$DefaultingConfigParser.remove_optionc C | ||s | jS t| ||S r )r DEF_BOOLEANr
getbooleanr r r r r z!DefaultingConfigParser.getbooleanc C r r )r DEF_FLOATr getfloatr r r r r r z DefaultingConfigParser.getfloatc C r r )r DEF_INTr getintr r r r r r z DefaultingConfigParser.getintc C s< d}t }| | | | }|r d||dg}|S )N
)r writeflushgetvaluerJ )r headerrF outputstreamr r r stringify s
z DefaultingConfigParser.stringifyr )r r r r r r r r r r r r r r r r r r r s
r )$r) loggingrC configparserr r r ior r cloudinitr r r r
cloudinit.settingsr r r
r getLoggerr rA r9 r r r r+ r5 r6 rK r[ r CloudInitPickleMixinr r r r r r
s*
:-j#