Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/pyipmi/interfaces/__pycache__/rmcp.cpython-39.pyc
Ðазад
a ]�h�Y � @ sP d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ ddlm Z ddl m Z ddl m Z mZmZmZmZ ddlmZ dd lmZmZmZ dd lmZ dd lmZm Z m Z m Z m Z dd l m!Z!m"Z"m#Z# d Z$d Z%dZ&dZ'dZ(dd� Z)G dd� de*�Z+G dd� de*�Z,G dd� de,�Z-G dd� de,�Z.G dd � d e*�Z/G d d � d e*�Z0dS ) � N)�array)�Queue� )�Target)�Session)�create_message�create_request_by_name�encode_message�decode_message� constants)�!ChannelAuthenticationCapabilities)� DecodingError�NotSupportedError� RetryError)�log)� IpmbHeaderReq�encode_ipmb_msg�encode_bridged_message�decode_bridged_message� rx_filter)�check_completion_code�check_rsp_completion_code�py3_array_tobytes� � � � c s: t �� �� ���fdd�}t j|d�}d|_|�� �jS )Nc s2 �� ��s.z �� � W q tjy* Y q 0 q d S �N)�wait�socket�timeout� ��args�func�interval�stoppedr! ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/pyipmi/interfaces/rmcp.py�loop2 s z call_repeatedly.<locals>.loop)�targetT)� threading�Event�Thread�daemon�start�set)r% r$ r# r( �tr! r" r' �call_repeatedly/ s r1 c @ s: e Zd ZdZdZdZdZdZd dd�Zdd� Z dd � Z dS ) �RmcpMsgz!BxBBr Nc C s |d ur|| _ d S r )� class_of_msg)�selfr3 r! r! r' �__init__H s zRmcpMsg.__init__c C s* t �| j| j|| j�}|d ur&||7 }|S r )�struct�pack�RMCP_HEADER_FORMAT�ASF_RMCP_V_1_0r3 )r4 �sdu� seq_number�pdur! r! r' r7 L s �z RmcpMsg.packc C sV t �| j�}|d |� }t �| j|�\| _| _| _||d � }| j| jkrRtd��|S )Nzinvalid RMCP version field) r6 �calcsizer8 �unpack�versionr; r3 r9 r )r4 r< � header_len�headerr: r! r! r' r> S s � zRmcpMsg.unpack)N) �__name__� __module__� __qualname__r8 r9 r? r; r3 r5 r7 r> r! r! r! r' r2 A s r2 c @ sH e Zd ZdZdZdZdZdd� Zdd� Zd d � Z d d � Z e d d� �Z dS )�AsfMsgz!IBBxB�@ r r c C s d| _ d| _d | _d | _d S �N� r )�iana_enterprise_number�tag�datar: �r4 r! r! r' r5 h s zAsfMsg.__init__c C sD | j rt| j �}nd}t�| j| j| j| j|�}| j r@|| j 7 }|S )Nr )rK �lenr6 r7 �ASF_HEADER_FORMATrI �asf_typerJ )r4 �data_lenr< r! r! r' r7 n s � z AsfMsg.packc C s� || _ t�| j�}|d |� }t�| j|�\| _| _| _}t|�|| k rTt d��nt|�|| krlt d��|dkr�|||| � | _ nd | _ t | d�r�| � � d S )N� short SDUzSDU has extra bytesr � check_header) r: r6 r= rN r> rI rO rJ rM r rK �hasattrrR )r4 r: r@ rA rP r! r! r' r> ~ s � z AsfMsg.unpackc C sH | j r"d�dd� td| j �D ��S | jrDd�dd� td| j�D ��S dS )N� c s s | ]}d | V qdS �z%02xNr! ��.0�br! r! r' � <genexpr>� � z!AsfMsg.__str__.<locals>.<genexpr>�Bc s s | ]}d | V qdS rU r! rV r! r! r' rY � rZ � )rK �joinr r: rL r! r! r' �__str__� s zAsfMsg.__str__c C sd t � }|�| � z t � jtt � jti|j }W n tyN td|j ��Y n0 |� }|�| � |S )Nz Unsupported ASF type(0x%02x)) rE r> �ASF_TYPE_PRESENCE_PING�AsfPing�ASF_TYPE_PRESENCE_PONG�AsfPongrO �KeyErrorr )r: Zasf�cls�instancer! r! r' � from_data� s �� zAsfMsg.from_dataN) rB rC rD rN ra r_ rO r5 r7 r> r^ � staticmethodrf r! r! r! r' rE ` s rE c s, e Zd Zdd� Zdd� Z� fdd�Z� ZS )r` c C s t �| � | j| _d S r )rE r5 r_ rO rL r! r! r' r5 � s zAsfPing.__init__c C s& | j | jkrtd��| jr"td��d S )N�type does not matchzData length is not zero)rO r_ r rK rL r! r! r' rR � s zAsfPing.check_headerc s dt t| ��� S )Nzping: )�superrE r^ rL �� __class__r! r' r^ � s zAsfPing.__str__)rB rC rD r5 rR r^ � __classcell__r! r! rj r' r` � s r` c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd S ) rb z!IIBB6xc C s$ | j | _d| _d| _d| _d| _d S rG )ra rO �oem_iana_enterprise_number� oem_defined�supported_entities�supported_interactionsrL r! r! r' r5 � s zAsfPong.__init__c C s t �| j| j| j| j| j�}|S r )r6 r7 � DATA_FORMATrm rn ro rp )r4 r< r! r! r' r7 � s �z AsfPong.packc C s8 t �| |� t�| j| j�\| _| _| _| _| � � d S r ) rE r> r6 rq rK rm rn ro rp � check_data)r4 r: r! r! r' r> � s � zAsfPong.unpackc C s2 | j dkr | jdkr td��| jdkr.td��d S )NrH r z SDU malformed)rm rn r rp rL r! r! r' rr � s zAsfPong.check_datac C s6 | j | jkrtd��t| j�t�| j�kr2td��d S )Nrh zData length mismatch)rO ra r rM rK r6 r= rq rL r! r! r' rR � s zAsfPong.check_headerN) rB rC rD rq r5 r7 r> rr rR r! r! r! r' rb � s rb c @ sf e Zd ZdZdZddd�Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� ZdS )�IpmiMsgz!BIIBz!BII16BBNFc C s || _ || _d S r )�session�ignore_sdu_length)r4 rt ru r! r! r' r5 � s zIpmiMsg.__init__c C s0 | j d ur| j j}nd}t�dt�d|��d S �Nr z<Iz>I)rt �sidr6 r> r7 )r4 � session_idr! r! r' �_pack_session_id� s zIpmiMsg._pack_session_idc C s0 | j d ur| j j}nd}t�dt�d|��d S rv )rt �sequence_numberr6 r> r7 )r4 �seqr! r! r' �_pack_sequence_number� s z IpmiMsg._pack_sequence_numberc C s( | j j}t|t�r t�|�}|�dd�S )z}Padd the password. The password/key is 0 padded to 16-bytes for all specified authentication types. � � )rt Z_auth_password� isinstance�str�encode�ljust)r4 �passwordr! r! r' �_padd_password� s zIpmiMsg._padd_passwordc C s | � � S )z#Return the auth code as bytestring.)r� rL r! r! r' �_pack_auth_code_straight s z IpmiMsg._pack_auth_code_straightc C s: t �dt|� | �� | �� || �� | �� �}t�|��� S )Nz>16s I %ds I 16s) r6 r7 rM r� ry r| �hashlib�md5�digest)r4 r: � auth_coder! r! r' �_pack_auth_code_md5 s �zIpmiMsg._pack_auth_code_md5c C s� |d urt |�}nd}| jd ur<| jj}| jjrB| j�� ntj}t�d|| � � | � � �}|tjkrfn>|tj kr~|| � � 7 }n&|tj kr�|| �|�7 }n td| ��|ttd|g��7 }|d ur�||7 }|S )Nr z!BIIzauthentication type %sr[ )rM rt � auth_type� activatedZincrement_sequence_numberr ZAUTH_TYPE_NONEr6 r7 r| ry ZAUTH_TYPE_PASSWORDr� Z AUTH_TYPE_MD5r� r r r )r4 r: rP r� r< r! r! r' r7 s0 � z IpmiMsg.packc C s� t d|�d }|dkr�t�| j�}|d |� }t d|�d | _t�d|dd� �\| _t�d|dd� �\| _dd� t�d |dd � �D �| _t d|�d }n4t�| j �}|d |� }t�| j |�\| _| _| _}| j �s t |�|| k r�t d ��n(t |�|| k�r t d � t |�||���t| d ��r0| �� | j �sZ|dk�rT|||| � }nd }n<z"||d � }|dk�rvd n|}W n t�y� d }Y n0 |S )Nr[ r z!I� � � c S s g | ]}|�qS r! r! )rW �ar! r! r' � <listcomp>> rZ z"IpmiMsg.unpack.<locals>.<listcomp>z!16B� rQ z%SDU has extra bytes ({:d},{:d},{:d} )rR rZ )r r6 r= �HEADER_FORMAT_AUTHr� r> rz rx r� �HEADER_FORMAT_NO_AUTHru rM r �formatrS rR � IndexError)r4 r< r� r@ rA rP r: r! r! r' r> 4 sF � �� zIpmiMsg.unpackc C s d S r r! rL r! r! r' rr _ s zIpmiMsg.check_datac C s d S r r! rL r! r! r' rR b s zIpmiMsg.check_header)NF)rB rC rD r� r� r5 ry r| r� r� r� r7 r> rr rR r! r! r! r' rs � s "+rs c @ s� e Zd ZdZdZdddde� fdd�Zd d � Zd d � Zd d� Z dd� Z d0dd�Z dd� Z dd� Z dd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� ZdS )1�Rmcp�rmcpN� � r� r c C s� d| _ d| _t�tjtj�| _d| _|| _t|�| _ || _ | � d� d| _ || _ d| _t� | _t�� | _|| _|�dd�| _|�dd�| _dS )a& Native RMCP interface constructor Parameter `quirks_cfg`: a dict of additional configuration parameters for the RMCP object. Supported keys/values are : - `rmcp_ignore_sdu_length: bool` whether or not to verify the SDU length of a received IPMI message. If absent or `False` (default), an exception will be raised if there is a mismatch between the received SDU length and the value stored in `payload_length` field of the PDU header. If `True`, ignore the header field `payload_length` and unpack the PDU anyway. Example: interfaces.create_interface( interface="rmcp", quirks_cfg={'rmcp_ignore_sdu_length': True} ) - `rmcp_ignore_rq_seq: bool` wheater or not to verify the req_seq field for rx_filter. The default value is `False`. Example: interfaces.create_interface( interface="rmcp", quirks_cfg={'rmcp_ignore_rq_seq': True} ) N� g @r Zrmcp_ignore_sdu_lengthFZrmcp_ignore_rq_seq)�host�portr �AF_INET� SOCK_DGRAM�_sockr; � slave_addressr � host_target� max_retries� set_timeout�next_sequence_number�keep_alive_interval�_stop_keep_aliver �_qr* �Lock�transaction_lock� quirks_cfg�getru � ignore_rq_seq)r4 r� Zhost_target_addressr� r� r� r! r! r' r5 k s z Rmcp.__init__c C sJ t |�}|�|| j�}| j�|| j| jf� | jdkrF| jd d | _d S )Nr� r� � )r2 r7 r; r� �sendtor� r� )r4 r: r3 r� r< r! r! r' �_send_rmcp_msg� s zRmcp._send_rmcp_msgc C s. | j �d�\}}t� }|�|�}|j|j|fS )Ni )r� �recvfromr2 r> r; r3 )r4 r< �_r� r: r! r! r' �_receive_rmcp_msg� s zRmcp._receive_rmcp_msgc C s | j �|� d S r )r� � settimeout)r4 r r! r! r' r� � s zRmcp.set_timeoutc C sL t � �d�d�dd� td|�D ���� t| j�}|�|�}| �|t � d S )Nz IPMI TX: {:s}rT c s s | ]}d | V qdS rU r! rV r! r! r' rY � rZ z&Rmcp._send_ipmi_msg.<locals>.<genexpr>r[ ) r �debugr� r] r rs �_sessionr7 r� �RMCP_CLASS_IPMI)r4 rK Zipmi�tx_datar! r! r' �_send_ipmi_msg� s � zRmcp._send_ipmi_msgFc C s^ | � � \}}}|tkr td��t|d�}|�|�}t� �d�d�dd� t d|�D ���� |S )N�"invalid class field in ASF message)ru z IPMI RX: {:s}rT c s s | ]}d | V qdS rU r! rV r! r! r' rY � rZ z)Rmcp._receive_ipmi_msg.<locals>.<genexpr>r[ ) r� r� r rs r> r r� r� r] r )r4 ru r� r3 r< �msgrK r! r! r' �_receive_ipmi_msg� s �zRmcp._receive_ipmi_msgc C s t � �d� | �|�� t� d S )Nz ASF TX: msg)r r� r� r7 �RMCP_CLASS_ASF)r4 r� r! r! r' � _send_asf_msg� s zRmcp._send_asf_msgc C s> | � � \}}}t� �d� |tkr*td��|� }|�|� |S )Nz ASF RX: msgr� )r� r r� r� r r> )r4 rd r� r3 rK r� r! r! r' �_receive_asf_msg� s zRmcp._receive_asf_msgc C s t � }| �|� | �t� d S r )r` r� r� rb )r4 �pingr! r! r' r� � s z Rmcp.pingc C sF d}t d�}| j|_||j_|j|j_| �|�}t |j � t |�}|S )N� Z$GetChannelAuthenticationCapabilities) r r� r) Zchannel�number� priv_level�privilege_level� requested�send_and_receiver �completion_coder )r4 rt ZCHANNEL_NUMBER_FOR_THIS�req�rsp�capsr! r! r' �_get_channel_auth_cap� s zRmcp._get_channel_auth_capc C sF t d�}| j|_|j|j_|jr0|j�dd�|_| � |�}t |� |S )NZGetSessionChallenger} � ) r r� r) r� �authentication�typeZ_auth_usernamer� Z user_namer� r )r4 rt r� r� r! r! r' �_get_session_challenge� s zRmcp._get_session_challengec C sX t d�}| j|_|j|j_|j|j_||_ | j j |_ t �dd�|_| �|�}t|� |S )NZActivateSessionr� l �� )r r� r) r� r� r� r� r� Zmaximum_requested�challenge_stringr� rw rx �random� randrangeZ initial_outbound_sequence_numberr� r )r4 rt � challenger� r� r! r! r' �_activate_session� s zRmcp._activate_sessionc C s. t d�}| j|_||j_| �|�}t|� |S )NZSetSessionPrivilegeLevel)r r� r) r� r� r� r )r4 �levelr� r� r! r! r' � _set_session_privilege_level� s z!Rmcp._set_session_privilege_levelc C s( t d�}| j|_| �|�}t|j� d S )NZ GetDeviceId)r r� r) r� r r� �r4 r� r� r! r! r' �_get_device_id� s zRmcp._get_device_idc C s� d | _ |j| _|j| _| �� t� �d� | �|�}t� �d| � t� �d� |� � |_ | � |�}|j }|j |_|| _ t� �d� | �||�}|j| j _|j| j _d| j _t� �d� | �|j� t� �d� | jr�t| j| j�| _d S )Nz'Get Channel Authentication Capabilitiesz%szGet Session ChallengezActivate SessionTzSet Session Privilege LevelzSession opened)r� Z _rmcp_hostr� Z _rmcp_portr� r� r r� r� Zget_max_auth_typer� r� r� Ztemporary_session_idrw r� rx Z initial_inbound_sequence_numberrz r� r� r� r� r1 r� r� )r4 rt r� r� Zsession_challenger! r! r' �establish_session s2 �zRmcp.establish_sessionc C sv | j r| � � | jjdu r*t� �d� d S t� �d| j � td�}| j|_| jj|_ | � |�}t |j � d| j_d S )NFzSession already closedzClose Session %sZ CloseSession) r� r� r� r r� r r� r) rw rx r� r r� r� r! r! r' � close_session' s zRmcp.close_sessionc C s | j d d | _ d S )Nr� rF )r� rL r! r! r' �_inc_sequence_number9 s zRmcp._inc_sequence_numberc C s� | � � t� }||_||_|j|_| j|_d|_| j |_ ||_ |j rXt |j ||| j�}n t||�}| j�� d}|| jk�rVz�| �|� d} d} | du �r| | jk�r| j�� s�| j�� } n | �| j�} td| �d tjkr�t| �} | s�q�t|| | j d�} | �s | j� | � | d7 } q�| �s,t d| j � ���W �qVW qn t j!�yR |d7 }Y qn0 qnW d � n1 �sl0 Y || jk�r�t d | j � ���| d d � S ) z�Send and receive data using RMCP interface. target: lun: netfn: cmdid: raw_bytes: IPMI message payload as bytestring Returns the received data as array. r Fr[ r� )�rq_seqr� zJMax retry while checking receiveddata against request header for rmcphost NzCMax retry while sending and/or receiving ipmimessage for rmcp host r ���)"r� r �netfnZrs_lunZ ipmb_addressZrs_sar� r� Zrq_lunr� Zrq_sa�cmdidZroutingr r r� r� r� r� �emptyr� r� ru r r ZCMDID_SEND_MESSAGEr r r� �putr r� r r ) r4 r) �lunr� r� �payloadrA r� �retry�receivedZreceived_retry�rx_datar! r! r' �_send_and_receive< s^ � � � 0 �zRmcp._send_and_receivec C s& | j |||td|�d |dd� d�S )z�Interface function to send and receive raw message. target: IPMI target lun: logical unit number netfn: network function raw_bytes: RAW bytes as bytestring Returns the IPMI message response bytestring. r[ r r� N�r) r� r� r� r� )r� r )r4 r) r� r� Z raw_bytesr! r! r' �send_and_receive_raw� s �zRmcp.send_and_receive_rawc C sD | j |j|j|j|jt|�d�}t|jd |j|j�}t||� |S )z�Interface function to send and receive an IPMI message. target: IPMI target req: IPMI message request Returns the IPMI message response. r� r� ) r� r) r� r� r� r r Zgroup_extensionr )r4 r� r� r� r! r! r' r� � s � zRmcp.send_and_receive)F)rB rC rD �NAMEr� �dictr5 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r! r! r! r' r� f s0 � 0 'Jr� )1r r6 r� r� r* r �queuer r\ r rt r Zmsgsr r r r r Z messagingr �errorsr r r �loggerr Zinterfaces.ipmbr r r r r �utilsr r r ZCLASS_NORMAL_MSGZ CLASS_ACK_MSGr� r� ZRMCP_CLASS_OEMr1 �objectr2 rE r` rb rs r� r! r! r! r' �<module> s6 L(
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка