x[h:SSKrSSKrSSKrSSKrSSKrSSKJr SSKrSSKJ r SSK J r SSK J r SSKJrJrJrJrJr SSKJrJr SSKJr SS KJrJr SS KJr SS KJr \R@"\!5r"S S /r#Sr$Sr%Sr&"SS\RNRP5r)Sr*Sr+"SS\RX5r-\-\R\44/r/Sr0g)N)urlparse)ConnectionError)HTTPConnection) PoolManager)dmi performancesources url_helperutil) EventScope EventType)NoDHCPLeaseError)EphemeralDHCPv4EphemeralIPv6Network)DataSourceHostname)ProcessExecutionErrorzhttp://169.254.42.42zhttp://[fd00:42::42] c6^\rSrSrSrU4SjrSSjrSrU=r$)SourceAddressAdapter&z> Adapter for requests to choose the local address to bind to. c :>Xl[[U]"S0UD6 g)N)source_addresssuperr__init__)selfrkwargs __class__s F/usr/lib/python3/dist-packages/cloudinit/sources/DataSourceScaleway.pyrSourceAddressAdapter.__init__+s, "D2>    3 3Q 7B  '!..)  r#)r.r)F) __name__ __module__ __qualname____firstlineno____doc__rr0__static_attributes__ __classcell__r s@r!rr&s=   r#rc [R"USUSUSS9n[R"UR5$![R anUR S:XaSnAgeSnAff=f)a% Retrieve user data or vendor data. Scaleway user/vendor data API returns HTTP/404 if user/vendor data is not set. This function calls `url_helper.readurl` but instead of considering HTTP/404 as an error that requires a retry, it considers it as empty user/vendor data. Also, be aware the user data/vendor API requires the source port to be below 1024 to ensure the client is root (since non-root users can't bind ports below 1024). If requests raises ConnectionError (EADDRINUSE), the caller should retry to call this function on an other port. NrcURS:g=(a3 [UR[RR 5(+$)N)code isinstancecauserequests exceptionsr)excs r!%query_data_api_once..Ws3SXX_&syy(*=*=*M*MNN&r#)datatimeoutretriessession exception_cbr<)r readurlr decode_binarycontentsUrlErrorr=) api_addressrFrequests_sessionresprBs r!query_data_api_oncerQ<sk !! $ !!$--00    88s? s9<A+A&%A&&A+c[S[US55Hn[RSX5 [R "5nSn[ U5RnUnUSS:XaUSSn[R"US[RS 9SSn U [R:XaS nURS [Xd4S 95 [XUS 9n [RSU5 U s $ W e![a NNf=f![ R"a:n [R%SX 5 [&R("S5 U n Sn A GM2Sn A ff=f)aGet user or vendor data. Handle the retrying logic in case the source port is used. Scaleway metadata service requires the source port of the client to be a privileged port (<1024). This is done to ensure that only a privileged user on the system can access the metadata service. r%rz*Trying to get %s data (bind on port %d)...z0.0.0.0r[N)protoz0::zhttp://)r)rFrOz%s-data downloadedz%Error while trying to get %s data: %s)rangemaxLOGdebugr@Sessionrnetlocr+ getaddrinfo IPPROTO_TCPAF_INET6 ValueErrormountrrQr rMwarningtimesleep) api_typerNrGrFportrO localhost url_addressaddress addr_protorErBlast_excs r!query_data_apirldsTaWa)"  IIS()!B/G#//T);); 0 %I  " "$Y4EF '?OD II*H 5K9*L N)  ""  KK? O JJqMH   s<-D A%C0.;D0 C=:D<C==DE.E  Ec^\rSrSrSr\R \R\R\R10r U4Sjr S\ SS4U4SjjrSrS r\S 5rS r\S 5r\S 5rSrSrSSjr\S5r\S5rSrU=r$)DataSourceScalewayScalewayc>[[U] XU5 [R"[R "USS/05/5Ul[UR RS[55Ul [UR RS[55Ul [UR RS[55Ul[R Ul[$UlSUlSUlSUlSUlSUlSUR R35;a#U=R&UR S- slgg)N datasourcerprGrFmax_waitT metadata_urls)rrnrr mergemanydictget_cfg_by_pathds_cfgintgetDEF_MD_RETRIESrGDEF_MD_TIMEOUTrFDEF_MD_MAX_WAITrsr UNSET_network_config DS_BASE_URLSrt metadata_url userdata_urlvendordata_urlephemeral_fixed_addresshas_ipv4keys)rsys_cfgdistropathsr s r!rDataSourceScaleway.__init__s  $0%H(($$W|Z.H"M   4;;??9nEF 4;;??9nEF DKKOOJHI &}})  "'+$ dkk..0 0   $++o"> >  1r#ci_pkl_versionreturnNc>[TU]U5 SS[[SSS.nUH#n[ X5(aM[ XX#5 M% g)NT)rrrsrtrr)r _unpickler|rhasattrsetattr)rr attr_defaultsattrr s r!rDataSourceScaleway._unpicklesM .)'+') "  "D4&&M$78"r#cv[R"5n[R"UURUR SS9up4U(a5[ RSU5 US3UlUS3Ul US3Ul g[ RSU[[R"5U- 55 [e) z? Define metadata_url based upon api-metadata URL availability. F)urlsrsrFconnect_synchronouslyz%s is reachablez/conf?format=jsonz/user_data/cloud-initz/vendor_data/cloud-initNz3Unable to reach api-metadata at %s after %s seconds) rc monotonicr wait_for_urlrsrFrYrZrrrrxr)rr start_time avail_url_s r!_set_metadata_url$DataSourceScaleway._set_metadata_urls ^^% !..]]LL"'   II' 3#,+-> ?D #,+-B CD %.K/F"GD   IIEDNN$z12  " !r#c[R"URURURS9n[ R "[R"UR55Ul [SURURUR5Ul [SURURUR5Ulg)N)rFrGz user-dataz vendor-data)r rJrrFrGjsonloadsr rKrLmetadatarlr userdata_rawrvendordata_raw)rrPs r!_crawl_metadata"DataSourceScaleway._crawl_metadatas!!   t||T\\  4#5#5dmm#DE * **DLL$,, - 4.. dll r#c[R"S5nUS:Xag[RR S5(ag[ R "5nSU;agg)z There are three ways to detect if you are on Scaleway: * check DMI data: not yet implemented by Scaleway, but the check is made to be future-proof. * the initrd created the file /var/run/scaleway. * "scaleway" is in the kernel cmdline. zsystem-manufacturerrpTz/var/run/scalewayscalewayN)r read_dmi_dataospathexistsr get_cmdline) vendor_namecmdlines r! ds_detectDataSourceScaleway.ds_detectsU''(=> * $ 77>>- . .""$   !r#cUR(a[URURR5n[R "S5 UR UR5 SSS5 UR5 USUl SURS'SSS5 UR(d[%URURR5 [R "S5 UR UR5 SSS5 UR5 SURS'SSS5 gg!,(df  N=f!,(df  N=f![[[4a6n[R"[ [#U55 SUlSnAGNSnAff=f!,(df  N=f!,(df  g=f![a gf=f) Nz7Setting api-metadata URL depending on IPv4 availabilityz fixed-addressipv4 net_in_useFz7Setting api-metadata URL depending on IPv6 availabilityipv6T)rrrfallback_interfacerTimedrrtrrrrrrr logexcrYstrr)rres r! _get_dataDataSourceScaleway._get_datas == &%KKKK22$**9..t/A/AB  ((*373HD028DMM,/.}} )KKKK22%**,..t/A/AB  ((*28DMM,/E !% &  CQ(!&  &" #  s*E+EE 01E!E+;*G%G <F9'G ?G E E E($E+(E++F6+F11F69 G G  GGG G('G(c |URc9[RS[R5 [RUlUR[R:wa UR$UR SGc0n0nUR SHnUSUR :Xa7SUS'SSSS .nS UR5;aUS ==U/- ss'MEU/US 'MMS UR5;aUS ==USS US 34- ss'OUSS US 34US 'USS:XdMUSSS.nS UR5;aUS ==U/- ss'MU/US 'M X!URR'SUS.UlOSSURR-S.nSS0/nUR S(aIUSSUR SS-SUR SS -SSSUR SS-S./S./- nXQS'S U/S!.Ul[RS"UR5 UR$)#zH Configure networking according to data received from the metadata API. z5Found None as cached _network_config. Resetting to %s private_ip public_ipsriTdhcp4z169.254.42.42/32z 62.210.0.1)zon-linktoviaroutes addresses/netmaskfamilyinet6gatewayz::/0)rrr)version ethernetsphysicalz%s)typenamerrstaticz::0)networkprefixr)rrirrsubnetsr%)rconfigznetwork_config : %s) r~rYrbr r}rrrrrrZ)rnetcfgip_cfgiprouters r!network_config!DataSourceScaleway.network_config4s    ' KKG  $+==D   7== 0'' ' == & .FFmmL1i=D$@$@@&*F7O$(0+E  6;;=0x(UG3(,17x("fkkm3{+!)}oQr)}o>0+ ")}oQr)}o>/{+(|w.(*9 V D#v{{}4"8,7,05wF8,92:6<4;;11 2/0v#FD #t{{===F()G}}V$ (#'$--*? *J#J#'$--*? *J#J,0*-+/"&--"7 "B,C# !(9 /0VH#ED  ')=)=>###r#cgNrrs r! launch_indexDataSourceScaleway.launch_indexr#c URS$)Nid)rrs r!get_instance_id"DataSourceScaleway.get_instance_ids}}T""r#c(URSVs/sHoSPM nnSn[U5nURRS/5H>nURU5(dMUR XTSR SS55 M@ U$s snf)Nssh_public_keyskeyzAUTHORIZED_KEY=tagsr )rlenry startswithappendreplace)rrssh_keysakeypreplentags r!get_public_ssh_keys&DataSourceScaleway.get_public_ssh_keyss*.--8I*JK*J3J*JK#7|==$$VR0C>>'** OOCJ..sC8 91 LsBc4[URSS5$)NhostnameF)rr)rfqdn resolve_ip metadata_onlys r! get_hostnameDataSourceScaleway.get_hostnames!$-- ";UCCr#cgrrrs r!availability_zone$DataSourceScaleway.availability_zonerr#cgrrrs r!regionDataSourceScaleway.regionrr#)r~rwrrrsrrrtrGrFrrrr)FFF)r2r3r4r5dsnamer NETWORKr BOOT_NEW_INSTANCEBOOT BOOT_LEGACYdefault_update_eventsrrxrrr staticmethodrrpropertyrrrrrrrr7r8r9s@r!rnrns F  ' ' NN  ! ! ?, 9 9 9"4  (0dM$M$^# Dr#rnc8[R"U[5$r)r list_from_depends datasources)dependss r!get_datasource_listr s  $ $Wk ::r#)1rloggingrr+rc urllib.parserr@requests.exceptionsrurllib3.connectionrurllib3.poolmanagerr cloudinitrrr r r cloudinit.eventr r cloudinit.net.dhcprcloudinit.net.ephemeralrrcloudinit.sourcesrcloudinit.subpr getLoggerr2rYrrzr|r{adapters HTTPAdapterrrQrl DataSourcernDEP_FILESYSTEMr r rr#r!rs  !/.+AA1/I00 !&(>?  8,,88 ,%P1hH++HX'0023 ;r#