ó
 ‹EYc@sk
dd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZd
Zeedƒrod„Z	e	Zn<ydd
l
Z
e
jZWn ek
rª


d„Z
e
Zn
XddlmZmZ
ddlmZmZmZmZ
eZdZdZd	„Zd
ef
d„ƒYZeedd
„d
„d
ƒZdef
d„ƒYZd„Z def
d„ƒYZ!d
S(iÿÿÿÿNt	setitimerc

Cstj
tj|ƒ
dS(
N(tsignalRtITIMER_REAL(
tseconds((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytalarm_itimer
s
c

Cstj
tj|ƒ
ƒ

dS(
N(R
talarmtmathtceil(
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytalarm_signals
(ttimertIOClosed(t	greenletstclear_sys_exc_infot	monotonictsixtreadtwritec


Csd
S(sP Used to de-fang a callback that may be triggered by a loop in BaseHub.wait
    N((
tfileno((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytclosed_callbackst
FdListenerc
Bs)eZ
d„Zd
„ZeZd„ZRS(cCsg|
tks|
t
kst‚
|
|_||_||_||_||_t|_	t
jƒ|_
d
S(sŠ The following are required:
        cb - the standard callback, which will switch into the
            listening greenlet to indicate that the event waited upon
            is ready
        tb - a 'throwback'. This is typically greenlet.throw, used
            to raise a signal into the target greenlet indicating that
            an event was obsoleted by its underlying filehandle being
            repurposed.
        mark_as_closed - if any listener is obsoleted, this is called
            (in the context of some other client greenlet) to alert
            underlying filehandle-wrapping objects that they've been
            closed.
        N(tREADtWRITEtAssertionErrortevtypeRtcbttbtmark_as_closedtFalsetspenttgreenlett
getcurrent(tselfRRRRR((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt__init__(s
	
	
	
	
	
	
c

Cs,d
t|ƒ
j
|j|j|j|jfS(Ns%s(%r, %r, %r, %r)(ttypet__name__RRRR(
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt__repr__?s

c

Cs2t|_
|jdk	r%|jƒ
nt|_dS(
N(RRRtNonetTrueR(
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytdefangDs
	



(R"t
__module__R R#t__str__R&(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR&s		ic


CsdS(
N(
R$(
t
x((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt<lambda>Kst
DebugListenerc
Bs eZ
d„Zd
„ZeZRS(cCsDtj
ƒ|_tjƒ|_tt|ƒj|
||||ƒ
dS(
N(t	tracebacktformat_stacktwhere_calledRRtsuperR+R (RRRRRR((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR Ss


c

	Cs;d
|j|j
|j|j|j|jdj|jƒ
fS(Ns:DebugListener(%r, %r, %r, %r, %r, %r)
%sEndDebugFdListenert(RRRRRRtjoinR.(
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR#Xs







(R"R'R R#R((((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR+Qs			cCs/d
dl}t
dt|j|
ƒ
ƒ
ƒ
‚
dS(NiÿÿÿÿsBlocking detector ALARMED at(tinspecttRuntimeErrortstrtgetframeinfo(tsignumtframeR2((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt
alarm_handlerds

tBaseHubcBsF
eZ
dZeefZeZeZd d
„
Z	d„Z
d„Zd„Zd„Z
d„Zd„Zd„Zd	„Zd
„Zd„Zd„Zd
„Zd d„
Zd„Zd„Zd„Zed„
Zd„Zd„Zd„Zd„Zd„Z d„Z!d„Z"d„Z#d„Z$d„Z%d„Z&d„Z'd„Z(RS(!s Base hub class for easing the implementation of subclasses that are
    specific to a particular underlying event architecture. cCsÂiit6it
6|_iit6it
6|_g|_|
dkrOtj}
n|
|_tj|j	ƒ
|_t
|_t
|_g|_
g|_t|_d
|_t|_t
|_d|_dS(Nii
(RRt	listenerstsecondariestclosedR$R
tclockRtrunRtstoppingtrunningttimerstnext_timersRtlclassttimers_canceledR%tdebug_exceptionstdebug_blockingtdebug_blocking_resolution(RR=((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR rs 


	

	
	
	
	
	
	
	
	
	
c
Cs>tjtj
tƒ}
|
tkr-|
|_nt|jƒ

dS(
N(R
tSIGALRMR8t_old_signal_handlert	arm_alarmRG(Rttmp((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytblock_detect_pre†s

c

CsBt|d
ƒr1|j
r1tjtj|j
ƒ
ntjdƒ

dS(NRIi(thasattrRIR
RHR(
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytblock_detect_postŽs

	

cCs‘|j|
||||ƒ}|j
|
}||krƒtr`td
|
||
|||fƒ
‚
n|j|
j|gƒj|ƒ

n
|||<|S(s– Signals an intent to or write a particular file descriptor.

        The *evtype* argument is either the constant READ or WRITE.

        The *fileno* argument is the file number of the file of interest.

        The *cb* argument is the callback which will be called when the file
        is ready for reading/writing.

        The *tb* argument is the throwback used to signal (into the greenlet)
        that the file was closed.

        The *mark_as_closed* is used in the context of the event hub to
        prepare a Python object as being closed, pre-empting further
        close operations from accidentally shutting down the wrong OS thread.
        sP
Second simultaneous %s on fileno %s detected.  Unless you really know what you're doing, make sure that only one greenthread can %s any particular socket.  Consider using a pools.Pool. If you do know what you're doing and want to disable this error, call eventlet.debug.hub_prevent_multiple_readers(False) - MY THREAD=%s; THAT THREAD=%s(RCR:tg_prevent_multiple_readersR3R;t
setdefaulttappend(RRRRRRtlistenertbucket((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytadd”s





 #

cCsát}xkt
j|jƒ
D]W\}}|
|krx2||
D]&}t}|jj|ƒ

|jƒ
q<W||
=qqWxft
j|jƒ
D]R\}}|
|kr‡||
}t}|jj|ƒ

|j	|ƒ

|jƒ
q‡q‡W|S(
sÀ We've received an indication that 'fileno' has been obsoleted.
            Any current listeners must be defanged, and notifications to
            their greenlets queued up to send.
        (
RRt	iteritemsR;R%R<RQR&R:tremove(RRtfoundRRSRR((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt	_obsolete¹s 














c
Csd
S(sÈ We might want to do something when a fileno is closed.
            However, currently it suffices to obsolete listeners only
            when we detect an old fileno being recycled, on open.
        N((RR((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytnotify_closeÓscCs¤|
jr
dS|
j
}|
j}|j|j|dƒ
||j|kr |j|j|dƒ}|sldS|jd
ƒ
|j||<|s |j||=q ndS(Ni(RRRR:tpopR$R;tget(RRRRRtsec((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyRVÚs
		
	






cCs|j|
ƒ

d
S(së If a file descriptor is returned by the OS as the result of some
            open call (or equivalent), that signals that it might be being
            recycled.

            Catch the case where the fd was previously in use.
        N(
RX(RR((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytmark_as_reopenedëscCsÓg}|j|j
tj|
tƒƒ

|j|j
tj|
tƒƒ

|j|jtj|
dƒƒ

|j|jtj|
dƒƒ

xF|D]>}y|j|
ƒ

Wqt	k
rÊ


|j
tjƒƒ

qXqWd
S(sQ Completely remove all listeners for this fileno.  For internal use
        only.N(((
RQR:RRZtnoopRtextendR;Rt	Exceptiontsquelch_generic_exceptiontsystexc_info(RRR:RR((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytremove_descriptorôs
 
 
 
 






c
Cs;|jj
ƒ}
|
jjs7|
jttjd
ƒƒ

ndS(sÑ Triggered from the main run loop. If a listener's underlying FD was
            closed somehow, throw an exception back to the trampoline, which should
            be able to manage it appropriately.
        sOperation on closed fileN(R<RZRtdeadRR
terrnotENOTCONN(RRR((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt	close_one
s
c
CsC|jj
r?tj|j|jjƒ}
|
|j_|
|_ndS(
N(RReR>tparent(Rtnew((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytensure_greenlet
s

c
CsÇtj
ƒ}
|
|jk	s'td
ƒ
‚
t|
ddƒ}|dk	rpy|ƒ
Wqp


|jtjƒƒ

qpXn|jƒ
y%|jj	|
k	rž|j|
_	nWnt
k
r²


n
Xtƒ
|jjƒS(Ns'Cannot switch to MAINLOOP from MAINLOOPt
switch_out(
RRRtgetattrR$RaRbRcRkRit
ValueErrorRtswitch(RtcurRl((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyRo
s 

















cCs€tj
|Œ
tjjd
|
f
ƒ

tjjƒ
y|j|
ƒ

Wn7tk
r{
}
tjjd|f
ƒ

tjjƒ
n
XdS(NsRemoving descriptor: %r
s(Exception while removing descriptor! %r
(R,tprint_exceptionRbtstderrRtflushRdR`(RRRct
e((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytsquelch_exception)
s









cCstd
ƒ
‚
dS(NsImplement this in a subclass(
tNotImplementedError(RR((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytwait3
s
c


Csd
S(NgN@((
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt
default_sleep6
s
c
Cs|j}
|
sdS|
d
d
S(Ni(RAR$(Rt
t((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytsleep_until9
s
	


c
Os<
|jrt
d
ƒ
‚
nz

t|_t|_xñ|js	
x|jrR|jƒ
q<W|jƒ
|jrs|j	ƒ
n|j
|jƒƒ

|jrœ|jƒ
n|jƒ
|j
ƒ}|dkrÍ|jƒ}n||jƒ}|dkrù|j|ƒ

q0|jdƒ

q0Wd|_|j2|j2Wdt|_t|_XdS(s/Run the runloop until abort is called.
        sAlready running!iN(R@R3R%RR?R<Rhtprepare_timersRFRLtfire_timersR=RNRzR$RxRwRDRARB(Rt
atkwtwakeup_whent
sleep_time((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR>?
s6	


	
	




	



	








	

	
cCs`|jrt
|_n|
r\|jtjƒk	s<td
ƒ
‚
|jdd„ƒ
|jƒ
ndS(sm
Stop the runloop. If run is executing, it will exit after
        completing the next runloop iteration.

        Set *wait* to True to cause abort to switch to the hub immediately and
        wait until it's finished processing.  Waiting for the hub will only
        work from the main greenthread; all other greenthreads will become
        unreachable.
        s5Can't abort with wait from inside the hub's greenlet.ic
SsdS(
N(
R$(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR*u
sN(R@R%R?RRRtschedule_call_globalRo(RRw((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytabortf
s		



	cCs1|jr-t
j|
Œ
tjjƒ
tƒ
ndS(
N(RER,RqRbRrRsR(RRc((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyRaz
s
	




cCs1|jr-t
j|Œ
tjjƒ
tƒ
ndS(
N(RER,RqRbRrRsR(RR	Rc((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytsquelch_timer_exception€
s
	




cCs-|jƒ|
j
}|jj||
fƒ

|S(
N(R=RRBRQ(RR	tscheduled_time((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt	add_timer†
s


cCsÂ|jd
7_t
|jƒ
t
|jƒ
}|dkr¾|d|jk
r¾d|_g|jD]}|d
js]|^q]|_g|jD]}|d
js‰|^q‰|_tj|jƒ

ndS(Ni
ièii(RDtlenRARBtcalledtheapqtheapify(RR	t
len_timersRy((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyttimer_canceled‹
s



	
,
,
c
Cs]tj
}
|j}x=|jD]2}|d
jrA|jd
8_q|
||ƒ
qW|j2dS(Ni
(RˆtheappushRARBR‡RD(RRŒRytitem((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR{”
s
	
	




cOs)tj
|
|||Ž}|j|ƒ

|S(
sz
Schedule a callable to be called after 'seconds' seconds have
        elapsed. Cancel the timer if greenlet has exited.
            seconds: The number of seconds to wait.
            cb: The callable to call after the given time.
            *args: Arguments to pass to the callable when called.
            **kw: Keyword arguments to pass to the callable when called.
        (R	t
LocalTimerR…(RRRtargsR~Ry((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytschedule_call_localž
s


cOs)tj
|
|||Ž}|j|ƒ

|S(
s³
Schedule a callable to be called after 'seconds' seconds have
        elapsed. The timer will NOT be canceled if the current greenlet has
        exited before the timer fires.
            seconds: The number of seconds to wait.
            cb: The callable to call after the given time.
            *args: Arguments to pass to the callable when called.
            **kw: Keyword arguments to pass to the callable when called.
        (R	tTimerR…(RRRRR~Ry((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyRª
s	


cCs¾|j}t
j}x¥|r¹|d
}|d
}|d}|
|krIPn||ƒ

y&|jrq|jd8_n|ƒ
Wq|jk
r’


‚q


|j|tjƒƒ
t	ƒ
qXqWdS(Nii
(
RARˆtheappopR‡RDtSYSTEM_EXCEPTIONSRƒRbRcR(RtwhenRyR’tnexttexpR	((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR|·
s$
	
		







	





c

Cs|jt
jƒS(
N(R:Rtvalues(
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytget_readersÓ
s
c

Cs|jt
jƒS(
N(R:RR—(
R((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytget_writersÖ
s
c

Cst|j
ƒ
t|jƒ
S(
N(R†RARB(
thub((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytget_timers_countÙ
s
cCs|
rt|_
n	t|_
dS(
N(R+RCR(Rtvalue((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytset_debug_listenersÜ
s

cCs
|
|_dS(
N(
RE(RRœ((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pytset_timer_exceptionsâ
s
N()R"R't__doc__tKeyboardInterruptt
SystemExitR“RRR$R RLRNRTRXRYRVR]RdRhRkRoRuRwRxRzR>RR‚RaRƒR…R‹R{RRR|R˜R™R›RRž(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyR9isF
			%							
			
			'						
		
					("RfRˆRR
RbR,R$RJRMRtitimerRtImportErrorRt
eventlet.hubsR	R
teventlet.supportRRRR
RR%RORRRtobjectRR^R+R8R9(((sF/home/tvault/.virtenv/lib/python2.7/site-packages/eventlet/hubs/hub.pyt<module>
s4






		





	

"
	%