ó
ü
ƒYc@s
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlmZ
e
je	ƒ
Z
yd
dlZd„ZWne
k
r–


d„Zn
Xdef
d„ƒYZdejf
d	„ƒYZd
ef
d„ƒYZdef
d
„ƒYZdejf
d„ƒYZdS(s,
Serialization/Deserialization for privsep.

The wire format is a stream of msgpack objects encoding primitive
python datatypes.  Msgpack 'raw' is assumed to be a valid utf8 string
(msgpack 2.0 'bin' type is used for bytes).  Python lists are
converted to tuples during serialization/deserialization.
iÿÿÿÿN(
t
_cCstt
jƒƒ
S(
N(tidtgreenlett
getcurrent(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyt_get_thread_ident'sc
Cs
tj
ƒjS(
N(t	threadingtcurrent_threadtident(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR-s
t
Serializerc
Bs#eZ
d„Zd
„Zd„ZRS(cCs
|
|_dS(
N(
t	writesock(tselfR	((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyt__init__2s
cCs)tj
|
d
tƒ

}|jj|ƒ

dS(Ntuse_bin_type(tmsgpacktpackbtTrueR	tsendall(R
tmsgtbuf((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pytsend5s

c

Cs|jj
tjƒ

dS(
N(R	tshutdowntsockettSHUT_WR(
R
((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pytclose9s(t__name__t
__module__RRR(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR1s
		tDeserializerc
Bs#eZ
d„Zd
„Zd„ZRS(cCs(|
|_t
jd
tddƒ|_dS(Ntuse_listtencodingsutf-8(treadsockR
tUnpackertFalsetunpacker(R
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyRAs
	
c


Cs|S(
N((
R
((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyt__iter__Es
c
Csxxtrzyt
|jƒ
SWqtk
rv


y2|jjd
ƒ
}
|
sK‚n|jj|
ƒ

Wqwtjk
rr


qwXqXqWdS(Ni(	RtnextR t
StopIterationRtrecvtfeedRttimeout(R
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyt__next__Hs
	










(RRRR!R'(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR@s
		tFuturec
Bs2eZ
dZd
„Zd„Zd„Zd„ZRS(s;A very simple object to track the return of a function callcCs(tj
|
ƒ
|_d|_d|_dS(
N(Rt	ConditiontcondvartNoneterrortdata(R
tlock((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyRYs

	
cCs|
|_|j
jƒ
d
S(s0Must already be holding lock used in constructorN(R-R*tnotify(R
R-((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyt
set_result^s	
cCs|
|_|j
jƒ
d
S(s0Must already be holding lock used in constructorN(R,R*R/(R
texc((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyt
set_exceptioncs	
c

Cs/|jj
ƒ
|jd
k	r(|j‚
n|jS(s0Must already be holding lock used in constructorN(R*twaitR,R+R-(
R
((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pytresulths



(RRt__doc__RR0R2R4(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR(Vs

			t
ClientChannelc
Bs5eZ
d„Zd
„Zd„Zd„Zd„ZRS(cCsqt|
ƒ
|_
tjƒ|_tjd
dd|jdt|
ƒ
f
ƒ|_t	|j_
i|_|jjƒ
dS(Ntnametprivsep_readerttargettargs(
RtwriterRtLockR.tThreadt_reader_mainRt
reader_threadRtdaemontoutstanding_msgststart(R
tsock((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyRqs


	

	

	cCs¿xb|
D]Z}|\}}|d
kr(q|j
.
||jksGt‚
|j|j|ƒ

Wd
QXqWtjdƒ

ttdƒ
ƒ
}|j
,
x$|jj	ƒD]}|j
|ƒ

qžWWd
QXd
S(s-This thread owns and demuxes the read channelNsEOF on privsep read channels,Premature eof waiting for privileged process(R+R.RAtAssertionErrorR0tLOGtdebugtIOErrorRtvaluesR2(R
treaderRtmsgidR-R1tmbox((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR>~s











c
Csd
S(s=Received OOB message. Subclasses might want to override this.N((R
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pytout_of_band•sc	Cs‚tƒ}t
|jƒ
}|j[
||jks7t‚
||j|<z&|jj||
fƒ

|jƒ}Wd|j|=XWdQX|S(
N(RR(R.RARDR;RR4(R
Rtmyidtfuturetreply((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyt	send_recv™s
	






c

Cs.|j
|j
jƒ
WdQX|jjƒ
dS(
N(R.R;RR?tjoin(
R
((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR©s


(RRRR>RLRPR(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR6ps

	
			t
ServerChannelc
Bs2eZ
dZd
„Zd„Zd„Zd„ZRS(s!Server-side twin to ClientChannelcCsFtj
ƒ|_tt|
ƒ
ƒ
|_tj
ƒ|_t|
ƒ
|_dS(
N(	RR<trlocktiterRtreader_itertwlockRR;(R
RC((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR³s



c


Cs|S(
N((
R
((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR!¹s
c

Cs!|j
t
|jƒ
SWdQXdS(
N(RSR"RU(
R
((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyR'¼s


cCs$|j
|j
j|
ƒ

WdQXdS(
N(RVR;R(R
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyRÀs


(RRR5RR!R'R(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyRR°s

			(R5tloggingRRR
tsixtoslo_privsep._i18nRt	getLoggerRRERRtImportErrortobjectRtIteratorRR(R6RR(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_privsep/comm.pyt<module>s"







@