HEX

File: //lib64/python3.9/site-packages/lsm/__pycache__/_common.cpython-39.pyc
a

B�:f=K�@sTddlZddlZddlZddlZddlZddlZzddlmZWney^ddl	mZYn0ddl
Z
z ddlmZm
Z
ddlmZWn.ey�ddlmZm
Z
ddlmZYn0ddlZddlZddlZddlZddlZdMdd�Zdd	�ZGd
d�de�ZdZdZd
ddddddddddddddddddddddddd�Zgd�ZdNdd�Zdd �Zd!d"�Z dOd#d$�Z!d%d&�Z"d'd(�Z#d)d*�Z$d+d,�Z%d-d.�Z&d/d0�Z'd1d2�Z(Gd3d4�d4e)�Z*ed5d6d7�ed8d9d7�ed:d;d7�Gd<d=�d=e)����Z+dPd>d?�Z,d@dA�Z-GdBdC�dCe�Z.GdDdE�dEe�Z/dFdG�Z0dHdI�Z1GdJdK�dKej2�Z3e4dLk�rPe�5�dS)Q�N)�Sequence)�URLError�	HTTPError)�urlparseTcsHd���fdd�}�fdd�}t||r,|ndd|����fdd�}|S)	z�
    Creates the get/set properties for the given name.  It assumes that the
    actual attribute is '_' + name

    TODO: Expand this with domain validation to ensure the values are correct.
    �_cs
t|��S�N)�getattr��self��attribute_name��1/usr/lib64/python3.9/site-packages/lsm/_common.py�getter.sz default_property.<locals>.gettercst|�|�dSr��setattr)r
�valuerr
r�setter1sz default_property.<locals>.setterNcst|���|Srr)�cls)�name�propr
r�	decorator6sz#default_property.<locals>.decorator)�property)rZ	allow_set�docrrrr
)rrrr�default_property%srcCs$t|t�rttjt|���t|t�rxt|�}d|vr\d|vrHttjd��d|vr\ttjd��t	dt
���ttj|��z*t
jr�t|t
j�r�ttjdt|���Wnty�Yn0tjr�t|t�r�ttjt|���t|tj	�r�ttjt|���t
��}t	d|�ttjd	tt|��|��dS)
Nz
urlopen errorz	Errno 111zConnection refusedz	Errno 113zHost is downzUnexpected network error:
zSSL Certificate error (%s)zUnexpected exception:
zUnexpected exception (TYPE= %s))�
isinstancer�LsmError�ErrorNumber�PLUGIN_AUTH_FAILED�strr�NETWORK_CONNREFUSED�NETWORK_HOSTDOWN�error�	traceback�
format_exc�
NETWORK_ERROR�sslZCertificateError�AttributeError�six�PY3�ConnectionError�socket�
PLUGIN_BUG�type)�expZdescZstack_tracer
r
r�common_urllib2_error_handler=s>

�
��r/c@s*eZdZdZd	dd�Zdd�Zdd�ZdS)
�ProxyzQ
    Used to provide an unambiguous error when a feature is not implemented.
    NcCs
||_dS)z<
        Constructor which takes an object to wrap.
        N)�proxied_obj)r
�objr
r
r�__init__oszProxy.__init__cCs*t|j|�rt�|j|�Sttjd��dS)zJ
        Called each time an attribute is requested of the object
        zUnsupported operationN)�hasattrr1�	functools�partial�_presentrr�
NO_SUPPORT)r
rr
r
r�__getattr__yszProxy.__getattr__cOst|j|�|i|��S)zQ
        Method which is called to invoke the actual method of interest.
        )rr1)r
Z_proxy_method_name�args�kwargsr
r
rr7�szProxy._present)N)�__name__�
__module__�__qualname__�__doc__r3r9r7r
r
r
rr0gs

r0z/var/run/lsm/ipc�ii�ii@Bi@iʚ;llJ)�l l�I�5ll�N�Zo)�B�KiBZKB�K�k�MiBZMB�M�m�GiBZGB�G�g�TiBZTB�T�t�PiBZPB�P�p�EiBZEB�E�e)rQrNrKrHrErBFcCsRd}|rJtD](}|t|kr|tt|�}|}q6q|s>d}d||fS|SdS)a
    Convert size in bytes to human readable size
    The return string will follow IEC binary prefixes, e.g. '1.9 KiB'
    For size less than 1024, we do nothing but return the int we get.
    TODO: Need a expect to handle when size is not a int. int() might do.
    NrAz%.2f %s)�SIZE_CONS_CHK_LST�	SIZE_CONS�float)�sizeZhuman�unitsZkey_namer
r
r�sh�srYcCs
t|d�S)a
    Convert integer size in bytes to human readable size.
    We are following rules of IEC binary prefixes on size:
        http://en.wikipedia.org/wiki/Gibibyte
    The biggest of unit this function supported is PiB.
    The precision is 2 which means you will get '1.99 KiB'
    T)rY)rWr
r
r�size_bytes_2_size_human�srZcCstt�dtj�}|�|�}d}|rl|�d�}|�d�}|s@t|�S|��}|�dd�}|tvrlt|t	|�}t|�S)a�
    Convert human readable size string into integer size in bytes.
    Following rules of IEC binary prefixes on size:
        http://en.wikipedia.org/wiki/Gibibyte
    Supported input size_human in these formats:
        '1.9KiB'        # int(1024*1.9)
        '1 KiB'         # 2**10
        '1B'            # 1
        '2K'            # 2*(2**10), treated as '2KiB'
        '2k'            # 2*(2**10), treated as '2KiB'
        '2KB'           # 2*(10**3)
    z�
        ^
        ([0-9\.]+)          # 1: number
        [ \t]*              # might have space between number and unit
        ([a-zA-Z]*)         # 2: units
        $
    rr@�ZIBZiB)
�re�compile�X�match�group�int�upper�replacerUrV)Z
size_humanZregex_size_humanZregex_matchZ
size_bytesZnumberrXr
r
r�size_human_2_size_bytes�s 
�


rdc
Csz�i}t|�}|jr|j|d<|jr.|j|d<|jr>|j|d<|jrN|j|d<|jr`|j|d<nd|d<t|�|d<|r�|D]}||vr|ttj	d|��q||r�|D] }||dvr�ttj	d	|��q�|WSt
�y}z ttj	d
t|���WYd}~n
d}~00dS)zq
    Common uri parse method that optionally can check for what is needed
    before returning successfully.
    �scheme�netloc�port�host�usernameN�
parametersz&uri missing "%s" or is in invalid formzuri missing query parameter %szuri invalid: reason: %s)rrerfrg�hostnameri�uri_parametersrr�INVALID_ARGUMENT�
ValueErrorr)�uriZrequiresZrequired_params�rc�u�r�ver
r
r�	uri_parsesB



��
�rtcCsP|jr|j}n|jr(td|d�j}niS|rHtdd�|�d�D��SiSdS)Nzhttp:r[cSsg|]}|�d��qS)�=)�split)�.0�partr
r
r�
<listcomp>I�z"uri_parameters.<locals>.<listcomp>�&)�query�pathr�dictrv)ror|r
r
rrl:srlcCsDztjdd�}Wnty*t��}Yn0|�|�d��|��S)NF)Zusedforsecurityzutf-8)�hashlib�md5�	Exception�update�encodeZ	hexdigest)rM�hr
r
rr�Qsr�cCs"tjr||St|�t|�SdSr)r(r)ra)�a�br
r
r�int_div\sr�cGsd�dd�|D��S)N�cSsg|]}t|��qSr
)r)rwrSr
r
rryirzz$params_to_string.<locals>.<listcomp>)�join)r:r
r
r�params_to_stringhsr�cCs0|�d�D] }t|�r
t�||d|�q
dS)z�
    If a message includes new lines we will create multiple syslog
    entries so that the message is readable.  Otherwise it isn't very readable.
    Hopefully we won't be logging much :-)
    �
z: N)rv�len�syslog)�levelZprg�msg�lr
r
r�post_msgvsr�cGs$ttjtj�tjd�t|��dS�Nr)	r�r�ZLOG_ERR�osr}�basename�sys�argvr��r�r
r
rr"�s�r"cGs(tr$ttjtj�tjd�t	|��dSr�)
�LOG_VERBOSEr�r�ZLOG_INFOr�r}r�r�r�r�r�r
r
r�info�s�r�c@seZdZdZdS)�	SocketEOFzL
    Exception class to indicate when we read zero bytes from a socket.
    N)r<r=r>r?r
r
r
rr��sr��codez
Error code)rr�z
Error message�datazOptional error datac@seZdZddd�Zdd�ZdS)rNcOs.tj|g|�Ri|��||_||_||_dS)z,
        Class represents an error.
        N)r�r3�_codeZ_msg�_data)r
r��messager�r:r;r
r
rr3�szLsmError.__init__cCs@t�|j�}|jdur.|jr.d||j|jfSd||jfSdS)Nz%s: %s Data: %sz%s: %s )r�error_number_to_strr�r�r�)r
Zerror_no_strr
r
r�__str__�s�zLsmError.__str__)N)r<r=r>r3r�r
r
r
rr�s
	rcCs|||||d�S)zC
    Used for gathering additional information about an error.
    ��domainr��	exception�debug�
debug_datar
r�r
r
r�addl_error_data�s�r�cCs`|�d�}d�|dd��}t|�rJt|�}|dd�D]}t||�}q8ntd�}t||�}|S)zn
    Given a class name it returns the class, caller will then
    need to run the constructor to create.
    �.N���r@�__main__)rvr�r��
__import__r)�
class_name�parts�modulerG�compr
r
r�	get_class�s

r�c@s�eZdZdZdZdZdZdZdZdZ	dZ
d	Zd
ZdZ
dZd
ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(d'Z)d(Z*d)Z+d*Z,d+Z-d,Z.e/�Z0e1d-d.��Z2d/S)0rrr@r[����
�2�4�e�}�������������������������������i,i-i3i7i^i�i�i�i�i�i�iicCs:ttj���D]"}tj||krd||fSqd|S)Nz%s(%d)zUNKNOWN_ERROR_NUMBER(%d))�listr�_LOCALS�keys)Zerror_noZ	error_strr
r
rr�szErrorNumber.error_number_to_strN)3r<r=r>ZOKZLIB_BUGr,ZJOB_STARTEDZTIMEOUTZDAEMON_NOT_RUNNINGZPERMISSION_DENIEDZ
NAME_CONFLICTZEXISTS_INITIATORrmZNO_STATE_CHANGEr r!r%Z	NO_MEMORYr8Z	IS_MASKEDZHAS_CHILD_DEPENDENCYZNOT_FOUND_ACCESS_GROUPZNOT_FOUND_FSZ
NOT_FOUND_JOBZNOT_FOUND_POOLZNOT_FOUND_FS_SSZNOT_FOUND_VOLUMEZNOT_FOUND_NFS_EXPORTZNOT_FOUND_GENERICZNOT_FOUND_SYSTEMZNOT_FOUND_DISKZNOT_LICENSEDZNO_SUPPORT_ONLINE_CHANGEZNO_SUPPORT_OFFLINE_CHANGErZPLUGIN_IPC_FAILZPLUGIN_SOCKET_PERMISSIONZPLUGIN_NOT_EXISTZNOT_ENOUGH_SPACEZTRANSPORT_COMMUNICATIONZTRANSPORT_SERIALIZATIONZTRANSPORT_INVALID_ARGZLAST_INIT_IN_ACCESS_GROUPZUNSUPPORTED_SEARCH_KEYZEMPTY_ACCESS_GROUPZPOOL_NOT_READYZ
DISK_NOT_FREE�localsr��staticmethodr�r
r
r
rr�s^rc@seZdZdZdZdZdS)�	JobStatusr@r[�N)r<r=r>Z
INPROGRESSZCOMPLETEZERRORr
r
r
rr�sr�cCs�t|t�rvt|t�s,td|tt|��f��t|�dkrT|D]}t||d|�q<q�t||�D]\}}t|||�q^nf|t|�kr�|dur�t|tj	�r�t|tj	�r�dSt
�|�r�tt|�|�s�td|t|�tt|��f��dS)Nz6%s call is returning a %s, but is expecting a sequencer@rz%s call expected: %s got: %s )
rr�	TypeErrorrr-r��type_compare�zipr(Zstring_types�inspectZisclass�
issubclass)Zmethod_nameZexp_typeZact_val�avr.Zactr
r
rr�#s.

�
�
���r�cs�fdd�}|S)a4
    Decorator function that allows us to ensure that we are getting the
    correct types back from a function/method call.

    Note: This is normally frowned upon by the python community, but this API
    needs to be language agnostic, so making sure we have the correct types
    is quite important.
    cst�����fdd��}|S)Ncsx�|i|��}t��dkrVt|�t��krFtd�jt��t|�f��t�j�|�nt��dkrtt�j�d|�|S)Nr@z.%s call expected %d return values, actual = %dr)r�r�r<r�)r:r;rr)�func�typesr
r�innerMs�z-return_requires.<locals>.outer.<locals>.inner)r5�wraps)r�r��r�)r�r�outerKszreturn_requires.<locals>.outerr
)r�r�r
r�r�return_requiresAs
r�c@s$eZdZdd�Zdd�Zdd�ZdS)�
TestCommoncCsdSrr
r	r
r
r�setUphszTestCommon.setUpc
Cs�z
t��Wn4ty>}z|�t|t��WYd}~n
d}~00ztddd��WnHty�}z0|�|jdko�|jdko�|jdk�WYd}~n
d}~00tddddd�}|�|ddko�|ddko�|ddko�|ddko�|ddk�dS)	N�
ZMessageZDatar�r�r�r�r�)r�Z
assertTruerrr�r�r�r�)r
rSZedr
r
r�test_simpleks(
&�
�
�
�
�zTestCommon.test_simplecCsdSrr
r	r
r
r�tearDownszTestCommon.tearDownN)r<r=r>r�r�r�r
r
r
rr�fsr�r�)TN)F)NN)NN)6rr�Zunittestr\r�r��collections.abcr�ImportError�collectionsr�Zurllib.errorrr�urllib.parserZurllib2r5r#r(r&r+rr/�objectr0ZUDS_PATHr�rUrTrYrZrdrtrlr�r�r�r�r"r�r�r�rr�r�rr�r�r�ZTestCaser�r<�mainr
r
r
r�<module>s�
*)�
)
2




R%