ó
±EYc@s‰dd
lZdd
l
Z
dd
lZdd
lZddlmZ
ddlmZ
ddlm	Z	
ej
eƒ
Zde
f
d„ƒYZd
S(iÿÿÿÿN(
tlog(
t_LE(
t_LWtInstanceJobTrackerc
Bs,eZ
d„Zd
„Zd„Zd„ZRS(c

Cstj
tƒ
|_dS(
N(tcollectionstdefaultdicttlisttjobs(
tself((sY/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/instancejobtracker.pyt__init__s
cCs|j|
j
j|ƒ

d
S(s‹
Appends process_id of instance to cache.

        This method will store the pid of a process in cache as
        a key: value pair which will be used to kill the process if it
        is running while deleting the instance. Instance uuid is used as
        a key in the cache and pid will be the value.

        :param instance: Object of instance
        :param pid: Id of the process
        N(Rtuuidtappend(Rtinstancetpid((sY/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/instancejobtracker.pytadd_job"scCsi|
j}||j
krB||j
|krB|j
|j|ƒ

n|j
|se|j
j|d
ƒ
nd
S(sÄRemoves pid of process from cache.

        This method will remove the pid of a process from the cache.

        :param instance: Object of instance
        :param pid: Id of the process
        N(R
RtremovetpoptNone(RRR
R
((sY/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/instancejobtracker.pyt
remove_job/s
	
"


cCs4
t|j
j|
jgƒƒ
}x
|D]
}ytj|tjƒ
WnRtk
r–
}
|j	t	j
kr—tjt
d
ƒ
i|d6|d6d|
ƒ

q—n
Xytj|dƒ
WnKtk
rø
}
|j	t	j
kr
tjt
dƒ
i
|d6d|
ƒ

q
n$Xtjtdƒ
i
|d6d|
ƒ

|j|
|ƒ
q%WdS(	sÕKills the running processes for given instance.

        This method is used to kill all running processes of the instance if
        it is deleted in between.

        :param instance: Object of instance
        sNFailed to kill process %(pid)s due to %(reason)s, while deleting the instance.R
treasonRis0Unexpected error while checking process %(pid)s.sWFailed to kill a long running process %(pid)s related to the instance when deleting it.N(RRtgetR
tostkilltsignaltSIGKILLtOSErrorterrnotESRCHtLOGterrorR
twarningRR(RRtpids_to_removeR
texc((sY/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/instancejobtracker.pytterminate_jobs?s(














(t__name__t
__module__R	RRR!(((sY/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/instancejobtracker.pyRs
		
	(RRRRtoslo_logRtloggingt	nova.i18nR
Rt	getLoggerR"RtobjectR(((sY/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/instancejobtracker.pyt<module>s