File manager - Edit - /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyc
Back
� .�t_c @ s� d Z d d l m Z d d l m Z d d l m Z d d l m Z m Z d d l m Z m Z d d l m Z d d l m Z d d l m Z m Z d d l m Z m Z d d l m Z m Z m Z d d l m Z m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l Z d d l Z d d l Z d e f d � � YZ d e e f d � � YZ d e e f d � � YZ! d e e f d � � YZ" d e e f d � � YZ# d e f d � � YZ$ d S( s� VDOService - manages the VDO service on the local node $Id: //eng/vdo-releases/magnesium/src/python/vdo/vdomgmnt/VDOService.py#35 $ i ( t ArgumentError( t Constants( t Defaults( t MgmntLoggert MgmntUtils( t Servicet ServiceError( t SizeString( t VDOKernelModuleService( t DeveloperExitStatust StateExitStatus( t SystemExitStatust UserExitStatusi����( t Commandt CommandErrort runCommand( t Transactiont transactionalN( t gethostbynamet VDOServiceErrorc B s e Z d Z e d � d � Z RS( s) Base class for VDO service exceptions. s VDO volume errorc O s t t | � j | | | � d S( N( t superR t __init__( t selft msgt argst kwargs( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR 8 s ( t __name__t __module__t __doc__t _R ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR 2 s t VDODeviceAlreadyConfiguredErrorc B s e Z d Z e d � d � Z RS( s8 The specified device is already configured for a VDO. s Device already configuredc O s t t | � j | | | � d S( N( R R R ( R R R R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR B s ( R R R R R ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR < s t VDOServiceExistsErrorc B s e Z d Z e d � d � Z RS( s VDO service exists exception. s VDO volume existsc O s t t | � j | | | � d S( N( R R R ( R R R R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR L s ( R R R R R ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR F s t VDOMissingDeviceErrorc B s e Z d Z e d � d � Z RS( s2 VDO underlying device does not exist exception. s Underlying device does not existc O s t t | � j | | | � d S( N( R R R ( R R R R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR V s ( R R R R R ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR P s t VDOServicePreviousOperationErrorc B s e Z d Z e d � d � Z RS( s3 VDO volume previous operation was not completed. s+ VDO volume previous operation is incompletec O s t t | � j | | | � d S( N( R R! R ( R R R R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR a s ( R R R R R ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR! [ s t VDOServicec B sz e Z d Z e j e j d � Z d Z d Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z e d � Z d g Z i d d 6d d 6d d 6d d 6d d 6d d 6d d 6d! d" 6d# d$ 6d% d& 6d' d( 6Z d) e f d* � � YZ e d+ � � Z! d, � Z" e# d- � Z$ d. � Z% e& e' d/ � � Z( d0 � Z) d1 � Z* d2 � Z+ d3 � Z, e& d4 � � Z- e& d5 � � Z. d6 � Z/ e' dw d7 � Z1 d8 � Z2 e' d9 � Z3 d: � Z4 e' dw d; � Z5 d< � Z6 d= � Z7 d> � Z8 d? � Z9 d@ � Z: e; dA � � Z< e dB � � Z= e> dC � � Z? dD � Z@ e> dE � � ZA dF � ZB dG � ZC dH � ZD e; dI � � ZE dJ � ZF dK � ZG dL � ZH dM � ZI dN � ZJ dO � ZK dP � ZL dQ � ZM dR � ZN dS � ZO dT � ZP e' dU � ZQ dV � ZR dW � ZS dX � ZT dY � ZU dZ � ZV d[ � ZW d\ d] � ZX d^ � ZY d_ � ZZ d` � Z[ da � Z\ db � Z] dc � Z^ dd � Z_ de � Z` dw df � Za dg � Zb e& dh � � Zc di � Zd dj � Ze dk � Zf dl � Zg dm � Zh e# dn � Zi do � Zj dp � Zk dq � Zl dr � Zm ds � Zn dt � Zo du � Zp dv � Zq RS(x s VDOService manages a vdo device mapper target on the local node. Attributes: ackThreads (int): Number of threads dedicated to performing I/O operation acknowledgement calls. activated (bool): If True, should be started by the `start` method. bioRotationInterval (int): Number of I/O operations to enqueue for one bio submission thread in a batch before moving on to enqueue for the next. bioThreads (int): Number of threads used to submit I/O operations to the storage device. blockMapCacheSize (sizeString): Memory allocated for block map pages. blockMapPeriod (int): Block map period. cpuThreads (int): Number of threads used for various CPU-intensive tasks such as hashing. device (path): The device used for storage for this VDO volume. enableCompression (bool): If True, compression should be enabled on this volume the next time the `start` method is run. enableDeduplication (bool): If True, deduplication should be enabled on this volume the next time the `start` method is run. enableReadCache (bool): If True, enables the VDO device's read cache. hashZoneThreads (int): Number of threads across which to subdivide parts of VDO processing based on the hash value computed from the block data indexCfreq (int): The Index checkpoint frequency. indexMemory (str): The Index memory setting. indexSparse (bool): If True, creates a sparse Index. indexThreads (int): The Index thread count. If 0, use a thread per core logicalSize (SizeString): The logical size of this VDO volume. logicalThreads (int): Number of threads across which to subdivide parts of the VDO processing based on logical block addresses. physicalSize (SizeString): The physical size of this VDO volume. physicalThreads (int): Number of threads across which to subdivide parts of the VDO processing based on physical block addresses. readCacheSize (SizeString): The size of the read cache, in addition to a minimum set by the VDO software. slabSize (SizeString): The size increment by which a VDO is grown. Using a smaller size constrains the maximum physical size that can be accomodated. Must be a power of two between 128M and 32G. writePolicy (str): sync, async or auto. s .Service.VDOServiceu !VDOServicet VDOss Read caches Read cache sizes Acknowledgement threadss Bio submission threadss Block map cache sizes Block map periods Block sizet Compressions CPU-work threadst Deduplications Hash zone threadss Logical sizes Logical threadss MD RAID5 modes Physical sizes Physical threadss VDO statisticss Write policyt devicet blockMapCacheSizet blockMapPeriodt readCachet readCacheSizet ackThreadst vdoAckThreadst bioRotationIntervalt vdoBioRotationIntervalt bioThreadst vdoBioThreadst cpuThreadst vdoCpuThreadst hashZoneThreadst vdoHashZoneThreadst logicalThreadst vdoLogicalThreadst physicalThreadst vdoPhysicalThreadst OperationStatec B s; e Z d Z d Z d Z d Z d Z d Z e d � � Z RS( t beginCreatet beginGrowLogicalt beginGrowPhysicalt beginRunningSetWritePolicyt finishedt unknownc C s" | j | j | j | j | j g S( s� Return a list of the possible specific operation states. "Specific operation state" means a state that is specifically set via normal processing. ( R: R; R< R= R> ( t cls( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt specificOperationStates� s ( R R R: R; R< R= R> R? t classmethodRA ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR9 � s c C sZ xS | j D]H } t | | d � d k r t d � j | � } t | d t �� q q Wd S( s� Validates that any options specified in the arguments are solely those which are modifiable. Argument: args - arguments passed from the user s+ Cannot change option {0} after VDO creationt exitStatusN( t fixedOptionst getattrt NoneR t formatR R ( R@ R t optionR ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt validateModifiableOptions� s c C s� | j � | j rB t d � j | j � � } | j j | � d S| j j t d � j | j � � � t | _ | j j | j � | t � d S( sC Marks the VDO device as activated, updating the configuration. s {0} already activatedNs Activating VDO {0}( t _handlePreviousOperationFailuret activatedR RG t getNamet logt announcet Truet configt addVdo( R R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt activate� s % c C s� | j � r= | j j t d � j | j � | j � � � nP | rk | j j t d � j | j � � � n" | j s� | j j t d � � n d S( s. Logs the VDO volume state during create/start.s' VDO instance {0} volume is ready at {1}s VDO volume created at {0}s, VDO volume cannot be started (not activated)N( t runningRM RN R RG t getInstanceNumbert getPathRK ( R t wasCreated( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt announceReady� s ( c C sw | j j t d � j | j � � � | j � t d d | j � d d g � | j j t d � j | j � � � d S( s Connect to index.s Attempting to get {0} to connectt dmsetupt messaget 0s index-enables {0} connect succeededN( RM RN R RG RL RJ R ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt connect s c s� | j j t d � j | j � � � | j j d j | j j � � | j � | j r� t d � j | j � � } t | � � n | j j | j � r� t d � j | j � } t | � � n | j � r� t d � j | j � � } t | d t �� n | j | j � | j | j | j | j � | s8| j � n t j j | j � } d � g } t j j � � r&g � f d � t j � � D� D]$ } t j j | � | k r�| ^ q�} | d k r&| j | � } | d k r#| j j d j d | � � g | D] } | | k r�| ^ q�} q#q&n t | � d k r�| j j d j d | d | � � g | D]$ } t j! d | � d k ra| ^ qa} t | � d k r�| } n | j" � | d | _ | j j d j d | j � � n" | j j d j d | d � � � | j# | j$ � | j% | j& j' � t( j) � } | j* | j j+ � | j* t, j- | j j. | j � � � | j/ | � | j0 � | j% | j& j1 � d S( s Creates and starts a VDO target.s Creating VDO {0}s confFile is {0}s VDO volume {0} already existss) Device {0} already configured for VDO uses2 Name conflict with extant device mapper target {0}RC s /dev/disk/by-idc 3 s$ | ] } t j j � | � Vq d S( N( t ost patht join( t .0t name( t idDir( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pys <genexpr>9 s s pruning {uuid} from aliasest uuidi s' found aliases for {original}: {aliases}t originalt aliasess .*/[dm][dm]-uuid-s using {new}t news+ no aliases for {original} found in {idDir}!Ra N(2 RM RN R RG RL t debugRP t filepathRJ t isConstructedR t isDeviceConfiguredR& R t _mapperDeviceExistsR R t _validateAvailableMemoryt indexMemoryt _validateModifiableThreadCountsR3 R5 R7 t _createCheckCleanDeviceR\ R] t realpatht isdirt listdirRF t _getDeviceUUIDt lent ret matcht sortt _installKernelModulet vdoLogLevelt _setOperationStateR9 R: R t transactiont addUndoStaget persistt functoolst partialt removeVdot _constructVdoFormatt _constructServiceStartR> ( R t forceR Ro Rd t absnamet deviceUUIDt at uuidAliasesRz ( ( Ra s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt create sp % $ . $ " c C s� | j � | j sB t d � j | j � � } | j j | � d S| j j t d � j | j � � � t | _ | j j | j � | t � d S( sG Marks the VDO device as not activated, updating the configuration. s {0} already deactivatedNs Deactivating VDO {0}( RJ RK R RG RL RM RN t FalseRP RQ RO ( R R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt deactivateo s % c C sm | j � y# t d d | j � d d g � Wn9 t k rh | j j t d � j | j � � � � n Xd S( s* Disables deduplication on this VDO device.RX RY RZ s index-disables$ Cannot stop deduplication on VDO {0}N( RJ R RL t ExceptionRM t errorR RG ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt disconnect~ s # c C s4 | j � | j r- | j � r- | j � n | j S( s9 Returns the instance number of a vdo if running, or zero.( RJ t instanceNumberRS t _determineInstanceNumber( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRT � s c C s t j j d | j � � S( s) Returns the full path to this VDO device.s /dev/mapper( R\ R] R^ RL ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRU � s c C sx | j � | j � sF t d � j | j � � } t | d t �� n | j � | | j k r� t d � j | j � } t | d t �� n< | | j k r� t d � j t j � } t | d t �� n | j | j j � | j j t d � j | j � � � t j � } | j | j j t d � j | j � � � t d d | j � d d t | j � � g � | j d � | j � | j | j � | j j t d � j | j � � � | j | j j t d � j | j � � � | j � } | j d t | � � } t d d | j d | g � | j d � | j j t d � j | j � � � | | _ | j � | j | j j � d S( sp Grows the logical size of this VDO volume. Arguments: newLogicalSize (SizeString): The new size. s VDO volume {0} must be runningRC s( Can't shrink a VDO volume (old size {0})s. Can't grow a VDO volume by less than {0} bytess- Preparing to increase logical size of VDO {0}s) Cannot prepare to grow logical on VDO {0}RX RY RZ t prepareToGrowLogicals) Increasing logical size of VDO volume {0}s Device {0} could not be changedt numSectorst reloads --tables( Increased logical size of VDO volume {0}N( RJ RS R RG RL R R t roundToBlockt logicalSizeR R t VDO_BLOCK_SIZERy R9 R; RM t infoR Rz t setMessageR� R t strt toBlocksRF t _suspendR{ t _resumet toSectorst _generateModifiedDmTablet _nameR> ( R t newLogicalSizeR Rz R� t vdoConf( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt growLogical� sN c C s� | j � | j � sF t d � j | j � � } t | d t �� n | j | j j � | j j t d � j | j � � � t j � } | j | j j t d � j | j � � � t d d | j � d d g � | j d � | j � | j | j � | j | j j t d � j | j � � � t d d | j � d d g � | j d � | j � } | d t j } | d | } t d j | � � | _ | j � | j | j j � d S( s� Grows the physical size of this VDO volume. Arguments: newPhysicalSize (SizeString): The new size. If None, use all the remaining free space in the volume group. s VDO volume {0} must be runningRC s. Preparing to increase physical size of VDO {0}s* Cannot prepare to grow physical on VDO {0}RX RY RZ t prepareToGrowPhysicals Cannot grow physical on VDO {0}t growPhysicalt blockSizet physicalBlockss {0}sN( RJ RS R RG RL R R Ry R9 R< RM R� R Rz R� R� R RF R� R{ R� t _getConfigFromVDOR t SECTOR_SIZER t physicalSizeR> ( R R Rz t vdoConfigt sectorsPerBlockR� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s8 c C sm | j � y# t d d | j � d d g � Wn9 t k rh | j j t d � j | j � � � � n Xd S( s) Enables deduplication on this VDO device.RX RY RZ s index-enables% Cannot start deduplication on VDO {0}N( RJ R RL R� RM R� R RG ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt reconnect s # c C s] | j j t d � j | j � � � y t j | j � Wn> t k ry | sz t d � j | j � } t | � � qz n Xg } y' | j | | � | s� | j � n Wn� t k r)| d k r#t | � d k r#| j t d � j | j � � � | j g | D] } d j | � ^ q� n � n X| j j | j � � | j � sY| j � n d S( s% Removes a VDO target. If removeSteps is not None it as an empty list to which the processing commands for removal will be appended. If force was not specified and the instance previous operation failure is not recoverable VDOServicePreviousOperationError will be raised. s Removing VDO {0}s. Device {0} not found. Remove VDO with --force.i s Steps to clean up VDO {0}:s {0}N( RM RN R RG RL R\ t statR& t OSErrorR t stopRJ R! RF Rs t appendt extendRP R t _hasHolderst _clearMetadata( R R� t removeStepsR t localRemoveStepst s( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt remove s, % , c C sQ y8 t d d d t j | j � g � } | j � d k SWn t k rL t SXd S( s- Returns True if the VDO service is available.RX t statuss --targett N( R R t vdoTargetNameRL t stripR� R� ( R t result( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRS I s c C s[ | j j t d � j | j � � � | j � | j sa | j j t d � j | j � � � d S| j � r� t j � r� | j j t d � j | j � � � d S| j | j � | j � | j � yT| r y | j � Wq t k r| j j t d � j | j � � � � q Xn t d d | j d | j � d | j � g � | j syy | j � Wqyt k ruqyXn | j � | j r�| j j t d � j | j � | j � � n y | j r�| j � n Wn9 t k r| j j t d � j | j � � � � n X| j � Wn9 t k rV| j j t d � j | j � � � � n Xd S( s� Starts the VDO target mapper. In noRun mode, we always assume the service is not yet running. Raises: ServiceError s Starting VDO {0}s VDO service {0} not activatedNs VDO service {0} already starteds Device {0} not read-onlyRX R� s --uuids --tables$ started VDO service {0} instance {1}s$ Could not enable compression for {0}s& Could not set up device mapper for {0}( RM RN R RG RL RJ RK R� RS R t noRunModeRk Rl Rw t _checkConfigurationt _forceRebuildR� R� R R� t _getUUIDt _generateDeviceMapperTablet enableDeduplicationR� R� R� t enableCompressiont _startCompressiont _startFullnessMonitoring( R t forceRebuild( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt startV sT % % % c C s� | j � i } | j | t d � <t | j � | | j <| j | | j <t j | | j <t j | j d k � | t d � <t j | j � | t d � <t j | j � | | j <t | j � | | j <t j | j � | | j <t j | j � | | j <t | j � | | j <t | j � | | j <| j | | j <| j | | j <| j | t d � <| j | | j <| j! | | j" <| j# | | j$ <| j% | | j& <t | j' � | t d � <| j( | t d � <| j) | t d � <| j* | t d � <| j+ | t d � <t j | j, � | t d � <| j- � | t d � <t. j/ � d k r�t0 j1 d d | j2 � g � | t d � <y5 t3 d d | j4 � g � } t5 j6 | � | | j7 <Wq�t8 k r�t d � | | j7 <q�Xn | S( sA Returns a dictionary representing the status of this object. s Storage devicei s Emulate 512 bytet Activates Bio rotation intervals Slab sizes Configured write policys Index checkpoint frequencys Index memory settings Index parallel factors Index sparses Index statusi RX R� s Device mapper statust vdostatss --verboses not available(9 RJ R& R R� R' t vdoBlockMapCacheSizeKeyR( t vdoBlockMapPeriodKeyR R� t vdoBlockSizeKeyt enableStringt logicalBlockSizeRK t enableReadCachet readCacheKeyR* t readCacheSizeKeyR� t vdoCompressionEnabledKeyR� t vdoDeduplicationEnabledKeyR� t vdoLogicalSizeKeyR� t vdoPhysicalSizeKeyR+ t vdoAckThreadsKeyR/ t vdoBioSubmitThreadsKeyR- R1 t vdoCpuThreadsKeyR3 t vdoHashZoneThreadsKeyR5 t vdoLogicalThreadsKeyR7 t vdoPhysicalThreadsKeyt slabSizet writePolicyt indexCfreqRl t indexThreadst indexSparset _getDeduplicationStatusR\ t getuidR t statusHelperRL R RU t yamlt safe_loadt vdoStatisticsKeyR� ( R R� R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � sR c C s< | j j t d � j | j � � � | } | s\ y | j � t } Wq\ t k rX q\ Xn | r� | j � r� t j � r� | j r� | j j t d � j | j � � � d Sn | j � } | r | j � r t d � j | j � � } t | d t �� n | r| j � s| r�d d | j � g } | d k rS| j d j | � � n | r�| rrt | d t �q�t d � j | j � � } t | d t �� q�n d d g } | d k r�| j d j | � � n | r�| r�t | d t �n | r| j | | � n d d | j � g } | d k rH| j d j | � � n t } | r�| r�xh t d � D]W } y t | � d SWn/ t k r�} d t | � k r�t } Pq�n Xt j d � qgWn | s�| j � n | j � r8| rt d � j | j � � } n t d � j | j � � } t | d t �� n d S( s� Stops the VDO target mapper. In noRun mode, assumes the service is already running. If removeSteps is not None it is a list to which the processing commands will be appended. If force was not specified and the instance previous operation failed VDOServicePreviousOperationError will be raised. Raises: ServiceError VDOServicePreviousOperationError s Stopping VDO {0}s VDO service {0} already stoppedNs" cannot stop VDO volume {0}: in useRC t umounts -ft t noThrows& cannot stop VDO volume with mounts {0}t udevadmt settleRX R� i s Device or resource busyi s* cannot stop VDO service {0}: device in uses cannot stop VDO service {0}( RM RN R RG RL RJ RO R! RS R R� t previousOperationFailureR� R� R R t _hasMountsRU RF R� R^ R t _stopFullnessMonitoringt rangeR� R� R� t timet sleept) _generatePreviousOperationFailureResponseR ( R R� R� t executeRS R t commandt inUset unused_it ex( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � sr % c C s� | j | r d n d d � | j � | r5 | j sF | r� | j r� d j | rX d n d � } | j j t | � | j � � d S| | _ | j j | j � | t � | j r� | j � n | j � d S( so Changes the compression setting on a VDO. If the VDO is running the setting takes effect immediately. t Enablingt Disablingt compressions compression already {0} on VDO t enabledt disabledN( t _announceRJ R� RG RM R� R RL RP RQ RO R� t _stopCompression( R t enableRY ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt setCompression" s c C s | | _ t | _ d S( s3 Sets the configuration reference and other attributes dependent on the configuration. This method must tolerate the possibility that the configuration is None to handle instantiation from YAML representation. At present, there is nothing for which we attempt to use the configuration. N( t _configR� t _configUpgraded( R RP ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt setConfig9 s c C s� | j | r d n d d � | j � | r5 | j sF | r� | j r� d j | rX d n d � } | j j t | � | j � � d S| | _ | j j | j � | t � | j � r�| j r�| j � d } xC t t j � D]2 } | j � } | t j k rt j d � q� Pq� W| t j k r'q�| t j k r`t t d � j | j � � d t �� q�| t j k r�t d � j | j � � } | j j | � q�t d � j | | j � � } t | d t �� q�| j � n d S( sq Changes the deduplication setting on a VDO. If the VDO is running the setting takes effect immediately. R� R� t deduplications! deduplication already {0} on VDO R� R� Ni s$ Error enabling deduplication for {0}RC s2 Timeout enabling deduplication for {0}, continuings; Unexpected kernel status {0} enabling deduplication for {0}( R� RJ R� RG RM R� R RL RP RQ RO RS R� RF R� R t DEDUPLICATION_TIMEOUTR� t deduplicationStatusOpeningR� R� t deduplicationStatusOnlinet deduplicationStatusErrorR R t warnR� ( R R� RY R� t _i( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt setDeduplicationF sB c C s� | j � | j t | d | j � t | d | j � t | d | j � � t } xO | j D]D } t | | d � } | d k rZ t | | j | | � t } qZ qZ W| r� | j j | j � | t � | j � r� | j j t d � j | j � � � q� n d S( s� Sets any of the modifiable options that are specified in the arguments. Argument: args - arguments passed from the user Raises: ArgumentError R4 R6 R8 s7 Note: Changes will not apply until VDO {0} is restartedN( RJ Rm RE R3 R5 R7 R� t modifiableOptionsRF t setattrRO RP RQ RL RS RM RN R RG ( R R t modifiedRH t value( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt setModifiableOptionss s& c C s� | j � | | j k r� | | _ | j � sM | j j | j � | t � q� | j | j j � | j � | j | j j � n d S( sa Changes the write policy on a VDO. If the VDO is running it is restarted with the new policyN( RJ R� RS RP RQ RL RO Ry R9 R= t _performRunningSetWritePolicyR> ( R t policy( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt setWritePolicy� s c C sO d d d d d d d d d d d d d d d d d d d d d d d d d g S( s8 Returns the list of standard attributes for this object.R+ RK R- R/ R' R( R1 R� R R& R3 R� Rl R� R� R� R� R5 t _operationStateR� R7 R) R* R� R� ( ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt getKeys� s2 c C s | d d � S( Nt YAMLInstance( RF ( R@ ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt _yamlMakeInstance� s c C s� t t | � j } t j | j � | d <t | j � | d <t j | j � | d <t j | j � | d <t j | j � | d <t | j � | d <t | j � | d <t j | j � | d <t | j � | d <t | j � | d <| j | d <| S( NRK R' R� R R� R� R� R) R* R� R� ( R R" t _yamlDataR R� RK R� R' R� R� R� R� R� R� R* R� R� ( R t data( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR � s c C s� t t | � j | � | j | d t j | j � � t j k | _ t | j | d | j j � � | _ | j | d t j | j � � t j k | _ | j | d t j | j � � t j k | _ | j | d t j | j � � t j k | _ t | j | d | j j � � | _ t | j | d | j j � � | _ | j | d t j | j � � t j k | _ t | j | d | j j � � | _ t | j | d | j j � � | _ d | k r�| d | _ n d S( NRK R' R� R R� R� R� R) R* R� R� ( R R" t _yamlSetAttributest _defaultIfNoneR R� RK R� R R' t toBytesR� R� R� R� R� R� R* R� R� ( R t attributes( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR � s> ! ! c C sD t t | � j } | j d d d d d d d d d d d g � | S( NRK R' R� R R� R� R� R) R* R� R� ( R R" t _yamlSpeciallyHandledAttributesR� ( R t specials( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR s c C s� | d k r | j � S| d k r, | j � S| d k rB | j � S| d k rX | j � S| d k rz t t | � j | � S| d k r� | j � S| d k r� | j � St d j d t | � j d | � � � d S( NRP Rh t operationStateR� Rl t% unrecoverablePreviousOperationFailureR� s( '{obj}' object has no attribute '{attr}'t objt attr( t _computedConfigt _computedIsConstructedt _computedOperationStatet! _computedPreviousOperationFailureR R" t __getattr__t. _computedUnrecoverablePreviousOperationFailuret _computedWritePolicyt AttributeErrorRG t typeR ( R R` ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR& - s c K sU t t | � j | � | j | � | j j | _ d | _ | j d � | _ | j | d t j � | _ | j | d t j � | _ | j | d t j � | _ | j | d t j � | _ | j | d t j � | _ | j | d t j � | _ t j | _ | j | d t j � } | t j k r.d | _ n | j | d t j � } | t j k | _ | j | d t j � } | t j k | _ | j | d t j � } | t j k | _ | j | d t j � | _ | j d t d � � | _ | j | d t j! � | _! t j" | _" t d � | _# | j | d t j$ � | _$ | j | d t j% � } | t j k | _& | j | d t j' � | _' | j | d t j( � | _( | j | d t j) � | _* t+ | _, d | _- | j d � | _. | j | d t j/ � | _0 | j1 | j | d t j2 � � | j | d t j3 � } | t j k | _4 | j | d t j5 � | _6 d S( NR& R, R. R0 R' R( R2 t emulate512i R� R RR R4 t vdoLogicalSizeRZ R6 R8 R) R* t vdoSlabSizeR� i Rx t cfreqt indexMemt sparseIndext udsParallelFactor(7 R R" R R R9 R? R RF t _previousOperationFailuret getR& R R R+ R- R/ R' R( R1 R R� R� R+ R� R� R� R R� RR RK R3 R R� R5 t mdRaid5ModeR� R7 R) R� R* R� R� t _writePolicyR� t _writePolicySetR� Rx R. R� t _setMemoryAttrR/ R0 R� R1 R� ( R R` t conft kwR+ R� R RR R) t sparse( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR D sr c C s� | d k r! | t j k | _ ne | d k r= | j | � nI | d k r^ | | _ t | _ n( | d k rm n t t | � j | | � | d k r� t | | � j � n d S( NR) Rl R� t identifierR� R� ( s logicalSizes physicalSize( R R� R� R7 R5 RO R6 R R" t __setattr__RE R� ( R R` R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR< � s c C s# | j | � } | d k r | S| S( N( R3 RF ( R R` t defaultR ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR � s c C s6 d j | | � } | j j t | � | j � � d S( Ns {0} {1} on VDO ( RG RM RN R RL ( R t actionRH RY ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s c C s� | j j � } | d | j k rR t d � j | j � � } t | d t �� n t | j t j � | _ t | j t j � | _ d S( sQ Check and fix the configuration of this VDO. Raises: ServiceError i i s$ Insufficient block map cache for {0}RC Ni ( R' R� R5 R RG RL R R t maxR( R t blockMapPeriodMint mint blockMapPeriodMax( R t cachePagesR ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s c C s� yK t j | j � j } t j | � sJ | j j d j d | j � � d SWn9 t k r� } | j j d j d | j d | � � d SXd d d j d | j � d d d g } t | � d S( s. Clear the VDO metadata from the storage devices- Not clearing {devicePath}, not a block devicet devicePathNs, Not clearing {devicePath}, cannot stat: {ex}R� t dds if=/dev/zeros of={devicePath}s oflag=directs bs=4096s count=1( R\ R� R& t st_modet S_ISBLKRM Rf RG R� R ( R t modeR� R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s" c C s� d d l m } | j s� d } y | j j | j � � } Wn t k rN n2 X| j | j j k r� | j | j j d t �n t | _ n | j S( s[ Update the instance properties as necessary and return the configuration instance. i ( t ConfigurationR| N( R� RI R RF R� t getVdoRL R R R9 R? Ry R> R� RO ( R RI t service( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR" � s c C s | j | j j k S( sY Returns a boolean indicating if the instance represents a fully constructed vdo. ( R R9 R> ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR# � s c C s= | } y | j j | j � � } Wn t k r5 n X| j S( s� Return the operation state of the instance. If there is an instance in the configuration the state reported is from that instance else it's from this instance. ( RP RJ RL R R ( R RK ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR$ � s c C sF | j d k r? | j | j j k o6 | j | j j k | _ n | j S( sC Returns a boolean indicating if the instance operation failed. N( R2 RF R R9 R? R> ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR% s c C s | j o | j | j j k S( sh Returns a boolean indicating if a previous operation failure cannot be automatically recovered. ( R� R R9 R: ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR' s c C sI | } | j sB y | j j | j � � } WqB t k r> qB Xn | j S( s� Return the write policy of the instance. If this instance's write policy was not explicitly set and there is an instance in the configuration the write policy reported is from that instance else it's from this instance. ( R6 RP RJ RL R R5 ( R RK ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR( # s c C s) | j j � } t t j | d � d � S( sC Compute the --slab-bits parameter value for the slabSize attribute.i g�������?( R� R� t intt mathRM ( R t blocks( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt _computeSlabBits4 s c C sI | j j d j | j � � � t j � } | j � | j | j � d S( Ns construction - starting; vdo {0}( RM Rf RG RL R Rz R� R{ R� ( R Rz ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� ; s c C s� | j j d j | j � � � t j � } | j | � | j | j � | j � } | d t j } | d | } t d j | � � | _ | d | } t d j | � � | _ d S( Ns1 construction - formatting logical volume; vdo {0}R� R� s {0}st logicalBlocks( RM Rf RG RL R Rz t _formatTargetR{ R� R� R R� R R� R� ( R R� Rz R� R� R� R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� C s c C s� y# t d d d d d | j g � Wnt k r*} g | j � j � D] } | j � ^ qH } t | � } | d k r!x� t | � D]� } t j d | | � d k r� x[ | | d D]K } t j d | � } | d k r� t d j | j d � � d t �� q� q� WPq� q� W| j | d � n | � n Xy t d d | j g � Wn) t k rp} | j � d k rqd Sn Xt d d d t �� d S( s� Performs a verification for create that the storage device doesn't already have something on it. Raises: VDOServiceError t pvcreates --configs devices/scan_lvs=1s -qqs --testi s ^TEST MODEi s' WARNING: (.* detected .*)\.\s+Wipe it\?s {0}; use --force to overrideRC i����t blkids -pi Ns device is a physical volume;s use --force to override( R R& R t getStandardErrort splitlinesR� Rs R� Rt Ru RF R RG t groupR R� t getExitCode( R t et linet linest lineCountt it detectionMatch( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRn S s6 + c C s� d j | j � � } y7 t | d � �" } t | j � j � � | _ Wd QXWn; t k r� } | j j t d � j | j � | � � n Xd S( s; Determine the instance number of a running VDO using sysfs.s /sys/kvdo/{0}/instancet rNs8 unable to determine VDO service {0} instance number: {1}( RG RL t openRL t readR� R� R� RM t warningR ( R R] t ft err( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s % c C s t d | j g � d S( sa Calls vdoforcerebuild to exit read-only mode and force a metadata rebuild at next start. t vdoforcerebuildN( R R& ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s c C s$ d g } | j d t | j � � | j } | d k rD t j } n | j s\ t j | _ n | j d t | � � | j r� | j d � n | j j � d k r� | j d | j j � � n | j t j k r� | j d t | j � � � n | r| j d � n | j | j � t | � d S( s Formats the VDO target.t vdoformats --uds-checkpoint-frequency=g s --uds-memory-size=s --uds-sparsei s --logical-size=s --slab-bits=s --forceN( R� R� R� Rl R R/ R� R� R� R t asLvmTextRO R& R ( R R� t commandLinet memVal( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRQ � s$ c C s | j j � } | j j � } d j d t | j � d t | j � d t | j � d t | j � d t | j � d t | j � d t | j � g � } d j d t | � t j | j t | j � t j | j � t | j j � � t | � t | j � | j | j | j | g � } | S( sR Generate the device mapper table line from the properties of this object. t ,s ack=s bio=s bioRotationInterval=s cpu=s hash=s logical=s physical=R� RZ ( R� R� R' R� R^ R� R+ R/ R- R1 R3 R5 R7 R R� R& R� R R� R� R* R( R4 R� R� ( R R� RC t threadCountConfigR� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s( c K s� t d d | j g � j � } | j j | � d d d d } t t | j d � | j d � � � } x$ | j � D] \ } } | | | <qt Wd j g | j d � D] } | | ^ q� � S( s� Changes the specified parameters in the dmsetup table to the specified values. Raises: CommandError if the current table cannot be obtained Returns: a valid new dmsetup table. RX t tables8 logicalStart numSectors targetName storagePath blockSizes5 readCache readCacheBlocks cacheBlocks blockMapPeriods! mdRaid5Mode writePolicy poolNames threadCountConfigR� ( R R� t rstripRM R� t dictt zipt splitt iteritemsR^ ( R R Rk t tableOrdert dmTablet keyt val( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s 'R� c C sC t d � j | j � | | d k r* d n d � } t | � � d S( s� Generates the required response to a previous operation failure. Logs a message indicating that the previous operation failed and raises the VDOServicePreviousOperationError exception with the same message. Arguments: operation (str) - the operation that failed; default to "create" as that is currently the only operation that is not automatically recovered Raises: VDOServicePreviousOperationError s8 VDO volume {0} previous operation ({1}) is incomplete{2}R� s( ; recover by performing 'remove --force'R� N( R RG RL R! ( R t operationR ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s c C s? | j s2 | j j t d � j | j � � � d S| j | j j � k r� t d � j | j � | j � } t | d t �� n� | j | j j k r� | j � n� | j | j j k r� | j � nn | j | j j k r� | j � nL | j | j j k r| j � n* t d � j | j � } t | d t �� t | _ d S( sB Handles a previous operation failure. If the failure can be corrected automatically it is. If not, the method logs a message indicating that the previous operation failed and raises the VDOServicePreviousOperationError exception with the same message. Raises: VDOServicePreviousOperationError if the previous operation failure is a non-recoverable error. VDOServiceError if unexpected/unhandled operation state is encountered. Excepting corruption or incorrect setting of state this indicates that the developer augmented the code with an operation (new or old) which can experience a catastrophic failure requiring some form of recovery but failed to update specificOperationStates() and/or failed to add a clause to this method to address the new failure. s0 No failure requiring recovery for VDO volume {0}Ns. VDO volume {0} in unknown operation state: {1}RC s5 Missing handler for recover from operation state: {0}( R� RM Rf R RG RL R R9 RA R R R: R� R; t _recoverGrowLogicalR< t _recoverGrowPhysicalR= t _recoverRunningSetWritePolicyR� R2 ( R R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRJ � s, c C s� | } t j | t j � s< t t d � j d | � � � n t j t j | � j � r� t d d | g � } | j � j � } n | d k r� t t d � j d | � � � n | S( s� Take the server name and convert it to a device name that can be opened from the kernel Arguments: devicePath (path): path to a device. Raises: ArgumentError s {path} does not existR] t readlinks -fR� s {path} could not be resolved( R\ t accesst F_OKR R RG R� t S_ISLNKt lstatRF R t runR� ( R RD t resolvedPatht cmd( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt _getBaseDevice, s c C s& t j t d | j g � � } | d S( sb Returns a dictionary of the configuration values as reported from the actual vdo storage. t vdodumpconfigt VDOConfig( R� R� R R& ( R RP ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� C s c C s* t j t d | j g � � } d | d S( s> Returns the uuid as reported from the actual vdo storage. R� s VDO-t UUID( R� R� R R& ( R RP ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� L s c C sb t d � } y> t d d | j � g � } | j d � } | t j j } Wn t k r] n X| S( Ns not availableRX R� R� ( R R RL Ro R t dmsetupStatusFieldst deduplicationStatusR� ( R R� t outputt fields( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� T s c C sq y( t d d d d d | g � j � } Wn. t k rX } | j j d t | � � d SX| d k ri d S| Sd S( s� Get the UUID of the device passed in, Arguments: devicePath (path): path to a device. Returns: UUID as a string, or None if none found RS s -sR� s -oR s blkid failed: R� N( R R� R RM R� R� RF ( R RD R� R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRr a s c C s� y= t j | j � � } t j | j � } t j | j � } Wn t k rQ t SXd j d | d | � } t j j | � r� t j | � } t | � d k r� | j j d j d | j � d d j | � � � t Sn t S( s� Tests whether other devices are holding the VDO device open. This handles the case where there are LVM entities stacked on top of us. Returns: True iff the VDO device has something holding it open. s& /sys/dev/block/{major}:{minor}/holderst majort minori s& {path} is being held open by {holders}R] t holdersR� ( R\ R� RU R� t st_rdevR� R� R� RG R] Rp Rq Rs RM R� R^ RO ( R t stR� R� t holdersDirectoryR� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� v s c C sr t d g d t �} | rn t j d t j | j � � d � } x* | j � D] } | j | � rN t SqN Wn t S( s� Tests whether filesystems are mounted on the VDO device. Returns: True iff the VDO device has something mounted on it. t mountR� s (\A|\s+)s \s+( R RO Rt t compilet escapeRU RU t searchR� ( R t mountListt matcherRY ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� � s & c C ss t � } y | j � Wn9 t k rR | j j t d � j | j � � � � n X| d k ro | j | � n d S( s� Install the kernel module providing VDO support. Arguments: logLevel: the level of logging to use; if None, do not set level s Kernel module {0} not installedN( R R� R� RM R� R RG RL RF t setLogLevel( R t logLevelt kms( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRw � s c C s4 y t j | j � � t SWn t k r/ t SXd S( sO Returns True if there already exists a dm target with the name of this VDO.N( R\ R� RU RO R� R� ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRj � s c C s� t j � } | j � | j | j � | j | j j t d � j | j � � � | j d | j � } | j | j j t d � j | j � � � t d d | j d | g � | j d � | j � d S( sH Peforms the changing of the write policy on a running vdo instance. s Device {0} could not be readR� s Device {0} could not be changedRX R� s --tableN( R Rz R� R{ R� R� RM R� R RG RL R� R� R R� RF ( R Rz R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR � s c C s� | j s1 | j j t d � j | j � � � n� | j | j j k rv t d � j | j � � } t | d t �� ni | j � } | d | d t j } t d j | � � | _ | j � r� | j � n | j | j j � d S( sc Recovers a VDO target from a previous grow logical failure. Raises: VDOServiceError s5 No grow logical recovery necessary for VDO volume {0}sC Previous operation failure for VDO volume {0} not from grow logicalRC RP R� s {0}sN( R� RM Rf R RG RL R R9 R; R R R� R R� R R� RS R� Ry R> ( R R R� R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRv � s c C s� | j s1 | j j t d � j | j � � � n� | j | j j k rv t d � j | j � � } t | d t �� ni | j � } | d | d t j } t d j | � � | _ | j � r� | j � n | j | j j � d S( sd Recovers a VDO target from a previous grow physical failure. Raises: VDOServiceError s6 No grow physical recovery necessary for VDO volume {0}sD Previous operation failure for VDO volume {0} not from grow physicalRC R� R� s {0}sN( R� RM Rf R RG RL R R9 R< R R R� R R� R R� RS R� Ry R> ( R R R� R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRw � s c C s� | j s1 | j j t d � j | j � � � nq | j | j j k rv t d � j | j � � } t | d t �� n, | j � r� | j � n | j | j j � d S( s� Recovers a VDO target from a previous setting of write policy against a running VDO. Raises: VDOServiceError s9 No set write policy recovery necessary for VDO volume {0}sG Previous operation failure for VDO volume {0} not from set write policyRC N( R� RM Rf R RG RL R R9 R= R R RS R Ry R> ( R R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRx s c C s� | j j t d � j | j � � � y t d d | j � g � Wn> t k r� } | j j t d � j | j � | � � � n X| j � | j j t d � j | j � � � d S( s Resumes a suspended VDO.s Resuming VDO volume {0}RX t resumes" Can't resume VDO volume {0}; {1!s}s Resumed VDO volume {0}N( RM R� R RG RL R R� R� R� ( R R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� , s % c C sD t | � } | d k r' t | � } n t t | � j d | � d S( Ng �?Rl ( t floatRL R R" R< ( R R t memory( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR7 9 s c C sB | | _ | r> | j j | j � | d t �| j j � n d S( Nt replace( R RP RQ RL RO R| ( R t stateR| ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRy B s c C s | j t � d S( s9 Starts compression on a VDO volume if it is running. N( t _toggleCompressionRO ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� I s c C sZ y t d d | j � g � Wn6 t k rU | j j t d � j | j � � � n Xd S( Nt vdodmeventds -rs$ Could not register {0} with dmeventd( R RL R� RM R� R RG ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� O s c C s | j t � d S( s8 Stops compression on a VDO volume if it is running. N( R� R� ( R ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� X s c C sW d d | j � g } | d k r: | j d j | � � n | rS t | d t �n d S( NR� s -uR� R� ( RL RF R� R^ R RO ( R R� R� R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� ^ s c C s� | j j t d � j | j � � � | j t d � y t d d | j � g � Wn> t k r� } | j j t d � j | j � | � � � n X| j j t d � j | j � � � d S( s Suspends a running VDO.s Suspending VDO volume {0}RX t suspends# Can't suspend VDO volume {0}; {1!s}s Suspended VDO volume {0}N( RM R� R RG RL R� RO RF R R� R� ( R R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� f s % c C sv | j � s d S| j j t d � j | r1 d n d | j � � � t d d | j � d d | rh d n d g � d S( s� Turns compression on or off if the VDO is running. Arguments: enable (boolean): True if compression should be enabled Ns {0} compression on VDO {1}t Startingt StoppingRX RY RZ R� t ont off( RS RM RN R RG RL R ( R R� ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR� s s c C s t d j t j t | � � � � } d } yu t d d d g � } xY | j � D]K } t j d | � } | d k rO | j d � } t d j | � � } qO qO WWn t k r� n X| d k r� | j j d � d S| j � | j � k r t t d j d | � � � � n d S( s= Validates whether there is likely enough kernel memory to at least create the index. If there is an error getting the info, don't fail the create, just let the real check be done in vdoformat. Arguments: indexMemory - the amount of memory requested or default. Raises: ArgumentError s {0}gt grept MemAvailables /proc/meminfos MemAvailable:\s*(\d+)i s {0}ks# Unable to validate available memoryNsG Not enough available memory in system for index requirement of {needed}t needed( R RG t localeR� R� RF R RU Rt Ru RV R� RM R� R R R ( R Rl t memoryNeededt memoryAvailableR� RY R� t available( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRk � s" $ c C s� | d k r | j } n | d k r0 | j } n | d k rH | j } n | d k sl | d k sl | d k r� | d k o� | d k o� | d k r� t t d � � � n d S( sY Validates that the hash zone, logical and physical thread counts are consistent (all zero or all non-zero). Arguments: hashZone - hash zone thread count to use, may be None logical - logical thread count to use, may be None physical - physical thread count to use, may be None Raises: ArgumentError i sR hash zone, logical and physical threads must either all be zero or all be non-zeroN( RF R3 R5 R7 R R ( R t hashZonet logicalt physical( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyRm � s $%N(r R R R R t getLoggert mynameRM t yaml_tagt vdosKeyR R� R� R� R� R� R� R� R� R� R� R� R� R� t vdoMdRaid5ModeKeyR� R� R� t vdoWritePolicyKeyRD R t objectR9 RB RI RR RO RW R[ R R� R� R� R� RT RU R� R� R� RF R� RS R� R� R� R� R R R R t staticmethodR R t propertyR R R R& R R< R R� R� R� R" R# R$ R% R' R( RO R� R� Rn R� R� RQ R� R� R� RJ R� R� R� R� Rr R� R� Rw Rj R Rv Rw Rx R� R7 Ry R� R� R� R� R� R� Rk Rm ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyR" g s� ( a :3 8 ; 2_ - $ 7 J 1 0 "(% R R� R R R R R R R R R R R R R t utilsR R R R R R} R� RM R\ Rt t socketR R� R� R� R R R R R! R" ( ( ( s; /usr/lib/python2.7/site-packages/vdo/vdomgmnt/VDOService.pyt <module> s4
| ver. 1.4 |
.
| PHP 8.1.32 | Generation time: 0 |
proxy
|
phpinfo
|
Settings