ó
õEYc@@s7
dZd
dl
mZmZ
d
dlZd
dlZd
dlmZ
d
dlm	Z	
ddl
mZ
ejd
dkZ
yd
dlZWnek
r 


dZn
Xyd
d	lmZ
Wnek
rÑ


d
„Zn
Xd„Zd„Ze
rÿd
„Zd„Znd„Zd„Zdejf
d„ƒYZd„ZdS(uCompatibility utilities.i(tabsolute_importtunicode_literalsN(
tpromise(
twrapsi
(
tstring_ti(
tset_cloexeccC@s†td
krd
Sy
tj}Wntk
r<


tdƒ
‚
n
Xtj|tjƒ}|
re||O}n||M}tj|tj|ƒS(u Set flag to close fd after exec.Nu1close-on-exec flag not supported on this platform(tfcntltNonet
FD_CLOEXECtAttributeErrortNotImplementedErrortF_GETFDtF_SETFD(tfdtcloexecRtflags((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pyRs












c

C@smy|jSWn[t
k
rh


y6t|jtƒrPt|jƒ
d
krP|jdSWqit
k
rd


qiXn
XdS(u’Get exception errno (if set).

    Notes:
        :exc:`socket.error` and :exc:`IOError` first got
        the ``.errno`` attribute in Py2.7.
    ii(terrnoR	t
isinstancetargsttupletlen(
texc((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pyt	get_errno)s



'




c
@stˆƒ
‡f
d
†ƒ
}
|
S(u,Decorator to mark generator as a co-routine.c@sˆ||
Ž}t|ƒ

|S(
N(
tnext(Rtkwargstco(
tgen(s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pyt_boot>s


(
R(RR((
Rs?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pytcoro<sc

C@st|t
ƒr|jƒS|S(
uConvert str to bytes.(Rtstrtencode(
t
s((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pytstr_to_bytesIs


c

C@st|t
ƒr|jƒS|S(
uConvert bytes to str.(Rtbytestdecode(
R((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pytbytes_to_strOs


c

C@st|t
ƒr|jƒS|S(
uConvert str to bytes.(RtunicodeR(
R((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pyR Vs


c


C@s|S(
uConvert bytes to str.((
R((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pyR#\stNullHandlerc
B@seZ
dZd
„ZRS(u$A logging handler that does nothing.c
C@sdS(
N((tselftrecord((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pytemitds
(t__name__t
__module__t__doc__R((((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pyR%as
c

C@sAt|t
ƒr!tj|ƒ
}n|js=|jtƒƒ

n|S(
uGet logger by name.(RRtloggingt	getLoggerthandlerst
addHandlerR%(
tlogger((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pyt
get_loggerhs


	

(R+t
__future__RR
R,tsystvineRt
vine.utilsRtfiveRtversion_infotis_py3kRtImportErrorRtosRRRR R#tHandlerR%R1(((s?/home/tvault/.virtenv/lib/python2.7/site-packages/amqp/utils.pyt<module>
s0