Name	Size	Mode	Actions
apport.cpython-310.pyc	7317	0644	editdlrm
atomic_helper.cpython-310.pyc	2878	0644	editdlrm
cloud.cpython-310.pyc	3199	0644	editdlrm
dmi.cpython-310.pyc	6310	0644	editdlrm
event.cpython-310.pyc	2076	0644	editdlrm
features.cpython-310.pyc	1668	0644	editdlrm
gpg.cpython-310.pyc	6912	0644	editdlrm
helpers.cpython-310.pyc	13685	0644	editdlrm
importer.cpython-310.pyc	1776	0644	editdlrm
lifecycle.cpython-310.pyc	8384	0644	editdlrm
netinfo.cpython-310.pyc	14066	0644	editdlrm
performance.cpython-310.pyc	3667	0644	editdlrm
persistence.cpython-310.pyc	2931	0644	editdlrm
registry.cpython-310.pyc	1482	0644	editdlrm
safeyaml.cpython-310.pyc	7931	0644	editdlrm
settings.cpython-310.pyc	1185	0644	editdlrm
signal_handler.cpython-310.pyc	2689	0644	editdlrm
simpletable.cpython-310.pyc	2688	0644	editdlrm
socket.cpython-310.pyc	4744	0644	editdlrm
ssh_util.cpython-310.pyc	15815	0644	editdlrm
stages.cpython-310.pyc	27561	0644	editdlrm
subp.cpython-310.pyc	9972	0644	editdlrm
templater.cpython-310.pyc	6374	0644	editdlrm
temp_utils.cpython-310.pyc	2837	0644	editdlrm
type_utils.cpython-310.pyc	471	0644	editdlrm
url_helper.cpython-310.pyc	29151	0644	editdlrm
user_data.cpython-310.pyc	8515	0644	editdlrm
util.cpython-310.pyc	70878	0644	editdlrm
version.cpython-310.pyc	466	0644	editdlrm
warnings.cpython-310.pyc	3376	0644	editdlrm
__init__.cpython-310.pyc	145	0644	editdlrm

o �t�hg�@s~dZd
dl
Z
d
dlZd
dlZd
dlZd
dlmZ
d
dlmZ
d
dl m Z
d
dlmZ
e
� e�
Zdefdd �ZGd d�d�ZdS)z#A module for common socket helpers.�N)
�suppress)
�Dict)
�performance)
�DEFAULT_RUN_DIR�messagec
Cs�tj
�d
d�}
|
sdS|
ddkr|
�ddd�
n |
ddkr#td �
�
t�tjtjtjB��}t � d t|�
�
|�|
�

|� |�d�
�

Wd�
dS1sOw



Y
dS)z[Send a sd_notify message. :param message: sd-notify message (must be valid ascii) � NOTIFY_SOCKET�Nr
�
@�
�
�
/zUnsupported socket typezSending sd_notify(%s)�ascii)�os�environ�get�replace�OSError�socket�AF_UNIX� SOCK_DGRAM�SOCK_CLOEXEC�LOG�info�str�connect�sendall�encode)r�socket_path�sock�r�2/usr/lib/python3/dist-packages/cloudinit/socket.py� sd_notifys

�


"�r!c@s<eZ
dZd
Zdefdd�Zdefdd�Zdd �Zd d�ZdS) � SocketSyncz>s�
��z'SocketSync.__init__..z/sharei�
T)�mode�exist_okz/share/z.sockN)�stage�first_exception�systemd_exit_code�experienced_any_error�sockets�connectionsr�makedirsr�itemsr�FileNotFoundError�remove�bind�listen)�selfr#r&rrrrr �__init__.s"



�


� 
�zSocketSync.__init__r*cCs"|
|jv
rt
d
|
���
�
|
|_|S)a�
Set the stage before entering context. This enables the context manager to be initialized separately from each stage synchronization. :param stage: the name of a stage to synchronize Example: sync = SocketSync("stage 1", "stage 2"): with sync("stage 1"): pass with sync("stage 2"): pass zInvalid stage name: )r.� ValueErrorr*)r6r*rrr �__call__Os 


zSocketSync.__call__c
Cs�t�
tj���
rt�d
�

dSd|_td|j �d��

|j |j }
t�d|j ���
�
|
� �\}}|�d�
\}}||j|j <Wd�
n1sHw



Y
d|krb|�ddd�
td t|�
�d ��
�
td|j �d��

|S) z�Wait until a message has been received on this stage's socket. Once the message has been received, enter the context. z:Stdin is a tty, so skipping stage synchronization protocolNr
zDSTATUS=Waiting on external services to complete before starting the z stage.zWaiting to start stage �sstartzReceived invalid message: [�
]zSTATUS=Running (z stage))r�isatty�sys�stdin�filenorrr,r!r*r.r�Timed�accept�recvfromr/�__exit__r8r)r6r� connection�
_�chunkrrr � __enter__cs,

�



�� 



�

zSocketSync.__enter__cCs�t�
tj���
r d
Sd|j��}|
r6d|_d|_t|�
�d|j ��}d}|j s*||_ t�|�

t d|���

|jp=t|j�
|_|j|j}|�d|�d |j�d ����

|��
dS)z.Notify the socket that this stage is complete.Nz,Completed socket interaction for boot stage rTz in zkfatal error, run "systemctl status cloud-init-main.service" and "cloud-init status --long" for more detailszSTATUS=zecho 'z'; exit �
;)rr<r=r>r?r*r,r-�repr�tb_framer+r�fatalr!�boolr/rr�close)r6�exc_type�exc_val�exc_tbr�statusrrrr rC�s,



�



�
�zSocketSync.__exit__N) �__name__� __module__�__qualname__�__doc__rr7r9rGrCrrrr r"+s
!"r")rU�loggingrrr=� contextlibr�typingr� cloudinitr�cloudinit.settingsr� getLoggerrRrrr!r"rrrr �
s