← Back
Editing: stages.cpython-38.pyc
U Ӈg � � @ s� d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ d dl m Z d dl m Z m Z mZmZmZmZmZmZ d dlmZmZmZmZmZmZmZm Z m Z m Z m Z m Z d dl!m"Z"m#Z# d dl$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/ d d l0m1Z1 d dl2m3Z3 d dl4m5Z5 d dl6m7Z7m8Z8m9Z9m:Z:m;Z; d dl<m=Z= e�>e?�Z@dZAdZBe jCeDe&e%eEd�dd�ZFG dd� d�ZGeHd�dd�ZIdd �eHeDd �d d �ZJdS ) � N)� namedtuple)�suppress)�Path)�Any�Dict�Iterable�List�Optional�Set�Tuple�Union) � atomic_helper�cloud�distros�features�handlers�helpers�importer� lifecycle�net�sources� type_utils�util)�Netv1�Netv2)� EventScope� EventType�userdata_to_events)�BootHookPartHandler)�CloudConfigPartHandler)�JinjaTemplatePartHandler)�ShellScriptPartHandler)� ShellScriptByFreqPartHandler)�cmdline)�events)� CLOUD_CONFIG�DEFAULT_RUN_DIR� PER_ALWAYS� PER_INSTANCE�PER_ONCE)�NetworkConfigSource�NO_PREVIOUS_INSTANCE_IDz�Aggregated cloud-config created by merging merged_system_cfg (/etc/cloud/cloud.cfg and /etc/cloud/cloud.cfg.d), metadata, vendordata and userdata. The combined_cloud_config represents the aggregated desired configuration acted upon by cloud-init.)� datasource�cfg�event_source_type�scope�returnc C s | j }t|�di ��}t�t�|�t�|�g�}tj| j �|t � �kr�t� | j �}|j |d kr�t�d|tj| j �d�� |�|�s�t � ||< || �tj� t�d|� |g}dd� |D �} |D ]*} ||�| g �kr�t�d| j |� d S q�t�d | |� d S ) aA Determine if a particular EventType is enabled. For the `event_source_type` passed in, check whether this EventType is enabled in the `updates` section of the userdata. If `updates` is not enabled in userdata, check if defined as one of the `default_events` on the datasource. `scope` may be used to narrow the check to a particular `EventScope`. Note that on first boot, userdata may NOT be available yet. In this case, we only have the data source's `default_update_events`, so an event that should be enabled in userdata may be denied. Zupdates�scopesz/Adding event: scope=%s EventType=%s found in %szhotplug.enabledzAllowed events: %sc S s g | ] }|j �qS � )�value)�.0�sr2 r2 �2/usr/lib/python3/dist-packages/cloudinit/stages.py� <listcomp>v s z(update_event_enabled.<locals>.<listcomp>z$Event Allowed: scope=%s EventType=%sTz$Event Denied: scopes=%s EventType=%sF)Zdefault_update_eventsr �getr � mergemanydict�copy�deepcopyr ZHOTPLUGZsupported_update_events�setZread_hotplug_enabled_file�pathsr3 �LOG�debug� get_cpath�add) r, r- r. r/ Zdefault_eventsZ user_eventsZallowedZhotplug_enabled_filer1 Z scope_valuesZ evt_scoper2 r2 r6 �update_event_enabledB sT � ��� � � � �rB c @ s e Zd Zdgeee d�dd�Zdd� Zedd� �Z ed d � �Z d d � Z ed d� �Z dd� Z dhdd�Zdd� Zeeeed�dd��Zdd� Zdidd �Zd d � Zed �d d!�Zd"d#� Zd$d%� Zd&d'� Zd(d)� Ze j d*�d+d,�Z d-d.� Z djd/d0�Z ed1�d2d3�Z!d4d5� Z"d6d7� Z#d8d9� Z$dkd;d<�Z%d=d>� Z&d?d@� Z'dAdB� Z(dCdD� Z)dEdF� Z*dGdH� Z+dIdJ� Z,dKdL� Z-dlee.j/ d*�dMdN�Z0dOdP� Z1dQdR� Z2dmdSdT�Z3e4fdUdV�Z5e4fdWdX�Z6e4fdYdZ�Z7e8e9e:df d*�d[d\�Z;e<e8e9e:df e8e=ef f d*�d]d^�Z>d_d`� Z?dadb� Z@eAd*�dcdd�ZBdedf� ZCdS )n�InitN)�ds_depsc C sd |d k r|| _ ntjtjg| _ i | _d | _d | _d | _d| _d | _ |d krZt j dddd�}|| _ d S )NFz init-reporterz init-desc)�name� descriptionZreporting_enabled) rD r ZDEP_FILESYSTEMZ DEP_NETWORK�_cfg�_paths�_distror, � ds_restored� _previous_iidr$ �ReportEventStack�reporter)�selfrD rM r2 r2 r6 �__init__� s �z Init.__init__c C s i | _ d | _d | _d S �N)rG rH rI �rN r2 r2 r6 �_reset� s z Init._resetc C sf | j s`| �d�}|�dd�}t�|�}t�d|� |||| j�| _ | jd k r`| j | j_ | j | j_ | j S )N�system�distroZubuntuzUsing distro class %s) rI � _extract_cfg�popr �fetchr> r? r= r, rT r- Zsys_cfg)rN Z system_configZ distro_nameZ distro_clsr2 r2 r6 rT � s z Init.distroc C s | � d�S )N� restricted)rU rQ r2 r2 r6 r- � s zInit.cfgc C s\ | � � t�| j�}|dkr*|�dd � n.|dkrBt�|di �}n|dkrXt�|di �}|S )NrX � system_inforS )rY r= )rY r= )�read_cfgr: r; rG rV r Zget_cfg_by_path)rN Z restrictionZocfgr2 r2 r6 rU � s zInit._extract_cfgc C s& | j s | �d�}t�|| j�| _ | j S )Nr= )rH rU r �Pathsr, )rN Z path_infor2 r2 r6 r= � s z Init.pathsc C s� | j j}| j j}|tj�|d�tj�|dd�tj�|dd�tj�|dd�tj�|dd�tj�|d�tj�|d�tj�|d�tj�|d �tj�|d �tj�|d �g }|S ) N�scriptsz per-instancezper-oncezper-bootZvendorZseedZ instancesr �sem�data)r= Z cloud_dir�run_dir�os�path�join)rN Zc_dirr_ Z initial_dirsr2 r2 r6 �_initial_subdirs� s �zInit._initial_subdirsFc C s8 | j jg}|r |�| j j� |D ]}t�|� q t|�S rP )r= Z boot_finished�append� instance_linkr �del_file�len)rN Zrm_instance_lnkZrm_list�fr2 r2 r6 � purge_cache� s zInit.purge_cachec C s | � � d S rP )�_initialize_filesystemrQ r2 r2 r6 � initialize� s zInit.initialize)�mode_1�mode_2r0 c C s | |@ S rP r2 )rl rm r2 r2 r6 �_get_strictest_mode� s zInit._get_strictest_modec C s� d}t �| �� � t �| jd�}|r�tt�� | �dt �|��}W 5 Q R X t j ||dd� | j� d�}|sni }t |t �s~|g}d }|D ]P}t � |�\}}zt �|||� W d S tk r� } z|}W 5 d }~X Y q�X q�t�d|d�|�|� d S )Ni� Z def_log_fileF)Z preserve_modeZsyslog_fix_permsz,Failed changing perms on '%s'. tried: %s. %s�,)r � ensure_dirsrc Zget_cfg_option_strr- r �OSErrorrn Zget_permissionsZ ensure_filer8 � isinstance�listZextract_usergroupZ chownbynamer> �warningrb ) rN �modeZlog_fileZperms�errorZperm�u�g�er2 r2 r6 rj � s: � �zInit._initialize_filesystemc C s | j s| �|�| _ d S rP )rG � _read_cfg)rN � extra_fnsr2 r2 r6 rZ s z Init.read_cfgc C sB | � |i �}|�di ��di �}|�d�tdfkr6|S | � ||�S )z read and merge our configurationrY r= r_ N)�_read_bootstrap_cfgr8 r& )rN r{ Zinitial_configr= r2 r2 r6 rz s zInit._read_cfg)�bootstrapped_configc C s< t �|| j�}|�d�}t j|| j|t|j|d�d�}|jS )N�instance_data_sensitive��instance_data_file)r= r, �additional_fns�base_cfg)r r[ r, � get_runpath� ConfigMerger�fetch_base_configr_ r- )rN r{ r} Z no_cfg_pathsr� Zmergerr2 r2 r6 r| + s � ��zInit._read_bootstrap_cfgc C s t �| j�d��S )N�obj_pkl)r Zpkl_loadr= � get_ipath_currQ r2 r2 r6 �_restore_from_cache: s zInit._restore_from_cachec C sL | j d krdS t�| jdd�r6tj| j�d�ddd� t�| j | j�d��S )NFZmanual_cache_cleanZmanual_clean_marker�w� )ZomodeZcontentr� ) r, r �get_cfg_option_boolr- � write_filer= r� r Z pkl_storerQ r2 r2 r6 �_write_to_cache@ s � �zInit._write_to_cachec C sN | j �d�pg }dt�t�fD ]}||kr |�|� q | j �d�pDg }||fS )NZdatasource_pkg_listr� Zdatasource_list)r- r8 r �obj_namer rd )rN �pkg_list�n�cfg_listr2 r2 r6 �_get_datasourcesO s zInit._get_datasourcesc C s� |dkrt d| ��| �� }|s$dS | j�d�}tj�|�rLt�|�� � }nd }||� � krh|d| fS |dkr||d| fS t |d�r�|� | j �r�|d | fS d d | fS d S ) N)�check�trustz!Unexpected value for existing: %s)Nzno cache found� instance_idz&restored from cache with run check: %sr� zrestored from cache: %s�check_instance_idz restored from checked cache: %sz cache invalid in datasource: %s)� ValueErrorr� r= r� r` ra �existsr �load_text_file�strip�get_instance_id�hasattrr� r- )rN �existing�dsZ run_iid_fnZrun_iidr2 r2 r6 �_restore_from_checked_cacheY s$ � z Init._restore_from_checked_cache)r0 c C s2 | j d k r| j S tjdd| | jd��0}| �|�\}}||_t|�| _t� |j� W 5 Q R X |�s zV| � � \}}t � | j | j| jt�| j�||| j�\}}t�| jj� t�d||� W nf t jk �r } zD|dkr�|�| �� }|r�|�� r�t�d|� nt�| jj� |�W 5 d }~X Y nX || _ | �� |S )Nz check-cachez"attempting to read from cache [%s])rE rF �parentzLoaded datasource %s - %sr� z3Restored fallback datasource from checked cache: %s)r, r$ rL rM r� rF �boolrJ r> r? r� r Z find_sourcer- rT r= r: r; rD r rf re �infoZDataSourceNotFoundExceptionr� Z check_if_fallback_is_allowedrR ) rN r� Zmyrepr� Zdescr� r� Zdsnamery r2 r2 r6 �_get_data_sources sP � � �zInit._get_data_sourcec C s dddgS )Nr r\ r] r2 rQ r2 r2 r6 �_get_instance_subdirs� s zInit._get_instance_subdirsc C s | j �|�}|std��|S )NzCNo instance directory is available. Has a datasource been fetched??)r= Z get_ipath� RuntimeError)rN �subnameZ instance_dirr2 r2 r6 � _get_ipath� s �zInit._get_ipath)�netcfgc C s� t j�| jj�sdS | j�d�}| j�d�}t j�|�r^|t� t� |��krnt j ||dd� nt j ||dd� t j�|�s�t� ||� dS )z�Create /var/lib/cloud/instance/network-config.json Only attempt once /var/lib/cloud/instance exists which is created by Init.instancify once a datasource is detected. N�network_config� �ru )r` ra �islinkr= re r� r� r� r � load_jsonr� r � write_json�sym_link)rN r� Zncfg_instance_pathZ network_linkr2 r2 r6 �_write_network_config_json� s � � z Init._write_network_config_jsonc C s� | � � }t| jj��� �� }|t|��� k}|r<t�d� n t� | jj� t� || jj� g }| � � D ]}|� t j�||�� qft�|� | j�d�}dt�| j�| jf }d }t j�|d�} zt�| ��� }W n tk r� Y nX |s�|}t�| d| � t�t j�|d�d| � | j�� } t j�|d�} | �� } t�| d| � t�| j�d�d| � t�t j�|d �d| � | � � |�r�||k�r�t�d � n| � � | S ) Nz0Instance link already exists, not recreating it.r^ z%s: %sr, z%s zprevious-datasource� instance-idr� zprevious-instance-idzJNot re-loading configuration, instance id and datasource have not changed.) r� r r= re ZresolveZabsoluter> r� r rf r� r� rd r` ra rb rp r@ r r� r, r� r� � Exceptionr� r� � previous_iidr� r� rR ) rN �idirZ destinationZalready_instancifiedZdir_list�d�dpr� Z previous_dsZds_fnZiid�iid_fnr� r2 r2 r6 �_reflect_cur_instance� sT � ��zInit._reflect_cur_instancec C sn | j d k r| j S | j�d�}tj�|d�}zt�|��� | _ W n t k rX t | _ Y nX t � d| j � | j S )Nr^ r� zprevious iid found to be %s) rK r= r@ r` ra rb r r� r� r� r+ r> r? )rN r� r� r2 r2 r6 r� s zInit.previous_iidc C s" | � � }|tkp || j�� k}|S )z�Return true if this is a new instance. If datasource has already been initialized, this will return False, even on first boot. )r� r+ r, r� )rN ZpreviousZretr2 r2 r6 �is_new_instance s �zInit.is_new_instancer� c C s | j |d�S )zUoptionally load datasource from cache, otherwise discover datasource )r� )r� )rN r� r2 r2 r6 rW $ s z Init.fetchc C s | � � S rP )r� rQ r2 r2 r6 � instancify* s zInit.instancifyc C s( t j| j| j| j| jt�| j�| jd�S )N)rM ) r ZCloudr, r= r- rT r ZRunnersrM rQ r2 r2 r6 �cloudify- s �z Init.cloudifyc C sp | � | j�� d� | �| j�� d� | �| j�� d� | �| j�� d� | �| j�� d� | �| j� � d� d S )NZuserdata� vendordata� vendordata2) �_store_rawdatar, Zget_userdata_raw�_store_processeddata� get_userdata�_store_raw_vendordata�get_vendordata_raw�get_vendordata�get_vendordata2_raw�get_vendordata2rQ r2 r2 r6 �update8 s$ � � � �z Init.updatec C sF t jdd| jd��* | jd kr&td��| jj| �� d� W 5 Q R X d S )Nzsetup-datasourcezsetting up datasource�r� z!Datasource is None, cannot setup.)r� )r$ rL rM r, r� Zsetupr� rQ r2 r2 r6 �setup_datasourceH s � zInit.setup_datasourcec C sR t jdd| jd��6 | jd kr&td��| jj| j| �� d� | �� W 5 Q R X d S )Nzactivate-datasourcezactivating datasourcer� z$Datasource is None, cannot activate.)r- r� ) r$ rL rM r, r� Zactivater- r� r� rQ r2 r2 r6 �activate_datasourceP s � �zInit.activate_datasourcec C s( |d kr d}t �| �d| �|d� d S )N� z%s_rawr� )r r� r� �rN r^ r, r2 r2 r6 r� ] s zInit._store_rawdatac C sR |d k r.t |�tttfkr.tdtt |�� ��t|t�rBt�|�}| �||� d S )Nz'vendordata_raw is unsupported type '%s') �type�bytes�strrs � TypeErrorrr r Z json_dumpsr� r� r2 r2 r6 r� c s � zInit._store_raw_vendordatac C s( |d kr d}t �| �|�t|�d� d S )Nr� r� )r r� r� r� )rN Zprocessed_datar, r2 r2 r6 r� n s �zInit._store_processeddatac C s� |d kr i }|� | j| jd�� tf |�}tf |�}tf |�}||ttf|�ttf|�tt f|�|t f |d|||gi��g}|S )N)r= r, Z sub_handlers) r� r= r, r r! r r" r' r( r) r )rN �optsZcloudconfig_handlerZshellscript_handlerZboothook_handlerZ def_handlersr2 r2 r6 �_default_handlersv s4 �� ����zInit._default_handlersc C s | j ddd�d�S )N�vendor_scriptsZvendor_cloud_config�Z script_pathZcloud_config_path�r� �r� rQ r2 r2 r6 � _default_vendordata_handlers� s ��z!Init._default_vendordata_handlersc C s | j ddd�d�S )Nr� Zvendor2_cloud_configr� r� r� rQ r2 r2 r6 � _default_vendordata2_handlers� s ��z"Init._default_vendordata2_handlersc s� |dkr g }| j �d�}| �d��|�fD ] }|r*|tjkr*tj�d|� q*� fdd�}t�� � ||� |D ]$}� j|dd�} | rlt � d| |� ql| � � �� ��fd d �} � ����fd d �} � ��fd d�} z| � | |� W 5 | � X dS )zb Generalized handlers suitable for use with either vendordata or userdata Nr r c s� | rt j�| �sd S t�| �}|�� D ]�\}}zjt�|dgddg�\}}|s`t� d|||� W q&t� |d �}t � |�}� � |�}|r�t�d|||� W q& tk r� t�td|� Y q&X q&d S )Nr� Z list_typesZ handle_partzJCould not find a valid user-data handler named %s in file %s (searched %s)r z(Added custom handler for %s [%s] from %sz"Failed to register handler from %s)r` ra �isdirr Zget_modules_from_dir�itemsr � find_moduler> rt � import_moduler Z fixup_handler�registerr? r� �logexc)ra Zpotential_handlers�fname�mod_nameZmod_locsZ looked_locs�mod�types)� c_handlersr2 r6 �register_handlers_in_dir� sD �� � �z3Init._do_handlers.<locals>.register_handlers_in_dirF)Z overwritez$Added default handler for %s from %sc s< � � � D ].\} }|� jkr qt�|��� � j�|� qd S rP )r� � initializedr Z call_beginrd �Z_ctyper� �r� r^ � frequencyr2 r6 � init_handlers� s z(Init._do_handlers.<locals>.init_handlersc s( � ���d| d�}t j�t j|d� d S )Nr )r Z handlerdirr^ r� Z handlercount�excluded)r^ )r �walkZwalker_callback)r� Z part_data�r� r^ �data_msgr� r� r2 r6 � walk_handlers� s � z(Init._do_handlers.<locals>.walk_handlersc sd � � � D ]V\} }|� jkr q� j�|� zt�|��� W q tk r\ t�td|� Y qX qd S )Nz Failed to finalize handler: %s) r� r� �remover Zcall_endr� r r� r> r� r� r2 r6 �finalize_handlers s z,Init._do_handlers.<locals>.finalize_handlers) r= r@ r� �sysra �insertr ZContentHandlersr� r> r? r� ) rN r� �c_handlers_listr� r� �cdirr� r� r� r� r� r� r� r2 r� r6 � _do_handlers� s, # zInit._do_handlersc C s� t jdd| jd��, t�| jdd�r0| �|� n t�d� W 5 Q R X t jdd| jd�� | � d |� W 5 Q R X t jd d | jd�� | � d |� W 5 Q R X | � � t � | j�}t |d < | �d�|d< t�� |d< tj| j�d�|dd� | j�d�}zt�t�|��}W nx ttfk �rB } zt�d||� W Y �d S d }~X Y n> tjt fk �r~ } zt�d||� W Y �d S d }~X Y nX |d |d< |d |d< tj||dd� d S )Nzconsume-user-dataz reading and applying user-datar� Zallow_userdataTz,allow_userdata = False: discarding user-datazconsume-vendor-dataz reading and applying vendor-datar� zconsume-vendor-data2z!reading and applying vendor-data2r� Z_docrS rY r Zcombined_cloud_configr� r� r~ zESkipping write of system_info/features to %s. Unable to read file: %szDSkipping write of system_info/features to %s. Invalid JSON found: %s) r$ rL rM r r� r- �_consume_userdatar> r? �_consume_vendordatarR r: r; �COMBINED_CLOUD_CONFIG_DOCrU r Z get_featuresr r� r= r� r� r� rq �IOErrorrt �jsonZJSONDecodeErrorr� )rN r� Zcombined_cloud_cfgZjson_sensitive_fileZ instance_jsonry r2 r2 r6 � consume_data sp � �� � ��� �zInit.consume_datac C sB |dkr&| j �� s t�d� dS d}n.|dkrL| j �� sFt�d� dS d}ntd��tj| j| j g | j d d �}|j � |i �}t |t �s�d d i}t� d ||� |� d �}|� d d�}t�|�s�t�d|� dS t |t�r�tjd|� d�ddd� t�d||� |dk�r| j �� }| �� } n| j �� }| �� } | j|| ||d� dS )zH Consume the vendordata and run the part handlers on it r� z no vendordata from datasourceNZ vendor_datar� z no vendordata2 from datasourceZ vendor_data2z>vendor_source arg must be either 'vendordata' or 'vendordata2'F)r= r, r� r� Zinclude_vendor�enabledz$invalid %s setting. resetting to: %sZdisabled_handlersz%s consumption is disabled.zUse of string 'z!' for 'vendor_data:enabled' fieldz23.1zUse boolean value instead.)Z deprecatedZdeprecated_versionZ extra_messagez)%s will be consumed. disabled_handlers=%s)r� )r, r� r> r? r� r� r r� rH r- r8 rr �dictrt r Zis_truer� r Z deprecater� r� r� r� r� ) rN Z vendor_sourcer� Zcfg_nameZ _cc_mergerZvdcfgr� Z no_handlersZvendor_data_msgr� r2 r2 r6 r� l sn �� � �� �zInit._consume_vendordatac C s& | j �d�}| �� }| �|||� dS )z@ Consume the userdata and run the part handlers TN)r, r� r� r� )rN r� Z user_data_msgr� r2 r2 r6 r� � s zInit._consume_userdatac C s |rd|kr|d S |S )z� Network configuration can be passed as a dict under a "network" key, or optionally at the top level. In both cases, return the config. �networkr2 )rN r- r2 r2 r6 �_get_network_key_contents� s z Init._get_network_key_contentsc C s0 t j�| j�d�d�}t j�|�r*d |fS tjt� � tj t� � tj d tj | j�d�i}| jrvt| jd�rv| jj|tj < | jr�| jj}ntjj}|D ]r}t|t�s�t�d|� q�||kr�t�d|� q�| �|| �}t�|�r�t� d|� d |f S |r�||f S q�| j�dd��s t�d � | j � � tj fS ) Nr^ zupgraded-networkr� r� z7data source specifies an invalid network cfg_source: %sz;data source specifies an unavailable network cfg_source: %sz network config disabled by %sTzEmpty network config found) r` ra rb r= r@ r� r* ZCMD_LINEr# Zread_kernel_cmdline_configZ INITRAMFSZread_initramfs_configZDSZ SYSTEM_CFGr- r8 r, r� r� Znetwork_config_sourcesr � DataSourcerr r> rt r� r Zis_disabled_cfgr? rT Zgenerate_fallback_configZFALLBACK)rN Z disable_fileZavailable_cfgs�orderZ cfg_sourceZncfgr2 r2 r6 �_find_networking_config� sZ � �� �� �z Init._find_networking_configc C sR z t �d|� | jj�|� W n. tk rL } zt �d|� W 5 d }~X Y nX d S )Nz applying net config names for %sz Failed to rename devices: %s)r> r? rT � networkingZapply_network_config_namesr� rt )rN r� ry r2 r2 r6 �_apply_netcfg_names s zInit._apply_netcfg_namesc C s" t dd�t�| j�d��dtf�S )NZ Semaphorezsemaphore argsr] �apply_network_config)r r ZFileSemaphoresr= r� r) rQ r2 r2 r6 � _get_per_boot_network_semaphore s �z$Init._get_per_boot_network_semaphorec C s | � � }|jj|j� S rP )r � semaphoreZhas_run�args)rN r] r2 r2 r6 �_network_already_configured s z Init._network_already_configuredc s� ddl m}m} ��� \}}|dkr4t�d|� dS �fdd�� � �fdd�}�jdk r���� s�|� s�� tj �s�t� d � �� |� dS ��� \}}�� |� |r�|||j d d d d � �jj�|� �� |� t�d |||� ��� }z8|jj|j� � �jj||d�W 5 Q R � W S Q R X W n\ tjk �rV } zt�d|� W Y �dS d}~X Y n& tk �rz t�d�j� Y dS X dS )z�Apply the network config. Find the config, determine whether to apply it, apply it via the distro, and optionally bring it up r )� SchemaType�validate_cloudconfig_schemaNz network config is disabled by %sc s$ t � j� j| tjd�o"� j�| g�S )N)r, r- r. r/ )rB r, r- r ZNETWORKZ update_metadata_if_supported)Z event_typerQ r2 r6 �"event_enabled_and_metadata_updated( s � �zEInit.apply_network_config.<locals>.event_enabled_and_metadata_updatedc s �� � o� tj�S rP )r r ZBOOTr2 �r rN r2 r6 �should_run_on_boot_event0 s �z;Init.apply_network_config.<locals>.should_run_on_boot_eventzWNo network config applied. Neither a new instance nor datasource network update allowedFT)ZconfigZ schema_type�strictZ log_detailsZlog_deprecationsz5Applying network configuration from %s bringup=%s: %s)�bring_upz@Unable to render networking. Network config is likely broken: %sz_distro '%s' does not implement apply_network_config. networking may not be configured properly.)Zcloudinit.config.schemar r r r> r� r, r� r Z BOOT_LEGACYr? r r� ZNETWORK_CONFIGrT r Zwait_for_physdevsr r �lockr r r ZRendererNotFoundErrorrv �NotImplementedErrorrt ) rN r r r r� �srcr r] ry r2 r r6 r sr ����� � � � ��zInit.apply_network_config)NN)F)N)N)r� )N)N)D�__name__� __module__� __qualname__r r r� rO rR �propertyrT r- rU r= rc ri rk � staticmethod�intrn rj rZ rz r� r| r� r� r� r� r r� r� r� r� r� r� r� r� rW r� r� r� r� r� r� r� r� r ZHandlerr� r� r� r� r( r� r� r� r r r r� r r* r r r r� r r r2 r2 r2 r6 rC � sj % 0 = � v P N � 6rC �r_ c C s t �tj�| d��S )Nz cloud.cfg)r Z read_confr` ra rb r r2 r2 r6 �read_runtime_configt s r r )r_ r0 c C s, t jt �� t jt|d�t| �t �� gdd�S )Nr T)�reverse)r r9 Zget_builtin_cfgZread_conf_with_confdr% r Zread_conf_from_cmdline)r_ r� r2 r2 r6 r� x s �� �r� )Kr: r� Zloggingr` r� � collectionsr � contextlibr �pathlibr �typingr r r r r r r r Z cloudinitr r r r r r r r r r r r Zcloudinit.configr r Zcloudinit.eventr r r Z cloudinit.handlers.boot_hookr Z cloudinit.handlers.cloud_configr Z!cloudinit.handlers.jinja_templater Z cloudinit.handlers.shell_scriptr! Z,cloudinit.handlers.shell_script_by_frequencyr" Z cloudinit.netr# Zcloudinit.reportingr$ Zcloudinit.settingsr% r& r' r( r) Zcloudinit.sourcesr* Z getLoggerr r> r+ r� r� r� r� rB rC r� r r� r2 r2 r2 r6 �<module> sP (8 � � E t
Save File
Cancel