ó
 ‹EYc
@s•dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdd
lZddlmZm	Z	m
Z

ddlmZm
Z

dddddd	d
ddd
g
ZdZeejejejfƒ
Zedejfƒ
Zejd dkr	
ejejƒ

ne
jr
ejZnejjdƒ
jZej j!ej ƒ
Z"d„Z#d„Z$d„Z%ejd dkr¯
eej&ejfƒ
Z'eej(ej)ej*fƒ
Z+n<eej&ejej)fƒ
Z'eej(ej*ej,fƒ
Z+d„Z-yddlm.Z.
Wne/k
r$


e0ƒZ.n
Xde0f
d„ƒYZ1d„Z2dZ3yddl4m5Z5
Wn'e/k
r‡


de0f
d„ƒYZ5n
Xd„Z6d
S(iÿÿÿÿN(t
trampolinet
notify_openedtIOClosed(t	get_errnotsixtGreenSockett_GLOBAL_DEFAULT_TIMEOUTtset_nonblockingtSOCKET_BLOCKINGt
SOCKET_CLOSEDtCONNECT_ERRtCONNECT_SUCCESSt
shutdown_safetSSLtsocket_timeoutiiitwintsocketcCsK|j|
ƒ
}|t
krd
S|tkrGtj|tj|ƒ‚
n|S(s›
    Attempts to connect to the address, returns the descriptor if it succeeds,
    returns None if it needs to trampoline, and raises any exceptions.
    N(t
connect_exR
tNoneRRterrorterrnot	errorcode(t
descriptortaddressterr((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pytsocket_connect"s




c
CsD|jt
jt
jƒ}
|
tkr@t
j|
tj|
ƒ‚
ndS(
N(t
getsockoptRt
SOL_SOCKETtSO_ERRORRRRR(RR((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pytsocket_checkerr/s


c
CsGy|jƒSWn2t
jk
rB
}

t|
ƒ
tjkr<d
S‚n
Xd
S(s«
    Attempts to accept() on the descriptor, returns a client,address tuple
    if it succeeds; returns None if it needs to trampoline, and raises
    any exceptions.
    N(tacceptRRRRtEWOULDBLOCKR(Rt
e((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt
socket_accept5s




c
Cs²y
|j}
Wn”t
k
r£


yd
dl}Wntk
rL


tdƒ
‚
n
X|jƒ}|j||jƒ}|tjB}||kr®|j||j	|ƒ
q®nX|
dƒ

dS(s£
    Sets the descriptor to be nonblocking.  Works on many file-like
    objects as well as sockets.  Only sockets can be nonblocking on
    Windows, however.
    iÿÿÿÿNsnset_nonblocking() on a file object with no setblocking() method (Windows pipes don't support non-blocking I/O)i(
tsetblockingtAttributeErrortfcntltImportErrortNotImplementedErrortfilenotF_GETFLtost
O_NONBLOCKtF_SETFL(tfdR"R$R't
orig_flagst	new_flags((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRNs











(
RcBs‹
eZ
dZd!Zejd
„
Zed„ƒ
Z	e
jr]d„Zd„Z
eee
ƒZnd„Zeed!d!d„Zd„Zd„Zd	„Zd
„Zd„Zd„Ze
jrÆd
„Zn	d„Zd„Zd„Zd„Zdd„
Zdd„
Zddd„Zddd„Zd„Z dd„
Z!d„Z"dd„
Z#d„Z$d„Z%d„Z&de'j(kr‰
d„Z)d „Z*nRS("s

    Green version of socket.socket class, that is intended to be 100%
    API-compatible.

    It also recognizes the keyword parameter, 'set_nonblocking=True'.
    Pass False to indicate that socket is already in non-blocking mode
    to save syscalls.
    cOs#
|jd
t
ƒ}t|
tjƒrIt|
||Ž
}t|jƒƒ

n|
}y|jƒpgt	j
ƒ|_Wn tk
r


t	j
ƒ|_n
X|r¤t
|ƒ

n||_t|_|j|_|j|_|j|_|j|_|j|_|j|_|j|_|j|_t|_dS(NR(tpoptTruet
isinstanceRt
integer_typest_original_socketR
R't
gettimeoutRtgetdefaulttimeoutt_timeoutR#RR,tFalsetact_non_blockingtbindtclosetgetsocknameRtlistent
setsockopttshutdownt_closed(tselftfamilytargstkwargstshould_set_nonblockingR,((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt__init__„s,









		







c


Cs|S(
N((
R@((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt_sock©sc


Cs
|jj
S(
N(R,t_io_refs(
R@((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt_get_io_refs®s
cCs|
|j_
dS(
N(R,RG(R@tvalue((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt_set_io_refs±s
cCsD|jdkrt|
ƒ
‚
nt|j|
ƒ}t||
|ƒ
|S(
N(R,RR#tgetattrtsetattr(R@tnametattr((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt__getattr__»s





cCsi|jrt
ƒ‚
ny/t|
d
|d|d|d|d|jƒ
SWnt
k
rd


|jƒ
‚n
XdS(sí We need to trampoline via the event hub.
            We catch any signal back from the hub indicating that the operation we
            were waiting on was associated with a filehandle that's since been
            invalidated.
        treadtwritettimeoutttimeout_exctmark_as_closedN(R?RRt_mark_as_closed(R@R,RPRQRRRS((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt_trampolineÂs	







c
Cs¥|jr|j
jƒS|j
}
td
ƒ
}xstr t|
ƒ
}|dk	rx|\}}t|ƒ

t|ƒ
|ƒ
|fS|j	|
dtd|j
ƒd|ƒ

q.WdS(Ns	timed outRPRRRS(R8R,RRR0R!RRttypeRVR4(R@R,t_timeout_exctrestclienttaddr((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRÕs
	


	

	






c

Cs
t|_
d
S(s" Mark this socket as being closed N(R0R?(
R@((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRUâsc
Cs,t|d
dƒ}
|
dk	r(|
ƒ
ndS(NR:(RKR(R@R:((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt__del__æs

cCsX
|jr|j
j|
ƒ
S|j
}td
ƒ
}|jƒdkr x
t||
ƒsœy|j|dtƒ


Wn#t	k
rŽ


t
jtj
ƒ
‚
n
Xt|ƒ

qCWn´tjƒ|jƒ}x›trS
t||
ƒrÒdStjƒ|krí|‚
n|tjƒ}y#|j|dtd|d|ƒ

Wn#t	k
rE



t
jtj
ƒ
‚
n
Xt|ƒ

q¹WdS(Ns	timed outRQRRRS(R8R,tconnectRR4RRRVR0RRRRtEBADFDRttime(R@RR,RXtendRR((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR]ìs.
	

	









	



	


#


cCst
|jr|j
j|
ƒ
S|j
}|jƒdkr¢x9
t||
ƒsžy!|j|d
tƒ


t|ƒ

Wq7t	j
k
r†
}
t|ƒ
Stk
rš


t
jSXq7WnÎtjƒ|jƒ}t	jt
jƒ
}x£tro
yet||
ƒrédStjƒ|kr
|‚
n|j|d
td|tjƒd|ƒ

t|ƒ

WqÍt	j
k
rW

}
t|ƒ
Stk
rk



t
jSXqÍWdS(NRQiRRRS(R8R,RR4RRRVR0RRRRRRR^R_RRtEAGAIN(R@RR,texR`RS((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR
s6
	

	












	




	
"







c
OsD|jj
|
|Ž}t|ƒ
|d
tƒ

}|j|jƒƒ

|S(NR(R,tdupRWR7t
settimeoutR4(R@RBtkwtsocktnewsock((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRc%
s



c
Ostj
||
|Ž
S(
N(R3tmakefile(R@RBRC((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRh,
s
c
OsG|jƒ}t
||
|Ž
}t|d
ƒrC|jƒ
d|_n|S(Nt_drop(Rct_python2_fileobjectthasattrRiRR:(R@RBRCtduppedRY((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRh/
s





c
Os&tj
d
tddƒ

|j|
|ŽS(Ns>makeGreenFile has been deprecated, please use makefile insteadt
stackleveli(twarningstwarntDeprecationWarningRh(R@RBRe((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt
makeGreenFile;
s
	


c

	Cs2|j|j
d
td|jƒdtdƒ
ƒ

dS(NRPRRRSs	timed out(RVR,R0R4R(
R@((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt_read_trampoline@
s


	


cGsÆ|j}|j
r|
|ŒSx£trÁy%|d
s?|jƒ
n|
|ŒSWnDtjk
r
}
t|ƒ
tkrtq‘t|ƒ
tkrŠ|S‚n
Xy|jƒ
Wqt	k
r½
}
t
ƒ‚
qXqWdS(Ni(R,R8R0RrRRRRR	RtEOFError(R@t	recv_metht	empty_valRBR,R ((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt
_recv_loopG
s$
	
	

	
	










icCs|j|j
jd
|
|ƒS(Nt(RvR,trecv(R@tbufsizetflags((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRxg
s
cCs|j|j
jd
|
|ƒS(NRw(RvR,trecvfrom(R@RyRz((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR{j
s
cCs|j|j
jd
|
||ƒS(Ni(RvR,t	recv_into(R@tbuffertnbytesRz((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR|m
s
cCs|j|j
jd
|
||ƒS(Ni(RvR,t
recvfrom_into(R@R}R~Rz((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRp
s
c	Gsß|jr|
||Œ
St
d
ƒ
}x¶trÚy|
||Œ
SWnCtjk
r
}
t|ƒ
}|tjksx|tkr‚‚q‚n
Xy,|j	|j
dtd|jƒd|ƒ

Wq%tk
rÖ


tjtj
dƒ‚
q%Xq%WdS(Ns	timed outRQRRRSs#Connection closed by another thread(R8RR0RRRRtENOTCONNRRVR,R4Rt
ECONNRESET(R@tsend_methodtdataRBRXR teno((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt
_send_loops
s
	


	







!



cCs|j|j
j|
|ƒS(
N(R…R,tsend(R@RƒRz((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR††
s
cGs|j|j
j|
|ŒS(
N(R…R,tsendto(R@RƒRB((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR‡‰
s
cCsO|j|
|ƒ}t
|
ƒ
}x*||krJ||j|
||ƒ7}q!WdS(
N(R†tlen(R@RƒRzttailtlen_data((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pytsendallŒ
s



cCs1|
rt|_
d|_nt|_
d
|_dS(Ng(R7R8RR6R0(R@tflag((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR"’
s


	
	
cCs±|
dks|
t
kr)|jtƒ

dSy
|
j}Wntk
rU


td
ƒ
‚
n
X|ƒ}
|
dkrztdƒ
‚
n|
dkr›t|_d|_	nt
|_|
|_	dS(Nsa float is requiredgsTimeout value out of range(RRR"R0t	__float__R#t	TypeErrort
ValueErrorR8R6R7(R@thowlongt
f((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRdš
s










	



	
	
c


Cs|jS(
N(
R6(
R@((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR4¬
s
t__pypy__c

Cs t|j
d
|j
ƒjƒ
dS(NRF(RKR,t_reuse(
R@((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR“°
s
c

Cs t|j
d
|j
ƒjƒ
dS(NRF(RKR,Ri(
R@((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRi³
s
N(+t__name__t
__module__t__doc__RR,RtAF_INETREtpropertyRFRtPY3RHRJRGROR7RVRRUR\R]RRcRhRqRrRvRxR{R|RR…R†R‡R‹R"RdR4tsystbuiltin_module_namesR“Ri(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRwsH%	
				
						
				 					
	cOstd
ƒ
‚
dS(NsI/O operation on closed file(
R(RBRC((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt_operation_on_closed_file·
s
s
    GreenPipe is a cooperative replacement for file class.
    It will cooperate on pipes. It will block on regular file.
    Differneces from file class:
    - mode is r/w property. Should re r/o
    - encoding property not implemented
    - write/writelines will not raise TypeError exception when non-string data is written
      it will write str(data) instead
    - Universal new lines are not supported and newlines property not implementeded
    - file argument can be descriptor, file name or file object.
    (
R
cBs`eZ
def
d
„ƒYZdef
d„ƒYZdef
d„ƒYZdef
d„ƒYZRS(tWantWriteErrorc
BseZ
RS((R”R•(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRÍ
s
t
WantReadErrorc
BseZ
RS((R”R•(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRžÐ
s
tZeroReturnErrorc
BseZ
RS((R”R•(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRŸÓ
s
tSysCallErrorc
BseZ
RS((R”R•(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR Ö
s
(R”R•t	ExceptionRRžRŸR (((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyR
Ì
s
c
Cszy3y|jt
jƒ
SWntk
r1


|jƒSXWn@t
jk
ru
}

t|
ƒ
tjtjtj	fkrv‚qvn
Xd
S(s§
 Shuts down the socket. This is a convenience method for
    code that wants to gracefully handle regular sockets, SSL.Connection
    sockets from PyOpenSSL and ssl.SSLSocket objects from Python 2.6
    interchangeably.  Both types of ssl socket require a shutdown() before
    close, but they have different arity on their shutdown method.

    Regular sockets don't need a shutdown before close, but it doesn't hurt.
    N(
R>Rt	SHUT_RDWRRŽRRRR€tEBADFtENOTSOCK(RfR ((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyRÚ
s	



$
(7RR)RRšR_Rnteventlett
eventlet.hubsRR
Rteventlet.supportRRt__all__tBUFFER_SIZEtsettEINPROGRESStEALREADYRR
tEISCONNRtplatformtaddt	WSAEINVALtPY2t_fileobjectRjtpatchertoriginalR3RRtwrap_is_timeoutRRRR!RaRRR€t	ESHUTDOWNR	tEPIPERRR%tobjectRRœt
greenpipe_doctOpenSSLR
R(((sJ/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/greenio/base.pyt<module>
sV






	


	



	
	
		
!
	#




ÿA