Gemfury

triliodata-4-0-patch / contego deb

Repository URL to install this package:
Details
contego / home / tvault / .virtenv / lib / python2.7 / site-packages / nova / virt / libvirt / driver.pyc
ó
±EYc@sdZddlZddlmZddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlZddl
Z
ddlZddlZddlmZddlmZddlmZddlmZddlmZdd	lmZdd
lmZddlmZddlm Z dd
lm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddl&Z&ddl'm(Z(ddl)m*Z+ddl,m-Z-ddl.m/Z/ddl.m0Z0ddl.m1Z1ddl.m2Z2ddl.m3Z4ddl.m5Z5ddl6Z,ddl7m8Z9ddl7m:Z;ddl,m<Z=ddl,m>Z>ddl?m@Z@dd l?mAZAdd!l?mBZBdd"l?mCZCdd#l,mDZDdd$lEmFZGdd%l,mHZHdd&lImJZJdd'lImKZLdd(lMmNZOddlMm3ZPddl,m3Z3dd)l,mQZQddlRm-ZSdd*lRmTZTdd+lRmUZUdd,lVmWZXdd-lYmZZZdd.lRm[Z[dd/lRm\Z\dd0lRm]Z]dd$l^mFZ_dd1lRm`Z`dd2lambZbdd3lamcZddd/lam\Zedd4lamfZgdd5lamhZhdd6lamiZidd7lamjZjdd8lamkZkdd9lamlZmdd:lnmoZodd;lnmpZpdd<lnmqZqddlam3Zrdd=lamsZtdd>lumvZvdd?lRmwZwdd@lRmxZxddAlymzZzddBlym{Z{da}e~aejeZe,jjZdCeejeejjfZidDdE6dFdG6ZdHe%jZdIZdZdJZejdKdLdMdNdOgZdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dagZdbZed|Zd}Zd~ZdZdZdZdZdZdZdgZdZdgZdZdZdZdZ dZ¡dZ¢dZ£dZ¤dZ¥dZ¦dZ§dZ¨dZ©dZªdZ«dsZ¬e¬dcZdZ®dZ¯dZ°ie¤e/j±6e¤e/j²6e§e/j³6e§e/j´6e§e/jµ6Z¶ie¥e/j±6e¥e/j²6e¨e/j³6e¨e/j´6e¨e/jµ6Z·dZ¸dtZ¹idudu6dvdw6dxdy6Zºdze[j»fd{YZ¼dS(sb
A connection to a hypervisor through libvirt.

Supports KVM, LXC, QEMU, UML, XEN and Parallels.

iÿÿÿÿN(tdeque(tgreenthread(ttpool(tetree(t	connector(tprocessutils(tlog(t	jsonutils(tloopingcall(texcutils(t	fileutils(timportutils(tstrutils(t	timeutils(tunits(trange(tbase(tblock_device(tarch(thv_type(tpower_state(ttask_states(tutils(tvm_mode(tserial(ttype(tcontext(t	exception(t_(t_LE(t_LI(t_LW(timage(tmodel(tobjects(tfields(tmigrate_data(tmanager(tversion(tconfigdrive(tdiagnostics(tapi(tguestfs(tdriver(tfirewall(thardware(timages(t	blockinfo(tconfig(tguest(thost(timagebackend(t
imagecache(tinstancejobtracker(t	migration(tdmcrypt(tlvm(t	rbd_utils(tvif(tremotefs(tnetutils(twatchdog_actions(tcinder(t
encryptorss%s.%ss/usr/share/OVMF/OVMF_CODE.fdtx86_64s/usr/share/AAVMF/AAVMF_CODE.fdtaarch64idsAUTO: sconsole=tty0 console=ttyS0tGuestNumaConfigtcpusettcputunet
numaconfigtnumatunes=iscsi=nova.virt.libvirt.volume.iscsi.LibvirtISCSIVolumeDrivers:iser=nova.virt.libvirt.volume.iser.LibvirtISERVolumeDrivers9local=nova.virt.libvirt.volume.volume.LibvirtVolumeDrivers<fake=nova.virt.libvirt.volume.volume.LibvirtFakeVolumeDrivers7rbd=nova.virt.libvirt.volume.net.LibvirtNetVolumeDrivers<sheepdog=nova.virt.libvirt.volume.net.LibvirtNetVolumeDrivers7nfs=nova.virt.libvirt.volume.nfs.LibvirtNFSVolumeDrivers=smbfs=nova.virt.libvirt.volume.smbfs.LibvirtSMBFSVolumeDrivers7aoe=nova.virt.libvirt.volume.aoe.LibvirtAOEVolumeDriversIglusterfs=nova.virt.libvirt.volume.glusterfs.LibvirtGlusterfsVolumeDriversSfibre_channel=nova.virt.libvirt.volume.fibrechannel.LibvirtFibreChannelVolumeDriversCscality=nova.virt.libvirt.volume.scality.LibvirtScalityVolumeDrivers:gpfs=nova.virt.libvirt.volume.gpfs.LibvirtGPFSVolumeDriversCquobyte=nova.virt.libvirt.volume.quobyte.LibvirtQuobyteVolumeDrivers:hgst=nova.virt.libvirt.volume.hgst.LibvirtHGSTVolumeDriversCscaleio=nova.virt.libvirt.volume.scaleio.LibvirtScaleIOVolumeDrivers=disco=nova.virt.libvirt.volume.disco.LibvirtDISCOVolumeDriversIvzstorage=nova.virt.libvirt.volume.vzstorage.LibvirtVZStorageVolumeDrivercCs.d}d}|tj_|tj_dS(sÃeventlet.tpool.Proxy doesn't work with old-style class in __str__()
    or __repr__() calls. See bug #962840 for details.
    We perform a monkey patch to replace those two instance methods.
    cSs
t|jS(N(tstrt_obj(tself((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt
str_method²scSs
t|jS(N(treprRH(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytrepr_methodµsN(RtProxyt__str__t__repr__(RJRL((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytpatch_tpool_proxys		iiiiiiiiii	ii
iii
tqcow2itVIR_PERF_PARAM_tcmtt	mbm_localtmbmlt	mbm_totaltmbmtt
LibvirtDriverc	BsÕ
eZied6ed6ed6ed6ed6ZedZdZedZdZ	d	Z
d
ZdZdZ
d
ZdZdZdZdZdZdZeeZedZedZedZdZdZdZdZdZdZdZ ddZ!dedd Z#d!Z$deded"Z%d#Z&dd$Z'ed%Z(d&Z)d'Z*d(Z+d)Z,d*Z-d+Z.d,Z/d-Z0d.Z1d/Z2d0Z3dddd1Z4d2Z5d3Z6dd4Z7dd5Z8d6Z9d7Z:d8Z;d9Z<d:Z=d;Z>d<Z?d=Z@d>ZAd?ZBd@ZCdAZDdBZEdCZFdDZGdEZHdFZIedGZJddHZKdIZLdddJZMdKZNddLZOdMZPdNZQdOZRdPdPdQZSddRZTdSZUdTZVddUZWddVZXdWZYdXZZdYZ[dddZZ\d[Z]d\Z^d]Z_d^Z`d_Zad`ZbdaZcedbZdeedddcZeedddZfedeZgdfZhedgdhZiediZjedjZkedkZldlZmdgdddddeddmZndnZoddddgdoZpdpZqdqZrdrZsedsZtddtZuduZvewdvZxdwZydxZzddyZ{ddzZ|d{Z}d|Z~d}Zd~ZdZdZdZdZdZedZdZdZdZdZdZdddZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ¡d Z¢d¡Z£dddd¢Z¤d£Z¥d¤Z¦ddd¥Z§d¦Z¨d§Z©d¨Zªe«j¬d©ZddeeddªZ®d«Z¯d¬Z°dZ±deeedd®Z²d¯Z³ed°Z´d±Zµd²Z¶d³Z·d´Z¸dµZ¹d¶Zºd·Z»d¸Z¼d¹Z½dºZ¾d»Z¿d¼ZÀd½ZÁd¾ZÂd¿ZÃdÀZÄdÁZÅeedÂZÆdÃZÇddÄZÈddÅZÉddÆZÊdÇZËdÈZÌdÉZÍdÊZÎdËZÏdÌZÐdÍZÑeddÎZÒdÏZÓdÐZÔdÑZÕdÒZÖedÓZ×dÔZØdÕZÙdÖZÚd×ZÛdØZÜdÙZÝdÚZÞdÛZßddÜZàddÝZáeddÞZâdßZãddàZäddáZåddâZædãZçeddäZèddåZéddæZêdçZëdèZìedéZídêZîdëZïdìZðedíZñdîZòddPdPdïZódðZôedñZõedòZöedóZ÷dôZødedõZùdöZúded÷ZûdøZüedùZýdúZþdûZÿedüZdýZdþZdÿZdZedZdZdZdZdZ	RS(thas_imagecachetsupports_recreatetsupports_migrate_to_same_hosttsupports_attach_interfacetsupports_device_taggingcCsett|j|tdkr=tjdatt_ntj	|j
|d|jd|j|_
d|_d|_d|_d|_g|_tjtd|j
|_tj|_tj|j||_d|_tj |_!t"j#t$j%|_&i|_'ddddd	d
g|_(t$jj)dk|_*xrt$jj'D]d}|j+d
\}}}||j(kr¦t,j-t.di|d6|d6qOn||j'|<qOWt/j0|_1t2j0|_3idd6|j4d6|j5d6|j6d6}|j7t$jj8|_9t:j;|_<t=j>|_?d|_@|_Ai|_BtCjD|_EdS(Ntlibvirttlifecycle_event_handlertconn_event_handlerR2tdefaulttnonetwritethrought	writebackt
directsynctunsafetkvmtqemut=sGInvalid cachemode %(cache_mode)s specified for disk type %(disk_type)s.t
cache_modet	disk_typecSsdS(N(tNone(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt<lambda>sR-tostautoi(skvmsqemu(FtsuperRXt__init__R^RlRt
import_moduletlibvirt_migrateR2tHostt_urit
emit_eventt_handle_conn_eventt_hostt
_initiatort	_fc_wwnnst	_fc_wwpnst_capst_supported_perf_eventsR,tload_drivertDEFAULT_FIREWALL_DRIVERtfirewall_drivertlibvirt_viftLibvirtGenericVIFDrivert
vif_driverR+tdriver_dict_from_configt_get_volume_driverstvolume_driverst_disk_cachemodeR4tImageCacheManagertimage_cache_managerR3tBackendtCONFtuse_cow_imagest
image_backendtdisk_cachemodestvalid_cachemodest	virt_typet_conn_supports_start_pausedt	partitiontLOGtwarningRR>tAPIt_volume_apiR t
_image_apit!_get_host_sysinfo_serial_hardwaret_get_host_sysinfo_serial_ost_get_host_sysinfo_serial_autotgettsysinfo_serialt_sysinfo_serial_funcR5tInstanceJobTrackertjob_trackerR;tRemoteFilesystemt	_remotefst_live_migration_flagst_block_migration_flagstactive_migrationsR-tnuma_get_reserved_huge_pagest_reserved_hugepages(RItvirtapit	read_onlytmode_strRktsepRjtsysinfo_serial_funcs((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRqKsf									



	cCstS(N(tlibvirt_volume_drivers(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRscCs@|jdkr9d|_|jtjs9d|_q9n|jS(NRbRc(RRlt_supports_direct_ioRtinstances_path(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytdisk_cachemodes
	cCsMy|j}|j}Wntk
r*dSX|jj||}||_dS(s0Set cache mode on LibvirtConfigGuestDisk object.N(tsource_typetdriver_cachetAttributeErrorRR(RItconfR°R±Rj((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_set_cache_mode§s	

	cCsy|jj}|jjj}tjjdksH|tjtj	fkrut
jtditjjd6|d6ndS(s0Warn about untested driver configurations.

        This will log a warning message about untested driver or host arch
        configurations to indicate to administrators that the quality is
        unknown. Currently, only qemu or kvm on intel 32- or 64-bit systems
        is tested upstream.
        RhRgsÏThe libvirt driver is not tested on %(type)s/%(arch)s by the OpenStack project and thus its quality can not be ensured. For more information, see: http://docs.openstack.org/developer/nova/support-matrix.htmlRRN(sqemuskvm(
Rxtget_capabilitiesR2tcpuRRR^RtI686tX86_64RRR(RItcapsthostarch((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_do_quality_warnings³scCs8tjtdi|d6|d6|j||dS(Ns2Connection event '%(enabled)d' reason '%(reason)s'tenabledtreason(RtinfoRt_set_host_enabled(RIR¼R½((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRwÆscCs&djg|D]}t|^q
S(Nt.(tjoinRG(RIR&tx((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_version_to_stringËsc
Cs|jj|j|j|j|_tjjdkrqtjj	oWtjj
rqtjt
dntjjdkrtjn|jjtsÇtjtd|jtntjjdkr|jjdtrtjtd|jtntjjdkr^|jjtr^tjtd	|jtn|jjtstjt
d
i|jtd6ntjjdkrê|jjdtrêtjt
di|jtd6ntj}tjjdkr|tkr|jjtj|tj|rtjtd
i|d6|jtj|d6|jtj|d6ndS(NtlxcsÖRunning libvirt-lxc without user namespaces is dangerous. Containers spawned by Nova will be run as the host's root user. It is highly suggested that user namespaces be used in a public or multi-tenant environment.Rgs,Nova requires libvirt version %s or greater.Rhthv_vers)Nova requires QEMU version %s or greater.t	parallelssARunning Nova with parallels virt_type requires libvirt version %ss£Running Nova with a libvirt version less than %(version)s is deprecated. The required minimum version of libvirt will be raised to %(version)s in the next release.R&sRunning Nova with a QEMU version less than %(version)s is deprecated. The required minimum version of QEMU will be raised to %(version)s in the next release.sRunning Nova with qemu/kvm virt_type on %(arch)s requires libvirt version %(libvirt_ver)s and qemu version %(qemu_ver)s, or greaterRtlibvirt_vertqemu_ver(sqemuskvm(sqemuskvm(skvmsqemu(Rxt
initializeR»t_parse_migration_flagst_get_supported_perf_eventsR}RR^Rtuid_mapstgid_mapsRRRR*t	force_tcgthas_min_versiontMIN_LIBVIRT_VERSIONRt
NovaExceptionRRÃtMIN_QEMU_VERSIONtMIN_LIBVIRT_PARALLELS_VERSIONtNEXT_MIN_LIBVIRT_VERSIONtNEXT_MIN_QEMU_VERSIONRt	from_hosttMIN_LIBVIRT_OTHER_ARCHRtMIN_QEMU_OTHER_ARCH(RIR2tkvm_arch((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt	init_hostÎsZ

	
							
cCscd}|tjO}tjjdkr5|tjO}n|tjO}|}}|tjO}||fS(Nitxen(R^tVIR_MIGRATE_LIVERRtVIR_MIGRATE_PEER2PEERtVIR_MIGRATE_UNDEFINE_SOURCEtVIR_MIGRATE_NON_SHARED_INC(RItmigration_flagstlive_migration_flagstblock_migration_flags((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_prepare_migration_flagss


cCs2tjjdkstjjr.|tjO}n|S(N(RR^tlive_migration_tunnelledRltVIR_MIGRATE_TUNNELLED(RIRà((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt _handle_live_migration_tunnelled/scCs#|jjdtdtrtStS(Ntlv_verRÅ(RxRÏtMIN_LIBVIRT_POSTCOPY_VERSIONtMIN_QEMU_POSTCOPY_VERSIONtTruetFalse(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_is_post_copy_available5s	cCsBtjjr>|jr(|tjO}q>tjtdn|S(NsLThe live_migration_permit_post_copy is set to True, but it is not supported.(RR^tlive_migration_permit_post_copyRìtVIR_MIGRATE_POSTCOPYRR¾R(RIRà((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt _handle_live_migration_post_copy;s
cCs|jjdtdtro|jrP|tj@dkrPtjt	dqt
jjr|tjO}qn"t
jjrtjt	dn|S(NRçRÅisThe live_migration_permit_post_copy is set to True and post copy live migration is available so auto-converge will not be in use.sPThe live_migration_permit_auto_converge is set to True, but it is not supported.(
RxRÏt!MIN_LIBVIRT_AUTO_CONVERGE_VERSIONtMIN_QEMU_AUTO_CONVERGERìR^RîRR¾RRt#live_migration_permit_auto_convergetVIR_MIGRATE_AUTO_CONVERGE(RIRà((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt$_handle_live_migration_auto_convergeDs	cCs|j\}}|j|}|j|}|j|}|j|}|j|}|j|}||_||_dS(N(RãRæRïRôR¢R£(RIRáRâ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÊSs							cCs
|jjS(N(Rxtget_connection(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_connectionqscCs²tjjdkr'tjjp!d}ntjjdkrNtjjpHd}n`tjjdkrutjjpod}n9tjjdkrtjjpd}ntjjp«d	}|S(
Ntumls
uml:///systemRÛsxen:///RÄslxc:///RÆsparallels:///systemsqemu:///system(RR^Rtconnection_uri(turi((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRuvscCskidd6dd6dd6}tjj}tjjp?|j|}|dkrctjd|n||S(Nsqemu+tcp://%s/systemRgRhsxenmigr://%s/systemRÛR(RR^Rtlive_migration_uriRRlRtLiveMigrationURINotAvailable(tdestturisRRù((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_live_migration_uris
cCs;d}tjj}|dkr+d|}n|o:t|S(NRhRgstcp://%s(sqemuskvm(RlRR^RRG(RüRùR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_migrate_uris

cCs4y|jj|tSWntjk
r/tSXdS(s2Efficient override of base instance_exists method.N(Rxt	get_guestRêRRÑRë(RItinstance((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytinstance_exists¥s
cCs:g}x-|jjdtD]}|j|jqW|S(Ntonly_running(Rxtlist_guestsRëtappendtname(RItnamesR1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytlist_instancesscCs:g}x-|jjdtD]}|j|jqW|S(NR(RxRRëRtuuid(RItuuidsR1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytlist_instance_uuids´scCs(x!|D]}|jj||qWdS(sPlug VIFs into networks.N(Rtplug(RIRtnetwork_infoR:((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt	plug_vifs»s
cCsOxH|D]@}y|jj||Wqtjk
rF|sGqGqXqWdS(sUnplug VIFs from networks.N(RtunplugRRÑ(RIRR
t
ignore_errorsR:((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_unplug_vifsÀs
cCs|j||tdS(N(RRë(RIRR
((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytunplug_vifsÉscCsntj|}tjj|d}|jjd}tjdi|d6|d6d|t	j
||dS(Ntrootfstrootfs_device_namesQAttempting to teardown container at path %(dir)s with root device: %(rootfs_dev)stdirt
rootfs_devR(t
libvirt_utilstget_instance_pathRntpathRÁtsystem_metadataRRtdebugtdisk_apitteardown_container(RIRt	inst_patht
container_dirR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_teardown_containerÌs	ic
s=yajj}tjjr`j|}x-|D]"\}}tjd|d|q7WnWntjk
r}d}nXd}|dk	ry|j
}|jWqtj
k
r}t}	|j}
|
tjkræt}	ng|
tjkr"|jj}|tjkrMt}	qMn+|
tjkrg|j}tjjdkrM|dkrMt}	qMnæ|
tjkr°tjtddtd}
tjd	|
n|
tjkrM|j t!j"krMtjtd
i|
d6|d6|d
6dt#j$4}|dkrAt|_%j&|ddSWdQXqMn|	st#j$/tj't(di|
d6|d6dWdQXqqXnfd}itd6t)j*||}|j+ddj,drtj-t.ddj&n"tjjdkr9j/ndS(NR2tportiÿÿÿÿRÄs-internal error: Some processes refused to dies+Cannot destroy instance, operation time outRsoperation time outR½sYError from libvirt during destroy. Code=%(errcode)s Error=%(e)s; attempt %(attempt)d of 3terrcodetetattemptiis?Error from libvirt during destroy. Code=%(errcode)s Error=%(e)scsÚy%j}|j}|j}Wn9tjk
r`tjtddtj	nX|t
jkrtjtddtj	n||krÖtjtddtd<tj	ndS(s+Called at an interval until the VM is gone.s*During wait destroy, instance disappeared.Rs Instance destroyed successfully.sInstance may be started again.t
is_runningN(
tget_infotstatetidRtInstanceNotFoundRR¾RRtLoopingCallDoneRtSHUTDOWNRê(texpected_domidtdom_infoR't	new_domid(RtkwargsRI(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_wait_for_destroy.s"	

R%tintervalgà?s Going to destroy instance again.(0RxRRtserial_consoleR¼t_get_serial_ports_from_guesttrelease_portRR)RlR(tpoweroffR^tlibvirtErrorRëtget_error_codetVIR_ERR_NO_DOMAINRêtVIR_ERR_OPERATION_INVALIDtget_power_stateRR+tVIR_ERR_INTERNAL_ERRORtget_error_messageRtVIR_ERR_OPERATION_TIMEOUTRRRRtInstancePowerOffFailuretVIR_ERR_SYSTEM_ERRORtget_int1terrnotEBUSYR	tsave_and_reraise_exceptiontreraiset_destroyterrorRRtFixedIntervalLoopingCalltstarttwaitR¾RR (RIRR$R1tserialsthostnameR!t	old_domidR#tis_okayR"R'terrmsgR½tctxtR0ttimer((RR/RIsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyREÖsv!
		
	

		
cCs-|j||j||||||dS(N(REtcleanup(RIRRR
tblock_device_infot
destroy_disksR$((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytdestroyZs
c	Cs¡y|jj|}y|jWn_tjk
r}tj;|j}tj	t
di|d6|d6d|WdQXnXWntjk
rnXdS(Ns@Error from libvirt during undefine. Code=%(errcode)s Error=%(e)sR"R#R(
RxRtdelete_configurationR^R6R	RCR7RRFRRR)(RIRR1R#R"((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_undefine_domain`s
)cCsx|r|j||tnt}x|r<y|j||Wnñtjk
r}	y|j|j}
Wntjk
rt	j
}
nX|
t	j
krÂtjt
dd||j|q9t}|	j}tjtdi|d6|	d6d|d}tjd|q%tk
r2t}q%Xt}q%Wtj|}
x8|
D]0}|d}|d	}|dk	r|jd
d}nd|krÿd
|dkrÿ|dd
}tj||j||}|rÿ|j||}|j|qÿny|j||WqStk
r}tjL}|ryt|_ tjt
di|j!d
d6|d6d|nWdQXqSXqSW|r×t"jj#dkr²|j$||nt"jj#dkr×|j%|q×nt}|rûd|krû|j&}n|s|rgt'|j(j!dd}|j)|}t*|d|j(d<|rZt|_+n|j,n|j-|dS(Ns0Instance may be still running, destroy it again.Rs@Error from libvirt during unfilter. Code=%(errcode)s Error=%(e)sR"R#sError unfiltering instance.R½tconnection_infotmount_devicet/itdatat	volume_ids=Ignoring Volume Error on vol %(vol_id)s during delete %(exc)stvol_idtexcR8trbdtis_shared_block_storagetclean_attemptst0i(.RRêtunfilter_instanceR^R6R&R'RR)RR+RRRRERëR7RtInstanceTerminationFailuret	ExceptionR+tblock_device_info_get_mappingRlt
rpartitionR?tget_encryption_metadataRt_get_volume_encryptort
detach_volumet_disconnect_volumeR	RCRDRRtimages_typet_cleanup_lvmt_cleanup_rbdR_tintRtdelete_instance_filesRGtcleanedtsaveRV(RIRRR
RRRSR$tdestroy_vifstretryR#R'R"R½tblock_device_mappingtvolRWtdisk_devR[t
encryptiont	encryptorR]ROR_tattemptstsuccess((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRQns	


	

				
cCsftj|j||}ttjg|D]}|d^q+}x|D]}tj|qKWdS(s0Detaches encrypted volumes attached to instance.RN(Rtloadstget_instance_disk_infotfilterR7tis_encryptedt
delete_volume(RIRRRtdiskstdisktencrypted_volumesR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_detach_encrypted_volumesÒs	 
c
cs°|j}tj|}|r+d|nd}d|}d|}|j|}t|dkrx|j|}nx1|D])}	|	jdt|	jdfVqWdS(	sReturns an iterator over serial port(s) configured on guest.

        :param mode: Should be a value in (None, bind, connect)
        s[@mode='%s']ts$./devices/serial[@type='tcp']/sources%./devices/console[@type='tcp']/sourceiR2tserviceN(tget_xml_descRt
fromstringtfindalltlenRRn(
RIR1tmodetxmlttreet
xpath_modet
serial_tcptconsole_tcpttcp_devicestsource((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR3Ûs


cCs.tjdtjjdtjjdtjjS(Ntpoolt	ceph_conftrbd_user(R9t	RBDDriverRR^timages_rbd_pooltimages_rbd_ceph_confR(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_rbd_driverïs	csJjtjkr$fd}nfd}tjj|dS(Ncs|jjo|jdS(Ns
disk.local(t
startswithR	tendswith(R(R(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRmüscs|jjS(N(RR	(R(R(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRmÿs(t
task_stateRtRESIZE_REVERTINGRXRtcleanup_volumes(RIRt	filter_fn((RsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRmöscCsQ|jddk	r(|j||n|j|}|rMtj|ndS(s/Delete all LVM disks for given instance object.tephemeral_key_uuidN(RRlRt
_lvm_disksR8tremove_volumes(RIRRRR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRls
cstjjrtjjdtjjtjjs=gSd|jfd}fd}tj	}t
||}t||}|SgS(s0Returns all LVM disks for given instance object.s/devs%s_cs
|jS(N(R(R(tpattern(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytbelongs_to_instancescstjj|S(N(RnRRÁ(R(tvg(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytfullpaths(RR^timages_volume_groupRnRRÁtexistsR	R8tlist_volumesR}tmap(RIRR£R¥tlogical_volumest
disk_namesR((R¢R¤sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR s
cCs7tj}tj|tjtjjdtdtj	S(Ntenforce_multipathR2(
Rtget_root_helperRtget_connector_propertiesRtmy_block_storage_ipR^tvolume_use_multipathRêR2(RIRtroot_helper((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_volume_connector s	cCsÇtj|d}tjj|rGtjdd|dtddn|jj	|d}|jr|j
tjdtn|jt
jkrÃ|j||j|||j||ndS(	Nt_resizetrms-rftdelay_on_retryRyiRR(RRRnRR§RtexecuteRêRR tremove_snaptRESIZE_SNAPSHOT_NAMER2RRVRRb(RIRR
ttargett	root_disk((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_cleanup_resize(s


cCs>|jd}||jkr3tjd|n|j|S(Ntdriver_volume_typetdriver_type(RRRtVolumeDriverNotFound(RIRWR½((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_volume_driverCscCs#|j|}|j||dS(N(R¿tconnect_volume(RIRWt	disk_infot
vol_driver((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_connect_volumeIscCs#|j|}|j||dS(N(R¿tdisconnect_volume(RIRWRvRÂ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRjMscCs|j|}|j||S(N(R¿t
get_config(RIRWRÁRÂ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_volume_configQscCstj||}|S(N(R?tget_volume_encryptor(RIRWRwRx((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRhUs		cCsO|jdkrK|jdkrKtjdi|jd6|jd6d|ndS(sõPerform some checks for volumes configured for discard support.

        If discard is configured for the volume, and the guest is using a
        configuration known to not work, we will log a message explaining
        the reason why.
        tunmaptvirtiosÀAttempting to attach volume %(id)s with discard support enabled to an instance using an unsupported configuration. target_bus = %(bus)s. Trim commands will not be issued to the storage device.tbusR(RN(tdriver_discardt
target_busRRR(RIR³R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt _check_discard_for_attach_volumeZs
	

c	CsF|jj|}|jdd}	i|	d6|d6|d6}
i}d|kr_|d}nd|kswd|krÆtjjd	krÆtjjd
krÆtdtjj}tj|qÆnt	j
|tjj|j|
}
|j||
|j
||
}|j||j||yr|j|j}|tjtjfk}|r~|j||}|j||n|j|dtd
|Wn§tk
rA}tjtd|d|t|tjr|j}|tjkr|j||	tj d|	qnt!j"|j||	WdQXnXdS(NRYitdevice_nametdisk_bustdevice_typeRZtlogical_block_sizetphysical_block_sizeRgRhsbVolume sets block size, but the current libvirt hypervisor '%s' does not support custom block sizet
persistenttlives)Failed to attach volume at mountpoint: %sRtdevice(#RxRRfRR^RRRtInvalidHypervisorTypeR/tget_info_from_bdmt
image_metaRÃRÆR´RÍR:RtRUNNINGtPAUSEDRht
attach_volumet
attach_deviceRêRdRRt
isinstanceR6R7tVIR_ERR_OPERATION_FAILEDRjtDeviceIsBusyR	RC(RIRRWRt
mountpointRÏRÐRwR1RvtbdmRZtmsgRÁR³R'RÔRxtexR"((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÛksN

	

		

cCs|j|}|jdtdt}y|jWntk
rHnXz°|jre|jn|j|dtdtx|jrt	j
dqW|jdt|røx#|jdtrÙt	j
dq·W|j|tj
tjnWd|jj|XdS(	s+Swap existing disk with a new block device.t
dump_inactivetdump_sensitivetcopyt	reuse_extgà?tpivottwait_for_job_cleanN(tget_block_deviceRRêt	abort_jobRdthas_persistent_configurationRUtrebasetwait_for_jobttimetsleeptresizeRtGitKiRxtwrite_instance_config(RIR1t	disk_pathtnew_patht	resize_totdevR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_swap_volume¢s$

"c
CsF|jj|}|jdd}|j|sItjd|ni|d6tjtj	j
|d6dd6}|j|||j||}	|	j
sÆ|j||ttdn|jd	}
tjjtj|
|j}tj|}||d
<|j|j|||	j
||j||dS(NRYitlocationRøRÊRRsSwap only supports host devicesRRW(RxRRftget_diskRtDiskNotFoundR/tget_disk_bus_for_disk_devRR^RRÃRÆtsource_pathRjtNotImplementedErrorRRR"tBlockDeviceMappingtget_by_volume_and_instancetnova_contexttget_admin_contextR	tdriver_block_devicetconvert_volumeRqRù(
RItold_connection_infotnew_connection_infoRRàR÷R1RvRÁR³R[Rát
driver_bdm((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytswap_volumeÊs,
		

cCsy"|jj|}|j}Wn_tjk
rtjtjj	||j
|}|jtj
||||j
d|}nX|S(NRR(RxRRRR)R/t
get_disk_infoRR^RRØt_get_guest_xmlRR(RIRR
RRR1RRÁ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_existing_domain_xmlés			
c
Cs[|jdd}y|jj|}|j|j}|tjtjfk}|j|j|dt	d|}	|r|j
||}
|
j|n|	Wn¡tj
k
rÒtjtdd|nutjk
r÷tjd|nPtjk
rF}|j}|tjkr@tjtdd|qGnX|j||dS(NRYiRÓRÔs+During detach_volume, instance disappeared.RRú(RfRxRR:RRÙRÚtdetach_device_with_retryRûRêRhRiRR)RRRtDeviceNotFoundRüR^R6R7R8Rj(
RIRWRRàRwRvR1R'RÔtwait_for_detachRxRãt
error_code((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRiùs4			

cCs|jj|}|jj|||jj||g|jj||||jtj	j
|j}yG|j|j}|tj
tjfk}|j|dtd|Wn[t	jk
rtjtdd|dt|jj||tjd|jnXdS(NRÓRÔs!attaching network adapter failed.Rtexc_infot
instance_uuid(RxRRRRtsetup_basic_filteringRÅtflavorRR^RR:RRÙRÚRÜRêR6RRFRRRtInterfaceAttachFailedR	(RIRRØR:R1tcfgR'RÔ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytattach_interface&s"	
	cCsn|jj|}|jj|||j|jtjj|j}yZ|jj	|||j
|j}|tjtj
fk}|j|dtd|WnËtjk
ri}|j}|tjkrètjtdd|qj|jd}	|j|	}
|
rCtjtdd|dttjd|jntjtd	i|	d
6d|nXdS(NRÓRÔs.During detach_interface, instance disappeared.Rtaddresss!detaching network adapter failed.RRsWDetaching interface %(mac)s failed  because the device is no longer found on the guest.tmac(RxRRRÅRØRRR^RRR:RRÙRÚt
detach_deviceRêR6R7R8RRRRtget_interface_by_macRFRRtInterfaceDetachFailedR	(RIRR:R1RR'RÔRãRRt	interface((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytdetach_interface:s0

	cCs¾itd6dd6|d6i|jd6dd6dd	6|jd
6|jd6d6}|jrk|j|dd
<n|jdkrd|d<n
||d<|jdr°|j|d<n
d|d<|S(Nt	is_publictactivetstatusRt	kernel_idtsnapshottimage_locationt	availabletimage_statetowner_idt
ramdisk_idt
propertiestos_typetamitdisk_formattcontainer_formattbare(RëR"t
project_idR(R*R,tobj_attr_is_setR-(RIRØRtimg_fmttsnp_nametmetadata((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_create_snapshot_metadatacs$


	

cCsRy|jj|}|j}Wn)tjk
rJtjd|jnX|jj||}t	j
|\}}	t	j|}
|
dkr|	}
nt
jjp¨|
}|dksÃ|dkrÌd}n|j|j|||d}tjj}
|j|j}|jjdtjr§|
dkr§t
jjr§t
jjr§t}y|j|jWqtjk
r£}|j }|tj!kr¤t"}q¤qXnt"}|t#j$krÅt"}n|j%|||||j&j'||d|
}|rt(j)t*dd	|nt(j)t*d
d	||dt+j,yt|dt+j-dt+j,|j.||
|||j/|d
<|j0||||||jj1|||dt"Wn}t2tj3tj4fk
r·}t5|t2krt(j6t7di|d6n|j8d
d}|r6it9|d6}n|j:|dtdt|dt+j,dt+j-|
dkr|rt"}|j%||||nt
jj;}t<j=|t>j?d|î}zgt@jAjB||
}|rt@jC|d|jD||||||	||jn|jE||Wd|j0|||||t(j)t*dd	|X|dt+j-dt+j,t	jF| }|jj1||||WdQXWdQXn~tGk
r4tHjI_t(jtJd|j8d
d}|rit9|d6}n|j:|dtdtWdQXnXt(j)t*dd	|dS(seCreate snapshot from a running VM instance.

        This command only works with qemu 0.14+
        tinstance_idR8R^trawRRt
image_typesBeginning live snapshot processRsBeginning cold snapshot processRtexpected_stateRútpurge_propssFPerforming standard snapshot because direct snapshot failed: %(error)sRFturltalso_destroy_volumeRRiÁNs*Snapshot extracted, beginning image uploadsFailed to snapshot imagesSnapshot image upload complete(KRxRt_domainRR)tInstanceNotRunningR	RRRt	find_disktget_disk_type_from_pathRlRR^tsnapshot_image_formatR4RØtuuid4thexR:RÏR2tHV_DRIVER_QEMUtephemeral_storage_encryptionR¼tworkaroundstdisable_libvirt_livesnapshotRêRêRëR6R7tVIR_ERR_CONFIG_UNSUPPORTEDRëRR+t_prepare_domain_for_snapshotRR#RR¾RRtIMAGE_PENDING_UPLOADtIMAGE_UPLOADINGtdirect_snapshott	image_reft_snapshot_domaintupdateRÿtImageUnacceptablet	ForbiddenRRRtpopRGtcleanup_direct_snapshottsnapshots_directoryR
tensure_treeRttempdirRnRRÁtchmodt_live_snapshottsnapshot_extractt	file_openRdR	RCR(RIRRtimage_idtupdate_task_stateR1tvirt_domR#Rõt
source_formatR°timage_formatR3t
snapshot_nameR't
live_snapshotRãRtsnapshot_backendR#tfailed_snaptsnapshot_directoryttmpdirtout_patht
image_file((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR#sÒ
		


			





		



cCsQtjjdkrM|rM|tjks7|tjkrM|j||qMndS(NRÄ(RR^RRRÙRÚtsuspend(RIRR`R'R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRH(scCs¯d}tjjdkr«|r«|tjkrC|jd|}n*|tjkrm|jd|dt}n|dk	r«|j	|t
j||j|||q«ndS(NRÄtdomaintpause(
RlRR^RRRÙt_create_domainRÚRêt_attach_pci_devicestpci_managertget_instance_pci_devst_attach_sriov_ports(RIRR`R\R'RR1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRM/scCsktjjdks%|jjtr4tjn|jj	dd}t
j|sgtjndS(NRgRhthw_qemu_guest_agentR(skvmsqemu(
RR^RRxRÏtMIN_LIBVIRT_SET_ADMIN_PASSWDRtSetAdminPasswdNotSupportedR)RRtbool_from_stringtQemuGuestAgentNotEnabled(RIRØthw_qga((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_can_set_admin_password?scCsÏ|j|j|jj|}|jjjd}|s^|jdkrUd}q^d}ny|j||WnVtj	k
rÊ}|j
}tdi|d6|d6|d6}tj
|nXdS(	Nt
os_admin_usertwindowst
AdministratortrootsaError from libvirt while set password for username "%(user)s": [Error Code %(error_code)s] %(ex)stuserRRã(RuRØRxRR)RR*tset_user_passwordR^R6R7RRRÑ(RIRtnew_passR1RzRãRRâ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytset_admin_passwordHs			cCsetjjdks%|jjtr=tjd|jn|j	j
dtsatjndS(NRgRhR5Ro(skvmsqemu(
RR^RRxRÏtMIN_LIBVIRT_FSFREEZE_VERSIONRtInstanceQuiesceNotSupportedR	R)RRëRs(RIRRØ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_can_quiesce[s	c	Cs£|j||y3|jj|}|r8|jn
|jWnYtjk
r}|j}tdi|j	d6|d6|d6}t
j|nXdS(NsXError from libvirt while quiescing %(instance_name)s: [Error Code %(error_code)s] %(ex)st
instance_nameRRã(RRxRtfreeze_filesystemstthaw_filesystemsR^R6R7RRRRÑ(	RIRRRØtquiescedR1RãRRâ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt
_set_quiescedds
	
cCs|j|||tdS(sFreeze the guest filesystems to prepare for snapshot.

        The qemu-guest-agent must be setup to execute fsfreeze.
        N(RRê(RIRRRØ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytquiescetscCs|j|||tdS(s*Thaw the guest filesystems after snapshot.N(RRë(RIRRRØ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt	unquiesce{sc	CsÜ|j|}	|jdtdt}
y|	jWntk
rHnXtj|d|}tj|d|dt}|d}
tj	||
|t}y |j
|||tt}WnTtjk
r}|j
jdtrìntjtdi|d6d	|nXz||jr/|jn|	j|
d
tdtdtx|	jrmtjd
qQW|	jtj|
tjWd|jj|
|rÁ|j
|||tnXtj|
d||dS(s&Snapshot an instance without downtime.RäRåtformattbasenames.deltatos_require_quiesces(Skipping quiescing instance: %(reason)s.R½RRæRçtshallowgà?NRQ(RêRRêRëRdRt
get_disk_sizetget_disk_backing_fileRëtcreate_cow_imageRRRÑR)RRR¾RRìRURíRîRïRðtchownRntgetuidRxRôtextract_snapshot(RIRRR1RõReR]R^RØRøRt
src_disk_sizet
src_back_patht
disk_deltaRterr((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRWsH
		



cCsEy|jj|||Wn$tk
r@tjtdnXdS(s·Send a snapshot status update to Cinder.

        This method captures and logs exceptions that occur
        since callers cannot do anything useful with these exceptions.

        Operations on the Cinder side waiting for this will time out if
        a failure occurs sending the update.

        :param context: security context
        :param snapshot_id: id of snapshot being updated
        :param status: new status value

        s9Failed to send updated snapshot status to volume service.N(Rtupdate_snapshot_statusRdRRR(RIRtsnapshot_idR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_volume_snapshot_update_statusÀs
cCsÔ|j}tj|}tj}|j|g}	g}
g}x2|jD]'}|jdkrkqPn|jdkrqPn|j
dks|j
|kr´|j|jqPni|jd6|j
d6|jd6|j
d6|jd6|jd6|jd6}
|
ddk	rQ|
d}tjjtjj||}|	j||fqP|
ddkrP|
j|
|fqPqPW|	r§|
r§td}tj|ntj}xZ|	D]R\}}tj}||_||_d|_d
|_d|_|j|qºWx¦|
D]\}
}tj}|
d|_d|_|
d|_
d
|_||_|
djdd}d||f|_|
d|_|
d|_|j|qWx9|D]1}tj}||_d|_|j|qÀW|j }t!j"d|d|y-|j|dt#dt#dt#dt#dSWn-t$j%k
rst!jt&dd|nXy)|j|dt#dt#dt#dt'Wn0t$j%k
rÏt!jt&dd|nXdS(sÜPerform volume snapshot.

           :param guest: VM that volume is attached to
           :param volume_id: volume UUID to snapshot
           :param new_file: relative path to new qcow2 file present on share

        RRøRtcurrent_filetsource_protocoltsource_nametsource_hoststsource_portstglustertnetfssFound no disk to snapshot.tfiletexternalRQtnetworkRYis%s/%stnossnap xml: %sRtno_metadatat	disk_onlyRçRNsPUnable to create quiesced VM snapshot, attempting again with quiescing disabled.s@Unable to create VM snapshot, failing volume_snapshot operation.(RR((RRRtvconfigtLibvirtConfigGuestt	parse_domtdevicest	root_namet
target_devRlRRRþRRRRRnRRÁtdirnameRRRÑtLibvirtConfigGuestSnapshottLibvirtConfigGuestSnapshotDiskRR°R#tdriver_nametadd_disktsplittto_xmlRRRêR^R6RRë(RIRRR1R[tnew_fileRtxml_doctdevice_infot
disks_to_snaptnetwork_disks_to_snapt
disks_to_skipt
guest_diskRÁRt
new_file_pathRâR#tcurrent_nametnew_filenamet	snap_disktold_dirRøtsnapshot_xml((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_volume_snapshot_create×s	








						
	
		


		
cCsPtjj|||j}tj|}|rL|j|||j|ndS(N(R"RRR	RRtrefresh_connection_infoR(RIRRR[RáR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_volume_refresh_connection_infoEs	cstjdi|d6dyjj}Wn)tjk
r^tjdjnX|ddkrtjt	d|dn|j
dd
d
krÅtjt	d	ny!j||d
WnPt
k
r8tj1tjtddjdWd
QXnXjdfd}tj|}|jddjd
S(sCreate snapshots of a Cinder volume via libvirt.

        :param instance: VM instance object reference
        :param volume_id: id of volume being snapshotted
        :param create_info: dict of information used to create snapshots
                     - snapshot_id : ID of snapshot
                     - type : qcow2 / <other>
                     - new_file : qcow2 file created by Cinder which
                     becomes the VM's active image after
                     the snapshot is complete
        s/volume_snapshot_create: create_info: %(c_info)stc_infoRR5RRQsUnknown type: %sRs#snapshot_id required in create_infoR³sMError occurred during volume_snapshot_create, sending error status to Cinder.RFNtcreatingcsPjj}|jddkrLjtjndS(NR!RÄ(Rtget_snapshotRRÂRR*(R#(RRRIRR[(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_wait_for_snapshot|s
R1gà?(RRRxRRR)R=R	RÑRRRlRÀRdR	RCRRRRGRHRI(RIRRR[tcreate_infoR1RÆRP((RRRIRR[sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytvolume_snapshot_createNs4	


c	Cs·|j}|dk	rKtdi|d6}tj|tj|n|dkrfd}g}n$|}tj|j	}d|g}|j
|jtj
ddd||dS(	sERebase a device tied to a guest using qemu-img.

        :param guest:the Guest which owns the device being rebased
        :type guest: nova.virt.libvirt.guest.Guest
        :param device: the guest block device to rebase
        :type device: nova.virt.libvirt.guest.BlockDevice
        :param active_disk_object: the guest block device to rebase
        :type active_disk_object: nova.virt.libvirt.config.                                    LibvirtConfigGuestDisk
        :param rebase_base: the new parent in the backing chain
        :type rebase_base: None or string
        sSomething went wrong when deleting a volume snapshot: rebasing a %(protocol)s network disk using qemu-img has not been fully testedtprotocolRs-Fsqemu-imgRís-bN(RRlRRRFRRÑR.t
qemu_img_infotfile_formatRRþRR¶(	R1RÕtactive_disk_objecttrebase_basetactive_protocolRâtbacking_filetqemu_img_extra_argt
b_file_fmt((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_rebase_with_qemu_imgs 		
	c	sétjd|d||ddkrLtd|d}tj|ny|jj|}Wn)tjk
rtjd|j	nXd!d!}|jtj
}	tj}
|
j|	d!x~|
jD]s}|jdkrùqÞn|jd!ksÞ|jd!krqÞn|j|krÞ|j|j}|j}|PqÞqÞWd!ksy|d!kr±|d!kr±td|}tjd	d|tj|ntjd
d|fd}
|dd!kre}|d
}|d!k	r)|d!k	r)|
|j}nytj|d!k	}Wn*tk
rltjtdt}nXtjdi|d6|d6tjj d6t!|d6d||j"|}|j#r9|j$|d|}|dkrýtjdd|nxb|j%dt&r5tjdd|t'j(dqWqåtjdd||j)|||nd!}d!}}ytj*WnXtk
rÜdj+gt,D]}t!|^q}td|}tj-|nX|d!k	r|
|dj}|
|d
j}n|p%|d}|p5|d
}tjdi|d6|d6|d6d||j"|}|j.||dt&}|dkr¬tjdd|nx6|j%dt&rätjd d|t'j(dq¯Wd!S("sNote:
            if file being merged into == active image:
                do a blockRebase (pull) operation
            else:
                do a blockCommit operation
            Files must be adjacent in snap chain.

        :param instance: instance object reference
        :param volume_id: volume UUID
        :param snapshot_id: snapshot UUID (unused currently)
        :param delete_info: {
            'type':              'qcow2',
            'file_to_merge':     'a.img',
            'merge_target_file': 'b.img' or None (if merging file_to_merge into
                                                  active image)
          }
        s'volume_snapshot_delete: delete_info: %sRRRQsUnknown delete_info type %sR5Rs0Disk with id: %s not found attached to instance.sDomain XML: %ssfound device at %sc
sK|dkr*td}tj|ntjdtjd|}d}|}d}jjdd}||krdSxd|dk	rò|jjdd}||krætjd|j|j}|j}Pn|j	}qW|dkr!td|}tj|ntjd	|j|d
|f}	|	S(Nsfilename cannot be NonesXML: %ssactive disk object: %sRYis[0]sfound match: %ssno match found for %ssindex of match (%s) is %ss%s[%s](
RlRRRÑRRRR±tindext
backing_store(
tfilenameRÔRâtfilename_to_mergetmatched_nametbRÓtcurrent_filenametsource_filenametmy_snap_dev(RÌtmy_devR(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt
_get_snap_dev÷s4		
tmerge_target_filet
file_to_mergesMRelative blockrebase support was not detected. Continuing with old behaviour.sBdisk: %(disk)s, base: %(base)s, bw: %(bw)s, relative: %(relative)sRtbwtrelativeis blockRebase started successfullytabort_on_errors&waiting for blockRebase job completiongà?sDGuest is not running so doing a block rebase using "qemu-img rebase"RÀsRelative blockcommit support was not detected. Libvirt '%s' or later is required for online deletion of file/network storage-backed volume snapshots.smwill call blockCommit with commit_disk=%(commit_disk)s commit_base=%(commit_base)s commit_top=%(commit_top)s tcommit_disktcommit_baset
commit_tops blockCommit started successfullys&waiting for blockCommit job completionN(/RRRRRÑRxRR)R=R	RlRRRR¦R§R¨R©RªR«RRþRRÔR^t VIR_DOMAIN_BLOCK_REBASE_RELATIVER²RRRët
libvirt_guesttBlockDevicetREBASE_DEFAULT_BANDWIDTHRGRêt	is_activeRíRîRêRïRðRÒt VIR_DOMAIN_BLOCK_COMMIT_RELATIVERÁt%MIN_LIBVIRT_BLOCKJOB_RELATIVE_VERSIONtInvalidtcommit(RIRRR[Rtdelete_infoRâR1tactive_diskR´RµR¹RÎRÝtrebase_diskRÍRáRøtresulttmy_snap_basetmy_snap_topRãRÂtverRäRå((RÌRÜRsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_volume_snapshot_delete´sÆ
			$	'

	





	
	

	

cCsy |j||||d|WnPtk
rrtj1tjtdd||j||dWdQXnX|j||d|j|||dS(NRïsMError occurred during volume_snapshot_delete, sending error status to Cinder.Rterror_deletingtdeleting(	RöRdR	RCRRRRRÂ(RIRRR[RRï((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytvolume_snapshot_deletes

c	Cs©|dkry|j|}Wn2tjk
rS}tjd|d|t}nX|rwtjtdd|dStjt	dd|n|j
||||S(s6Reboot a virtual machine, given an instance reference.tSOFTsInstance soft reboot failed: %sRs$Instance soft rebooted successfully.Ns3Failed to soft reboot instance. Trying hard reboot.(t_soft_rebootR^R6RRRëR¾RRRt_hard_reboot(	RIRRR
treboot_typeRRtbad_volumes_callbacktsoft_reboot_successR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytreboots

cCs\|jj|}|j|j}|j}|tjkrI|jn|jtj	|dxót
tjj
D]ß}|jj|}|j|j}|j}||krG|tjtjgkr'tjtdd||jd|jtj|j|}|jddjtStjtdd|tSntjdquWtS(	sAttempt to shutdown and restart the instance gracefully.

        We use shutdown and create here so we can return if the guest
        responded and actually rebooted. Note that this method only
        succeeds if the guest responds to acpi. Therefore we return
        success or failure so we can fall back to a hard reboot if
        necessary.

        :returns: True if the reboot succeeded
        tallsInstance shutdown successfully.RRhR1gà?sBInstance may have been rebooted during soft reboot, so return now.i(RxRR:R(RRÙtshutdownt_prepare_pci_devices_for_useRlRmRRR^twait_soft_reboot_secondsR+tCRASHEDRR¾RRjR<RRGt_wait_for_runningRHRIRêRRðRë(RIRR1R'RLRÂR.RP((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRû±s4	
		cs:jjtj}tj|tjtj	j
j|}j|||jd|}|j
dk	r»jj||}j|||nj||||d|dtdtjtjdfd}	tj|	}
|
jddjdS(	s9Reboot a virtual machine, given an instance reference.

        Performs a Libvirt reset (if supported) on the domain.

        If Libvirt reset is unavailable this method actually destroys and
        re-creates the domain to ensure the reboot happens, as the guest
        OS cannot ignore this action.
        RRRtvifs_already_pluggedRcsMjj}|tjkrItjtddtjndS(s4Called at an interval until the VM is running again.sInstance rebooted successfully.RN(	R&R'RRÙRR¾RRR*(R'(RRI(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_wait_for_reboot	s
R1gà?N(RERVRRR
RTR/R
RR^RRØRt
auth_tokenRlt_get_instance_disk_infoRt_create_images_and_backingt_create_domain_and_networkRêRRlRmRRGRHRI(RIRRR
RRtinstance_dirRÁRtbacking_disk_infoRRP((RRIsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRüâs6


				
	cCs|jj|jdS(sPause VM instance.N(RxRRi(RIR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRi#	scCs*|jj|}|j|jdS(sUnpause paused VM instance.N(RxRtresumetsync_guest_time(RIRR1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytunpause'	s
c	Cs®tjtjg}y|jj|}Wntjk
r?tSX|j|j}||kr{t	j
tdd|tSt	jd|d||j
|}xêtjj|D]Ö}|jj|}|j|j}||kr
t	j
td|d|tS|dkrs|}y't	jd||d||j
Wq}tjk
rot	jdd|q´q}Xn
|d8}tjdq´Wt	j
td	|d|tS(
sAttempt to shutdown the instance gracefully.

        :param instance: The instance to be shutdown
        :param timeout: How long to wait in seconds for the instance to
                        shutdown
        :param retry_interval: How often in seconds to signal the instance
                               to shutdown while waiting

        :returns: True if the shutdown succeeded
        sInstance already shutdown.Rs$Shutting down instance from state %ss0Instance shutdown successfully after %d seconds.is:Instance in state %s after %d seconds - resending shutdowns1Ignoring libvirt exception from shutdown request.is*Instance failed to shutdown in %d seconds.(RR+RRxRRR)RêR:RR¾RRRtsixtmovesRR^R6RïRðRë(	RIRttimeouttretry_intervaltSHUTDOWN_STATESR1R'tretry_countdowntsec((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_clean_shutdown-	sL


		


icCs-|r|j|||n|j|dS(s!Power off the specified instance.N(RRE(RIRRR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt	power_offv	scCs|j||||dS(s Power on the specified instance.N(Rü(RIRRR
RR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytpower_on|	scCs¹y|jj|jWntjk
r´}|j}|tjkrYtjn'|tj	krtj
d|jntjt
di|jd6|d6|d6nXdS(sATrigger crash dump by injecting an NMI to the specified instance.R5sbError from libvirt while injecting an NMI to %(instance_uuid)s: [Error Code %(error_code)s] %(ex)sRRRãN(RxRt
inject_nmiR^R6R7tVIR_ERR_NO_SUPPORTRtTriggerCrashDumpNotSupportedR9R=R	RR(RIRRãR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyttrigger_crash_dump	s
cCsL|jj|}|j|tj||j||||jdS(sSuspend the specified instance.N(RxRt_detach_pci_devicesRlRmt_detach_sriov_portstsave_memory_state(RIRRR1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRg	s
	c	
CsÈtjtjj||jd|}|j|||}|j|||||d|dt}|j	|t
j||j||||t
j|j|}|jddj|jdS(sresume the specified instance.RRRR1gà?N(R/R
RR^RRØRRRêRkRlRmRnRRGRRHRIR(	RIRRR
RRRÁRR1RP((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR¡	s 						cCsyV|jj|}|j|j}tjtjtjtjf}||krUdSWntj	k
rlnX|j
||||dS(s)resume guest state when a host is booted.N(RxRR:RRÙt	SUSPENDEDtNOSTATERÚRRÑRü(RIRRR
RRR1R'tignored_states((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytresume_state_on_host_bootµ	scCsttj|}|j||}tjj|d}tj||d}	|jdrg|j	}	ni|	pt
jjp|j
d6t
jjp|jd6t
jjp®|jd6}
tjt
jj||dt}tj|j||d|d|d	d
}|j|||dd	d
d|
d|d||j|||||d|
}
|j||j|
d
|dS(sLoads a VM using rescue images.

        A rescue is normally performed when something goes wrong with the
        primary images and data needs to be corrected/recovered. Rescuing
        should not edit or over-ride the original image, only allow for
        data recovery.

        sunrescue.xmlR(RZR"R(trescuet
admin_passR
tsuffixs.rescuetmappingtdisk_imagestpost_xml_callbackN(RRRRnRRÁt
write_to_fileRlR0R(RR^trescue_image_idRLtrescue_kernel_idR"trescue_ramdisk_idR(R/R
RRêt	functoolstpartialt_create_configdrivet
_create_imageRRERj(RIRRR
RØtrescue_passwordR
tunrescue_xmltunrescue_xml_pathR.t
rescue_imagesRÁt
gen_confdriveR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR'Í	s>


			
csItj}tjj|d}tj|}|jj}|j}|j	|j
||tj|tjj|d}xFtj
|D]5}	tjj|	rÅtj|	qtj|	qWtjg|jD]}
|
jdrì|
^qìtjjdkrEfd}tjj|ndS(sGReboot the VM which is being rescued back into primary images.
        sunrescue.xmls*.rescues.rescueR^cs|jjo|jdS(Ns.rescue(RR	R(R(R(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRm
sN(RRRnRRÁt	load_fileRxRR<RERjtfile_deletetglobtiglobtisdirtshutiltrmtreeR8R¡R RRR^RkRXRR(RIRR
R
R7RR1R\trescue_filestrescue_filetlvmdiskR((RsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytunrescueú	s$	

cCsdS(N((RIRt	instances((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytpoll_rebooting_instances
sc
stjtjj||}tjj|d|d|d|}	j||dd|d|d|d|j	j
||||d|}
j||
||d|d|	tj
ddfd	}tj|}|jd
djdS(NR(tfilesR
R*RRR,sInstance is runningRcsMjj}|tjkrItjtddtjndS(s.Called at an interval until the VM is running.sInstance spawned successfully.RN(	R&R'RRÙRR¾RRR*(R'(RRI(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_wait_for_boot:
s
R1gà?(R/R
RR^RR1R2R3R4t _ensure_console_log_for_instanceRRRRRRGRHRI(
RIRRRØtinjected_filestadmin_passwordR
RRRÁR9RRHRP((RRIsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytspawn
s6			

			cCs/tjdd|ddtdt\}}|S(Ntddsif=%ssiflag=nonblocktrun_as_roottcheck_exit_code(RR¶RêRë(RItptytoutR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_flush_libvirt_consoleF
s	cCsMtjtdi|d6|d6t|d}|j|WdQX|S(Ns data: %(data)r, fpath: %(fpath)rRZtfpathsa+(RR¾Rtopentwrite(RIRZRStfp((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_append_to_fileN
s
c
CsÈ|jj|}|j}tj|}i}|jd}x>|D]6}|jd}	|j|	g||	j|qIW|jdrxý|jdD]é}
|
j	d}|dkrÉq¢n|jd}|säq¢ntjj
|stjtdd|dStj|tjtj|d	N}
tj|
t\}}|d
krtjtd|d|n|SWdQXq¢Wn|jdrûxc|jdD]C}|j	d}|dkrØq±n|jd}|sóq±nPq±Wntj|j|}tjj
|rAtj|tjn|j|}|j||}tj|d	N}
tj|
t\}}|d
krºtjtd|d|n|SWdQXdS(
Ns./devices/consoleRR s./sourceRsVInstance is configured with a file console, but the backing file is not (yet?) presentRRtrbis0Truncated console log returned, %d bytes ignoredRP(RxRRRRRRt
setdefaultRtfindRlRnRR§RR¾RRRRRYRt
last_bytestMAX_CONSOLE_BYTESRtConsoleNotAvailablet_get_console_log_pathRRRW(RIRRR1RRt
console_typest
console_nodestconsole_nodetconsole_typetfile_consoletsource_nodeRRVtlog_datat	remainingtpty_consoleRPtconsole_logRZRS((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_console_outputV
sf
	
cCsUtj}tj|krNtjtditjd6dj|d6ntjS(NsLmy_ip address (%(my_ip)s) was not found on any of the interfaces: %(ifaces)stmy_ips, tifaces(t
compute_utilstget_machine_ipsRRjRRRRÁ(RItips((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_host_ip_addr¢
s
$csCfd}|j}tjj}tjd|d|S(Ncskjj}|j}tj|}|jd}|dk	rU|jdStj	dddS(Ns./devices/graphics[@type='vnc']R!Rbtvnc(
RxRRRRRZRlRRtConsoleTypeUnavailable(RR1Rtxml_domtgraphic(RRI(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_vnc_port_for_instance«
s
R2R!(RRRptvncserver_proxyclient_addresstctypet
ConsoleVNC(RIRRRtR!R2((RRIsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_vnc_consoleª
s
csQfd}|j}tjj}tjd|d|dd|dS(Ncszjj}|j}tj|}|jd}|dk	rd|jd|jdfStj	dddS(Ns!./devices/graphics[@type='spice']R!ttlsPortRbtspice(
RxRRRRRZRlRRRq(RR1RRrRs(RRI(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_spice_ports_for_instance¾
sR2R!iRyi(RRRztserver_proxyclient_addressRvtConsoleSpice(RIRRR{tportsR2((RRIsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_spice_console½
s
cCsa|jj|}x6|j|ddD]\}}tjd|d|SWtjdddS(NRtbindR2R!RbR(RxRR3Rvt
ConsoleSerialRRq(RIRRR1RKR!((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_serial_consoleÐ
s
	c	CsÔttds tjdtStjj|d}t}d}zJywtj	|tj
tjBtjB}d}t
j
d|}|jd|tj||tjdi|d6WnÌtk
r@}|jtjkrtjd	i|d6|d
6t}qtj)tjtdi|d6|d
6WdQXnJtk
r}tj)tjtdi|d6|d
6WdQXnXWd|dk	rªtj|nytj|Wntk
rÎnXX|S(NtO_DIRECTs/This python runtime does not support direct I/Os.directio.testiiÿÿÿÿRÂs#Path '%(path)s' supports direct I/ORs5Path '%(path)s' does not support direct I/O: '%(ex)s'Rãs7Error on '%(path)s' while checking direct I/O: '%(ex)s'(thasattrRnRRRëRRÁRêRlRTtO_CREATtO_WRONLYRtmmapRUtOSErrorRAtEINVALR	RCRFRRdtclosetunlink(tdirpathttestfilethasDirectIOtfdt
align_sizetmR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR×
sD
#			

#
cCsC|s tjd|d|ntj|||d|d|dS(NR6s%dGRNtspecified_fs(Rtcreate_imageRtmkfs(R¹tephemeral_sizetfs_labelR*tis_block_devRR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_create_ephemeralscCs+tjd|d|tjd|dS(s%Create a swap file of specified size.R6s%dMtswapN(RRRR(R¹tswap_mbR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_create_swapscCstjjtj|dS(Nsconsole.log(RnRRÁRR(R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR^scCs?|j|}tjd|d|tj|djdS(Ns&Ensure instance console log exists: %sRta(R^RRRRYR(RIRtconsole_file((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRIsRcCs tjjtj|d|S(Nsdisk.config(RnRRÁRR(RR)((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_disk_config_path5scCstjjdkrdSdS(NR^R6(RR^Rk(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_disk_config_image_type:scCs t|jdpd|kS(sDetermines whether the VM is booting from volume

        Determines whether the disk mapping indicates that the VM
        is booting from a volume.
        RLR(tboolR(Rtdisk_mapping((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_is_booted_from_volumeAscCs5|r1d|ks*d|ks*d|kr1tSntS(s½Determines whether the VM has a local disk

        Determines whether the disk mapping indicates that the VM
        has a local disk (e.g. ephemeral, swap disk and config-drive).
        s
disk.locals	disk.swapsdisk.config(RêRë(RR¡((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_has_local_diskKscCsvd
}|js3tjj}|dkr3d
}q3ntjjdkrNd
}ntjjr{|jdr{t|j	}nd
}tjj
sd
}ntj|dtjj}|jd}	t
|||	||frr|j}
y8tj|j|j|||	||d|ddWqrtk
rn}tj/tjtd	i|
d
6|d6d|Wd
QXqrXnd
S(sÄInjects data in a disk image

        Helper used for injecting data in a disk image file system.

        Keyword arguments:
          injection_image -- An Image object we're injecting into
          instance -- a dict that refers instance specifications
          network_info -- a dict that refers network speficications
          admin_pass -- a string used to set an admin password
          files -- a list of files needs to be injected
        iRÄtkey_datatlibvirt_virt_typeR3Rt	mandatoryRGs2Error injecting data into image %(img_id)s (%(e)s)timg_idR#RN(sfiles(RlR"RR^tinject_partitionRt
inject_keyRRGR¤tinject_passwordR<tget_injected_network_templatetanyRLRtinject_datat	get_modelt_connRdR	RCRRFR(RItinjection_imageRR
R(RGttarget_partitiontkeytnetR3R§R#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_inject_dataYs6				
cs/j|}tjjfdfd}
tjtjtj	t
dd|sijd6jd6j
d6}n|dr9tj|d}|
djd	tjd
|d|d|d|dr9tj|d}|
djd	tjd
|d|d|dq9nj}tjjd
krstjdjdnj|||||	||
|
tjj}tj|}jj}d|krRd}tjjdddjd|j }d||f}|t!j"}|jd	|d
|d|d|d|nxt#t$j%|D]ð\}}t&j'|}|j(d}|rÓj)|rÓt*d|}t+j,d|ntjjdd|djd|j }|dt!j"}d|d|f}|jd	|d
|d|d|d|dd|qhWd|kr+|d}d}t$j-|}t$j.|r£|d}n4|d dkr×t/j0|d!|r×|d }n|dkr+|t!j1}djd	j2d
|dd"|d|d#|q+ndS($Ncsjj||S(N(RR (tfnameR7(RRIR)(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR scs|ddS(NR7R6((Rµ(R (sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR6ssCreating imageRRZR"R(tkernelt
fetch_funcRRÕtramdiskR÷RRys
disk.localRt
ephemeral0R*Rsephemeral_%s_%stsizeRtguest_formats%s format is not supportedtdetailssephemeral%dRs	disk.swapit	swap_sizeRRøsswap_%sR(3R¢RR^RkR
RTRRRR¾RRLR"R(R4tget_cache_fnametcachetfetch_raw_imaget
get_flavorRRRt_create_and_inject_local_rootRtget_fs_type_for_os_typeR*tget_file_extension_for_os_typeRtephemeral_gbR1R2RRRRòt	enumerateR+t block_device_info_get_ephemeralsR/tget_eph_diskRtis_supported_fs_formatRRtInvalidBDMFormattblock_device_info_get_swaptswap_is_usableRtvolume_in_mappingtMiR(RIRRR¡R)R+R
RRRGR(tinject_filestfallback_from_hosttbooted_from_volumeR6Rµt	inst_typetos_type_with_defaulttfile_extensionRÅt
disk_imagetfnRºtidxtephRRâR*RR((R RRIR)sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR4s¦


			


	





cs]tj|o%|	o%tjjdk}|s7tjd}|jjt	j
}
|
dksl|dkrud}
n|jj
|d|tjj|jtjkr¼jtjnjrãfd}|}n	tj}|j||d||
|
|rY|j||||qYn"|rYtjtdd|ndS(	NiþÿÿÿRZis.rescueRcsCyjdWn$tjk
r>tj||nXdS(NRZ(tcloneRRORtfetch_image(targsR/(tbackendRR+(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytclone_fallback_to_fetchss@File injection into a boot from volume instance is not supportedR(R'trequired_byRR^R¨R4R¾Rtroot_gbRRòRlRR RkRRt
RESIZE_FINISHtcreate_snapRR¸tSUPPORTS_CLONERÚt_try_fetch_image_cacheR´RRR(RIRRRÑR)R+R
R(RGRÏRÐtneed_injectt
root_fnameRºRÝR·((RÜRR+sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÂs0				


c

Cs©|j|||_d}tj|r¥tjtdd||jj	|d||j
}|js¥i}|r||d<ntj
|d|d|d|d|}	tjd	|	}
|
|j||}tjtd
i|d6d|y|
j|WnEtjk
rW}tj!tjtd|d|WdQXnXWdQXz|j||d|Wdtjjd
krtj|nXq¥ndS(NsUsing config driveRsdisk.configR(tcontenttextra_mdR
trequest_contexttinstance_mds!Creating config drive at %(path)sRs+Creating config drive failed with error: %sR^(t_build_device_metadatatdevice_metadataRlR'RÞRR¾RRR RR§tinstance_metadatatInstanceMetadatatConfigDriveBuilderRt
make_driveRtProcessExecutionErrorR	RCRFRtimport_fileRR^RkRnR(
RIRRR(RGR
R)tconfig_drive_imageRçtinst_mdtcdbtconfig_drive_local_pathR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR3-sD		



cCsÔtjjdkrdSyrx4|D],}|d}|jj|}|jq Wx4|D],}|d}|jj|}|jqWWWnEtjk
rÏ}tj	d|dd|ddt
j|nXdS(NRÛthypervisor_nameR(RR½(RR^RRxtdevice_lookup_by_nametdettachtresetR6RtPciDevicePrepareFailedRt	text_type(RItpci_devicesRøtlibvirt_dev_addrtlibvirt_devR]((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRas


cCs~y-x&|D]}|j|j|dt|j}tj|}tj}|j|xÅg|j	D]}t
|tjrm|^qmD]}|j|j
|j|jg}	tj|j}
g|	D]}t|d^qÌg|
D]}t|d^qëkrtjddd|qqWq
WWnJtjk
ry}|j}
|
tjkrstjtdqznXdS(NRÔiR½RRøs:Instance disappeared while detaching a PCI device from it.(Rt_get_guest_pci_deviceRêRRRR¦R§R¨R©RÝtLibvirtConfigGuestHostdevPCIRhRÊtslottfunctiont	pci_utilst
parse_addressRRnRtPciDeviceDetachFailedR^R6R7R8RRR(RIR1tpci_devsRøRR´tguest_configtdthdevthdbsftdbsfRÂRãR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR s*

"%	cCspy+x$|D]}|j|j|q
WWn>tjk
rktjtdi|d6|jd6nXdS(Ns0Attaching PCI devices %(dev)s to %(dom)s failed.Røtdom(RÜRÿR^R6RRFRR((RIR1RRø((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRks
cCs,x%|D]}|dtjkrtSqWtS(Nt	vnic_type(t
network_modeltVNIC_TYPE_DIRECTRêRë(R
R:((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_has_sriov_port¨s
cCsÌ|dkr|jj}n|dkr+dS|j|rÈx|D]}|dtjkrA|jj|||j|j	t
jj|j
}tjdi|d6|jd6d||j|qAqAWndS(NR
s)Attaching SR-IOV port %(port)s to %(dom)sR!RR(Rlt
info_cacheR
RRtVNIC_TYPES_SRIOVRRÅRØRRR^RRxRRR(RÜ(RIRRR1R
R:R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRn¯s"
		c
CsÉ|jj}|dkrdS|j|rÅg|D]@}|dtjkr2|djddk	r2|dd^q2}tj|d}g|D]}|j	|kr|^q}	|j
||	ndS(NR
tprofiletpci_slotR(RR
RlRRRRRlRmRR (
RIRRR1R
R:tsriov_pci_addressesRtpci_devt
sriov_devs((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR!Ãs
-
cCs4idt6dt6}|}tj}yªtjj|tj}|j	|krÐ|j	sv|j
r¹|j
jtr¹||_	|rt|nt
|_
|jtjd||qÐtjd||nWn\tjk
rtjtdtjn0tk
r/tjtdtjdtnXdS(	søEnables / Disables the compute service on this host.

           This doesn't override non-automatic disablement with an automatic
           setting; thereby permitting operators to keep otherwise
           healthy hosts out of rotation.
        tdisabledR¼s%Updating compute service status to %ss5Not overriding manual compute service status with: %ssECannot update service status on host "%s" since it is not registered.sICannot update service status on host "%s" due to an unexpected exception.RN(RêRëRRR"tServicetget_by_compute_hostRR2Rtdisabled_reasonRtDISABLE_PREFIXtDISABLE_REASON_UNDEFINEDRqRRRtComputeHostNotFoundRRRd(RIR¼tdisable_reasontstatus_nametdisable_servicetctxR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR¿Ûs0	


		
		

	cCstjj}tjj}tjjdks<tjjdkrj|dkrQd}n|dkrtjSn|dks|dkrdStjjdkrÒtjjdkrÒtdtjj}t	j
|n|dkr|dkrtd}t	j
|n6|dkr>|dk	r>td}t	j
|ntjd	i|d
6|pZdd6tj}||_
||_|S(
NRgRhs
host-modelRbsuConfig requested an explicit CPU model, but the current libvirt hypervisor '%s' does not support selecting CPU modelstcustomsCConfig requested a custom CPU model, but no model name was providedsEA CPU model name should not be set when a host CPU model is requesteds0CPU mode '%(mode)s' model '%(model)s' was chosenRRR!(RR^tcpu_modet	cpu_modelRRlR¦tLibvirtConfigGuestCPURRRíRRRR!(RIRR!RâR¶((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_cpu_model_config

s6	
	
			cCse|j}|dkrdStj||d|}|j|_|j|_|j|_||_|S(Nt
numa_topology(R'RlR-tget_best_cpu_topologytsocketstcorestthreadstnuma(RIRRØtguest_cpu_numa_configtinstance_numa_topologyR¶ttopology((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_cpu_config1
s	c
	CstjjrV|jjdtdtjsVtditd6}t	j
|qVn|jj|||}|dkrÖ|dkrÖ|j
rÖ|jj||d}|j
rÖ|}tjdd	|qÖn||}	|j|	d
|	d|	d|j|d
|jjS(NRÅRs?Volume sets discard option, qemu %(qemu)s or later is required.Rhsdisk.configR^tflatsEConfig drive not found in RBD, falling back to the instance directoryRRÊRøRtextra_specs(RR^thw_disk_discardRxRÏtMIN_QEMU_DISCARD_VERSIONR2RCRRRíRR R§RRtlibvirt_infoR¯tget_version(
RIRRR¡RÒR7RâR t
flat_imageRÁ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_disk_configB
s.		


cCs(|jj|||}|jddS(NRYtploop(RR tlibvirt_fs_info(RIRRR7R ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_fs_configd
s	c CsÐg}|d}	tj|}
tjjdk}|r}tj}d|_tj	j
tj|d|_
|j|n^|tjkrtjjdkr|rî|j|d}
|j|
|j|d}d|_|j|qÛd|	krÛ|j|d}|j|qÛn¼|rr|j|d|	|}|j||j|d|	|}|j|nd|	kr¦|j|d|	|}|j|nd	|	krï|j|d	|	|}|j|tj|j|_nxQttj|D]:\}}|j|tj||	|}|j|qWd
|	kr|j|d
|	|}|j|tj|j|_n|rdnd}||	krÛ|j|||	||j}|j|nxtj|
|D]p}|d
}tj|d}|	|}|j|||j ||}|j|||d
<|j!qîWx|D]}|j"|qiW|j#j$drÌ|j#j%}tj&}d|_'||_(|j|n|S(NR*RÄtmountRRÆsdisk.rescueRs/mnt/rescues
disk.locals	disk.swapsdisk.config.rescuesdisk.configRWRXt
hw_scsi_modeltscsi()R+ReRR^RR¦tLibvirtConfigGuestFilesysR°RnRRÁRRt
source_dirRRtEXER<t
target_dirR9Rtprepend_devR«tdefault_ephemeral_deviceRÆRÇR/RÈtdefault_swap_deviceRtget_bdms_to_connectRÃRÆRqR´R)RR>tLibvirtConfigGuestControllerRR!( RIRRØRÁR'RRRÒR*R©R¡Rttmount_rootfstfstfsrescuetfsost
diskrescuetdiskost	disklocalR×RØtdiskephtdiskswaptconfig_namet
diskconfigRuRWtvol_devR¾RRR>tscsi_controller((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_storage_configj
sª
			!
			
						
		




		cCs|jj}|jjS(sÝGet a UUID from the host hardware

        Get a UUID for the host hardware reported by libvirt.
        This is typically from the SMBIOS data, unless it has
        been overridden in /etc/libvirt/libvirtd.conf
        (RxRµR2R	(RIR¹((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÕ
scCstjjds0td}tj|ntdT}|jj}|sutd}tj|nt	t
j|dSWdQXdS(sfGet a UUID from the host operating system

        Get a UUID for the host operating system. Modern Linux
        distros based on systemd provide a /etc/machine-id
        file containing a UUID. This is also provided inside
        systemd based containers and can be provided by other
        init systems too, since it is just a plain text file.
        s/etc/machine-ids7Unable to get host UUID: /etc/machine-id does not exists1Unable to get host UUID: /etc/machine-id is emptyiN(RnRR§RRRÑRTtreadR±RGR	tUUID(RIRâtftlines((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRß
s	cCs*tjjdr|jS|jSdS(Ns/etc/machine-id(RnRR§RR(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRö
s
cCsatj}tj|_tj|_tj|_|j	|_
|j|_d|_
|S(NsVirtual Machine(R¦tLibvirtConfigGuestSysinfoR&t
vendor_stringtsystem_manufacturertproduct_stringtsystem_producttversion_string_with_packagetsystem_versionRt
system_serialR	tsystem_uuidt
system_family(RIRtsysinfo((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_config_sysinfoü
s	cCs|tj|j}tj}|\|_|_|_|_t	j
jdkrZd|_nt	j
jdkrxd|_n|S(	NRÛRÆR£RgRhtyes(sxens	parallels(skvmsqemu(
RRRR¦RRhRÊRRRR^Rtmanaged(RIt
pci_deviceRRø((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÿ
scCstj}tj|_|j|_tj|_|j	dkr]d|_|j	|_n|dk	r±tj
}|j|_|j|_|j|_|j|_||_ntj}|j}|j|_|j|_|j|_|j|_|j|_|j |_ ||_|S(sGet metadata config for guest.RR N(RN(!R¦t"LibvirtConfigGuestMetaNovaInstanceR&R`tpackagetdisplay_nameRRïtcreationTimeRLRltroottypetrootidtLibvirtConfigGuestMetaNovaOwnertuser_idtuseridt	user_nametusernameR/t	projectidtproject_nametprojectnametownert LibvirtConfigGuestMetaNovaFlavorRt	memory_mbtmemorytvcpusRÅt	ephemeralRßRR(RIRRtmetatometatfmetaR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_config_metas0			cCsCi}x6tjjD](}|jd\}}}|||<qW|S(NRi(RR^thw_machine_typeR(RItmappingsR*t	host_archRtmachine_type((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_machine_type_mappings9s
cCsÐd}|jjddk	r-|jj}n|jjjtjkrNd}n|jjjtjkrod}n|jjjtj	tj
fkrd}ntjjrÌ|j
}|j|jjj}n|S(NRsvexpress-a15tvirtss390-ccw-virtio(RlR)RRR2R¶RtARMV7tAARCH64tS390tS390XRR^R(RIRØR¹t	mach_typeR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_machine_type@s		!	cCség}t|dkr;|dd!}tjtdnx§|D]}yi|}g|jdD]}t|^qd}|d|_|d|_|d|_|j	|WqBt
tfk
ràtjtd|qBXqBW|S(Niis+Too many id maps, only included first five.t:iisInvalid value for id mapping %s(RRRRR±RnRHR¹tcountRt
ValueErrort
IndexError(tklasstmap_stringstidmapst
map_stringtidmaptitvalues((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_create_idmaps[s

	(


cCsg}tjjdkrOtjjrO|jtjtjj}|j|ntjjdkrtjjr|jtj	tjj}|j|n|S(NRÄ(
RR^RRÌRR¦tLibvirtConfigGuestUIDMaptextendRÍtLibvirtConfigGuestGIDMap(RItid_mapsRÌRÍ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_idmapsmsc
	Cs|jj}dddg}tg|D]%}d||jjkr(|^q(}|rr|rrtjn|s|d	krdS|jdkrªt	j
|_nd|j|j_xJ|D]B}d|}	|	|jkrÄt
|j|t|j|	qÄqÄWdS(
Ntsharestperiodtquotas
quota:cpu_RÄRgRhi(slxcskvmsqemu(Rxtis_cpu_control_policy_capableR¬R3tkeysRtUnsupportedHostCPUControlPolicyRDRlR¦tLibvirtConfigGuestCPUTuneR|RtsetattrRn(
RIR1RRtis_ablet	cputuningtkt
wants_cputuneRR²((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_update_guest_cputuneys (

cCs|rtj}xj|jD]_}tj}|j|_|j|_|jtj	|_|rkd|_
n|jj|qW|SdS(Ntshared(R¦tLibvirtConfigGuestCPUNUMAtcellstLibvirtConfigGuestCPUNUMACellR(RCtcpusR{RRót	memAccessR(RIR/twants_hugepagestguest_cpu_numat
instance_cellt
guest_cell((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt"_get_cpu_numa_config_from_instances
cCs\xUtD]M}|jj|r|j|}tjdtdi|d6qqWtS(NR½s#Invalid libvirt version %(version)sR&(tBAD_LIBVIRT_CPU_POLICY_VERSIONSRxthas_versionRÃRtCPUPinningNotSupportedRRê(RIRõtver_((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_has_cpu_policy_support¬s
cCs|dks|dkrtSg|jdjD]}|j^q-}|j|d}x3|jD](}|jdk	r`|j|kr`tSq`WtS(snDetermine if the guest / host topology implies the
           use of huge pages for guest RAM backing
        iiN(RlRëR®tmempagestsize_kbtsorttpagesizeRê(RIt
host_topologytinstance_topologytpagetavail_pagesizetcell((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_wants_hugepages´s#

cCsG|jr(|dk	r(tjn|j}|j||j||}|skt|dddS|r0tj	}tj
}g}	tj}
g|jD]}tj
^q¥}x|jD]}
x	t|jD]ø\}}|j|
jkrÝ||}||_|
jg|_d|_|
jj|
j|j|}x|jD]~}tj}||_|jr¢|jr¢|j|}t|g|_n|
j|_|	j|j|jj|qPWqÝqÝWqÇWtj}t|	|_||_|jjdtj dt!j"|rÇ|j#j$t%sMtj&nt!j'td|jD||\}}tj(}||_)d|_*t+j,j-|_.|j/j|||j_n|
|_0||_1xAtt2|j|j1D]$\}\}}||_||_qõWtd|||St|d|dSdS(sReturns the config objects for the guest NUMA specs.

        Determines the CPUs that the guest can be pinned to if the guest
        specifies a cell topology and the host supports it. Constructs the
        libvirt XML config object representing the NUMA topology selected
        for the guest. Returns a tuple of:

            (cpu_set, guest_cpu_tune, guest_cpu_numa, guest_numa_tune)

        With the following caveats:

            a) If there is no specified guest NUMA topology, then
               all tuple elements except cpu_set shall be None. cpu_set
               will be populated with the chosen CPUs that the guest
               allowed CPUs fit within, which could be the supplied
               allowed_cpus value if the host doesn't support NUMA
               topologies.

            b) If there is a specified guest NUMA topology, then
               cpu_set will be None and guest_cpu_numa will be the
               LibvirtConfigGuestCPUNUMA object representing the guest's
               NUMA topology. If the host supports NUMA, then guest_cpu_tune
               will contain a LibvirtConfigGuestCPUTune object representing
               the optimized chosen cells that match the host capabilities
               with the instance's requested topology. If the host does
               not support NUMA, then guest_cpu_tune and guest_numa_tune
               will be None.
        tstrictR²R(css|]}|jVqdS(N(R((t.0R¶((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pys	<genexpr>EstfifoN(3t_has_numa_supportRlRtNUMATopologyUnsupportedt_get_host_numa_topologyR¶RÅRBR¦R¥tLibvirtConfigGuestNUMATunet LibvirtConfigGuestNUMATuneMemoryR®t!LibvirtConfigGuestNUMATuneMemNodeRÆR(tcellidtnodesetRRR°t LibvirtConfigGuestCPUTuneVCPUPintcpu_pinningR»tsetRCRtvcpupint$LibvirtConfigGuestCPUTuneEmulatorPintemulatorpinR¾toperatort
attrgetterR-tis_realtime_enabledRxRÏtMIN_LIBVIRT_REALTIME_VERSIONtRealtimePolicyNotSupportedtvcpus_realtime_topologyt"LibvirtConfigGuestCPUTuneVCPUSchedR|t	schedulerRR^trealtime_scheduler_prioritytpriorityt	vcpuschedR{tmemnodestzip(RIR/Rtallowed_cpusRØR0R.tguest_cpu_tunetguest_numa_tunetallpcpustnuma_memRt
numa_memnodest	host_cellt
guest_node_idtguest_config_celltnodetobject_numa_cellR¶t
pin_cpusettpcpuRÖtvcpus_rttvcpus_emRáRRÄtmemnode((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_numa_configÊs

		
		
									
		cCsU|dkrtj}n9|dkr0tj}n!|dkrHtj}n	tj}|S(s-Returns the guest OS type based on virt type.RÄR÷RÛ(RRBtUMLtXENtHVM(RIRtret((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_os_typeas	cCs¥|jdrwtjj|d|_|dkrCd||_qwd|tf|_|dkrw|jd7_qwn|jdr¡tjj|d	|_ndS(
NR"s
kernel.rescueRÛs
ro root=%ss
root=%s %sRhs no_timer_checkR(sramdisk.rescue(RRnRRÁt	os_kernelt
os_cmdlinetCONSOLEt	os_initrd(RIR'R1RRtroot_device_name((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_set_guest_for_rescuemscCs±tjj|d|_|dkr4d||_n1d|tf|_|dkre|jd7_n|jrtjj|d|_n|jj	dr|jj
|_ndS(	NR¶RÛs
ro root=%ss
root=%s %sRhs no_timer_checkR¸tos_command_line(RnRRÁRúRûRüR(RýR)RR(RIRR1RRRþRØ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_set_guest_for_inst_kernelzs	cCsstj}|dkr7tjtdd|_n	d|_|j||dkro|j|||ndS(NRws6Configuring timezone for windows instance to localtimet	localtimetutcRg(R¦tLibvirtConfigGuestClockRR¾Rtoffsett	set_clockt_set_kvm_timers(RIR1R*RØRtclk((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt
_set_clocks	
c	Csþtj}d|_d|_tj}d|_d|_|j||j|tj|}|tjtj	fkr«tj}d|_t
|_|j|n|dkrú|jj
ttrútj}d|_t|_|j|ndS(NtpittdelaytrtctcatchupthpetRwthypervclock(R¦tLibvirtConfigGuestTimerRt
tickpolicyt	add_timerRtget_archRR·R¸RëtpresentRxRÏt MIN_LIBVIRT_HYPERV_TIMER_VERSIONtMIN_QEMU_HYPERV_TIMER_VERSIONRê(	RIRR*RØttmpitttmrtct	guestarchttmhpetttmhyperv((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRs*				

					cCs|dkrI|jjjtjtjfkrI|jjtjqIn|d	kss|dkr¢|j	t
jkr¢|jjtj|jjtj
n|d
krý|dkrýtj}t|_t|_d|_t|_|jj|ndS(NRÛRÄR÷RÆRhRgRwiÿ(slxcsumls	parallelssxen(sqemuskvm(R2R¶RR·R¸tfeaturesRR¦tLibvirtConfigGuestFeaturePAER*RR÷tLibvirtConfigGuestFeatureACPItLibvirtConfigGuestFeatureAPICtLibvirtConfigGuestFeatureHyperVRêtrelaxedt	spinlockstspinlock_retriestvapic(RIR1R*R¹Rthv((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt
_set_features¿s!				cCsCtjj}|dkr?|tkr?tjdtd|ndS(NRgRhtallowedR(skvmsqemu(RR^RtALLOWED_QEMU_SERIAL_PORTSRtSerialPortNumberLimitExceeded(RIt	num_portsR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_check_number_of_serial_console×s
	cCs;tj|}tjjrÓtj||}|tjtj	fkrQt
j}nt
j}|j
|xÍtjj|D]R}|}	||	_d|	_tjj|	_tj|	j|	_|j|	qzWnd|tjtj	fkrt
j}
d|
_nt
j}
d|
_|j||
_|j|
dS(NttcptsclplmR (RRRR2R¼R-tget_number_of_serial_portsRRRR¦tLibvirtConfigGuestConsoletLibvirtConfigGuestSerialR+RRRR!Rtproxyclient_addresstlisten_hosttacquire_porttlisten_portt
add_devicettarget_typeR^Rþ(RIR1RRRØt
guest_archR*tconsole_clsR!tconsolet
consolelog((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_create_serial_console_devicesÞs.	
				c	Csxd}tj}tj|}|jtjkr?d|_n`tj	j
dkr]d|_nB|tjtj
tjfkrd|_ntjjrd|_n|jjdrê|jj|_|j|krêtjd|jqên|jjd	d
}t|jjdd
}||krAtjd|d
|n|rg|rg|tjtj|_n|j|dS(NtvgatcirrustvmvgaRÛtqxlRÆthw_video_modelR!thw_video_ramishw_video:ram_max_mbtreq_vramtmax_vram(svgascirrussvmvgasxensqxl(R¦tLibvirtConfigGuestVideoRRR*RRöRRR^RRtPPCtPPC64tPPC64LERzR¼R)RR@RtInvalidVideoModeRnR3tRequestedVRamTooHighRRÎRótvramR5(	RIR1RØRtVALID_VIDEO_DEVICEStvideoRt	video_ramRC((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_add_video_drivers.cCsEtj}d|_d|_dd|jf|_|j|dS(Ntunixsorg.qemu.guest_agent.0s /var/lib/libvirt/qemu/%s.%s.sock(R¦tLibvirtConfigGuestChannelRttarget_nameRRþR5(RIR1Rtqga((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_add_qga_device&s		cCs±tj}|jjdd}|jjdd}|r]t||_t||_ntjj	}|rt
jj|rt
jd|n||_|j|dS(Nshw_rng:rate_bytesishw_rng:rate_periodR(R¦tLibvirtConfigGuestRngR3RRnt
rate_bytestrate_periodRR^trng_dev_pathRnRR§RtRngDeviceNotExistRÜR5(RIR1Rt
rng_deviceRUR trng_path((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_add_rng_device.s	cCs|jjdtr;tjdd||j||n|jjddk}|jjdd}tj|}|r|r|j	||ndS(NRos2Qemu guest agent is enabled through image metadataRthw_rng_modelRÉshw_rng:allowedR(
R)RRëRRRSR3RRrR[(RIR1RRRØt
rng_is_virtiotrng_allowed_strtrng_allowed((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_set_qemu_guest_agent;sc	Cs¸t}|r6x'|jD]}|jrt}PqqWntj|}d}|r|j||}|rtj	}||_
qn|r´|stj	}nt|_t|_n|S(N(
RëR®R¿RêR-RÙRlt%_get_memory_backing_hugepages_supportR¦tLibvirtConfigGuestMemoryBackingt	hugepagestlockedtsharedpages(	RIt
inst_topologyRFRt
wantsmempagesRÄt
wantsrealtimet
membackingtpages((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt _get_guest_memory_backing_configGs(		cCs|jstjn|j}|dkrBtjng|jdjD]}|j^qS}|j|d}g}xt	|jD]\}}	|	j
r|	j
|krxX|jD]J}
||
jkrÀt
j}|g|_|	j
|_|j|PqÀqÀWqqW|S(Ni(t_has_hugepage_supportRtMemoryPagesUnsupportedRËRlR®R¼R½R¾RÆR¿RâRÏR¦t#LibvirtConfigGuestMemoryBackingPageRÐR(RIRfRFRÀRÂRÃtsmallestRjtguest_cellidt	inst_cellRó((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRaas(#


cCs|dk	r|S|jS(N(RlR(RIRORR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_flavorscCsetjtjg}|jj}|jjj|kod|jjtodt	j
jt|jjjS(N(
RR¸RRxRµR2R¶RÏtMIN_LIBVIRT_UEFI_VERSIONRnRR§tDEFAULT_UEFI_LOADER_PATH(RItsupported_archsR¹((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_has_uefi_supports
cCsttjjdks+|jjtr/gSg}|j}x:tjjD],}|j||drN|j	|qNqNW|S(NiR(
RRR^tenabled_perf_eventsRxRÏtMIN_LIBVIRT_PERF_VERSIONt
_get_cpu_infot_supported_perf_eventR(RItsupported_eventst
host_cpu_infotevent((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRËscCsst|j}tt|s9tjtd|tS|tkrot||krotjtd|tSt	S(Ns&Libvirt doesn't support event type %s.s$Host does not support event type %s.(
tLIBVIRT_PERF_EVENT_PREFIXtupperRR^RRRRëtPERF_EVENTS_CPU_FLAG_MAPPINGRê(RIR}tcpu_featurestlibvirt_perf_event_name((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRzsc	CsÝ|dkr3|jtjkrÙtjj|_qÙn¦|dkrj|jjj	t	j
t	jfkr|j||_
tj|_n|jjd}|tjjkr|jrøtsÖtjtdtant|jjj	|_d|_qtjn|j |||_!|jjddkrXt#j$|j%jdd	|_&qÙ|jj'|_&no|d
krd|_(t)|_*nN|dkr¬d
|_+||_,n-|dkrÙ|jtj-krÙd|_(qÙndS(NRÛRgRhthw_firmware_types^uefi support is without some kind of functional testing and therefore considered experimental.tpflashthw_boot_menushw:boot_menuR£RÄs
/sbin/initR÷s/usr/bin/linuxRÆ(skvmsqemu(.R*RR÷RR^txen_hvmloader_patht	os_loaderR2R¶RR·R¸RfReR¦tLibvirtConfigGuestSMBIOSt	os_smbiosR)RR#tFirmwareTypetUEFIRvtuefi_loggedRRRRêRttos_loader_typeRtUEFINotSupportedRtos_mach_typeRlRRrR3tos_bootmenuRtos_init_pathRüRûRútos_rootRB(	RIR1RR¹RRØRRþR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_configure_guest_by_virt_type®s>!			c		Cs`|r"|j|||||n:|jrJ|j||||||ntj||_dS(N(RÿR"RR/tget_boot_ordertos_boot_dev(	RIRR1RþR'RRRØRÁ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_conf_non_lxc_umlÖs
	
cCsz|dkrj|j|||||jjjtjtjfkr[tj}d|_qvtj	}ntj}|S(NRhRgtsclp(sqemuskvm(
R;R2R¶RRRR¦R/R6R0(RIRR1RRRØR¹t
consolepty((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_create_consolesâs!cCsÛ|s
dS|stj}n|j|_|j|_|j|_|j|_|j|_|jrtjd|jd|j	d|j
|_n	d|_g|j
D]$}tjd|jd|j^q¤}||_
|S(sUpdate VirtCPUModel object according to libvirt CPU config.

        :param:cpu_config: vconfig.LibvirtConfigGuestCPU presenting the
                           instance's virtual cpu configuration.
        :param:vcpu_model: VirtCPUModel object. A new object will be created
                           if None.

        :return: Updated VirtCPUModel object, or None if cpu_config is None

        NR*R+R,Rtpolicy(R"tVirtCPUModelRtvendorR!RtmatchR*tVirtCPUTopologyR+R,R0RlRtVirtCPUFeatureRR(RIt
cpu_configt
vcpu_modelRYR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_cpu_config_to_vcpu_modelñs&					1	cCsÙtj}|j|_|j|_|j|_|j|_|j|_|jr|jj|_|jj	|_	|jj
|_
n|jrÕxH|jD]:}tj}|j
|_
|j|_|jj|qWn|S(s§Create libvirt CPU config according to VirtCPUModel object.

        :param:vcpu_model: VirtCPUModel object.

        :return: vconfig.LibvirtConfigGuestCPU.

        (R¦R&RR!RRRR0R*R+R,RtLibvirtConfigGuestCPUFeatureRRtadd(RIR¡R RYtxf((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_vcpu_model_to_cpu_configs"			cCsW|j}tj|}	|d}
tjj}tj}||_|j|_|j	|_	|j
tj|_
|j|_tj}
tj|d}|j|j||
|}|j|_|j|_|j|_|j|j|j||_|jj|j|||j|_x|jD]}|j |q*W|j!||||j"|||j#|j|_$|j%|j$|j&|_&d|
kr¶t'j(|
dd}nd}|rÎ||_*nt+j,|pé|j-||_.|j/j0}|j1||||||||dkrN|j2||||||	||n|j3||j.|||j4||j.|||j5|||||||j.}x|D]}|j6|q«Wx?|D]7}|j7j8||||||j/}|j6|qÉW|j9||||||}|dkrGd|_:|j6|n|j;|j.|}|rr|j6|ntj<j=r»tj<j>r»|dkr»tj?}d
|_@|j6|ntA}tjBj=r"|dkr"tjC}d|_:tjBjD|_DtjBjE|_F|j6|tG}ntj<j=r|dkrtjC}d|_:tj<jD|_Dtj<jH|_F|j6|tG}n|r|jI|||n|dkrÄ|jJ||||n|dkrxWtj|D]}|j6|jK|qàWn'tL|dkr*tMjNd|nd|jOkrUtPjQtRdd|n|jOjSdp||jOjSdp|d}|jTjSd|}|dkrétUjV|rÔtjW}||_X|j6|qétMjYd|n|dkrStjjZdkrStj[}|d kr+d|_\n	d	|_\tjjZ|_]|j6|n|S(!sýGet config data for parameters.

        :param rescue: optional dictionary that should contain the key
            'ramdisk_id' if a ramdisk is needed for the rescue image and
            'kernel_id' if a kernel is needed for the rescue image.
        R*RRyRøRÄR÷RÆRPRÛscom.redhat.spice.0RpRzRhRgiRthw_watchdog_actionsOld property name "hw_watchdog_action" is now deprecated and will be removed in the next release. Use updated property name "hw:watchdog_action" insteadRshw:watchdog_actionRtactionRÉN(slxcsuml(slxcsumlsxen(slxcsuml(slxcsumlsxen(sqemuskvm(sxensqemuskvm(sxensqemuskvm(sqemuskvm(^RRRRR^RR¦R§RR	RzRRóR{R|R-tget_vcpu_pin_setRlRmRôR(RCRDRFRkRiR3RRRRR}tadd_perf_eventR«R1RER¶R¢R¡RRDRlRþRtget_from_instanceRùR*RxRµRRR&R	RVR5RRÅRRt_get_guest_pointer_modelRzR¼t
agent_enabledRPRQRëRptLibvirtConfigGuestGraphicstkeymaptvncserver_listentlistenRêt
server_listenRNR`RÿRRtPciDeviceUnsupportedHypervisorR3RRRRR)R=tis_valid_watchdog_actiontLibvirtConfigGuestWatchdogR¨tInvalidWatchdogActiontmem_stats_period_secondstLibvirtConfigMemoryBalloonR!R (RIRR
RØRÁR'RRRRRR¡RR1RäRtguest_numa_configR}RþR¹tstorage_configsR0R:Rtpointertchanneltadd_video_drivertgraphicsRtwatchdog_actiontbarktballoon((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_guest_config2sô		
	


					
		
		
			cCsÎ|jjdtj}|dkrLtjjrLd}tjt	dn|dkrÊtj
js}tjjrtjj
r|j|Stjstjjrµtjt	dqÊtjddndS(Nthw_pointer_modelt	usbtabletsThe option "use_usb_tablet" has been deprecated for Newton in favor of the more generic "pointer_model". Please update nova.conf to address this change.sUSB tablet requested for guests by host configuration. In order to accept this request VNC should be enabled or SPICE and SPICE agent disabled on host.R!(R)RRt
pointer_modelRlR^tuse_usb_tabletRRRRpR¼RzRt_get_guest_usb_tabletRt UnsupportedPointerModelRequested(RIR*RØRÅ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR¬æs	
	cCswd}|tjkr6tj}d|_d|_n=tjsKtj	j
ratjt
dntjdd|S(NttablettusbsUSB tablet requested for guests by host configuration. In order to accept this request the machine mode should be configured as HVM.R!RÄ(RlRR÷R¦tLibvirtConfigGuestInputRRÊRRÅR^RÆRRRRRÈ(RIR*RÉ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÇ
s			cCs£t|}di|d6|d6|d6|d6|d6}	tjtj|	d||j|||||||}
|
j}tjdi|d	6d||S(
NsStart _get_guest_xml network_info=%(network_info)s disk_info=%(disk_info)s image_meta=%(image_meta)s rescue=%(rescue)s block_device_info=%(block_device_info)sR
RÁRØR'RRRsEnd _get_guest_xml xml=%(xml)sR(RGRRRt
mask_passwordRÂR²(RIRRR
RÁRØR'RRtnetwork_info_strRâR³R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRs			cCs"|jj|}|j|jS(søRetrieve information from libvirt for a specific instance name.

        If a libvirt error is encountered during lookup, we might raise a
        NotFound exception or Error exception depending on how severe the
        libvirt error is.

        (RxRR&(RIRR1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR&9scCstj|}|pi}|jdi}|j||r³tj|}tj|}tj	|t
jj||}|j
|d||ddd}	tj|	}
n'|jj|d}|j|j}
tjj|d}tj|tj|
d|}
yQ|
r*|
|jd<nt
jjsBt
jjra|j}tj||nWn1t k
rt!j"|j#|WdQXnXdS(	NR*RWRZtdevice_pathRRRR($RRRR¢R+ReRtget_root_bdmR/R×RR^RRÃtimgmodeltLocalBlockImageRR R®R¯RnRRÁR
RTRtsetup_containerRRÌRÍRtchown_for_id_mapsRdR	RCt_create_domain_cleanup_lxc(RIRRØRRRÁRR¡RtRºRõtimage_modelR RRR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_create_domain_setup_lxcFs6	
	

cCs£tj|}tjj|d}y|j|j}Wntjk
rVd}nX|t
jkrtj
d|d|tjd|ntjd|dS(NRs.Attempting to unmount container filesystem: %sRR(RRRnRRÁR&R'RR)RlRRÙRRRtclean_lxc_namespaceR(RIRRRR'((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÔns
	
ccsOtjjdkrdVdS|j||||z	dVWd|j|XdS(sPContext manager to handle the pre and post instance boot,
           LXC specific disk operations.

           An image or a volume path will be prepared and setup to be
           used by the container, prior to starting it.
           The disk will be disconnected and unmounted if a container has
           failed to start.
        RÄN(RR^RRÖRÔ(RIRRØRRRÁ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_lxc_disk_handlers
	cCs|r7tjj||j}|dk	rF|qFntj|}|sR|re|jd|ntjs~|jn|S(sÐCreate a domain.

        Either domain or xml must be passed in. If both are passed, then
        the domain definition is overwritten from the xml.

        :returns guest.Guest: Guest just created
        RiN(	RçtGuesttcreateRxRltlaunchRt
is_neutrontenable_hairpin(RIRRhRRiR,R1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRjs	

cCsItjtdi|d6|jd6d|tjrEtjndS(NsANeutron Reported failure on event %(event)s for instance %(uuid)sR}R	R(RRFRR	Rtvif_plugging_is_fatalRtVirtualInterfaceCreateException(RIt
event_nameR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_neutron_failed_callback³s
	cCs9g|D].}|jdttkrd|df^qS(NR snetwork-vif-pluggedR((RRêRë(RIR
R:((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_neutron_events»sc
CsGz#|r"|jr"|jnWd|j||d|d|XdS(NR
RR(RêR5RQ(RIRRR
RRR1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_cleanup_failed_startÄs
cCsÖtj|}x|D]}|d}
|rd|
krd|
dkr|
dd}tj||j||
}|r |j|
|}|j||q qqWtj}|j	rçt
jrç|	rç|rç|rç|j|}ng}t
|}d	}y»|jj||d|d|j|j|||jj|||jj|||j||j||&|j|d|d|d|
}Wd	QX|jj||Wd	QXWntjk
rütj|j|||||Wd	QXnÃtj j!k
rit"j#t$d
i|j%d6d|tj&r¿|j|||||tjq¿nVt'k
r¾t"j(t)d
d|tj|j|||||Wd	QXnX|rÒ|j*n|S(s,Do required network setup and create domain.RWRZR[tdeadlineterror_callbackRiRR,Ns?Timeout waiting for vif plugging callback for instance %(uuid)sR	RsFailed to start libvirt guest(+R+ReR?RgRRhRÛRtvif_plugging_timeoutRRRÜRâR RlR§twait_for_instance_eventRáRRRtprepare_instance_filterRØRØRjtapply_instance_filterRRßR	RCRãteventletRtTimeoutRRRR	RÞRdRFRR(RIRRRR
RÁRRRRRR,RtRuRWR[RwRxRteventsRiR1((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÍst	
					


	



cCsDy|jj}Wn(tjk
r=tjtddSXtjsK|St	j
}d}y|jj}WnFtjk
r¸}|j
}tjtdi|d6|d6nX|r||ks:tdit|d6t|d6f}tj|q:n.t|d	|kr:tjtd
nt|S(szGet available vcpu number of physical computer.

        :returns: the number of cpu core instances can be used.

        sZCannot get the number of cpu, because this function is not implemented for this platform. iscCouldn't retrieve the online CPUs due to a Libvirt error: %(error)s with error code: %(error_code)sRFRsInvalid vcpu_pin_set config, one or more of the specified cpuset is not online. Online cpuset(s): %(online)s, requested cpuset(s): %(req)stonlinetreqiÿÿÿÿs9Invalid vcpu_pin_set config, out of hypervisor cpu range.N(Rxt
get_cpu_countR^R6RRRRtvcpu_pin_setR-R©Rltget_online_cpusR7RtsortedRRíR(RIttotal_pcpust
available_idstonline_pcpusRãRRâ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_vcpu_totals2			cCstjjdkr*tjtjj}n9tjjdkrQtjj}nt	j
tj}x.tj
|D]\}}|tj||<qsW|S(s!Get local storage info of the compute node in GB.

        :returns: A dict containing:
             :total: How big the overall usable filesystem is (in gigabytes)
             :free: How much space is free (in gigabytes)
             :used: How much space is used (in gigabytes)
        R8R^(RR^RkR8tget_volume_group_infoR¦RXRt
get_pool_infoRtget_fs_infoR®Rt	iteritemsRRò(R¾R©tv((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_local_gb_infoEs
cCsÀd}tjjdkr |dSx|jjD]}y5|j}|dk	rj|tt|7}nWn=tj	k
rª}t
jtdi|j
d6|d6nXtjdq0W|S(sGet vcpu usage number of physical computer.

        :returns: The total number of vcpu(s) that are currently being used.

        iRÄisJcouldn't obtain the vcpu count from domain id: %(uuid)s, exception: %(ex)sR	RãN(RR^RRxRtget_vcpus_infoRlRtlistR6RRRR	RRð(RIttotalR1R|R#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_vcpu_used\s	cCs|jj}t}xb|jD]W}xN|jD]C}tj|jtj|tj|j	f}|j
|q2Wq"W|S(s&Get hypervisor instance capabilities

        Returns a list of tuples that describe instances the
        hypervisor is capable of hosting.  Each tuple consists
        of the triplet (arch, hypervisor_type, vm_mode).

        :returns: List of tuples describing instance capabilities
        (RxRµRþtgueststdomtypeRtcanonicalizeRRtostypeR(RIR¹t
instance_capstgtdttinstance_cap((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_instance_capabilitiesus		cCs|jj}t}|jjj|d<|jjj|d<|jjj|d<t}tt	|jj
ddg|d<|jjj|d<|jjj|d<|jjj
|d<||d	<t}x'|jjjD]}|j|jqÛW||d
<|S(sGet cpuinfo information.

        Obtains cpu feature from virConnect.getCapabilities.

        :return: see above description

        RR!RR®iR*R+R,R0R(RxRµtdictR2R¶RR!RRtgetattrR0R*R+R,RÓRR¤R(RIR¹tcpu_infoR0RRY((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRys 			%
	
csèfd}jj|}|jd}tj}|j|d|jj|jj|jj	|jj
f}i|jd6|d6d|jjd6d|jj
d6}|jj|d	<d
||d<|j||||S(sReturns a dict of PCI device.cs
x²|jjD]¤}|jdkr3itjjd6S|jdkr
t|jdkr
d|jdd|jdd|jdd|jddf}itjjd6|d	6Sq
Wj	j
tsùtj
tj|}|rùitjjd6Snitjjd6S(
sIGet a PCI device's device type.

            An assignable PCI device can be a normal PCI device,
            a SR-IOV Physical Function (PF), or a SR-IOV Virtual
            Function (VF). Only normal PCI devices or SR-IOV VFs
            are assignable, while SR-IOV PFs are always owned by
            hypervisor.
            tvirt_functionstdev_typet
phys_functionis%04x:%02x:%02x.%01xiiitparent_addr(tpci_capabilitytfun_capabilityRR#t
PciDeviceTypetSRIOV_PFRtdevice_addrstSRIOV_VFRxRÏt&MIN_LIBVIRT_PF_WITH_NO_VFS_CAP_VERSIONRtis_physical_functiontget_pci_address_fieldstSTANDARD(tcfgdevtpci_addresstfun_captphys_addressR(RI(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_device_typeªs*	
		is%04x:%02x:%02x.%1xtdev_idRs%04xt
product_idt	vendor_idt	numa_nodes"label_%(vendor_id)s_%(product_id)stlabel(RxR÷tXMLDescR¦tLibvirtConfigNodeDevicet	parse_strRRhRÊRRRR!R"R#RN(RItdevnameRtvirtdevtxmlstrRRRÕ((RIsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_pcidev_info§s&'
			
cCsét|dtstjgSy|jjp4g}Wnttjk
r®}|j}|tj	kr¨t
|_tj
tdi|jd6|d6tjgSnXg}x$|D]}|j|j|q¼Wtj|S(sGet host PCI devices information.

        Obtains pci devices information from libvirt, and returns
        as a JSON string.

        Each device information is a dictionary, with mandatory keys
        of 'address', 'vendor_id', 'product_id', 'dev_type', 'dev_id',
        'label' and other optional device specific information.

        Refer to the objects/pci_device.py for more idea of these keys.

        :returns: a JSON string containing a list of the assignable PCI
                  devices information
        t_list_devices_supporteds3URI %(uri)s does not support listDevices: %(error)sRùRF(RRêRtdumpsRxtlist_pci_devicesR^R6R7RRëR,RRRRuRR+(RIt	dev_namesRãRtpci_infoR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_pci_passthrough_devicesês 
	

cCsÿxatD]Y}|jj|rt|dts\tjtd|j|t	|_
ntSqWittj
tjf6ttjtjf6}|jj}t}xS|jD]E\}}|jjj|kr²|jj|ttjr²t	}q²q²W|S(Nt_bad_libvirt_numa_version_warns You are running with libvirt version %s which is known to have broken NUMA support. Consider patching or updating libvirt on this host if you need NUMA support.(tBAD_LIBVIRT_NUMA_VERSIONSRxR¸RRëRRRRÃRêR2tMIN_LIBVIRT_NUMA_VERSIONRR·R¸tMIN_LIBVIRT_NUMA_VERSION_PPCRFRGRµtitemsR2R¶RÏtMIN_QEMU_NUMA_HUGEPAGE_VERSIONRC(RIRõtsupport_matrixR¹tis_supportedtarchsRÇ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÉs$

cCs[tjtjtjtjg}|jj}|jjj|koZ|jj	t
ttjS(N(
RR·R¸RGRFRxRµR2R¶RÏtMIN_LIBVIRT_HUGEPAGE_VERSIONR7RC(RIRuR¹((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRl,sc
Cs|jsdS|jj}|jj}|dksA|jrEdSg}tj}|jj	}|ry||M}n|}d}xg|jD]\}t
d|jD}tt
t
t
d|jD}	||M}g|	D]}
|
|@^qê}	g|	D]}
t|
dkr|
^q}	g}|jrg|jD]B}tjd|jd|jddd	|||j|j^qG}ntjd
|jd|d|jtjd
dddd|	dt
gd|}|j|qWtjd|S(NcSs%|jj|i}|j|dS(Ni(R¦R(RItcell_idt	page_sizeRÄ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_reserved_memory_for_cellHscss|]}|jVqdS(N(R((RÇR¶((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pys	<genexpr>Mscss-|]#}|jr!t|jndVqdS(N((tsiblingsttuple(RÇR¶((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pys	<genexpr>OsiR½RÿtuseditreservedR(RCR{t	cpu_usagetmemory_usageR?tpinned_cpusR¼R®(RÉRxRµR2R0RlR®R-R©RñRÓR°RòR©RRlR¼R"tNUMAPagesTopologyRºRÿR(tNUMACellR{RRóRtNUMATopology(
RIR¹R0R®Rätonline_cpusR>RÄRCR?tsibR¼Rj((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRË6sB
			
+R	cCsûg}xî|D]æ}|d}xÓ|dD]Ç}|d}|jdrT|d}n|d}tjd|d||j||}	|	r(td|d|d	|	d
d|	dd
|	dd|	d}
tjd|
d||j|
q(q(Wq
W|S(sRReturn usage info for volumes attached to vms on
           a given host.
        Rt
instance_bdmsRÎs/dev/iR[s%Trying to get stats for the volume %stvolumetrd_reqitrd_bytesitwr_reqitwr_bytesisGot volume usage stats for the volume=%(volume)s, rd_req=%(rd_req)d, rd_bytes=%(rd_bytes)d, wr_req=%(wr_req)d, wr_bytes=%(wr_bytes)d(RRRtblock_statsR
R(RIRtcompute_host_bdmst	vol_usageRKRRáRàR[t	vol_statststats((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_all_volume_usagems.


	





cCsÂy,|jj|}|j}|j|SWntjk
r}|j}tjt	di|j
d6|d6|d6|d6d|n3tjk
r½tjt	d|j
d|nXdS(	s/Note that this function takes an instance name.sGetting block stats failed, device might have been detached. Instance=%(instance_name)s Disk=%(disk)s Code=%(errcode)s Error=%(e)sRRR"R#RsSCould not find domain in libvirt for instance %s. Cannot get block stats for deviceN(
RxRR<t
blockStatsR^R6R7RR¾RRRR)(RIRtdisk_idR1RhR#R"((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRQs	
	cCsidd6dd6dd6S(Ns	127.0.0.1RtfakeuserRttfakepasswordtpassword((RIRb((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_console_pool_info§s
cCs|jj|dS(N(Rtrefresh_security_group_rules(RItsecurity_group_id((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR]¯scCs|jj|dS(N(Rtrefresh_instance_security_rules(RIR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR_²scCsQ|j}i}|j|d<|j|d<|jj|d<|d|d<|j|d<|jj|d<|d|d	<|jj|d
<|jj|d<|jj	|d<t
j|j|d
<|d}|j
}|tj|}|tj|d<|j|d<|j}|rC|j|d<n
d|d<|S(sRetrieve resource information.

        This method is called when nova-compute launches, and
        as part of a periodic task that records the results in the DB.

        :param nodename: unused in this driver
        :returns: dictionary containing resource info
        tsupported_instancesR|RzRÿtlocal_gbt
vcpus_usedtmemory_mb_usedRAt
local_gb_usedthypervisor_typethypervisor_versionthypervisor_hostnameRtfreetdisk_available_leasttpci_passthrough_devicesR(N(RüR	RöRxtget_memory_mb_totalRtget_memory_mb_usedtget_driver_typeR7tget_hostnameRR-Ryt#_get_disk_over_committed_size_totalRRòR1RËt_to_jsonRl(RItnodenametdisk_info_dictRZtdisk_free_gbtdisk_over_committedtavailable_leastR(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_available_resourceµs.



cCs|jjjrdStj|}tjj|s>dSt	j
d|\}}tjd|d|tj
|i|d6S(sCheck if instance files located on shared storage.

        This runs check on the destination host, and then calls
        back to the source host to check the results.

        :param context: security context
        :param instance: nova.objects.instance.Instance object
        :returns:
         - tempfile: A dict containing the tempfile info on the destination
                     host
         - None:

            1. If the instance path is not existing.
            2. If the image backend is shared block storage type.
        RsfCreating tmpfile %s to verify with other compute node that the instance is on the same shared storage.RRÕN(RRÜR_RlRRRnRR§ttempfiletmkstempRRR(RIRRRRttmp_file((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt#check_instance_shared_storage_localìs	

cCstjj|dS(NRÕ(RnRR§(RIRRZ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt$check_instance_shared_storage_remotescCstj|ddS(NRÕ(R
tdelete_if_exists(RIRRZ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt%check_instance_shared_storage_cleanupscCsÛ|d}|tjtj}|js5|jjrU|d}	|jd|	|n|j|jd||j|}
t	j
}|
|_tjj
|_|dk	r¶||_n|dk	rÎ||_n||_|S(sÑCheck if it is possible to execute live migration.

        This runs checks on the destination host, and then calls
        back to the source host to check the results.

        :param context: security context
        :param instance: nova.db.sqlalchemy.models.Instance
        :param block_migration: if true, prepare for block migration
        :param disk_over_commit: if true, allow disk over commit
        :returns: a LibvirtLiveMigrateData object
        RiRN(RRóRtreserved_host_disk_mbR¡R!t_compare_cpuRlt _create_shared_storage_test_fileR"tLibvirtLiveMigrateDataRÕR^RkR7tblock_migrationtdisk_over_committdisk_available_mb(RIRRtsrc_compute_infotdst_compute_infoRRtdisk_available_gbRtsource_cpu_infoRÕRZ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt"check_can_live_migrate_destinations 

		cCs|j}|j|dS(svDo required cleanup on dest host after check_can_live_migrate calls

        :param context: security context
        N(RÕt!_cleanup_shared_storage_test_file(RIRtdest_check_dataRÕ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt(cleanup_live_migration_destination_check;s	cCst|tjs4tj}|j||}ntj}|j|j	||_
|j||||_|j
|d|}|j||}|j||}	d|krÅ|j|_n|jr2|jrtd}
tjd|
d|nd|kr/|j|||j|j|n|rx|jd}|rÎ|jjtrÎdjgtD]}t|^qj}
td	i|jd
6|
d6}tj |d|tj!d|n|r/|j"t#j$@d
kr/tdi|jd
6}tj |d|tj!d|q/qxnF|jpN|j
pN|oN|	sxtd}
tj%d|
d|nt&j'|dt(}||_)|S(sêCheck if it is possible to execute live migration.

        This checks if the live migration can succeed, based on the
        results from check_can_live_migrate_destination.

        :param context: security context
        :param instance: nova.db.sqlalchemy.models.Instance
        :param dest_check_data: result of check_can_live_migrate_destination
        :param block_device_info: result of _get_instance_block_device_info
        :returns: a LibvirtLiveMigrateData object
        RRRs4Block migration can not be used with shared storage.R½RRRtRÀsCannot block migrate instance %(uuid)s with mapped volumes. Selective block device migration feature requires libvirt version %(libvirt_ver)sR	RÇRisCannot block migrate instance %(uuid)s with mapped volumes. Selective block device migration is not supported with tunnelled block migrations.svLive migration can not be used without shared storage except a booted from volume VM which does not have a local disk.Rá(*RÝtmigrate_data_objtLiveMigrateDataR"Rtfrom_legacy_dictRR2t_check_shared_storage_test_fileRÕtis_shared_instance_patht_is_shared_block_storageR_R|R¢R£tis_on_shared_storageRRRtInvalidLocalStoraget!_assert_dest_node_has_enough_diskRRRRxRÏt)MIN_LIBVIRT_BLOCK_LM_WITH_VOLUMES_VERSIONRÁRGR	RRFtMigrationPreCheckErrorR£R^RåtInvalidSharedStorageRRRêtinstance_relative_path(RIRRRRRtmd_objRtdisk_info_textRÑthas_local_diskR½RáRÂRõRât
instance_path((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytcheck_can_live_migrate_sourceDsf
					

					
		c	Cs|jdr=tjj|jkr=|jjjr=tS|j	r_|jjj
r_tS|jrtt
j|j||rtStS(s(Check if all block storage of an instance can be shared
        between source and destination of a live migration.

        Returns true if the instance is volume backed and has no local disks,
        or if the image backend is the same on source and destination and the
        backend shares block storage between compute nodes.

        :param instance: nova.objects.instance.Instance object
        :param dest_check_data: dict with boolean fields image_type,
                                is_shared_instance_path, and is_volume_backed
        R7(R0RR^RkR7RRÜR_RêRtis_file_in_instance_pathtis_volume_backedR RR{R|Rë(RIRRRR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRs
				cCsêd}|r|tj}n|j|d|}tj|}d}	|rtxJ|D]}
|	t|
d7}	qSWn%x"|D]}
|	t|
d7}	q{W||	dkrætdi|jd6|d6|	d6}tj	d	|nd
S(s:Checks if destination has enough disk for block migration.iRRt	disk_sizetvirt_disk_sizesUnable to migrate %(instance_uuid)s: Disk of instance is too large(available on destination host:%(available)s < need:%(necessary)s)RR%t	necessaryR½N(
RRÎR|RR{RnRR	RR(RIRRtavailable_mbRRRR%Røt
disk_infosR£R¾R½((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÎs$	

	
c
Cs'tjjdkrdS|dkrÛtj|}tjtd|t	j
}|d|_|d|_|d|_
|dd|_|dd	|_|dd
|_x:|dD]}|jt	j|q¸Wn|j|}d}td
}y8|j}	tjd|	d||jj|	}
Wntjk
rÑ}|j}|tjkrtjdi|jd6|d6dStj|i|d6|d6tjd|i|d6|d6nX|
dkr#tj|i|
d6|d6tj d|i|
d6|d6ndS(sCheck the host is compatible with the requested CPU

        :param guest_cpu: nova.objects.VirtCPUModel or None
        :param host_cpu_str: JSON from _get_cpu_info() method

        If the 'guest_cpu' parameter is not None, this will be
        validated for migration compatibility with the host.
        Otherwise the 'host_cpu_str' JSON string will be used for
        validation.

        :returns:
            None. if given cpu info is not compatible to this server,
            raise exception.
        RgNs"Instance launched has CPU info: %sRR!RR0R*R+R,RsEhttp://libvirt.org/html/libvirt-libvirt-host.html#virCPUCompareResults8CPU doesn't have compatibility.

%(ret)s

Refer to %(u)sscpu compare xml: %sRsZURI %(uri)s does not support cpu comparison. It will be proceeded though. Error: %(error)sRùRFRøtuR½i(skvm(!RR^RRlRR{RR¾RR¦tLibvirtConfigCPURR!RR*R+R,tadd_featuretLibvirtConfigCPUFeatureR¦RR²RRxtcompare_cpuR6R7RRuRFRRtInvalidCPUInfo(
RIt	guest_cputhost_cpu_strRR¾R¶RYR¦Rtcpu_xmlRøR#R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR÷sB


		cCsTtj}tjd|\}}tjd|d|tj|tjj	|S(s(Makes tmpfile under CONF.instances_path.Rs]Creating tmpfile %s to notify to other compute nodes that they should mount the same storage.R(
RR®RwRxRRRnRRR(RIRRRRy((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR7s		

cCsitjtjdtjjtj|}tjj|sFt}nt	}t
jd||d||S(ssConfirms existence of the tmpfile under CONF.instances_path.

        Cannot confirm tmpfile return False.
        s_Check if temp file %s exists to indicate shared storage is being used for migration. Exists? %sRN(RntutimeRR®RlRRÁR§RëRêRR(RIRÕRRyR§((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRAs			cCs)tjjtj|}tj|dS(s;Removes existence of the tmpfile under CONF.instances_path.N(RnRRÁRR®tremove(RIRÕRy((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRXscCs³|jj|||jj||tttj}xq|r®|jj||r]Pn|jt	|dkrt
d}tj||j
ntjdq>WdS(s[Ensure that an instance's filtering rules are enabled.

        When migrating an instance, we need the filtering rules to
        be configured on the destination host before starting the
        migration.

        Also, when restarting the compute service, we need to ensure
        that filtering rules exist for all running services.
        is)The firewall filter for %s does not existiN(RRRèRþRRtlive_migration_retry_counttinstance_filter_existsRQRRRRÑRRRð(RIRR
t
timeout_countRâ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt#ensure_filtering_rules_for_instance]s		
cCs|jjdS(N(Rtfilter_defer_apply_on(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRµyscCs|jjdS(N(Rtfilter_defer_apply_off(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR¶|scCsGtj|s$tjd|n|j|||||||dS(s§Spawning live_migration operation for distributing high-load.

        :param context: security context
        :param instance:
            nova.db.sqlalchemy.models.Instance object
            instance object that is migrated.
        :param dest: destination host
        :param post_method:
            post operation method.
            expected nova.compute.manager._post_live_migration.
        :param recover_method:
            recovery method when any exception occurs.
            expected nova.compute.manager._rollback_live_migration.
        :param block_migration: if true, do block migration.
        :param migrate_data: a LibvirtLiveMigrateData object

        RKN(Rtis_valid_hostnameRtInvalidHostnamet_live_migration(RIRRRütpost_methodtrecover_methodRR$((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytlive_migrations
	cCse|jj|}|j}y|jWn5tjk
r`}tjtd|d|nXdS(skAborting a running live-migration.

        :param instance: instance object that is in migration

        sFailed to cancel migration %sRN(	RxRR<tabortJobR^R6RRFR(RIRR1RR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytlive_migration_aborts	
c	Csäd
}tjj|k}tjj|k}tjjr=|sPtjjrq|rqtd}tjd|n|rà|j	d|k}|j	d|k}tjjr´|sÇtjjrà|ràt
jtd	qàndS(Ns0.0.0.0s	127.0.0.1s::s::1s^Your libvirt version does not support the VIR_DOMAIN_XML_MIGRATABLE flag or your destination node does not support retrieving listen addresses.  In order for live migration to work properly, you must configure the graphics (VNC and/or SPICE) listen addresses to be either the catch-all address (0.0.0.0 or ::) or the local address (127.0.0.1 or ::1).R½RpRzs«Your libvirt version does not support the VIR_DOMAIN_XML_MIGRATABLE flag, and the graphics (VNC and/or SPICE) listen addresses on the destination node do not match the addresses on the source node. Since the source node has listen addresses set to either the catch-all address (0.0.0.0 or ::) or the local address (127.0.0.1 or ::1), the live migration will succeed, but the VM will continue to listen on the current addresses.(s0.0.0.0s	127.0.0.1s::s::1(
RRpR°RzR²R¼RRtMigrationErrorRRRR(RItlisten_addrstLOCAL_ADDRSt	local_vnctlocal_spiceRâtdest_local_vnctdest_local_spice((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt*_check_graphics_addresses_can_live_migrate¯s	cCs1tjjr-td}tjd|ndS(NsYour libvirt version does not support the VIR_DOMAIN_XML_MIGRATABLE flag or your destination node does not support retrieving listen addresses.  In order for live migration to work properly you must either disable serial console or upgrade your libvirt version.R½(RR2R¼RRR¿(RIRâ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt"_verify_serial_console_is_disabled×scCsîy|jr|j}n	|j}tj|}	|jj}
|
sM|	rg|j|	|jnd}d|kr¹|j
dk	r¹|j
}|tj@dkr¹|j
|}q¹nd}d}
|jjrþ|	sã|jrþtj|||j}n|jjtrWitjjd6|d6|d6}
|tj@dkrW|
jdqWn|j|j|d|d|d|
d	|dtjjWnBtk
rÖ}tj!tjtd
|d|WdQXnXtjd
d|dS(sInvoke the live migration operation

        :param context: security context
        :param instance:
            nova.db.sqlalchemy.models.Instance object
            instance object that is migrated.
        :param dest: destination host
        :param block_migration: if true, do block migration.
        :param migrate_data: a LibvirtLiveMigrateData object
        :param guest: the guest domain object
        :param device_names: list of device names that are being migrated with
            instance

        This method is intended to be run in a background thread and will
        block that thread until the migration is finished or failed.
        ttarget_connect_addrit	bandwidthtdestination_xmlt
migrate_diskstmigrate_uritflagstparamst
domain_xmlsLive Migration failure: %sRNs'Migration operation thread has finished(RR£R¢Rstgraphics_listen_addrsRxtis_migratable_xml_flagRÆRÇRlRÈR^RåRÿtbdmstget_updated_guest_xmlRÆRÏRRtlive_migration_bandwidthRQtmigrateRþRdR	RCRRFRR(RIRRRüRR$R1tdevice_namesRàRÀtmigratable_flagRÌtnew_xml_strRÎR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_live_migration_operationãsX			

			


*ccstjj}tjj}tjj}|tjjjkrKtjjj}n|tjjjkrrtjjj}n|tjjj	krtjjj	}nt
||}|t|d}||dt|}x;t|dD])}t
||t
|||fVqæWdS(s³Calculate downtime value steps and time between increases.

        :param data_gb: total GB of RAM and disk to transfer

        This looks at the total downtime steps and upper bound
        downtime value and uses an exponential backoff. So initially
        max downtime is increased by small amounts, and as time goes
        by it is increased by ever larger amounts

        For example, with 10 steps, 30 second step delay, 3 GB
        of RAM and 400ms target maximum downtime, the downtime will
        be increased every 90 seconds in the following progression:

        -   0 seconds -> set downtime to  37ms
        -  90 seconds -> set downtime to  38ms
        - 180 seconds -> set downtime to  39ms
        - 270 seconds -> set downtime to  42ms
        - 360 seconds -> set downtime to  46ms
        - 450 seconds -> set downtime to  55ms
        - 540 seconds -> set downtime to  70ms
        - 630 seconds -> set downtime to  98ms
        - 720 seconds -> set downtime to 148ms
        - 810 seconds -> set downtime to 238ms
        - 900 seconds -> set downtime to 400ms

        This allows the guest a good chance to complete migration
        with a small downtime value.
        iN(
RR^tlive_migration_downtimetlive_migration_downtime_stepstlive_migration_downtime_delaytnovaR³tLIVE_MIGRATION_DOWNTIME_MINt!LIVE_MIGRATION_DOWNTIME_STEPS_MINt!LIVE_MIGRATION_DOWNTIME_DELAY_MINRntfloatR(tdata_gbtdowntimetstepsRRRR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_migration_downtime_stepsgsc
Cs7g}g}g}|jtj@dkr´|jjtr´tjj||j	}t
j||}t
j|}	x>|	D]3}
t
|
djddd}|j|qzWnxv|jD]h}|jsÁ|jrßqÁn|jdkrôqÁn|j|kr	qÁn|j|j|j|jqÁW||fS(sbGet list of disks to copy during migration

        :param context: security context
        :param instance: the instance being migrated
        :param guest: the Guest instance being migrated

        Get the list of disks to copy during migration.

        :returns: a list of local source paths and a list of device names to
            copy
        iRXRYiR tblock(sfilesblock(R£R^RåRxRÏRR"tBlockDeviceMappingListtget_by_instance_uuidR	R+tget_block_device_infoReRGtrsplitRt
get_all_diskstreadonlyt	shareableR°R«Rþ(
RIRRR1t
disk_pathsRÖt
block_devicestbdm_listRRtblock_device_mappingsRáRÎRø((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_live_migration_copy_disk_pathss4
						
 c	CsÊ|jjtjtj}|dkr/d}nd}x|D]}yBtj|j}|tj}|dkryd}n||7}Wq<tk
r½}t	j
tdi|d6|d6q<Xq<W||S(sRCalculate total amount of data to be transferred

        :param instance: the nova.objects.Instance being migrated
        :param disk_paths: list of disk paths that are being migrated
        with instance

        Calculates the total amount of data that needs to be
        transferred during the live migration. The actual
        amount copied will be larger than this, due to the
        guest OS continuing to dirty RAM while the migration
        is taking place. So this value represents the minimal
        data size possible.

        :returns: data size to be copied in GB
        iisUnable to stat %(disk)s: %(ex)sRRã(RRzRRÎRòRntstattst_sizeRRRR(	RIRRîtram_gbtdisk_gbRRºtsize_gbR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_live_migration_data_gbÇs	

	cCs|r
|jS|jS(N(R£R¢(RItis_block_migration((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_migration_flagsìsc
Cst}|j||
}t|j|}
|j}d}|j|j}d}tj}|}d}d}|j	|}xpt
rö|j}|jt
jkrþ|	jsÍtjdd|qþtj|||_tjd|jd|n|jt
jkr&tjdd|nÀ|jt
jkrÀtj|||j|||tj}||}|dks|dks||jkr¦|j}|}ntj
j}ttj
j|}tj|||||||jrBy|jWqBt
jk
r>}tj t!d|d||j"|qBXn|rtj#|j$|j||jrtj%|||n|j}tj&||||
|}|ddkr³d	}|j'dkråt(|j)d	|j'}ntj*||||tj}|d
dkr tj+}n|t,di|dd
6|d6|j-d6|j)d6|j'd6d||j|kr³|t,di|jd6|d6||d6d|q³n|d}n&|jt
j.krtj+t,dd|||||||Pná|jt
j/krctj0t1dd|tj2|j3|||||||||Pn|jt
j4krÇtj t!dd|tj2|j3|||||||||ddPntj t!d|jd|tj5dqW|j"|dS(Niiÿÿÿÿs!Operation thread is still runningRs!Fixed incorrect job type to be %dsMigration not running yetsFailed to abort migration %si
idi<s¥Migration running for %(secs)d secs, memory %(remaining)d%% remaining; (bytes processed=%(processed_memory)d, remaining=%(remaining_memory)d, total=%(total_memory)d)itsecsRftprocessed_memorytremaining_memoryttotal_memorysZData remaining %(remaining)d bytes, low watermark %(watermark)d bytes %(last)d seconds agot	watermarktlastis!Migration operation has completedsMigration operation has aborteds!Migration operation was cancelledtmigration_statust	cancelleds!Unexpected migration job type: %dgà?(6RRøRþRåR6RlRúRRït_is_post_copy_enabledRêtget_job_infoRR^tVIR_DOMAIN_JOB_NONEtreadyRRRst
find_job_typetVIR_DOMAIN_JOB_UNBOUNDEDt	run_tasksR¤tdata_remainingRtlive_migration_progress_timeoutRnt!live_migration_completion_timeouttshould_abortR!RëR6RRt_clear_empty_migrationtshould_switch_to_postcopytmemory_iterationttrigger_postcopy_switchtupdate_downtimetmemory_totaltroundtmemory_remainingt
save_statsR¾Rtmemory_processedtVIR_DOMAIN_JOB_COMPLETEDtVIR_DOMAIN_JOB_FAILEDRFRtrun_recover_tasksRxtVIR_DOMAIN_JOB_CANCELLEDRð(RIRRR1RüRºR»RR$tfinish_eventRîton_migration_failureRâtdowntime_stepsR6tcurdowntimeRàtnRHt
progress_timetprogress_watermarktprevious_data_remainingtis_post_copy_enabledR¾tnowtelapsedtprogress_timeouttcompletion_timeoutR#Rftlg((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_live_migration_monitorñsÜ			
	

		

	
			

	




cCsBy|j|j=Wn*tk
r=tjtdd|nXdS(Ns6There are no records in active migrations for instanceR(R¤R	tKeyErrorRRR(RIR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRs

csZ|jj}g}	g}
|jrE|j||\}	}
ntj|j||||||
}tjj	}t
|jj<fd}
|j
|
|tjdzy?tjdd|j|||||||||	
Wn?tk
r=}tjtdi|d6ddtnXWdtjd	dXdS(
s,Do live migration.

        :param context: security context
        :param instance:
            nova.db.sqlalchemy.models.Instance object
            instance object that is migrated.
        :param dest: destination host
        :param post_method:
            post operation method.
            expected nova.compute.manager._post_live_migration.
        :param recover_method:
            recovery method when any exception occurs.
            expected nova.compute.manager._rollback_live_migration.
        :param block_migration: if true, do block migration.
        :param migrate_data: a LibvirtLiveMigrateData object

        This fires off a new thread to run the blocking migration
        operation, and then this thread monitors the progress of
        migration and controls its operation
        cs!tjdd|jdS(Ns'Migration operation thread notificationR(RRtsend(tthreadR}(R(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytthread_finishedÇsis%Starting monitoring of live migrationRs"Error monitoring migration: %(ex)sRãRNs%Live migration monitoring is all done(RxRRRòRRLRÙRêR}tEventRR¤R	tlinkRïRðRRR*RdRRRê(RIRRRüRºR»RR$R1RîRÖtopthreadRR.Rã((RsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR¹s<			
cCs*|jr&|tj@dkr&tSntS(Ni(RìR^RîRêRë(RIRà((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRßscCsHy|j|jjdWn&tk
rCtjd|jnXdS(Nsforce-completeR5(R¤R	RR+RtNoActiveMigrationForInstance(RIR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytlive_migration_force_completeås

	c	Cs~ytj|||Wn`tjk
ry|s6ntjdi|d6|d6tjd|d|d|dtnXdS(NsaImage %(image_id)s doesn't exist anymore on image service, attempting to copy image from %(host)sRZR2tsrcRütreceive(RRÚRt
ImageNotFoundRRt
copy_imageRê(RIRRRZRRÐ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_try_fetch_imageìs	cCs·tj|}|jr³tjj|d}tjj|s^|j|||j||n|jr³tjj|d}tjj|s°|j|||j||q°q³ndS(s?Download kernel and ramdisk for instance in instance directory.R¶R¸N(	RRR"RnRRÁR§R8R((RIRRRÐR
tkernel_pathtramdisk_path((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_fetch_instance_kernel_ramdiskûs		
		c	Cs}z |j||||||Wdt}|r;|j}n|sxtj||}tjj|rxtj	|qxnXdS(s8Clean up destination node after a failed live migration.N(
RTRêRRt get_instance_path_at_destinationRnRR§R?R@(	RIRRR
RRRSR$RR
((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt&rollback_live_migration_at_destinationscCs]|dk	rtj|}ntjd|d||j}|j}|j}	|sùtj	||}
t
jj|
rt
jd|
ntjd|
d|t
j|
|rNi}xG|D]?}t
jj|d}
t
jj|
|
}|d||<qÄWtjd|d|t
jj|
d}tj|tj|n|sÐtjdd||j|||
|d	|jtj|rÐtjd
krÐd|j|
f}|jj||
qÐn|	sù|j||j||qùntj|}t |r*tjdd|nxI|D]A}|d
}t!j"|tj#j$|j%|}|j&||q1Wtjdd|tj'}xt(|D]}y|j)||PWqt*j+k
r||dkrãqtj,t-di|d6|d6d|t.j/dqXqW|s=t0j1dg}n	g|_2tj3j4|_5tj6j7|_8tj9j:|_;tj#j<|_=|j>|_?xÈ|D]À}|d
}|j@drt!j"|tj#j$|j%|}t0jA}|d|_B||_C|d|_D|d|_E|d|_F|j@d|_G|j@d|_H|j2jI|qqW|S(sPreparation live migration.s&migrate_data in pre_live_migration: %sRRsCreating instance directory: %sRs(Creating disk.info with the contents: %ss	disk.infosQChecking to make sure images and backing files are present before live migration.RÐtiso9660s%s:%s/disk.configs)Connecting volumes before live migration.RWs$Plugging VIFs before live migration.is6plug_vifs() failed %(cnt)d. Retry up to %(max_retry)d.tcntt	max_retryRÒRRÊRøRt
boot_indexN(JRlRR{RRR_RRRR<RnRR§RtDestinationDiskExiststmkdirRRÁR-R-RR2R'RÞRtconfig_drive_formatR¡t	copy_fileRIR;R+ReRR/R×R^RRØRÃR±RRRRðRRRRðR"RRÒRpR°tgraphics_listen_addr_vncRzR²tgraphics_listen_addr_spiceR2R1tserial_listen_addrtlive_migration_inbound_addrRÈR}tsupported_perf_eventsRtLibvirtLiveMigrateBDMInfoRRWRÊRøRRRAR(RIRRRRR
RÁR$R_RRùR
timage_disk_infoR¾Rft
image_pathtimage_disk_info_pathR4RtRáRWR@R?Rutbdmi((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytpre_live_migration)s²			

	
		


	

	

	

	


c	
sy,|jd|d|d|d|d|Wnitjk
rsKntjdi|d6d6d|fd	}	|jd|	d|nXdS(
NR·RRÕRZRºsaImage %(image_id)s doesn't exist anymore on image service, attempting to copy image from %(host)sR2Rc	s&tjd|d|ddtdS(NR4RüR2R5(RR7Rê(R¹(RÐ(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytcopy_from_hostËs(R¿RR6RR(
RIR R·RRÕRZRRºRÐRQ((RÐsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRã¹s	c
Csº|sg}nx|D]}tjj|d}tjj||}|drtjj|rtj|d||dq|drtjj|d}	|jj||t	j
j}
|	jdr|
j
d|jd|	d|jd	|	d
|dd|dtjq|	jdrm|j}|j}|
j
d|jd	d
|d
|tjd|q|j|
tj||	|j||d|qqW|j||d|dS(sY:param context: security context
           :param instance:
               nova.db.sqlalchemy.models.Instance object
               instance object that is migrated.
           :param instance_dir:
               instance path to use, calculated externally to handle block
               migrating an instance with an old style instance path
           :param disk_info:
               disk info specified in _get_instance_disk_info (list of dicts)
           :param fallback_from_host:
               host where we can retrieve images if the glance images are
               not available.

        RRÏRR¢R}R·RR*RÕRºRRsswap_%sRRÐN(RnRRRÁR§RRRR RR^RkRR¿RR*RRòRÁRRRÎRãRÚRLR;(
RIRRR
RÁRÐR¾Rt
instance_diskt
cache_nameR RÒR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÓsJ	

			
	

	c
Cs½tj|}|j|}|j}x|D]}|dd}	|j||	|}
d|ddkr|ddd}||
dd<n|djdd}|j|
|q.WdS(NRWRtmultipath_idRZRXRYi(R+ReR²Rtinitialize_connectionRfRj(
RIRRRRR$RtRt
volume_apiRuR[RWRTRv((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytpost_live_migrations		
		cCs|j||dS(sÄUnplug VIFs from networks at source.

        :param context: security context
        :param instance: instance object reference
        :param network_info: instance network information
        N(R(RIRRR
((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytpost_live_migration_at_source8scCs2|jj|}|j}|jj|dS(skPost operation of live migration at destination host.

        :param context: security context
        :param instance:
            nova.db.sqlalchemy.models.Instance object
            instance object that is migrated.
        :param network_info: instance network information
        :param block_migration: if true, post operation of block_migration.
        N(RxRRRô(RIRRR
RRRR1R((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt"post_live_migration_at_destinationAsc	Cs9tj|}t}x2|D]*}|djdd}|j|qWg}tj|}	d}
tjj	dkr¡|	j
djtj
kr¡d}nd}|
|	|\}}
}}xpt|
D]b\}}||jd	}|jd
p	|jd}|dkr,||jd}n||jd}|sYtjd
|qÏn|dkr{tjd|qÏn||kr«tjdi|d6|d6qÏn|d
krS||jd	dkr8d}xwtj|D]K\}}}x9|D]1}tjj||}|tjj|7}qüWqæWqttjj|}nE|dkrw|rwtj|}n!tjdi|d6|d6qÏ||jd	}|dkrètj|}tj|}t||}nd}|}d}|ji|d	6|d6|d6|d6|d6|d6qÏW|S(sGet the non-volume disk information from the domain xml

        :param str instance_name: the name of the instance (domain)
        :param str xml: the libvirt domain xml for the instance
        :param dict block_device_info: block device info for BDMs
        :returns disk_info: list of dicts with keys:

          * 'type': the disk type (str)
          * 'path': the disk path (str)
          * 'virt_disk_size': the virtual disk size (int)
          * 'backing_file': backing file of a disk image (str)
          * 'disk_size': physical disk size (int)
          * 'over_committed_disk_size': virt_disk_size - disk_size or 0
        RXRYicSsD|jd||jd||jd||jd|fS(Ns
.//devices/%ss.//devices/%s/sources.//devices/%s/drivers.//devices/%s/target(R(tdocRÐ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt
find_nodespsRÆsos/typet
filesystemRRR RøRs/skipping disk for %s as it does not have a pathRæs,skipping disk because it looks like a volumes5skipping disk %(path)s (%(target)s) as it is a volumeRR¹R:isCskipping disk %(path)s (%(target)s) - unable to determine if volumeRQRR¢RÏR¡tover_committed_disk_size(sfilesblock(sqcow2sploop( R+ReRÓRfR¤RRRR^RRZttextRRBRÆRtattribRRRntwalkRRÁtgetsizeRnR8tget_volume_sizeRRRRR(RIRRRRRttvolume_devicesRuRvRÁRZR[t	node_typet
disk_nodest
path_nodestdriver_nodesttarget_nodesR?t	path_nodeRkRR¹tdk_sizeRtdirnamest	filenamesRYRVRÏt	virt_sizetover_commit_size((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR
Usv		
				
!	cCs¯y"|jj|}|j}Wnktjk
r}|j}tjtdi|j	d6|d6|d6d|t
jd|jnXt
j|j|j	||S(NseError from libvirt while getting description of %(instance_name)s: [Error Code %(error_code)s] %(ex)sRRRãRR5(RxRRR^R6R7RRRRRR)R	RR-R
(RIRRRR1RRãR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyR|»s

cCsd}|jj}|s|Sg|D]}|j^q&}tj}i|d6}tjj||dt}d|D}tj	j
||}	xê|D]â}y¸tj|}
|
j
}d}|
j|kr|	r|
j|	krtj||
j|	|
j}n|j|
j|d|}
|
s6wnx"|
D]}|t|d7}q=WWntjk
r®}|j}tjtdi|
jd6|d	6|d
6nÅtk
r6}|jtjtjfkrûtjtdi|
jd6qs|jtjkr0tjtd
i|
jd6qsn=t j!k
rr}tjtdi|
jd6|d6nXt"j#dqW|S(s8Return total over committed disk size for all instances.iR	t	use_slavecSsi|]}||jqS((R	(RÇtinst((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pys
<dictcomp>çs	RRR]seError from libvirt while getting description of %(instance_name)s: [Error Code %(error_code)s] %(ex)sRRRãsPeriodic task is updating the host stat, it is trying to get disk %(i_name)s, but disk file was removed by concurrent operations such as resize.ti_names½Periodic task is updating the host stat, it is trying to get disk %(i_name)s, but access is denied. It is most likely due to a VM that exists on the compute node but is not managed by Nova.sÁPeriodic task is updating the host stats, it is trying to get disk info for %(i_name)s, but the backing volume block device was removed by concurrent operations such as resize. Error: %(error)sRFN($Rxtlist_instance_domainst
UUIDStringRRR"tInstanceListtget_by_filtersRêRçtbdms_by_instance_uuidRçRÙRRlR	R+RéR
RRnR^R6R7RRRRRAtENOENTtESTALEtEACCESRtVolumeBDMPathNotFoundRRð(RItdisk_over_committed_sizetinstance_domainsRtinstance_uuidsR"tfilterstlocal_instance_listtlocal_instancesRÒR1RRRR¥R¾RãRR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRoÏsb
			
	
	

cCs|jj|d|dS(s/See comments of same method in firewall_driver.R
N(RRb(RIRR
((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRb%scCs|jjgS(N(RxRn(RItrefresh((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_available_nodes*scCs
|jjS(s)Return the current CPU state of the host.(Rxt
get_cpu_stats(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_host_cpu_stats-scCstjddd\}}|S(s'Returns the result of calling "uptime".tenvsLANG=Ctuptime(RR¶(RIRQR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_host_uptime1scCs|jj||dS(s!Manage the local cache of images.N(RRN(RIRt
all_instances((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytmanage_image_cache6scCssy[tjj|rZtjdd|tjd|||sZ|jj||qZnWntk
rnnXdS(s?Used only for cleanup in case migrate_disk_and_power_off fails.R´s-rftmvN(RnRR§RR¶R¡t
remove_dirRd(RIRüt	inst_basetinst_base_resizetshared_storage((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_cleanup_remote_migration:s
cCsÃtjjdkrtS||jk}|s¿tjjd}tj	j
||}yR|jj||tj	j
|rt}tj|n|jj||Wq¿tk
r»q¿Xn|S(NR^s.tmp(RR^RkRêRoR	RARBRnRRÁR¡tcreate_fileR§Rtremove_fileRd(RIRüRRRyttmp_path((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_is_storage_shared_withFs
c	#sÂtjddtj|}	tj|	p:jj}
|jjjk}|j|
k}j	d|}
j
|
}|r|s|rÅtd}tj
tjd|ntj|
}tjjdkr|rtd}tj
tjd|ntj}|d}j||}|s¦yjj||Wq¦tjk
r¢}td	|}tj
tjd|q¦Xnj||tj|}x?|D]7}|d
}|djdd
}j||qÏWywt j!d|||rBd}t j!dd|nfd}fd}j#}xª|D]¢}|d}t$j%j&|}t$j%j'||}|dkoÝ|j(dd|j(ddksy|dt)k} tj*||d|d|d|d| qyqyWt$j%j'|d}!t$j%j+|!rt$j%j'|d}"tj*|!|"d|d|d|nWn:t,k
r½t-j.j/||||WdQXnX|
S(Ns#Starting migrate_disk_and_power_offRRRsUnable to resize disk down.R½R8s3Migration is not supported for LVM backed instancesR³s#not able to execute ssh command: %sRWRXRYiRRCs-pcsjj|jS(N(Rtadd_jobtpid(tprocess(RRI(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRm¨scsjj|jS(N(Rt
remove_jobR(R(RRI(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRmªsRs	disk.swapRiRR2t
on_executet
on_completiontcompressions	disk.info(0RRR+RÇRtget_bdm_ephemeral_disk_sizeRRÅRßR|R¢RRtInstanceFaultRollbacktResizeErrorRR{RR^RkRRRRR¡t
create_dirRRðRReRfRjRR¶RlRÁRnRRRÁRtNO_COMPRESSION_TYPESR7R§RdR	RCR(#RIRRRüRR
RRRRt
ephemeralsteph_sizet	root_downtephemeral_downRRÑR½RÁRRRR#RtRuRWRvRRt
active_flavorR¾timg_pathRµt	from_pathRtsrc_disk_info_pathtdst_disk_info_path((RRIsM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytmigrate_disk_and_power_off_s		
	


$	

cCsM|j|j}|tjkrItjtdd|tjndS(NsInstance running successfully.R(	R&R'RRÙRR¾RRR*(RIRR'((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÖscCsG|dkr|jj}n!|dkr6|jj}nd}|tjS(sKDetermines the disk size from instance properties

        Returns the disk size by using the disk name to determine whether it
        is a root or an ephemeral disk, then by checking properties of the
        instance returns the size converted to bytes.

        Returns 0 if the disk name not match (disk, disk.local).
        Rs
disk.locali(RRßRÅRRò(Rt	disk_nameRº((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_disk_size_from_instanceÝs
c	CsC|d}tjdddddd||tjd||d	S(
sConverts a raw disk to qcow2.t_qcowsqemu-imgtconverts-fR6s-ORQRN(RR¶(Rt	path_qcow((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_disk_raw_to_qcow2òs
c	CsC|d}tjdddddd||tjd||d	S(
sConverts a qcow2 disk to raw.t_rawsqemu-imgRs-fRQs-OR6RN(RR¶(Rtpath_raw((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_disk_qcow2_to_rawús
cCsÌt|tjs#tjddSt}|r|jtjkrtj	|j
|rtj|r|j|j
t
}tj|j
tj}n|r¯tj||n|rÈ|j|j
ndS(sAttempts to resize a disk to size

        :param image: an instance of nova.virt.image.model.Image

        Attempts to resize a disk by checking the capabilities and
        preparing the format, then calling disk.api.extend.

        Note: Currently only support disk extend.
        s"Skipping resize of non-local imageN(RÝRÐtLocalFileImageRRRëRtFORMAT_QCOW2Rtcan_resize_imageRtis_image_extendableR²Rêt
FORMAT_RAWRR¯(RIR Rºt	converted((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_disk_resizes 
c
Csítjdd|tjtjj|||}
|j|||
dd|dddt	d|j
|j|tj
|j||d|}tj|}x¤|D]}|d}
tjj|
}|j||}|rtj|
|d	}|j||n|d
kr¤|d	dkr¤tjr¤|j|dq¤q¤W|j||||
|d|}|j|||||
d|d|	d
td|}|	rÖtj|j|}|j ddj!|j"ntjdd|dS(NsStarting finish_migrationRR*R
RRRÏRÐRRsdisk.configR6RRR,R1gà?s'finish_migration finished successfully.(#RRR/R
RR^RR4RlRëtsource_computeRIR1R2R3RR{RnRRR«RÐR³R¹RR¯RRRêRRGRRHRIR(RIRR6RRÁR
RØtresize_instanceRRRtblock_disk_infoR9R¾RRªRºR RR1RP((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytfinish_migration%sR	

		
%				
cCsCytj|Wn+tk
r>}|jtjkr?q?nXdS(sbMake sure that a failed migrate doesn't prevent us from rolling
        back in a revert.
        N(R?R@RRARw(RIRR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_cleanup_failed_migrations
cCs¢tjdd|tj|}|d}tjj|ra|j|tj	d||n|j
j|d}|jrçzHy|jtj
Wn-tjk
rÈtjtdtj
nXWd|jtj
dtXntjtjj||j|}	|j||||	|jd|}
|j||
|||	d|d	|d
t|rtj|j|}|jddj ntjd
d|dS(Ns Starting finish_revert_migrationRR³RRs Failed to rollback snapshot (%s)RRRRRR1gà?s.finish_revert_migration finished successfully.(!RRRRRnRR§R¾RR¶RR trollback_to_snapR¸RtSnapshotNotFoundRRR·RêR/R
RR^RRØRRRRGRRHRI(RIRRR
RRRRRRºRÁRRP((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytfinish_revert_migrationsH


				cCs|j||dS(s,Confirms a resize, destroying the source VM.N(R»(RIR6RR
((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytconfirm_migrationÑsc	CsÕigd6gd6}ytj|}Wntk
r;|SXddg}x|D]~\}}|j|}x`|D]X}xO|jD]A}|jdkr|jdr||j|jdqqWqqWqOW|S(	s1get the list of io devices from the xml document.tvolumesRks./devices/disks./devices/interfaceR¹Rø(s./devices/disksvolumes(s./devices/interfacesifaces(RRRdRtgetchildrenttagRR(	R´RòRZtblocksRæR²tsectionRítchild((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_io_devicesÕs
	
)c
Cs^|jj|}|j}i}y9x2|jD]$}|j|dt|jd<q1WWntjk
rpnX|j	}t
j|}x|dD]}ym|j|}	|	d||d<|	d||d<|	d||d	<|	d
||d<|	d||d
<Wqtjk
r qXqWxÌ|dD]À}
y£|j
|
}	|	d||
d<|	d||
d<|	d||
d<|	d
||
d<|	d||
d<|	d||
d<|	d||
d<|	d||
d<Wq0tjk
rïq0Xq0W|j|d<y9|j}x&|jD]}|||d|<q WWntjtfk
rYnX|S(NR¶t_timeRÃit	_read_reqit_readit
_write_reqit_writeit_errorsRkt_rxt_rx_packetst
_rx_errorst_rx_dropt_txit_tx_packetsit
_tx_errorsit_tx_dropR{smemory-(RxRR<RýRïRGR(R^R6RRXRÉRWtinterfaceStatst	maxMemorytmemoryStatsR£R²(
RIRR1RhtoutputtvcpuRtdom_ioR¹RURtmemR²((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_diagnosticsçsR	&cCs|jj|}|j}|j}tj|}|j|j\}}}}	}
tj|}t	j
|j}t	j|t	j
}
tjdtj|ddd|ddd|
}|tj|j_|tj|j_y.x'|jD]}|jd|jq÷WWntjk
r+nXtj|}xn|d	D]b}yE|j|}|jd
|dd|d
d|dd|dWqFtjk
r§qFXqFWx|dD]}ym|j |}|j!d|d
d|dd|dd|dd|dd|dd|dd|dWq·tjk
r@q·Xq·W|j"r|j#d}x6t$|D]%\}}|j%d |j"|_&qjWn|S(!NR'R+R^tconfig_drivet
hypervisor_ostlinuxRRïRÃt
read_bytesit
read_requestsitwrite_bytesitwrite_requestsiRkt	rx_octetst	rx_errorstrx_dropt
rx_packetst	tx_octetsit	tx_errorsittx_dropit
tx_packetsis./devices/interface/macR('RxRR<RRRt_get_domain_infoR'RÞR
tnormalize_timetlaunched_att
delta_secondstutcnowR(tDiagnosticsRt	STATE_MAPRRÎtmemory_detailstmaximumRARýtadd_cpuRïR^R6RXRÉRWR°RØtadd_nictnic_detailsRRÆRtmac_address(RIRR1RhRR´R'tmax_memRÞtnum_cputcpu_timeRàRñRtdiagsRÜRÝR¹RURtnodesRÓRí((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_instance_diagnostics#sb	!		







	 cCsßd}|jr|jjnd}t|jtjrHtj}not|tjr·|j	dkrxtj
}q·|j	dkrtj}q·|j	dkr·tj}q·n|dk	rÛ|dk	rÛ||_
n|S(sFDetermins the device bus and it's hypervisor assigned address
        R?tideRÊN(Rltdevice_addrtformat_addressRÝR¦t"LibvirtConfigGuestDeviceAddressPCIR"tPCIDeviceBustLibvirtConfigGuestDiskRÌt
SCSIDeviceBustIDEDeviceBustUSBDeviceBusR(RøRÊR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_prepare_device_busms	csÚdtjj||j}d|D}tjj||j}fd|D}g}|jj|}|j}	tj	|	}
t
j}|j|
x|j
D]}t|t
jr=|j|j}
|
sëqµn|j|}tjd|
jd|
jg}|r-||_n|j|nt|t
jrµ|j|j}|smqµn|j|}tjd|jg}|r¦||_n|j|qµqµW|rÖtjd|}|SdS(sBuilds a metadata object for instance devices, that maps the user
           provided tag to the hypervisor assigned device address.
        cSstj|jS(N(Rt	strip_devRÎ(Rá((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt_get_device_namescSs%i|]}|jr||jqS((RÅR(RÇR:((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pys
<dictcomp>s	cs(i|]}|jr||qS((RÅ(RÇRá(R
(sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pys
<dictcomp>s	RttagsR©N(R"tVirtualInterfaceListRèR	RçRxRRRRR¦R§R¨R©RÝtLibvirtConfigGuestInterfaceRtmac_addrRtNetworkInterfaceMetadataRRÅRÊRRR«tDiskMetadatatInstanceDeviceMetadata(RIRRtvifsttagged_vifsRÒttagged_bdmsR©R1RRrRRøR:RÊRÕRátdev_meta((R
sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRêsJ		
		cCsYtj|}tjd|d|tj|tj}|jjj	}|pX|S(Ns(Checking instance files accessibility %sR(
RRRRRntaccesstW_OKRRÜR_(RIRRtshared_instance_pathtshared_block_storage((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytinstance_on_disk·scCs|jj||dS(N(RR(RIRtnw_info((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytinject_network_infoÄsc	CsÈtj|}|d}|d}xrtjjdD]^}ytjd||PWntk
rgnXytjd||PWq6tk
rq6Xq6Wd}x0||fD]"}t	j
j|r«|}Pq«q«W|rpt	j
j|rp|jj
|tjtd|d||}ytj|Wqptk
rl}tjtdi|d6|d	6d|qpXn|r¨t	j
j|r¨tjtd
|d|tStjtd|d|tS(NR³t_deliRsDeleting instance files %sRs-Failed to cleanup directory %(target)s: %(e)sR¹R#sDeletion of %s failedsDeletion of %s complete(RRRRRRR¶RdRlRnRR§Rtterminate_jobsRR¾RR?R@RRFRRëRê(	RIRR¹t
target_resizet
target_delRtremaining_pathtpR#((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRoÇsH
	


cCstS(N(Rë(RI((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytneed_legacy_block_device_infoscCsqtj|tjj|d}tj|tjj|d}tj|tjj||||}tj|dS(NRtcdromRø(R/tget_disk_bus_for_device_typeRR^Rt
get_root_infoRRD(RIRRØtroot_bdmRÏt	cdrom_bust	root_info((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytdefault_root_device_namescGs¥ttj|}xO|D]G}|jdk	rtjtdi|jd6d|d|_qqWtj	||}t
jtj
jtj|||jdS(Ns\Ignoring supplied device name: %(device_name)s. Libvirt can't honour user-supplied dev namesRÎR(Rþt	itertoolstchainRÎRlRRRR+RéR/tdefault_device_namesRR^RRRRØ(RIRRþtblock_device_listsRtRáRR((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt!default_device_names_for_instances
				cCs¶tj||}tjtjj||jd|}|j}|dk	rqt
jtdi|d6d|nd|_tj
|tjj|j|d|d}tj|dS(NRRs0Ignoring supplied device name: %(suggested_dev)st
suggested_devRR*Rø(R+RéR/R
RR^RRØRÎRlRRRR×RRD(RIRRÒtblock_device_objRRt
instance_infotsuggested_dev_nameRÁ((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pytget_device_name_for_instance%s			cCs"|tjtjtjtjgkS(N(RtFS_FORMAT_EXT2tFS_FORMAT_EXT3tFS_FORMAT_EXT4t
FS_FORMAT_XFS(RItfs_type((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRÉ9sN(
t__name__t
__module__RêRëtcapabilitiesRqRtpropertyR¯R´R»RwRÃRÚRãRæRìRïRôRÊRöR¯tstaticmethodRuRþRÿRRRRRRR RERlRTRVRQRR3RRmRlR R²R»R¿RÃRjRÆRhRÍRÛRùR	RRiRRR4R#RHRMRuR}RRRRRWRRÀRÂRÈRÒRöRùRRûRüRiRRRRRRgRR&R'RDRFRLRRRWRiRoRxRRRRRR^RIRRR¢R£R´R4RÂR3RR RkRRnR!RR¿R'R1R9R<RVRRRRfRÿRRRRRR«R¶R»RÅRôRùRÿRR	RR&R+R;RNRSR[R`RkRaRrRvRËRzRRRR¢R¦RÂR¬RÇRR&RÖRÔt
contextlibtcontextmanagerRØRjRáRâRãRRöRüRR	RyR+R1RÉRlRËRVRQR\R]R_RvRzR{R}RRRRRRRRRR´RµR¶R¼R¾RÆRÇRÙRåRòRøRúR*RR¹RR3R8R;R=RPRãRRWRXRYR
R|RoRbRRRRRRR©RR«R¯R²R¹R½R¾RÁRÂRÉRßRRRêRRRoR&R-R2R7RÉ(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyRXBs6
J						K																
	c														6	(	 ,		)		¨											A		n			9.Ô		2@			I				-		)			L				/	
	9l	+3	 		
	.	'	!	k	
					!									
			#			&	"		
			#			
		(			&	²	$		
	(					
K	)				C	'		
	7	#					7	 		&	h"'	@	
							(		3	-	%		¦		A			E	f	V					t		%f	9		<	J	5	
		;	
		(iii(iii(iii(iii(iii(iii(iii(iii(iii(iii	i(iii(iii
(iii(iii(iii	(iii(iii(iii(iii(iii
(iii(iii(iii(iii(iii(iii(sqcow2(iii
(iii(iii(iii(½t__doc__tcollectionsRRBRAR1R<R.RR×RnR?RwRïR	RêRRtlxmlRtos_brick.initiatorRtoslo_concurrencyRtoslo_logRtloggingtoslo_serializationRtoslo_serviceRt
oslo_utilsR	R
RRR
RRt	six.movesRtnova.api.metadataRRìRÝRtnova.computeRRRRRRlRt	nova.conftnova.consoleRR2RRvRRRt	nova.i18nRRRRR tnova.networkR!RR"tnova.objectsR#R$Rtnova.pciR%RlRR&t	nova.virtRR'R(tnova.virt.diskR)Rtnova.virt.disk.vfsR*R+R,R-tnova.virt.imageRÐR.tnova.virt.libvirtR/R0R¦tlibvirt_firewallR1RçR2R3R4R5R6Rstnova.virt.libvirt.storageR7R8R9RR:Rtnova.virt.libvirt.volumeR;R<R=tnova.volumeR>R?RlR^RëRt	getLoggerR=RR³RtIptablesFirewallDriverRRtRóR\RRRüt
namedtupleRBR¬RPRÐRÒRÔRÕRìRR5R4R5R3R;R·R7R~RsRRRÓRptMIN_LIBVIRT_KVM_S390_VERSIONtMIN_QEMU_S390_VERSIONRtMIN_LIBVIRT_KVM_PPC64_VERSIONtMIN_QEMU_PPC64_VERSIONRðRñRtQEMU_MAX_SERIAL_PORTSR(RÚRèRéRRRERFRGR×RØRxR~Rt
ComputeDriverRX(((sM/home/tvault/.virtenv/lib/python2.7/site-packages/nova/virt/libvirt/driver.pyt<module>sT
triliodata-4-0-patch / contego deb

Products

About

Resources

Contact Gemfury
