grthtrhthjhtyjytjytkergtrhtrjytjerhrfh4:24 29/09/2026a dtd @sdZddlZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZmZmZmZmZddl mZmZdd l mZmZdd l mZmZd Zd d ZGddde ZGdddeZGdddeZGdddeZGdddeZGdddeZ Gddde!Z"eeeeeee dZ#ee$ddee$dd d!ee$d"dee$d#d$d!e e$d%diZ%ia&Gd&d'd'e Z'd(d)Z(e)d*kre(dS)+a Implements the RTS Target backstore and storage object classes. This file is part of RTSLib. Copyright (c) 2011-2013 by Datera, Inc Copyright (c) 2011-2014 by Red Hat, Inc. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. N)range)ALUATargetPortGroup)CFSNode)freadfwrite generate_wwn RTSLibErrorRTSLibNotInCFS)convert_scsi_path_to_hctlconvert_scsi_hctl_to_path) is_dev_in_useget_blockdev_type)get_size_for_blk_devget_size_for_disk_namez/var/run/rtslib_backstore.lockcCs4zt|ddkrWdSWnty.Yn0dS)zM Helper function that can be called by passthrough type of backends. Z alua_supportrTF)int get_attributer )Zsor./usr/lib/python3.9/site-packages/rtslib/tcm.py$storage_object_get_alua_support_attr&s   rcs`eZdZdZddZdAfdd ZdBddZd d Zd d Zd dZ e ddZ e ddZ ddZ ddZddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0ZdCfd2d3 Zd4d5Zeed6d7Zeed8d7Z eed9d7Z!ee ed:d7Z"eed;d7Z#eedd7Z&fd?d@Z'Z(S)D StorageObjectz This is an interface to storage objects in configFS. A StorageObject is identified by its backstore and its name. cCsd|jj|j|jfS)Nz <%s %s/%s>) __class____name__pluginnameselfrrr__repr__;szStorageObject.__repr__Ncstt|d|vs.d|vs.d|vs.d|vr8tdn||_t|t||||_d|jj|j f|_ |jj |_ z| |Wn|j Yn0dS)N/   zAA storage object's name cannot contain /, newline or spaces/tabs%s/%s)superr__init__r _name _Backstoretype _backstorepathr_pathr_create_in_cfs_inedelete)rrmodeindexrrrr$>s    zStorageObject.__init__cCs|s td}||_|dS)NZ unit_serial)rwwn_config_pr_aptplrr0rrr _configureNszStorageObject._configurecCs|j|jko|j|jkSN)rrrotherrrr__eq__UszStorageObject.__eq__cCs ||k Sr4rr5rrr__ne__XszStorageObject.__ne__cCsddlm}d|j}ztd||jf}WnYdS0|ddsTdSg}|D]8}|drpg}q\|dr||q\||q\|D]}t |j d d |qdS) z LIO actually *writes* pr aptpl info to the filesystem, so we need to read it in and squirt it back into configfs when we configure the storage object. BLEH. rRTSRootz%s/prz %s/aptpl_%sNrz PR_REG_START:z PR_REG_END:z/pr/res_aptpl_metadata,) rootr:Zdbrootrr0split startswithappendstriprr)join)rr:Z aptpl_dirlinesZ reservationslineZres_listresrrrr1[s"     zStorageObject._config_pr_aptplccs2td|jD]}tj|r||VqdS)Nz %s/core/*_*/*)glob configfs_dirosr)isdir so_from_path)clsZso_dirrrrallxs zStorageObject.allcCs6tj|}|dddd\}}t|||dS)zQ Build a StorageObject of the correct type from a configfs path. r_r)r.)rGr)basenamer=rsplit so_mapping)rJr)Zso_nameZso_typeZso_indexrrrrI~s zStorageObject.so_from_pathcCs<||r0d|j}t|ddStddS)N%s/wwn/vpd_unit_serial:zDCannot read a T10 WWN Unit Serial from an unconfigured StorageObject) _check_self is_configuredr)r partitionr@r rr)rrr_get_wwns  zStorageObject._get_wwncCs6||r*d|j}t|d|ntddS)NrQz%s zCCannot write a T10 WWN Unit Serial to an unconfigured StorageObject)rTrUr)rr )rr0r)rrr_set_wwns  zStorageObject._set_wwncCs$|d|j}t|d|dS)N %s/udev_path%srTr)r)r udev_pathr)rrr_set_udev_paths zStorageObject._set_udev_pathcCs<|d|j}t|}|s8|jjdkr8|d}|S)NrZfileioFile)rTr)rr(r _parse_infor@)rr)r]rrr_get_udev_paths  zStorageObject._get_udev_pathcCs|jjSr4)r(versionrrrr _get_versionszStorageObject._get_versioncCs|jSr4)r%rrrr _get_nameszStorageObject._get_namecCs |d|j}t|ddS)N %s/enablez1 r\rWrrr_enables zStorageObject._enablecCs,|d|j}t|dt|dS)Nz %s/controlr[rTr)rstrr@)rZcommandr)rrr_controls zStorageObject._controlcCs,|d|j}t|dt|dS)Nz%s/fdr[rh)rcontentsr)rrr _write_fds zStorageObject._write_fdcCsR|td|j}z"td|d|dWStyLYdS0dS)N%s/info.*%s: ([^: ]+).*rr rTrr)researchrAr=groupAttributeErrorrkeyinforrrras  zStorageObject._parse_infocCs||dS)NZStatus)rTralowerrrrr _get_statusszStorageObject._get_statusc cs6tjj}tjj}tj}tjj}|j}ddlm}ddlm }m }m } ddl m } dd|jDD]\} } || D]} | | vrrd| | f}||D]}d||f}||r||D]x}d||f}||D]^}d||f}||r|||kr|d |}|d }| | | }||||d|d Vqqqqrqbd S) z Fast scan of luns attached to a storage object. This is an order of magnitude faster than using root.luns and matching path on them. rr9)LUNTPGTarget)target_names_excludescss|]}|jr|j|fVqdSr4)existsr)).0fmrrr z3StorageObject._gen_attached_luns..r"z %s/%s/lunrMN)rGr)rHislinklistdirrealpathr<r:targetryrzr{Zfabricr|Zfabric_modulesr=)rrHrrrr)r:ryrzr{r|baserZtgt_dirZ tpgts_baseZtpgt_dirZ luns_baseZlun_dirZ links_baseZlun_filelinkvalrrrr_gen_attached_lunss0             z StorageObject._gen_attached_lunsccs ||D] }|VqdS)zB Generates all luns attached to a storage object. N)rTr)rlunrrr_list_attached_lunss z!StorageObject._list_attached_lunsccs4|td|jD]}|jrt||VqdS)zF Generate all ALUA groups attach to a storage object. z%s/aluaN)rTrGrr)alua_supportedr)rtpgrrr_list_alua_tpgsszStorageObject._list_alua_tpgscCs |dS)zU Children should override if the backend did not always support ALUA T)rTrrrr_get_alua_supportedsz!StorageObject._get_alua_supportedFcs||D]}|jdkr|q|rV|D]}|jdkrLqVq8|q8tt||j |rddl m }m }| |d|jd|jdS)a$ Recursively deletes a StorageObject object. This will delete all attached LUNs currently using the StorageObject object, and then the StorageObject itself. The underlying file and block storages will not be touched, but all ramdisk data will be lost. Zdefault_tg_pt_gpZ activatedr)r:default_save_filez /backstores/rN)rTrrr,rUrstatusr#rr(r<r:rZ save_to_filerr%)rZsaveZalua_tpgrr:rr/rrr,s       zStorageObject.deletecCs6|d|j}tj|r.ttt|SdSdS)zV @return: True if the StorageObject is configured, else returns False rfTN)rTr)rGisfileboolrrrWrrrrUs   zStorageObject.is_configuredz0Get the version of the StorageObject's backstoredocz'Get the StorageObject name as a string.z,Get the StorageObject udev_path as a string.z8Get or set the StorageObject T10 WWN Serial as a string.zOGet the storage object status, depending on whether or not itis used by any LUNz)Get the list of all LUN objects attached.z-Get list of ALUA Target Port Groups attached.:Returns true if ALUA can be setup. False if not supported.cs:tt|}|j|d<|j|d<dd|jD|d<|S)NrrcSsg|] }|qSr)dump)r~rrrr ?rz&StorageObject.dump.. alua_tpgs)r#rrrrrrdr/rrr;s   zStorageObject.dump)N)N)F))r __module__ __qualname____doc__rr$r3r7r8r1 classmethodrKrIrXrYr^rbrdrergrjrlrarxrrrrr,rUpropertyrcrr]r0rZ attached_lunsrrr __classcell__rrr/rr4sj         rcseZdZdZd%fdd ZfddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZeejeddZeeddZeeddZee ddZee ddZee ddZee d dZee d!dZeed"dZfd#d$ZZS)&PSCSIStorageObjectzG An interface to configFS storage objects for pscsi backstore. Ncs\|durDtt||d|z||WqX|YqX0ntt||d|dS)a A PSCSIStorageObject can be instantiated in two ways: - B{Creation mode}: If I{dev} is specified, the underlying configFS object will be created with that parameter. No PSCSIStorageObject with the same I{name} can pre-exist in the parent PSCSIBackstore in that mode, or instantiation will fail. - B{Lookup mode}: If I{dev} is not set, then the PSCSIStorageObject will be bound to the existing configFS object in the parent PSCSIBackstore having the specified I{name}. The underlying configFS object must already exist in that mode, or instantiation will fail. @param name: The name of the PSCSIStorageObject. @type name: string @param dev: You have two choices: - Use the SCSI id of the device: I{dev="H:C:T:L"}. - Use the path to the SCSI device: I{dev="/path/to/dev"}. @type dev: string @return: A PSCSIStorageObject object. Ncreatelookup)r#rr$r3r,)rrdevr.r/rrr$Js zPSCSIStorageObject.__init__c s |zt|\}}}}|}Wntz6|d\}}}}t|}t|}t|}t|}Wn"tytdd|Yn0t||||}Yn0t|rtdd|||||fd| d|d|d |d || || t t |dS) NrRzBCannot find SCSI device by path, and dev parameter not in H:C:T:L z format: %s'Cannot configure StorageObject because zdevice %s (SCSI %d:%d:%d:%d) zis already in usezscsi_host_id=%d,zscsi_channel_id=%d,zscsi_target_id=%d,zscsi_lun_id=%d)rTr r@r=r ValueErrorr r r rjr^rgr#rr3)rrZhostidZ channelidZtargetidZlunidr]r/rrr3isR        zPSCSIStorageObject._configurecCsdSr4rr2rrrrYszPSCSIStorageObject._set_wwncCs:|td|j}ttdd|d S)Nrmz.*Model:(.*)Rev:rr rTrr)rirprqrAr=rrr@rrvrrr _get_models zPSCSIStorageObject._get_modelcCs:|td|j}ttdd|d S)Nrmz.*Vendor:(.*)Model:rrrrrrr _get_vendors zPSCSIStorageObject._get_vendorcCs||dS)NZRevrTrarrrr _get_revisionsz PSCSIStorageObject._get_revisioncCs|t|dS)Nz Channel IDrTrrarrrr_get_channel_idsz"PSCSIStorageObject._get_channel_idcCs|t|dS)Nz Target IDrrrrr_get_target_idsz!PSCSIStorageObject._get_target_idcCs|t|dS)Nryrrrrr_get_lunszPSCSIStorageObject._get_luncCs|t|dS)NzHost IDrrrrr _get_host_idszPSCSIStorageObject._get_host_idcCs|t|Sr4rTrrrrrrsz&PSCSIStorageObject._get_alua_supportedziGet the StorageObject T10 WWN Unit Serial as a string. You cannot set it for pscsi-backed StorageObjects.rz Get the SCSI device model stringz!Get the SCSI device vendor stringz#Get the SCSI device revision stringzGet the SCSI device host idzGet the SCSI device channel idzGet the SCSI device target idzGet the SCSI device LUNrcstt|}|j|d<|S)Nr)r#rrr]rr/rrrs zPSCSIStorageObject.dump)NN)rrrrr$r3rYrrrrrrrrrrrXr0ZmodelZvendorZrevisionZhost_idZ channel_idZ target_idrrrrrrr/rrCsP .rcseZdZdZdfdd ZfddZdd Zd d Zd d ZddZ e eddZ e eddZ e eddZ e e ddZfddZZS)RDMCPStorageObjectzH An interface to configFS storage objects for rd_mcp backstore. NFcs`|durHtt||d|z||||Wq\|Yq\0ntt||d|dS)aO A RDMCPStorageObject can be instantiated in two ways: - B{Creation mode}: If I{size} is specified, the underlying configFS object will be created with that parameter. No RDMCPStorageObject with the same I{name} can pre-exist in the parent Backstore in that mode, or instantiation will fail. - B{Lookup mode}: If I{size} is not set, then the RDMCPStorageObject will be bound to the existing configFS object in the parent Backstore having the specified I{name}. The underlying configFS object must already exist in that mode, or instantiation will fail. @param name: The name of the RDMCPStorageObject. @type name: string @param size: The size of the ramdrive to create, in bytes. @type size: int @param wwn: T10 WWN Unit Serial, will generate if None @type wwn: string @param nullio: If rd should be created w/o backing page store. @type nullio: boolean @return: A RDMCPStorageObject object. Nrr)r#rr$r3r,)rrsizer0nullior.r/rrr$s zRDMCPStorageObject.__init__cs`|tt|t}|dkr(d}|d||rD|d|tt| |dS)Nrrz rd_pages=%dz rd_nullio=1) rTroundfloatresourceZ getpagesizerjrgr#rr3)rrr0rr/rrr3s zRDMCPStorageObject._configurecCs |t|dddS)NPAGES/PAGE_SIZE*rrTrrar=rrrr_get_page_sizesz!RDMCPStorageObject._get_page_sizecCs |t|dddS)Nrrrrrrrr _get_pagesszRDMCPStorageObject._get_pagescCs|||}|Sr4)rTrr)rrrrr _get_sizeszRDMCPStorageObject._get_sizecCs6|ztt|dWSty0YdS0dS)NrFrTrrrarsrrrr _get_nullios  zRDMCPStorageObject._get_nulliozGet the ramdisk page size.rz Get the ramdisk number of pages.zGet the ramdisk size in bytes.zGet the nullio status.cs4tt|}|j|d<|j|d<|jr0d|d<|S)Nr0rTr)r#rrr0rrrr/rrr2s   zRDMCPStorageObject.dump)NNFN)rrrrr$r3rrrrrZ page_sizeZpagesrrrrrrr/rrs("  rcseZdZdZdfdd ZfddZdd Zd d Zd d ZddZ e eddZ e eddZ e eddZ e e ddZfddZZS)FileIOStorageObjectzH An interface to configFS storage objects for fileio backstore. NFcsd|durLtt||d|z||||||Wq`|Yq`0ntt||d|dS)a A FileIOStorageObject can be instantiated in two ways: - B{Creation mode}: If I{dev} and I{size} are specified, the underlying configFS object will be created with those parameters. No FileIOStorageObject with the same I{name} can pre-exist in the parent Backstore in that mode, or instantiation will fail. - B{Lookup mode}: If I{dev} and I{size} are not set, then the FileIOStorageObject will be bound to the existing configFS object in the parent Backstore having the specified I{name}. The underlying configFS object must already exist in that mode, or instantiation will fail. @param name: The name of the FileIOStorageObject. @type name: string @param dev: The path to the backend file or block device to be used. - Examples: I{dev="/dev/sda"}, I{dev="/tmp/myfile"} - The only block device type that is accepted I{TYPE_DISK}, or partitions of a I{TYPE_DISK} device. For other device types, use pscsi. @type dev: string @param size: Size of the object, if not a block device @type size: int @param wwn: T10 WWN Unit Serial, will generate if None @type wwn: string @param write_back: Should we create the StorageObject with write caching enabled? Disabled by default @type write_back: bool @return: A FileIOStorageObject object. Nrr)r#rr$r3r,)rrrrr0 write_backaior.r/rrr$Cs  zFileIOStorageObject.__init__cs|t|}|dur\tj|r8tj|s8td|durHtd|d||fn2|dkrltdt|rtd||d||r| dd |d ||r|d || || t t ||dS) Nz"Path not to a file or block devicezPath is to a file, size neededzfd_dev_name=%s,fd_dev_size=%drz&Device is not a TYPE_DISK block devicezDevice %s is already in usezfd_dev_name=%semulate_write_cacherzfd_buffered_io=%dzfd_async_io=%d)rTrrGr)r}rr rjr Z set_attributer^rgr#rr3)rrrr0rrZ block_typer/rrr3ms*   zFileIOStorageObject._configurecCs|tt|dSNrrTrrrrrrr_get_wb_enabledsz#FileIOStorageObject._get_wb_enabledcCs<||jr*t|dt|dSt|dSdS)Nr` SectorSizeSize)rTis_blockrrarrrrrrs   zFileIOStorageObject._get_sizecCst|jduSr4)rr]rrrr _is_blockszFileIOStorageObject._is_blockcCsF|td|j}tdd|}|s4dStt| dS)Nrmz.*Async: ([^: ]+).*rFr) rTrr)rprqrAr=rrrr)rrvrrrr_aios zFileIOStorageObject._aioATrue if write-back, False if write-through (write cache disabled)rz+Get the current FileIOStorage size in byteszCTrue if FileIoStorage is backed by a block device instead of a filez#True if asynchronous I/O is enabledcsDtt|}|j|d<|j|d<|j|d<|j|d<|j|d<|S)Nrr0rrr)r#rrrr0r]rrrr/rrrs     zFileIOStorageObject.dump)NNNFFN)rrrrr$r3rrrrrrrrrrrrrr/rr<s,* %  rcseZdZdZdfdd ZfddZdd Zd d Zd d ZddZ ddZ e eddZ e eddZ e eddZe e ddZe e ddZfddZZS)BlockStorageObjectzG An interface to configFS storage objects for block backstore. NFcs`|durHtt||d|z||||Wq\|Yq\0ntt||d|dS)aw A BlockIOStorageObject can be instantiated in two ways: - B{Creation mode}: If I{dev} is specified, the underlying configFS object will be created with that parameter. No BlockIOStorageObject with the same I{name} can pre-exist in the parent Backstore in that mode. - B{Lookup mode}: If I{dev} is not set, then the BlockIOStorageObject will be bound to the existing configFS object in the parent Backstore having the specified I{name}. The underlying configFS object must already exist in that mode, or instantiation will fail. @param name: The name of the BlockIOStorageObject. @type name: string @param dev: The path to the backend block device to be used. - Example: I{dev="/dev/sda"}. - The only device type that is accepted I{TYPE_DISK}. For other device types, use pscsi. @type dev: string @param wwn: T10 WWN Unit Serial, will generate if None @type wwn: string @return: A BlockIOStorageObject object. Nrr)r#rr$r3r,)rrrr0readonlyrr.r/rrr$s zBlockStorageObject.__init__csz|t|dkr td|t|r8tdd||||d||d||tt| |dS)Nrz)Device %s is not a TYPE_DISK block devicerzdevice %s is already in usez udev_path=%sz readonly=%d) rTrr r r^rjrgr#rr3)rrr0rr/rrr3s   zBlockStorageObject._configurecCs|t|dS)NZMajorrrrrr _get_majorszBlockStorageObject._get_majorcCs|t|dS)NZMinorrrrrr _get_minorszBlockStorageObject._get_minorcCst|dt|dS)NZdevicer)rrarrrrrrszBlockStorageObject._get_sizecCs|tt|dSrrrrrrrsz"BlockStorageObject._get_wb_enabledcCs6|ztt|dWSty0YdS0dS)NrFrrrrr _get_readonly s  z BlockStorageObject._get_readonlyz!Get the block device major numberrz!Get the block device minor numberzGet the block device sizerz4True if the device is read-only, False if read/writecs:tt|}|j|d<|j|d<|j|d<|j|d<|S)Nrrr0r)r#rrrrr0r]rr/rrrs     zBlockStorageObject.dump)NNFFN)rrrrr$r3rrrrrrmajorminorrrrrrrrr/rrs4$  rcseZdZdZdfdd ZfddZddZd d Zd d Zd dZ ddZ e eddZ e eddZ e eddZe e ddZe e ddZfddZZS)UserBackedStorageObjectzR An interface to configFS storage objects for userspace-backed backstore. Ncs|durl|durtdd|vr(tdtt||d|z||||||Wq|Yq0ntt||d|dS)a @param name: The name of the UserBackedStorageObject. @type name: string @param config: user-handler-specific config string. - e.g. "rbd/machine1@snap4" @type config: string @param size: The size of the device to create, in bytes. @type size: int @param wwn: T10 WWN Unit Serial, will generate if None @type wwn: string @hw_max_sectors: Max sectors per command limit to export to initiators. @type hw_max_sectors: int @control: String of control=value tuples separate by a ',' that will passed to the kernel control file. @type: string @return: A UserBackedStorageObject object. NzK'size' and 'config' must be set when creating a new UserBackedStorageObjectrzL'config' must contain a '/' separating subtype from its configuration stringrr)r r#rr$r3r,)rrconfigrr0hw_max_sectorscontrolr.r/rrr$,s z UserBackedStorageObject.__init__csx|d|vrtd|d||d||durJ|d||dur\|||tt||dS)NrRz ':' not allowed in config stringz dev_config=%sz dev_size=%dzhw_max_sectors=%s)rTr rjrgr#rr3)rrrr0rrr/rrr3Ps z"UserBackedStorageObject._configurecCs|t|dS)Nrrrrrrr_sz!UserBackedStorageObject._get_sizecCs|t|dS)NZ HwMaxSectorsrrrrr_get_hw_max_sectorscsz+UserBackedStorageObject._get_hw_max_sectorscCsv|g}|d}|dkr,|d||d}|dkrL|d||d}|dkrl|d|d|S) NZ MaxDataAreaMBNULLzmax_data_area_mb=%sZ hw_block_sizezhw_block_size=%sZDataPagesPerBlkzdata_pages_per_blk=%sr;)rTrar?rrA)rZtuplesrrrr_get_control_tuplesgs   z+UserBackedStorageObject._get_control_tuplescCs"||d}|dkrdS|S)NZConfigrr)rrrrr _get_configys  z#UserBackedStorageObject._get_configcCs|t|Sr4rrrrrrsz+UserBackedStorageObject._get_alua_supportedz Get the max sectors per command.rz?Get the comma separated string containing control=value tuples.zGet the size in bytes.zGet the TCMU config.rcsDtt|}|j|d<|j|d<|j|d<|j|d<|j|d<|S)Nr0rrrr)r#rrr0rrrcontrol_tuplesrr/rrrs     zUserBackedStorageObject.dump)NNNNNN)rrrrr$r3rrrrrrrrrrrrrrrr/rr's4$ rc@seZdZdZddZdS)StorageObjectFactoryzY Create a storage object based on a given path. Only works for file & block. cCsl|ddd}tj|r\t|}t|jr@t||dSt |jr\t |||j dSt d|dS)Nr-)rr)rrrz(Can't create storageobject from path: %s) r@replacerGr)r}statS_ISBLKst_moderS_ISREGrst_sizer )rJr)rsrrr__new__s     zStorageObjectFactory.__new__N)rrrrrrrrrrsr)pscsird_mcpramdiskr_iblockblockuserr)rrr)r alt_dirprefixr_rrrcseZdZdZdfdd ZfddZddZd d Zd d Zd dZ ddZ e e ddZ e eddZ e eddZe e ddZZS)r&z Backstore is needed as a level in the configfs hierarchy, but otherwise useless. 1:1 so:backstore. Created by storageobject ctor before SO configfs entry. Ncstt|||_t|jd|_t|jd|j}|durtst d|j D]B}| d}|d}|d dd\} } d | |f} t | t| <qTd ||f|_|durt|jd|_|jdkr|d krtd |j|fn t ||_|jdkr|d krtd |j|fntjds0tdttd} t| tjtt} tdD](}|| vr\||_|jt|j<qq\t| tjtdt| tjd|j ||jf|_z| |Wn"|jtvrt|j=Yn0dS)Nrrz%s/core/*_*/*/rrLrMrr"rzStorage object %s/%s existsrzStorage object %s/%s not foundz/var/runzw+izNo available backstore indexz %s/core/%s_%d)!r#r&r$Z_so_cls bs_params_plugingetbs_cacherEZiglobrFr=rOr _lookup_key_indexr r rGr)r}makedirsopen lock_filefcntlZflockZLOCK_EXsetvaluesrZLOCK_UNr*r+)rrZstorage_object_clsr-r.ZdirpdirpartsZbs_nameZbs_dirpZbs_indexZ current_keyZlkfdZindexesr/rrr$s^              z_Backstore.__init__cs$tt||jtvr t|j=dSr4)r#r&r,rrrr/rrr,s z_Backstore.deletecCs|jSr4)rrrrr _get_indexsz_Backstore._get_indexcCsR|td|j}z"td|d|dWStyLYdS0dS)Nz %s/hba_infornrrrortrrrra s  z_Backstore._parse_infocCs||dS)Nrcrrrrrrdsz_Backstore._get_versioncCs||jSr4)rTrrrrr _get_pluginsz_Backstore._get_plugincCs|d|j|jfS)Nz%s%d)rTrr.rrrrresz_Backstore._get_namezGet the backstore plugin name.rz"Get the backstore index as an int.z(Get the Backstore plugin version string.zGet the backstore name.)N)rrrrr$r,rrardrrerrr.rcrrrrr/rr&s(9  r&cCsddl}|dS)Nr)doctestZtestmod)rrrr_test*sr__main__)*rrGrrprErrZ six.movesrZaluarZnoderZutilsrrrr r r r r rrrrrrrrrrrobjectrrPdictrrr&rrrrrrsZ   ags     g