| Server IP : 23.254.227.96 / Your IP : 216.73.216.7 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 : /lib/python3.6/site-packages/cloudinit/reporting/__pycache__/ |
Upload File : |
3
�� b1 � @ s$ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl m Z d dl
m Z d dl
m
Z
mZ d dlmZ e je�ZG dd� de�ZG dd � d e jd
�ZG d d � d e�ZG d
d� de�ZG dd� de�ZG dd� de�Ze� Z e j de� e j de� e j de� e j de� dS )� N)�datetime)�log)�
url_helper�util)� DictRegistryc @ s e Zd ZdS )�ReportExceptionN)�__name__�
__module__� __qualname__� r r � /usr/lib/python3.6/handlers.pyr s r c @ s& e Zd ZdZejdd� �Zdd� ZdS )�ReportingHandlerz�Base class for report handlers.
Implement :meth:`~publish_event` for controlling what
the handler does with an event.
c C s dS )zPublish an event.Nr )�self�eventr r r �
publish_event s z ReportingHandler.publish_eventc C s dS )z0Ensure ReportingHandler has published all eventsNr )r r r r �flush$ s zReportingHandler.flushN)r r r
�__doc__�abc�abstractmethodr r r r r r r
s r
)� metaclassc s* e Zd ZdZd� fdd� Zdd� Z� ZS )�
LogHandlerzBPublishes events to the cloud-init log at the ``DEBUG`` log level.�DEBUGc sb t t| �j� t|t�rn>|}ytt|j� �}W n& tk
rV t j
d|� tj }Y nX || _ d S )Nz invalid level '%s', using WARN)
�superr �__init__�
isinstance�int�getattr�logging�upper� Exception�LOG�warningZWARN�level)r r" Z input_level)� __class__r r r + s
zLogHandler.__init__c C s2 t jdjdd|j|jg��}|j| j|j� � d S )N�.� cloudinitZ reporting)r � getLogger�join�
event_type�namer r" � as_string)r r Zloggerr r r r 8 s zLogHandler.publish_event)r )r r r
r r r �
__classcell__r r )r# r r ( s
r c @ s e Zd ZdZdd� ZdS )� PrintHandlerz Print the event as a string.c C s t |j� � d S )N)�printr* )r r r r r r B s zPrintHandler.publish_eventN)r r r
r r r r r r r, ? s r, c s& e Zd Zd� fdd� Zdd� Z� ZS )�WebHookHandlerNc sZ t t| �j� t||||g�r4tj||||d�| _nd | _|| _|| _|| _ t
j � | _ d S )N)� consumer_key� token_key� token_secret�consumer_secret)
r r. r �anyr ZOauthUrlHelper� oauth_helper�endpoint�timeout�retriesr Zfetch_ssl_details� ssl_details)r r5 r/ r0 r1 r2 r6 r7 )r# r r r G s
zWebHookHandler.__init__c
C sd | j r| j j}ntj}y$|| jtj|j� �| j| j| j d�S t
k
r^ t j d|j
� � Y nX d S )N)�datar6 r7 r8 zfailed posting event: %s)r4 �readurlr r5 �json�dumpsZas_dictr6 r7 r8 r r r! r* )r r r: r r r r a s
z WebHookHandler.publish_event)NNNNNN)r r r
r r r+ r r )r# r r. F s r. c s� e Zd ZdZdZdZdZee ZdZdZ dZ
dZ d(Z d Z
d Ze
d
f� fdd� Zedd� �Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Z � Z S ))�HyperVKvpReportingHandlera,
Reports events to a Hyper-V host using Key-Value-Pair exchange protocol
and can be used to obtain high level diagnostic information from the host.
To use this facility, the KVP user-space daemon (hv_kvp_daemon) has to be
running. It reads the kvp_file when the host requests the guest to
enumerate the KVP's.
This reporter collates all events for a module (origin|name) in a single
json string in the dictionary.
For more information, see
https://technet.microsoft.com/en-us/library/dn798287.aspx#Linux%20guests
i i i Z
CLOUD_INIT�msg�resultZmsg_i�,�:z/var/lib/hyperv/.kvp_pool_1FNc sr t t| �j� || _tj| j� || _tj� | _| j � | _
dj | j | j
�| _
tj| jd�| _d| j_| jj� d S )Nz{0}|{1})�targetT)r r= r �_kvp_file_path�_truncate_guest_pool_file� _event_types�queueZQueue�q�_get_incarnation_noZincarnation_no�format� EVENT_PREFIX�event_key_prefix� threadingZThread�_publish_event_routineZpublish_threadZdaemon�start)r Z
kvp_file_pathZ event_types)r# r r r � s
z"HyperVKvpReportingHandler.__init__c C s� | j r
dS tj� ttj� � }zby*tjj|�|k rHt|d�� W dQ R X W n2 t t
fk
r| } zt j d|� W Y dd}~X nX W dd| _ X dS )a
Truncate the pool file if it has not been truncated since boot.
This should be done exactly once for the file indicated by
KVP_POOL_FILE_GUEST constant above. This method takes a filename
so that we can use an arbitrary file during unit testing.
Since KVP is a best-effort telemetry channel we only attempt to
truncate the file once and only if the file has not been modified
since boot. Additional truncation can lead to loss of existing
KVPs.
N�wz$failed to truncate kvp pool file, %sT)
� _already_truncated_pool_file�time�floatr �uptime�os�path�getmtime�open�OSError�IOErrorr r! )�clsZkvp_fileZ boot_time�er r r rD � s "z3HyperVKvpReportingHandler._truncate_guest_pool_filec C sB t j� }yttj� t|� �S tk
r< tjd|� dS X dS )z�
use the time passed as the incarnation number.
the incarnation number is the number which are used to
distinguish the old data stored in kvp and the new data.
z"uptime '%s' not in correct format.r N)r rS r rQ rR �
ValueErrorr r! )r Z
uptime_strr r r rH � s z-HyperVKvpReportingHandler._get_incarnation_noc
c s~ t | jd��h}tj|tj� |j|� |j| j�}x.t|�| jkr`| j |�}|V |j| j�}q4W tj|tj
� W dQ R X dS )z-iterate the kvp file from the current offset.�rbN) rW rC �fcntl�flock�LOCK_EX�seek�read�HV_KVP_RECORD_SIZE�len�_decode_kvp_item�LOCK_UN)r �offset�f� record_dataZkvp_itemr r r �
_iterate_kvps� s
z'HyperVKvpReportingHandler._iterate_kvpsc C s dj | j|j|jtj� �S )z�
the event key format is:
CLOUD_INIT|<incarnation number>|<event_type>|<event_name>|<uuid>
[|subevent_index]
z{0}|{1}|{2}|{3})rI rK r( r) �uuidZuuid4)r r r r r �
_event_key� s z$HyperVKvpReportingHandler._event_keyc C s* t jd| j| jf |jd�|jd��}|S )Nz%ds%dszutf-8)�struct�pack� HV_KVP_EXCHANGE_MAX_KEY_SIZE� HV_KVP_EXCHANGE_MAX_VALUE_SIZE�encode)r �key�valuer9 r r r �_encode_kvp_item� s z*HyperVKvpReportingHandler._encode_kvp_itemc C sd t |�}|| jkr$tdj|| j���|d| j� jd�jd�}|| j| j� jd�jd�}||d�S )Nz$record_data len not correct {0} {1}.r zutf-8� )rr rs )rd rc r rI ro �decode�strip)r ri Zrecord_data_len�k�vr r r re � s
z*HyperVKvpReportingHandler._decode_kvp_itemc
C sX t | jd��B}tj|tj� x|D ]}|j|� q"W |j� tj|tj� W d Q R X d S )NZab)rW rC r^ r_ r` �writer rf )r ri rh r9 r r r �_append_kvp_item s
z*HyperVKvpReportingHandler._append_kvp_itemc C s� || j = tj|�}|dt|�d � }d}g }d| j d }x�||| j< d|| j < tj|| jd�}| jt|� d } |j|dj| j |d | � d ��}
d
j||�} |j | j
| |
�� |d7 }|| d � }t|�dkr>P q>W |S ) N� r �"z":""� )�
separators� z"{key}":"{desc}")rr Zdescz{}|{}) �MSG_KEYr; r< rd � DESC_IDX_KEY�JSON_SEPARATORS�HV_KVP_AZURE_MAX_VALUE_SIZE�replacerI �appendrt ) r rr � meta_data� descriptionZ des_in_json�iZ result_arrayZmessage_place_holderZdata_without_descZ
room_for_descrs Zsubkeyr r r � _break_down
s.
z%HyperVKvpReportingHandler._break_downc C s� | j |�}|j|jtj|j�j� d d�}t|| j�rB|j || j< |j
|| j < t j
|| jd�}t|�| jkr|| j|||j
�S | j||�}|gS dS )z�
encode the event into kvp data bytes.
if the event content reaches the maximum length of kvp value.
then it would be cut to multiple slices.
�Z)r) �typeZts)r N)rl r) r( r ZutcfromtimestampZ timestampZ isoformat�hasattr�
RESULT_KEYr? r� r� r; r< r� rd r� r� rt )r r rr r� rs r9 r r r �
_encode_event( s
z'HyperVKvpReportingHandler._encode_eventc C s� x�d}y�| j jdd�}|d7 }g }xP|d k rr|| j|�7 }y| j jdd�}|d7 }W q$ tjk
rn d }Y q$X q$W zFy| j|� W n2 ttfk
r� } ztj d|� W Y d d }~X nX W d xt
|�D ]}| j j � q�W X W q t k
r� d S X qW d S )Nr T)�blockr| Fz failed posting events to kvp, %s)
rG �getr� rF ZEmptyr{ rX rY r r! �rangeZ task_done�EOFError)r Zitems_from_queuer Z encoded_datar[ �_r r r rM C s*
"z0HyperVKvpReportingHandler._publish_event_routinec C s$ | j s|j| j kr | jj|� d S )N)rE r( rG Zput)r r r r r r a s z'HyperVKvpReportingHandler.publish_eventc C s t jd� | jj� d S )Nz0HyperVReportingHandler flushing remaining events)r �debugrG r' )r r r r r e s
z HyperVKvpReportingHandler.flush)r@ rA ) r r r
r rp r� ro rc rJ r� r� r� r� ZKVP_POOL_FILE_GUESTrP r � classmethodrD rH rj rl rt re r{ r� r� rM r r r+ r r )r# r r= r s2
r= r r- ZwebhookZhyperv) r r^ r; rT rF rm rL rQ rk r r% r r r r Zcloudinit.registryr r& r r r r �ABCMetar
r r, r. r= Zavailable_handlersZ
register_itemr r r r �<module> s2
, y