ó
ƒjbc @ sM d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m Z m
Z
d d l m Z
d d l m Z d d l m Z d d l m Z e j e ƒ Z d Z d e f d „ ƒ YZ d
e f d „ ƒ YZ d e f d
„ ƒ YZ d d „ Z d „ Z d „ Z d „ Z d d „ Z! d d „ Z" d „ Z# d S( iÿÿÿÿN( t EphemeralIPv4Networkt find_fallback_nict get_devicelistt has_url_connectivity( t mask_and_ipv4_to_bcast_addr( t
temp_utils( t util( t StringIOs /run/systemd/netif/leasest InvalidDHCPLeaseFileErrorc B s e Z d Z RS( s¤ Raised when parsing an empty or invalid dhcp.leases file.
Current uses are DataSourceAzure and DataSourceEc2 during ephemeral
boot to scrape metadata.
( t __name__t
__module__t __doc__( ( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR s t NoDHCPLeaseErrorc B s e Z d Z RS( s' Raised when unable to get a DHCP lease.( R R
R ( ( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR $ s t EphemeralDHCPv4c B sM e Z d d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( c C s( | | _ d | _ d | _ | | _ d S( N( t ifacet Nonet _ephipv4t leaset connectivity_url( t selfR R ( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt __init__* s c C s< | j r2 t | j ƒ r2 t j d | j ƒ d Sn | j ƒ S( sU Setup sandboxed dhcp context, unless connectivity_url can already be
reached.s: Skip ephemeral DHCP setup, instance has connectivity to %sN( R R t LOGt debugt obtain_lease( R ( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt __enter__0 s
c C s | j ƒ d S( s Teardown sandboxed dhcp context.N( t
clean_network( R t excp_typet
excp_valuet excp_traceback( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt __exit__; s c C s< | j r d | _ n | j s" d S| j j d d d ƒ d S( s@ Exit _ephipv4 context to teardown of ip configuration performed.N( R R R R ( R ( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR ? s
c C sW | j r | j Sy t | j ƒ } Wn t k
r? t ƒ ‚ n X| sR t ƒ ‚ n | d | _ t j d | j d | j d | j d ƒ i d d 6d d 6d d 6d d 6d
d g d 6d
d 6} | j | ƒ } | d s÷ t | d | d ƒ | d <n | d rt | d ƒ | d <n | j
r1| j
| d <n t | } | j ƒ | | _
| j S( s9 Perform dhcp discovery in a sandboxed environment if possible.
@return: A dict representing dhcp options on the most recent lease
obtained from the dhclient discovery if run, otherwise an error
is raised.
@raises: NoDHCPLeaseError if no leases could be obtained.
iÿÿÿÿs# Received dhcp lease on %s for %s/%st interfaces
fixed-addresss subnet-maskt ipt prefix_or_masks broadcast-addresst broadcasts rfc3442-classless-static-routess classless-static-routest
static_routest routerst routerR ( R t maybe_perform_dhcp_discoveryR R R R R t extract_dhcp_options_mappingt bcipt parse_static_routesR R R R ( R t leasest nmapt kwargst ephipv4( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR G s:
c C sb i } xU | j ƒ D]G \ } } t | t ƒ rD | j | | | ƒ q | j j | ƒ | | <q W| S( N( t itemst
isinstancet listt get_first_option_valueR t get( R R* t resultt internal_referencet lease_option_names( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR& q s
c C s= x6 | D]. } | j | ƒ s | j j | ƒ | | <q q Wd S( N( R1 R ( R t internal_mappingR4 R2 t different_names( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR0 ~ s
N(
R R
R R R R R R R& R0 ( ( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR
) s *
c C s¹ | d k r5 t ƒ } | d k rX t j d ƒ g Sn# | t ƒ k rX t j d | ƒ g St j d ƒ } | s~ t j d ƒ g St j d t d d d t ƒ } t
| | | ƒ SWd QXd S(
s¹ Perform dhcp discovery if nic valid and dhclient command exists.
If the nic is invalid or undiscoverable or dhclient command is not found,
skip dhcp_discovery and return an empty dict.
@param nic: Name of the network interface we want to run dhclient on.
@return: A list of dicts representing dhcp options for each lease obtained
from the dhclient discovery if run, otherwise an empty list is
returned.
s1 Skip dhcp_discovery: Unable to find fallback nic.s8 Skip dhcp_discovery: nic %s not found in get_devicelist.t dhclients7 Skip dhclient configuration: No dhclient command found.t rmtree_ignore_errorst prefixs cloud-init-dhcp-t needs_exeN( R R R R R R t whichR t tempdirt Truet dhcp_discovery( t nict
dhclient_patht tdir( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR% … s"
c C s t j d ƒ } g } t j | ƒ } t | ƒ d k rN t d j | ƒ ƒ ‚ n x“ | j | ƒ D]‚ } g } x` | j d ƒ D]O } | j ƒ j
d d ƒ j
d d ƒ } | s° qz n | j | j d d ƒ ƒ qz W| j t | ƒ ƒ q^ W| st d
j | ƒ ƒ ‚ n | S( s Parse the given dhcp lease file for the most recent lease.
Return a list of dicts of dhcp options. Each dict contains key value pairs
a specific lease in order from oldest to newest.
@raises: InvalidDHCPLeaseFileError on empty of unparseable leasefile
content.
s lease {(?P<lease>[^}]*)}\ni s& Cannot parse empty dhcp lease file {0}t ;t "t s option t i s1 Cannot parse dhcp lease file {0}. No leases found(
t ret compileR t load_filet lenR t formatt findallt splitt stript replacet appendt dict( t
lease_filet lease_regext dhcp_leasest
lease_contentR t
lease_optionst line( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt parse_dhcp_lease_file¤ s& $ c
C sõ t j d | ƒ t j j | d ƒ } t j | | ƒ t j j | d ƒ } t j j | d ƒ } t j | t j ƒ s} | } n t j d d d d | d g d
t
ƒ| d d d
| d | | d d g
} t j | d
t
ƒt j | | g d d d d ƒ} | r't j d d j d „ | Dƒ ƒ ƒ g Sd } x¥ t
d d ƒ D]” } t j | ƒ j ƒ }
y t |
ƒ } Wn t k
r{nI Xt j | ƒ } | d k rÄt j d | ƒ t j | t j ƒ t | ƒ St j d ƒ q=Wt j d |
| d ƒ t | ƒ S( s 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.
@return: A list of dicts of representing the dhcp leases parsed from the
dhcp.leases file or empty list.
s! Performing a dhcp discovery on %sR7 s dhclient.pids dhcp.leasesR t linkt sett devt upt captures -1s -vs -lfs -pfs -sfs /bin/truet maxwaiti t napleng{®Gáz„?s+ dhclient did not produce expected files: %ss , c s s! | ] } t j j | ƒ Vq d S( N( t ost patht basename( t .0t f( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pys <genexpr>ô s t unknowni iè i s killing dhclient with pid=%ssC dhclient(pid=%s, parentpid=%s) failed to daemonize after %s secondsg $@( R R R_ R` t joinR t copyt accesst X_OKt subpR= t wait_for_filest warningt rangeRH RM t intt
ValueErrort
get_proc_ppidt killt signalt SIGKILLRW t timet sleept error( t dhclient_cmd_pathR t cleandirt sandbox_dhclient_cmdt pid_fileRQ t cmdt missingt ppidt _t pid_contentt pid( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR> Ã sD %
c C s t t j t | ƒ d t ƒƒ S( sÛ Parse 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.t list_values( RP t configobjt ConfigObjR t False( t content( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt networkd_parse_lease
s c C sw | d k r t } n i } t j j | ƒ s1 | Sx? t j | ƒ D]. } t t j t j j | | ƒ ƒ ƒ | | <qA W| S( sŸ Return 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(
R t NETWORKD_LEASES_DIRR_ R` t isdirt listdirR… R RH Re ( t leases_dt rett lfile( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt networkd_load_leases s )c C sb | d k r t } n t d | ƒ } x7 t | j ƒ ƒ D]# \ } } | j | ƒ r7 | | Sq7 Wd S( NR‰ ( R R† RŒ t sortedR- R1 ( t keynameR‰ R) t _ifindext data( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt networkd_get_option_from_leases* s c sº ˆ j d ƒ ‰ g t j d ˆ ƒ D] } | r" | ^ q" } g } ‡ f d † } d } x^t | ƒ D]P\ } } | | k r€ qb n t | ƒ } | t d d ƒ k r$d } t | | ƒ | k rÛ | | | t | | ƒ ƒ | Sd j | | d | d
!ƒ } d j | | d
| | !ƒ }
| | } nq| t d d ƒ k rÃd } t | | ƒ | k rs| | | t | | ƒ ƒ | Sd j | | d | d
!d g ƒ } d j | | d
| | !ƒ }
| | } nÒ| t d d ƒ k red } t | | ƒ | k r| | | t | | ƒ ƒ | Sd j | | d | d !d d g ƒ } d j | | d | | !ƒ }
| | } n0| t d d ƒ k r
d } t | | ƒ | k r´| | | t | | ƒ ƒ | Sd j | | d | d !d d d g ƒ } d j | | d | | !ƒ }
| | } n‹ | d k rd
} t | | ƒ | k rP| | | t | | ƒ ƒ | Sd } d j | | d | | !ƒ }
| | } n t j d | ƒ | S| j
d | | f |
f ƒ qb W| S( s” 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
RB s [, .]c s' d | | | ˆ f } t j | ƒ d S( Ns¥ RFC3442 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( R Ru ( t cidrt requiredt remaint msg( t rfc3442( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt _trunc_errorR s i i i! i t .i i i i i t 0i i i i s 0.0.0.0sS Parsed invalid net length "%s". Verify DHCP rfc3442-classless-static-routes value.s %s/%s( t rstripRF RL t enumerateRm Rl RI Re R Ru RO ( R– t tokt tokensR" R— t current_idxt idxt
net_lengtht req_tokst net_addresst gateway( ( R– s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyR( 4 sl +
%
(
+
!($ R t loggingR_ RF Rq Rs t
cloudinit.netR R R R t cloudinit.net.network_stateR R' t cloudinitR R t sixR t getLoggerR R R† t ExceptionR R t objectR
R R% RW R> R… RŒ R‘ R( ( ( ( s6 /usr/lib/python2.7/site-packages/cloudinit/net/dhcp.pyt <module> s, " \ J