"T`=@sxddlZddlZddlZddlZddlZddlZddlmZddlm Z m Z m Z m Z ddl mZddlmZddlmZddlmZejeZdZGd d d eZGd d d eZGd ddeZddddZddZdddZddZ dddZ!dddZ"ddZ#dS)N)StringIO)EphemeralIPv4Networkfind_fallback_nicget_devicelisthas_url_connectivity)mask_and_ipv4_to_bcast_addr) temp_utils)subp)utilz/run/systemd/netif/leasesc@seZdZdZdS)InvalidDHCPLeaseFileErrorzRaised when parsing an empty or invalid dhcp.leases file. Current uses are DataSourceAzure and DataSourceEc2 during ephemeral boot to scrape metadata. N)__name__ __module__ __qualname____doc__rr4/usr/lib/python3/dist-packages/cloudinit/net/dhcp.pyr s r c@seZdZdZdS)NoDHCPLeaseErrorz'Raised when unable to get a DHCP lease.N)r r rrrrrrr$s rc@smeZdZdddddZddZddZdd Zd d Zd d ZddZ dS)EphemeralDHCPv4NcCs1||_d|_d|_||_||_dS)N)iface_ephipv4lease dhcp_log_funcconnectivity_url)selfrrrrrr__init__)s     zEphemeralDHCPv4.__init__cCs9|jr/t|jr/tjd|jdS|jS)zUSetup sandboxed dhcp context, unless connectivity_url can already be reached.z:Skip ephemeral DHCP setup, instance has connectivity to %sN)rrLOGdebug obtain_lease)rrrr __enter__0s  zEphemeralDHCPv4.__enter__cCs|jdS)z Teardown sandboxed dhcp context.N) clean_network)rZ excp_typeZ excp_valueZexcp_tracebackrrr__exit__;szEphemeralDHCPv4.__exit__cCs9|jrd|_|jsdS|jjddddS)z@Exit _ephipv4 context to teardown of ip configuration performed.N)rrr )rrrrr?s    zEphemeralDHCPv4.clean_networkcCsb|jr|jSyt|j|j}Wn1tk r\}zt|WYdd}~XnX|slt|d|_tjd|jd|jd|jdddddddd d d d d gddi}|j|}|d st |d|d|d <|d r&t |d |d <|j r<|j |d             zEphemeralDHCPv4.obtain_leasecCsbi}xU|jD]G\}}t|trD|j|||q|jj|||[^}]*)}\nrz&Cannot parse empty dhcp lease file {0};"zoption  r!z1Cannot parse dhcp lease file {0}. No leases found) recompiler load_filelenr formatfindallsplitstripreplaceappenddict) lease_fileZ lease_regexZ dhcp_leasesZ lease_contentrZ lease_optionslinerrrparse_dhcp_lease_files& $ rIc Cs tjd|tjj|d}tj||tjj|d}tjj|d}tj|tjsz|}t j dddd|d gd d |d d d|d||ddg }t j |d d \}} tj ||gdddd} | r/tj ddjdd| DgSd} d} xt ddD]} tj |j}yt|}Wntk rYnFXtj|} | dkrtjd|tj|tjd } PtjdqKW| stjd || d"|d!k r||| t|S)#a Run dhclient on the interface without scripts or filesystem artifacts. @param dhclient_cmd_path: Full path to the dhclient used. @param interface: Name of the network inteface on which to dhclient. @param cleandir: The directory from which to run dhclient as well as store dhcp leases. @param dhcp_log_func: A callable accepting the dhclient output and error streams. @return: A list of dicts of representing the dhcp leases parsed from the dhcp.leases file or empty list. z!Performing a dhcp discovery on %sr5z dhclient.pidz dhcp.leasesr#linksetZdevZupZcaptureTz-1z-vz-lfz-pfz-sfz /bin/trueZmaxwaitZnapleng{Gz?z+dhclient did not produce expected files: %sz, css!|]}tjj|VqdS)N)ospathbasename).0frrr sz!dhcp_discovery..unknownFrir!zkilling dhclient with pid=%szCdhclient(pid=%s, parentpid=%s) failed to daemonize after %s secondsNg$@)rrrMrNjoinr copyaccessX_OKr Zwait_for_filesZwarningranger>rCint ValueErrorZ get_proc_ppidkillsignalSIGKILLtimeZsleeperrorrI)Zdhclient_cmd_pathr"ZcleandirrZsandbox_dhclient_cmdZpid_filerGcmdouterrZmissingZppidZ daemonized_Z pid_contentpidrrrr7sN %       r7cCsttjt|ddS)zParse a systemd lease file content as in /run/systemd/netif/leases/ Parse this (almost) ini style file even though it says: # This is private data. Do not parse. Simply return a dictionary of key/values.Z list_valuesF)rF configobjZ ConfigObjr)Zcontentrrrnetworkd_parse_leasesrfcCst|dkrt}i}tjj|s.|Sx?tj|D].}ttjtjj||||W|S)zReturn a dictionary of dictionaries representing each lease found in lease_d.i The top level key will be the filename, which is typically the ifindex.N) NETWORKD_LEASES_DIRrMrNisdirlistdirrfr r>rT)leases_dZretZlfilerrrnetworkd_load_leases"s )rkcCs_|dkrt}td|}x7t|jD]#\}}|j|r4||Sq4WdS)Nrj)rgrksortedr.r2)Zkeynamerjr*Z_ifindexdatarrrnetworkd_get_option_from_leases4s  rnc sjdddtjdD}g}fdd}d}xt|D]\}}||krtqYt|}|tdd kr*d }t||d |kr|||t||d |Sd j||d |d} d j||d||} ||}n|tddkrd}t||d |kr|||t||d |Sd j||d |ddg} d j||d||} ||}n|td dkrd}t||d |kr6|||t||d |Sd j||d |dddg} d j||d||} ||}nQ|td d krFd}t||d |kr|||t||d |Sd j||d |ddddg} d j||d||} ||}n|dkrd}t||d |kr|||t||d |Sd} d j||d ||} ||}ntj d||S|j d| |f| fqYW|S)a parse rfc3442 format and return a list containing tuple of strings. The tuple is composed of the network_address (including net length) and gateway for a parsed static route. It can parse two formats of rfc3442, one from dhcpcd and one from dhclient (isc). @param rfc3442: string in rfc3442 format (isc or dhcpd) @returns: list of tuple(str, str) for all valid parsed routes until the first parsing error. E.g. sr=parse_static_routes("32,169,254,169,254,130,56,248,255,0,130,56,240,1") sr=[ ("169.254.169.254/32", "130.56.248.255"), ("0.0.0.0/0", "130.56.240.1") ] sr2 = parse_static_routes("24.191.168.128 192.168.128.1,0 192.168.128.1") sr2 = [ ("191.168.128.0/24", "192.168.128.1"), ("0.0.0.0/0", "192.168.128.1") ] Python version of isc-dhclient's hooks: /etc/dhcp/dhclient-exit-hooks.d/rfc3442-classless-routes r8cSsg|]}|r|qSrr)rPtokrrr Ys z'parse_static_routes..z[, .]cs'd|||f}tj|dS)NzRFC3442 string malformed. Current route has CIDR of %s and requires %s significant octets, but only %s remain. Verify DHCP rfc3442-classless-static-routes value: %s)rr_)ZcidrZrequiredZremainmsg)rfc3442rr _trunc_error\sz)parse_static_routes.._trunc_errorr! N.r!rL0z0.0.0.0zSParsed invalid net length "%s". Verify DHCP rfc3442-classless-static-routes value.z%s/%s) rstripr<rB enumeraterYrXr?rTrr_rE) rrtokensr$rsZ current_idxidxroZ net_lengthZreq_toksZ net_addressZgatewayr)rrrr)>sl   !!  (!  +!  .!   !  !r))$reZloggingrMr<r\r^iorZ cloudinit.netrrrrZcloudinit.net.network_staterr(Z cloudinitrr r Z getLoggerr rrg Exceptionr robjectrr&rIr7rfrkrnr)rrrrs.      "^! Q