B çÚ†\YIãH@s:dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z ddl mZddlmZddlmZddlmZydd lmZWnek r¼dZYnXydd lmZWnek rædZYnXe jd krüddlZndZe jdd kZd ddddddddddddddddddd d!d"d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;dd?d@dAdBdCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTgHZejdUkZejdVkZe j dW¡Ze j dX¡ZeZ e j dY¡Z!e j dZ¡Z"e j d[¡Z#e!pe"pe#Z$e j d\¡Z%e j d]¡Z&d^Z'd_Z(d`Z)daZ*dbZ+dcZ,ddZ-deZ.dfZ/dgZ0dhZ1diZ2djZ3dkZ4dlZ5dmZ6dnZ7doZ8dpZ9dqZ:drZ;dsZdvZ?dwZ@edkrždxZAdyZBdZCn Gdzd{„d{ejDƒZEeFƒ GeEjH¡edkrÒd|ZId}ZJn Gd~d„dejDƒZKeFƒ GeKjH¡e  L¡ZMesd€ZNn2y e  O¡ZNWn$ePk r6er.dnd€ZNYnXedHd‚dƒd„d…d†d‡gƒZQedDd‚dƒd„d…gƒZRedBdˆd‰dŠd‹dŒdgƒZSedCdŽddd‘gƒZTedEd’d“d”d•d–d—d˜d™gƒZUedIdšd›dœddžgƒZVed@dŸd d¡d¢d£d¤džgƒZWedFd d¥d¦d§d¨gƒZXedGd©dªd«d¬gƒZYedAd­d®d¯d°gƒZZed±d²d³d´gƒZ[edµd¶d²d·d¸gƒZ\ed¹d…dºd»gƒZ]ed¼d¶d²gƒZ^ed8d½d¾d¿dÀgƒZ_ed=dÁdŸgƒZ`ed>dÂdÃdÄgƒZaed?dÅdÆdÇgƒZbed:dÅdÆdÇgƒZced;dˆd‰dŠd‹gƒZded>> @memoize ... def foo() ... return 1 ... >>> foo() 1 >>> foo.cache_clear() >>> csH|tt| ¡ƒƒf}yˆ|Stk rBˆ||Ž}ˆ|<|SXdS)N)Ú frozensetÚsortedÚitemsÚKeyError)ÚargsÚkwargsÚkeyr)ÚcacheÚfunr]r^Úwrapper%s zmemoize..wrappercs ˆ ¡dS)z Clear cache.N)Úclearr])r‰r]r^Ú cache_clear.szmemoize..cache_clear)Ú functoolsÚwrapsr)rŠr‹rr])r‰rŠr^rKs  cs6t ˆ¡‡fdd„ƒ}dd„}dd„}||_||_|S)aúA memoize decorator which is disabled by default. It can be activated and deactivated on request. For efficiency reasons it can be used only against class methods accepting no arguments. >>> class Foo: ... @memoize ... def foo() ... print(1) ... >>> f = Foo() >>> # deactivated (default) >>> foo() 1 >>> foo() 1 >>> >>> # activated >>> foo.cache_activate(self) >>> foo() 1 >>> foo() >>> foo() >>> csPy|jˆ}Wn<tk r&ˆ|ƒStk rJˆ|ƒ}|jˆ<YnX|S)N)Ú_cacheÚAttributeErrorr…)Úselfr)rŠr]r^r‹Qsz'memoize_when_activated..wrappercSs i|_dS)zjActivate cache. Expects a Process instance. Cache will be stored as a "_cache" instance attribute.N)r)Úprocr]r]r^Úcache_activate_sz.memoize_when_activated..cache_activatecSs"y|`Wntk rYnXdS)zDeactivate and clear cache.N)rr‘)r“r]r]r^Úcache_deactivatedsz0memoize_when_activated..cache_deactivate)rŽrr”r•)rŠr‹r”r•r])rŠr^Úmemoize_when_activated7s r–c CsVyt |¡}Wn6tk rD}z|jtjtjfkr4‚dSd}~XYnXt |j¡SdS)zœSame as os.path.isfile() but does not swallow EACCES / EPERM exceptions, see: http://mail.python.org/pipermail/python-dev/2012-June/120787.html FN)ÚosÚstatÚOSErrorÚerrnoÚEPERMÚEACCESÚS_ISREGÚst_mode)rvÚstÚerrr]r]r^rJpsc CsNyt |¡Wn6tk rD}z|jtjtjfkr4‚dSd}~XYnXdSdS)zœSame as os.path.exists() but does not swallow EACCES / EPERM exceptions, see: http://mail.python.org/pipermail/python-dev/2012-June/120787.html FNT)r—r˜r™ršr›rœ)rvr r]r]r^rMsc Cs`tjrtdkrdSy2t ttj¡}t |¡| d¡WdQRXdStjk rZdSXdS)z2Return True if IPv6 is supported on this platform.NF)z::1rT)ÚsocketZhas_ipv6rrÚ contextlibÚclosingZbindÚerror)Zsockr]r]r^rOŽs cCszi}d}t}xh| d|¡}||kr$P| d||¡}||krj|||…}||d|…}|rb| ¡}|||<|d}qW|S)zCParse a C environ block of environment variables into a dictionary.rúú=rX)rÚfindÚupper)ÚdatarÚposZWINDOWS_Znext_posZ equal_posrˆryr]r]r^rLœs    c Cs4tdkr |Sy t |¡Sttfk r.|SXdS)zConvert a numeric socket family value to an IntEnum member. If it's not a known member, return the numeric value itself. N)Úenumr¡Z AddressFamilyÚ ValueErrorr‘)Únumr]r]r^rP¸s  c Cs4tdkr |Sy t |¡Sttfk r.|SXdS)zConvert a numeric socket type value to an IntEnum member. If it's not a known member, return the numeric value itself. N)r«r¡Z AddressTyper¬r‘)r­r]r]r^rQÅs  cs‡fdd„}|S)zƒA decorator which can be used to mark a method as deprecated 'replcement' is the method name which will be called instead. cs:d|jˆf‰|jdkrˆ|_t |¡‡‡fdd„ƒ}|S)Nz8%s() is deprecated and will be removed; use %s() insteadcs tjˆtddt|ˆƒ||ŽS)NrW)ÚcategoryÚ stacklevel)ÚwarningsÚwarnÚDeprecationWarningÚgetattr)r’r†r‡)ÚmsgÚ replacementr]r^ÚinnerÜsz/deprecated_method..outer..inner)rZÚ__doc__rŽr)rŠr¶)rµ)r´r^ÚouterÖs   z deprecated_method..outerr])rµr¸r])rµr^rIÒs c@sBeZdZdZdd„Zdd„Zdd„Zdd „Zdd d „Zd d„Z d S)Ú _WrapNumberszNWatches numbers so that they don't overflow and wrap (reset to zero). cCs t ¡|_i|_i|_i|_dS)N)Ú threadingZLockÚlockr‰Ú remindersÚ reminder_keys)r’r]r]r^Ú__init__és z_WrapNumbers.__init__cCsT||jkst‚||jkst‚||jks*t‚||j|<ttƒ|j|<ttƒ|j|<dS)N)r‰ÚAssertionErrorr¼r½rÚintÚset)r’Ú input_dictrhr]r]r^Ú _add_dictïs  z_WrapNumbers._add_dictcCsd|j|}t| ¡ƒt| ¡ƒ}x<|D]4}x"|j||D]}|j||=qYnXg}xvtt|ƒƒD]f} || } || } || f} | | krÖ|j|| | 7<|j||  | ¡|  | |j|| ¡qˆWt |ƒ||<q>W||j|<|S)zkCache dict and sum numbers which overflow and wrap. Return an updated copy of `input_dict` ) r‰rÃrÇrÄr…ÚrangeÚlenr¼r½ÚaddÚappendÚtuple) r’rÂrhrÅZnew_dictrˆZ input_tupleZ old_tupleÚbitsÚiZ input_valueÚ old_valuerÆr]r]r^Úruns2      z_WrapNumbers.runNc Csh|jX|dkr0|j ¡|j ¡|j ¡n*|j |d¡|j |d¡|j |d¡WdQRXdS)z>Clear the internal cache, optionally only for function 'name'.N)r»r‰rŒr¼r½Úpop)r’rhr]r]r^r)s   z_WrapNumbers.cache_clearc Cs"|j|j|j|jfSQRXdS)z5Return internal cache dicts as a tuple of 3 elements.N)r»r‰r¼r½)r’r]r]r^Ú cache_info5sz_WrapNumbers.cache_info)N) rZr[r\r·r¾rÃrÇrÐrrÒr]r]r]r^r¹äs ' r¹c Cstjt ||¡SQRXdS)zÅGiven an `input_dict` and a function `name`, adjust the numbers which "wrap" (restart from zero) across different calls by adding "old value" to "new value" and return an updated dict. N)Ú_wnr»rÐ)rÂrhr]r]r^rR;scKst|df|ŽS)NÚrb)Úopen)Úfnamer‡r]r]r^Ú open_binaryIsr×cKs*tr| dt¡| dt¡t|df|ŽS)z¨On Python 3 opens a file in text mode by using fs encoding and a proper en/decoding errors handler. On Python 2 this is just an alias for open(name, 'rt'). ÚencodingÚerrorsZrt)ÚPY3Ú setdefaultrrrÕ)rÖr‡r]r]r^Ú open_textMs  rÜ)N){r·Z __future__rr¢ršrŽr—r¡r˜Úsysrºr°Ú collectionsrrrrrrÚ ImportErrorr Ú version_infor«rÚÚ__all__rhrrÚplatformÚ startswithrrrr rrr rZAIXr+r,r(r-r/r3r'r1r2r)r*r0r.r4rr"r!rrr#rrrrrr r$r%r&ÚIntEnumrYÚglobalsÚupdateÚ __members__rbrcraÚgetfilesystemencodingrrÚgetfilesystemencodeerrorsr‘rFrBr@rArCrGr>rDrEr?rlrorprqr6r;r<r=r8r9r:r7r5rzrHrNrKr–rJrMrOrLrPrQrIr¹rRrÓrrÒr×rÜr]r]r]r^ÚsR                                        9   W