File "reduction.cpython-33.pyc"

Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python33/lib64/python3.3/multiprocessing/__pycache__/reduction.cpython-33.pyc
File size: 14.91 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit


f%c@sdd
ddgZddl
Z
ddlZddlZddlZddlZddlZddlmZ
ddl	m
Z
mZmZ
ddl	m
Z
mZ
ejd	kpeed
oeedsed

nejd	kr
ed
g
7ZddlZddZddZGdddeZGdddeZddZddZdd
ZddZdd
ZddZnmejdkZddZddZGd d!d!eZd"dZd#dZd$d
Zd%dZGd&d'd'eZ e Z!dS((u
reduce_socketureduce_connectionusend_handleurecv_handleiN(
ucurrent_process(uregister_after_forkudebugu	sub_debug(u
is_exitingusub_warninguwin32uCMSG_LENu
SCM_RIGHTSu%pickling of connections not supportedureduce_pipe_connectioncCs&t|
t
j|}|j|

dS(
N(u	DupHandleu_winapiuDUPLICATE_SAME_ACCESSusend(uconnuhandleudestination_pidudh((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyusend_handle*s

c


Cs|jj
S(
N(urecvudetach(
uconn((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyurecv_handle.s
c

Bs/|EeZ
dZdd
d
ZddZdS(u	DupHandlec
Cs|dkrt
j}ntjtjd|}z+tjtj|
||dd
|_	Wdtj
|

X||_||_dS(NiF(
uNoneuosugetpidu_winapiuOpenProcessuPROCESS_DUP_HANDLEuFalseuDuplicateHandleuGetCurrentProcessu_handleuCloseHandleu_accessu_pid(uselfuhandleuaccessupiduproc((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu__init__2s




	

	
uDupHandle.__init__c

Cs{|jt
jkr|jStjtjd
|j}
z/tj|
|jtj	|j
d
tjSWdtj|


XdS(NF(
u_piduosugetpidu_handleu_winapiuOpenProcessuPROCESS_DUP_HANDLEuFalseuDuplicateHandleuGetCurrentProcessu_accessuDUPLICATE_CLOSE_SOURCEuCloseHandle(uselfuproc((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyudetach@s






uDupHandle.detachN(u__name__u
__module__u__qualname__uNoneu__init__udetach(
u
__locals__((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu	DupHandle1s
u	DupHandlec

Bs,|EeZ
dZd
dZddZdS(u	DupSocketcs:|
jf
d
d}t
j|j|_dS(Ncs j|

}|j
|

dS(
N(ushareu
send_bytes(uconnupidushare(
unew_sock(u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyusendPs

u DupSocket.__init__.<locals>.send(udupuresource_shareruregisterucloseu_id(uselfusockusend((
unew_socku>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu__init__Ns

uDupSocket.__init__c

CsAtj
|j
}
z|
j}tj|
SWd|
j
XdS(
N(uresource_shareruget_connectionu_idu
recv_bytesusocketu	fromshareuclose(uselfuconnushare((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyudetachUs




uDupSocket.detachN(u__name__u
__module__u__qualname__u__init__udetach(
u
__locals__((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu	DupSocketMs
u	DupSocketc

Cstt
|
f
fS(
N(urebuild_socketu	DupSocket(
u
s((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu
reduce_socket]s
c


Cs
|jS(
N(
udetach(
uds((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyurebuild_socket`s
urebuild_socketc
CsY|j}
t
j|
t
jt
j,}t|
}t||j|jffSWdQXdS(
N(	ufilenousocketufromfduAF_INETuSOCK_STREAMu	DupSocketurebuild_connectionureadableuwritable(uconnuhandleu
suds((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyureduce_connectioncs



cCs2d
dlm
}
|j}||j|
|S(Ni
(
u
Connection(u
connectionu
Connectionudetach(udsureadableuwritableu
Connectionusock((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyurebuild_connectionis


urebuild_connectionc
Cs\|jrt
jnd
|jr't
jnd
B}
t|j|
}t||j|jffS(Ni(ureadableu_winapiuFILE_GENERIC_READuwritableuFILE_GENERIC_WRITEu	DupHandleufilenourebuild_pipe_connection(uconnuaccessudh((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyureduce_pipe_connectionns



cCs,d
dlm
}
|j}|||
|S(Ni
(
uPipeConnection(u
connectionuPipeConnectionudetach(udhureadableuwritableuPipeConnectionuhandle((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyurebuild_pipe_connectionts


urebuild_pipe_connectionudarwincCstj
|jtjtj8}|jd
g
tjtjtj	d|
fg

WdQXt
r|jdkrtd

ndS(Ns
xu@isACKu%did not receive acknowledgement of fd(
usocketufromfdufilenouAF_UNIXuSOCK_STREAMusendmsgu
SOL_SOCKETu
SCM_RIGHTSustructupackuACKNOWLEDGEu
recv_bytesuRuntimeError(uconnuhandleudestination_pidu
s((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyusend_handles

$



c

Cstj
d

}
tj|jtjtj}|jdtj|

\}}}}yit	rs|j
d

n|d\}}}	|tjkr|tjkrtj
d
|	d|
dSWntttjfk
r


Yn
Xtd

WdQXdS(Nu@ii
sACKiuInvalid data received(ustructucalcsizeusocketufromfdufilenouAF_UNIXuSOCK_STREAMurecvmsguCMSG_LENuACKNOWLEDGEu
send_bytesu
SOL_SOCKETu
SCM_RIGHTSuunpacku
ValueErroru
IndexErroruerroruRuntimeError(
uconnusizeu
sumsguancdatauflagsuaddru
cmsg_levelu	cmsg_typeu	cmsg_data((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyurecv_handles

$
'






"


c

Bs,|EeZ
dZd
dZddZdS(uDupFdcsLtj
|

f
d
d}f
dd}tj|||_dS(Ncst||

dS(
N(
usend_handle(uconnupid(
unew_fd(u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyusends
uDupFd.__init__.<locals>.sendcstj


dS(
N(uosuclose((
unew_fd(u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyucloses
uDupFd.__init__.<locals>.close(uosudupuresource_shareruregisteru_id(uselfufdusenduclose((
unew_fdu>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu__init__s

uDupFd.__init__c

Cs2tj
|j
}
zt|

SWd|
j
XdS(
N(uresource_shareruget_connectionu_idurecv_handleuclose(uselfuconn((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyudetachs


uDupFd.detachN(u__name__u
__module__u__qualname__u__init__udetach(
u
__locals__((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyuDupFds
uDupFdc
Cs1t|j

}
t|
|j|j|jffS(
N(uDupFdufilenourebuild_socketufamilyutypeuproto(u
sudf((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu
reduce_sockets

cCs5|j}t
j||
||}tj|

|S(
N(udetachusocketufromfduosuclose(udfufamilyutypeuprotoufdu
s((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyurebuild_sockets




c
Cs+t|j

}
t|
|j|jffS(
N(uDupFdufilenourebuild_connectionureadableuwritable(uconnudf((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyureduce_connections

cCs,d
dlm
}
|j}|||
|S(Ni
(
u
Connection(u
connectionu
Connectionudetach(udfureadableuwritableu
Connectionufd((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyurebuild_connections


c

Bsq|EeZ
dZd
dZddZedd
Zddd
Zd	d
Z	ddZ
d
dZdS(uResourceSharerc

CsYd
|_i|_
g|_tj|_d|_d|_d|_	t
|tj
dS(Ni(
u_keyu_cacheu
_old_locksu	threadinguLocku_lockuNoneu	_listeneru_addressu_threaduregister_after_forkuResourceShareru
_afterfork(
uself((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu__init__s
	
	
	

	
	
	
uResourceSharer.__init__c
Cse|jV
|j
dkr&|j
n|jd
7_|
|f|j|j<|j
|jfSWdQXdS(Ni
(u_locku_addressuNoneu_startu_keyu_cache(uselfusenduclose((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyuregisters







uResourceSharer.registerc
CsQd
dlm
}

|\}}|
|dtj

}|j|tjf

|S(Ni
(
uClientuauthkey(u
connectionuClientucurrent_processuauthkeyusenduosugetpid(uidentuClientuaddressukeyu
c((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyuget_connections




uResourceSharer.get_connectioncCsd
dlm
}
|j
|jdk	r||jdtj

}|jd

|j
|j	j
|


|j	jrtd

n|j
j
d|_	d|_d|_
x*|jjD]\}\}}|
qW|jj
nWdQXdS(Ni
(
uClientuauthkeyu-ResourceSharer thread did not stop when asked(u
connectionuClientu_locku_addressuNoneucurrent_processuauthkeyusenducloseu_threadujoinuis_aliveusub_warnu	_listeneru_cacheuitemsuclear(uselfutimeoutuClientu
cukeyusenduclose((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyustops 















	
	
	
"

uResourceSharer.stopc
Csx*|jj
D]\}
\}}|
qW|jj
|jj|j

tj|_|jdk	r{|jj

nd|_d|_d|_dS(
N(
u_cacheuitemsuclearu
_old_locksuappendu_locku	threadinguLocku	_listeneruNoneucloseu_addressu_thread(uselfukeyusenduclose((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu
_afterforks
"






	
	
uResourceSharer._afterforkc
Csd
dlm
}

|jdks%t
td

|
dtj
|_|jj|_	t
jd|j
}d|_|j
||_dS(Ni
(
uListeneru0starting listener and thread for sending handlesuauthkeyutargetT(u
connectionuListeneru	_listeneruNoneuAssertionErrorudebugucurrent_processuauthkeyuaddressu_addressu	threadinguThreadu_serveuTrueudaemonustartu_thread(uselfuListeneru
t((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu_starts







	


uResourceSharer._startc

Cstt
d
r1t
jt
jtdt
j
nxyq|jj}
|
j}|dkrbPn|\}}|j
j|
\}}||
|
|
|
j
Wq4


t
sddl}tdddd|jdd

nYq4Xq4dS(Nupthread_sigmaski
iu.thread for sharing handles raised exception :
u
-iOu

(uhasattrusignalupthread_sigmasku	SIG_BLOCKurangeuNSIGu	_listeneruaccepturecvuNoneu_cacheupopucloseu
is_exitingu	tracebackusub_warningu
format_exc(uselfuconnumsgukeyudestination_pidusenducloseu	traceback((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu_serve
s$

"













	

uResourceSharer._serveN(u__name__u
__module__u__qualname__u__init__uregisterustaticmethoduget_connectionuNoneustopu
_afterforku_startu_serve(
u
__locals__((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyuResourceSharers

uResourceSharer("u__all__uosusysusocketu	threadingustructusignalumultiprocessingucurrent_processumultiprocessing.utiluregister_after_forkudebugu	sub_debugu
is_exitingusub_warninguplatformuhasattruImportErroru_winapiusend_handleurecv_handleuobjectu	DupHandleu	DupSocketu
reduce_socketurebuild_socketureduce_connectionurebuild_connectionureduce_pipe_connectionurebuild_pipe_connectionuACKNOWLEDGEuDupFduResourceShareruresource_sharer(((u>/opt/alt/python33/lib64/python3.3/multiprocessing/reduction.pyu<module>sF










		\