| Server IP : 23.254.227.96 / Your IP : 216.73.216.183 Web Server : Apache/2.4.62 (Unix) OpenSSL/1.1.1k System : Linux hwsrv-1277026.hostwindsdns.com 4.18.0-477.13.1.el8_8.x86_64 #1 SMP Tue May 30 14:53:41 EDT 2023 x86_64 User : viralblo ( 1001) PHP Version : 8.1.31 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3.6/site-packages/cloudinit/cmd/devel/__pycache__/ |
Upload File : |
3
�� bH# � @ s, d Z ddlZddlZddlZddlZddlZddlmZmZm Z ddl
m Z m Z ddl
mZmZ ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ eje�Zd Z d d d
�Z G dd� dej �Z G dd� de �Z de e j!fiZ"dd� Z#dd� Z$ed�dd�Z%dd� Z&ed k�r(e � j'� Z(e&e e(� dS ) z(Handle reconfiguration on hotplug events� N)�log� reporting�stages)�
EventScope� EventType)�
activators�read_sys_net_safe)�parse_net_config_data)�events)�
DataSource)�DataSourceNotFoundException)�Initz hotplug-hookc C s� | st jttd�} t| _| jdddddgd� | jdd d
�}d|_|jd d d
� |jddd
�}|jdddddd� |jddddddgd� | S )a Build or extend an arg parser for hotplug-hook utility.
@param parser: Optional existing ArgumentParser instance representing the
subcommand which will be extended to support the args of this utility.
@returns: ArgumentParser with proper argument configuration.
)�prog� descriptionz-sz --subsystemTzsubsystem to act on�net)�required�help�choiceszHotplug Action�hotplug_action)�title�dest�queryz/query if hotplug is enabled for given subsystem)r Zhandlezhandle the hotplug eventz-dz --devpath�PATHz sysfs path to hotplugged device)r �metavarr z-uz --udevactionzaction to take�add�remove) �argparse�ArgumentParser�NAME�__doc__r � add_argumentZadd_subparsersr Z
add_parser)�parserZ
subparsersZ
parser_handle� r" �"/usr/lib/python3.6/hotplug_hook.py�
get_parser s:
r$ c @ s` e Zd Zdd� Zejdd� �Zeejdd� ��Zeje d�dd ��Z
d
d � Z d d
� Z dd� Z
dS )�
UeventHandlerc C s" || _ || _|| _|| _|| _d S )N)�id�
datasource�devpath�action�
success_fn)�selfr& r' r( r) r* r" r" r# �__init__I s
zUeventHandler.__init__c C s
t � �d S )N)�NotImplementedError)r+ r" r" r# �applyP s zUeventHandler.applyc C s
t � �d S )N)r- )r+ r" r" r# �configT s zUeventHandler.config)�returnc C s
t � �d S )N)r- )r+ r" r" r# �device_detectedY s z UeventHandler.device_detectedc C sP d }| j dkrd}n | j dkr$d}ntd| j ��|| j� krLtd| j ��d S )Nr Tr FzUnknown action: %sz'Failed to detect %s in updated metadata)r) �
ValueErrorr1 � RuntimeErrorr& )r+ Zdetect_presencer" r" r# �detect_hotplugged_device] s
z&UeventHandler.detect_hotplugged_devicec C s | j � S )N)r* )r+ r" r" r# �successk s zUeventHandler.successc C s, | j jtjg�}|s(td| j tjf ��|S )Nz&Datasource %s not updated for event %s)r' Z update_metadata_if_supportedr �HOTPLUGr3 )r+ �resultr" r" r# �update_metadatan s
z UeventHandler.update_metadataN)�__name__�
__module__� __qualname__r, �abc�abstractmethodr. �propertyr/ �boolr1 r4 r5 r8 r" r" r" r# r% H s r% c s> e Zd Z� fdd�Zdd� Zedd� �Zed�dd �Z� Z S )
�
NetHandlerc s* t tjj|�d�}t� j|||||� d S )NZaddress)r �os�path�basename�superr, )r+ r' r( r) r* r& )� __class__r" r# r, { s zNetHandler.__init__c C sx | j jj| jdd� tjj| j�}tj � }| j
dkrP|j |�stt dj
| j���n$| j
dkrt|j|�stt dj
| j���d S )NF)Zbring_upr z Failed to bring up device: {}r z Failed to bring down device: {})r' ZdistroZapply_network_configr/ rA rB rC r( r Zselect_activatorr) Zbring_up_interfacer3 �formatZbring_down_interface)r+ Zinterface_nameZ activatorr" r" r# r. � s
zNetHandler.applyc C s | j jS )N)r' Znetwork_config)r+ r" r" r# r/ � s zNetHandler.config)r0 c s< t � j�}� fdd�|j� D �}tjd� j|� t|�dkS )Nc s g | ]}|j d �� jkr|�qS )Z mac_address)�getr& )�.0Ziface)r+ r" r# �
<listcomp>� s z.NetHandler.device_detected.<locals>.<listcomp>zIfaces with ID=%s : %sr )r r/ Ziter_interfaces�LOG�debugr& �len)r+ Znetstate�foundr" )r+ r# r1 � s
zNetHandler.device_detected)
r9 r: r; r, r. r> r/ r? r1 �
__classcell__r" r" )rE r# r@ z s r@ r c C s\ yt | d }W n2 tk
rB } ztdj|��|�W Y d d }~X nX tj| j| jtj |d�S )N� z4hotplug-hook: cannot handle events for subsystem: {})r' �cfgZevent_source_type�scope)
�SUBSYSTEM_PROPERTES_MAP�KeyError� ExceptionrF r Zupdate_event_enabledr' rP r r6 )� hotplug_init� subsystemrQ �er" r" r# �
is_enabled� s rX c C sR t jd� | jdd�}|jtjg�s4t jd|� d S t| |�sNt jd|� d S |S )NzFetching datasourceZtrust)Zexistingz*hotplug not supported for event of type %sz(hotplug not enabled for event of type %s)rJ rK ZfetchZget_supported_eventsr r6 rX )rU rV r' r" r" r# �initialize_datasource� s
rY )rU c C s t | |�}|sd S t| d }tjd|� ||||| jd�}dddddg}x�t|�D ]�\}} tjd ||t|�� yNtjd
� |j� tjd � |j� tjd � |j � tjd
� |j
� P W qT t k
r� }
z tjd|
� t j
| � |
} W Y d d }
~
X qTX qTW | �d S )Nr zCreating %s event handler)r' r( r) r* rO � � �
� z!subsystem=%s update attempt %s/%szRefreshing metadataz$Detecting device in updated metadatazApplying config changezUpdating cachez,Exception while processing hotplug event. %s)rY rR rJ rK Z_write_to_cache� enumeraterL r8 r4 r. r5 rT �timeZsleep) rU r( rV �
udevactionr' Z handler_clsZ
event_handlerZ
wait_timesZattempt�waitrW Zlast_exceptionr" r" r# �handle_hotplug� s@
rb c C s8 t j| tdd�}tg |d�}|j� tj|j� d|jkrLtj |jj
d�� t j d| |j
|jd|krj|jnd d|krz|jnd � |�� yn|j
dkr�yt||j�}W n& tk
r� td � tjd
� Y nX t|r�d nd � nt||j|j|jd
� W n" tk
�r t jd� � Y nX W d Q R X t j d� tj� d S )NT)Zreporting_enabled)Zds_depsZreporterr zh%s called with the following arguments: {hotplug_action: %s, subsystem: %s, udevaction: %s, devpath: %s}r` r( r z9Unable to determine hotplug state. No datasource detectedrO ZenabledZdisabled)rU r( rV r` z*Received fatal exception handling hotplug!zExiting hotplug handler)r
ZReportEventStackr r
Zread_cfgr Z setupLoggingrP r Zupdate_configurationrG rJ rK r rV r` r( rY r �print�sys�exitrb rT Z exceptionZ flush_events)�name�argsZhotplug_reporterrU r' r" r" r# � handle_args� sF
rh �__main__)N))r r< r rA rd r_ Z cloudinitr r r Zcloudinit.eventr r Z
cloudinit.netr r Zcloudinit.net.network_stater Zcloudinit.reportingr
Zcloudinit.sourcesr r Zcloudinit.stagesr
Z getLoggerr9 rJ r r$ �ABCr% r@ ZNETWORKrR rX rY rb rh �
parse_argsrg r" r" r" r# �<module> s4
22(&5