ó
ǍEYc@sœdd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
ddlmZ
eje	ƒ
Z
d„Zdef
d„ƒYZ
def
d	„ƒYZd
S(
iÿÿÿÿN(
t	greenpool(
tloopingcall(
t	timeutilscCs|
j|ƒ

d
S(s°Callback function to be passed to GreenThread.link() when we spawn().

    Calls the :class:`ThreadGroup` to notify it to remove this thread from
    the associated group.
    N(
tthread_done(t_greenthreadtgrouptthread((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt_on_thread_donestThreadcBsMeZ
dZed
„
Zed„ƒ
Zd„Zd„Zd„Z	d„Z
RS(sÎWrapper around a greenthread.

     Holds a reference to the :class:`ThreadGroup`. The Thread will notify
     the :class:`ThreadGroup` when it has done so it can be removed from
     the threads list.
    cCs;|
|_|r(|jj
t||ƒ
nt|
ƒ
|_dS(
N(RtlinkRtidt_ident(tselfRRR	((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt__init__+s
	


c


Cs|jS(
N(
R(
R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pytident1sc


Cs|jj
ƒ
dS(
N(Rtkill(
R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pytstop5s
c


Cs
|jj
ƒS(
N(Rtwait(
R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR8s
cOs|jj
|
||Ž

dS(
N(RR	(Rtfunctargstkwargs((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR	;s
c
Gs|jj
|
Œ
dS(
N(Rtcancel(Rt
throw_args((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR>s
(t__name__t
__module__t__doc__tTrueR
tpropertyRRRR	R(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR$s
			tThreadGroupcBs’eZ
dZd
d„
Zddd„Zdd„
Zd„Zd„Zd„Z	d„Z
d	„Zd
„Ze
d„
Zd„Zd
„Zd„ZRS(s¸The point of the ThreadGroup class is to:

    * keep track of timers and greenthreads (making it easier to stop them
      when need be).
    * provide an easy API to add timers.
    i
cCs(tj
|
ƒ
|_g|_g|_dS(
N(Rt	GreenPooltpooltthreadsttimers(Rtthread_pool_size((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR
Is

	
cOs?tj
|
||Ž
}|jd
|d|ƒ
|jj|ƒ

|S(Nt
initial_delaytperiodic_interval_max(R
tDynamicLoopingCalltstartR tappend(RtcallbackR"R#RRttimer((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pytadd_dynamic_timerNs




cOs?tj
|||Ž
}|jd
|
d|ƒ
|jj|ƒ

|S(NtintervalR"(R
tFixedIntervalLoopingCallR%R R&(RR*R'R"RRtpulse((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt	add_timerVs




cOsT|jj
|
||Ž
}t||d
tƒ
}|jj|ƒ

|jt||ƒ
|S(NR	(RtspawnRtFalseRR&R	R(RR'RRtgttth((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt
add_thread^s





cCs|jj
|
ƒ

dS(
N(Rtremove(RR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyRes
cCs|jj
|
ƒ

dS(
N(R R3(RR(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt
timer_donehs
cCstj
ƒ}xl|jD]`}|j|jkr5qny|
|ƒ

Wqtjjk
r\


qtk
rv


||ƒ

qXqWdS(
N(t	threadingtcurrent_threadRRteventlettgreenlettGreenletExitt	Exception(Rtaction_funct
on_error_functcurrentt
x((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt_perform_action_on_threadsks







c

Cs|jd
„d„ƒ
dS(Nc


Ss
|jƒS(
N(
R(
R>((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt<lambda>}sc

Ss
tj
d
ƒ
S(NsError stopping thread.(tLOGt	exception(
R>((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR@~s(
R?(
R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt
_stop_threads{s


c
Cs+x|jD]}
|
j
ƒ
q
Wg|_dS(
N(R R(RR(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pytstop_timers€s


c
Cs+|jƒ
|
r|j
ƒ
n
|jƒ
d
S(sästop function has the option of graceful=True/False.

        * In case of graceful=True, wait for all threads to be finished.
          Never kill threads.
        * In case of graceful=False, kill threads immediately.
        N(RDRRC(Rtgraceful((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR…s


c
CssxV|jD]K}
y|
j
ƒ
Wq
tjjk
r7


q
tk
rT


tjd
ƒ

q
Xq
W|jd„d„ƒ
dS(NsError waiting on timer.c


Ss
|jƒS(
N(
R(
R>((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR@ sc

Ss
tj
d
ƒ
S(NsError waiting on thread.(RARB(
R>((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR@¡s(	R RR7R8R9R:RARBR?(RR>((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR–s









c
CsMtj
ƒ}
x:|jD].}|j|
jkr5qn|jjstSqWtS(
N(R5R6RRRtdeadRR/(RR=R>((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt_any_threads_alive£s





c
s¹|j‡f
d
†d„ƒ
|j
ddƒ}|dkr>dS|j
ddƒ}tjd|ƒ
}|jƒ
xF|jƒr´|jƒsštj	|ƒ

qont
jdƒ

|jƒ
qoWdS(Nc

s
|jˆŒS(
N(
R(
R>(
R(sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR@¯sc

Ss
tj
d
ƒ
S(NsError canceling thread.(RARB(
R>((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR@°sttimeoutt	wait_timei
tdurations)Cancel timeout reached, stopping threads.(
R?tgettNoneRt	StopWatchR%RGtexpiredR7tsleepRAtdebugR(RRRRHRItwatch((
RsM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyR­s

















N(RRRR
RLR)R-R2RR4R?RCRDR/RRRGR(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyRBs

							
	
(tloggingR5R7Rtoslo_serviceR
t
oslo_utilsRt	getLoggerRRARtobjectRR(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/threadgroup.pyt<module>s