File Manager

Viewing File: /usr/lib/python2.7/site-packages/cloudinit/util.pyo

ó
ƒjbc@s
ddlZddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZ
ddlZddl
Z
ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZmZddlmZmZddlmZ ddl!Z!ddl"m#Z#ddl"m$Z%ddl"m&Z&ddl"m'Z'dd	l"m(Z(dd
l"m)Z)ddl"m*Z*ddl"m+Z+dd
l,m-Z-yddl.m/Z/Wne0k
rd„Z/nXda2e%j3e4ƒZ5ide
j66Z7dej8ej9Z:dæZ;dçZ<dddgdgdgfZ=e/ƒdd„ƒZ>e/ƒdd „ƒZ?dd!„Z@dd"„ZAd#d$„ZBd#d%„ZCd&„ZDd'„ZEd(„ZFd)ZGid*d+6d,d-6d.d/6d0d16d2d36d4d56d6d76d8d96d:d;6d<d=6d>d?6d@dA6dBdC6dDdE6dFdG6dHdI6dJdK6ZHdLeIfdM„ƒYZJdNeKfdO„ƒYZLdPeMfdQ„ƒYZNdReMfdS„ƒYZOdT„ZPddU„ZQddV„ZRddW„ZSdXddY„ZTddZ„ZUd[„ZVd\„ZWd]„ZXd^„ZYeZeZd_„Z[d`„Z\da„Z]eZeZde%j^db„Z_dc„Z`e/ƒdd„ƒZaebde„Zcddf„Zddgdh„Zeddi„Zfe/ƒdj„ƒZge/ƒdk„ƒZhddl„Ziddm„Zjdn„Zkdddo„Zlddpdpdpdpdq„Zmebdr„Znejods„ƒZpejodt„ƒZqdu„Zrdv„ZseZddw„Ztdpdpdxdy„Zuddz„Zvdewfd{„Zxdpdpdxd|dgd}„Zyd~„Zzd„Z{dd€„Z|dd„Z}d‚„Z~ebdƒ„Zd„d…„Z€d†„Zd‡„Z‚dˆ„Zƒd‰„Z„dŠ„Z…d‹„Z†ddŒdebdd„Z‡debdŽ„Zˆd„Z‰d„ZŠdebeZd‘„Z‹e/ƒd’„ƒZŒd“„Zd”dd•„ZŽddd–„Zddd—„Zd˜„Z‘d™„Z’dš„Z“dd›„Z”dœ„Z•d„Z–dž„Z—dŸd „Z˜ewfd¡„Z™d¢„Zšd£„Z›d¤„Zœdd¥„Zejod¦„ƒZžd§„ZŸdddd¨„Z d©„Z¡dª„Z¢ebd«„Z£d¬„Z¤d„Zd®„Z¥d¯„Z¦d°„Z§d±d²„Z¨d³„Z©d´„Zªd±dµebd¶„Z«d·„Z¬d¸„ZdddeZebebebd¹ddddº„Z®d»d¼d½„Z¯d¾„Z°eZd¿„Z±dddÀ„Z²dÁ„Z³dÂ„Z´d#d¹dÃ„ZµdÄ„Z¶dÅ„Z·dÆ„Z¸e5ebdÇ„Z¹dÈ„ZºdÉ„Z»dÊ„Z¼dË„Z½dÌ„Z¾dÍ„Z¿e5ebdÎ„ZÀdÏ„ZÁdddÐ„ZÂddebdÑ„ZÃdÒ„ZÄdde
jÅj6dÓ„ZÆdÔebdÕ„ZÇdÖ„ZÈd×„ZÉdØ„ZÊddÙ„ZËdÚ„ZÌdÛ„ZÍddÜ„ZÎdÝ„ZÏdÞ„ZÐdß„ZÑebddà„ZÒdádpdâ„ZÓdã„ZÔdddä„ZÕdå„ZÖdS(èiÿÿÿÿN(tENOENTtENOEXEC(t	b64decodet	b64encode(tparse(timporter(tlog(tmergers(tsafeyaml(t
temp_utils(t
type_utils(t
url_helper(tversion(tCFG_BUILTIN(t	lru_cachecCs
d„}|S(s+pass-thru replace for Python3's lru_cache()cSs|S(N((tf((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytwrapper:s((R((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR8s	t_s_-.()ttruet1tontyestofft0tnotfalsessystemd-detect-virts--quiets--containersrunning-in-containerslxc-is-containercCs.tddgdtd|ƒ\}}|jƒS(Ntdpkgs--print-architecturetcapturettarget(tsubptTruetstrip(RtoutR((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_architectureRscCs;idd6dd6dd6dd6}i}yÍtd	d
gdtd|ƒ\}}xO|jƒD]A}|jd
ƒ\}}}||kr\|jƒ|||<q\q\Wg|jƒD]}||kr®|^q®}	t|	ƒrôtjddj	|	ƒƒnWn?t
k
r6}
tjd|
ƒtd„|jƒDƒƒ}nX|S(NtcodenametCodenametdescriptiontDescriptiontidsDistributor IDtreleasetReleasetlsb_releases--allRRt:s.Missing fields in lsb_release --all output: %st,s#Unable to get lsb_release --all: %scss|]}|dfVqdS(tUNAVAILABLEN((t.0tv((s2/usr/lib/python2.7/site-packages/cloudinit/util.pys	<genexpr>ls(RRt
splitlinest	partitionRtvaluestlentLOGtwarningtjointProcessExecutionErrortdict(RtfmaptdataR Rtlinetfnametvaltktmissingterr((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt_lsb_releaseYs"$+	 cCs#t|ƒdkrt|ƒStƒS(Nt/(ttarget_pathR@(R((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR)qs
cCs²|dkrd}nSt|tjƒs:td|ƒ‚n.tjj|ƒ}|jdƒrh|d}n|sr|Sx*t	|ƒrž|ddkrž|d}quWtjj
||ƒS(NtRAsUnexpected input for target: %ss//ii(NRC(tNonet
isinstancetsixtstring_typest
ValueErrortostpathtabspatht
startswithR2R5(RRJ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRBys	
sutf-8cCs#t|tjƒr|S|j|ƒS(N(RERFRGtdecode(tblobtencoding((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
decode_binaryscCs#t|tjƒr|S|j|ƒS(N(RERFtbinary_typetencode(ttextRO((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytencode_text–scCs6t|ƒ}y|jdƒSWntk
r1|SXdS(Nsutf-8(RRMtUnicodeDecodeError(tsourcetdecoded((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytb64ds

cCs4t|tƒs!|jdƒ}nt|ƒjdƒS(Nsutf-8(REtbytesRRRRM(RV((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytb64e§scCs}|jdtƒ}tjry|jƒdkryt|tƒry|jƒ}|rc|jrc|j}nd}|j	|dƒS|S(NRMRSsutf-8tsurrogateescape(
tget_payloadRRFtPY3tget_content_maintypeRERYtget_charsettinput_codecRM(tparttcte_payloadtcharsetRO((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytfully_decoded_payload¯s	s/sys/class/dmi/idtboard_asset_tagsbaseboard-asset-tagtboard_vendorsbaseboard-manufacturert
board_namesbaseboard-product-nametboard_serialsbaseboard-serial-numbert
board_versionsbaseboard-versiont	bios_datesbios-release-datetbios_vendorsbios-vendortbios_versionsbios-versiontchassis_asset_tagschassis-asset-tagtchassis_vendorschassis-manufacturertchassis_serialschassis-serial-numbertchassis_versionschassis-versiont
sys_vendorssystem-manufacturertproduct_namessystem-product-nametproduct_serialssystem-serial-numbertproduct_uuidssystem-uuidtproduct_versionssystem-versionR6cBsGeZdZdZdddddddd„Zd„Zdd„ZRS(sr%(description)s
Command: %(cmd)s
Exit code: %(exit_code)s
Reason: %(reason)s
Stdout: %(stdout)s
Stderr: %(stderr)st-c	Csº|s|j|_n	||_|sO|rC|tkrCd|_qXd|_n	||_t|tjƒsy|j|_n	||_|s¯|dkr£|j|_	qÁ||_	n|j
|ƒ|_	|sî|dkrâ|j|_q||_n|j
|ƒ|_|r||_n|j|_||_
|ji|j|jƒd6|j|jƒd6|j|jƒd6|j|jƒd6|j|j	ƒd6|j|jƒd6}tj||ƒdS(	Ns(Exec format error. Missing #! in script?s'Unexpected error while running command.R$tcmdt	exit_codetstdouttstderrtreason(t
empty_attrRwRR$RERFt
integer_typesRxRDRzt_indent_textRyR{terrnotMESSAGE_TMPLt_ensure_stringtIOErrort__init__(	tselfRyRzRxRwR$R{Rtmessage((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRƒæsB					cCs t|tjƒr|jƒS|S(s1
        if data is bytes object, decode
        (RERFRQRM(R„RS((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRsicCsZd}d|}t|tjƒr=|jƒ}|jƒ}n|j|ƒj|||ƒS(sY
        indent text on all but the first line, allowing for easy to read output
        s
t (RERFRQRRtrstriptreplace(R„RStindent_leveltcrtindent((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR~"s
N(t__name__t
__module__R€R|RDRƒRR~(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR6Üs3	tSeLinuxGuardcBs&eZed„Zd„Zd„ZRS(cCsIytjdƒ|_Wntk
r2d|_nX||_||_dS(Ntselinux(Rt
import_moduleRtImportErrorRDRJt	recursive(R„RJR’((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRƒ2s

	cCs$|jr|jjƒrtStSdS(N(Rtis_selinux_enabledRtFalse(R„((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt	__enter__<scCs|js|jjƒrdStjj|jƒs7dStjj|jƒ}tjrdt|ƒ}ny-tj	|ƒ}|jj
||tjƒWnt
k
r¥dSXtjd||jƒy|jj|d|jƒWn,t
k
r}tjd||j|ƒnXdS(Ns,Restoring selinux mode for %s (recursive=%s)R’s,restorecon failed on %s,%s maybe badness? %s(RR“RIRJtlexiststrealpathRFtPY2tstrtlstattmatchpathcontstattST_MODEtOSErrorR3tdebugR’t
restoreconR4(R„t	excp_typet
excp_valuetexcp_tracebackRJtstatste((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt__exit__Bs&	
	
	(RŒRR”RƒR•R¦(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRŽ1s
	tMountFailedErrorcBseZRS((RŒR(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR§[stDecompressionErrorcBseZRS((RŒR(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR¨_scOs“tjƒ}|dkrsy|||ŽtjdƒWqtk
rottdtj|ƒƒtjdƒqXntjd|tj|ƒƒdS(Nis&Failed forking and calling callback %sis(Forked child %s who will run callback %s(	RItforkt_exitt	ExceptiontlogexcR3R
tobj_nameRŸ(tchild_cbtargstkwargstfid((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytfork_cbcs

		cCsat|tƒr|tkSt}|r8t|ƒ|}ntj|ƒjƒjƒ|kr]tSt	S(N(
REtboolRtTRUE_STRINGStlistRFt	text_typetlowerRR”(R<taddonst	check_set((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_truers
!cCsat|tƒr|tkSt}|r8t|ƒ|}ntj|ƒjƒjƒ|kr]t	StS(N(
RER³R”t
FALSE_STRINGSRµRFR¶R·RR(R<R¸R¹((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_false}s
!cCs*|s
tSt|tƒr|St||ƒS(N(R”RER³Rº(R<R¸((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyttranslate_boolˆs
i cCsWtjƒ}|s%tjtj}ndjgtd|ƒD]}|j|ƒ^q;ƒS(NRCi(trandomtSystemRandomtstringt
ascii_letterstdigitsR5trangetchoice(tstrlentselect_fromtrt_x((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytrand_str“scCsG|sd}nx1trBtddƒd|}||krPqqW|S(NRCRÅiR(RRÉ(t
dictionarytpostfixtnewkey((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
rand_dict_keyšs		cCsJytt|ƒdiƒSWn)tk
rE}|jtkr?iS‚nXdS(Ntdefault(t	load_yamlt	load_fileR‚RR(R;R¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt	read_conf¤scGstt|ŒƒS(N(tsortedt
uniq_merge(tlists((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytuniq_merge_sorted±scGs}g}xj|D]b}t|tjƒrb|jƒjdƒ}g|D]}t|ƒrA|^qA}n|j|ƒq
Wt|ƒS(NR+(RERFRGRtsplitR2textendt	uniq_list(RÔt
combined_listta_listta((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRÓ½s
(cCs•x,tjƒD]\}}|j||ƒ}q
Wg}x*|D]"}|tkr<|j|ƒq<q<Wx |D]}|j|dƒ}qiW|jƒ}|S(NRC(tFN_REPLACEMENTStitemsRˆt
FN_ALLOWEDtappendR(tfnR=R.tremovals((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytclean_filenameÈs

cCsœyctjt|ƒƒ}tjtjddd|ƒƒ'}|rRt|j	ƒƒS|j	ƒSWdQXWn2t
k
r—}|r|Sttj|ƒƒ‚nXdS(Ntrbi(
RFtBytesIORTt
contextlibtclosingtgziptGzipFileRDRPtreadR«R¨R¶(R9tquietRMtbuftghR¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytdecomp_gzipÕs$cCs½|s
dS|jddƒ}|djƒ}t|ƒdkrQ|djƒ}nd}|s||dks||jƒdkr…d}n|sª|dksª|jƒdkr³d}n||fS(NR*iiis-1tnone(NN(RDRÖRR2R·(tug_pairt	ug_partedtutg((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytextract_usergroupås%	%	cCs›tƒ}x‹tjtjj|dƒƒD]k}tjj|ƒsFq(ntjj|ƒdd!}|jƒ}|r(|jdƒdkr(|||<q(q(W|S(Ns*.pyiiýÿÿÿt.iÿÿÿÿ(	R7tglobRIRJR5tisfiletbasenameRtfind(troot_dirtentriesR;tmodname((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytfind_modulesõs	%cCsÀ|rtjj|ƒn|r|d}tjj|ƒrit|dƒ}|j|ƒ|jƒWdQXq|tjj|ƒn|r¼|ddkr©|j	||d ƒq¼|j	||ƒndS(Ns/dev/consoletwiÿÿÿÿs
(
tsysRztwriteRIRJtexiststopentflushRyR(RStconsoleRzRt	log_leveltconpathtwfh((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt	multi_logs

cCs‰|jdƒ}t|ƒdkr%tSy?g|D].}dt|ƒkoRdknr/|^q/}Wntk
rxtSXt|ƒdkS(s<determine if input string is a ipv4 address. return boolean.Rôiii(RÖR2R”tintR«(tinstrttokstx((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_ipv4s?
cCstƒddkS(Ntvarianttfreebsd(tsystem_info(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
is_FreeBSD*scCs||kr|St||ƒS(N(R½(tyobjtkeyRÎ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_cfg_option_bool/scCs?||kr|S||}t|tjƒs;t|ƒ}n|S(N(RERFRGR™(RRRÎR<((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_cfg_option_str5s
icCstt||d|ƒƒS(NRÎ(RR(RRRÎ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_cfg_option_int>scCsÂ|sd}ntjj|ƒs%iSt|ƒ}d}tj||ƒ}|r¾|jƒ}|djƒjdƒd|d<|ddkr™d|d<ni|dd6|d	d
6|dd6SiS(
s¦Return a dictionary of distro info fields from /etc/redhat-release.

    Dict keys will align with /etc/os-release keys:
        ID, VERSION_ID, VERSION_CODENAME
    s/etc/redhat-releasesA(?P<name>.+) release (?P<version>[\d\.]+) \((?P<codename>[^)]+)\)tnames linuxisred hat enterprisetredhattIDRt
VERSION_IDR"tVERSION_CODENAME(	RIRJRRÐtretmatcht	groupdictR·R0(trelease_filetredhat_releasetredhat_regexRtgroup((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt_parse_redhat_releaseBs	!
c	CsÊd}d}d}i}tjjdƒr?ttdƒƒ}n|sQtƒ}n|r|jddƒ}|jddƒ}d|ks“d|kr¢tjƒ}nR|jddƒ}|sôt	j
d|jd	dƒƒ}|rô|jƒd
}qôn|dkr½d}q½n±tjjd
ƒrKd}tddgƒ\}}|j
ƒ}nrd}z(ytjƒ}Wntk
rwnXWdd}x|D]}|r‰d}q‰q‰W|s¸tjdƒnX|S|||fS(NRCs/etc/os-releaseRRtslestsuseRs[^ ]+ \((?P<codename>[^)]+)\)tVERSIONR"trhelRs/bin/freebsd-versionRtunames-risPUnable to determine distribution, template expansion may have unexpected results(RCRCRC(RIRJRtload_shell_contentRÐR"tgettplatformtmachineRRRRRtdistR«RDR3R4(	tdistro_nametdistro_versiontflavort
os_releaseRRR,tfoundtentry((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_linux_distro\sN	


cCsitjƒd6tjƒd6tjƒd6tjƒd6tjƒd6tƒd6}|djƒ}d}|dkrä|dd	jƒ}|dkrœ|}qù|dkr±d}qù|dkrÆd}qù|dkrÛd}qùd}n|dkrù|}n||d<|S( NR*tsystemR'tpythonR'R,tunknowntlinuxitarchtcentostdebiantfedoraR&R$tubuntut	linuxminttmintRtopensusesopensuse-tumbleweeds
opensuse-leapR#twindowstdarwinRR
(R8R9R:R;srhelssuse(R<R=R>(R?sopensuse-tumbleweeds
opensuse-leapssles(R@sdarwinsfreebsd(R*R4R'tpython_versionR'R3R·(tinfoR4tvart
linux_dist((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRs4





								
cCs‚||kr|S||dkr$gS||}t|tƒrZg|D]}|^qD}|St|tjƒs{t|ƒ}n|gS(sª
    Gets the C{key} config option from C{yobj} as a list of strings. If the
    key is present as a single string it will be returned as a list with one
    string arg.

    @param yobj: The configuration object.
    @param key: The configuration key to get.
    @param default: The default to return if key is not found.
    @return: The configuration option as a list of strings or default if key
        is not found.
    N(RDRERµRFRGR™(RRRÎR<R.tcval((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_cfg_option_list²s
cCsYt|tjƒr$|jdƒ}n|}x(|D] }||krG|S||}q1W|S(s×Return the value of the item at path C{keyp} in C{yobj}.

    example:
      get_cfg_by_path({'a': {'b': {'num': 4}}}, 'a/b/num') == 4
      get_cfg_by_path({'a': {'b': {'num': 4}}}, 'c/d') == None

    @param yobj: A dictionary.
    @param keyp: A path inside yobj.  it can be a '/' delimited string,
                 or an iterable.
    @param default: The default to return if the path does not exist.
    @return: The value of the item at keyp."
        is not found.RA(RERFRGRÖ(RtkeypRÎtcurttok((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_cfg_by_pathÍs
cCs,t||ƒ\}}t||ƒ||fS(N(tget_output_cfgtredirect_output(tcfgtmodetoutfmtterrfmt((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytfixup_outputås
c	CsXttjjdƒƒr)tjdƒdS|s;tj}n|sMtj}n|rptjd||ƒ|j	ddƒ\}}|dks–|dkrÃd}|dkr±d	}nt
||ƒ}nF|d
krùtj|dt
dtjƒ}|j}ntd
|ƒ‚|r.tj|jƒ|jƒƒn||krptjd||ƒtj|jƒ|jƒƒdSn|rTtjd||ƒ|j	ddƒ\}}|dks¹|dkræd}|dkrÔd	}nt
||ƒ}nF|d
krtj|dt
dtjƒ}|j}ntd|ƒ‚|rTtj|jƒ|jƒƒqTndS(Nt_CLOUD_INIT_SAVE_STDOUTs5Not redirecting output due to _CLOUD_INIT_SAVE_STDOUTsRedirecting %s to %sR†it>s>>tabtwbt|tshelltstdins"Invalid type for output format: %ss!Invalid type for error format: %s(RºRItenvironR)R3RŸRþRyRzRÖRt
subprocesstPopenRtPIPERYt	TypeErrortdup2tfileno(	RPRQto_outto_errROtargtowithtnew_fptproc((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRMøsN
		RCc	Cs·|p	dg}d}|r*t|ƒ}n|dk	rK|dd|7}n|j|pZdƒ|j|pmdƒ|j|p€dƒ|j|p“dƒ|j|p¦dƒtj|ƒS(NRCR*s%s(R™RDRßturlparset
urlunparse(	tschemethosttportRJtparamstquerytfragmenttpiecestnetloc((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytmake_url+scCs~|rt|ƒ}ni}x\|D]T}|r"tj|ƒ}|sRtjƒ}ntj|ƒ}|j||ƒ}q"q"W|S(N(treversedRtdict_extract_mergerstdefault_mergerst	constructtmerge(tsrcstreverset
merged_cfgRNtmergers_to_applytmerger((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
mergemanydict@s
ccs7tjƒ}ztj|ƒ|VWdtj|ƒXdS(N(RItgetcwdtchdir(tndirtcurr((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR~Os

	ccs-tj|ƒ}z	|VWdtj|ƒXdS(N(RItumask(tn_msktold((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRYs	cCsdj|d|ddd|ƒS(Ns{0:{fill}{align}{size}}tfilltalignt^tsize(tformat(RSR„tmax_len((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytcenterbscCs!tjd|ƒtj|ƒdS(NsRecursively deleting %s(R3RŸtshutiltrmtree(RJ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytdel_dirgsc	Csx|rtjj|ƒrdSg}g}|dkr>g}nEt|tƒr_t|ƒg}n$t|tƒrw|}ntdƒ‚x½ttj	|ƒƒD]¦}tjj
||ƒ}tjj|ƒr™tj|tj
ƒr™|j|ƒyt||gdtƒWq?tk
r;}ttd||jƒ|j|ƒq?Xq™q™W|rt|rttdt|ƒt|ƒfƒ‚ndS(Ns%exe_prefix must be None, str, or listRsFailed running %s [%s]s.Runparts: %s failures in %s attempted commands(RIRJtisdirRDRER™RµR^RÒtlistdirR5RötaccesstX_OKRßRR”R6R¬R3RxtRuntimeErrorR2(	tdirpt
skip_no_existt
exe_prefixtfailedt	attemptedtprefixtexe_nametexe_pathR¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytrunpartsls.		'
icCsjy4t|||ƒ\}}||d<||d<tSWn/tjk
re}|jtjkr_tS‚nXdS(Ns	user-datas	meta-data(tread_seededRRtUrlErrortcodet	NOT_FOUNDR”(R„tbasetextttimeouttmdtudR¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytread_optional_seeds

cCswi}ddg}|r^|jtjj|jdƒdƒtjj|jdƒdƒgƒnt|ƒ}g|D]$}|rqtjj|ƒrq|^qq}d}xH|D]@}tjj	tjj|dƒƒr¨tjj|dƒ}Pq¨q¨Wd}xH|D]@}tjj	tjj|dƒƒrùtjj|dƒ}PqùqùW|r`|r`||d<||d<n|rs||d<n|S(	Ns/var/lib/cloud/data/ssls /var/lib/cloud/instance/data/sslR9tsslscert.pemskey.pemt	cert_filetkey_file(
R×RIRJR5t
get_ipath_curt	get_cpathRÓRŽRDRö(tpathstssl_detailstssl_cert_pathstdR§R¨((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytfetch_ssl_details›s2	%1
!
!


c
Cs…|}t|ƒ}y…tjdt|ƒ|ƒtj|ƒ}|dkr_tjdƒ|}n1t||ƒstd|t	j
|ƒfƒ‚n|}Wnçtjttfk
r€}d}d}t
|dƒrñt|dƒrñt|dƒ}n0t
|dƒr!t|dƒr!t|dƒ}n|rZ|djd|jd	d
|jd	d|ƒ7}n|djd|ƒ7}tj|ƒnX|S(
NsKAttempting to load yaml from string of length %s with allowed root types %ss-loaded blob returned None, returning default.s2Yaml load allows %s root types, but got %s insteadsFailed loading yaml blobtcontext_marktproblem_marks5. Invalid format at line {line} column {col}: "{err}"R:itcolR?s. {err}(RPR3RŸR2RtloadRDRER^R
Rt	YAMLErrorRHthasattrtgetattrRˆR:tcolumnR4(RNRÎtallowedtloadedt	convertedR¥tmsgtmark((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRÏ»s6	
	
	'i
cCsè|jdƒdkr4|d|}|d|}n&d|d|f}d|d|f}tj|d|d|ƒ}d}|jƒr¥tt|jƒdiƒ}ntj|d|d|ƒ}	d}
|	jƒrÞ|	j}
n||
fS(	Ns%sis	user-datas	meta-datas%s%s%sR¢tretriesRÎ(RøRtread_file_or_urlRDtokRÏRPtcontents(R R¡R¢R½tfile_retriestud_urltmd_urltmd_respR£tud_respR¤((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRœÝs 		cCsÀttj|ƒdtƒ}g|D]}|jdƒr"|^q"}g|D]-}tjjtjj||ƒƒrJ|^qJ}g}x0|D](}|jt	tjj||ƒƒƒqŠWt
|ƒS(NRxs.cfg(RÒRIRRtendswithRJRöR5RßRÑR|(tconfdtconfsRtcfgsRà((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytread_conf_dôs(
-
&cCs×t|ƒ}t}d|krz|d}|rt|tjƒsbtd|tj|ƒfƒ‚qwt|ƒj	ƒ}qn#t
jjd|ƒrd|}n|s·t
jj|ƒr»|St
|ƒ}t||gƒS(Ntconf_ds8Config file %s contains 'conf_d' with non-string type %ss%s.d(RÑR”RERFRGR^R
RR™RRIRJRŽRÊR|(tcfgfileRNRÇt	confd_cfg((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytread_conf_with_confds

cCsttd|ƒƒS(Ntcmdline(RÏtread_cc_from_cmdline(RÏ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytread_conf_from_cmdlinesc	Csè|dkrtƒ}nd}d}t|ƒ}t|ƒ}t|ƒ}g}|j|ƒ}x{|dkrÚ|j|||ƒ}|dkr—|}n|j||||!jƒjddƒƒ|j|||ƒ}q`Wdj|ƒS(Nscc:tend_ccis\ns
(RDtget_cmdlineR2RøRßtlstripRˆR5(	RÏt	tag_beginttag_endtbegin_ltend_ltclenttokenstbegintend((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRÐ$s"		 
cCsC|jdƒ}|dks/||ddkr3|S|jddƒS(Ns
iis
s
(RøRˆ(RÀtpos((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytdos2unixCs cCsÎd|kr8|d}t|d|jdƒdƒ}nŒd|kr|djdƒdkr|d}|d|jdƒ }nC|jdtd|ƒ}d|kr²|d}n|jd|ƒ}||fS(sæGet hostname and fqdn from config if present and fallback to cloud.

    @param cfg: Dictionary of merged user-data configuration (from init.cfg).
    @param cloud: Cloud instance from init.cloudify().
    @param metadata_only: Boolean, set True to only query cloud meta-data,
        returning None if not present in meta-data.
    @return: a Tuple of strings <hostname>, <fqdn>. Values can be none when
        metadata_only is True and no cfg or metadata provides hostname info.
    tfqdnthostnameRôit
metadata_only(RRÖRøtget_hostnameR(RNtcloudRáRßRà((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_hostname_fqdnKs

"%

s
/etc/hostscCsÄd}y¦xŸt|ƒjƒD]‹}|jdƒ}|dkrM|d|!}n|jƒ}|seqn|jƒ}t|ƒdkr‰qn||dkr|d}PqqWWntk
r¿nX|S(s¤
    For each host a single line should be present with
      the following information:

        IP_address canonical_hostname [aliases...]

      Fields of the entry are separated by any number of  blanks  and/or  tab
      characters.  Text  from a "#" character until the end of the line is a
      comment, and is ignored. Host  names  may  contain  only  alphanumeric
      characters, minus signs ("-"), and periods (".").  They must begin with
      an  alphabetic  character  and  end  with  an  alphanumeric  character.
      Optional aliases provide for name changes, alternate spellings, shorter
      hostnames, or generic hostnames (for example, localhost).
    t#iiiiN(RDRÐR/RøRRÖR2R‚(RàtfilenameRßR:thashposR
((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_fqdn_from_hostsjs$

cCsWtdkrötƒ}d	}i}x°|D]¨}y‚tj|dddtjtjƒ}g||<xM|D]E\}}}}	}
||jd|	|
dfƒ|j|
dƒqfWWq(tj	tj
fk
rÏq(Xq(W|a|rötjd|ƒqöny<tj|dƒ}|ddd}|tkr-t
StSWntj	tj
fk
rRt
SXdS(
sÜdetermine if a url is resolvable, return a boolean
    This also attempts to be resilent against dns redirection.

    Note, that normal nsswitch resolution is used here.  So in order
    to avoid any utilization of 'search' entries in /etc/resolv.conf
    we have to append '.'.

    The top level 'invalid' domain is invalid per RFC.  And example.com
    should also not exist.  The '__cloud_init_expected_not_found__' entry will
    be resolved inside the search list.
    sdoes-not-exist.example.com.sexample.invalid.t!__cloud_init_expected_not_found__is%s: %ssdetected dns redirection: %siN(sdoes-not-exist.example.com.sexample.invalid.Ré(t_DNS_REDIRECT_IPRDtsettsockettgetaddrinfotSOCK_STREAMtAI_CANONNAMERßtaddtgaierrorterrorR3RŸR”R(Rtbadipstbadnamest
badresultstinametresultt_famt_stypet_prototcnametsockaddrtaddr((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
is_resolvable’s6
	

cCstjƒ}|S(N(Rìtgethostname(Rà((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRâ¾scCs1ytj|ƒdSWntjk
r,dSXdS(Ni(Rìt
gethostbyaddrtherrorRD(tip((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRÃsc
Cs5tdtjdd|dtdtj|ƒjfƒS(s5determine if this url is resolvable (existing or ip).tlogfuncR»sResolving URL: tfuncR¯(tlog_timeR3RŸRþRgRà(turl((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_resolvable_urlÊscCs=x6|D].}yt|ƒr |SWqtk
r4qXqWdS(sc
    Search through a list of mirror urls for one that works
    This needs to return quickly.
    N(RR«RD(t
candidatestcand((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytsearch_for_mirrorÑs

cCsWttjjdƒƒrdSttjƒ&}tj|jƒtj	jƒƒWdQXdS(sú
    reopen stdin as /dev/null so even subprocesses or other os level things get
    /dev/null as input.

    if _CLOUD_INIT_SAVE_STDIN is set in environment to a non empty and true
    value then input will not be closed (useful for debugging).
    t_CLOUD_INIT_SAVE_STDINN(
RºRIRZR)RtdevnullR_R`RþRY(tfp((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytclose_stdinßstdevicec
Cs/dg}g}|r)|jd|ƒn|rC|jd|ƒn|r_|jddgƒn|ry|jd|ƒn|r|j|ƒn||}y"t|ddd	gƒ\}}	Wn.tk
rë}
|
jtkråd
}qì‚nXg}x6|jƒD](}|jƒ}|rÿ|j|ƒqÿqÿW|S(s–
    find devices matching given criteria (via blkid)
    criteria can be *one* of:
      TYPE=<filesystem>
      LABEL=<label>
      UUID=<uuid>
    tblkids-t%ss-s%ss-cs	/dev/nulls-o%strcsiiRC(RßR×RR6RRR/R(
tcriteriatoformatttagtno_cacheRJt
blk_id_cmdtoptionsRwR t_errR¥RúR:((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytfind_devs_withís2		
"	c	CsÎ|dkrg}nt|ƒ}dddg}|rL|jddgƒn|j|ƒt|dtddƒ\}}i}xJ|jƒD]<}|jd	ƒ\}}}t|ƒ||<|||d
<qŠW|S(sñGet all device tags details from blkid.

    @param devs: Optional list of device paths you wish to query.
    @param disable_cache: Bool, set True to start with clean cache.

    @return: Dict of key value pairs of info for the device.
    Rs-otfulls-cs	/dev/nullRRMRˆR*tDEVNAMEN(RDRµR×RRR/R0R((	tdevst
disable_cacheRwR RtretR:tdevR9((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR!s	
cCs<tjd||ƒt|dƒ}|j|ƒSWdQXdS(NsPeeking at %s (max_bytes=%s)Rã(R3RŸRRé(R;t	max_bytestifh((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt	peek_file@scCs:g}x-|D]%}||kr%q
q
|j|ƒq
W|S(N(Rß(tin_listtout_listti((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRØFs
c	CsÂtjd||ƒtjƒ}y/t|dƒ}t||d|ƒWdQXWn4tk
r„}|sl‚n|jtkr…‚q…nX|j	ƒ}tjdt
|ƒ|ƒ|rºt|ƒS|SdS(NsReading from %s (quiet=%s)Rãtchunk_cbsRead %s bytes from %s(R3RŸRFRäRtpipe_in_outR‚RRtgetvalueR2RP(R;tread_cbRêRMtofhR!R¥RÀ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRÐPs

cCs’tƒr^y&tdƒ}|jddƒd }WqŽtk
rZ}tjd|ƒd}qŽXn0ytdƒjƒ}Wntk
rd}nX|S(Ns/proc/1/cmdlinetR†iÿÿÿÿs"failed reading /proc/1/cmdline: %sRCs
/proc/cmdline(tis_containerRÐRˆR«R3R4R(RÀRÏR¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt_get_cmdlinecs	

cCs!dtjkrtjdStƒS(NtDEBUG_PROC_CMDLINE(RIRZR-(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRÓvsicCsvd}x_trg|j|ƒ}t|ƒdkr4Pq	|j|ƒ|t|ƒ7}|r	||ƒq	q	W|jƒ|S(Ni(RRéR2RÿR(tin_fhtout_fht
chunk_sizeR&tbytes_pipedR9((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR'}s	

cCsI|dkr|dkrdStjd|||ƒtj|||ƒdS(Niÿÿÿÿs%Changing the ownership of %s to %s:%s(Niÿÿÿÿ(Niÿÿÿÿ(RDR3RŸRItchown(R;tuidtgid((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt	chownbyidŒscCs€d}d}y:|r*tj|ƒj}n|rEtj|ƒj}nWn#tk
rk}td|ƒ‚nXt|||ƒdS(NiÿÿÿÿsUnknown user or group: %s(	tpwdtgetpwnamtpw_uidtgrptgetgrnamtgr_gidtKeyErrorRžR6(R;tuserR!R4R5R¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytchownbyname”sc
Csddg}|sd|kr#|S|d}||krF||}nd|krV|S|d}t|tƒr~||g}nt|tƒrÖt|ƒdkr°|d|d<nt|ƒdkrÖ|d|d<qÖnt|tƒr"d|kr|d|d<nd|kr"|d|d<q"n|ddkrC|d|d<nddd	g}x³tt|ƒƒD]Ÿ}||s{qen||jƒ}t}xG|D]?}	|j	|	ƒr˜d
|	|t|	ƒj
ƒf}t}Pq˜q˜W|súd
d|j
ƒf}n|||<qeW|S(NtoutputtalliiRòs&1s>>RTRWs%s %s(RDRER™RµR2R7RÃRÔR”RLRR(
RNRORtoutcfgtmodecfgtswlistR%R<R1ts((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRLªsL




 cCsg}|st|tƒr!|S|jdƒ}|rF|j|ƒnx¨t|dƒD]—}|shqVntjd|ƒ}|s†qVn|jdƒ}|j	ƒ}t
|ƒdkrÃ|j|ƒqVddg|d krV|j|dƒqVqVWtt|ƒƒS(	sˆReturn a list of log file paths from the configuration dictionary.

    @param cfg: The cloud-init merged configuration dictionary.
    tdef_log_files (?P<type>\||>+)\s*(?P<target>.*)Rittees-aiN(
RER7R)RßRLRDRRR!RÖR2RµRë(RNtlogstdefault_logtfmtRRtparts((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_config_logfilesäs&cGsT|r|j||Œntjƒ}|dkr:d}n|j|d||ŒdS(Ntexc_info(NNN(R4RþRMRDRŸ(RR»R¯RM((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR¬þs	cCsMtj|ƒ}|jt|ƒƒ|jƒ}|dk	rE|d|!S|SdS(Ni(thashlibtnewtupdateRTt	hexdigestRD(RNtroutinetmlenthashertdigest((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt	hash_blobscCs0ytj|ƒrtSWntk
r+tSXdS(N(R7R8RR=R”(R((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_users

cCs0ytj|ƒrtSWntk
r+tSXdS(N(R:R;RR=R”(R((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_group#s

cCs'tjd||ƒtj||ƒdS(NsRenaming %s to %s(R3RŸRItrename(tsrctdest((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRY+siícCs"x|D]}t||ƒqWdS(N(t
ensure_dir(tdirlistROR®((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytensure_dirs1s
cCsutjt|ƒƒ}t|t|ƒƒsqdjg|D]}t|ƒ^q7ƒ}td|t|ƒfƒ‚n|S(Ns, s((%s) root types expected, got %s instead(	tjsontloadsRPREttupleR5R™R^ttype(RSt
root_typesRWtttexpected_types((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt	load_json6s(cCs?ydjt|ƒƒSWn!tk
r:djt|ƒƒSXdS(s1Handler for types which aren't json serializable.s
ci-b64:{0}s)Warning: redacted unserializable type {0}N(RˆRZtAttributeErrorRb(t_obj((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytjson_serialize_default?s
cCs}tj|ƒ}xg|jƒD]Y\}}t|tƒrJt|ƒ||<nt|tƒrdjt|ƒƒ||<qqW|S(sPreserialize any discovered binary values to avoid json.dumps issues.

    Used only on python 2.7 where default type handling is not honored for
    failure to encode binary data. LP: #1801364.
    TODO(Drop this function when py2.7 support is dropped from cloud-init)
    s
ci-b64:{0}(	tobj_copytdeepcopyRÝRER7tjson_preserialize_binaryRYRˆRZ(R9Rtvalue((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRlGs c
Cspy)tj|dddtdddtƒSWn@tk
rktjd dkret|ƒ}tj|ƒS‚nXd
S(
s%Return data in nicely formatted json.R‹it	sort_keyst
separatorsR+s: RÎiiN(R+s: (ii(R_tdumpsRRiRURþtversion_infoRl(R9((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
json_dumpsWs

cCsetjj|ƒsTttjj|ƒdtƒtj|ƒWdQXt||ƒn
t||ƒdS(NR’(RIRJRŽRŽtdirnameRtmakedirstchmod(RJRO((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR\ds
ccs0z	|VWd|r+d|g}t|ƒnXdS(Ntumount(R(Rvt
umount_cmd((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt	unmounteros
	cCswi}yFtjjdƒr6tdƒjƒ}d}n$tdƒ\}}|jƒ}d}d}xÕ|D]Í}y|dkr|jƒ\}}}	}
}}nNtj||ƒ}
|
j	dƒ}|
j	dƒ}|
j	dƒ}	|
j	dƒ}
Wnt
k
rqgnX|jd	d
ƒ}i|	d6|d6|
d
6||<qgWtj
d||ƒWn$ttfk
rrttdƒnX|S(Ns/proc/mountsRftmounts*^(/dev/[\S]+) on (/.*) \((.+), .+, (.+)\)$iiiis\040R†tfstypet
mountpointtoptssFetched %s mounts from %ssFailed fetching mount points(RIRJRRÐR/RRÖRtsearchR!R«RˆR3RŸR‚RžR¬(tmountedt
mount_locstmethodtmountoutputRtmountretmplineRtmpRzR|t_freqt_passnotm((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytmountsys:	
!
cCs±t|tƒr|g}nWt|ttfƒr?t|ƒ}n3|dkrTd}ntdjdt|ƒƒƒ‚tj	ƒj
ƒ}|dkr«|dkrdg}qno|jdƒr|dkrØdddg}nx?t|ƒD]%\}}|d	kråd||<qåqåWn	d
g}t
ƒ}tjƒ|}	t}
tjj|ƒ|krm|tjj|ƒd}nÝd}x²|D]ª}d}yfdd
dg}
|r´|
jd|gƒn|
j|ƒ|
j|	ƒt|
d|ƒ|	}
|	}PWqzttfk
r#}tjd|||ƒ|}qzXqzW|sJtd||	|fƒ‚n|jdƒsf|d7}nt|
ƒ3|dkrŽ||ƒ}n|||ƒ}|SWdQXWdQXdS(s2
    Mount the device, call method 'callback' passing the directory
    in which it was mounted, then unmount.  Return whatever 'callback'
    returned.  If data != None, also pass data to callback.

    mtype is a filesystem type.  it may be a list, string (a single fsname)
    or a list of fsnames.
    s6Unsupported type provided for mtype parameter: {_type}t_typeR7tautotbsdtufstcd9660tvfattiso9660RCR{Rys-otros-tt
update_envs Failed mount of '%s' as '%s': %ss#Failed mounting %s to %s due to: %sRAN(RER™RµRaRDR^RˆRbR*R4R·RÆt	enumerateRˆR	ttempdirR”RIRJR—R×RßRR‚RžR3RŸR§Rx(RtcallbackR9tmtypetupdate_env_for_mounttmtypestplatsystindexR~ttmpdRvR{tfailure_reasontmountcmdtexcR((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytmount_cb¡sh				


	


cCs
tjtƒS(N(RjRkR
(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_builtin_cfgìscCs tjd|ƒtjj|ƒS(NsTesting if a link exists for %s(R3RŸRIRJtislink(RJ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_linkñscCsLtjd||ƒ|r8tjj|ƒr8t|ƒntj||ƒdS(Ns$Creating symbolic link from %r => %r(R3RŸRIRJRtdel_filetsymlink(RVtlinktforce((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytsym_linkös
cCsStjd|ƒytj|ƒWn+tk
rN}|jtkrO|‚qOnXdS(NsAttempting to remove %s(R3RŸRItunlinkRžRR(RJR¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR¢ýscCs'tjd||ƒtj||ƒdS(NsCopying %s to %s(R3RŸR‹tcopy(RZR[((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR¨scCs:ytjdtjƒƒ}Wntk
r5d}nX|S(Ns%a, %d %b %Y %H:%M:%S %zs??(ttimetstrftimetgmtimeR«(tts((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyttime_rfc2822s

cCsd}d}yÍtjjdƒrOd}tdƒ}|rØ|jƒd}qØn‰d}tjdƒ}tjƒ}tjƒ}tj	|ƒ|_
|jdtj|ƒtj|ƒddƒtjƒ}|j
}||}Wn"tk
rýttd|ƒnX|S(	Ns??R6s/proc/uptimeitctypess/lib/libc.so.7s
kern.boottimes&Unable to read uptime using method: %s(RIRJRRÐRÖR®tCDLLtc_size_ttc_inttsizeofRmtsysctlbynametbyrefRDR©R«R¬R3(t
uptime_strR€RÀtlibcR‡Rëtnowtbootup((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytuptimes*	
cCst||ddddƒdS(NtomodeRURO(t
write_fileRD(RJtcontent((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytappend_file-si¤cCs t|ddddd|ƒdS(NR¼RCRºRURO(R»(RJRO((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytensure_file1scCs-yt|ƒSWnttfk
r(dSXdS(N(RRHR^RD(tpossible_int((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytsafe_int5scCsBt|ƒ}|r>|r>t|ƒtj||ƒWdQXndS(N(RÀRŽRIRu(RJROt	real_mode((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRu<s
RVc	
Cs5|rBy%tj|ƒ}tj|jƒ}WqBtk
r>qBXnttjj|ƒƒd|jƒkrt	|ƒ}d}nt
|ƒ}d}yd|}Wntk
r¼d|}nXtj
d|||t|ƒ|ƒtd|ƒ4t||ƒ}|j|ƒ|jƒWdQXWdQXt||ƒdS(	sv
    Writes a file with the given content and sets the file mode as specified.
    Restores the SELinux context if possible.

    @param filename: The full path of the file to write.
    @param content: The content to write to the file.
    @param mode: The filesystem mode to set on the file.
    @param omode: The open mode used when opening the file (w, wb, a, etc.)
    tbRYt
characterss%os%rsWriting to %s - %s: [%s] %s %sRJN(RIRœtS_IMODEtst_modeRžR\RJRsR·RTRPR^R3RŸR2RŽRRÿRRu(	RæR¼RORºt	copy_modet	file_statt
write_typetmode_rtfh((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR»Cs.
	
	
cCs\xUtj|ƒD]D}tjj||ƒ}tjj|ƒrJt|ƒqt|ƒqWdS(s™
    Deletes all contents of a directory without deleting the directory itself.

    @param dirname: The directory whose contents should be deleted.
    N(RIRRJR5RŽRR¢(Rstnodet
node_fullpath((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytdelete_dir_contentsis

c
OsÞ|jddƒ}t|ƒdkr?d|kr?tƒg}ntjdtƒ‡}tjj||ƒ}d|kr“|gt	|dƒ|d<n!t	|ƒ}|g|d|d<t
||ddƒt||ŽSWdQXdS(	sWrite blob to a tempfile, and call subp with args, kwargs. Then cleanup.

    'basename' as a kwarg allows providing the basename for the file.
    The 'args' argument to subp will be updated with the full path to the
    filename as the first argument.
    R÷t	subp_blobiR¯t	needs_exeROiÀN(tpopR2RaR	R“RRIRJR5RµR»R(RNR¯R°R÷Ršttmpf((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytsubp_blob_in_tempfilewsRˆcsØ|	dk	rtdƒ‚n|dkr3dg}nd}|
rs|dkrWtj}n|jƒ}|j|
ƒnt|	ƒdkržd|	gt|ƒ}n|rát|tƒrÂdj	|ƒn|}
|dj
d|
ƒƒn|stjd||||rd	n|ƒntjd
|ƒd}d}d}|rLt
j}t
j}n|rgt
j}t
j}n|dkr‹ttjƒ}|}n't
j}t|tƒs²|jƒ}nt|tjƒrÍ|}n^t|tjƒrñ|jdƒ}n:g|D]-}t|tjƒr|n|jdƒ^qø}zµyFt
j|d|d
|d|d|d|ƒ}|j|ƒ\}}Wnhtk
rÞ}|r™|dƒntd|d|d|jdˆrÀdndd
ˆrÒdndƒ‚nXWd|rö|jƒnX|s|r$|sd}n|s$d}q$nˆrWd‡fd†}||ƒ}||ƒ}n|j}||kr¯|r‹|dj
d|ƒƒntd|d
|d|d|ƒ‚n|rÎ|dj
d|ƒƒn||fS(sØRun a subprocess.

    :param args: command to run in a list. [cmd, arg1, arg2...]
    :param data: input to the command, made available on its stdin.
    :param rcs:
        a list of allowed return codes.  If subprocess exits with a value not
        in this list, a ProcessExecutionError will be raised.  By default,
        data is returned as a string.  See 'decode' parameter.
    :param env: a dictionary for the command's environment.
    :param capture:
        boolean indicating if output should be captured.  If True, then stderr
        and stdout will be returned.  If False, they will not be redirected.
    :param combine_capture:
        boolean indicating if stderr should be redirected to stdout. When True,
        interleaved stderr and stdout will be returned as the first element of
        a tuple, the second will be empty string or bytes (per decode).
        if combine_capture is True, then output is captured independent of
        the value of capture.
    :param shell: boolean indicating if this should be run with a shell.
    :param logstring:
        the command will be logged to DEBUG.  If it contains info that should
        not be logged, then logstring will be logged instead.
    :param decode:
        if False, no decoding will be done and returned stdout and stderr will
        be bytes.  Other allowed values are 'strict', 'ignore', and 'replace'.
        These values are passed through to bytes().decode() as the 'errors'
        parameter.  There is no support for decoding to other than utf-8.
    :param target:
        not supported, kwarg present only to make function signature similar
        to curtin's subp.
    :param update_env:
        update the enviornment for this command with this dictionary.
        this will not affect the current processes os.environ.
    :param status_cb:
        call this fuction with a single string argument before starting
        and after finishing.

    :return
        if not capturing, return is (None, None)
        if capturing, stdout and stderr are returned.
            if decode:
                entries in tuple will be python2 unicode or python3 string
            if not decode:
                entries in tuple will be python2 string or python3 bytes
    s&target arg not supported by cloud-initiRAtchrootR†sBegin run command: {command}
tcommandsFRunning command %s with allowed return codes %s (shell=%s, capture=%s)tcombinesFRunning hidden command to protect sensitive input/output logstring: %ssutf-8RyRzRYtenvRXs1ERROR: End run command: invalid command provided
RwR{RRvNRCcs#t|tƒs|S|j|ˆƒS(N(RERYRM(R9R‡(RM(s2/usr/lib/python2.7/site-packages/cloudinit/util.pytldecodess%ERROR: End run command: exit({code})
RžRxsEnd run command: exit({code})
(RDRHRIRZR¨RPRBRµRER5RˆR3RŸR[R]tSTDOUTRRRYRRRFRQRGR\tcommunicateRžR6Rtcloset
returncode(R¯R9RRÖRtcombine_captureRXt	logstringRMRR‘t	status_cbt
devnull_fpRÔRYRyRzt
bytes_argsRtspR R?R¥R×trc((RMs2/usr/lib/python2.7/site-packages/cloudinit/util.pyRs˜4$							7
		RåtcreatedcCsGtjƒ}t|ƒ}|d|jƒ|f7}|dtƒ7}|S(Ns %s by cloud-init v. %ss on %s(Rtversion_stringR™ttitleR(tcomment_charR tci_vertheader((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytmake_header*s
cGstjjtjj|ŒƒS(N(RIRJRKR5(R«((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytabs_join2scCsEt|ttfƒs1tdtj|ƒƒ‚nd}|rJ|d7}ndd}d}xÔ|D]Ì}t|ttfƒrßg}x4|D],}|jdtj|ƒj	d|ƒƒq‰Wd	|d
j
|ƒf}|d7}qat|tjƒrd	||f}|d7}qatdtj|ƒ|fƒ‚qaWtj
d
|ƒ|S(Ns8Input to shellify was type '%s'. Expected list or tuple.RCs
#!/bin/sh
s%s%s%s%st's\is'%s's%s%s
R†isCUnable to shellify type '%s'. Expected list, string, tuple. Got: %ssShellified %s commands.(Rës\RëRë(RERaRµR^R
RRßRFR¶RˆR5RGR3RŸ(tcmdlistt
add_headerR¼tescapedt	cmds_madeR¯tfixedR((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytshellify:s0


*

cCsU|r(|j|ƒr(|t|ƒ}n|rQ|j|ƒrQ|t|ƒ }n|S(N(RLR2RÆ(R:R˜tsuffix((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytstrip_prefix_suffixZs
cCs5x:tD]2}yt|ƒtSWqttfk
r8qXqWy0tdƒ}d|kr\tSd|krltSWnttfk
r†nXtjjdƒr°tjjdƒr°tSygt	dƒj
ƒ}xN|D]F}|jdƒrÌ|jƒj
ddƒ\}}|d	krtSqÌqÌWWnttfk
r0nXtS(
sH
    Checks to see if this code running in a container of some sort
    it	containertLIBVIRT_LXC_UUIDs/proc/vzs/proc/bcs/proc/self/statussVxID:R*R(tCONTAINER_TESTSRRR‚Ržtget_proc_envRIRJRŽRÐR/RLRRÖR”(thelpertpid1envtlinesR:t_keyR<((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR,bs4
%
cCstjjdƒS(s2Check to see if we are running in a lxd container.s
/dev/lxd/sock(RIRJR(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_lxdscCsÝtjjdt|ƒdƒ}yt|dtƒ}Wnttfk
rNiSXi}d\}}|rˆd\}}|j||ƒ}nxN|j	|ƒD]=}|sªq˜n|j	|dƒ\}	}
|	r˜|
||	<q˜q˜W|S(	sH
    Return the environment in a dict that a given process id was started with.

    @param encoding: if true, then decoding will be done with
                     .decode(encoding, errors) and text will be returned.
                     if false then binary will be returned.
    @param errors:   only used if encoding is true.s/procRZRMR+t=i(sRý(sRý(
RIRJR5R™RÐR”R‚RžRMRÖ(tpidROterrorsRàRÀRÖtnulltequalRJRR<((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR÷”s"cCsgi}xZ|jƒD]L}y|jddƒ\}}Wntk
rT|}t}nX|||<qW|S(NRýi(RÖRHR(tkvstringRRJRR<((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytkeyval_str_to_dict²s

cCs0|jdƒr|d}ntjjd|ƒS(Ns/dev/is/sys/class/block/%s/partition(RLRIRJRö(R((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_partition¾s
cCsüt|tƒs|g}ng}xÔ|D]Ì}t|tjƒrS|j|ƒq(nt|ttfƒrèt|ƒdksŒt|ƒdkr›tdƒ‚nt|ƒdkrÔ|drÔ|j|t|ƒƒq(n|j|dƒq(tdƒ‚q(W|S(Niis Invalid package & version tuple.isInvalid package type.(RERµRFRGRßRaR2R’(tversion_fmttpkgstpkglisttpkg((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytexpand_package_listÅs 

$cCsIg|jdƒD]}|r|^q}d}d}d}d}	x²t|ƒD]¤\}
}|jƒ}t|ƒdkr›|jd|
dt|ƒ|ƒdS|d}
g|
jdƒD]}|rµ|^qµ}t|ƒt|ƒkrëqMntt|ƒt|ƒƒ}|d|!|d|!kr&qMn|	dk	rPt|	ƒt|ƒkrPqMny|jdƒ}
Wn)tk
rŽ|jd|
d|ƒdSXy ||
d}||
d	}Wn)tk
rÚ|jd
|
d|ƒdSX|
}|}	|d}qMW|r&|rE|rE|rE|rE||||fSn|rE|rE|rE|||fSdS(
sRReturn the mount information for PATH given the lines from
    /proc/$$/mountinfo.RAi
s$Line %d has two few columns (%d): %siiiRvs,Did not find column named '-' in line %d: %sis/Too few columns after '-' column in line %d: %siN(	RÖRDR’R2RŸtminR™RHt
IndexError(RJtmountinfo_linesRtget_mnt_optsR¥t
path_elementstdevpthtfs_typetmatch_mount_pointtmatch_mount_point_elementsR%R:RKtmount_pointtmount_point_elementsRt
mount_options((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytparse_mount_infoàsV(	
(
	
	
cCsSxLtdƒjƒD]8}|jƒd \}}}||kr|||fSqWdS(s<On older kernels there's no /proc/$$/mountinfo, so use mtab.s	/etc/mtabiN(RÐR/RÖRD(RJR:RRR((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
parse_mtab*	s
cCsÒ|jdƒ}t|ƒdkr)|dS|ddkr¾|d}tdd	d
gƒ\}}xS|jdƒD]B}|jƒ}t|ƒdkrn|d|krn|d}PqnqnWt|ƒStjd
|ƒdS(NRAiitlabeltgptRŒitglabeltstatuss-ss
is)Unexpected input in find_freebsd_part: %s(RRsufs(RÖR2RR™R3R4(tfstsplittedttarget_labelRaRtlabelsRÝ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytfind_freebsd_part3	s
"

cCsfd}xY|jdƒD]H}|jƒ}t|ƒdkrtjj|d|ƒr|}PqqW|S(Ns
ii(RDRÖR2RIRJR(RJtmnt_listt
path_foundR:RÝ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_path_dev_freebsdD	s,cCs¨tdd|gdddgƒ\}}t|ƒrstddgƒ\}}t||ƒ}|dkrjdS|}n|jƒ}t|dƒ}d||d|dfS(NRys-pRiis/dev/i(RR2R#RDRÖR (RJR÷R?R!R"Rt
label_part((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_mount_info_freebsdN	s'	cCsñtjjdƒs#tjdƒdSytdd|gƒ\}}Wn'tk
rk}tjd||ƒdSXt	|ƒr|dSd}xh|j
dƒD]W}tj||ƒr’||kr’d|kr’|j
ƒd	}tjd
||ƒ|Sq’WdS(Ns/dev/zfss"Cannot get zpool info, no /dev/zfstzpoolRs$Unable to get zpool status of %s: %ss.*(ONLINE).*s
tstateisfound zpool "%s" on disk %s(
RIRJRR3RŸRDRR6R4R2RÖRR}(R&tzpoolstatusR?RÇR:tdisk((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_device_info_from_zpool\	s 
*cCstdgƒ\}}|jƒ}d}xÞ|D]Ö}tj||ƒ}|sRq.n|jdƒ}|jdƒ}|jdƒ}	|	dkr|jdƒ}	ntjd|||	ƒtjd|ƒ}
|
rëtƒrë|	d	krët	|ƒS||kr.||	|fSq.WdS(
NRysH^(/dev/[\S]+|.*zroot\S*?) on (/[\S]*) (?=(?:type)[\s]+([\S]+)|\(([^,]*))iiiis?found line in mount -> devpth: %s, mount_point: %s, fs_type: %ss^(/dev/.+)p([0-9])$tzfs(
RR/RR}R!RDR3RŸRR%(RJRRRtregexR:R‡RRRtdevm((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytparse_mountp	s(
	

cCsqdtjƒ}tjj|ƒrGt|ƒjƒ}t||||ƒStjjdƒrct|ƒSt|ƒSdS(Ns/proc/%s/mountinfos	/etc/mtab(	RItgetpidRJRRÐR/RRR.(RJRR
tmountinfo_pathRú((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_mount_info“	s
cCs%tjj|ƒo$tj|tjƒS(N(RIRJRöRR‘(tfpath((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_exeº	scCs1t|ƒ}tjj|kr:tt||ƒƒr:|Sn|dkrÃgtjjddƒjtj	ƒD]}|j
dƒ^qh}|dkr˜|}qÃg|D]}|jdƒrŸ|^qŸ}ng|D]}tjj|ƒ^qÊ}xB|D]:}tjjj
||fƒ}tt||ƒƒrï|SqïWdS(NtPATHRCt"RA(RBRIRJtsepR3RDRZR)RÖtpathsepRRLRKR5(tprogramR}RtpR«RJtppath((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytwhich¿	s :	+%
cCs:|dkrg}n|dkr*i}ntjƒ}d}|rlyttƒƒ}Wqltk
rhqlXnz|||Ž}Wdtjƒ|}	d}
|dk	rÒyttƒƒ|}
WqÒtk
rÎqÒXnd|	}|rt|
tƒr|d|
7}q|d7}ny|||ƒWntk
r4nXX|S(Ns took %0.3f secondss (%0.2f)s (N/A)(RDR©tfloatR¹RHRER«(RR»RR¯R°t
get_uptimetstarttustartRtdeltatudeltattmsg((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRÜ	s<		




cCs6|jddƒ}t|ƒdkr(|S|dfSdS(NRôi(trsplitR2RD(tdottedR
((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytexpand_dotted_devname
scCsî|dkrg}n|dkr*g}ng}i}x||D]u}y(t|||dtdtƒ||<WqAtk
rµ}|jtkr–‚n||kr¶|j|ƒq¶qAXqAWt|ƒrêtdj	ddj
|ƒƒƒ‚n|S(NRêRMsMissing required files: {files}tfilesR+(RDRÐR”R‚RRRßR2RHRˆR5(R trequiredtoptionaltdelimR>RRR¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytpathprefix2dict
s$		(!s
/proc/meminfoc	Csõidd6dd6dd6dd	6}id
d6dd
6dd6}i}x«t|ƒjƒD]—}y|jƒ\}}}Wn)tk
r |jƒ\}}d}nX|rÂt|ƒ||||<qV||krVt|ƒ|||||<qVqVW|S(Nii
tkBitmBitBitgBttotals	MemTotal:tfreesMemFree:t	availables
MemAvailable:iii@(RÐR/RÖRHR(	tmeminfotrawtmplierstkmapRR:RRmtunit((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytread_meminfo%
s"


#cCsù|}|jdƒr"|d }nidd6dd6dd6dd
6dd6}|}d}x:|D]2}|j|ƒr^|}|d
t|ƒ!}q^q^Wyt|ƒ}Wn!tk
rÇtd|ƒ‚nX|d
krçtd|ƒ‚nt|||ƒS(sbConvert human string or integer to size in bytes
      10M => 10485760
      .5G => 536870912
    RMiÿÿÿÿiii
tKitMitGi(tTis'%s' is not valid input.s'%s': cannot be negativeiii@I(RÆR2R<RHR(R‡tsize_inRTtnumtmplierR‡((s2/usr/lib/python2.7/site-packages/cloudinit/util.pythuman2bytes:
s"
)

cCs|tkrd
St|}djt|ƒ}tjd|ƒy©tjj|ƒsetjd|ƒd
St	|dt
ƒ}|s‘tjd|ƒd
S|dt|ƒddkr¸d	}n|jd
ƒj
ƒ}tjd||ƒ|SWn"tk
r	ttd|ƒd
SXd
S(s4
    Reads dmi data with from /sys/class/dmi/id
    s{0}/{1}squerying dmi data %ssdid not find %sRMs%s did not return any datasÿis
RCtutf8sdmi data %s returned %ssfailed read of %sN(tDMIDECODE_TO_DMI_SYS_MAPPINGRDRˆtDMI_SYS_PATHR3RŸRIRJRRÐR”R2RMRR«R¬(Rt
mapped_keytdmi_key_pathtkey_datatstr_data((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt_read_dmi_syspathW
s*
	
cCs˜yd|d|g}t|ƒ\}}|jƒ}tjd||ƒ|jddƒdkr_dS|SWn-ttfk
r“}tjd||ƒdSXdS(s
    Calls out to dmidecode to get the data out. This is mostly for supporting
    OS's without /sys/class/dmi/id support.
    s--strings dmidecode returned '%s' for '%s'RôRCsfailed dmidecode cmd: %s
%sN(RRR3RŸRˆR‚RžRD(Rtdmidecode_pathRwR÷RR¥((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt_call_dmidecodex
scCsO|dkrtjƒd}n|dkpH|ddkoH|ddk}|S(s$Return True if platform is x86-baseditx86_64iR%it86N(RDRIR'(t
uname_archtx86_arch_match((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytis_x86Š
s
 cCs¤tƒr
dSt|ƒ}|dk	r)|Stjƒd}t|ƒpZ|dkpZ|dksqtjd|ƒdStdƒ}|rt	||ƒStj
dtƒdS(sˆ
    Wrapper for reading DMI data.

    If running in a container return None.  This is because DMI data is
    assumed to be not useful in a container as it does not represent the
    container but rather the host.

    This will do the following (returning the first that produces a
    result):
        1) Use a mapping to translate `key` from dmidecode naming to
           sysfs naming and look in /sys/class/dmi/... for a value.
        2) Use `key` as a sysfs key directly and look in /sys/class/dmi/...
        3) Fall-back to passing `key` to `dmidecode --string`.

    If all of the above fail to find a value, None will be returned.
    itaarch64tamd64sdmidata is not supported on %st	dmidecodes0did not find either path %s or dmidecode commandN(R,RDRgRIR'RnR3RŸR;RiR4Rb(Rt
syspath_valueRlRh((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
read_dmi_data”
s"	
	cCs6tjd dkr)tjtj|ƒƒStj|ƒS(Nii(ii(RþRqtemailtmessage_from_fileRFtStringIOtmessage_from_string(RÀ((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyRw¾
scCs»tddgd|dtƒ\}}tƒ}x‡|jƒD]y}y|jddƒ\}}}Wntk
ruq:nX|jdƒs”|jdƒr:|jt	j
dd	|ƒƒq:q:W|S(
Ns
dpkg-querys--listRRithitiis:.*RC(RRRëR/RÖRDRHRLRðRtsub(RR Rt	pkgs_instR:R'R((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytget_installed_packagesÄ
s$	
#cCsÈd}y>tt|dtƒƒ}|jddƒjƒdkrCtSWn&tk
rl}tjd||ƒnXtƒ}d|kr†tStddtƒ}d|jƒkr®tSt	j
jd	ƒrÄtStS(
Ns/etc/os-releaseRêRRCsubuntu-cores!Unexpected error loading '%s': %ss
snap_core=s/etc/system-image/channel.inis/etc/system-image/config.d/(
R(RÐRR)R·RHR3R4RÓRIRJRŽR”(torpathtorinfoR¥RÏR¼((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytsystem_is_snappyÓ
s 	cCs>g}x(|jtƒD]}|j||ƒqWdj|ƒS(sBreplacement for indent from textwrap that is not available in 2.7.RC(R/RRßR5(RSR˜RúR:((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR‹ë
scCs
d}x1|jƒD]#}|jdƒr|d}PqqW|dkrJdS|jdƒr]|S|jdƒr~d|tdƒS|jdƒr¥d|tdƒjƒS|jdƒrd	|tdƒjƒ}tjj|ƒrä|St|ƒ}|rþ|d
S|Sd|S(Nsroot=is/dev/sLABEL=s/dev/disk/by-label/sUUID=s/dev/disk/by-uuid/s	PARTUUID=s/dev/disk/by-partuuid/i(	RDRÖRLR2R·RIRJRR(RÏR1RJt
disks_pathtresults((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytrootdev_from_cmdlineó
s.
cCsjd„}i}xT||ƒD]F}|jddƒ\}}|sI|}n|sU|r|||<qqW|S(sðGiven shell like syntax (key=value
key2=value2
) in content
       return the data in dictionary form.  If 'add_empty' is True
       then add entries in to the returned dictionary for 'VAR='
       variables.  Set their value to empty_val.cSstj|dtƒS(Ntcomments(tshlexRÖR(RN((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt_shlex_splitsRýi(RÖ(R¼t	add_emptyt	empty_valR…R9R:RRm((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyR(s		gà?cCsêt|ƒ}d}x»trÏ|tg|D]}tjj|ƒr(|^q(ƒ8}t|ƒdkr|tjd|||ƒgS|dkr¡tjd|||ƒn|||krµPntj	|ƒ||7}qWtjd|||ƒ|S(Nis)%sAll files appeared after %s seconds: %ss6%sWaiting up to %s seconds for the following files: %ss*%sStill missing files after %s seconds: %s(
RëRRIRJRR2R3RŸR©tsleep(tflisttmaxwaittnaplentlog_pretneedtwaitedR((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytwait_for_files%s$	5	
	
	
cCs3t|dtƒ}|djdƒ}|ddkS(s1Check whether the given mount point is mounted rwR
iÿÿÿÿR+itrw(R1RRÖ(RR÷t
mount_opts((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytmount_is_read_write;scCsfddg}|r?tjj|ƒr(dS|jd|gƒn|r\|jd|gƒnt|ƒS(sAInvoke udevadm settle with optional exists and timeout parameterstudevadmtsettleNs--exit-if-exists=%ss--timeout=%s(RIRJRR×R(RR¢t
settle_cmd((s2/usr/lib/python2.7/site-packages/cloudinit/util.pytudevadm_settleBscCsxd}ytd|dtƒ}Wn&tk
rH}tjd||ƒnX|rt|jddƒ}t|dƒ}n|S(s-
    Return the parent pid of a process.
    is
/proc/%s/statRês Failed to load /proc/%s/stat. %sR†ii(RÐRR‚R3R4RÖR(RþtppidRÀR¥RK((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt
get_proc_ppidPs(RRRsyes(RRRR(×RåR¨RjR®RtRõR:RçRNR_RItos.pathR*R7R¾RR„R‹RìRœRÀR[RþR©RRRtbase64RRtsix.moves.urllibRRgRFt	cloudinitRRtloggingRRR	R
RRtcloudinit.settingsR
t	functoolsRR‘RDRêt	getLoggerRŒR3R6RÜRÂRÁRÞR´R»RöR!R@R)RBRPRTRXRZRdRbRaR‚R6tobjectRŽR«R§R¨R²RºR¼R½RÉRÍRÑRÕRÓRâRRíRóRütDEBUGRRRR”RRRR"R3RRGRKRRRMRqR|tcontextmanagerR~RRŠRR›R¥R¯R7RÏRœRÊRÎRÑRÐRÞRäRèRþRâRRR
RRRR"RØRÐR-RÓR'R6R?RLRLR¬RVRWRXRYR^RfRiRlRrR\RxRˆRžRŸR¡R¦R¢RR¹R½R¾RÀRuR»RÍRÒRRéRêRñRóR,RüR÷RRR	RRR R#R%R*R.R1R3R;RRERJRJRWR_RgRiRnRsRwR|RR‹R‚R(RR’R–R˜(((s2/usr/lib/python2.7/site-packages/cloudinit/util.pyt<module>s¸


	
		
U*	
	
			
				4"	3
			# "			(	,					3		
		:									

	(J										&		—	 	-				J				
			#'	'			!	
	*
Back to Directory File Manager