GIF89a=( �' 7IAXKgNgYvYx\%wh&h}t�h%�s%x�}9�R��&�0%� (�.��5�SD��&�a)�x5��;ͣ*ȡ&ղ)ׯ7׵<ѻ4�3�H֧KͯT��Y�aq��q��F� !� ' !� NETSCAPE2.0 , =( ��pH,�Ȥr�l:xШtJ�Z�جv��z��xL.:��z�n���|N�����~�������& !�0`9R�}��"�"a:S�~x��������g���E�������R���E����B�� ��ȸ��D���"�Ů� �H��L��D٫D�B�����D���T���H �G��A R�ڐ |�� ٭&��E8�S�kG�A�px�a��� R2XB��E8I���6X�:vT)�~��q�賥��"F~%x� � 4#Z�0O|-4Bs�X:= Q� Sal��yXJ`GȦ|s h��K3l7�B|�$'7Jީܪ0!��D�n=�P� ����0`�R�lj����v>���5 �.69�ϸd�����nlv�9��f{���Pbx �l5}�p� ��� �3a���I�O����!ܾ���i��9��#��)p�a ޽ �{�)vm��%D~ 6f��s}Œ�D�W E�`!� �&L8x� �ܝ{)x`X/>�}m��R�*|`D�=�_ ^�5 !_&'a�O�7�c��`DCx`�¥�9�Y�F���`?��"� �n@`�} lď��@4>�d S �v�xN��"@~d��=�g�s~G��� ���ud &p8Q�)ƫlXD����A~H�ySun�j���k*D�LH�] ��C"J��Xb~ʪwSt}6K,��q�S:9ت:���l�@�`�� �.۬�t9�S�[:��=`9N����{¿�A !R�:���6��x�0�_ �;������^���#����!����U���;0L1�����p% A��U̬ݵ��%�S��!���~`�G���� ���=4�np�3���������u�u�ٮ|%2�I��r�#0��J``8�@S@5� ���^`8E�]�.�S���7 � �0�j S�D� z���i�S�����!���l��w9*�D�I�nEX��� &A�Go�Qf��F��;���}�J����F5��Q|���X��T��y���]� o ��C=��:���PB@ D׽S�(>�C�x}`��xJЬ�۠��p+eE0`�}`A �/NE�� �9@��� H�7�!%B0`�l*��!8 2�%� �:�1�0E��ux%nP1�!�C)�P81l�ɸF#Ƭ{����B0>�� �b�`��O3��()yRpb��E.ZD8�H@% �Rx+%���c� ���f��b�d�`F�"8�XH"��-�|1�6iI, 2�$+](A*j� QT�o0.�U�`�R�}`�SN����yae�����b��o~ S)�y�@��3 �tT�0�&�+~L�f"�-|�~��>!�v��~�\Q1)}@�}h#aP72�"�$ !� " , =( &7IAXG]KgNgYvYxR"k\%w]'}h}t�h%�g+�s%r.m3ax3�x�}9��&��+�!7�0%� (�.�SD��&��;�"&ײ)׻4��6�K� �@pH,�Ȥr�l:xШtJ�Z�جv��z��xL.:��z�n���|N�����~�������& !�0`9R�}��"�"a:S�~x��������g �� E �� �������E �´��C���ǶR��D��"Ʒ�ʱH��M��GڬD�B����D��T����G���C�C� l&�~:'�tU�6ɹ#��)�'�.6�&��Ȼ K(8p0N�?!�2"��NIJX>R��OM '��2�*x�>#n� �@<[:�I�f ��T���Cdb��[�}E�5MBo��@�`@��tW-3 �x�B���jI�&E�9[T&$��ﯧ&"s��ȳ����dc�UUρ#���ldj?����`\}���u|3'�R]�6 �S#�!�FKL�*N E���`$�:e�YD�q�.�촁�s \-�jA 9�����-��M[�x(�s��x�|���p��}k�T�DpE@W� ��]k`1� ���Yb ��0l��*n0��"~zBd�~u�7�0Bl��0-�x~|U�U0 �h�*HS�|��e"#"?vp�i`e6^�+q��`m8 #V�� ��VS|`��"m"сSn|@:U���~`pb�G�ED����2F�I�? >�x� R� ��%~jx��<�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� h9��G�,m���3��6-��E�L��I�³*K���q�`DwV�QXS��peS��� qܧTS����R�u �<�a�*At�lmE� � ��N[P1�ۦ��$��@`��Dpy�yXvCAy�B`}D� 0QwG#� �a[^�� $���Ǧ{L�"[��K�g�;�S~��GX.�goT.��ư��x���?1z��x~:�g�|�L� ��S`��0S]P�^p F<""�?!,�!N4&P� ����:T�@h�9%t��:�-~�I<`�9p I&.)^ 40D#p@�j4�ج:�01��rܼF2oW�#Z ;$Q q  �K��Nl#29 !F@�Bh�ᏬL!XF�LHKh�.�hE&J�G��<"WN!�����Y@� >R~19J"�2,/ &.GXB%�R�9B6�W]���W�I�$��9�RE8Y� ��"�A5�Q.axB�&ة�J�! �t)K%tS-�JF b�NMxL��)�R��"���6O!TH�H� 0 !� ) , =( &AXKgNgYvYxR"k\%wh&h}h%�g+�s%r.x3�x�}9��&��+�R,�!7�0%� (�.��5��&�a)��;�"&ף*Ȳ)ׯ7׻4�3��6�H֧KͻH�T��Y��q��h� ��pH,�Ȥr�l:xШtJ�Z�جv��z��xL.:��z�n���|N�����~�������& !�0`9R�}��"�"a:S�~x��������g �� E$����� � ����$E$��"��D� � ������R��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/��aHae+�Dm?# ǣ6�8�J�x�Di�M���j���5oQ7�- <! *�l��R2r/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�%�S�X �؁)�@��:E��w�u�Sxb8y\m�zS��Zb�E�L��w!y(>�"w�=�|��s�d �C�W)H�cC$�L �7r.�\{)@�`@ �X�$PD `aaG:���O�72E�amn]�"Rc�x�R� &dR8`g��i�xLR!�P &d����T���i�|�_ � Qi�#�`g:��:noM� :V �)p����W&a=�e�k� j���1߲s�x�W�jal|0��B0�, \j۴:6���C ��W��|��9���zĸV {�;��n��V�m�I��.��PN� ����C��+��By�ѾHŸ:��� 7�Y�FTk�SaoaY$D�S���29R�kt� ��f� ��:��Sp�3�I��DZ� �9���g��u�*3)O��[_hv ,���Et x�BH� �[��64M@�S�M7d�l�ܶ5-��U܍��z�R3Ԭ3~ ��P��5�g: ���kN�&0�j4���#{��3S�2�K�'ợl���2K{� {۶?~m𸧠�I�nE�='����^���_�=��~�#O���'���o..�Y�n��CSO��a��K��o,���b�����{�C�� "�{�K ��w��Ozdը�:$ ���v�] A#� ���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��9`k���'Rr��Z�NB�MF �[�+9���-�wj���8�r� ,V�h"�|�S=�G_��"E� 0i*%̲��da0mVk�):;&6p>�jK ��# �D�:�c?:R Ӭf��I-�"�<�="��7�3S��c2RW ,�8(T"P0F¡Jh�" ; 403WebShell
403Webshell
Server IP : 81.88.48.95  /  Your IP : 10.2.217.94, 216.73.216.227
Web Server : Apache
System : Linux opus07 3.2.0-4-amd64 #1 SMP Debian 3.2.68-1+deb7u3 x86_64
User : nobody ( 99)
PHP Version : 5.3.3-7+squeeze3
Disable Function : NONE
MySQL : ON  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : OFF  |  Pkexec : OFF
Directory :  /usr/lib/python2.6/multiprocessing/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : /usr/lib/python2.6/multiprocessing//managers.pyc
Mc)@sddddgZddkZddkZddkZddkZddkZddkZddklZddk	l
Z
lZlZl
Z
lZlZddklZdd	klZlZlZlZdd
klZlZyddklZWn#ej
oddklZnXdZeieiegZ d
ddfD]Z!e e"e#he!qJ[ Z$de%fdYZ&fhdZ'dZ(de)fdYZ*dZ+dZ,de%fdYZ-de%fdYZ.hei/ei0fd6ei1ei2fd6Z3de%fdYZ4de5fdYZ6de%fd YZ7d!Z8hd"Z9e:e:e:e;d#Z<d$e%fd%YZ=d&e%fd'YZ>e;d(Z?d)e7fd*YZ@d+e7fd,YZAd-eAfd.YZBd/e7fd0YZCd1e7fd2YZDd3e7fd4YZEe9d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKfZFdLeFfdMYZGe9dNd7d8d:d<d@dOdPdQdRd
ddGdSdTdUdfZHe9dVd<d:d@d;dAfZIe9dWdXdYdZd[d\d]d^d_d`f	ZJhdadY6dad_6dbd[6dbd\6eJ_Kde4fdcYZLeLiddeieLideeieLidfeiMeCeLidgeiNeAeLidheiOeAeLidieiPeAeLidjeiQeAeLidkeiReBeLidle
eJeLidmeSeGeLidneTeHeLid&e>eEeLidoe?eIeLid$e=eDeLidbdpe@dqeUeLidadqeUdS(rtBaseManagertSyncManagert	BaseProxytTokeniN(t
format_exc(tProcesstcurrent_processtactive_childrentPooltutilt
connection(tAuthenticationString(texittPopentassert_spawningtForkingPickler(tFinalizetinfo(t
PicklingErrorcCsti|i|iffS(N(tarrayttypecodettostring(ta((s./usr/lib/python2.6/multiprocessing/managers.pytreduce_array&stitemstkeystvaluescBs8eZdZdZdZdZdZdZRS(	s4
    Type to uniquely indentify a shared object
    ttypeidtaddresstidcCs!||||_|_|_dS(N(RRR(tselfRRR((s./usr/lib/python2.6/multiprocessing/managers.pyt__init__6scCs|i|i|ifS(N(RRR(R((s./usr/lib/python2.6/multiprocessing/managers.pyt__getstate__9scCs|\|_|_|_dS(N(RRR(Rtstate((s./usr/lib/python2.6/multiprocessing/managers.pyt__setstate__<scCsd|i|i|ifS(Ns#Token(typeid=%r, address=%r, id=%r)(RRR(R((s./usr/lib/python2.6/multiprocessing/managers.pyt__repr__?s(stypeidsaddresssid(t__name__t
__module__t__doc__t	__slots__RR R"R#(((s./usr/lib/python2.6/multiprocessing/managers.pyR0s			cCsP|i||||f|i\}}|djo|St||dS(sL
    Send a message to manager using connection `c` and return response
    s#RETURNN(tsendtrecvtconvert_to_error(tcRt
methodnametargstkwdstkindtresult((s./usr/lib/python2.6/multiprocessing/managers.pytdispatchGs

cCs|djo|S|djo%t|tjptt|S|djo)t|tjpttd|StdSdS(Ns#ERRORs
#TRACEBACKs#UNSERIALIZABLEsUnserializable message: %s
sUnrecognized message type(ttypetstrtAssertionErrortRemoteErrort
ValueError(R/R0((s./usr/lib/python2.6/multiprocessing/managers.pyR*Qs


R5cBseZdZRS(cCs)ddddt|idddS(Ns
t-iKi(R3R-(R((s./usr/lib/python2.6/multiprocessing/managers.pyt__str__^s(R$R%R8(((s./usr/lib/python2.6/multiprocessing/managers.pyR5]scCsQg}xDt|D]6}t||}t|do|i|qqW|S(s4
    Return a list of names of methods of `obj`
    t__call__(tdirtgetattrthasattrtappend(tobjttemptnametfunc((s./usr/lib/python2.6/multiprocessing/managers.pytall_methodses
cCs:g}t|D]"}|ddjo||qq~S(sP
    Return a list of names of methods of `obj` which do not start with '_'
    it_(RB(R>t_[1]R@((s./usr/lib/python2.6/multiprocessing/managers.pytpublic_methodspstServerc	BseZdZddddddddd	g	Zd
ZdZdZd
ZdZdZ	dZ
he	d6e
d6ed6ZdZdZ
dZdZdZdZdZdZdZRS(sM
    Server class which runs in a process controlled by a manager object
    tshutdowntcreatetaccept_connectiontget_methodst
debug_infotnumber_of_objectstdummytincreftdecrefcCst|tpt||_t||_t|\}}|d|dd|_|ii|_hddfd6|_
h|_ti
|_d|_dS(NRtbacklogii((t
isinstancetbytesR4tregistryRtauthkeytlistener_clienttlistenerRtNonet	id_to_objtid_to_refcountt	threadingtRLocktmutextstop(RRSRRTt
serializertListenertClient((s./usr/lib/python2.6/multiprocessing/managers.pyRs		cCs|t_zymxfy|ii}Wnttfj
o
qnXtid|id|f}t	|_
|iqWntt
fj
onXWdd|_|iiXdS(s(
        Run the server forever
        ttargetR-Ni(Rt_manager_serverRVtaccepttOSErrortIOErrorRZtThreadthandle_requesttTruetdaemontstarttKeyboardInterruptt
SystemExitR]tclose(RR+tt((s./usr/lib/python2.6/multiprocessing/managers.pyt
serve_forevers			cCsd}}}yuti||iti||i|i}|\}}}}||ijptd|t||}Wn"t	j
odt
f}	nIXy||||}Wn"t	j
odt
f}	nXd|f}	y|i|	Wnut	j
oi}
y|idt
fWnt	j
onXti
d|	ti
d|ti
d|
nX|idS(s)
        Handle a new connection
        s%r unrecognizeds
#TRACEBACKs#RETURNsFailure to send message: %rs ... request was %rs ... exception was %rN(RWR
tdeliver_challengeRTtanswer_challengeR)tpublicR4R;t	ExceptionRR(R	RRm(RR+tfuncnameR0trequesttignoreR-R.RAtmsgte((s./usr/lib/python2.6/multiprocessing/managers.pyRgs4cCstidtii|i}|i}|i}x|ipy$d}}|}|\}}}	}
||\}}}||jo#t
d|t||fnt||}
y|
|	|
}Wn!t
j
o}d|f}ntX|o|i|d}|oF|i|||\}}t||i|}d||ff}n
d|f}Wnt
j
o|djodtf}qQy8|i|}||||||	|
}d|f}WqQt
j
odtf}qQXn[tj
o-tidtiitidn#t
j
odtf}nXy@y||Wn+t
j
o}|d	t|fnXWq7t
j
oY}tid
tiitid|tid||itid
q7Xq7WdS(sQ
        Handle requests from the proxies in a particular process/thread
        s$starting server thread to service %rs+method %r of %r object is not in exposed=%rs#ERRORs#PROXYs#RETURNs
#TRACEBACKs$got EOF -- exiting thread serving %ris#UNSERIALIZABLEsexception in thread serving %rs ... message was %rs ... exception was %riN(R	tdebugRZtcurrent_threadR@R)R(RXR]RWtAttributeErrorR2R;RstgetRHRRRtfallback_mappingtEOFErrortsysRtreprRRm(RtconnR)R(RXR,R>RutidentR-R.texposedt	gettypeidtfunctiontresRxRwRtridenttrexposedttokent
fallback_funcR0((s./usr/lib/python2.6/multiprocessing/managers.pytserve_clientsn				

	


		
cCs|S(N((RRRR>((s./usr/lib/python2.6/multiprocessing/managers.pytfallback_getvaluescCs
t|S(N(R3(RRRR>((s./usr/lib/python2.6/multiprocessing/managers.pytfallback_strscCs
t|S(N(R(RRRR>((s./usr/lib/python2.6/multiprocessing/managers.pyt
fallback_reprsR8R#s	#GETVALUEcCsdS(N((RR+((s./usr/lib/python2.6/multiprocessing/managers.pyRM scCs|iizg}|ii}|ixU|D]M}|djo:|id||i|t|i|dd fq6q6Wdi|SWd|ii	XdS(sO
        Return some info --- useful to spot problems with refcounting
        is  %s:       refcount=%s
    %siKs
N(
R\tacquireRXRtsortR=RYR3tjointrelease(RR+R0RR((s./usr/lib/python2.6/multiprocessing/managers.pyRK#s


	
(cCst|idS(s*
        Number of shared objects
        i(tlenRX(RR+((s./usr/lib/python2.6/multiprocessing/managers.pyRL5sc
Cs
zytid|id	titijo)tidtit_tit_nti	dx(t
D]}tid|iqsWx(t
D]}tid|iqWti	ti
dWnddk}|inXWdtdXdS(
s'
        Shutdown this process
        s!manager received shutdown messages#RETURNsresetting stdout, stderris&terminating a child process of managersmanager exiting with exitcode 0iN(s#RETURNN(R	RyR(RWRtstdoutt
__stdout__t
__stderr__tstderrt_run_finalizersRt	terminateRRt	tracebackt	print_excR(RR+tpR((s./usr/lib/python2.6/multiprocessing/managers.pyRG;s.








cOsi|iizG|i|\}}}}|djo0t|djo|pt|d}	n|||}	|djot|	}n|dj	o4t|tjptt	|t	|}ndt
|	}
tid||
|	t
||f|i|
<|
|ijod|i|
<n|i||
|
t|fSWd|iiXdS(s>
        Create a new shared object and return its id
        iis%xs&%r callable returned object with id %rN(R\RRSRWRR4RER2tdicttlistRR	RytsetRXRYRNttupleR(RR+RR-R.tcallableRtmethod_to_typeidt	proxytypeR>R((s./usr/lib/python2.6/multiprocessing/managers.pyRH[s(

"

cCst|i|idS(sL
        Return the methods of the shared object indicated by token
        i(RRXR(RR+R((s./usr/lib/python2.6/multiprocessing/managers.pyRJscCs-|ti_|id|i|dS(s=
        Spawn a new thread to serve this connection
        s#RETURNN(s#RETURNN(RZRzR@R(RWR(RR+R@((s./usr/lib/python2.6/multiprocessing/managers.pyRIs
cCs9|iiz|i|cd7<Wd|iiXdS(Ni(R\RRYR(RR+R((s./usr/lib/python2.6/multiprocessing/managers.pyRNs
cCs|iizn|i|djpt|i|cd8<|i|djo(|i|=|i|=tid|nWd|iiXdS(Niisdisposing of obj with id %r(R\RRYR4RXR	RyR(RR+R((s./usr/lib/python2.6/multiprocessing/managers.pyROs
(R$R%R&RrRRoRgRRRRR}RMRKRLRGRHRJRIRNRO(((s./usr/lib/python2.6/multiprocessing/managers.pyRFzs.			"	J			
				 	&			tStatecBs#eZdgZdZdZdZRS(tvalueiii(R$R%R'tINITIALtSTARTEDtSHUTDOWN(((s./usr/lib/python2.6/multiprocessing/managers.pyRs	tpicklet	xmlrpclibcBseZdZhZeZddddZdZdZ	dZ
dZedZ
dZdd	Zd
ZdZdZd
ZedZedZeddddedZRS(s!
    Base class for managers
    RcCss|djoti}n||_t||_t|_ti|i_	||_
t|\|_|_
dS(N(RWRRTt_addressRt_authkeyRt_stateRRt_serializerRUt	_Listenert_Client(RRRTR^((s./usr/lib/python2.6/multiprocessing/managers.pyRs
		cCs%t|i|i|i|iffS(N(R2tfrom_addressRRR(R((s./usr/lib/python2.6/multiprocessing/managers.pyt
__reduce__scCs<|iitijptt|i|i|i|i	S(sX
        Return server object with serve_forever() method and address attribute
        (
RRRRR4RFt	_registryRRR(R((s./usr/lib/python2.6/multiprocessing/managers.pyt
get_serverscCsNt|i\}}||id|i}t|ddti|i_	dS(s>
        Connect manager object to the server process
        RTRMN(
RURRRR1RWRRRR(RR_R`R((s./usr/lib/python2.6/multiprocessing/managers.pytconnectsc	Cs8|iitijpttidt\}}tdt	|i
d|i|i|i
|i|f|_did|iiD}t	|id||i_|ii|i|i|_|iti|i_ti|t	|id|i|i|i
|i|ifdd|_d	S(
s@
        Spawn a server process for this manager object
        tduplexRaR-t:cssx|]}t|VqWdS(N(R3(t.0ti((s./usr/lib/python2.6/multiprocessing/managers.pys	<genexpr>s	R7texitpriorityiN(RRRRR4R
tPipetFalseRR2t_run_serverRRRRt_processRt	_identityR$R@RjRmR)RR	Rt_finalize_managerRRG(RtreadertwriterR((s./usr/lib/python2.6/multiprocessing/managers.pyRjs$


cCsS|i||||}|i|i|itid|i|idS(s@
        Create a server, report its address and run it
        smanager serving at %rN(t_ServerR(RRmR	RRo(tclsRSRRTR^Rtserver((s./usr/lib/python2.6/multiprocessing/managers.pyRs

c	Os|iitijp
td|i|id|i}z)t|dd|f||\}}Wd|i
Xt||i||fS(sP
        Create a new shared object; return the token and exposed tuple
        sserver not yet startedRTRHN(RRRRR4RRRR1RWRmR(RRR-R.RRR((s./usr/lib/python2.6/multiprocessing/managers.pyt_creates )cCs|ii|dS(sC
        Join the manager process (if it has been spawned)
        N(RR(Rttimeout((s./usr/lib/python2.6/multiprocessing/managers.pyRscCsA|i|id|i}zt|ddSWd|iXdS(sS
        Return some info about the servers shared objects and connections
        RTRKN(RRRR1RWRm(RR((s./usr/lib/python2.6/multiprocessing/managers.pyt_debug_info!scCsA|i|id|i}zt|ddSWd|iXdS(s5
        Return the number of shared objects
        RTRLN(RRRR1RWRm(RR((s./usr/lib/python2.6/multiprocessing/managers.pyt_number_of_objects+scCs|S(N((R((s./usr/lib/python2.6/multiprocessing/managers.pyt	__enter__5scCs|idS(N(RG(Rtexc_typetexc_valtexc_tb((s./usr/lib/python2.6/multiprocessing/managers.pyt__exit__8scCs'|iotidy8||d|}zt|ddWd|iXWntj
onX|idd|iojtidt|doItid	|i	|idd
|iotidqqqnt
i|_yt
i|=Wntj
onXdS(sQ
        Shutdown the manager process; will be registered as a finalizer
        s#sending shutdown message to managerRTRGNRg?smanager still aliveRs'trying to `terminate()` manager processg?s#manager still alive after terminate(tis_aliveR	RR1RWRmRsRR<RRRRRt_address_to_localtKeyError(tprocessRRTR!RR((s./usr/lib/python2.6/multiprocessing/managers.pyR;s.






cCs|iS((R(R((s./usr/lib/python2.6/multiprocessing/managers.pyt<lambda>[sc
s,d|ijo|ii|_ndjo
tn|ptdd}|ptdd}|ocx`|iD]N\}}t|tjpt	d|t|tjpt	d|qWn|||f|i<|o/fd}	|	_
t||	ndS(s9
        Register a typeid with the manager type
        Rt	_exposed_t_method_to_typeid_s%r is not a stringc	stid|i||\}}||id|d|id|}|i|id|i}t|dd|i	f|S(Ns)requesting creation of a shared %r objecttmanagerRTRRO(
R	RyRRRRRR1RWR(RR-R.RtexptproxyR(RR(s./usr/lib/python2.6/multiprocessing/managers.pyR?xsN(t__dict__RtcopyRWt	AutoProxyR;RR2R3R4R$tsetattr(
RRRRRRt
create_methodtkeyRR?((RRs./usr/lib/python2.6/multiprocessing/managers.pytregister]s"


!)
	N(R$R%R&RRFRRWRRRRRjtclassmethodRRRRRRRtstaticmethodRtpropertyRRhR(((s./usr/lib/python2.6/multiprocessing/managers.pyRs(
					!		
	
		 	tProcessLocalSetcBseZdZdZRS(cCsti|ddS(NcSs
|iS((tclear(R>((s./usr/lib/python2.6/multiprocessing/managers.pyRs(R	tregister_after_fork(R((s./usr/lib/python2.6/multiprocessing/managers.pyRscCst|dfS(N((R2(R((s./usr/lib/python2.6/multiprocessing/managers.pyRs(R$R%RR(((s./usr/lib/python2.6/multiprocessing/managers.pyRs	cBseZdZhZeiZdddedZ	dZ
d
hdZdZdZ
edZdZdZd	Zd
ZdZRS(s.
    A base for proxies of shared objects
    cCsCtiizRtii|id}|djo)tit	f}|ti|i<nWdtii
X|d|_|d|_||_
|i
i|_||_||_t|d|_|dj	ot||_n3|idj	o|ii|_nti|_|o|inti|tidS(Nii(Rt_mutexRRR|RRWR	tForkAwareLocalRRt_tlst_idsett_tokenRt_idt_managerRRURRRRRTt_increfRt_after_fork(RRR^RRTRRNt	tls_idset((s./usr/lib/python2.6/multiprocessing/managers.pyRs,



			
cCstidti}tiidjo|dtii7}n|i|iid|i	}t
|dd|f||i_
dS(Nsmaking connection to managert
MainThreadt|RTRI(R	RyRR@RZRzRRRRR1RWRR
(RR@R((s./usr/lib/python2.6/multiprocessing/managers.pyt_connects
cCs;y|ii}WnBtj
o6tidtii|i|ii}nX|i	|i
|||f|i\}}|djo|S|djo|\}}|ii
|id}	|	||id|id|id|}
|i|id|i}t|d	d|if|
St||d	S(
sW
        Try to call a method of the referrent and return a copy of the result
        s#thread %r does not own a connections#RETURNs#PROXYiRRTRRON(RR
R{R	RyRZRzR@RR(RR)RRRRRRRR1RWRR*(RR,R-R.RR/R0RRRR((s./usr/lib/python2.6/multiprocessing/managers.pyt_callmethods*	


cCs
|idS(s9
        Get a copy of the value of the referent
        s	#GETVALUE(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyt	_getvaluesc
Cs|i|iid|i}t|dd|iftid|ii	|i
i|i|io
|ii
}ti|tid|i|i||i|i
|ifdd|_dS(NRTRNs	INCREF %rR-Ri
(RRRRR1RWRR	RyRRtaddRRRRt_decrefRt_close(RRR!((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs|i|i|djp|itijoqyEtid|i||id|}t	|dd|ifWqt
j
o}tid|qXntid|i|o@t|do0tidti
i|ii|`ndS(Ns	DECREF %rRTROs... decref failed %ss%DECREF %r -- manager already shutdownR
s-thread %r has no more proxies so closing conn(tdiscardRRWRRRR	RyRR1RsR<RZRzR@R
Rm(RRTR!ttlstidsetRRRx((s./usr/lib/python2.6/multiprocessing/managers.pyRs 	
cCsDd|_y|iWn&tj
o}tid|nXdS(Nsincref failed: %s(RWRRRsR	R(RRx((s./usr/lib/python2.6/multiprocessing/managers.pyRs
	cCsh}tio|i|d<nt|dto*|i|d<tt|i|i	|ffStt
||i|i	|ffSdS(NRTt_isautoR(R
tthread_is_spawningRR;RRtRebuildProxyRRRR2(RR.((s./usr/lib/python2.6/multiprocessing/managers.pyRs

cCs
|iS(N(R(Rtmemo((s./usr/lib/python2.6/multiprocessing/managers.pyt__deepcopy__*scCs*dt|i|iidt|fS(Ns<%s object, typeid %r at %s>s0x%x(R2R$RRR(R((s./usr/lib/python2.6/multiprocessing/managers.pyR#-scCs:y|idSWn"tj
ot|d dSXdS(sV
        Return representation of the referent (or a fall-back if that fails)
        R#is; '__str__()' failed>N(RRsR(R((s./usr/lib/python2.6/multiprocessing/managers.pyR81sN((R$R%R&RR	tForkAwareThreadLockRRWRhRRRRRRRRRRR#R8(((s./usr/lib/python2.6/multiprocessing/managers.pyRs%						
		cCsttdd}|o&|i|ijo|i|idS|idtottdt}|||d||SdS(s
    Function used for unpickling proxy objects.

    If possible the shared object is returned, or otherwise a proxy for it.
    RbiRNt_inheritingN(	R;RRWRRXRtpopRhR(RARR^R.RRN((s./usr/lib/python2.6/multiprocessing/managers.pyR>sc	Bse|}y|||fSWnej
onXh}x |D]}d||f|UqAWe|ef|}||_||||f<|S(sC
    Return an proxy type whose methods are given by `exposed`
    sLdef %s(self, *args, **kwds):
        return self._callmethod(%r, args, kwds)(RRR2RR(R@Rt_cachetdictmetht	ProxyType((s./usr/lib/python2.6/multiprocessing/managers.pyt
MakeProxyTypeSs	c
Cst|d}|djoC||id|}zt|dd|f}Wd|iXn|djo|dj	o
|i}n|djoti}ntd|i	|}|||d|d|d|}	t
|	_|	S(s*
    Return an auto-proxy for `token`
    iRTRJNs
AutoProxy[%s]RRN(RURWRR1RmRRRTRRRhR(
RR^RRTRRNRRRR((s./usr/lib/python2.6/multiprocessing/managers.pyRis


		t	NamespacecBseZdZdZRS(cKs|ii|dS(N(Rtupdate(RR.((s./usr/lib/python2.6/multiprocessing/managers.pyRscCsu|ii}g}x?|D]7\}}|idp|id||fqqW|idtid|S(NRCs%s=%rs
Namespace(%s)s, (RRt
startswithR=RR3R(RRR?R@R((s./usr/lib/python2.6/multiprocessing/managers.pyR#s
(R$R%RR#(((s./usr/lib/python2.6/multiprocessing/managers.pyRs	tValuecBs>eZedZdZdZdZeeeZRS(cCs||_||_dS(N(t	_typecodet_value(RRRtlock((s./usr/lib/python2.6/multiprocessing/managers.pyRs	cCs|iS(N(R
(R((s./usr/lib/python2.6/multiprocessing/managers.pyR|scCs
||_dS(N(R
(RR((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs dt|i|i|ifS(Ns
%s(%r, %r)(R2R$RR
(R((s./usr/lib/python2.6/multiprocessing/managers.pyR#s(	R$R%RhRR|RR#RR(((s./usr/lib/python2.6/multiprocessing/managers.pyRs
			cCsti||S(N(R(RtsequenceR((s./usr/lib/python2.6/multiprocessing/managers.pytArrayst
IteratorProxycBsDeZdZdZdZdZdZd	Zd
ZRS(t__next__tnextR(tthrowRmcCs|S(N((R((s./usr/lib/python2.6/multiprocessing/managers.pyt__iter__scGs|id|S(NR(R(RR-((s./usr/lib/python2.6/multiprocessing/managers.pyRscGs|id|S(NR(R(RR-((s./usr/lib/python2.6/multiprocessing/managers.pyRscGs|id|S(NR((R(RR-((s./usr/lib/python2.6/multiprocessing/managers.pyR(scGs|id|S(NR(R(RR-((s./usr/lib/python2.6/multiprocessing/managers.pyRscGs|id|S(NRm(R(RR-((s./usr/lib/python2.6/multiprocessing/managers.pyRms(s__next__snextssendsthrowsclose(	R$R%RRRRR(RRm(((s./usr/lib/python2.6/multiprocessing/managers.pyRs					t
AcquirerProxycBs5eZdZedZdZdZdZRS(RRcCs|id|fS(NR(R(Rtblocking((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs
|idS(NR(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs
|idS(NR(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs
|idS(NR(R(RRRR((s./usr/lib/python2.6/multiprocessing/managers.pyRs(sacquiresrelease(R$R%RRhRRRR(((s./usr/lib/python2.6/multiprocessing/managers.pyRs
		tConditionProxycBs,eZdZd	dZdZdZRS(
RRtwaittnotifyt
notify_allcCs|id|fS(NR(R(RR((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs
|idS(NR(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs
|idS(NR(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyRs(sacquiresreleaseswaitsnotifys
notify_allN(R$R%RRWRRR(((s./usr/lib/python2.6/multiprocessing/managers.pyRs	t
EventProxycBs5eZdZdZdZdZd	dZRS(
tis_setRRRcCs
|idS(NR(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs
|idS(NR(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs
|idS(NR(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyRscCs|id|fS(NR(R(RR((s./usr/lib/python2.6/multiprocessing/managers.pyRs(sis_setssetsclearswaitN(R$R%RRRRRWR(((s./usr/lib/python2.6/multiprocessing/managers.pyRs
			tNamespaceProxycBs)eZdZdZdZdZRS(t__getattribute__t__setattr__t__delattr__cCsD|ddjoti||Sti|d}|d|fS(NiRCRR(tobjectR(RRt
callmethod((s./usr/lib/python2.6/multiprocessing/managers.pyt__getattr__scCsJ|ddjoti|||Sti|d}|d||fS(NiRCRR (R"R R(RRRR#((s./usr/lib/python2.6/multiprocessing/managers.pyR scCsD|ddjoti||Sti|d}|d|fS(NiRCRR!(R"R!R(RRR#((s./usr/lib/python2.6/multiprocessing/managers.pyR!s(s__getattribute__s__setattr__s__delattr__(R$R%RR$R R!(((s./usr/lib/python2.6/multiprocessing/managers.pyRs		t
ValueProxycBs/eZdZdZdZeeeZRS(R|RcCs
|idS(NR|(R(R((s./usr/lib/python2.6/multiprocessing/managers.pyR|scCs|id|fS(NR(R(RR((s./usr/lib/python2.6/multiprocessing/managers.pyRs(sgetsset(R$R%RR|RRR(((s./usr/lib/python2.6/multiprocessing/managers.pyR%s		t
BaseListProxyt__add__t__contains__t__delitem__t__delslice__t__getitem__t__getslice__t__len__t__mul__t__reversed__t__rmul__t__setitem__t__setslice__R=tcounttextendtindextinsertRtremovetreverseRt__imul__t	ListProxycBseZdZdZRS(cCs|id|f|S(NR4(R(RR((s./usr/lib/python2.6/multiprocessing/managers.pyt__iadd__scCs|id|f|S(NR9(R(RR((s./usr/lib/python2.6/multiprocessing/managers.pyR9s(R$R%R;R9(((s./usr/lib/python2.6/multiprocessing/managers.pyR:s	t	DictProxyRRR|thas_keytpopitemt
setdefaultR	t
ArrayProxyt	PoolProxytapplytapply_asyncRmtimaptimap_unorderedRtmapt	map_asyncRtAsyncResulttIteratorcBseZdZRS(s(
    Subclass of `BaseManager` which supports a number of shared object types.

    The types registered are those intended for the synchronization
    of threads, plus `dict`, `list` and `Namespace`.

    The `multiprocessing.Manager()` function creates started instances of
    this class.
    (R$R%R&(((s./usr/lib/python2.6/multiprocessing/managers.pyRs	tQueuet
JoinableQueuetEventtLockR[t	SemaphoretBoundedSemaphoret	ConditionRRRRRR(Vt__all__tosRtweakrefRZRRJRRtmultiprocessingRRRRR	R
tmultiprocessing.processRtmultiprocessing.forkingRR
RRtmultiprocessing.utilRRtcPickleRtImportErrorRRRRDR@R2R;t
view_typesR"RR1R*RsR5RBRERFRR_R`tXmlListenert	XmlClientRURRRRRRRWRhRRRRRRRRRR%R&R:R<R@RARRRLRMR[RNRORPRRR(((s./usr/lib/python2.6/multiprocessing/managers.pyt<module>
s."	<
			
,

	
		


Youez - 2016 - github.com/yon3zu
LinuXploit