+ hA^csH^RIt^RIt^RIt^RIt^RIt^RIHt^RIHtH t ^RI H t Rt Rt RtRtR tR tR tR tR tRtRtRtRtRtRtRtRtRtRt!RR4t!RR]4t !RR] 4t!!RR] 4t"!R R!]4t#!R"R#]4t$R#)$N)log) StoragePool StorageVolume)xmlutilcsVPV4pVP4VR3# \PdIpTP 4'd%TP 4\P 8wdhRT3uRp?#Rp?ii;i)z Try to find a volume matching the full passed path. Call info() on it to ensure the volume wasn't removed behind libvirt's back N)ZstorageVolLookupByPathinfolibvirtZ libvirtErrorZget_error_codeZVIR_ERR_NO_STORAGE_VOL)connpathvole&& //usr/share/virt-manager/virtinst/diskbackend.py_lookup_vol_by_pathr ss ))$/  Dy       !"2"2"48V8V"V Qws$'B=A?9B?Bcs\PPV4pW P49dVP V4#R#)z Try to lookup a volume for 'path' in parent 'pool' by it's filename. This sometimes works in cases where full volume path lookup doesn't, since not all libvirt storage backends implement path lookup. N)osrbasenameZ listVolumesZstorageVolLookupByName)poolrname&& r _lookup_vol_by_basenamer)s= 77  D !D !!**400"cs\P!V\P4p\P!V^^4p\P!V4V# \ d^pT#i;ir)ropenO_RDONLYlseekclose Exception)rfdsize& r _get_block_sizer4sZ WWT2;; 'xxAq!   K  KsAA A('A(cs\PPV4'g^#\V4'd \ V4#\PP V4#r)rrexists_stat_is_blockrZgetsizer&r _get_sizer#?sA 77>>$  dt$$ 77??4  rcs\PPV4'gR#\P!\P!V4\P ,4#F)rrrstatZS_ISBLKZST_MODEr!r"r r r Gs8 77>>$   << dll3 44rcs&\W4wr#V'dW"P43#\P!V\P P V44pV'gR#\P!VRR7\W4wr%V'd\WA4pMV'g0V'g(V'd \\R4RVRV/,4hW$3# \dLGi;i \dpRpRp\T4pRp?LjRp?ii;i)zt Try to lookup storage objects for the passed path. Returns (volume, parent pool). Only one is returned at a time. NT)Zrefreshz$Cannot use storage %(path)s: %(err)srerr)NN) r ZstoragePoolLookupByVolumerZlookup_pool_by_pathrrdirnameZensure_pool_is_runningrrstr ValueError_)rrr ignorerZverrr s&& r _check_if_path_managedr,Ms &d1KC 11333  * *41F GD  **4>'3   -d9  tABfdTY[_E``aa 9   1vs6&-C, C C)&C,(C))C,, D7D  DcsT;'gRp.ROp\V4'dR#VF*pVPVR,4'g W8XgK)R# R#)F/T)z/devz/sysz/proc) path_is_urlZ startswith)rZ skip_prefixesZprefixrr _can_auto_manager0qsI ::2D-M4 ??6C< ( (DN  rcsz^RIHpV!V4pVPR8XdVPP R4#V#)i)URIZrbdr.)Zurir1ZschemerZstrip)rr1Zuriobjrr _get_storage_search_pathr2~s6 YF }}{{  %% KrcsVPP4'gR#V'gR#\V4'g1\W4'g \P P V4p\V4p\W4wr4V'gV'g\V4'gWV3#\P PV4p\P PV4PRR4pV'gRp\P!W4p\P !RWe4\V4pWgnVP$VnWWnVP+RRRR7p\-WA4pWV3#) zH If path is not managed, try to create a storage pool to probe the path  r*Zdirpoolz%Attempting to build pool=%s target=%sFT)ZbuildcreateZ autostart)NNN)ZsupportZ conn_storager/path_is_network_volrrabspathr2r,r0r'rreplacerZfind_free_namerdebugrZTYPE_DIRtype target_pathinstallr)rrZ searchpathr rr'ZpoolnameZpoolxmls&& r manage_pathr<s" << $ $ & &  t  %8%D%Dwwt$)$/J&t8IC d*400$ggood#Gww(00c:H ))$9HII5xI$GL##GL! ??tt? DD !$ -C d?rcsV\\P!RT;'gR44#)z Detect if path is a URL z[a-zA-Z]+(\+[a-zA-Z]+)?://.*r-)boolreZmatchr!r"r r/r/s! 8$**"E FFrcsVP4F/pV'gK VPV8XgK VPR8Hu# R#)z> Detect if path is a network volume such as rbd, gluster, etc networkF)Zfetch_all_volsr:r9)rrZvolxmlrr r5r5s=%%' 4F&&$.;;)+ +( rcsV'dVP'd VP#V'd?VP4pV\P8XdR#V\P8XdR#V'd]VP 4^,pV\P 8XdR#V\P8XdR#V\P8XdR#V'dl\V4'dR#V'd\V4'gR#R#\PPV4'dR#\V4'dR#R#)z$ Try to get device type for volume. blockr?ZfileZdir) r9Z get_disk_typerZ TYPE_BLOCKZ TYPE_NETWORKrZ TYPE_FILEr/r0rrisdirr )rvol_xml vol_objectZpool_xmlZremoteZts&&&&& r _get_dev_typerDs7<<<||  " " $ (( ( -,, , OO a  '' ' -** * -,, , t   #D)) *  ww}}T""%% rcsVfR#\W4wr#TpV'dR#VP4'g \PP V4#R# \ dR#i;i)zo Return True if the path certainly exists, False if we are unsure. See DeviceDisk entry point for more details FT)r, is_remoterrrr)rrr rr+s&& r path_definitely_existsrFsi  |  ,T8  ~~77>>$' '     sAAA A('A(Zsetfaclcsj\RRV,V.p\P!V\P\PR7pVP 4wrE\ P !RV4V'g V'd\ P !RWE4VP^8wd \V4hR#)z--modifyz user:%s:xZstdoutZstderrzRan command '%s'z out=%s err=%sN) SETFACL subprocessPopenPIPE communicaterr8 returncoder))r'usernamecmdprocoutr&&& r _fix_perms_aclrSs J h 6 @C   C   PD!HCII #& c "C- !orcsN\P!RV4\P!V4PpV\P ,p\P !W4\P!V4PV8wd\\R4V,4hR#)zSetting +x on %sz!Permissions on '%s' did not stickN) rr8rr%st_modeS_IXOTHZchmodr)r*)r'ZmodeZnewmoderr _fix_perms_chmodrVssII '* 777  # #DT\\!GHHW www7*>?'IJJ+rcs>Rp/pVF%pV'd\WA4K\ V4K' V# \d:p\P!RT4\P!R4RpRp?LQRp?ii;i \dp\ T4Y4&Rp?KRp?ii;i)Tzsetfacl failed: %sz trying chmodFN)rSrrr8rVr()ZdirlistrNZuseaclZerrdictr'r rRr set_dirs_searchablerWs FG  w1  & W % N  .2 .)  &"1vG  &s+ 2 A9 A6/A11A69 B BBcs\P!V4pYP8Xd\PpM1YP 8Xd\P pM\Pp\TPT,4'dR#RT.p\P!T\P\PR7pTP4wrxTP ^8wd\P!RYX4R#RT,p \\"P$!T P'RR 4T44# \dR#i;i \d\P!R4R#i;i) z0 Check if passed directory is searchable by uid FTZgetfaclrGz Didn't find the getfacl command.zCmd '%s' failed: %sz user:%s:..xzutf-8r7)rr%OSErrorZst_uidZS_IXUSRZst_gidZS_IXGRPrUr=rTrIrJrKrLrr8rMr>ZsearchZencode) r'uidrNZstatinfoZflagrOrPrQr&Zpatterns &&& r _is_dir_searchablerZ5s777# oo||  |||| H  t #$$ g CJOOJOOT##%  ! '2h&G  '..)>;R;RRSSrr_N)r| __module__ __qualname____firstlineno____doc__rerirkrlrmrnrorrrsrtrwryrzr4__static_attributes____classdictcell__Z __classdict__@r r]r]ssW%$$$$$$%$$$$TTrr]cra]tRtRtoRtRtRtRtRtRt Rt R t R t R t R tR tRtRtRtVtR#)_StorageCreatorizC Base object for classes that will actually create storage on disk csv\PW4RVnRVnRVnRVnRVnR#r^)r]re_pool _vol_install_path_size _dev_typerbrdr reZ_StorageCreator.__init__s4d)    rc\hr^rgrcr}rdr r4Z_StorageCreator.create!!rcrr^rgrhr"r rsZ_StorageCreator.validaterrcrr^rgrhr"r riZ_StorageCreator.get_sizerrcsVP'dVP'g\VPVPPP ^4R7pVP 4R8Xd(VPPVnVP#\PPVPVPP4VnVP#)rrpr?) rrrr`rrqrkrrrZjoinr:)rcZxmlobj& r rtZ_StorageCreator.get_paths    TZZZ d6G6G6L6L6T6TUV6WXF  "i/!..33 zz WW\\&*<*O>O>T>TU zzrcVP#r^rrhr"r rmZ_StorageCreator.get_vol_install   rcrr^rrhr"r get_vol_xmlZ_StorageCreator.get_vol_xmlrrcsVP'gO\VPVPRVP 4VP P 44VnVP#r^)rrDrrrrr`rErhr"r rkZ_StorageCreator.get_dev_typesR~~~* !!((* $$& DN~~rcsVP'd7VPP4'dVPP#R#)raw)rsupports_formatformatrhr"r rlZ_StorageCreator.get_driver_types8      0022((///rcruTrvrhr"r rzZ#_StorageCreator.will_create_storagercrur^rvrhr"r rnZ_StorageCreator.get_vol_objectrrcsVVP'dVPP#R#r^)rrrhr"r roZ_StorageCreator.get_parent_pools#    $$)) )rcrur$rvrhr"r rZ_StorageCreator.existsrxr)rrrrrN)r|r~rrrrer4rsrirtrmrrkrlrzrnrorrrrrr rrsP"""!!   rrcsBa]tRtRtoRtRtRtRtRtRt Rt Vt R #) ManagedStorageCreatoriz Handles storage creation via libvirt APIs. All the actual creation logic lives in StorageVolume, this is mostly about pulling out bits from that class and mapping them to DeviceDisk elements cs^\PW4VPVnW nR#r^)rrerrr)rcrZ vol_installs&&&r reZManagedStorageCreator.__init__s#  , %% 'rcs:VPPVR7#))r})rr;rrdr r4ZManagedStorageCreator.creates  ((u(55rc6VPP4#r^)rryrhr"r ryZ&ManagedStorageCreator.is_size_conflicts  1133rcrr^)rrsrhr"r rsZManagedStorageCreator.validates  ))++rcsj\VPP4R, R, R, #)@)floatrcapacityrhr"r riZManagedStorageCreator.get_size s(T&&//069FBVKKr)rrN) r|r~rrrrer4ryrsrirrrrr rrs* ( 64,LLrrcsHa]tRtRtoRtRtRtRtRtRt Rt R t Vt R #) CloneStorageCreatoriz Handles manually copying local files for Cloner Many clone scenarios will use libvirt storage APIs, which will use the ManagedStorageCreator csl\PW4W nW nW0nW@nWPnR#r^)rrer _output_path _input_pathr_sparse)rcrZ output_pathZ input_pathrsparses&&&&&&r reZCloneStorageCreator.__init__s+  , '%  rcrr^)rrhr"r riZCloneStorageCreator.get_size zzrcsRpRpVP4R8Xd\VP4pMw\P!\P P \P PVP444pVPVP,p\VP4R,R,R,pWS8dhVP'd \R4pM Rp\R4pV'd5VR, pV\R4R VR ,R VR ,/,, pW3#) FNr@zkThe filesystem will not have enough free space to fully allocate the sparse file when the guest is running.Tz2There is not enough free space to create the disk.r3z+%(mem1)s M requested > %(mem2)s M availableZmem1Zmem2i)rkr#rrZstatvfsrr'r6Zf_frsizeZf_bavailintrrr*)rcretmsgZavailZvfsZneeds& r ryZ$CloneStorageCreator.is_size_conflict"s    ' )djj)E**RWW__RWW__TZZ-HIJCLL3<</E4::%,t3 <|||# LMs qFGTk2U{3KzrcsVPf*\\R4VP4,4hVP 4wrV'd \V4hV'd\ P !V4R#R#)Nz+size is required for non-existent disk '%s')rr)r*rtryrZwarning)rcr&rrr rsZCloneStorageCreator.validate>s] :: QLMPTP]P]P__` `((* S/ !  KK  rcs\R4R\PPVP4/,p\ VP 4R,R,R,4pVPW#4VPW4R#)zCloning %(srcfile)sZsrcfilerN) r*rrrrrriZstart _clone_local)rcr}Ztext size_bytesr r r4ZCloneStorageCreator.createHsg&'9bgg6F6FtGWGW6X*YY4/$6=>  D% %,rc sVPR8Xd\P!R4R#VPVP8Xd\P!R4R#\P P VP4'gVP'dRpRpRp\P!VP\P\P,R4p\P!WR4V'd\P!V4MRpRp\P!RVPVPVV4RpRRr\P!VP\P4p\P!VP\P\P,R4p^p \P!Ws4p \V 4p V ^8XdVP!4MvV'dWj8Xd\P"!W^4M-\P$!W4p W8wdVP!4M#W, p W8gKVP'V 4KVe\P!V4Ve\P!V4R#R# T'd\P!T4ii;i \(d_p \P!R RR 7\+R 4R TPR TPR\-T 4/,p\/T4RhRp ? ii;i Te\P!T4Te\P!T4ii;i)z /dev/nullz"Source dev was /dev/null. SkippingNz.Source and destination are the same. Skipping.iTiFz0Local Cloning %s to %s, sparse=%s, block_size=%szError while cloning)Zexc_infozBError cloning diskimage %(inputpath)s to %(outputpath)s: %(error)sZ inputpathZ outputpathZerroris)rrr8rrrrrrZO_WRONLYZO_CREATZ ftruncaterrZreadZlenZendrZwriteZupdaterXr*r(Z RuntimeError)rcr}rZclone_block_sizerrZzerosZsrc_fdZdst_fdZiZdataZsZbr rs&&& r rZ CloneStorageCreator._clone_localQs   { * II: ;    t00 0 IIF G  ww~~d//00T\\\# FB !WWT.. bjj0H%P R,HHRL/ F >          t# ! 2!1!12;;?!2!2BKK"**4LeT776>MM7M=)rrrrrN) r|r~rrrreriryrsr4rrrrrr rrs/8-I!I!rrcr\)StorageBackendStubizv Class representing a storage path for a parsed XML disk, that we don't want to do slow resolving of unless requested csT\PW4W nW0nW@nR#r^)r]rerr _driver_type)rcrrZdev_typeZ driver_type&&&&&r reZStorageBackendStub.__init__s d) !'rcrr^)rrhr"r rtZStorageBackendStub.get_pathrrcrur^rvrhr"r rnZ!StorageBackendStub.get_vol_objectrrcrur^rvrhr"r rZStorageBackendStub.get_vol_xmlrrcrur^rvrhr"r roZ"StorageBackendStub.get_parent_poolrrcs^#rrvrhr"r riZStorageBackendStub.get_sizesrcrurrvrhr"r rZStorageBackendStub.existsrrcrr^)rrhr"r rkZStorageBackendStub.get_dev_types ~~rcrr^)rrhr"r rlZ"StorageBackendStub.get_driver_typerrcrur^rvrhr"r rsZStorageBackendStub.validatercrur^rvrhr"r rmZ"StorageBackendStub.get_vol_installrrcR#F)FNrvrhr"r ryZ#StorageBackendStub.is_size_conflictrcrurrvrhr"r rwZStorageBackendStub.is_stubrrcrur$rvrhr"r rzZ&StorageBackendStub.will_create_storagerxr)rrrN)r|r~rrrrertrnrrorirrkrlrsrmryrwrzrrrrr rrsU ( !rrcr)StorageBackendizU Class that carries all the info about any existing storage that the disk references cs8\PW4W0nW@nW nVPeRVnVP'd)VP'g\ P !R4hRVnRVnRVn RVn RVn R#)Nzparent_pool must be specified) r]re _vol_object _parent_poolrrr{_vol_xmlra_existsrr)rcrrrCZ parent_poolrr reZStorageBackend.__init__sd)%'    'DJ    D$5$5$5""#BC C $  rcsrVP'dVP4P#VP#r^)rrr:rrhr"r rtZStorageBackend.get_paths-    ##%11 1zzrcrr^)rrhr"r rnZStorageBackend.get_vol_objectsrcsVPfQ\VPVPP ^4R7VnVP VPnVP#)Nrp)rrr`rrqrrrhr"r rZStorageBackend.get_vol_xmlsL == )$**t?O?O?W?WXY?Z[DM!%!2!2DMM }}rcrr^)rrhr"r roZStorageBackend.get_parent_poolrrc s,VPf|^pVP'dVP4PpM'VP'd\ VP4p\ V4R, R, R, VnVP#)z! Return size of existing storage r)rrrrrr#r)rcrrr riZStorageBackend.get_sizesn :: C&&(11 +sf,v5>DJzzrcsVPEf`VP'dRVnVP#VPfRVnVP#VP4R8wdcVPP 4'gC\ PPVP4'dRVnVP#VP'dRVnVP#VP4R8XdRVnVP#VPP 4'd/\VP4'gRVnVP#RVnVP#)NTr?F) rrrrkr`rErrrrr0rhr"r rZStorageBackend.exists s- << # *||)## &||#!!#y0 ,,..GGNN4::..# ||"""$ ||""$ 1# ||%%''0@0L0L $ || % ||rc sVPfsRpVP'dVP4p\VPVVPVP 4VP P44VnVP#)z/ Return disk 'type' value per storage settings N)rrrrDrrrr`rE)rcrBrr rkZStorageBackend.get_dev_type'st >> !G**,*   ((* $$& DN~~rcsVP'dAVP4P4'dVP4P#R#R#)rN)rrrrrhr"r rlZStorageBackend.get_driver_type8sA    !1133'')000rcrur^rvrhr"r rsZStorageBackend.validate?rrcrur^rvrhr"r rmZStorageBackend.get_vol_installBrrcrrrvrhr"r ryZStorageBackend.is_size_conflictErrcrur$rvrhr"r rzZ"StorageBackend.will_create_storageHrxr)rrrrarrrrN)r|r~rrrrertrnrrorirrkrlrsrmryrzrrrrr rrsP 0   ! 4"rr)%rr>r%rIrZloggerrZstoragerrr-rr rrr#r r,r0r2r<r/r5rDrFrHrSrVrWrZr[r]rrrrrrvrr rs /(1!5 !H  DG*Z4  K,!DH44T4TnGlGTLOL4L!/L!^11hx\xr