ó
ǍEYc@sadZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dlZd
dl	Z	d
dl
Z
d
dlZd
dlZd
dl
Z
d
dl
mZ
d
dlmZ
d
dlmZ
d
dlmZ
d
dlmZ
d
dlmZ
d
d	lmZ
ejeƒ
Zd
dgZd„Zd
„Zd„Zd„Ze
j e
j!ƒ
de"f
d„ƒYƒ
Z#de$f
d„ƒYZ%e
j e%ƒ
de"f
d„ƒYƒ
Z&de"f
d„ƒYZ'de(f
d„ƒYZ)de'f
d„ƒYZ*de"f
d„ƒYZ+de"f
d„ƒYZ,d e#f
d!„ƒYZ-d"e"f
d#„ƒYZ.d$d
d%„Z/dS(&s:Generic Node base class for all workers that run on hosts.iÿÿÿÿN(
tevent(
t	lockutils(
t
_(
t_options(
teventlet_backdoor(
tsystemd(
tthreadgrouptreloadtmutatecCs d
t
jtjtjƒ
fg
S(s&Entry point for oslo-config-generator.N(tNonetcopytdeepcopyRteventlet_backdoor_optstservice_opts(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt	list_opts1s
cCsyy(tj
ƒtjtjjƒƒ
k}WnJtjk
rD


t}n1t	k
rt
}

|
j
t
jkrnt}qu‚n
X|S(
N(tostgetpgrpt	tcgetpgrptsyststdouttfilenotiotUnsupportedOperationtTruetOSErrorterrnotENOTTY(t	is_daemonterr((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt
_is_daemon7s
(
	

	
c

Cs,tƒj
d
ƒ
o|tjks%tStƒS(NtSIGHUP(t
SignalHandlertis_signal_supportedtsignalRtFalseR(
tsigno((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_is_sighup_and_daemonKs


c

Cs:t|t
ƒs6ttd
ƒ
i|d6t
d6ƒ
‚
ndS(Ns1Service %(service)s must an instance of %(base)s!tservicetbase(t
isinstancetServiceBaset	TypeErrorR(
R%((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_check_service_baseTs


R(cBsVeZ
dZejd
„ƒ
Zejd„ƒ
Zejd„ƒ
Zejd„ƒ
ZRS(sBase class for all services.c


Csd
S(sStart service.N((
tself((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pytstart^sc


Csd
S(s
Stop service.N((
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pytstopbsc


Csd
S(sWait for service to complete.N((
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pytwaitfsc


Csd
S(s_Reset service.

        Called in case service running in daemon mode receives SIGHUP.
        N((
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pytresetjs(	t__name__t
__module__t__doc__tabctabstractmethodR,R-R.R/(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR(Zs
t	Singletonc
Bs#eZ
iZejƒZd„ZRS(
c
Os^tj
d
d|jƒ

9
||jkrMtt|ƒj|
|Ž|j|<nWdQX|j|S(Ntsingleton_lockt
semaphores(R
tlockt_semaphorest
_instancestsuperR5t__call__(tclstargstkwargs((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR<vs





(R0R1R:R
t
SemaphoresR9R<(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR5rs

Rc
BsGeZ
d„Zd
„Zd„Zd„Zd„Zd„Zd„ZRS(c
s‰tt
ˆƒj|
|Ž
dˆ_t‡f
d†ttƒ
Dƒ
ƒ
ˆ_td„ˆjjƒDƒ
ƒ
ˆ_	t
jtƒ
ˆ_
ˆjƒ
dS(NtSIG_DFLtSIG_IGNc
3sB|]8}
|
jdƒ
r|
ˆj
kr|
tt|
ƒfV
qd
S(tSIGN(t
startswitht_ignore_signalstgetattrR!(t.0tname(
R+(sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pys	<genexpr>†s


c
ss!|]\}
}||
fV
qdS(
N((RGRHtsigval((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pys	<genexpr>‹s
(sSIG_DFLsSIG_IGN(R;Rt__init__REtdicttdirR!t_signals_by_nametitemstsignals_to_nametcollectionstdefaultdicttsett_signal_handlerstclear(R+R>R?((
R+sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRJs
	





c
Cs8x$|jD]}
t
j
|
t
jƒ
q
W|jjƒ
dS(
N(RSR!RART(R+tsig((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRTs


cCs%x|
D]}|j||ƒ
qWdS(
N(
tadd_handler(R+tsignalsthandlerRU((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pytadd_handlers•s


cCsK|j|
ƒ
sdS|j
|
}|j|j|ƒ

tj||jƒ
dS(
N(R RMRStaddR!t_handle_signal(R+RURXR#((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRV™s






cCstj
|j|
|ƒ
dS(
N(teventlettspawnt_handle_signal_cb(R+R#tframe((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR[ scCs)x"|j|
D]}||
|ƒ
qWdS(
N(
RS(R+R#R_RX((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR^°s

cCs
|
|jkS(
N(
RM(R+tsig_name((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR ´s
(	R0R1RJRTRYRVR[R^R (((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR~s						tLaunchercBsAeZ
dZd
d„
Zdd„
Zd„Zd„Zd„ZRS(s:Launch one or more services and wait for them to complete.RcCsl|
|_|
j
tjƒ

tƒ|_tj|jƒ
|_||_	|t
krhttd
ƒ
|ƒ
‚
ndS(s
Initialize the service launcher.

        :param restart_method: If 'reload', calls reload_config_files on
            SIGHUP. If 'mutate', calls mutate_config_files on SIGHUP. Other
            values produce a ValueError.
        :returns: None

        sInvalid restart_method: %sN(
tconft
register_optsRR
tServicestservicesRtinitialize_if_enabledt
backdoor_porttrestart_methodt_LAUNCHER_RESTART_METHODSt
ValueErrorR(R+RbRh((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRJ»s		


	

i
cCsW|dk	r-|d
kr-t
tdƒ
ƒ
‚
nt|
ƒ

|j|
_|jj|
ƒ

dS(s
Load and start the given service.

        :param service: The service you would like to start, must be an
                        instance of :class:`oslo_service.service.ServiceBase`
        :param workers: This param makes this method compatible with
                        ProcessLauncher.launch_service. It must be None, 1 or
                        omitted.
        :returns: None

        i
s(Launcher asked to start multiple workersN(R	RjRR*RgReRZ(R+R%tworkers((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pytlaunch_serviceÍs





c


Cs|jj
ƒ
d
S(sPStop all services which are currently running.

        :returns: None

        N(ReR-(
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR-Þsc


Cs|jj
ƒ
d
S(s]Wait until all services have been stopped, and then return.

        :returns: None

        N(ReR.(
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR.æsc

CsO|jd
kr|j
jƒ
n|jdkr>|j
jƒ
n|jjƒ
dS(s±Reload config files and restart service.

        :returns: The return value from reload_config_files or
          mutate_config_files, according to the restart_method.
        RRN(RhRbtreload_config_filestmutate_config_filesRetrestart(
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRoîs




(R0R1R2RJRlR-R.Ro(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRa¸s
		t
SignalExitcBseZ
dd
„
ZRS(i
cCs#tt
|ƒj|ƒ

|
|_dS(
N(R;RpRJR#(R+R#texccode((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRJüs

(R0R1RJ(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRpûs
tServiceLaunchercBsYeZ
dZd
d„
Zd„Zd„Zd„Zd„Zd„Zd„Z	d	„Z
RS(
s-Runs one or more service in a parent process.RcCs,tt
|ƒj|
d
|ƒ


tƒ|_dS(stConstructor.

        :param conf: an instance of ConfigOpts
        :param restart_method: passed to super
        RhN(R;RrRJRtsignal_handler(R+RbRh((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRJ
s


c
GsO|jj
ƒ
|jjrA|jjd
ƒ
rAtj|jjƒ

n|jƒ
dS(NtSIGALRM(RsRTRbtgraceful_shutdown_timeoutR R!talarmR-(R+R>((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_graceful_shutdown

s






c
Gs |jj
ƒ
ttjƒ
‚
dS(
N(RsRTRpR!R(R+R>((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_reload_service
s


c
Gstj
d
ƒ

tjdƒ

dS(Ns+Caught SIGINT signal, instantaneous exitingi
(tLOGtinfoRt_exit(R+R>((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt
_fast_exit
s


c
Gstj
d
ƒ

tjdƒ

dS(Ns9Graceful shutdown timeout exceeded, instantaneous exitingi
(RyRzRR{(R+R>((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_on_timeout_exit
s

c

Csi|jj
ƒ
|jjd
|jƒ
|jjd|jƒ
|jjd|jƒ
|jjd|jƒ
dS(s,Set self._handle_signal as a signal handler.tSIGTERMtSIGINTRRtN(RsRTRVRwR|RxR}(
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt
handle_signal!
s





c
Cséd}
d
}|j
jr>tjdƒ

|j
jttjƒ
nytt	|ƒj
ƒ
Wn‡tk
rŸ
}
|jj
|j}tjd|ƒ
|j}
|j}n@tk
rÄ
}
|jƒ
|j}
ntk
rÞ


|jƒ
n
X|
|fS(NisFull set of CONF:sCaught %s, exiting(R	Rbtlog_optionsRytdebugtlog_opt_valuestloggingtDEBUGR;RrR.RpRsROR#Rztcodet
SystemExitR-t	Exception(R+tstatusR#texctsigname((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_wait_for_exit_or_signal)
s$









	








c
Csqtj
ƒ
|jjƒ
x@trY|jƒ
|jƒ\}
}t|ƒ
sLPn|jƒ
qWt	t
|ƒjƒ
|
S(
shWait for a service to terminate and restart it on SIGHUP.

        :returns: termination status
        (Rtnotify_onceRsRTRR€RŒR$RoR;RrR.(R+R‰R#((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR.?
s



	






(R0R1R2RJRwRxR|R}R€RŒR.(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRr

s


						tServiceWrapperc
BseZ
d„ZRS(
cCs+|
|_||_
tƒ|_g|_dS(
N(R%RkRRtchildrent	forktimes(R+R%Rk((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRJR
s
	
	

(R0R1RJ(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRŽQ
s
tProcessLaunchercBs§eZ
dZd
dd„Zd„Zd„Zd„Zd„Zd„Zd	„Z	d
„Z
d„Zd„Zd
„Z
dd„
Zd„Zd„Zd„Zd„ZRS(s0Launch a service with a given number of workers.g{®Gáz„?RcCs»|
|_|
j
tjƒ

i|_d|_t|_||_	d|_
tjƒ\}|_
tjj|d
ƒ|_tƒ|_|jƒ
||_|tkr·ttdƒ
|ƒ
‚
ndS(s
Constructor.

        :param conf: an instance of ConfigOpts
        :param wait_interval: The interval to sleep for between checks
                              of child process exit.
        :param restart_method: If 'reload', calls reload_config_files on
            SIGHUP. If 'mutate', calls mutate_config_files on SIGHUP. Other
            values produce a ValueError.
        t
rsInvalid restart_method: %sN(RbRcRR
RR	t	sigcaughtRtrunningt
wait_intervaltlauncherRtpipet	writepipeR\tgreeniot	GreenPipetreadpipeRRsR€RhRiRjR(R+RbR•Rhtrfd((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRJ\
s
	

	
	
	
	
	





	

c

Cs\|jj
d
|jƒ
|jj
d|jƒ
|jj
d|jƒ
|jj
d|jƒ
dS(s1Add instance's signal handlers to class handlers.R~RRRtN(RsRVt_handle_termt_handle_hupR|t_on_alarm_exit(
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR€u
s


cCs#|
|_t
|_|jjƒ
d
S(slHandle a TERM event.

        :param signo: signal number
        :param frame: current stack frame
        N(R“R"R”RsRT(R+R#R_((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR|
s	
	cCs|
|_t
|_d
S(skHandle a HUP event.

        :param signo: signal number
        :param frame: current stack frame
        N(R“R"R”(R+R#R_((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRžˆ
s	
cCstj
d
ƒ

tjdƒ

dS(Ns+Caught SIGINT signal, instantaneous exitingi
(RyRzRR{(R+R#R_((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR|•
s


cCstj
d
ƒ

tjdƒ

dS(Ns9Graceful shutdown timeout exceeded, instantaneous exitingi
(RyRzRR{(R+R#R_((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRŸ™
s

c

CsG|jj
d
ƒ

tjdƒ

|jr6|jjƒ
ntjd
ƒ

dS(Ni
s-Parent process has died unexpectedly, exiting(R›treadRyRzR–R-Rtexit(
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt
_pipe_watcherž
s

	
c
sk‡f
d
†}
‡f
d†}ˆjj
ƒ
ˆjjd|
ƒ
ˆjjd|ƒ
ˆjjdˆjƒ
dS(Nc

sˆjj
ƒ
ˆjjƒ
dS(
N(RsRTR–R-(
R>(
R+(sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_sigterm­
s


c
s ˆjj
ƒ
ttjƒ
‚
dS(
N(RsRTRpR!R(
R>(
R+(sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_sighup±
s


R~RR(RsRTRVR|(R+R£R¤((
R+sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_child_process_handle_signalª
s


cCs­d
}d
}y|
jƒ
Wn†t
k
rd
}
|jj|j}tjd|ƒ
|j}|j}n?tk
r
}
|j}n$t	k
r¢


tj
dƒ

d}n
X||fS(NisChild caught %s, exitingsUnhandled exceptioni(R.RpRsROR#RyRzR†R‡t
BaseExceptiont	exception(R+R–R‰R#RŠR‹((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_child_wait_for_exit_or_signal¼
s






	








cCsj|jƒ
t
jjƒ
tj|jƒ

t
j|jƒ

t	j
ƒ
t|jd
|j
ƒ

}|j|
ƒ

|S(NRh(R¥R\thubstuse_hubRtcloseR˜tspawn_nR¢trandomtseedRaRbRhRl(R+R%R–((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_child_processÒ
s






cCsE
t|
j
ƒ
|
jkrhtjƒ|
j
d
|
jkrUtjdƒ

tjdƒ

n|
j
jd
ƒ

n|
j
jtjƒƒ

t	j
ƒ}|d
kr
|j|
jƒ
|_
xVtr
|jƒ
|j|j
ƒ
\}}t|ƒ
só|j
jƒ
Pn|j
jƒ
q®Wt	j|ƒ

ntjd|ƒ
|
jj|ƒ

|
|j|<|S(NisForking too fast, sleepingi
sStarted child %d(tlenRRkttimeRyRztsleeptpoptappendRtforkR¯R%R–RR¥R¨R$R.RoR{R‚RRZ(R+twraptpidR‰R#((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_start_childå
s,
 





	










i
cCset|
ƒ

t
|
|ƒ}tjd
|jƒ
x2|jr`t|jƒ
|jkr`|j|ƒ

q/WdS(s
Launch a service with a given number of workers.

       :param service: a service to launch, must be an instance of
              :class:`oslo_service.service.ServiceBase`
       :param workers: a number of processes in which a service
              will be running
        sStarting %d workersN(	R*RŽRyRzRkR”R°RR¸(R+R%RkR¶((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRls



$
c
Cs
y)tj
d
tjƒ\}
}|
s(dSWn5tk
r`
}
|jtjtjfkr\‚ndSXtj|ƒ
r¡tj	|ƒ
}t
jdtd|
d|ƒƒ
n.tj
|ƒ
}t
jdtd|
d|ƒƒ
|
|jkròt
jd|
ƒ
dS|jj|
ƒ
}|jj|
ƒ

|S(Nis&Child %(pid)d killed by signal %(sig)dR·RUs)Child %(pid)s exited with status %(code)dR†spid %d not in child list(RtwaitpidtWNOHANGR	RRtEINTRtECHILDtWIFSIGNALEDtWTERMSIGRyRzRKtWEXITSTATUSRtwarningR³tremove(R+R·R‰RŠRUR†R¶((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_wait_childs*








	

	




c
Cstxm|jro|j
ƒ}
|
s7tjj|jƒ

qnx2|jrkt|
jƒ
|
jkrk|j	|
ƒ

q:WqWdS(
N(
R”RÂR\tgreenthreadR²R•R°RRkR¸(R+R¶((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt_respawn_children3s




$
c
CsÄ
tj
ƒ
|jjr<tjd
ƒ

|jjttjƒ
ny
x
t	rY
|j
ƒ
|jƒ
|jsidS|j
j|j}
tjd|
ƒ
t|jƒ
sŸPn|jdkr¾|jjƒ
n|jdkrÝ|jjƒ
nx=tg|jjƒD]}|j^qóƒ
D]}|jƒ
q	
Wx$|jD]}tj|tjƒ
q'
Wt	|_d|_qBWWn$tj j!k
r



tjdƒ

n
X|jj"r¶
|j
j#dƒ
r¶
tj$|jj"ƒ

n|j%ƒ
dS(s<Loop waiting on children to die and respawning as necessary.sFull set of CONF:NsCaught %s, stopping childrenRRs-Wait called after thread killed. Cleaning up.Rt(&RRRbRRyR‚RƒR„R…RR€RÄR“RsRORzR$RhRmRnRRRtvaluesR%R/RtkillR!R~R”R	R\tgreenlettGreenletExitRuR RvR-(R+R‹R¶R%R·((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR.?s>





	



	








,

	




c
Csÿt|_
tjd
ƒ

x=tg|jjƒD]}
|
j^q,ƒ
D]}|jƒ
qBWtjdƒ

xV|jD]K}yt	j
|tjƒ
Wqmt
k
r·
}
|jtjkr¸‚q¸qmXqmW|jrûtjdt|jƒ
ƒ
x|jr÷|jƒ
qáWndS(s+Terminate child processes and wait on each.sStop services.sKilling children.sWaiting on %d children to exitN(R"R”RyR‚RRRRÅR%R-RRÆR!R~RRtESRCHRzR°RÂ(R+R¶R%R·RŠ((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR-ls 	


,







	


(R0R1R2RJR€RRžR|RŸR¢R¥R¨R¯R¸RlRÂRÄR.R-(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR‘Y
s"
			
							#			-tServicecBsAeZ
dZd
d„
Zd„Zd„Zed„
Zd„ZRS(s-Service object for binaries running on hosts.iècCstj
|
ƒ
|_dS(
N(RtThreadGroupttg(R+tthreads((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRJ‡s
c


Csd
S(s-Reset a service in case it received a SIGHUP.N((
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR/Šsc


Csd
S(sStart a service.N((
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR,scCs|jj
|
ƒ

d
S(s‘Stop a service.

        :param graceful: indicates whether to wait for all threads to finish
               or terminate them instantly
        N(RÌR-(R+tgraceful((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR-sc


Cs|jj
ƒ
d
S(s Wait for a service to shut down.N(RÌR.(
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR.˜s(	R0R1R2RJR/R,R"R-R.(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRʄs
		RdcBsDeZ
d„Zd
„Zd„Zd„Zd„Zed„ƒ
ZRS(c

Cs+g|_t
jƒ|_tjƒ|_dS(
N(ReRRËRÌRtEventtdone(
R+((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRJŸs
	

cCs0|jj
|
ƒ

|jj|j|
|jƒ
d
S(sgAdd a service to a list and create a thread to run it.

        :param service: service to run
        N(ReR´RÌt
add_threadtrun_serviceRÐ(R+R%((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRZ¤s
c
CsNx|jD]}
|
j
ƒ
q
W|jjƒs=|jjƒ
n|jj
ƒ
d
S(s<Wait for graceful shutdown of services and kill the threads.N(ReR-RÐtreadytsendRÌ(R+R%((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR-¬s


c
Cs/x|jD]}
|
j
ƒ
q
W|jj
ƒ
d
S(sWait for services to shut down.N(ReR.RÌ(R+R%((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyR.¹s

c
CsW|jƒ
t
jƒ|_x7|jD],}
|
jƒ
|jj|j|
|jƒ
q#Wd
S(s-Reset services and start them in new threads.N(	R-RRÏRÐReR/RÌRÑRÒ(R+trestart_service((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRo¿s






cCsIy|jƒ
Wn*t
k
r:


tjd
ƒ

tdƒ
‚
nX|
jƒ
dS(s£Service start wrapper.

        :param service: service to run
        :param done: event to wait on until a shutdown is triggered
        :returns: None

        sError starting thread.i
N(R,RˆRyR§R‡R.(R%RÐ((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRÒÇs	





(	R0R1RJRZR-R.RotstaticmethodRÒ(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyRds			
		i
cCsƒ|dk	r-|d
k
r-t
tdƒ
ƒ
‚
n|dksE|dkrZt|d|ƒ

}nt|d|ƒ

}|j|
d|ƒ


|S(sZLaunch a service with a given number of workers.

    :param conf: an instance of ConfigOpts
    :param service: a service to launch, must be an instance of
           :class:`oslo_service.service.ServiceBase`
    :param workers: a number of processes in which a service will be running
    :param restart_method: Passed to the constructed launcher. If 'reload', the
        launcher will call reload_config_files on SIGHUP. If 'mutate', it will
        call mutate_config_files on SIGHUP. Other values produce a ValueError.
    :returns: instance of a launcher that was used to launch the service
    is%Number of workers should be positive!i
RhRkN(R	RjRRrR‘Rl(RbR%RkRhR–((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pytlaunchÙs



(0R2R3RPR
RRR„RR­R!tsixRR±R\Rtoslo_concurrencyR
toslo_service._i18nRtoslo_serviceRRRRt	getLoggerR0RyRiRRR$R*t
add_metaclasstABCMetatobjectR(ttypeR5RRaR‡RpRrRŽR‘RÊRdR×(((sI/home/tvault/.virtenv/lib/python2.7/site-packages/oslo_service/service.pyt<module>sP
















					

9CPÿ,<