| Server IP : 162.240.50.153 / Your IP : 216.73.216.201 Web Server : Apache System : Linux vps-880082.mktpower.cl 3.10.0-1160.119.1.el7.tuxcare.els25.x86_64 #1 SMP Wed Oct 1 17:37:27 UTC 2025 x86_64 User : wwmktp ( 1003) PHP Version : 8.3.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/lib/python2.7/site-packages/lsm/ |
Upload File : |
�
-�P`c @ s� d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z y d d l m Z Wn! e k
r d d l m Z n Xd d l
Z
y* d d l m Z m
Z
d d l m Z Wn7 e k
r� d d l m Z m
Z
d d l m Z n Xd d l Z d d l Z d d l Z d d l Z d d l Z e d d � Z d � Z d e f d � � YZ d Z e Z i d
d 6dR d 6dS d 6dT d 6dU d 6dV d 6dW d 6dX d 6dY d 6dZ d 6d[ d 6d\ d 6d] d 6d^ d 6d_ d" 6d` d# 6da d$ 6db d& 6dc d( 6dd d) 6de d* 6df d, 6dg d. 6dh d/ 6di d0 6Z d, d& d d d d g Z e d1 � Z! d2 � Z" d3 � Z# d d d4 � Z$ d5 � Z% d6 � Z& d7 � Z' d8 � Z( d9 � Z) d: � Z* d; � Z+ d< e, f d= � � YZ- e d> d? d@ �e dA d? dB �e dC d? dD �dE e, f dF � � Y� � � Z. d d dG � Z/ dH � Z0 dI e f dJ � � YZ1 dK e f dL � � YZ2 dM � Z3 dN � Z4 dO e j5 f dP � � YZ6 e7 dQ k r�e j8 � n d S(j i����N( t Sequence( t URLErrort HTTPError( t urlparsec s_ d � � � f d � } � f d � } t | | r: | n d d | � � � � f d � } | S( s�
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.
t _c s
t | � � S( N( t getattr( t self( t attribute_name( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt getter9 s c s t | � | � d S( N( t setattr( R t value( R ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt setter< s c s t | � � � | S( N( R ( t cls( t namet prop( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt decoratorA s N( t propertyt None( R
t allow_sett docR R R ( ( R R
R s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt default_property0 s
!c C s� t | t � r* t t j t | � � � n t | t � r� t | � } d | k r� d | k rr t t j d � � n d | k r� t t j d � � q� n t d t
j � � t t j | � � n yA t
j r� t | t
j � r� t t j d t | � � � q� n Wn t k
rn Xt j rGt | t � rGt t j t | � � � n t | t j � rtt t j t | � � � n t
j � } t d | � t t j d t t | � � | � � d S(
Ns
urlopen errors Errno 111s Connection refuseds Errno 113s Host is downs Unexpected network error:
s SSL Certificate error (%s)s Unexpected exception:
s Unexpected exception (TYPE= %s)( t
isinstanceR t LsmErrort ErrorNumbert PLUGIN_AUTH_FAILEDt strR t NETWORK_CONNREFUSEDt NETWORK_HOSTDOWNt errort tracebackt
format_exct
NETWORK_ERRORt sslt CertificateErrort AttributeErrort sixt PY3t ConnectionErrort sockett
PLUGIN_BUGt type( t expt desct stack_trace( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt common_urllib2_error_handlerH s:
t Proxyc B s, e Z d Z d d � Z d � Z d � Z RS( sQ
Used to provide an unambiguous error when a feature is not implemented.
c C s
| | _ d S( s<
Constructor which takes an object to wrap.
N( t proxied_obj( R t obj( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt __init__{ s c C s; t | j | � r% t j | j | � St t j d � � d S( sJ
Called each time an attribute is requested of the object
s Unsupported operationN( t hasattrR. t functoolst partialt _presentR R t
NO_SUPPORT( R R
( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt __getattr__� s c O s t | j | � | | � S( sQ
Method which is called to invoke the actual method of interest.
( R R. ( R t _proxy_method_namet argst kwargs( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR4 � s N( t __name__t
__module__t __doc__R R0 R6 R4 ( ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR- s s
s /var/run/lsm/ipci t Bi i
t KiBi t KBt Kt ki t MiBi t MBt Mt mi t GiBi t GBt Gt gi( t TiBi t TBt Tt ti2 t PiBi t PBt Pt pi< t EiBi t EBt Et ec C sp d } | rh x< t D]4 } | t | k r | t t | � :} | } Pq q W| sZ d } n d | | f S| Sd S( s
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.
R= s %.2f %sN( R t SIZE_CONS_CHK_LSTt SIZE_CONSt float( t sizet humant unitst key_name( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt sh� s
c C s
t | t � S( s
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'
( R] t True( RY ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt size_bytes_2_size_human� s c C s� t j d t j � } | j | � } d } | r� | j d � } | j d � } | s^ t | � S| j � } | j d d � } | t k r� t | t | � } q� n t | � S( s�
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)
s�
^
([0-9\.]+) # 1: number
[ \t]* # might have space between number and unit
([a-zA-Z]*) # 2: units
$
i i i t IBt iB(
t ret compilet Xt matcht groupt intt uppert replaceRW RX ( t
size_humant regex_size_humant regex_matcht
size_bytest numberR[ ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt size_human_2_size_bytes� s
c C si y3i } t | � } | j r. | j | d <n | j rG | j | d <n | j r` | j | d <n | j ry | j | d <n | j r� | j | d <n
d
| d <t | � | d <| r� x6 | D]+ } | | k r� t t j
d | � � q� q� Wn | r.x: | D]/ } | | d k r� t t j
d | � � q� q� Wn | SWn/ t k
rd} t t j
d t | � � � n Xd
S( sq
Common uri parse method that optionally can check for what is needed
before returning successfully.
t schemet netloct portt hostt usernamet
parameterss& uri missing "%s" or is in invalid forms uri missing query parameter %ss uri invalid: reason: %sN(
R Rp Rq Rr t hostnameRt R t uri_parametersR R t INVALID_ARGUMENTt
ValueErrorR ( t urit requirest required_paramst rct ut rt ve( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt uri_parse s:
c C sy | j r | j } n' | j r8 t d | d � j } n i S| rq t g | j d � D] } | j d � ^ qU � Si Sd S( Ns http:i t &t =( t queryt pathR t dictt split( Rz R� t part( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyRw D s /c C s, t j � } | j | j d � � | j � S( Ns utf-8( t hashlibt md5t updatet encodet hexdigest( RM t h( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR� [ s c C s t j r | | S| | Sd S( N( R# R$ ( t at b( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt int_diva s c G s& d j g | D] } t | � ^ q
� S( Nt ( t joinR ( R8 RU ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt params_to_stringm s c C sE x> | j d � D]- } t | � r t j | | d | � q q Wd S( s�
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 :-)
s
s : N( R� t lent syslog( t levelt prgt msgt l( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt post_msgz s c G s0 t t j t j j t j d � t | � � d S( Ni ( R� R� t LOG_ERRt osR� t basenamet syst argvR� ( R� ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR � s c G s9 t r5 t t j t j j t j d � t | � � n d S( Ni (
t LOG_VERBOSER� R� t LOG_INFOR� R� R� R� R� R� ( R� ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt info� s t SocketEOFc B s e Z d Z RS( sL
Exception class to indicate when we read zero bytes from a socket.
( R: R; R< ( ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR� � s t codeR s
Error codeR� s
Error messaget datas Optional error dataR c B s e Z d d � Z d � Z RS( c O s2 t j | | | � | | _ | | _ | | _ d S( s,
Class represents an error.
N( t ExceptionR0 t _codet _msgt _data( R R� t messageR� R8 R9 ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR0 � s c C sV t j | j � } | j d k rA | j rA d | | j | j f Sd | | j f Sd S( Ns %s: %s Data: %ss %s: %s ( R t error_number_to_strR� R� R R� ( R t error_no_str( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt __str__� s
N( R: R; R R0 R� ( ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR � s c C s' i | d 6| d 6| d 6| d 6| d 6S( sC
Used for gathering additional information about an error.
t domainR� t exceptiont debugt
debug_data( ( R� R� R� R� R� ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt addl_error_data� s c C s� | j d � } d j | d � } t | � ra t | � } x? | d D] } t | | � } qE Wn t d � } t | | � } | S( sn
Given a class name it returns the class, caller will then
need to run the constructor to create.
t .i����i t __main__( R� R� R� t
__import__R ( t
class_namet partst moduleRE t comp( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt get_class� s R c B s" e 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
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 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' d& Z( d' Z) d( Z* d) Z+ d* Z, e- � Z. e/ d+ � � Z0 RS(, i i i i i i i
i2 i4 ie i} i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i� i, i- i3 i7 i^ i� i� i� i� i� i� i i c C sI x> t t j j � � D]' } t j | | k r d | | f Sq Wd | S( Ns %s(%d)s UNKNOWN_ERROR_NUMBER(%d)( t listR t _LOCALSt keys( t error_not error_str( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR� s (1 R: R; t OKt LIB_BUGR' t JOB_STARTEDt TIMEOUTt DAEMON_NOT_RUNNINGt PERMISSION_DENIEDt
NAME_CONFLICTt EXISTS_INITIATORRx t NO_STATE_CHANGER R R t NO_MEMORYR5 t IS_MASKEDt HAS_CHILD_DEPENDENCYt NOT_FOUND_ACCESS_GROUPt NOT_FOUND_FSt
NOT_FOUND_JOBt NOT_FOUND_POOLt NOT_FOUND_FS_SSt NOT_FOUND_VOLUMEt NOT_FOUND_NFS_EXPORTt NOT_FOUND_SYSTEMt NOT_FOUND_DISKt NOT_LICENSEDt NO_SUPPORT_ONLINE_CHANGEt NO_SUPPORT_OFFLINE_CHANGER t PLUGIN_IPC_FAILt PLUGIN_SOCKET_PERMISSIONt PLUGIN_NOT_EXISTt NOT_ENOUGH_SPACEt TRANSPORT_COMMUNICATIONt TRANSPORT_SERIALIZATIONt TRANSPORT_INVALID_ARGt LAST_INIT_IN_ACCESS_GROUPt UNSUPPORTED_SEARCH_KEYt EMPTY_ACCESS_GROUPt POOL_NOT_READYt
DISK_NOT_FREEt localsR� t staticmethodR� ( ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR � sZ t JobStatusc B s e Z d Z d Z d Z RS( i i i ( R: R; t
INPROGRESSt COMPLETEt ERROR( ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR� s c
C sQ t | t � r� t | t � sC t d | t t | � � f � � n t | � d k r} xU | D] } t | | d | � q\ WqMx� t | | � D] \ } } t | | | � q� Wn� | t | � k rM| d k rMt | t j
� r� t | t j
� r� d St j | � s t
t | � | � rMt d | t | � t t | � � f � � qMn d S( Ns6 %s call is returning a %s, but is expecting a sequencei i s %s call expected: %s got: %s ( R R t TypeErrorR R( R� t type_comparet zipR R# t string_typest inspectt isclasst
issubclass( t method_namet exp_typet act_valt avR) t act( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR� s$
c s � f d � } | S( s4
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.
c s% t j � � � � f d � � } | S( Nc s� � | | � } t � � d k rz t | � t � � k rd t d � j t � � t | � f � � n t � j � | � n, t � � d k r� t � j � d | � n | S( Ni s. %s call expected %d return values, actual = %di ( R� R� R: R� ( R8 R9 R ( t funct types( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt innerH s %( R2 t wraps( R� R� ( R� ( R� s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt outerG s !( ( R� R� ( ( R� s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt return_requires> s t
TestCommonc B s# e Z d � Z d � Z d � Z RS( c C s d S( N( ( R ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt setUp` s c C s y
t � � Wn) t k
r8 } | j t | t � � n Xy t d d d � � WnG t k
r� } | j | j d k o� | j d k o� | j d k � n Xt d d d d d � } | j | d d k o| d d k o| d d k o| d d k o| d d k � d S( Ni
t Messaget DataR� R� R� R� R� ( R� t
assertTrueR R R� R� R� R� ( R RU t ed( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt test_simplec s
$ &c C s d S( N( ( R ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt tearDownw s ( R: R; R� R R ( ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyR� _ s R� i i� i i i i@B i i i @i ʚ;i @i @I I ��� I I I I �Ƥ~� I I I I d����
I I (9 R� R� t unittestRb R� R� t collections.abcR t ImportErrort collectionsR� t urllib.errorR R t urllib.parseR t urllib2R2 R R# R R& R^ R R R, t objectR- t UDS_PATHR� RW RV t FalseR] R_ Ro R� Rw R� R� R� R� R R� R� R� R R� R� R R� R� R� t TestCaseR� R: t main( ( ( s/ /usr/lib/python2.7/site-packages/lsm/_common.pyt <module> s�
+)
(1
Q !