ó
±EYc@sû
dZd
dl
Z
d
dlZd
dlZd
dlmZ
d
dlmZ
d
dl	Z
d
dlmZ
d
dl
mZ
d
dlmZ
d
dlmZ
d
dlZd
d	lmZ
d
d
lmZ
d
dlmZ
d
dlmZmZmZmZ
d
d
lmZ
d
dlmZ
d
dlmZ
d
dlm Z 
d
dlm!Z!
d
dlm"Z"
d
dlm#Z#
d
dlm$Z$
ej%e&ƒ
Z'ej(j)Z)d„Z*d„Z+dej,f
d„ƒYZ,dej,f
d„ƒYZ-d„Z.da0dd„
Z1d„Z2dS(s:Generic Node base class for all workers that run on hosts.iÿÿÿÿN(
tprocessutils(
tlog(
tservice(
timportutils(
tbaserpc(
t	conductor(
tcontext(
tdebugger(
t	exception(t
_t_LEt_LIt_LW(
tobjects(
tbase(
trpc(
tservicegroup(
tutils(
tversion(
twsgicCsJtj
|
ƒ
}|j|_|j|_|j|_d
|_|jƒ
|S(Ni(R
tServicethosttbinaryttopictreport_counttcreate(tthis_serviceRR((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyt_create_service_ref3s




	


c

Csm|jt
jkritjtd
ƒ
i|jd6|jd6|jd6t
jd6ƒ
t
j|_|jƒ
ndS(NsKUpdating service version for %(binary)s on %(host)s from %(old)i to %(new)iRRtoldtnew(	Rtservice_objtSERVICE_VERSIONtLOGtinfoRRRtsave(
R((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyt_update_service_ref=s









RcBs›eZ
dZdddded
„Zd„Zd„Zd„Ze	dddddddded„	ƒ
Z
d„Zd„Ze
d„
Zd	„Zd
„ZRS(sõService object for binaries running on hosts.

    A service takes a manager and enables rpc by listening to queues based
    on topic. It also periodically runs tasks on the manager and reports
    its state to the database services table.
    c

Osëtt
|ƒjƒ
|
|_||_||_||_tjƒ|_	t
j|jƒ
}|d
|j|
|Ž
|_d|_||_||_||_||_|
||_|_d|_tjd|	ƒ
|_|jjtjƒƒ

dS(NRt	use_local(tsuperRt__init__RRRtmanager_class_nameRtAPItservicegroup_apiRtimport_classtmanagertNonet	rpcservertreport_intervaltperiodic_enabletperiodic_fuzzy_delaytperiodic_interval_maxt
saved_argstsaved_kwargst
backdoor_portRt
conductor_apitwait_until_readyRtget_admin_context(
tselfRRRR+R.R/R0R1t
db_allowedtargstkwargst
manager_class((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyR&Qs"
	
	
	
	



	
	
	
	
	

	

c

Cs3d
i|jj
d6|jd6|jd6|jd6S(NsP<%(cls_name)s: host=%(host)s, binary=%(binary)s, manager_class_name=%(manager)s>tcls_nameRRR+(t	__class__t__name__RRR'(
R8((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyt__repr__gs








c
CsLtj
ƒ}
tjtd
ƒ
i|jd6|
d6ƒ
|jƒ
|jjƒ
t	|_
tjƒ}t
jj||j|jƒ|_|jr™t|jƒ

nWyt||ƒ|_Wn>tjtjfk
rï


t
jj||j|jƒ|_n
X|jjƒ
|jdk	r
|j|j_ntjd|jƒ
tjd|jd|jƒ}|jtj|jj |jƒg}|j!|jj"ƒ

t#j$ƒ}t%j&|||ƒ|_'|j'j(ƒ
|jj)ƒ
tjd|jƒ
|j*j+|j|j|ƒ
|j,rH|j-rt.j/d|j-ƒ}nd}|j0j1|j2d|d	|j3ƒ

ndS(
Ns-Starting %(topic)s node (version %(version)s)RRs"Creating RPC server for service %stservers0Join ServiceGroup membership for this service %sit
initial_delayR1(4Rtversion_string_with_packageR R!RRtbasic_config_checkR+t	init_hosttFalsetmodel_disconnectedRR7R
Rtget_by_host_and_binaryRRtservice_refR#RRtServiceTopicExiststServiceBinaryExiststpre_start_hookR4R,tdebugt	messagingtTargetRt
BaseRPCAPItservice_nametextendtadditional_endpointstobjects_basetNovaObjectSerializerRt
get_serverR-tstarttpost_start_hookR)tjoinR/R0trandomtrandintttgtadd_dynamic_timertperiodic_tasksR1(R8tverstrtctxtttargett	endpointst
serializerRB((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRWpsN







	

	

	



	






	

	
	

cCs"|jj
d
dƒ}t||
ƒS(NR+(t__dict__tgetR,tgetattr(R8tkeyR+((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyt__getattr__­s

c
Cs
|
stj
}
n|s4tjjtjd
ƒ
}n|sP|jdƒ
d}n|s‚d|jdƒ
d}
tj|
d
ƒ}n|d
krštj
}n|d
kr²tj}n|d
krÊtj}nt
jƒ
||
|||d|d|d|d|d	|	ƒ}|S(s6Instantiates class and passes back application object.

        :param host: defaults to CONF.host
        :param binary: defaults to basename of executable
        :param topic: defaults to bin_name - 'nova-' part
        :param manager: defaults to CONF.<topic>_manager
        :param report_interval: defaults to CONF.report_interval
        :param periodic_enable: defaults to CONF.periodic_enable
        :param periodic_fuzzy_delay: defaults to CONF.periodic_fuzzy_delay
        :param periodic_interval_max: if set, the max time to wait between runs

        isnova-is
%s_managerR.R/R0R1R9N(tCONFRtostpathtbasenametsystargvt
rpartitionReR,R.R/R0Rtinit(tclsRRRR+R.R/R0R1R9tmanager_clsR((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyR±s0




















	c

CsI|jƒ
y|j
jƒ
Wn'tjk
rD


tjtd
ƒ
ƒ

n
XdS(sþDestroy the service object in the datastore.

        NOTE: Although this method is not used anywhere else than tests, it is
        convenient to have it here, so the tests might easily and in clean way
        stop and remove the service_ref.

        s)Service killed that has no database entryN(tstopRItdestroyRtNotFoundR twarningR(
R8((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pytkillÞs





c

Csy|jj
ƒ
|jjƒ
Wntk
r1


n
Xy|jjƒ
Wn$tk
ri


tjtd
ƒ
ƒ

n
Xt	t
|ƒj
ƒ
dS(Ns*Service error occurred during cleanup_host(R-Rstwaitt	ExceptionR+tcleanup_hostR RR
R%R(
R8((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRsìs











cCs"tj
ƒ}|jj|d
|
ƒ

S(s'Tasks to be run at a periodic interval.traise_on_error(RR7R+R^(R8R{R`((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyR^ûs
c
CsTytj
ƒ
Wd
QXWn6tk
rO
}

tjtdƒ
|
ƒ
tjdƒ

n
Xd
S(s7Perform basic config checks before starting processing.Ns"Temporary directory is invalid: %si
(RttempdirRyR terrorR
Rmtexit(R8t
e((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRD
s






c


Cs|jj
ƒ
dS(
N(R+treset(
R8((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyR€

s
N(R?t
__module__t__doc__R,tTrueR&R@RWRhtclassmethodRRwRsRFR^RDR€(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRIs"

			=	



)			
tWSGIServicecBsMeZ
dZdedd
„Zd„Zd„Zd„Zd„Z	d„Z
RS(s<Provides ability to launch API from a 'paste' configuration.cCs†
|
|_d
|
|_
d|_|jƒ|_|p=tjƒ|_|jj	|
ƒ
|_
|
jdƒ
rpd}n|
}tt
d|
dƒ|_tt
d|
dƒ|_tt
d|dƒpÇtjƒ|_|jr(
|jd	kr(
d|
}td
ƒ
i|d6t|jƒ
d6}tj|ƒ
‚
n||_tj|
|j
d
|jd|jd|jd|ƒ|_|jj|_d|_dS(sÝInitialize, but do not start the WSGI server.

        :param name: The name of the WSGI server given to the loader.
        :param loader: Loads the WSGI application using the given name.
        :returns: None

        snova-%stopenstack_compute_apit
osapi_computes	%s_listens0.0.0.0s%s_listen_portis
%s_workersi
sG%(worker_name)s value of %(workers)s is invalid, must be greater than 0tworker_nametworkersRtporttuse_ssltmax_url_lenN(tnameRR,Rt_get_managerR+RtLoadertloadertload_apptappt
startswithRfRiRRŠRtget_worker_countR‰R	tstrRtInvalidInputR‹tServerRAR4(R8RRR‹RŒtwnameRˆtmsg((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyR&
s8	

	



	







	



	
	
	
	
	
	

c


Cs|jj
ƒ
tjjƒ
d
S(scReset server greenpool size to default and service version cache.

        :returns: None

        N(RAR€RRtclear_min_version_cache(
R8((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyR€<
s

c
CsOd
|j}
|
t
krdSt
j|
dƒ}|s9dStj|ƒ
}|ƒS(s$
Initialize a Manager object appropriate for this service.

        Use the service name to look up a Manager subclass from the
        configuration and initialize an instance. If no class name
        is configured, just return None.

        :returns: a Manager instance, or None.

        s
%s_managerN(RRiR,ReRR*(R8tflR'R<((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRŽE
s






c
Csÿtj
ƒ}
tjj|
|j|jƒ}|r=t|ƒ

nQyt||
ƒ}Wn;t	j
t	jfk
r


tjj|
|j|jƒ}n
X|jrÕ|jj
ƒ
|jjƒ
|jd
k	rÕ|j|j_qÕn|jjƒ
|jrû|jjƒ
nd
S(sÕStart serving this service using loaded configuration.

        Also, retrieve updated port number in case '0' was passed in, which
        indicates a random port should be used.

        :returns: None

        N(RR7R
RRHRRR#RRRJRKR+RERLR4R,RARWRX(R8R`RI((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRWZ
s&	







	
	








	
c


Cs|jj
ƒ
d
S(s8Stop serving this API.

        :returns: None

        N(RARs(
R8((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRs{
sc


Cs|jj
ƒ
d
S(sPWait for the service to stop serving this API.

        :returns: None

        N(RARx(
R8((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRxƒ
sN(R?RR‚R,RFR&R€RŽRWRsRx(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyR…
s
+				!	cCstj
td
dƒ

S(Ntrestart_methodtmutate(RtProcessLauncherRi(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pytprocess_launcherŒ
s
cCs7trt
td
ƒ
ƒ
‚
ntjt|d|
ƒ
adS(Nsserve() can only be called onceR‰(t	_launchertRuntimeErrorR	RtlaunchRi(RAR‰((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pytserve–
s
c
Cstj
ƒ
dS(
N(R Rx(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyRxž
s
(3R‚RjRZRmtoslo_concurrencyRtoslo_logR
tloggingtoslo_messagingRNtoslo_serviceRt
oslo_utilsRtnovaRRt	nova.confRRRt	nova.i18nR	R
RRR
tnova.objectsRRTRRRRRRt	getLoggerR?R tconfRiRR#RR…RŸR,R R£Rx(((sA/home/tvault/.virtenv/lib/python2.7/site-packages/nova/service.pyt<module>sB











"







	
	Å~