File Manager

Viewing File: /usr/lib/python2.7/site-packages/lsm/_common.pyo

ó
-ÎP`c@sddlZddlZddlZddlZddlZddlZyddlmZWn!ek
rddl	mZnXddl
Z
y*ddlmZm
Z
ddlmZWn7ek
rïddlmZm
Z
ddlmZnXddlZddlZddlZddlZddlZedd„Zd„Zdefd„ƒYZd	ZeZid
d6dRd6dSd6dTd6dUd6dVd6dWd6dXd6dYd6dZd6d[d6d\d6d]d6d^d 6d_d"6d`d#6dad$6dbd&6dcd(6ddd)6ded*6dfd,6dgd.6dhd/6did06Zd,d&d dddgZe d1„Z!d2„Z"d3„Z#ddd4„Z$d5„Z%d6„Z&d7„Z'd8„Z(d9„Z)d:„Z*d;„Z+d<e,fd=„ƒYZ-ed>d?d@ƒedAd?dBƒedCd?dDƒdEe,fdF„ƒYƒƒƒZ.dddG„Z/dH„Z0dIefdJ„ƒYZ1dKefdL„ƒYZ2dM„Z3dN„Z4dOej5fdP„ƒYZ6e7dQkr‰ej8ƒndS(jiÿÿÿÿN(tSequence(tURLErrort	HTTPError(turlparsecs_dˆ‰‡fd†}‡fd†}t||r:|ndd|ƒ‰‡‡fd†}|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_cs
t|ˆƒS(N(tgetattr(tself(tattribute_name(s//usr/lib/python2.7/site-packages/lsm/_common.pytgetter9scst|ˆ|ƒdS(N(tsetattr(Rtvalue(R(s//usr/lib/python2.7/site-packages/lsm/_common.pytsetter<scst|ˆˆƒ|S(N(R	(tcls(tnametprop(s//usr/lib/python2.7/site-packages/lsm/_common.pyt	decoratorAsN(tpropertytNone(R
t	allow_settdocRRR((RR
Rs//usr/lib/python2.7/site-packages/lsm/_common.pytdefault_property0s
!cCs·t|tƒr*ttjt|ƒƒ‚nt|tƒr¿t|ƒ}d|kr–d|krrttjdƒ‚nd|kr–ttjdƒ‚q–nt	dt
jƒƒttj|ƒ‚nyAt
jrÿt|t
jƒrÿttjdt|ƒƒ‚qÿnWntk
rnXtjrGt|tƒrGttjt|ƒƒ‚nt|tj	ƒrtttjt|ƒƒ‚nt
jƒ}t	d|ƒttjd	tt|ƒƒ|ƒ‚dS(
Ns
urlopen errors	Errno 111sConnection refuseds	Errno 113sHost is downsUnexpected network error:
sSSL Certificate error (%s)sUnexpected exception:
sUnexpected exception (TYPE= %s)(t
isinstanceRtLsmErrortErrorNumbertPLUGIN_AUTH_FAILEDtstrRtNETWORK_CONNREFUSEDtNETWORK_HOSTDOWNterrort	tracebackt
format_exct
NETWORK_ERRORtssltCertificateErrortAttributeErrortsixtPY3tConnectionErrortsockett
PLUGIN_BUGttype(texptdesctstack_trace((s//usr/lib/python2.7/site-packages/lsm/_common.pytcommon_urllib2_error_handlerHs:				
	tProxycBs,eZdZdd„Zd„Zd„ZRS(sQ
    Used to provide an unambiguous error when a feature is not implemented.
    cCs
||_dS(s<
        Constructor which takes an object to wrap.
        N(tproxied_obj(Rtobj((s//usr/lib/python2.7/site-packages/lsm/_common.pyt__init__{scCs;t|j|ƒr%tj|j|ƒSttjdƒ‚dS(sJ
        Called each time an attribute is requested of the object
        sUnsupported operationN(thasattrR.t	functoolstpartialt_presentRRt
NO_SUPPORT(RR
((s//usr/lib/python2.7/site-packages/lsm/_common.pyt__getattr__…s	cOst|j|ƒ||ŽS(sQ
        Method which is called to invoke the actual method of interest.
        (RR.(Rt_proxy_method_nametargstkwargs((s//usr/lib/python2.7/site-packages/lsm/_common.pyR4•sN(t__name__t
__module__t__doc__RR0R6R4(((s//usr/lib/python2.7/site-packages/lsm/_common.pyR-ss
	s/var/run/lsm/ipcitBii
tKiBitKBtKtkitMiBitMBtMtmitGiBi	tGBtGtgi(tTiBitTBtTtti2tPiBitPBtPtpi<tEiBitEBtEtecCspd}|rhx<tD]4}|t|kr|tt|ƒ:}|}PqqW|sZd}nd||fS|SdS(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(RtSIZE_CONS_CHK_LSTt	SIZE_CONStfloat(tsizethumantunitstkey_name((s//usr/lib/python2.7/site-packages/lsm/_common.pytshÄs
	cCs
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]tTrue(RY((s//usr/lib/python2.7/site-packages/lsm/_common.pytsize_bytes_2_size_humanÝscCs¬tjdtjƒ}|j|ƒ}d}|r¢|jdƒ}|jdƒ}|s^t|ƒS|jƒ}|jddƒ}|tkr¢t|t	|ƒ}q¢nt|ƒ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
        $
    iiitIBtiB(
tretcompiletXtmatchtgrouptinttuppertreplaceRWRX(t
size_humantregex_size_humantregex_matcht
size_bytestnumberR[((s//usr/lib/python2.7/site-packages/lsm/_common.pytsize_human_2_size_bytesës

cCsiy3i}t|ƒ}|jr.|j|d<n|jrG|j|d<n|jr`|j|d<n|jry|j|d<n|jr’|j|d<n
d
|d<t|ƒ|d<|rëx6|D]+}||kr¹tt	j
d|ƒ‚q¹q¹Wn|r.x:|D]/}||dkrøtt	j
d|ƒ‚qøqøWn|SWn/tk
rd}tt	j
d	t|ƒƒ‚nXd
S(sq
    Common uri parse method that optionally can check for what is needed
    before returning successfully.
    tschemetnetloctportthosttusernamet
parameterss&uri missing "%s" or is in invalid formsuri missing query parameter %ssuri invalid: reason: %sN(
RRpRqRrthostnameRtRturi_parametersRRtINVALID_ARGUMENTt
ValueErrorR(turitrequirestrequired_paramstrctutrtve((s//usr/lib/python2.7/site-packages/lsm/_common.pyt	uri_parses:					

	
		cCsy|jr|j}n'|jr8td|dƒj}niS|rqtg|jdƒD]}|jdƒ^qUƒSiSdS(Nshttp:it&t=(tquerytpathRtdicttsplit(RzR„tpart((s//usr/lib/python2.7/site-packages/lsm/_common.pyRwDs		/cCs,tjƒ}|j|jdƒƒ|jƒS(Nsutf-8(thashlibtmd5tupdatetencodet	hexdigest(RMth((s//usr/lib/python2.7/site-packages/lsm/_common.pyRŠ[scCstjr||S||SdS(N(R#R$(tatb((s//usr/lib/python2.7/site-packages/lsm/_common.pytint_divas	cGs&djg|D]}t|ƒ^q
ƒS(Nt(tjoinR(R8RU((s//usr/lib/python2.7/site-packages/lsm/_common.pytparams_to_stringmscCsEx>|jdƒD]-}t|ƒrtj||d|ƒqqWdS(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‡tlentsyslog(tleveltprgtmsgtl((s//usr/lib/python2.7/site-packages/lsm/_common.pytpost_msgzscGs0ttjtjjtjdƒt|ŒƒdS(Ni(	R›R–tLOG_ERRtosR…tbasenametsystargvR”(R™((s//usr/lib/python2.7/site-packages/lsm/_common.pyR…scGs9tr5ttjtjjtjdƒt	|ŒƒndS(Ni(
tLOG_VERBOSER›R–tLOG_INFORR…RžRŸR R”(R™((s//usr/lib/python2.7/site-packages/lsm/_common.pytinfoŠst	SocketEOFcBseZdZRS(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¤stcodeRs
Error codeR™s
Error messagetdatasOptional error dataRcBseZdd„Zd„ZRS(cOs2tj|||Ž||_||_||_dS(s,
        Class represents an error.
        N(t	ExceptionR0t_codet_msgt_data(RR¥tmessageR¦R8R9((s//usr/lib/python2.7/site-packages/lsm/_common.pyR0›s		cCsVtj|jƒ}|jdk	rA|jrAd||j|jfSd||jfSdS(Ns%s: %s Data: %ss%s: %s (Rterror_number_to_strR¥R¦RR™(Rterror_no_str((s//usr/lib/python2.7/site-packages/lsm/_common.pyt__str__¤s
N(R:R;RR0R®(((s//usr/lib/python2.7/site-packages/lsm/_common.pyR—s	cCs'i|d6|d6|d6|d6|d6S(sC
    Used for gathering additional information about an error.
    tdomainR—t	exceptiontdebugt
debug_data((R¯R—R°R±R²((s//usr/lib/python2.7/site-packages/lsm/_common.pytaddl_error_datascCs€|jdƒ}dj|d ƒ}t|ƒrat|ƒ}x?|dD]}t||ƒ}qEWntdƒ}t||ƒ}|S(sn
    Given a class name it returns the class, caller will then
    need to run the constructor to create.
    t.iÿÿÿÿit__main__(R‡R“R•t
__import__R(t
class_nametpartstmoduleREtcomp((s//usr/lib/python2.7/site-packages/lsm/_common.pyt	get_classµsRcBs"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,e-ƒZ.e/d+„ƒZ0RS(,iiiiiii
i2i4iei}iŒiiŽi˜i™i i¡iÈiÉiÊiËiÌiÍiÎiÐiÑiâiúiûi,i-i3i7i^ii‘i’iöiþiÿiicCsIx>ttjjƒƒD]'}tj||krd||fSqWd|S(Ns%s(%d)sUNKNOWN_ERROR_NUMBER(%d)(tlistRt_LOCALStkeys(terror_not	error_str((s//usr/lib/python2.7/site-packages/lsm/_common.pyR¬s(1R:R;tOKtLIB_BUGR'tJOB_STARTEDtTIMEOUTtDAEMON_NOT_RUNNINGtPERMISSION_DENIEDt
NAME_CONFLICTtEXISTS_INITIATORRxtNO_STATE_CHANGERRRt	NO_MEMORYR5t	IS_MASKEDtHAS_CHILD_DEPENDENCYtNOT_FOUND_ACCESS_GROUPtNOT_FOUND_FSt
NOT_FOUND_JOBtNOT_FOUND_POOLtNOT_FOUND_FS_SStNOT_FOUND_VOLUMEtNOT_FOUND_NFS_EXPORTtNOT_FOUND_SYSTEMtNOT_FOUND_DISKtNOT_LICENSEDtNO_SUPPORT_ONLINE_CHANGEtNO_SUPPORT_OFFLINE_CHANGERtPLUGIN_IPC_FAILtPLUGIN_SOCKET_PERMISSIONtPLUGIN_NOT_EXISTtNOT_ENOUGH_SPACEtTRANSPORT_COMMUNICATIONtTRANSPORT_SERIALIZATIONtTRANSPORT_INVALID_ARGtLAST_INIT_IN_ACCESS_GROUPtUNSUPPORTED_SEARCH_KEYtEMPTY_ACCESS_GROUPtPOOL_NOT_READYt
DISK_NOT_FREEtlocalsR½tstaticmethodR¬(((s//usr/lib/python2.7/site-packages/lsm/_common.pyRÉsZ	t	JobStatuscBseZdZdZdZRS(iii(R:R;t
INPROGRESStCOMPLETEtERROR(((s//usr/lib/python2.7/site-packages/lsm/_common.pyRçsc
CsQt|tƒr°t|tƒsCtd|tt|ƒƒfƒ‚nt|ƒdkr}xU|D]}t||d|ƒq\WqMxÍt||ƒD]\}}t|||ƒqWn|t|ƒkrM|dk	rMt|t	j
ƒröt|t	j
ƒrödStj|ƒst
t|ƒ|ƒrMtd|t|ƒtt|ƒƒfƒ‚qMndS(Ns6%s call is returning a %s, but is expecting a sequenceiis%s call expected: %s got: %s (RRt	TypeErrorRR(R•ttype_comparetzipRR#tstring_typestinspecttisclasst
issubclass(tmethod_nametexp_typetact_valtavR)tact((s//usr/lib/python2.7/site-packages/lsm/_common.pyRì s$
cs‡fd†}|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.
    cs%tjˆƒ‡‡fd†ƒ}|S(Ncsªˆ||Ž}tˆƒdkrzt|ƒtˆƒkrdtdˆjtˆƒt|ƒfƒ‚ntˆjˆ|ƒn,tˆƒdkr¦tˆjˆd|ƒn|S(Nis.%s call expected %d return values, actual = %di(R•RëR:Rì(R8R9R(tfuncttypes(s//usr/lib/python2.7/site-packages/lsm/_common.pytinnerHs%(R2twraps(R÷Rù(Rø(R÷s//usr/lib/python2.7/site-packages/lsm/_common.pytouterGs!((RøRû((Røs//usr/lib/python2.7/site-packages/lsm/_common.pytreturn_requires>s	t
TestCommoncBs#eZd„Zd„Zd„ZRS(cCsdS(N((R((s//usr/lib/python2.7/site-packages/lsm/_common.pytsetUp`sc	Csy
tƒ‚Wn)tk
r8}|jt|tƒƒnXytdddƒ‚WnGtk
r˜}|j|jdko‘|jdko‘|jdkƒnXtdddddƒ}|j|ddko|ddko|ddko|ddko|ddkƒdS(	Ni
tMessagetDataR¯R—R°R±R²(R¤t
assertTrueRRR¥R™R¦R³(RRUted((s//usr/lib/python2.7/site-packages/lsm/_common.pyttest_simplecs
$	&cCsdS(N((R((s//usr/lib/python2.7/site-packages/lsm/_common.pyttearDownws(R:R;RþRR(((s//usr/lib/python2.7/site-packages/lsm/_common.pyRý_s		Rµiièiiii@Biii@iÊš;i@i@II¥ÔèIIII€Æ¤~IIIId§³¶à
II(9R‰RtunittestRbRŸR–tcollections.abcRtImportErrortcollectionsRïturllib.errorRRturllib.parseRturllib2R2RR#R R&R^RRR,tobjectR-tUDS_PATHR¡RWRVtFalseR]R_RoRRwRŠR‘R”R›RR£R§R¤RR³R»RRçRìRütTestCaseRýR:tmain(((s//usr/lib/python2.7/site-packages/lsm/_common.pyt<module>sœ

	+)
		(1				
				Q		!
Back to Directory File Manager