x[hl SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKJrJr SSK J!r! SSK"J#r# SSK$J%r% SSK&J'r' SS K(J)r)J*r*J+r+J,r,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5J6r6 SS K7J8r8 SSK9r9SS K:J;r;Jr>J?r?J@r@JArAJBrBJCrCJDrDJErE SS KFJGrG SS KHJIrIJJrJ \*(aSSKKJLrL SqM\ R"\O5rP\ RS0rRS\R-\R-rUSrVSrWSrX\#"5S5rY\#"5S5rZSS\5\[\\4S\[4Sjjr]SS\5\[\\4S\\4Sjjr^\?R"S5S\\S\\4Sj5r`Sra"SS 5rb"S!S"\c5rd"S#S$\c5reS%rfSS&jrgSS'jrhSS(jriSS)jrjSS*jrkSS+.S\.4S,jjrlS-rmS.rnS/roSS1jrpS2rqS3\[S\r4S4jrs\#"5S55rt\#"5S65ru\#"5S75rv\#"5S85rw\#"5S95rx\#"5S:5rySS<jrzSS=jr{SS>jr|SS?jr}\#"5S@5r~SAr\#"5SB5rSSCjrSSDjrSErSSFjrSSG\4\1S\r4SHjjr\R<SI5r\R<SJ5rSKrSLrSSMjrSSNjrS\r44SOjrSSPjrSS+.S\r4SQjjrSS+.S\r4SRjjrSSSjrSSTjrSUr"SVSW\25rSSXjrSSYjr\?R"SZ5S\4S[j5rS\rS]rS^rS_rSS`jrSSajrSSbjrSScjrSSdjrSSejrSfrSS;Sg.Sh\5\[\ GRF4Si\3\,\/S4Sj\S\\4SkjjrSS;Sg.Sh\5\[\ GRF4Si\3\,\/S4Sj\S\[4Sljjr\#"5Sm5rSnrS\4SojrSSpjrSSqjrSSrjrSs\.\[\+4St\3\[S\0\3\[4SujrSs\.\[\+44SvjrSSw\[S\[4SxjjrSyrSzrS{rSS|jr\?R"S}5\r44S~j5rSrSSjr\R<S5rSrSSjrSrSrSSjrSrSrSr\#"5S5rSrSrSS;S.St\S\SS4SjjjrSrSrS\[S\4SjrS\[S\4SjrS\[S\[4SjrS\[S\[4SjrS\[S\0\[4Sjr\?R"S5SS0SSS.S\S\4Sjjj5rSrSSjrSSjrSSjrSrSrSrSr\#"5S5rSrSS\[S\[S\.\[\[44SjjrSrSrSr\PS;4SjrSrSrSrSrSSjr\PS;4SjrS\[S\4SjrSrSS\ GRR4SjrSSjrSrSSjrSrSrSrSrSSjrSSjrSrSrSSjrSSS\r4Sjr\S\/S\+S44Sj5rg)N) b64decode)deque)contextmanagersuppress)ENOENT) lru_cache)Path) ModuleType)IO TYPE_CHECKINGAnyCallableDequeDict GeneratorListMapping NamedTupleOptionalSequenceUnioncast)parse) featuresimportermergersnet performancesettingssubp temp_utils type_utils url_helperversion)logexc) CFG_BUILTINPER_ONCE)Paths_z_-.())true1onyes)off0nofalsec[[[[R"5R R S5SS55$)N.)tuplemapintosunamereleasesplit0/usr/lib/python3/dist-packages/cloudinit/util.pykernel_versionr?`s2 S"((*,,2237;< ==r=cd[R"SS/SS9nURR5$)zReturn the sanitized string output by `dpkg --print-architecture`. N.B. This function is wrapped in functools.lru_cache, so repeated calls won't shell out every time. dpkgz--print-architectureTcapture)r stdoutstrip)outs r>get_dpkg_architecturerGds- ))V34d CC ::   r=cJSSSSS.n0n[R"SS/SS 9nURR5H3nURS 5upEnX@;dMUR 5XU'M5 UR 5Vs/sH owU;dM UPM nnU(a%[ RS S RU55 U$s snf![RaAn [ RS U 5 [SUR 555nSn A U$Sn A ff=f)Ncodename descriptionidr:)Codename DescriptionzDistributor IDRelease lsb_releasez--allTrB:z.Missing fields in lsb_release --all output: %s,z#Unable to get lsb_release --all: %sc3(# UHoS4v M g7f) UNAVAILABLENr<).0vs r> lsb_release..s> 1 & s) r rD splitlines partitionrEvaluesLOGwarningjoinProcessExecutionErrordict) fmapdatarFlinefnamer)valkmissingerrs r>rOrOos$  D D?ii0$?JJ))+D NN3/MEc}$'IIK%[!,#kkm=m}1m=  KK@!  K>  % %? 93?> >> K ?s6A C +C  CC.C C D"!6DD"blobreturncN[U[5(aU$URUS9$N)encoding) isinstancestrdecode)rhrls r> decode_binaryrps$dC((4Ldkk8k.LLr=textcN[U[5(aU$URUS9$rk)rmbytesencode)rqrls r> encode_textrus$dE**4N X 0NNr=zBase64 decodingrac[U[5(d[S[U5-5e[ USS9$![ R a Us$f=f)zbase64 decode data If data is base64 encoded bytes, return b64decode(data). If not, return data unmodified. @param data: data as bytes. TypeError is raised if not bytes. zdata is '%s', expected bytesT)validate)rmrs TypeErrortyperbinasciiError)ras r>maybe_b64decoder|sP dE " "6dCDD-- >> s 8AAcURSS9nUR5S:Xa^[U[5(aIUR 5nU(aUR (a UR nOSnUR US5$U$)NT)rorqutf-8surrogateescape) get_payloadget_content_maintypermrs get_charset input_codecro)part cte_payloadcharsetrls r>fully_decoded_payloadrs~ ""$"/K   "f,U22""$ w****HH!!(,=>> r=c*\rSrSrSSjrSrSrSrg) SeLinuxGuardcU [R"S5UlXlX lg![a SUlN f=f)Nselinux)r import_moduler ImportErrorpath recursive)selfrrs r>__init__SeLinuxGuard.__init__sB  #11) __enter__SeLinuxGuard.__enter__s! <__exit__SeLinuxGuard.__exit__s||4<<#B#B#D#D wwtyy)) ww * HHTNE LL % %d$,,,? @ :  NN   LL # #DNN # C     KK>    s+ AD/#D# D D # E-"EE)rrrNF)__name__ __module__ __qualname____firstlineno__rrr__static_attributes__r<r=r>rrs # r=rc\rSrSrSrg)MountFailedErrorr<Nrrrrrr<r=r>rrr=rc\rSrSrSrg)DecompressionErrorr<Nrr<r=r>rrrr=rcf[R"5nUS:Xa U"U0UD6 [R"S5 g[ RSU[ R"U55 g![a> [ [ S[ R"U55 [R"S5 gf=f)Nrz&Failed forking and calling callback %sz(Forked child %s who will run callback %s) r8fork_exit Exceptionr%r[r"obj_namer)child_cbargskwargsfids r>fork_cbrs '')C ax  d %f % HHQK 6     )   8##H-  HHQK  sA((AB0/B0c[U[5(aUSL$[nU(a[U5U-n[ U5R 5R 5U;aggr)rmbool TRUE_STRINGSlistrnlowerrErdaddons check_sets r>is_truersQ#d{I Of,  3x~~9, r=c[U[5(aUSL$[nU(a[U5U-n[ U5R 5R 5U;agg)NFT)rmr FALSE_STRINGSrrnrrErs r>is_falsersQ#e|I Of,  3x~~9, r=cVU(dg[U[5(aU$[X5$NF)rmrr)rdrs r>translate_boolrs' # 3 r=c[R"5nU(d![R[R-nSR [ U5Vs/sHo2RU5PM sn5$s snfN)random SystemRandomstring ascii_lettersdigitsr]rangechoice)strlen select_fromr_xs r>rand_strr(sSA **V]]: 77E&MBMbHH[)MB CCBsA7cHU(dSn[SS9S-U-nX ;aU$M)Nr)rr))r) dictionarypostfixnewkeys r> rand_dict_keyr/s4  #c)G3  #  M r=instance_data_filec SSKJnJnJnJn [ U5nU(aF[RRU5(a"U"UUU5n[RSUU5 [U0S9$![ a 0s$f=f!Ua!n[RSUU5 SnAN>SnAfUa NIUa+n[RSUU[U55 SnANtSnAff=f)z>Read a yaml config with optional template, and convert to dictr)JinjaLoadErrorJinjaSyntaxParsingException NotJinjaErrorrender_jinja_payload_from_filez?Applied instance data in '%s' to configuration loaded from '%s'z4Failed to render templated yaml config file '%s'. %sNz:Could not apply Jinja template '%s' to '%s'. Exception: %sdefault)!cloudinit.handlers.jinja_templaterrrrload_text_fileFileNotFoundErrorr8rexistsr[rr\repr load_yaml)rcrrrrr config_filers r> read_confr9s$U+ bggnn-?@@ 8"K II1"  0 [" --E   +  KKF       KK "Q    s; A0!B0 A?>A?CB$$ C/C4!CCc$[[U65$N)sorted uniq_merge)listss r>uniq_merge_sortedrms *e$ %%r=c/nUHbn[U[5(a9UR5RS5nUVs/sH o3(dM UPM nnUR U5 Md [ U5$s snf)NrQ)rmrnrEr;extend uniq_list)r combined_lista_listas r>rrysjM fc " "\\^))#.F!'-A1aF-V$  ] ##.s A6A6c[R5HupURX5nM /nUH nU[;dMUR U5 M" UHnURUS5nM UR 5nU$r)FN_REPLACEMENTSitemsreplace FN_ALLOWEDappendrE)fnrerUremovalss r>clean_filenamer st%%' ZZ (H  J  OOA  ZZ2  B Ir=Tc[R"[U55n[R"SSSU5nU(a+[ UR 55sSSS5 sSSS5 $UR 5sSSS5 sSSS5 $!,(df  O=fSSS5 g!,(df  g=f![a(nU(aUsSnA$[[U55UeSnAff=f)Nrbr) ioBytesIOrugzipGzipFilerpreadrrrn)raquietrobufghrs r> decomp_gziprs 4 ZZ D) *c4== $34 $RWWY/ 4 4 * * wwy 4 4 * *4 4 * * * 4 K$SV,! 3 4soB;B* B B*$ B;.B= B* B; B B*!B;* B84B;8B;; C-C( C-C((C-c8U(dgURSS5nUSR5n[U5S:XaUSR5nOSnU(aUS:XdUR5S:XaSnU(aUS:XdUR5S:XaSnX#4$)NNNrPrrr4z-1none)r;rElenr)ug_pair ug_partedugs r>extract_usergroupr!s  c1%I! A 9~ aL     T QWWY&0  T QWWY&0  6Mr=root_dirc[5n[R"[RR US55Hn[RR U5(dM)[RR U5SSnUR5nU(dMdURS5S:XdM{X1U'M U$)Nz*.pyrr3) r_globr8rr]isfilebasenamerEfind)r"entriesrcmodnames r>get_modules_from_dirr,sfG277<<&9:ww~~e$$ ''""5)!B/--/ 7w||C(B.$EN ; Nr=c2S[R"5;$)zdeprecated: prefer Distro object's `is_linux` property Multiple sources of truth is bad, and already know whether we are working with Linux from the Distro class. Using Distro offers greater code reusablity, cleaner code, and easier maintenance. Linuxplatformsystemr<r=r>is_Linuxr2s hoo' ''r=clS[R"5;ag[R"5S:Xagg)NBSDT DragonFlyFr/r<r=r>is_BSDr6s) !!K' r=c"[5SS:H$)Nvariantfreebsd system_infor<r=r> is_FreeBSDr< = #y 00r=c"[5SS:H$)Nr8 dragonflyr:r<r=r>is_DragonFlyBSDr@s = #{ 22r=c"[5SS:H$)Nr8netbsdr:r<r=r> is_NetBSDrCs = #x //r=c"[5SS:H$)Nr8openbsdr:r<r=r> is_OpenBSDrFr=r=Fc*X;aU$[X5$r)ryobjkeyrs r>get_cfg_option_boolrKs  $) $$r=c\X;aU$Xn[U[5(d [U5nU$r)rmrn)rIrJrrds r>get_cfg_option_strrMs.  )C c3  #h Jr=c([[XUS95$)Nr)r7rMrHs r>get_cfg_option_intrOs !$W= >>r=cU(dSn[RRU5(d0$[U5nSnSU;aSn[R "X!5nU(afUR 5nSUS;aUSUS'USR5RS5SUS'USS :XaS US'USUS USS .$0$) zReturn a dictionary of distro info fields from /etc/redhat-release. Dict keys will align with /etc/os-release keys: ID, VERSION_ID, VERSION_CODENAME z/etc/redhat-releasezA(?P.+) release (?P[\d\.]+) \((?P[^)]+)\) Virtuozzoz)(?P.+) release (?P[\d\.]+)namerIz linuxrzred hat enterpriseredhatr$)ID VERSION_IDVERSION_CODENAME) r8rrrrematch groupdictrrY) release_fileredhat_release redhat_regexrXgroups r>_parse_redhat_releaser^s , 77>>, ' ' #L1N # n$C HH\ 2E ! %- ' %f E* f ++-77A!Df =0 0$E&M- * %j 1  Ir=cJSnSnSn0nSn[RRS5(a[[ S55nU(d Sn[ 5nU(aUR SS5nUR SS5nSU;dSU;a[R"5nOUS :XdUS :XaUR S S5nOzUS :XaU(dUR S S5nOZUR S S5nU(dA[R"SUR SS55nU(aUR5SnUS:XaSnO[5(a9[R"5R5n[R"5nOLSn[R "5nSnUHnU(dM SnM U(d[$R'S5 U$XU4$!["a NDf=f!SnUHnU(dM SnM U(d[$R'S5 ff=f)NrF/etc/os-releaseTrTrUslessusealpinephoton PRETTY_NAME virtuozzorVz[^ ]+ \((?P[^)]+)\)VERSIONrIrhelrS)rrrrzPUnable to determine distribution, template expansion may have unexpected results)r8rrload_shell_contentrr^getr0machinerWrXrYr6r1rr:distrr[r\) distro_namedistro_versionflavor os_releaseos_release_rhelrXrlfoundentrys r>get_linux_distrort sKN FJO ww~~'(('7H(IJ *,  nnT2. # b9 [ Fk$9 %%'F H $ x(?^^M26F K '^^M26F^^$6;F4NN9b1"__.z:F & "K oo'--/ !))+ ==?DE5E <  00   E5E <s*G G*'G-)G**G-- H">$H"cUSR5nSnUS:XaCUSSR5nUS;aUnU$US;aSnU$US :XaS nU$US ;aS nU$SnU$US ;aUnU$)Nr1unknownlinuxrlr) almalinuxrcaoscarch azurelinuxcentos cloudlinuxdebian eurolinuxfedoramariner miraclelinux openeuler opencloudos openmandrivardrhrockyrb tencentosrf)ubuntu linuxmintmintrrSrh)opensusez opensuse-leapzopensuse-microoszopensuse-tumbleweedsle_hpcz sle-microrarb)windowsdarwinr9rBrEr?)r)infor1r8 linux_dists r> _get_variantr^s (^ ! ! #FG &\!_**,   .!G6 N5: :G2 N18 #G. N-  G NG N   Nr=c[R"5[R"5[R"5[R"5[ [R "55[ 5S.n[U5US'U$)N)r0r1r:pythonr9rlr8)r0r1r:python_versionrr9rtr)rs r>r;r;sc%%'//###%))+hnn&' "  D#4(DO Kr=cX;aU$Xc/$Xn[U[5(aUVs/sHoDPM nnU$[U[5(d [U5nU/$s snf)a 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. )rmrrn)rIrJrrdrUcvals r>get_cfg_option_listrsj  y )C#3a3 c3  #h 5L  s Ac[U[5(aURS5nUnUHnXC;aUs $X4nM U$)aReturn 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./)rmrnr;)rIkeyprcurtoks r>get_cfg_by_pathrsE$zz# C >Nh Jr=c8[X5up#[X#5 X#4$r)get_output_cfgredirect_output)cfgmodeoutfmterrfmts r> fixup_outputrs %c0VF#  r=c0[[RRS55(a[R S5 gU(d[ RnU(d[ RnSnU(Ga0[R SX 5 URSS5upVUS:XdUS:XaS nUS:XaS n[Xg5nO[US :XaG[R"US [RUS 9n [[[ U R"5nO[%SU-5eU(a3[R&"UR)5UR)55 X:XaJ[R SX05 [R&"UR)5UR)55 gU(a[R SX15 URSS5upVUS:XdUS:XaS nUS:XaS n[Xg5nO[US :XaG[R"US [RUS 9n [[[ U R"5nO[%SU-5eU(a4[R&"UR)5UR)55 ggg)N_CLOUD_INIT_SAVE_STDOUTz5Not redirecting output due to _CLOUD_INIT_SAVE_STDOUTc[R"S5 [R"S5Rn[R "U5 g![ a gf=f)a{Reconfigure umask and group ID to create output files securely. This is passed to subprocess.Popen as preexec_fn, so it is executed in the context of the newly-created process. It: * sets the umask of the process so created files aren't world-readable * if an adm group exists in the system, sets that as the process' GID (so that the created file(s) are owned by root:adm) admN)r8umaskgrpgetgrnamgr_gidsetgidKeyError)group_ids r>set_subprocess_umask_and_gid5redirect_output..set_subprocess_umask_and_gidsJ  ||E*11H IIh     s A AAzRedirecting %s to %s r>>>abwb|T)shellstdin preexec_fnz"Invalid type for output format: %sz!Invalid type for error format: %s)rr8environrjr[rsysrDstderrr;open subprocessPopenPIPErr r rrxdup2fileno) rro_outo_errrrargowithnew_fpprocs r>rrsrzz~~7899 IJ     & (%8ll3*  3;$$,Es{#%F S[## oo7 D"S'4::.F@6IJ J  GGFMMOU\\^ 4   II,e < GGFMMOU\\^ 4   (%8ll3*  3;$$,Es{#%F S[## oo7 D"S'4::.F?&HI I  GGFMMOU\\^ 4 +r=sourcescU(a[[U55n0nUHenU(dM [R"U5nU(d[R"5n[R "U5nUR X#5nMg U$)aMerge multiple dicts according to the dict merger rules. Dict merger rules can be found in cloud-init documentation. If no mergers have been specified, entries will be recursively added, but no values get replaced if they already exist. Functionally, this means that the highest priority keys must be specified first. Example: a = { "a": 1, "b": 2, "c": [1, 2, 3], "d": { "a": 1, "b": 2, }, } b = { "a": 10, "c": [4], "d": { "a": 3, "f": 10, }, "e": 20, } mergemanydict([a, b]) results in: { 'a': 1, 'b': 2, 'c': [1, 2, 3], 'd': { 'a': 1, 'b': 2, 'f': 10, }, 'e': 20, } )rreversedrdict_extract_mergersdefault_mergers constructmerge)rreverse merged_cfgrmergers_to_applymergers r> mergemanydictr@suTx()J 3&;;C@ ##*#:#:#< &&'78Fj6J r=c## [R"5n[R"U5 Uv [R"U5 g![R"U5 f=f7fr)r8getcwdchdir)ndircurrs r>rrxs; 99;D   sA%A A% A""A%c## [R"U5nUv [R"U5 g![R"U5 f=f7fr)r8r)n_mskolds r>rrs2 ((5/C    sA5AA  Ac$SRXSUS9$)Nz{0:{fill}{align}{size}}^)fillalignsize)format)rqrmax_lens r>centerrs! $ + + s , r=c\[RSU5 [R"U5 g)NzRecursively deleting %s)r[rshutilrmtreers r>del_dirrsII'. MM$r=c[XUS9upEpgXPS'X`S'X@S'XpS'g![Ra)nUR[R:XaSnAgeSnAff=f) z returns boolean indicating success or failure (presense of files) if files are present, populates 'fill' dictionary with 'user-data' and 'meta-data' entries )baseexttimeout user-data vendor-data meta-datanetwork-configTNF) read_seededr#UrlErrorcode NOT_FOUND) rrrrmdudvdnetworkrs r>read_optional_seedrsj )tgN[ ][!(     66Z)) ) s AAAAc0nU(dSS/nO^[RRURS5S5[RRUR S5S5/n[ U5nUVs/sH3o3(dM [RR U5(dM1UPM5 nnSnUHgn[RR[RRUS55(dMG[RRUS5n O SnUHgn[RR[RRUS55(dMG[RRUS5n O U(aU(a XAS'XQS'U$U(aXAS'U$s snf) Nz/var/lib/cloud/data/sslz /var/lib/cloud/instance/data/sslrasslzcert.pemzkey.pem cert_filekey_file)r8rr] get_ipath_cur get_cpathrisdirr')paths ssl_detailsssl_cert_pathsdrrs r>fetch_ssl_detailsr sUK  % .  GGLL,,V4e < GGLL0% 8  /N!/JA1aq9IaNJI  77>>"'',,q*5 6 6 Q 3I H  77>>"'',,q)4 5 5ww||Ay1H X#,K "*J  #,K !Ks< F; "F;0F;cUn[U5n[RS[U5U5 [R "U5nUc[RS5 UnO8[ XB5(d([SU<S[R"U5<S35eUnU$![R[[4anSnSn[US5(a[US5(a [US5nO.[US5(a[US5(a [US5nU(a/US RURS -UR S -US 9- nOUS RUS 9- n[R#U5 SnAU$SnAff=f)NzKAttempting to load yaml from string of length %s with allowed root types %sz-loaded blob returned None, returning default.zYaml load allows z root types, but got  insteadzFailed loading yaml blob context_mark problem_markz5. Invalid format at line {line} column {col}: "{err}"r)rbcolrgz. {err})rg)rpr[rryaml safe_loadrmrxr"r YAMLError ValueErrorhasattrgetattrrrbcolumnr\)rhrallowedloaded convertedrmsgmarks r>rrsk F  D!  6 I   NN4(   IIE FII//J// :< " M! NNIz 2( 1n % %'!^*D*D1n-D Q ' 'GA~,F,F1n-D  GNNQDKK!OO C 9###* *C C M!sB BF;B>E??FcURS5S:aUURSSU-5nURSSU-5nURSSU-5nURSSU-5nOs[R(a2USS:wa)[R "U5R S :XaUS- nU<S<U<3nU<S<U<3nU<S<U<3nU<S<U<3nSn[R"XrUS 9n U R5(a[U R5n[R"XbUS 9n Sn U R5(a[U R0S 9n [R"XBUS 9n SnU R5(a U RnSn[R"XRUS 9nUR5(a URnO[RS 5 XX4$![Ra n [RS U 5 Sn A NSn A ff=f![Ra n [RSU 5 Sn A NjSn A ff=f)Nz%srrrrrr%rr)rretrieszNo network config provided: %srzError in vendor-data responsez!Error in vendor-data response: %s)r)rr%NOCLOUD_SEED_URL_APPEND_FORWARD_SLASHrurlparsequeryr#read_file_or_urlokrcontentsrr[r)rrrrud_urlvd_urlmd_url network_urlr network_resprmd_resprud_resprrvd_resps r>rrs yy!dK#$56dMC$78dK#$56ll4)9C)?@  9 9Bx35>>$#7#=#=#C !;4!=#6!;4"&(8#> G7!22 ' ??   5 56G))G Bzz|| w'' 4))G Bzz||    B 7-- W  ::<<!!B II5 6 2 A   7 2A6670   : 5q99:s0!G,H#,H HH #I7IIc [[R"U5SS9nUVs/sHo3RS5(dMUPM nnUVs/sHHn[RR [RR X55(dMFUPMJ nn/nUH<n[RR X5nUR[UUS95 M> [U5$s snfs snf![a [RSU5 Mx[a!n[RSXg5 SnAMSnAff=f)zRead configuration directory.Trz.cfgr1REDACTED config part %s, insufficient permissionsError accessing file %s: [%s]N)rr8listdirendswithrr'r]r rPermissionErrorr[r\rr)confdrconfsfcfgsr rrs r> read_conf_dr6)s 2::e$d 3E 41F!3QE 4 H1 U0F!GQE H Dww||E& B KK'9   / 5 I  KKCT  B KK7 A A Bs6C,C, AC1C1C66 E E"D>>Ec[5n0n[XS9nURU5 SnSU;abUSnU(aU[U[5(d'[SU<S[R"U5<35e[U5R5nO,[RRUS 35(aUS 3nU(a>[RRU5(a[!XQS9nUR#U5 [%U5$![a [R SU5 GN [ a!n[R SX5 SnAGN.SnAff=f) aRead yaml file along with optional ".d" directory, return merged config Given a yaml file, load the file as a dictionary. Additionally, if there exists a same-named directory with .d extension, read all files from that directory in order and return the merged config. The template file is optional and will be applied to any applicable jinja file in the configs. For example, this function can read both /etc/cloud/cloud.cfg and all files in /etc/cloud/cloud.cfg.d and merge all configs into a single dict. rr-r.Nrconf_dz Config file z( contains 'conf_d' with non-string type z.d)rrr r1r[r\rrmrnrxr"rrEr8rrr6 appendleftr)cfgfilerr5rrr2 confd_cfgs r>read_conf_with_confdr<Is$DC G C E3H  eS)) 3 3E :< E ((* '"~ & &)2 u%%M   "  9   ?  A 3W@@As D E1 E:EEc&[[US95$)Ncmdline)rread_cc_from_cmdliner>s r>read_conf_from_cmdlinerAxs )': ;;r=cUc [5nSU3nSnSn[U5n[U5n[U5n/nURU5nUS:aURX'U-5nUS:aUnUR[R "XU-UR 55RSS55 URXU-5nUS:aMSRU5$)Nrz cc:end_ccrz\n ) get_cmdlinerr)r runquotelstriprr]) r? tag_begintag_endbegin_lend_lclentokensbeginends r>r@r@}s-'mGIG)nG LE wdos2unixrSs= -- C ax8!G$,   FD ))r=c4\rSrSr%\\S'\\S'\\S'Srg)HostnameFqdnInfoihostnamefqdn is_defaultr<N)rrrrrn__annotations__rrr<r=r>rUrUsM Ir=rUcjSnSU;a.[US5n[USURS5S5nOrSU;a5USRS5S:aUSnUSSURS5nO7UR SUS9R nSU;aUSnOUR US 9upS[ XTU5$) aGet 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 meta-data, returning None if not present in meta-data. @return: a namedtuple of , , (str, str, bool). Values can be none when metadata_only is True and no cfg or metadata provides hostname info. is_default is a bool and it's true only if hostname is localhost and was returned by util.get_hostname() as a default. This is used to differentiate with a user-defined localhost hostname. FrWrVr3rNT)rW metadata_only)r[)rnrMr;r) get_hostnamerVrU)rcloudr[rXrWrVs r>get_hostname_fqdnr^s"J }3v;%c:tzz#q7IJ  Z!5!5c!:Q!>z?D:'738H%%&h S z?','9'9"/(:($ HJ 77r=c<Sn[U5R5HinURS5nUS:aUSUnUR5nU(dM8UR 5n[ U5S:aMYXSS;dMcUSn U$ U$![ a U$f=f)ax 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). N#rr4r)rrXr)rEr;rIOError)rVfilenamerWrbhashpostokss r>get_fqdn_from_hostsrfs D "8,779DiinG!|Ag:: is_resolvablers$J   D   E ++4Av'9'96;N;N%' !=C9D&%,, -LMJJx{+>D "  II4j A  j !  !2!2!8!8!>??" !?"##D$/ay|A+++OOV\\2  " ! OOV\\ *sBA9EF*6F  F*2F$FF FF$GGc0[R"5nU$r)rl gethostname)rVs r>r\r\5s!!#H Or=cj[R"U5S$![Ra gf=fNr)rl gethostbyaddrherror)ips r>rr:s3##B'** ==s 22c[U5$)z5determine if this url is resolvable (existing or ip).)r)rus r>is_resolvable_urlrAs  r=cUcg[RSU5 UH.n[U5(a[RSU5 Us $M0 g![a M@f=f)zW Search through a list of mirror urls for one that works This needs to return quickly. Nz%search for mirror in candidates: '%s'zfound working mirror: '%s')r[rrr) candidatescands r>search_for_mirrorrFsh II5zB  && 6= '    s'A AAc/nU(d-[R"S5[R"S5-$URS5(aSURS5nSU-SU-4Vs/sH+n[RR U5(dM)UPM- nnU$US:Xa[R"S5nU$US:Xa[R"S5nU$s snf)Nz/dev/msdosfs/*z/dev/iso9660/*LABEL=z /dev/msdosfs/z /dev/iso9660/ TYPE=vfat TYPE=iso9660)r& startswithrGr8rr)criteriaoformattagno_cacherdevlistlabelps r>find_devs_with_freebsdrYsG yy)*TYY7G-HHH8$$)&-/FG Gww~~a  G   N [ )),- N ^ #)),- N s *(CCc/nSnSnSnU(aNURS5(aURS5nURS5(aURS5n[R"/SQS/S9n U RR 5Hnn U(dU(a[R"SU /SS/S9upU(a S U-U;aM>US :XaS U;aMLUS :XaS U;aMZUR S U -5 Mp U$)NrrzTYPE=sysctl-nz hw.disknamesrrcs mscdlabelrz label "%s"iso9660zISO filesystemvfat/dev/)rrGr rDr;r ) rrrrrrr_type mscdlabel_outrFdevr)s r>find_devs_with_netbsdrmsG E EM   x ( (OOH-E   w ' 'OOG,E ))41# >Czz! E#yy+s);!QH M lU*=@  I "2-"G  F?/=@ w}%" Nr=c[R"/SQS/S9n/nURR5RS5HinUR S5(dMUS:XaM#UR USSS-5 UR S 5(aMRUR USSS -5 Mk UVs/sHnS U-PM sn$s snf) NrrrrQrPzfd0:r%rcdir)r rDrstripr;r0r r) rrrrrrFrrsrs r>find_devs_with_openbsdrs ))41# >CG""$**3/~~c""  F? uSbzC'(%% NN5":+ ,0") )AGaK )) )s5CcD[R"/SQS/S9n[URR5SS9Vs/sH5nUR S5(aMUR S5(aM3UPM7 nnUS:Xa*UVs/sHofR S 5(dMUPM nnOMUS ;a*UVs/sHofR S 5(aMUPM nnOU(a[ R S U5 UVs/sHnS U-PM sn$s snfs snfs snfs snf) N)rrz kern.disksrrTr,rvnr)racd)zLABEL=CONFIG-2rzUnexpected criteria: %sr)r rrDr;rr[r)rrrrrrFrrs r>find_devs_with_dragonflybsdrs ))2 !%Egm)D1gE 4 4%Kgll=.I1gK  +X6!( )AGaK ))FK *s/DD3DD"D5DD<Dc([5(a [XX#U5$[5(a [XX#U5$[ 5(a [ XX#U5$[ 5(a [XX#U5$S/n/nU(aURSU-5 U(aURSU-5 U(aURSS/5 U(aURSU-5 U(aURU5 XV-n[R"USS/S 9up/n UR5H-n U R5n U (dMU RU 5 M/ U $![Ra!n U R[:XaS nS n A NteS n A ff=f) z~ find devices matching given criteria (via blkid) criteria can be *one* of: TYPE= LABEL=