관리-도구
편집 파일: cmdline.cpython-39.pyc
a B�:f�9 � : @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z d dl m Z m Z d dl mZ d dlZd dlmZmZmZmZmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z" d dl#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z. g d�Z/ej0�r e1Z2zd dl3m4Z4 W n e5�yL d dl6m4Z4 Y n0 da7�dkdd �Z8d d � Z9d d � Z:dd� Z;dd� Z<dZ=dd� Z>dd� Z?dd� Z@dd� ZAdd � ZB�dld d �ZCd d!� ZDd"d#� ZEG d$d%� d%eF�ZG�dmd(d)�ZHd*d+� ZIG d,d-� d-�ZJd.d/� ZKg d0�ZLd1ZMd2d3�NeM� ZOd4ZPd5d3�NeP� ZQd6d7gZRd8d3�NeR� ZSeTd9d:eSeRe>d;�ZUg d<�ZVd=d3�NeV� d> d? ZWeTd9d:eWeVe>d;�ZXd@ZYeTdAdBdCdD�ZZeZ�[� Z\dEe\dF< eTdGdHdIdD�Z]e]�[� Z^dJe^dF< eTdKdLdMdD�Z_e_�[� Z`dNe`dF< eTdOdPdQdD�Zaea�[� ZbdRebdF< eTdSdTdUdD�Zcec�[� ZddVeddF< eTdWdXdYe;dZ�ZeeTd[d\d]dD�ZfeTd^d_d`dD�ZgeTdadbdcdD�ZheTdddedfdD�ZieTdgdheYdD�ZjeTdidjdkdD�ZkeTdldmdndo�ZleTdpdqdrdo�ZmeTdsdtdueAdv�ZneTdwdxeTdydzd{�NeL� d| d}eLe>d~�geTe\�eTe^�eTe`�eTei�eTed�eTeb�eTeh�eTek�gd�eTd�d�eTd�d�d�dD�gd��eTd�d�eTeZ�gd��eTd�d�d��eTd�d�eTd�d�d�do�eTej�eTe]�geTd�eOd�eMe>d��gd�eTd�d�eTd�d�d�do�eTddd�d�d�d��eTd�d�d{�Ne)jo� e)joe>d��geTd�d�eY d��gd�eTd�d�eTeZ�gd��eTd�d�eTe_�gd��eTd�d�eTe_�eTdgd�d�eY dD�gd��eTd�d�eTe_�eTd�d�d�dD�eTd�d�eQePd��geTdGd�d��gd�eTd�d�eTd�d�d�dD�eTd�d�d�dD�eTd�d�d�d�d�gd��eTd�d�d�d�e<d��eTd�d�d�d�e<d��eTd�d�d�d�e<d��gd��eTd�d�eTeZ�gd��eTd�d�eTe_�gd��eTd�d�eTe_�gd��eTd�d�eTe_�gd��eTd�d�eTe_�eTec�gd��eTd�d�eTec�eTe_�gd��eTd�d�eTe_�gd��eTd�d�eTe_�gd��eTd�d�eTe_�gd��eTd�d�eTdKdLd�dD�gd��eTd�d�eTdKdLd�dD�gd��eTd�d�eTdAdBd�dD�eTd�d�e<d�gd��eTd�d�eTe]�gd��eTd�d�eTd�d�d�dD�eTee�eTeZ�gd��eTd�d�eTec�eTee�gd��eTd�d�eTec�eTee�gd��eTd�d�eTec�gd��eTd�d�eTec�gd��eTd�d�eTee�geTd�d�d�dD�eTd�d�d�dD�eTd�d�d�dD�eTd�d�d�dD�gd�eTd�d�eTd�d��d dD�eTej�eTe]�gd��eT�d�deTea�gd��eT�d�deTea�eTdgd�d�eY dD�gd��eT�d�deTea�geT�d�d�d dD�eT�d �d �d e jpe<�d �eT�d�d�de jpe<�d �eT�d�d�ddD�eT�d�d�dd�g eI�d�eT�d�d�dd�g eI�d�eT�d�d �d d�g eI�d�gd�eT�d �d eTeg�gd��eT�d �d!eT�d"�d#�d$dD�eT�d%�d&�d'dD�geT�d(�d)�d*dD�gd�eT�d+�d,eTd��d-�d.dD�eTea�gd��eT�d/�d0eTef�eTea�gd��eT�d1�d2eTef�eTea�geT�d3�d4�d5d�g �d6�eT�d7�d8�d9d�g �d6�gd�eT�d:�d;eTea�geT�d3�d4d�g �d<�d=�gd�eT�d>�d?eTea�geT�d3d�g �d@�dA�gd�eT�dB�dCeTea�eT�dD�dE�dFdD�eT�dG�dH�dIdD�geT�d(�d*d��gd�eT�dJ�dKg g d�eT�dL�dMg g d�eT�dN�dOeTe_�gd��eT�dP�dQeTe_�eTeU�gd��eT�dR�dSeTe_�eTeU�gd��eT�dT�dUeTe_�eTeX�gd��eT�dV�dWeTel�gd��eT�dX�dYeTel�gd��eT�dZ�d[eTel�gd��eT�d\�d]eTel�gd��eT�d^�d_eTem�eTen�gd��f5ZqeT�d`�da�db�dc�dd�de�dfd�d�d�d�d�d�d�d�d�d�d�d�d�d�d�d�d�d�d�d�dJ�dg�dN�dP�dR�dT�dV�dX�dZ�d\�dh�%ZrG �di�dj� �djes�ZtdS (n � N)�ArgumentParser�ArgumentTypeError)�RawTextHelpFormatter)�Client�Pool�VERSION�LsmError�Disk�Volume� JobStatus� ErrorNumber� BlockRange� uri_parse�Proxy�size_human_2_size_bytes� AccessGroup� FileSystem� NfsExport� TargetPort� LocalDisk�Battery) � DisplayData�PlugData�out�vol_provision_str_to_type�vol_rep_type_str_to_type�VolumeRAIDInfo� PoolRAIDInfo�VcrCap� LocalDiskInfo�VolumeRAMCacheInfo�LocalLedSlotInfo)�local-disk-list�local-disk-ident-led-on�local-disk-ident-led-off�local-disk-fault-led-on�local-disk-fault-led-off�local-led-slot-list�local-led-slot-set)� OrderedDictc C s� d}d}�zFzt � }|�| � W n� tyb } z*tj�t|�� tj�� d}W Y d}~n�d}~0 ty� } z@tj�t|�d � tj�� |j t j kr�d}nd}W Y d}~njd}~0 t y� d}Y nN t y� } z|j }W Y d}~n.d}~0 ddl}|jtjd� d}Y n0 W |�rFz|�|� W n t�yD Y n0 t�|� n6|�r|z|�|� W n t�yz Y n0 t�|� 0 dS ) z+ Common command line code, called. r N� � � � � )�file)�CmdLine�process�ArgError�sys�stderr�write�str�flushr �coder ZPERMISSION_DENIED�KeyboardInterrupt� SystemExit� traceback� print_exc�stdout�shutdown� Exception�exit)�cZerr_exit�cliZae�leZser; � rD �8/usr/lib64/python3.9/site-packages/lsm/lsmcli/cmdline.py�cmd_line_wrapper8 sF �rF c C s\ t j�� } t�| �}z0t�t j�� � t j�d�}W t�| tj |� nt�| tj |� 0 |S )Nr. ) r3 �stdin�fileno�termiosZ tcgetattr�ttyZsetraw�readZ tcsetattrZ TCSADRAIN)�fd�prevZchrD rD rE �getche s $rN c C s, t �| �\}}}|r ||fS td| ��dS )z� If init_id is a WWPN, convert it into LSM standard version: (?:[0-9a-f]{2}:){7}[0-9a-f]{2} Return (converted_init_id, lsm_init_type) z,--init "%s" is not a valid WWPN or iSCSI IQNN)r �initiator_id_verifyr2 )�init_id�validZconverted_init_type�converted_init_idrD rD rE �parse_convert_initp s �rS c C s( t �| �\}}}|r|S td| ��dS )z� Call back from validating an initiator :param init_id: Initiator to validate :return: Value of initiator or raises an exception z!"%s" is invalid WWPN or iSCSI IQNN)r rO r )rP rQ �_rR rD rD rE � _check_init� s �rU c C sH z$t | d�}|dk r td| ��|W S tyB td| ��Y n0 dS )z� Call back for validating a positive integer :param num: Number string to check :return: Numeric value, else exception � r z,invalid: require positive integer value '%d'z*invalid: not a positive integer value '%s'N)�longr � ValueError)Znum�rcrD rD rE �_check_positive_integer� s � �rZ Zchild_c C s | � � S �N)�upper)�srD rD rE �_upper� s r^ c C s� | sdS | � d�}t|�dkr"dS d| v r.dS |D ]t}dt|� k rNdksVn dS t|�dkrt|d dkrt dS zt|d �d kr�W dS W q2 ty� Y dS 0 q2d S ) z� Check if a string represents a valid ip4 address :param address: String representing address :return: True if valid address, else false F�.r- �/r � r. �0rV � T)�split�len�intrX )�address�parts�irD rD rE �_valid_ip4_address� s$ rj c s� d� d}| sdS d| v r dS t | �d��dkr2dS | �d�}t |�dk sTt |�dkrXdS d |d v r�t|�� �s|td � dS |�d d g� d| v r�d d� |D �}|�d � d}|r�t |�dks�t |�dkr�tdd� |D ��o�t� fdd�d�|�D ��S dS )z� Check if a string represents a valid ipv6 address :param address: String representing address :return: True if valid address, else false zABCDEFabcdef0123456789:Fr` z::r* �:ra � r_ ���zNot valid ipv suffixrb c S s g | ]}|d kr|�qS )� rD )�.0�prD rD rE � <listcomp>� � z&_valid_ip6_address.<locals>.<listcomp>T� c s s | ]}t |�d kV qdS )r- N)re �ro �xrD rD rE � <genexpr>� rr z%_valid_ip6_address.<locals>.<genexpr>c 3 s | ]}|� v V qd S r[ rD rt ��allowedrD rE rv � rr rn ) re rd rj �pop�print�extend�append�all�join)rg Z has_zerosrh rD rw rE �_valid_ip6_address� s2 �r c C s� t tjtjtjtjd�}| �� �d�}|D ](}||�� vr*t d|t |�� �f ��q*t |�t t |��kr�t |�dkr|t d��t |�dkr�|d dd� |d dd� kr�t d ��||d ||d B S ||d S n t d | ��d S ) N)ZIDENT_ONZ IDENT_OFFZFAULT_ONZ FAULT_OFFrk z&Invalid state '%s', valid choices = %sr* z(Maximum number of LED state values is 2!r r- r. z0States which counteract one another are invalid!z&Repeated same LED state is invalid! %s) �dictr ZLED_STATUS_IDENT_ONZLED_STATUS_IDENT_OFFZLED_STATUS_FAULT_ONZLED_STATUS_FAULT_OFFr\ rd �keysr �listre �set)�stateZ valid_optionsZt_statesr] rD rD rE �_check_led_state� s0 � � ��r� c s� t �dt j�� t �d�}t| �r$dS t| �r0dS t| �dkr@dS |�| �rNdS | d dkrf| dd� } t� fd d �| �d�D ��S ) z� Checks to see if the supplied string is a valid ip4/6 or hostname :param ip_hn: String representing address user inputted :return: True if valid IP address or hostname z(?!-)[A-Z0-9-]{1,63}(?<!-)$z ^[0-9.]+$Trc Frm r_ Nc 3 s | ]}� � |�V qd S r[ )�matchrt rw rD rE rv & rr z)_is_valid_network_name.<locals>.<genexpr>) �re�compile� IGNORECASErj r re r� r} rd )Zip_hnZ digits_onlyrD rw rE �_is_valid_network_name s r� Fc C sp d}|r t }| jddddtjd tf d� | jdd td d | tjd � | jd dd tdd| dd � | jdddd| dd� | jdddd| dd� | jd d d d | d d d!� | jd"d#dd$| d%d&d'� | jd(d)dd*| d%d+d'� | jd,d-d d.| d/td0� | jd1dd2| d3d� | jd4dd5| d%d6d'� | jd7d8dd9| d%d:d'� |�rlt � }d;|d.| < | j f i |�� d<S )=a As https://bugs.python.org/issue23058 indicate, argument parser should not have subparser sharing the same argument and destination. For subparser, we add common options as 'child_xxx' destination. For default value, False is the only allowed default value in root. rn z-vz --version�versionz%s %sr )�actionr� z --fork_plugin�storez<plugin executable>z %splugin_exe)r� �type�metavar�dest�helpz-uz--uriz<URI>z%suriz,Uniform resource identifier (env LSMCLI_URI)z-Pz--prompt� store_truez%spromptz)Prompt for password (env LSMCLI_PASSWORD))r� r� r� z-Hz--humanz%shumanz:Print sizes in human readable format (e.g., MiB, GiB, TiB)z-tz--tersez%ssepz<SEP>z;Print output in terse form with "SEP" as a record separator)r� r� r� r� z-ez--enumz%senumFz3Display enumerated types as numbers instead of text)r� r� �defaultr� z-fz--forcez%sforcez3Bypass confirmation prompt for data loss operationsz-wz--waitz%swaitz+Command timeout value in ms (default = 30s))r� r� r� r� z--headerz%sheaderz Include the header with tersez-bz%s_asynczmRun the command async. Instead of waiting for completion. Command will exit(7) and job id written to stdout.z-sz--scriptz%sscriptzMDisplaying data in script friendly way with additional information(if exists)i0u N) �_CHILD_OPTION_DST_PREFIX� add_argumentr3 �argvr r6 �argparse�SUPPRESSrZ r� � set_defaults)Z arg_parser�is_child�prefixZ default_dictrD rD rE �_add_common_options) s� ��� ��������� r� c C s` i } t �� D ]N}zt �|�}|| |< W q tyX } z|jtjkrD� W Y d }~q d }~0 0 q | S r[ )r r� � vpd83_getr r8 r � NO_SUPPORT)�lookup�dZvpd�lsm_errrD rD rE �_sd_paths_cache� s r� c C sv g | _ td u rt� az*t| j�dkr<| jtv r<t�| j�| _ W n2 typ } z|jt j kr\� W Y d }~n d }~0 0 | S )Nr ) Zsd_paths�LOCAL_DISK_LOOKUPr� re �vpd83r Z vpd83_searchr r8 r r� )Zlsm_objr� rD rD rE � _add_sd_paths� s r� c @ s e Zd Zdd� Zdd� ZdS )r2 c O s" t j| g|�R i |�� || _dS )z, Class represents an error. N)r? �__init__�msg)�self�message�args�kwargsrD rD rE r� � s zArgError.__init__c C s dt j�tjd �| jf S )Nz%s: error: %s r )�os�path�basenamer3 r� r� �r� rD rD rE �__str__� s zArgError.__str__N)�__name__� __module__� __qualname__r� r� rD rD rD rE r2 � s r2 �itemTc C s: | D ]}|j |kr| S q|r2td||f ��nd S d S )Nz%s with ID %s not found!)�idr2 )�lZthe_idZ friendly_name� raise_errorr� rD rD rE � _get_item� s r� c C s t | �}|r| S td| ��dS )zT Custom value checker for hostname/IP address :param addr: :return: z %s is invalid IP or hostnameN)r� r )ZaddrrQ rD rD rE �_check_network_host� s r� c @ s, e Zd ZdZdd� Zedd� �Zdd� ZdS ) � PluginForkz Container for plugin fork datac C s6 t jdd�| _tj�| jd�| _d | _d | _d | _ t � t j t j �}|� | j� |�� t � t j t j �}|�| j� |�� }z*tj|d| g|gtjtjtjd�| _W nJ ty� } z2td|t|�f � | �� t�d� W Y d }~n d }~0 0 |� � \| _}|�� |�� t j t j | fdd �| _ | j �!� d }d S ) NZLSM_DEV_)r� Zuds_pathz%d)Zpass_fds�envr= r4 zFile: %s issue: %srs zplugin stdout reader)�targetr� �name)"�tempfileZmkdtemp�uds_dirr� r� r~ �uds_socket_file�client�plugin_process�thread�socketZAF_UNIXZ SOCK_STREAMZbindZlistenZconnectrH � subprocess�Popen�environ�PIPEZSTDOUTr? rz r6 �closer3 r@ Zaccept� threading�Threadr� � read_stdout�start)r� � plugin_exeZserverZpluginZ plugin_fd�erT rD rD rE r� � s@ � � zPluginFork.__init__c C sV | j j}|�� }|sq2qtd|�d��d� � q| j �� d urRtd| j �� � d S )Nz PLUGIN>> %szutf-8r+ zPLUGIN EC>> %d)r� r= �readlinerz �decode�rstripZpoll�wait)�instance�output�linerD rD rE r� s zPluginFork.read_stdoutc C sB | j r| j �� | jr.t�| j� t�| j� | jr>| j�� }d S r[ ) r� r� r� r� �remove�rmdirr� r� r~ )r� rY rD rD rE r� s zPluginFork.closeN)r� r� r� �__doc__r� � staticmethodr� r� rD rD rD rE r� � s 0 r� c C s& t |�}t|j�� �tjd< || _d S )NZLSMCLI_DEBUG_FD)r� r6 r� rH r� r� � plugin_fork)r� r� ZfdatarD rD rE �_fork_exec_plugin$ s r� ) �VOLUMES�POOLS�FS� SNAPSHOTS�EXPORTS�NFS_CLIENT_AUTH� ACCESS_GROUPS�SYSTEMS�DISKS�PLUGINS� TARGET_PORTS� BATTERIES)�DEFAULTZTHINZFULLzprovisioning type: �, )�CLONE�COPYZ MIRROR_ASYNCZ MIRROR_SYNCzreplication type: �ENABLEZDISABLEzPolicy: z--policyz<POLICY>)r� r� r� �choicesr� )�WB�AUTOZWTzWrite cache polices: z' which stand for "write back", "auto", z"write through"z7Can use B, KiB, MiB, GiB, TiB, PiB postfix (IEC sizing)z--sysz<SYS_ID>z System ID)r� r� r� zmSearch by System ID. Only supported for: (VOLUMES, POOLS, FS, DISKS, ACCESS_GROUPS, TARGET_PORTS, BATTERIES)r� z--poolz <POOL_ID>zPool IDz;Search by Pool ID. Only supported for: (VOLUMES, POOLS, FS)z--volz<VOL_ID>z Volume IDzASearch by Volume ID. Only supported for: (VOLUMES, ACCESS_GROUPS)z--fsz<FS_ID>zFile System IDz=Search by FS ID. Only supported for: (FS, SNAPSHOTS, EXPORTS)z--agz<AG_ID>zAccess Group IDzGSearch by Access Group ID. Only supported for: (ACCESS_GROUPS, VOLUMES)z--initz <INIT_ID>z Initiator ID)r� r� r� r� z--snapz <SNAP_ID>z Snapshot IDz--exportz <EXPORT_ID>z Export IDz --nfs-exportz<NFS_EXPORT_ID>z6Search by NFS Export ID. Only supported for: (EXPORTS)z--diskz <DISK_ID>z.Search by Disk ID. Only supported for: (DISKS)z--sizez<SIZE>z--tgtz<TGT_ID>z=Search by target port ID. Only supported for: (TARGET_PORTS)z--pathzLocal disk pathz <DISK_PATH>)r� r� r� z--slotzLED slot identifierz <slot_id>z--statez[LED slot value state (IDENT_[ON|OFF] or [FAULT_[ON|OFF], or combination separated with ':')z<state>)r� r� r� r� r� z List records of different typesz--typezList records of type: z z3 When listing SNAPSHOTS, it requires --fs <FS_ID>.z<TYPE>)r� r� r� r� r� )r� r� r� �optionalz job-statusz Retrieve information about a jobz--jobz<JOB_ID>z job status id)r� r� r� � capabilitiesz Retrieves array capabilitiesz plugin-infoz(Retrieves plugin description and version)r� r� � volume-createz Creates a volume (logical unit)z--namez volume namez<NAME>z--provisioningr� )r� r� r� r� r� zvolume-raid-createz(Creates a RAIDed volume on hardware RAIDz<DISK>z>Free disks for new RAIDed volume. This is repeatable argument.r| )r� r� r� r� z --raid-typez@RAID type for the new RAID group. Should be one of these: %s)r� r� r� r� z --strip-sizez Strip size. zvolume-raid-create-capz=Query capability of creating a RAIDed volume on hardware RAID� volume-deletez Deletes a volume given its idz volume-resizezRe-sizes a volumez <NEW_SIZE>z New size. %szvolume-replicatez:Creates a new volume and replicates provided volume to it.z<NEW_VOL_NAME>z"The name for New replicated volumez --rep-typez <REPL_TYPE>)r� r� r� r� z[Pool ID to contain the new volume. By default, new volume will be created in the same pool.zvolume-replicate-rangez3Replicates a portion of a volume to existing volumez --src-volz <SRC_VOL_ID>zSource volume idz --dst-volz <DST_VOL_ID>zDestination volume idz <REP_TYPE>z Replication type: CLONE, COPYr� r� z --src-startz<SRC_START_BLK>z>Source volume start block number. This is repeatable argument.)r� r� r� r� r� z --dst-startz<DST_START_BLK>zCDestination volume start block number. This is repeatable argument.z--countz <BLK_COUNT>z;Number of blocks to replicate. This is repeatable argument.z!volume-replicate-range-block-sizez2Size of each replicated block on a system in byteszvolume-dependantsz>Returns True if volume has a dependant child, like replicationzvolume-dependants-rmzRemoves volume dependencieszvolume-access-groupz4Lists the access group(s) that have access to volumez volume-maskz>Grants access to an access group to a volume, like LUN Maskingz volume-unmaskz7Revoke the access of specified access group to a volumez volume-enablez Enable block access of a volumezvolume-disablez Disable block access of a volumezvolume-raid-infoz Query volume RAID informationzvolume-ident-led-onz!Enable the IDENT LED for a volumezTargeted volume. zvolume-ident-led-offz"Disable the IDENT LED for a volumez system-read-cache-pct-updatez,Change the read cache percentage of a systemzTargeted system. z --read-pctzRead cache percentage. )r� r� r� zpool-member-infoz!Query Pool membership informationzaccess-group-createzCreate an access groupz <AG_NAME>z$Human readable name for access groupzaccess-group-addz+Add an initiator into existing access groupzaccess-group-removez.Remove an initiator from existing access groupzaccess-group-deletezDeletes an access groupzaccess-group-volumeszBLists the volumes that the access group has been granted access toz iscsi-chapz5Configures iSCSI inbound/outbound CHAP authenticationz --in-userz <IN_USER>zInbound chap user namez --in-passz <IN_PASS>zInbound chap passwordz --out-userz <OUT_USER>zOutbound chap user namez --out-passz <OUT_PASS>zOutbound chap password� fs-createzCreates a file systemz <FS_NAME>zname of the file system� fs-deletezDelete a filesystem� fs-resizezRe-sizes a filesystemz fs-exportz Export a filesystem via NFS.z --exportpathz <EXPORT_PATH>z(NFS server export path. e.g. '/foo/bar'.z --anonuidz <ANON_UID>z%UID(User ID) to map to anonymous user)r� r� r� r� r� z --anongidz <ANON_GID>z&GID(Group ID) to map to anonymous userz --auth-typez <AUTH_TYPE>z NFS client authentication typez --root-hostz <ROOT_HOST>z9The host/IP has root access. This is repeatable argument.)r� r� r� r� r� r� z --ro-hostz <RO_HOST>zrThe host/IP has readonly access. This is repeatable argument. At least one '--ro-host' or '--rw-host' is required.z --rw-hostz <RW_HOST>zsThe host/IP has readwrite access. This is repeatable argument. At least one '--ro-host' or '--rw-host' is required.z fs-unexportzRemove an NFS exportzfs-clonezCreates a file system clonez--src-fsz <SRC_FS_ID>z&The ID of existing source file system.z --dst-namez <DST_FS_NAME>z3The name for newly created destination file system.z--backing-snapshotz <BE_SS_ID>zbacking snapshot idzfs-snap-createzCreates a snapshotz <SNAP_NAME>z'The human friendly name of new snapshotzfs-snap-deletezDeletes a snapshot�fs-snap-restorez;Restores a FS or specified files to previous snapshot statez--filez <FILE_PATH>zkOnly restore provided file Without this argument, all files will be restored This is a repeatable argument.)r� r� r� r� r� z--fileasz<NEW_FILE_PATH>zGstore restore file name to another name. This is a repeatable argument.z fs-dependantszHReturns True if filesystem has a child dependency(clone/snapshot) existsz-For file check This is a repeatable argument.)r� r� r� r� r� �fs-dependants-rmz Removes file system dependencieszHFile or files to remove dependencies for. This is a repeatable argument.)r� r� r� r� z file-clonez,Creates a clone of a file (thin provisioned)z--srcz<SRC_FILE_PATH>zCsource file to clone (relative path) This is a repeatable argument.z--dstz<DST_FILE_PATH>z@Destination file (relative path), this is a repeatable argument.r" z Query local disk informationr' z#Query slots with LED identificationzvolume-cache-infoz"Query volume RAM cache informationz volume-phy-disk-cache-updatez)Update volume physical disk cache settingz volume-read-cache-policy-updatez Update volume read cache policyz volume-write-cache-policy-updatez Update volume write cache policyr# z/Turn on the identification LED for a local diskr$ z0Turn off the identification LED for a local diskr% z&Turn on the fault LED for a local diskr& z'Turn off the fault LED for a local diskr( z#Sets the state of the specified LEDzlist --type systemszlist --type poolszlist --type volumeszlist --type diskszlist --type access_groupszlist --type fszlist --type target_portszlist --type batteries)%ZlsZlp�lvZldZlaZlf�ltrA rp ZvcZvrcZvrccZvdZvrZvmZvu�ve�viZacZaa�arZadZvriZvilonZviloffZsrcpuZpmiZldlZlbZvciZvpdcuZvrcpuZvwcpuZldilonZldiloffZldflonZldfloffc @ s` e Zd ZdZdd� Zdd� Zdd� Zedd � �Zed d � �Z d d � Z dd� Z edd� �Z dd� Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zed.d/� �Zd0d1� Z d2d3� Z d4d5� Z d6d7� Z d8d9� Z d:d;� Z!d<d=� Z"d>d?� Z#d@dA� Z$dBdC� Z%dDdE� Z&edFdG� �Z'dHdI� Z(dJdK� Z)dLdM� Z*dNdO� Z+dPdQ� Z,dRdS� Z-dTdU� Z.dVdW� Z/dXdY� Z0dZd[� Z1d\d]� Z2d^d_� Z3d`da� Z4dbdc� Z5ddde� Z6dfdg� Z7dhdi� Z8djdk� Z9dldm� Z:dndo� Z;dpdq� Z<drds� Z=dtdu� Z>d�dwdx�Z?d�dydz�Z@d{d|� ZAd}d~� ZBdd�� ZCd�d�� ZDd�d�� ZEd�d�� ZFd�d�� ZGd�d�� ZHd�d�� ZId�d�� ZJd�d�� ZKdvS )�r0 z' Command line interface class. c C sL | j jsD|rdnd}td| � t� }|�� dkr6dS td� dS ndS dS ) z1 Give the user a chance to bail. ZwillZmayzxWarning: You are about to do an operation that %s cause data to be lost! Press [Y|y] to continue, any other key to abort�YTzOperation aborted!FN)r� �forcer rN r\ )r� Zdeletingr� ZpressedrD rD rE �confirm_prompt s � zCmdLine.confirm_promptc C sl d}t |�dkrd S tj}d}| jjr*d}| jjr6d}| jjrDtj}tj||| jj | jj | jj||d� d S )NFr T)� display_wayZ flag_humanZ flag_enumZsplitter�flag_with_headerZflag_dsp_all_data) re r ZDISPLAY_WAY_DEFAULTr� �sep�headerZscriptZDISPLAY_WAY_SCRIPT� display_dataZhuman�enum)r� ZobjectsZ display_allr r rD rD rE r 2 s& �zCmdLine.display_datac C sH g }d}t �|�}|D ]"}|�|�\}}|�t||�� q| �|� d S )Nz<}{>)r Zavailable_pluginsrd r| r r )r� r� r Zpluginsrp �descr� rD rD rE �display_available_pluginsK s z!CmdLine.display_available_pluginsc C sD g } t jdd� D ],}|tv r4| �t| �d�� q| �|� q| S )ab Walk the command line argument list and build up a new command line with the appropriate substitutions which is then passed to argparse, so that we can avoid adding more sub parsers and do all argument parsing before the need to talk to the library :return copy of command line args with alias expansion: r. N� )r3 r� �aliasesr{ rd r| )rY ri rD rD rE � handle_aliasV s zCmdLine.handle_aliasc C s. d} t t�� �D ]\}}| d�||�7 } q| S )Nzcommand aliases: z {0:<18} Alias of '{1}' )�sortedr �items�format)rY �k�vrD rD rE �alias_help_textg s zCmdLine.alias_help_textc C s� t dd�}t|dd� t dt�� d td�}t|dd� |jdd �}d|_tD ]�}|j|d |d |gtd �}|� d �}|� dg �D ](}|d }|d = |j |fddi|�� q�|� d�}|� dg �D ]2}|d } |d = t | t �s�| f} |j | i |�� q�|jt| |d �dd��d� qNttj�dk�r8|�� td� || _|jt�� d�} t| ��� D ]R\} } | �t ��rZ| tt �d� } t| | �du �s�t| | �du �rZt | | | � �qZ| S )z3 Command line interface parameters F)�add_helpT)r� z^The libStorageMgmt command line interface. Run %(prog)s <command> -h for more on each command.zh Copyright 2012-2022 Red Hat, Inc. Please report bugs to <libstoragemgmt-devel@lists.fedorahosted.org> )� description�epilog�formatter_classZcommand)r� r� r� )r� �parentsr zcmd required argumentsr� �requiredzcmd optional argumentsr� �-rT )�funcr. �r� N) r r� r0 r r �add_subparsersr �cmds� add_parser�add_argument_group�getr� � isinstance�tupler� �getattr�replacere r3 r� � print_usager@ �parser� parse_argsr �varsr � startswithr� �setattr)r� Z parent_parserr& Z subparsers�cmdZ sub_parser�group�argr� �flagsZ known_argsr r Zroot_krD rD rE rB o s^ �� � � �z CmdLine.clic C s: | j jr"t| j j�| j�� �� ntd�| j�� �� dS )zD Dump the supported nfs client authentication types r� N)r� r r r~ rA Z export_authr� rD rD rE �!display_nfs_client_authentication� s z)CmdLine.display_nfs_client_authenticationc C s� d }d }| j df| jdf| jdf| jdf| jdf| jdf| jdf| jdff}|D ].}|d rP|rvtd ||d f ��qP|\}}qP||fS ) NZ system_id�pool_id� volume_id�disk_id�access_group_id�fs_id� nfs_export_id� tgt_port_idr z,Search key specified more than once (%s, %s)r. ) r3 �pool�vol�disk�ag�fsZ nfs_exportZtgtr2 )r� � search_key� search_valueZ search_argsZsarD rD rE �_get_search_key_value� s& �� �� z CmdLine._get_search_key_valuec C s� t �|�\}}|jdkr�g }|dkr(d}|dkrZt| j�� |jddd�}|r�| j�|�}n*|rv|tj vrvt d| ��n| j� ||�}| � t d d � |D ��� �nT|jd kr�|d kr�d}|r�|tj vr�t d | ��| � | j�||�� �n |jdk�r8|dk�rd}|�r |tj v�r t d| ��| � | j�||�� �n�|jdk�r�|jd u �rXt d��|�rt|dk�rtt d| ��t| j�� |jd�}| � | j�|�� �nV|jdk�r�|dk�r�d}|�r�|tj v�r�t d| ��| � | j�||�� �n|jdk�r|�rt d��| �� �n�|jdk�r�|dk�r.d}|dk�rtt| j� � |jddd�}|�rh| � | j�|��S | � g �S n |�r�|tj v�r�t d| ��| � | j�||�� �nJ|jd k�r�|�r�t d ��| � | j�� � �n |jd k�r4|d k�r�d}|�r|tj v�rt d | ��| � t d!d � | j�||�D ��� n�|jd"k�r�|d#k�rNd}|�rl|t j v�rlt d$| ��| � | j� ||�� nr|jd%k�r�|�r�t d&��| � � nN|jd'k�r�|�r�|t j v�r�t d(| ��| � | j� ||�� nt d)|j ��d S )*Nr� r1 r� r3 � Access GroupF)r� z3Search key '%s' is not supported by volume listing.c s s | ]}t |�V qd S r[ �r� �ro r rD rD rE rv � rr z CmdLine.list.<locals>.<genexpr>r� r0 z1Search key '%s' is not supported by pool listing.r� r4 r� z --fs <file system id> requiredz5Search key '%s' is not supported by snapshot listing.� File Systemr� r5 z6Search key '%s' is not supported by NFS Export listingr� zCNFS client authentication type listing with search is not supportedr� r z8Search key '%s' is not supported by Access Group listingr� z+System listing with search is not supportedr� r2 z0Search key '%s' is not supported by disk listingc s s | ]}t |�V qd S r[ r@ �ro r� rD rD rE rv - s �r� r6 z7Search key '%s' is not supported by target port listingr� z,Plugins listing with search is not supportedr� z3Search key '%s' is not supported by battery listingzunsupported listing type=%s)!r0 r> r� r� rA � access_groupsr: �"volumes_accessible_by_access_groupr ZSUPPORTED_SEARCH_KEYSr2 �volumesr r� r �poolsr r; � fs_snapshotsr �exportsr/ r8 � access_groups_granted_to_volumer �systemsr �disksr Z target_portsr r Z batteries)r� r� r< r= Zlsm_vols�lsm_agr; �lsm_volrD rD rE r� � s� ��� � �� � �� � � �� � �� �� ��z CmdLine.listc C sF t | j�� |jd�}t|j�\}}| j�|j|||�}| �|g� d S �N�System) r� rA rK r3 rS �init�access_group_creater� r )r� r� �systemrP � init_typeZ access_grouprD rD rE rR F s �zCmdLine.access_group_createc C sJ t | j�� |jd�}t|j�\}}|r6| j�|||�S | j�|||�S d S �Nr? )r� rA rD r: rS rQ Zaccess_group_initiator_addZ access_group_initiator_delete)r� r� �oprM rP rT rD rD rE �_add_rm_access_grp_initM s ��z CmdLine._add_rm_access_grp_initc C s | � | �|d�g� d S )NT�r rW �r� r� rD rD rE �access_group_addY s zCmdLine.access_group_addc C s | � | �|d�g� d S )NFrX rY rD rD rE �access_group_remove] s zCmdLine.access_group_removec C s@ | j �� }t||jd�}| j �|�}| �tdd� |D ��� d S )Nr? c s s | ]}t |�V qd S r[ r@ rA rD rD rE rv d rr z/CmdLine.access_group_volumes.<locals>.<genexpr>)rA rD r� r: rE r r� )r� r� �aglr, ZvolsrD rD rE �access_group_volumes` s z CmdLine.access_group_volumesc C s� t |j�\}}|tjkr&td|j ��| jjr>| jjs>td��| jjrV| jjsVtd��| jjrn| jj sntd��| jj r�| jjs�td��| jjr�| jj r�| jjr�| jjs�td��| j � ||j| jj| jj| jj � d S )Nz$--init "%s" is not a valid iSCSI IQNz --in-user requires --in-passz --in-pass requires --in-userz --out-user requires --out-passz --out-pass requires --out-userz?out-user and out-password only supported if inbound is supplied) rS rQ r ZINIT_TYPE_ISCSI_IQNr2 r� Zin_userZin_passZout_userZout_passrA Ziscsi_chap_auth)r� r� rP rT rD rD rE � iscsi_chapf s, ��� �zCmdLine.iscsi_chapc C s. t | j�� |jd�}| j�|�}| �|� d S �Nr )r� rA rF r8 rJ r )r� r� r8 �groupsrD rD rE �volume_access_group� s zCmdLine.volume_access_groupc C s$ | j �� }t||jd�}| j �|�S rU )rA rD r� r: �access_group_delete)r� r� r\ r, rD rD rE rb � s zCmdLine.access_group_deletec C s8 t | j�� |jd�}| �d�r4| �d| j�|�d � d S )NrB Tr� )r� rA r; r � _wait_for_it� fs_delete�r� r� r; rD rD rE rd � s zCmdLine.fs_deletec C sL t | j�� |jd�}| jdg| j�||j| �|j���R � }| � |g� d S )Nr r� ) r� rA rG r7 rc � fs_creater� �_size�sizer )r� r� rp r; rD rD rE rf � s � ��zCmdLine.fs_createc C sl t | j�� |jd�}| �|j�}||jkr6ttjd��| � d�rh| j dg| j� ||��R � }| � |g� d S )NrB � Specified size same as currentFr� ) r� rA r; rg rh Z total_spacer r �NO_STATE_CHANGEr rc � fs_resizer )r� r� r; rh rD rD rE rk � s � zCmdLine.fs_resizec C sd t | j�� |jd�}d }|jr4t | j�|�|jd�}| jdg| j�||j|��R � }| � |g� d S )NzSource File System�Snapshot�fs_clone) r� rA r; �src_fs�backing_snapshotrH rc rm Zdst_namer )r� r� rn �ssr; rD rD rE rm � s ��zCmdLine.fs_clonec C s\ t | j�� |jd�}| jjr4t | j�|�|jd�}nd }| �d| j�||j|j |�d � d S )NrB rl � fs_file_clone) r� rA r; r� ro rH rc rq �src�dst�r� r� r; rp rD rD rE � file_clone� s ��zCmdLine.file_clonec C s t | �}|dkr td| ��|S )Nr z$Incorrect size argument format: '%s')r r2 )r] Z size_bytesrD rD rE rg � s z CmdLine._sizec C s> | j jd ur| j j}nd}|r$d}nd}td|||f � d S )Nrk � SUPPORTED� UNSUPPORTED�%s%s%s)r� r r )r� �cap�valr] r rD rD rE �_cp� s z CmdLine._cpc C s� t | j�� |jd�}| j�|�}t|�� �� �}t|�d��� �}tj }| j j d ur\| j j }t � }|D ] }d||< qf|D ]}||vrxd||< qxt� |g|� d S )NrP Trv rw )r� rA rK r3 r� r Z get_supported�valuesr ZDEFAULT_SPLITTERr� r r) Zdisplay_data_script_way) r� r� r] ry Zsup_capsZall_capsr Zcap_datar rD rD rE r� � s zCmdLine.capabilitiesc C s> | j �� \}}|jr*td||j|f � ntd||f � d S )Nrx zDescription: %s Version: %s)rA � plugin_infor r )r� r� r r� rD rD rE r} � s zCmdLine.plugin_infoc C sX t | j�� |jd�}| jdg| j�||j| �|j�t |j ���R � }| � t |�g� d S )Nr r� ) r� rA rG r7 rc � volume_creater� rg rh r Z provisioningr r� )r� r� rp r8 rD rD rE r~ � s ����zCmdLine.volume_createc C sB t | j�� |jd�}| jdg| j�||j��R � }| �|g� d S )NrB zsnapshot-create)r� rA r; rc Zfs_snapshot_creater� r rt rD rD rE �fs_snap_create s �zCmdLine.fs_snap_createc C s� t | j�� |jd�}t | j�|�|jd�}| jj}t|�dkrBd }d}| jjrzd}| jjrzt| jj�t| jj�krzt d��| � d�r�| � d| j� |||| jj|�d � d S )NrB rl r TFz&number of --file not equal to --fileasr� ) r� rA r; rH �snapr� r/ re Zfileasr2 r rc Zfs_snapshot_restore)r� r� r; rp �filesZflag_all_filesrD rD rE �fs_snap_restore s& ��zCmdLine.fs_snap_restorec C s8 t | j�� |jd�}| �d�r4| �d| j�|�d � d S )Nr Tr� )r� rA rF r8 r rc � volume_delete�r� r� r rD rD rE r� $ s zCmdLine.volume_deletec C sP t | j�� |jd�}t | j�|�|jd�}| �d�rL| �d| j�||�d � d S )NrB rl T�fs_snap_delete)r� rA r; rH r� r rc Zfs_snapshot_deletert rD rD rE r� * s �zCmdLine.fs_snap_deletec C s� |s|S | j jr$t|� | �tj� | j�|�\}}}|tj krLt � d� q$|tj krf| j� |� |S t|d t|� ��q$d S )Ng �?z job error code= )r� Z_asyncr r> r � JOB_STARTEDrA � job_statusr Z INPROGRESS�time�sleep�COMPLETE�job_freer2 r6 )r� r� �jobr� r] �percentrD rD rE rc 7 s zCmdLine._wait_for_itc C s^ | j �|j�\}}}|tjkrB|r2| �t|�g� | j �|j� ntt |�� | � t j � d S r[ ) rA r� r� r r� r r� r� r r6 r> r r� )r� r� r] r� r� rD rD rE r� P s zCmdLine.job_statusc C s� d }|j r t| j�� |j d�}t| j�� |jd�}t|j�}|tj krRt d| ��| j dg| j� ||||j ��R � }| �t|�g� d S )Nr r � invalid replication type= %szreplicate volume)r7 r� rA rG rF r8 r �rep_typer �REPLICATE_UNKNOWNr2 rc �volume_replicater� r r� )r� r� rp r r� r8 rD rD rE r� ] s ��zCmdLine.volume_replicatec C s@ dd� }| j dd� d� || d� | j dd� d� || d� d S ) Nc S s� t dt| ��D ]n}t| |d |�}| |d j}t| | |�}| | j}|| |krtd|||| d ||| d f ��qd S )Nr. z<Overlapping %s replication range %d..%d overlaps with %d..%d)�rangere r# Z block_countr2 )�r�memberri ZpsZpc�csZccrD rD rE �_overlapq s �z(CmdLine._check_overlap.<locals>._overlapc S s | j S r[ )� src_block�ru rD rD rE �<lambda>} rr z(CmdLine._check_overlap.<locals>.<lambda>)�keyr� c S s | j S r[ )� dest_blockr� rD rD rE r� rr r� )�sort)�rangesr� rD rD rE �_check_overlapn s zCmdLine._check_overlapc C sd t | j�� |jd�}t | j�� |jd�}t|j�}|tjkrHt d| ��|j }|j }|j }t |�r�t |�t |� kr�t |�ks�n t d��g }tt |��D ]�} t|| �} t|| �} t|| �} | dk r�t d��| dk r�t d��| dk r�t d��| | |jk�r t d ��| | |jk�r$t d ��|�t| | | �� q�t�|� | �d ��r`| j�||||� d S ) Nz Source VolumezDestination Volumer� z@Differing numbers of src_start, dest_start, and count parametersr z--count: value < 0z--src-start: value < 0z--dst_start: value < 0z#--src-start + --count > source sizez(--dst-start + --count > destination sizeF)r� rA rF Zsrc_volZdst_volr r� r r� r2 � src_start� dst_start�countre r� rW � num_of_blocksr| r r0 r� r �volume_replicate_range) r� r� rr rs r� Z src_startsZ dst_startsZcountsr� �br� r� r� rD rD rE r� � sB �� z CmdLine.volume_replicate_rangec C s( t | j�� |jd�}t| j�|�� d S rO )r� rA rK r3 r �!volume_replicate_range_block_size)r� r� r] rD rD rE r� � s z)CmdLine.volume_replicate_range_block_sizec C s: t | j�� |jd�}t | j�� |jd�}| j�||� d S )Nr r? )r� rA rF r8 rD r: � volume_mask)r� r� r8 r: rD rD rE r� � s zCmdLine.volume_maskc C s6 t | j�� |jd�}t | j�� |jd�}| j�||�S )Nr? r )r� rA rD r: rF r8 � volume_unmask)r� r� r: r8 rD rD rE r� � s zCmdLine.volume_unmaskc C sv t | j�� |jd�}| �|j�}||j|j kr<tt j d��| � d�rr| j dg| j� ||��R � }| �t|�g� d S )Nr ri FZresize)r� rA rF r8 rg rh Z block_sizer� r r rj r rc � volume_resizer r� )r� r� r rh r8 rD rD rE r� � s � zCmdLine.volume_resizec C s$ t | j�� |jd�}| j�|� d S r_ )r� rA rF r8 � volume_enabler� rD rD rE r� � s zCmdLine.volume_enablec C s$ t | j�� |jd�}| j�|� d S r_ )r� rA rF r8 �volume_disabler� rD rD rE r� � s zCmdLine.volume_disablec C s$ t | j�� |jd�}| j�|� d S )Nz NFS Export)r� rA rI �exportZ export_remove)r� r� r� rD rD rE � fs_unexport� s zCmdLine.fs_unexportc C st t | j�� |jd�}t|j�dkr8t|j�dkr8td��| j�|j|j |j |j|j|j |j |j d � }| �|g� d S )NrB r z& please specify --ro-host or --rw-host)r� rA r; re Zrw_hostZro_hostr2 Z export_fsr� Z exportpathZ root_hostZanonuidZanongidZ auth_typer )r� r� r; r� rD rD rE � fs_export� s � �zCmdLine.fs_exportc C s, t | j�� |jd�}| j�|�}t|� d S r_ )r� rA rF r8 Zvolume_child_dependencyr )r� r� r rY rD rD rE �volume_dependants� s zCmdLine.volume_dependantsc C s. t | j�� |jd�}| �d| j�|�d � d S )Nr zvolume-dependant-rm)r� rA rF r8 rc Zvolume_child_dependency_rmr� rD rD rE �volume_dependants_rm� s �z CmdLine.volume_dependants_rmc C s: t | j�� |jd�}| �t|jg| j�|��R � g� d S r_ )r� rA rF r8 r r r� �volume_raid_info�r� r� rN rD rD rE r� � s �zCmdLine.volume_raid_infoc C s: t | j�� |jd�}| �t|jg| j�|��R � g� d S )Nr )r� rA rG r7 r r r� �pool_member_info)r� r� Zlsm_poolrD rD rE r� � s �zCmdLine.pool_member_infoc s� t �� j�}| j�� }� fdd�|D �}t|�t� j�krhttj dd� t � j�t dd� |D �� � ��dd� |D �}t|�dkr�ttj d d� |� ��� j r�t� j �}ntj}| �t| j�� j|||��g� d S ) Nc s g | ]}|j � jv r|�qS rD )r� r9 rC r rD rE rq rr z.CmdLine.volume_raid_create.<locals>.<listcomp>zDisk ID %s not foundr� c s s | ] }|j V qd S r[ )r� rC rD rD rE rv rr z-CmdLine.volume_raid_create.<locals>.<genexpr>c S s g | ]}|j tj@ s|j�qS rD )�statusr Z STATUS_FREEr� rC rD rD rE rq s r. zDisk %s is not free)r Zraid_type_str_to_lsm� raid_typerA rL re r9 r r ZNOT_FOUND_DISKr~ r� Z DISK_NOT_FREE� strip_sizer r ZVCR_STRIP_SIZE_DEFAULTr r� �volume_raid_creater� )r� r� r� Z all_lsm_disksZ lsm_disksZ busy_disksr� rD r rE r� s4 ��� � ���zCmdLine.volume_raid_createc C s: t | j�� |jd�}| �t|jg| j�|��R � g� d S rO )r� rA rK r3 r r r� Zvolume_raid_create_cap_get)r� r� Zlsm_sysrD rD rE �volume_raid_create_cap s �z CmdLine.volume_raid_create_capc C s$ t | j�� |jd�}| j�|� d S r_ )r� rA rF r8 �volume_ident_led_on�r� r� Z lsm_volumerD rD rE r� $ s zCmdLine.volume_ident_led_onc C s$ t | j�� |jd�}| j�|� d S r_ )r� rA rF r8 �volume_ident_led_offr� rD rD rE r� ) s z CmdLine.volume_ident_led_offc C s� t | j�� |jd�}zt|j�}W n4 tyV } z ttj t |���W Y d }~n d }~0 0 | j� ||� t | j�� |jd�}| � |g� d S rO ) r� rA rK r3 rf �read_pctrX r r ZINVALID_ARGUMENTr6 � system_read_cache_pct_updater )r� r� Z lsm_systemr� r� rD rD rE r� . s &z$CmdLine.system_read_cache_pct_updatec C s0 t | j�� |jd�}| j�||j�}t|� d S )NrB )r� rA r; Zfs_child_dependencyr/ r )r� r� r; rY rD rD rE � fs_dependants: s zCmdLine.fs_dependantsc C s2 t | j�� |jd�}| �d| j�||j�d � d S )NrB r� )r� rA r; rc Zfs_child_dependency_rmr/ re rD rD rE �fs_dependants_rm@ s �zCmdLine.fs_dependants_rmc C s� d}t j�d�d }t j�|�s$dS t|��p}|D ]Z}|�� �d�rFq2z2dd� |�dd �D �\}}||v rvt| ||� W q2 t y� Y q20 q2W d � n1 s�0 Y dS ) zo Set uri from config file. Will be overridden by cmdline option or env var if present. )�uri�~z/.lsmcliN�#c S s g | ] }|� � �qS rD )�striprt rD rD rE rq X rr z,CmdLine._read_configfile.<locals>.<listcomp>�=r. ) r� r� � expanduser�exists�open�lstripr) rd r* rX )r� Zallowed_config_optionsZ config_path�fr� r� rz rD rD rE �_read_configfileE s zCmdLine._read_configfilec C s | j jj�dd�tv rdS dS )zU Return True if current command is one of _CONNECTION_FREE_COMMANDS. rT r TF)r� r r� r$ �_CONNECTION_FREE_COMMANDSr� rD rD rE �is_connection_free_cmd^ s �z CmdLine.is_connection_free_cmdc C s4 d | _ d | _d | _d | _d | _| �� | _d | _t| jj �| _ | j rL| j dk rTt d��| � � r`d S | � � t�d�d ur�t�d�| _ t�d�| _| jj d ur�| jj | _ | j d u r�d| jv r�| jjdkr�d| _ d | _nt d��| jjr�t�� | _| jd u�rt| j �}|d d u �rt d ��| jj�r0t| | jj� d S ) Nr z0[-w|--wait] requires a non-zero positive integerZ LSMCLI_URIZLSMCLI_PASSWORDr� r� zsim://z"--uri missing or export LSMCLI_URI�usernamez+password specified with no user name in uri)r� rA r& Z unknown_argsr� rB r� �cleanuprf r� �tmor2 r� r� r� �getenv�passwordr� �prompt�getpassr r� r� )r� �urD rD rE r� h s> zCmdLine.__init__Nc C s: | j r| � � | jd ur(| j�� d | _|r6t�|� d S r[ )r� r� r� r3 r@ )r� ZecrD rD rE r> � s zCmdLine.shutdownc C s� | � � r| j�| j� n||rJt|� �| _| j�| j| j| j� | jj | _ n4tt | j| j| j��| _t � d�rttd� | jj| _ | j�| j� | �� dS )z- Process the parsed command. ZLSM_DEBUG_PLUGINz8Attach debugger to plug-in, press <return> when ready...N)r� r� r r rA Zplugin_registerr� r� r� Zplugin_unregisterr� r r� r� �inputr� r> )r� rB rD rD rE r1 � s zCmdLine.processc C s g }t jt jt jt jt jt jt jd�}t �� D ]�}dt j t j dt j t j t jd�}|�� D ]l}z|| |�||< W qX ty� } z:|jtjkr�tj�d|| j||j|jf � W Y d }~qXd }~0 0 qX|�t||d |d |d |d |d |d |d �� q.| �|� d S ) N)r� �rpm� link_type� serial_num� led_status� link_speed� health_statusrn zWARN: %s('%s'): %d %s r� r� r� r� r� r� r� ) r r� Zrpm_getZ link_type_getZserial_num_getZled_status_getZlink_speed_getZhealth_status_getr� r ZRPM_NO_SUPPORTZLINK_TYPE_NO_SUPPORTZLED_STATUS_UNKNOWNZLINK_SPEED_UNKNOWNZHEALTH_STATUS_UNKNOWNr� r r8 r r� r3 r4 r5 r� r� r| r r )r� r� Z local_disksZ func_dictZ disk_pathZ info_dictr� r� rD rD rE �local_disk_list� sH � � �� ��zCmdLine.local_disk_listc C sb g }t �� �8}|D ]"}|�t|�� |�� |�� �� qW d � n1 sJ0 Y | �|� d S r[ )r �led_slots_openr| r! r� r� Zdevicer )r� r� Zlocal_led_slots�slotsr] rD rD rE �local_led_slot_list� s �$zCmdLine.local_led_slot_listc C s: t | j�� |jd�}| �t|jg| j�|��R � g� d S r_ )r� rA rF r8 r r r� �volume_cache_infor� rD rD rE r� � s �zCmdLine.volume_cache_infoc C s` t | j�� |jd�}|jdkr&tj}ntj}| j�||� | � t |j g| j� |��R � g� d S �Nr r� ) r� rA rF r8 �policyr ZREAD_CACHE_POLICY_ENABLEDZREAD_CACHE_POLICY_DISABLEDZ!volume_physical_disk_cache_updater r r� r� �r� r� rN r� rD rD rE � volume_phy_disk_cache_update� s �z$CmdLine.volume_phy_disk_cache_updatec C s` t | j�� |jd�}|jdkr&tj}ntj}| j�||� | � t |j g| j� |��R � g� d S r� ) r� rA rF r8 r� r ZPHYSICAL_DISK_CACHE_ENABLEDZ PHYSICAL_DISK_CACHE_DISABLED� volume_read_cache_policy_updater r r� r� r� rD rD rE r� s �z'CmdLine.volume_read_cache_policy_updatec C sr t | j�� |jd�}|jdkr&tj}n|jdkr8tj}ntj}| j� ||� | � t |j g| j� |��R � g� d S )Nr r� r� )r� rA rF r8 r� r Z WRITE_CACHE_POLICY_WRITE_BACKZWRITE_CACHE_POLICY_AUTOZ WRITE_CACHE_POLICY_WRITE_THROUGH� volume_write_cache_policy_updater r r� r� r� rD rD rE r� s �z(CmdLine.volume_write_cache_policy_updatec C s t �|j� d S r[ )r Z ident_led_onr� rY rD rD rE �local_disk_ident_led_on s z CmdLine.local_disk_ident_led_onc C s t �|j� d S r[ )r Z ident_led_offr� rY rD rD rE �local_disk_ident_led_off s z CmdLine.local_disk_ident_led_offc C s t �|j� d S r[ )r Z fault_led_onr� rY rD rD rE �local_disk_fault_led_on# s z CmdLine.local_disk_fault_led_onc C s t �|j� d S r[ )r Z fault_led_offr� rY rD rD rE �local_disk_fault_led_off& s z CmdLine.local_disk_fault_led_offc C sp t �� �F}|D ]0}|�� |jkr|�|j� W d � d S qW d � n1 sT0 Y td|j ��d S )NzLED slot id '%s' not found!)r r� r� ZslotZ state_setr� r2 )r� r� r� r] rD rD rE �local_led_slot_set) s 2zCmdLine.local_led_slot_set)N)N)Lr� r� r� r� r r r r� r r rB r/ r> r� rR rW rZ r[ r] r^ ra rb rd rf rk rm ru rg r{ r� r} r~ r r� r� r� rc r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r> r1 r� r� r� r� r� r� r� r� r� r� r� rD rD rD rE r0 s� A q 1 4 & r0 )N)F)r� T)ur� r� r� r� r3 r� r� r� r� rJ rI r� r r r ZsixZlsmr r r r r r r r r r r r r r r r r r Zlsm.lsmcli.data_displayr r r r r r r r r r r! r� ZPY3rf rW � collectionsr) � ImportErrorZ ordereddictr� rF rN rS rU rZ r� r^ rj r r� r� r� r� r� r? r2 r� r� r� r� Z list_choicesZprovision_typesr~ Zprovision_helpZreplicate_typesZreplicate_helpZ policy_typesZ policy_helpr� Z policy_optZwrite_cache_policy_typesZwrite_cache_policy_helpZwrite_cache_policy_optZ size_helpZ sys_id_opt�copyZsys_id_filter_optZ pool_id_optZpool_id_filter_optZ vol_id_optZvol_id_filter_optZ fs_id_optZfs_id_filter_optZ ag_id_optZag_id_filter_optZ init_id_optZ snap_id_optZ export_id_optZnfs_export_id_filter_optZdisk_id_filter_optZsize_optZtgt_id_filter_optZlocal_disk_path_optZlocal_disk_led_slot_optZ local_disk_led_slot_state_optZVOL_CREATE_RAID_TYPES_STRZANON_UID_GID_NAr r �objectr0 rD rD rD rE �<module> s� P4 - * h L ��������������������� �� ����� ���� � ������������ ��� �����������"���������� �������� �� �� ��� ����� ������������������ ���� ����������0����� ������ ����������������������������������������� � � � � R�+