آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 \¼me،Aم@sddlZddlZddlZddlmZmZmZddlmZddl m Z ddl mZmZm Z ddlmZmZmZmZejeƒZGdd„deƒZGd d „d ƒZGdd„dƒZGd d„dƒZdd„ZGdd„dƒZGdd„dƒZGdd„dƒZGdd„dƒZGdd„dej ƒZ!Gdd„deƒZ"dS)éN)ع NoOptionErrorعNoSectionErrorعRawConfigParser)عStringIO)عtime)عpersistenceع type_utilsعutil)عCFG_ENV_NAMEع PER_ALWAYSعPER_INSTANCEعPER_ONCEc@seZdZdS)عLockFailureN)ع__name__ع __module__ع__qualname__©rrْ/usr/lib/python3.6/helpers.pyrsrc@seZdZdS)ع DummyLockN)rrrrrrrrsrc@s4eZdZdd„Zejddd„ƒZdd„Zdd „Zd S)عDummySemaphorescCsdS)Nr)عselfrrrع__init__!szDummySemaphores.__init__FccstƒVdS)N)r)rع_nameع_freqZ_clear_on_failrrrعlock$szDummySemaphores.lockcCsdS)NFr)rrrrrrعhas_run(szDummySemaphores.has_runcCsdS)NTr)rrrrrrعclear+szDummySemaphores.clearN)F) rrrrع contextlibعcontextmanagerrrrrrrrr s rc@seZdZdd„Zdd„ZdS)عFileLockcCs ||_dS)N)عfn)rr rrrr0szFileLock.__init__cCsdtj|ƒ|jfS)Nz<%s using file %r>)rZobj_namer )rrrrع__str__3szFileLock.__str__N)rrrrr!rrrrr/srcCs|jddƒS)Nْ-ع_)عreplace)عnamerrrعcanon_sem_name7sr&c@sDeZdZdd„Zejddd„ƒZdd„Zdd „Zd d„Z dd „Z dS)عFileSemaphorescCs ||_dS)N)عsem_path)rr(rrrr<szFileSemaphores.__init__FccsFt|ƒ}y|j||ƒVWn&tk r@|r:|j||ƒ‚YnXdS)N)r&ع_acquireع Exceptionr)rr%عfreqع clear_on_failrrrr?szFileSemaphores.lockcCsNt|ƒ}|j||ƒ}ytj|ƒWn&ttfk rHtjtd|ƒdSXdS)NzFailed deleting semaphore %sFT)r&ع _get_pathr Zdel_fileعIOErrorعOSErrorعlogexcعLOG)rr%r+عsem_filerrrrIszFileSemaphores.clearcCsn|j||ƒrdS|j||ƒ}dtjƒtƒf}ytj||ƒWn&ttfk rdtj t d|ƒdSXt|ƒS)Nz%s: %s z Failed writing semaphore file %s)rr-عosعgetpidrr Z write_filer.r/r0r1r)rr%r+r2عcontentsrrrr)SszFileSemaphores._acquirecCsh|s|tkrdSt|ƒ}|j||ƒ}tjj|ƒr6dS||krdtjj|j||ƒƒrdtjd||ƒdSdS)NFTzœ%s has run without canonicalized name [%s]. likely the migrator has not yet run. It will run next boot. run manually with: cloud-init single --name=migrator)rr&r-r3عpathعexistsr1عwarning)rr%r+Zcnamer2rrrrcszFileSemaphores.has_runcCs<|j}|s|tkr"tjj||ƒStjj|d||fƒSdS)Nz%s.%s)r(rr3r6عjoin)rr%r+r(rrrr-}szFileSemaphores._get_pathN)F)rrrrrrrrr)rr-rrrrr';s r'c@s&eZdZdd„Zdd„Zd dd„ZdS) عRunnerscCs||_i|_dS)N)عpathsعsems)rr;rrrr†szRunners.__init__cCsj|tks|rdSd}|tkr,|jjdƒ}n|tkr@|jjdƒ}|sHdS||jkr`t|ƒ|j|<|j|S)Nعsem)rrr;ع get_ipathr ع get_cpathr<r')rr+r(rrrع_get_semٹs zRunners._get_semNFc Cs‍|j|ƒ}|stƒ}|sg}|j||ƒr:tjd||ƒdS|j|||ƒڈL}|s\td|ƒ‚n4tjd||ƒt|tƒr€|f|ژ}n||ژ}d|fSWdQRXdS)Nz%s already ran (freq=%s)FzFailed to acquire lock for %szRunning %s using lock (%s)T)FN) r@rrr1عdebugrrع isinstanceعdict) rr%Zfunctorعargsr+r,r=Zlkعresultsrrrعrun‌s zRunners.run)NF)rrrrr@rFrrrrr:…sr:c@sHeZdZddd„Zdd„Zdd„Zd d „Zedœdd „Ze dd„ƒZ dS)عConfigMergerNTcCs(||_||_||_||_||_d|_dS)N)ع_pathsع_dsع_fnsع _base_cfgع_include_vendorع_cfg)rr;ع datasourceZadditional_fnsZbase_cfgZinclude_vendorrrrr³szConfigMerger.__init__cCsZg}|jrVy&|jjƒ}|r.t|tƒr.|j|ƒWn$tk rTtjtd|jƒYnX|S)Nz2Failed loading of datasource config object from %s) rIZget_config_objrBrCعappendr*r r0r1)rZd_cfgsZds_cfgrrrع_get_datasource_configsأs z$ConfigMerger._get_datasource_configscCsTg}ttjkrPtjt}y|jtj|ƒƒWn"tk rNtjtd|ƒYnX|S)Nz%Failed loading of env. config from %s) r r3عenvironrOr ع read_confr*r0r1)rZe_cfgsZe_fnrrrع_get_env_configsزs zConfigMerger._get_env_configscCs²g}|js|Sdg}|jr.|jdƒ|jdƒx~|D]v}|jj|ƒ}|r4tjj|ƒr4y|jtj|ƒƒWq4t k rˆt jd|ƒYq4tk r¨tj t d|ƒYq4Xq4W|S)Nعcloud_configعvendor2_cloud_configعvendor_cloud_configz5Skipped loading cloud-config from %s due to non-root.z&Failed loading of cloud-config from %s)rHrLrOع get_ipath_curr3r6عisfiler rRعPermissionErrorr1rAr*r0)rZi_cfgsZcc_pathsZcc_pZcc_fnrrrع_get_instance_configsـs( z"ConfigMerger._get_instance_configs)عreturncCsکg}|jrRxF|jD]<}y|jtj|ƒƒWqtk rLtjtd|ƒYqXqW|j|jƒƒ|j|j ƒƒ|j|j ƒƒ|jrژ|j|jƒtj|ƒS)Nz'Failed loading of configuration from %s) rJrOr rRr*r0r1عextendrSrZrPrKZ mergemanydict)rعcfgsZc_fnrrrع _read_cfgüszConfigMerger._read_cfgcCs|jdkr|jƒ|_|jS)N)rMr^)rrrrعcfgs zConfigMerger.cfg)NNNNT)rrrrrPrSrZrCr^عpropertyr_rrrrrG²s rGc@sFeZdZdd„Zdd„Zdd„Zdd„Zddd„Zd d„Zdd„Z dS)عContentHandlerscCsi|_g|_dS)N)ع registeredعinitialized)rrrrrszContentHandlers.__init__cCs |j|ƒS)N)ع is_registered)rعitemrrrع__contains__!szContentHandlers.__contains__cCs |j|ƒS)N)ع_get_handler)rعkeyrrrع__getitem__$szContentHandlers.__getitem__cCs ||jkS)N)rb)rعcontent_typerrrrd'szContentHandlers.is_registeredFTcCsrtƒ}x4|jƒD](}|r$|j|ƒq|j|ƒs|j|ƒqWx|D]}||j|<qBW|rn||jkrn|jj|ƒ|S)N)عsetZ list_typesعaddrdrbrcrO)rعmodrcZ overwriteعtypesعtrrrعregister*s zContentHandlers.registercCs |j|S)N)rb)rrjrrrrg8szContentHandlers._get_handlercCst|jjƒƒS)N)عlistrbعitems)rrrrrr;szContentHandlers.itemsN)FT) rrrrrfrirdrprgrrrrrrras rac@sreZdZdZdedœdd„Zeddœdd„Zdd d „Zddd„Z dd d„Z ddd„Zdedœdd„Z ddd„ZdS)عPathséN)ع path_cfgscCs´||_|jddƒ|_|jddƒ|_tjj|jdƒ|_tjj|jdƒ|_tjj|jdƒ|_ |jdd ƒ}tjj|d ƒ|_ ddd ddddddddddddddddddd d!d"œ|_||_dS)#Nع cloud_dirz/var/lib/cloudعrun_dirz/run/cloud-initعinstancez boot-finishedZseedZ templates_dirz/etc/cloud/templates/z%s.tmplع boothookszcloud-config.txtعdataعhandlerszinstance-data.jsonzinstance-data-sensitive.jsonzcombined-cloud-config.jsonznetwork-config.jsonz.instance-idzmanual-cleanzobj.pklعscriptsr=zuser-data.txt.iz user-data.txtzvendor-data.txt.izvendor-data2.txt.izvendor-data2.txtzvendor-data.txtzvendor2-cloud-config.txtzvendor-cloud-config.txtzscripts/vendorعwarnings)ryrTrzr{ع instance_dataعinstance_data_sensitiveعcombined_cloud_configZnetwork_configZinstance_idZmanual_clean_markerZobj_pklr|r=ZuserdataZuserdata_rawZ vendordataZvendordata2Zvendordata2_rawZvendordata_rawrUrVZvendor_scriptsr}) r]عgetrvrwr3r6r9ع instance_linkZ boot_finishedZseed_dirZtemplate_tplعlookupsrN)rruعdsZtemplate_dirrrrrBsD zPaths.__init__)عci_pkl_versionr[cCs^t|dƒst|j|jdچj|_d|jkr2d|jd<d|jkrFd|jd<d|jkrZd|jd<d S) z(Perform deserialization fixes for Paths.rw)rur„r~zinstance-data.jsonrzinstance-data-sensitive.jsonr€zcombined-cloud-config.jsonN)عhasattrrsr]rNrwrƒ)rr…rrrع _unpicklers zPaths._unpicklecCs|j|j|ƒS)N)r-r‚)rr%rrrrW‰szPaths.get_ipath_curcCs|j|j|ƒS)N)r-rv)rr%rrrr?ژszPaths.get_cpathcCsf|js dS|jjƒ}|dkr dSt|ƒjtjdƒ}tjj|jd|ƒ}|j j |ƒ}|rbtjj||ƒ}|S)Nr#Z instances)rNZget_instance_idعstrr$r3عsepr6r9rvrƒrپ)rr%ZiidZ path_safe_iidعipathZadd_onrrrع _get_ipath“s zPaths._get_ipathcCs$|j|ƒ}|stjdƒdS|SdS)Nz?No per instance data available, is there an datasource/iid set?)r‹r1r8)rr%rٹrrrr>£s zPaths.get_ipath)عbasecCs |dkr|Stjj||j|ƒS)N)r3r6r9rƒ)rrŒr%rrrr-®szPaths._get_pathcCs|j|j|ƒS)N)r-rw)rr%rrrعget_runpath³szPaths.get_runpath)N)N)N)N)N)N)N)rrrZ_ci_pkl_versionrCrعintr‡rWr?r‹r>rˆr-rچrrrrrs?s0 rsc@sXeZdZdZdZdZdZdd„Zddd„Zd d „Z dd„Z d d„Zdd„Zddd„Z dS)عDefaultingConfigParserrgFNcCsD|j}ytj|||ƒ}Wn&tk r,Yntk r>YnX|S)N)عDEF_BASErrپrr)rعsectionعoptionعvaluerrrrپاszDefaultingConfigParser.getcCs6|j|ƒr"|jƒdkr"|j|ƒtj||||ƒdS)Nعdefault)Zhas_sectionعlowerZadd_sectionrrk)rr‘r’r“rrrrkرs zDefaultingConfigParser.setcCs|j||ƒrtj|||ƒdS)N)ع has_optionrع remove_option)rr‘r’rrrr—ضsz$DefaultingConfigParser.remove_optioncCs |j||ƒs|jStj|||ƒS)N)r–عDEF_BOOLEANrع getboolean)rr‘r’rrrr™عsz!DefaultingConfigParser.getbooleancCs |j||ƒs|jStj|||ƒS)N)r–ع DEF_FLOATrعgetfloat)rr‘r’rrrr›كszDefaultingConfigParser.getfloatcCs |j||ƒs|jStj|||ƒS)N)r–عDEF_INTrعgetint)rr‘r’rrrr‌نszDefaultingConfigParser.getintcCs<d}tƒ}|j|ƒ|jƒ|jƒ}|r8dj||dgƒ}|S)Nعع )rعwriteعflushعgetvaluer9)rعheaderr5Zoutputstreamrrrع stringifyés z DefaultingConfigParser.stringify)N)N)rrrrœrڑrکrگrپrkr—r™r›r‌r¤rrrrrڈءs rڈ)#rZloggingr3ZconfigparserrrrعiorrZ cloudinitrrr Zcloudinit.settingsr rrr Z getLoggerrr1r*rrrrr&r'r:rGraZCloudInitPickleMixinrsrڈrrrrعs( J-j#