관리-도구
편집 파일: simarray.pyc
� .�P`c @ s 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 m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z d � Z d � Z d � Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d S( i����N( t size_human_2_size_bytes( t Systemt Volumet Diskt Poolt FileSystemt AccessGroupt FsSnapshott NfsExportt md5t LsmErrort TargetPortt ErrorNumbert JobStatust Batteryt int_divc s � f d � } | S( Nc si y � | | � SWnQt j k r� } t | d � t k rc t | d d � rc | d j j � n t | � d k r� t t j d � � n t t j d t | � � � n� t k r� t | d � t k r� t | d d � r� | d j j � n � nl t k rd} t | d � t k rEt | d d � rE| d j j � n t t j d t | � � � n Xd S( Ni t bs_objs database is lockeds% Timeout to require lock on state files% Got unexpected error from sqlite3: %ss Got unexpected error: %s( t sqlite3t OperationalErrort typet SimArrayt hasattrR t trans_rollbackt strR R t TIMEOUTt PLUGIN_BUGt Exception( t argst kargst sql_errort base_error( t method( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt wrapper s, ) ))( ( R R ( ( R s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _handle_errors s c C sS d g } x: t d d � D]) } | j t d t j d d � � � q Wd j | � S( s. Generate a random VPD83 NAA_Type3 ID t 50i i s %02xi� t ( t ranget appendR t randomt randintt join( t vpdt _( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _random_vpd: s 'c C s< i } x/ t | j � D] \ } } | | | | d <q W| S( Ni ( t enumeratet description( t cursort rowt dt idxt col( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _dict_factoryD s t PoolRAIDc B s� e Z i d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6Z i d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6d � e j 6Z e d � � Z RS( c C s | d k S( Ni ( ( t x( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt <lambda>M s c C s | d k S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 N s c C s | d k S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 O s c C s | d k S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 P s c C s | d k S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 Q s c C s | d k S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 R s c C s | d k S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 S s c C s | d k o | d d k S( Ni i i ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 T s c C s | d k o | d d k S( Ni i i ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 U s c C s | d k o | d d k S( Ni i i ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 V s c C s | d k o | d d k S( Ni i i ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 W s c C s | d k o | d d k S( Ni i i ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 X s c C s | d k o | d d k S( Ni i i ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 Y s c C s | d k o | d d k S( Ni i i ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 Z s c C s | S( N( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 ^ s c C s | S( N( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 _ s c C s d S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 ` s c C s | d S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 a s c C s | d S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 b s c C s | d S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 c s c C s | d S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 d s c C s t | d � S( Ni ( R ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 e s c C s t | d � d S( Ni i ( R ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 f s c C s t | d � d S( Ni ( R ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 g s c C s | d S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 h s c C s | d S( Ni ( ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 i s c C s t | d � d S( Ni i ( R ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 j s c C s t | d � d S( Ni ( R ( R5 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR6 k s c C s} | t t j j � � k r4 t t j d | � � n t j | | � t k rl t t j d | | f � � n t j | | � S( s� Return a integer indicating how many disks should be used as real data(not mirrored or parity) disks. Treating RAID 5 and 6 using fixed parity disk. s0 data_disk_count(): Got unsupported raid type(%d)s; data_disk_count(): Illegal disk count(%d) for raid type(%d)( t listR4 t _RAID_DISK_CHKt keysR R R t Falset _RAID_PARITY_DISK_COUNT_FUNC( t raid_typet disk_count( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt data_disk_countn s ( t __name__t __module__R t RAID_TYPE_JBODt RAID_TYPE_RAID0t RAID_TYPE_RAID1t RAID_TYPE_RAID3t RAID_TYPE_RAID4t RAID_TYPE_RAID5t RAID_TYPE_RAID6t RAID_TYPE_RAID10t RAID_TYPE_RAID15t RAID_TYPE_RAID16t RAID_TYPE_RAID50t RAID_TYPE_RAID60t RAID_TYPE_RAID51t RAID_TYPE_RAID61R8 R; t staticmethodR> ( ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR4 K s> t BackStorec B s� e Z d Z d e e e � f Z d Z d Z d Z d Z d Z d Z d Z d d Z e j Z e j Z e j Z e j Z d Z d Z d Z e j e j e j e j e j e j e j g Z! d d d d d d d d d d d d d d d d g Z" d � Z# d � Z$ d � Z% d � Z& d � Z' d � Z( d � Z) d � Z* d � Z+ e, d � Z- d � Z. d � Z/ e0 e0 d � Z1 d � Z2 d � Z3 d! � Z4 d" � Z5 d# � Z6 d$ � Z7 d% � Z8 d& d& d' � Z9 d& d( � Z: d) � Z; e0 d* � Z< e0 d+ � Z= d, � Z> d- � Z? d. � Z@ eA d/ � � ZB d& d0 � ZC d1 � ZD d2 � ZE d3 � ZF d4 � ZG d5 � ZH d6 � ZI d7 � ZJ e0 d8 � ZK d9 � ZL d: � ZM eA d; � � ZN e0 d< � ZO d= � ZP d> � ZQ d? � ZR d@ � ZS dA � ZT dB � ZU dC � ZV dD � ZW eX dE � ZY dF � ZZ dG � Z[ dH � Z\ dI � Z] e0 dJ � Z^ dK � Z_ dL � Z` dM � Za dN � Zb dO � Zc dP � Zd dQ � Ze dR � Zf dS � Zg dT � Zh dU � Zi dV � Zj dW � Zk dX � Zl dY � Zm dZ � Zn d[ � Zo d\ � Zp RS(] s 4.1s LSM_SIMULATOR_DATA_%s_%si i i s sim-01s LSM simulated storage plug-ini i� i i t #i i i i i@ i c C s� t j j | � sH t j t j | t j t j B� � t j | d � n | | _ d | _ t j | d t t | d � � d d �| _ t | j _ d } | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d 7} | d! 7} | d" 7} | d# 7} | j i d$ t j d% 6t j d& 6t j d' 6t j d( 6t j d) 6� } | j j � } y | j | � Wn_ t j k rS} d* t | � k rJq�| � n/ t j k r�} t t j d+ | j � � n Xd S(, Ni� t timeouti� t isolation_levelt IMMEDIATEs PRAGMA foreign_keys = ON; s� CREATE TABLE systems ( id TEXT PRIMARY KEY, name TEXT NOT NULL, status INTEGER NOT NULL, status_info TEXT, read_cache_pct INTEGER, version TEXT NOT NULL); s% CREATE TABLE tgts ( id INTEGER PRIMARY KEY, port_type INTEGER NOT NULL, service_address TEXT NOT NULL, network_address TEXT NOT NULL, physical_address TEXT NOT NULL, physical_name TEXT NOT NULL); s� CREATE TABLE pools ( id INTEGER PRIMARY KEY, name TEXT UNIQUE NOT NULL, status INTEGER NOT NULL, status_info TEXT, element_type INTEGER NOT NULL, unsupported_actions INTEGER, raid_type INTEGER NOT NULL, parent_pool_id INTEGER, member_type INTEGER, strip_size INTEGER, total_space LONG); s� CREATE TABLE disks ( id INTEGER PRIMARY KEY, total_space LONG NOT NULL, disk_type INTEGER NOT NULL, status INTEGER NOT NULL, disk_prefix TEXT NOT NULL, location TEXT NOT NULL, owner_pool_id INTEGER, role TEXT, vpd83 TEXT, rpm INTEGER, link_type INTEGER, FOREIGN KEY(owner_pool_id) REFERENCES pools(id) ON DELETE SET DEFAULT); s; CREATE TABLE volumes ( id INTEGER PRIMARY KEY, vpd83 TEXT NOT NULL, name TEXT UNIQUE NOT NULL, total_space LONG NOT NULL, consumed_size LONG NOT NULL, admin_state INTEGER, is_hw_raid_vol INTEGER, write_cache_policy INTEGER NOT NULL, read_cache_policy INTEGER NOT NULL, phy_disk_cache INTEGER NOT NULL, pool_id INTEGER NOT NULL, FOREIGN KEY(pool_id) REFERENCES pools(id) ON DELETE CASCADE); sx CREATE TABLE ags ( id INTEGER PRIMARY KEY, name TEXT UNIQUE NOT NULL); s� CREATE TABLE inits ( id TEXT UNIQUE NOT NULL, init_type INTEGER NOT NULL, owner_ag_id INTEGER NOT NULL, FOREIGN KEY(owner_ag_id) REFERENCES ags(id) ON DELETE CASCADE); s CREATE TABLE vol_masks ( vol_id INTEGER NOT NULL, ag_id INTEGER NOT NULL, FOREIGN KEY(vol_id) REFERENCES volumes(id) ON DELETE CASCADE, FOREIGN KEY(ag_id) REFERENCES ags(id) ON DELETE CASCADE); sV CREATE TABLE vol_reps ( rep_type INTEGER, src_vol_id INTEGER NOT NULL, dst_vol_id INTEGER NOT NULL, FOREIGN KEY(src_vol_id) REFERENCES volumes(id) ON DELETE CASCADE, FOREIGN KEY(dst_vol_id) REFERENCES volumes(id) ON DELETE CASCADE); s` CREATE TABLE fss ( id INTEGER PRIMARY KEY, name TEXT UNIQUE NOT NULL, total_space LONG NOT NULL, consumed_size LONG NOT NULL, free_space LONG, pool_id INTEGER NOT NULL, FOREIGN KEY(pool_id) REFERENCES pools(id) ON DELETE CASCADE); s CREATE TABLE fs_snaps ( id INTEGER PRIMARY KEY, name TEXT UNIQUE NOT NULL, fs_id INTEGER NOT NULL, timestamp LONG NOT NULL, FOREIGN KEY(fs_id) REFERENCES fss(id) ON DELETE CASCADE); s- CREATE TABLE fs_clones ( src_fs_id INTEGER NOT NULL, dst_fs_id INTEGER NOT NULL, FOREIGN KEY(src_fs_id) REFERENCES fss(id) ON DELETE CASCADE, FOREIGN KEY(dst_fs_id) REFERENCES fss(id) ON DELETE CASCADE); sd CREATE TABLE exps ( id INTEGER PRIMARY KEY, fs_id INTEGER NOT NULL, exp_path TEXT UNIQUE NOT NULL, auth_type TEXT, anon_uid INTEGER, anon_gid INTEGER, options TEXT, FOREIGN KEY(fs_id) REFERENCES fss(id) ON DELETE CASCADE); s� CREATE TABLE exp_root_hosts ( host TEXT NOT NULL, exp_id INTEGER NOT NULL, FOREIGN KEY(exp_id) REFERENCES exps(id) ON DELETE CASCADE); s� CREATE TABLE exp_rw_hosts ( host TEXT NOT NULL, exp_id INTEGER NOT NULL, FOREIGN KEY(exp_id) REFERENCES exps(id) ON DELETE CASCADE); s� CREATE TABLE exp_ro_hosts ( host TEXT NOT NULL, exp_id INTEGER NOT NULL, FOREIGN KEY(exp_id) REFERENCES exps(id) ON DELETE CASCADE); s� CREATE TABLE jobs ( id INTEGER PRIMARY KEY, duration REAL NOT NULL, timestamp TEXT NOT NULL, data_type INTEGER, data_id INTEGER); s� CREATE TABLE batteries ( id INTEGER PRIMARY KEY, name TEXT NOT NULL, type INTEGER NOT NULL, status INTEGER NOT NULL); s� CREATE VIEW pools_view AS SELECT pool0.id, 'POOL_ID_' || SUBSTR('{ID_PADDING}' || pool0.id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_pool_id, pool0.name, pool0.status, pool0.status_info, pool0.element_type, pool0.unsupported_actions, pool0.raid_type, pool0.member_type, pool0.parent_pool_id, 'POOL_ID_' || SUBSTR('{ID_PADDING}' || pool0.parent_pool_id, -{ID_FMT_LEN}, {ID_FMT_LEN}) parent_lsm_pool_id, pool0.strip_size, pool1.total_space total_space, pool1.total_space - pool2.vol_consumed_size - pool3.fs_consumed_size - pool4.sub_pool_consumed_size free_space, pool1.data_disk_count, pool5.disk_count FROM pools pool0 LEFT JOIN ( SELECT pool.id, ifnull(pool.total_space, ifnull(SUM(disk.total_space), 0)) total_space, COUNT(disk.id) data_disk_count FROM pools pool LEFT JOIN disks disk ON pool.id = disk.owner_pool_id AND disk.role = 'DATA' GROUP BY pool.id ) pool1 ON pool0.id = pool1.id LEFT JOIN ( SELECT pool.id, ifnull(SUM(volume.consumed_size), 0) vol_consumed_size FROM pools pool LEFT JOIN volumes volume ON volume.pool_id = pool.id GROUP BY pool.id ) pool2 ON pool0.id = pool2.id LEFT JOIN ( SELECT pool.id, ifnull(SUM(fs.consumed_size), 0) fs_consumed_size FROM pools pool LEFT JOIN fss fs ON fs.pool_id = pool.id GROUP BY pool.id ) pool3 ON pool0.id = pool3.id LEFT JOIN ( SELECT pool.id, ifnull(SUM(sub_pool.total_space), 0) sub_pool_consumed_size FROM pools pool LEFT JOIN pools sub_pool ON sub_pool.parent_pool_id = pool.id GROUP BY pool.id ) pool4 ON pool0.id = pool4.id LEFT JOIN ( SELECT pool.id, COUNT(disk.id) disk_count FROM pools pool LEFT JOIN disks disk ON pool.id = disk.owner_pool_id GROUP BY pool.id ) pool5 ON pool0.id = pool5.id GROUP BY pool0.id; s CREATE VIEW tgts_view AS SELECT id, 'TGT_PORT_ID_' || SUBSTR('{ID_PADDING}' || id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_tgt_id, port_type, service_address, network_address, physical_address, physical_name FROM tgts; s� CREATE VIEW disks_view AS SELECT id, 'DISK_ID_' || SUBSTR('{ID_PADDING}' || id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_disk_id, disk_prefix || '_' || id name, total_space, disk_type, role, status, vpd83, rpm, link_type, location, owner_pool_id FROM disks; sf CREATE VIEW volumes_view AS SELECT id, 'VOL_ID_' || SUBSTR('{ID_PADDING}' || id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_vol_id, vpd83, name, total_space, consumed_size, admin_state, is_hw_raid_vol, write_cache_policy, read_cache_policy, phy_disk_cache, pool_id, 'POOL_ID_' || SUBSTR('{ID_PADDING}' || pool_id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_pool_id FROM volumes; s� CREATE VIEW fss_view AS SELECT id, 'FS_ID_' || SUBSTR('{ID_PADDING}' || id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_fs_id, name, total_space, consumed_size, free_space, pool_id, 'POOL_ID_' || SUBSTR('{ID_PADDING}' || pool_id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_pool_id FROM fss; s� CREATE VIEW bats_view AS SELECT id, 'BAT_ID_' || SUBSTR('{ID_PADDING}' || id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_bat_id, name, type, status FROM batteries; sp CREATE VIEW fs_snaps_view AS SELECT id, 'FS_SNAP_ID_' || SUBSTR('{ID_PADDING}' || id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_fs_snap_id, name, timestamp, fs_id, 'FS_ID_' || SUBSTR('{ID_PADDING}' || fs_id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_fs_id FROM fs_snaps; s; CREATE VIEW volumes_by_ag_view AS SELECT vol.id, 'VOL_ID_' || SUBSTR('{ID_PADDING}' || vol.id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_vol_id, vol.vpd83, vol.name, vol.total_space, vol.consumed_size, vol.pool_id, 'POOL_ID_' || SUBSTR('{ID_PADDING}' || vol.pool_id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_pool_id, vol.admin_state, vol.is_hw_raid_vol, vol_mask.ag_id ag_id, vol.write_cache_policy, vol.read_cache_policy, vol.phy_disk_cache FROM volumes vol LEFT JOIN vol_masks vol_mask ON vol_mask.vol_id = vol.id; s CREATE VIEW ags_view AS SELECT ag.id, 'AG_ID_' || SUBSTR('{ID_PADDING}' || ag.id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_ag_id, ag.name, CASE WHEN count(DISTINCT init.init_type) = 1 THEN init.init_type WHEN count(DISTINCT init.init_type) = 2 THEN {AG_INIT_TYPE_MIXED} ELSE {AG_INIT_TYPE_UNKNOWN} END init_type, group_concat(init.id, '{SPLITTER}') init_ids_str FROM ags ag LEFT JOIN inits init ON ag.id = init.owner_ag_id GROUP BY ag.id ORDER BY init.init_type; sO CREATE VIEW ags_by_vol_view AS SELECT ag_new.id, 'AG_ID_' || SUBSTR('{ID_PADDING}' || ag_new.id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_ag_id, ag_new.name, ag_new.init_type, ag_new.init_ids_str, vol_mask.vol_id vol_id FROM ( SELECT ag.id, ag.name, CASE WHEN count(DISTINCT init.init_type) = 1 THEN init.init_type WHEN count(DISTINCT init.init_type) = 2 THEN {AG_INIT_TYPE_MIXED} ELSE {AG_INIT_TYPE_UNKNOWN} END init_type, group_concat(init.id, '{SPLITTER}') init_ids_str FROM ags ag LEFT JOIN inits init ON ag.id = init.owner_ag_id GROUP BY ag.id ORDER BY init.init_type ) ag_new LEFT JOIN vol_masks vol_mask ON vol_mask.ag_id = ag_new.id ; sg CREATE VIEW exps_view AS SELECT exp.id, 'EXP_ID_' || SUBSTR('{ID_PADDING}' || exp.id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_exp_id, exp.fs_id, 'FS_ID_' || SUBSTR('{ID_PADDING}' || exp.fs_id, -{ID_FMT_LEN}, {ID_FMT_LEN}) lsm_fs_id, exp.exp_path, exp.auth_type, exp.anon_uid, exp.anon_gid, exp.options, exp2.exp_root_hosts_str, exp3.exp_rw_hosts_str, exp4.exp_ro_hosts_str FROM exps exp LEFT JOIN ( SELECT exp_t2.id, group_concat( exp_root_host.host, '{SPLITTER}') exp_root_hosts_str FROM exps exp_t2 LEFT JOIN exp_root_hosts exp_root_host ON exp_t2.id = exp_root_host.exp_id GROUP BY exp_t2.id ) exp2 ON exp.id = exp2.id LEFT JOIN ( SELECT exp_t3.id, group_concat( exp_rw_host.host, '{SPLITTER}') exp_rw_hosts_str FROM exps exp_t3 LEFT JOIN exp_rw_hosts exp_rw_host ON exp_t3.id = exp_rw_host.exp_id GROUP BY exp_t3.id ) exp3 ON exp.id = exp3.id LEFT JOIN ( SELECT exp_t4.id, group_concat( exp_ro_host.host, '{SPLITTER}') exp_ro_hosts_str FROM exps exp_t4 LEFT JOIN exp_ro_hosts exp_ro_host ON exp_t4.id = exp_ro_host.exp_id GROUP BY exp_t4.id ) exp4 ON exp.id = exp4.id GROUP BY exp.id; ; t 0t ID_PADDINGt ID_FMT_LENt AG_INIT_TYPE_MIXEDt AG_INIT_TYPE_UNKNOWNt SPLITTERs already existssL Stored simulator state incompatible with simulator, please move or delete %s(! t ost patht existst closet opent O_WRONLYt O_CREATt chmodt statefilet Nonet lastrowidR t connectt intR t sql_connR3 t row_factoryt formatRP t _ID_FMT_LENR t INIT_TYPE_ISCSI_WWPN_MIXEDt INIT_TYPE_UNKNOWNt _LIST_SPLITTERR. t executescriptR R t DatabaseErrorR R t INVALID_ARGUMENT( t selfRc RR t sql_cmdt sql_curR ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt __init__� s� # ' ] 'E c C s{ | j � } t | � d k s) | d r- t Sd | d j � k r^ | d d t j k r^ t St t j d | j � � d S( Ni t versionsL Stored simulator state incompatible with simulator, please move or delete %s( t sim_sysst lenR: R9 RP t VERSION_SIGNATUREt TrueR R Rq Rc ( Rr Rw ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _check_version- s c C s* | j � | j � r$ | j � d S| j d i t j d 6t j d 6t j d 6d d 6t j d 6t j d 6� t d � } t d � } g } x t d d � D]n } | j d i d d 6| d 6t j d 6t j d 6t � d 6d d 6t j d 6d | d 6� | j | j � q� Wg } x� t d d � D]� } | j d i d d 6| d 6t j d 6t j d 6t � d 6d d 6t j d 6d | d 6� t | � d k r#| j | j � q#q#Wg } x� t d d � D]� } | j d i d d 6| d 6t j d 6t j d 6t � d 6t j d 6t j d 6d | d 6� t | � d k r�| j | j � q�q�Wxr t d d � D]a } | j d i d! d 6| d 6t j d 6t j d 6t � d 6t j d 6t j d 6d" | d 6� qZW| j d d# d$ t j d% | d& t j t j Bt j Bt j Bt j Bd' t j! t j" B� } | j# d d( d) | d& t j t j Bt j Bd* | � | j d d+ d$ t j d% | d& t j t j Bt j B� | j d d, d& t j t j Bt j Bd$ t j$ d% | � | j d- i t% j& d. 6d/ d0 6d/ d1 6d/ d2 6d3 d4 6� | j d- i t% j' d. 6d5 d0 6d5 d1 6d5 d2 6d6 d4 6� | j d- i t% j( d. 6d7 d0 6d8 d1 6d9 d2 6d: d4 6� | j d- i t% j( d. 6d7 d0 6d; d1 6d< d2 6d= d4 6� | j d- i t% j( d. 6d7 d0 6d> d1 6d< d2 6d= d4 6� | j d? i d@ d 6t) j* dA 6t) j d 6� | j d? i dB d 6t) j+ dA 6t) j d 6� | j � d Sd S(C s^ Raise error if version not match. If empty database found, initiate. Nt systemst idt namet statusR# t status_infoRv t read_cache_pctt 2TiBt 512GiBi i t diskss 2TiB SATA Diskt disk_prefixt total_spacet disk_typet vpd83i t rpmt link_types Port: %d Box: 1 Bay: 1t locationi s 2TiB SAS Diski�: s Port: %d Box: 1 Bay: 2i s 512GiB SSD Disks Port: %d Box: 1 Bay: 3i s 2TiB SSD Disks Port: %d Box: 1 Bay: 4s Pool 1R< t sim_disk_idst element_typet unsupported_actionss Pool 2(sub pool of Pool 1)t parent_pool_idt sizes Pool 3t lsm_test_aggrt tgtst port_types 50:0a:09:86:99:4b:8d:c5t service_addresst network_addresst physical_addresst FC_a_0bt physical_names 50:0a:09:86:99:4b:8d:c6t FCoE_b_0cs" iqn.1986-05.com.example:sim-tgt-03s sim-iscsi-tgt-3.example.com:3260s a4:4e:31:47:f4:e0t iSCSI_c_0ds 10.0.0.1:3260s a4:4e:31:47:f4:e1t iSCSI_c_0es% [2001:470:1f09:efe:a64e:31ff::1]:3260t batteriess' Battery SIMB01, 8000 mAh, 05 March 2016R s& Capacitor SIMC01, 500 J, 05 March 2016(, t trans_beginR{ t trans_committ _data_addRP t SYS_IDt SYS_NAMER t STATUS_OKRy t _DEFAULT_READ_CACHE_PCTR R$ R t TYPE_SATAR+ t LINK_TYPE_ATAR% Re t TYPE_SASt LINK_TYPE_SASRx t TYPE_SSDt RPM_NON_ROTATING_MEDIUMt sim_pool_create_from_diskR RC R t ELEMENT_TYPE_POOLt ELEMENT_TYPE_FSt ELEMENT_TYPE_VOLUMEt ELEMENT_TYPE_DELTAt ELEMENT_TYPE_SYS_RESERVEDt UNSUPPORTED_VOLUME_GROWt UNSUPPORTED_VOLUME_SHRINKt sim_pool_create_sub_poolRB R t TYPE_FCt TYPE_FCOEt TYPE_ISCSIR t TYPE_CHEMICALt TYPE_CAPACITOR( Rr t size_bytes_2tt size_bytes_512gt pool_1_diskst it test_pool_diskst ssd_pool_diskst pool_1_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt check_version_and_init; s. c C s2 | j j � } | j | � | j | _ | j � S( s9 Execute sql command and get all output. ( Rh R. t executeRe t fetchall( Rr Rs Rt ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sql_exec� s c C s d | } | j | � S( Ns SELECT * FROM %s( R� ( Rr t table_nameRs ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _get_table s c C s | j j d � d S( Ns BEGIN IMMEDIATE TRANSACTION;( Rh R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� s c C s | j j � d S( N( Rh t commit( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� s c C s | j j � d S( N( Rh t rollback( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR s c C s� t | j � � } g t | j � � D]$ } | d k r= d n t | � ^ q% } d | d d j | � d d j | � f } | j | � d S( NR# s INSERT INTO %s (%s) VALUES (%s);s '%s's ', '( R7 R9 t valuesRd R R( R� ( Rr R� t data_dictR9 t vR� Rs ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� s =c C sy d | | f } | j | � } | rq t | � d k r; d St | � d k rU | d St t j d t � � � n | Sd S( Ns SELECT * FROM %s WHERE %si i s% _data_find(): Got non-unique data: %s( R� Rx Rd R R R t locals( Rr t tablet conditiont flag_uniqueRs t sim_datas( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _data_find s c C sI | d k r" d | | | f } n d | | | | f } | j | � d S( Ns# UPDATE %s SET %s=NULL WHERE id='%s's# UPDATE %s SET %s='%s' WHERE id='%s'( Rd R� ( Rr R� t data_idt column_namet valueRs ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _data_update- s c C s! d | | f } | j | � d S( Ns DELETE FROM %s WHERE %s;( R� ( Rr R� R� Rs ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _data_delete7 s c C sH | j d i t j d t j � d 6t j � d 6| d 6| d 6� | j S( s* Return a job id(Integer) t jobst LSM_SIM_TIMEt durationt timestampt data_typeR� ( R� R[ t getenvRP t JOB_DEFAULT_DURATIONt timeRe ( Rr t job_data_typeR� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_job_create; s c C s | j d d | � d S( NR� s id="%s"( R� ( Rr t sim_job_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_job_deleteJ s c C sE | j d d | d t �} | d k r= t t j d � � n t t j � t | d � | d d � } d } d } | d k r� d } n | d k r8d } | d t j k r� | j | d � } | d } q8| d t j k r| j | d � } | d } q8| d t j k r8| j | d � } | d } q8n | | | f S( sg Return (progress, data_type, data) tuple. progress is the integer of percent. R� s id=%sR� s Job not foundR� R� id i R� R� N( R� Rz Rd R R t NOT_FOUND_JOBRg R� t floatRP t JOB_DATA_TYPE_VOLt sim_vol_of_idt JOB_DATA_TYPE_FSt sim_fs_of_idt JOB_DATA_TYPE_FS_SNAPt sim_fs_snap_of_id( Rr R� t sim_jobt progresst dataR� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_job_statusM s. ) c C s | j d � S( s0 Return a list of sim_sys dict. R| ( R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyRw p s c C s$ t d � | j d d | � D� � S( Nc s s | ] } | d Vq d S( t lsm_disk_idN( ( t .0R0 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>x s t disks_views owner_pool_id="%s"( R7 R� ( Rr t sim_pool_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt lsm_disk_ids_of_poolv s c C s | j d � S( s1 Return a list of sim_disk dict. R� ( R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_disks| s c C s | j d � S( s1 Return a list of sim_pool dict. t pools_view( R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_pools� s c C s | j d | t j d � S( NR� R ( t _sim_data_of_idR t NOT_FOUND_POOL( Rr R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_pool_of_id� s i c C s7 | d k r t j } n | t j k s6 | t j k rB t j } n | j d i | d 6t j d 6d d 6| d 6| d 6| d 6t j d 6| d 6� t j | t | � � } | j } x> | | D]2 } | j d | d | � | j d | d d � q� Wx> | | D]2 } | j d | d | � | j d | d d � q� W| S( Ni t poolsR~ R R# R� R� R� R< t member_typet strip_sizeR� t owner_pool_idt rolet DATAt PARITY( RP t DEFAULT_STRIP_SIZER RC RA t BLK_SIZER� R R� t MEMBER_TYPE_DISKR4 R> Rx Re R� ( Rr R~ R� R< R� R� R� R> R� t sim_disk_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� � s< c C s_ | j d i | d 6t j d 6d d 6| d 6| d 6t j d 6t j d 6| d 6| d 6� | j S( NR� R~ R R# R� R� R� R< R� R� R� ( R� R R� R t RAID_TYPE_OTHERt MEMBER_TYPE_POOLRe ( Rr R~ R� R� R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� � s c C s | j d | � d d S( Ns3 SELECT COUNT(id) FROM disks WHERE owner_pool_id=%s;i ( R� ( Rr R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_pool_disks_count� s c C s | j d | � d d S( NsC SELECT COUNT(id) FROM disks WHERE owner_pool_id=%s and role='DATA';i ( R� ( Rr R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_pool_data_disks_count� s c C s+ | r | j d d | � S| j d � Sd S( s0 Return a list of sim_vol dict. t volumes_by_ag_views ag_id=%st volumes_viewN( R� R� ( Rr t sim_ag_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vols� s c C sO | j | d | d t �} | d k rK | rD t | d | � � qK d Sn | S( Ns id=%sR� s %s not found( R� Rz Rd R ( Rr R� R� t lsm_error_not data_namet sim_data( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� � s c C s | j d | t j d � S( sD Return sim_vol if found. Raise error if not found. R R ( R� R t NOT_FOUND_VOLUME( Rr t sim_vol_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� � s c C s8 | j | � } | d | k r4 t t j d � � n d S( Nt free_spaces Insufficient space in pool( R� R R t NOT_ENOUGH_SPACE( Rr R� t size_bytest sim_pool( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _check_pool_free_space� s c C s | t j d t j t j S( Ni ( RP R ( R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _block_rounding� s c C s� t j | � } | j | | � t � } t � | d <| | d <| | d <| | d <| | d <t j | d <| | d <t j | d <t j | d <t j | d <y | j d | � Wn, t j k r� } t t j d | � � n X| j S( NR� R~ t pool_idR� t consumed_sizet admin_statet is_hw_raid_volt write_cache_policyt read_cache_policyt phy_disk_cachet volumess+ Name '%s' is already in use by other volume( RP R R t dictR+ R t ADMIN_STATE_ENABLEDt DEFAULT_WRITE_CACHE_POLICYt DEFAULT_READ_CACHE_POLICYt DEFAULT_PHYSICAL_DISK_CACHER� R t IntegrityErrorR R t NAME_CONFLICTRe ( Rr R~ R R� R t sim_volR ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_create� s( c C s | j | � } | j | � r3 t t j d � � n | j | � } t | � d k r� x2 | D]' } | | k r[ t t j d � � q[ q[ Wn | d r� x< | j d d | d � D] } | j d | d d d � q� W| j d d | d � n | j d d | � d S( sB This does not check whether volume exist or not. s Volume is masked to access groupi s% Requested volume has child dependencyR R� s owner_pool_id="%s"R R� R} R� R� s id="%s"R N( R� t _sim_ag_ids_of_masked_volR R t IS_MASKEDt dst_sim_vol_ids_of_srcRx t HAS_CHILD_DEPENDENCYR� R� Rd R� ( Rr R R% t dst_sim_vol_idst dst_sim_vol_idR0 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_delete s$ c C ss | j | � | j | � | j d d | | f � } | rQ t t j d � � n | j d i | d 6| d 6� d S( Nt vol_maskss ag_id="%s" AND vol_id="%s"s2 Volume is already masked to requested access groupt ag_idt vol_id( R� t sim_ag_of_idR� R R t NO_STATE_CHANGER� Rd ( Rr R R t exist_mask( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_mask2 s c C sk | j | � | j | � d | | f } | j d | � } | rU | j d | � n t t j d � � d S( Ns ag_id="%s" AND vol_id="%s"R. s. Volume is not masked to requested access group( R� R1 R� R� R R R2 Rd ( Rr R R R� R3 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_unmaskB s c C s$ t d � | j d d | � D� � S( Nc s s | ] } | d Vq d S( R0 N( ( R� t m( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>Q s R. s ag_id="%s"( R7 R� ( Rr R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_vol_ids_of_masked_agO s c C s$ t d � | j d d | � D� � S( Nc s s | ] } | d Vq d S( R/ N( ( R� R6 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>V s R. s vol_id="%s"( R7 R� ( Rr R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR' T s c C s t j | � } | j | � } | d | k rC t t j d � � n | j | d � } | | d } | d k r� | d t j @r� t t j d � � n | d | k r� t t j d � � q� n& | d t j @r� t t j d � � n | j d | d | � | j d | d | � d S( NR� s% Volume size is identical to requestedR i R� s. Requested pool does not allow volume size growR s Insufficient space in poolR R ( RP R R� R R R2 R� R R� t NO_SUPPORTR R� R� ( Rr R t new_size_bytesR% R t increment( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_resizeY s0 c C s1 | j | � t d � | j d d | � D� � S( sL Return a list of dst_vol_id for provided source volume ID. c s s | ] } | d Vq d S( t dst_vol_idN( ( R� R0 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s t vol_repss src_vol_id="%s"( R� R7 R� ( Rr t src_sim_vol_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR) | s c C s� | j | � | j | � | | k r* d S| t j k r= d St d � | j d d | � D� � } t | � d k ry d S| j d i | d 6| d 6| d 6� d S( Nc s s | ] } | d Vq d S( t src_vol_idN( ( R� t r( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s R= s dst_vol_id="%s"i R? R< t rep_type( R� R t REPLICATE_COPYR7 R� Rx R� ( Rr R> R, RA t blk_rangest cur_src_sim_vol_ids( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_replica� s" c C s< | j | � s$ t t j d � � n | j d d | � d S( Ns+ Provided volume is not a replication sourceR= s src_vol_id="%s"( R) R R R2 R� ( Rr R> ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_src_replica_break� s c C sN | j | � } | d | k r4 t t j d � � n | j d | d | � d S( NR s, Volume admin state is identical to requestedR ( R� R R R2 R� ( Rr R t new_admin_stateR% ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_state_change� s c C s% | d j t j � | d <| d =| S( s= Update 'init_type' and 'init_ids' of sim_ag t init_ids_strt init_ids( t splitRP Rn ( t sim_ag( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_ag_format� s c C sN | r | j d d | � } n | j d � } g | D] } t j | � ^ q5 S( Nt ags_by_vol_views vol_id=%st ags_view( R� R� RP RM ( Rr R t sim_agst a( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyRP � s c C s\ y) | j d i | d 6| d 6| d 6� Wn, t j k rW } t t j d | � � n Xd S( Nt initsR} t init_typet owner_ag_ids6 Initiator '%s' is already in use by other access group( R� R R# R R t EXISTS_INITIATOR( Rr RS t init_idR R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_init_create� s c C s d S( N( Rd ( Rr RV t in_usert in_passt out_usert out_pass( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt iscsi_chap_auth_set� s c C sj y$ | j d i | d 6� | j } Wn, t j k rR } t t j d | � � n X| j | | | � | S( Nt agsR~ s1 Name '%s' is already in use by other access group( R� Re R R# R R R$ RW ( Rr R~ RS RV R R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_ag_create� s c C sI | j | � | j | � r1 t t j d � � n | j d d | � d S( Ns! Access group has volume masked toR] s id="%s"( R1 R7 R R R( R� ( Rr R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_ag_delete� s c C s~ | j | � } | | d k r4 t t j d � � n | t j k rg | t j k rg t t j d � � n | j | | | � d S( NRJ s! Initiator already in access groups. Only support iSCSI IQN and WWPN initiator type( R1 R R R2 R t INIT_TYPE_ISCSI_IQNt INIT_TYPE_WWPNR8 RW Rd ( Rr R RV RS RL ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_ag_init_add� s c C sw | j | � } | | d k r4 t t j d � � n t | d � d k r_ t t j d � � n | j d d | � d S( NRJ s( Initiator is not in defined access groupi s6 Refused to remove the last initiator from access groupRR s id="%s"( R1 R R R2 Rx t LAST_INIT_IN_ACCESS_GROUPR� ( Rr R RV RL ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_ag_init_delete s c C s, | j d | t j d � } t j | � | S( NRO s Access Group( R� R t NOT_FOUND_ACCESS_GROUPRP RM ( Rr R RL ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR1 s c C s | j d � S( s/ Return a list of sim_fs dict. t fss_view( R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fss s c C s. t j } | s d } n | j d | | d � S( NRf s File System( R t NOT_FOUND_FSRd R� ( Rr t sim_fs_idt raise_errorR ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� " s c C s� t j | � } | j | | � y7 | j d i | d 6| d 6| d 6| d 6| d 6� Wn, t j k r� } t t j d | � � n X| j S( Nt fssR~ R� R R R s' Name '%s' is already in use by other fs( RP R R R� R R# R R R$ Re ( Rr R~ R R� R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_create* s c C sI | j | � | j | � r1 t t j d � � n | j d d | � d S( Ns* Requested file system has child dependencyRk s id="%s"( R� t clone_dst_sim_fs_ids_of_srcR R R* R� ( Rr Ri ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_delete= s c C s� t j | � } | j | � } | d | k rC t t j d � � n | j | d � } | | d k r� | d | | d k r� t t j d � � n | j d | d | � | j d | d | � | j d | d | � d S( NR� s* File System size is identical to requestedR R s Insufficient space in poolRk R ( RP R R� R R R2 R� R R� ( Rr Ri R9 t sim_fsR ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_resizeF s" c C s! | j | � | j d d | � S( Nt fs_snaps_views fs_id="%s"( R� R� ( Rr Ri ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_snaps` s c C sJ | j d | t j d � } | rF | d | k rF t t j d � � n | S( NRq s File system snapshott fs_idsF Defined file system snapshot ID is not belong to requested file system( R� R t NOT_FOUND_FS_SSR ( Rr t sim_fs_snap_idRi t sim_fs_snap( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� d s c C st | j | � y5 | j d i | d 6| d 6t t j � � d 6� Wn( t j k rl } t t j d � � n X| j S( Nt fs_snapsR~ Rs R� s6 The name is already used by other file system snapshot( R� R� Rg R� R R# R R R$ Re ( Rr Ri R~ R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_snap_createo s c C s* | j | � | r& | j | | � n d S( N( R� R� ( Rr Ri Ru t filest restore_filest flag_all_files( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_snap_restore s c C s5 | j | � | j | | � | j d d | � d S( NRw s id="%s"( R� R� R� ( Rr Ru Ri ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_snap_delete� s c C s d | } | j | � d S( Ns& DELETE FROM fs_snaps WHERE fs_id='%s';( R� ( Rr Ri Rs ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_snap_del_by_fs� s c C sU | j | � | j | � | r3 | j | | � n | j d i | d 6| d 6� d S( Nt fs_clonest src_fs_idt dst_fs_id( R� R� R� ( Rr t src_sim_fs_idt dst_sim_fs_idRu ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_clone� s c C s* | j | � | r& | j | | � n d S( N( R� R� ( Rr Ri t src_fs_namet dst_fs_nameRu ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_file_clone� s c C s1 | j | � t d � | j d d | � D� � S( sM Return a list of dst_fs_id for provided clone source fs ID. c s s | ] } | d Vq d S( R� N( ( R� R0 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s R s src_fs_id="%s"( R� R7 R� ( Rr R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyRm � s c C s | j d d | � d S( NR s src_fs_id="%s"( R� ( Rr R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_fs_src_clone_break� s c C s` xY d d d g D]H } d | } | | rG | | j t j � | | <n g | | <| | =q W| S( Nt root_hostst rw_hostst ro_hostss exp_%s_str( RK RP Rn ( Rr t sim_expt key_nameR� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_exp_format� s c s# t � f d � � j d � D� � S( Nc 3 s | ] } � j | � Vq d S( N( R� ( R� t e( Rr ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s t exps_view( R7 R� ( Rr ( ( Rr s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_exps� s c C s" | j | j d | t j d � � S( NR� s NFS Export( R� R� R t NOT_FOUND_NFS_EXPORT( Rr t sim_exp_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_exp_of_id� s c C s0 | d k r d t � d } n | j | � y> | j d i | d 6| d 6| d 6| d 6| d 6| d 6� Wn( t j k r� } t t j d � � n X| j } x, | D]$ } | j d i | d 6| d 6� q� Wx, | D]$ } | j d i | d 6| d 6� q� Wx, | D]$ } | j d i | d 6| d 6� qW| S( Ns /nfs_exp_%si t expsRs t exp_patht anon_uidt anon_gidt auth_typet optionss/ Export path is already used by other NFS exportt exp_root_hostst hostt exp_idt exp_rw_hostst exp_ro_hosts( Rd R+ R� R� R R# R R R$ Re ( Rr Ri R� R� R� R� R� R� R� R� R R� t root_hostt rw_hostt ro_host( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_exp_create� sJ c C s% | j | � | j d d | � d S( NR� s id="%s"( R� R� ( Rr R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_exp_delete� s c C s | j d � S( s0 Return a list of sim_tgt dict. t tgts_view( R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_tgts s c C s | j d � S( s0 Return a list of sim_bat dict. t bats_view( R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_bats s c C s' | j | � | j d | d | � d S( NR R ( R� R� ( Rr R t pdc( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_pdc_set s c C s' | j | � | j d | d | � d S( NR R ( R� R� ( Rr R t rcp( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_rcp_set s c C s' | j | � | j d | d | � d S( NR R ( R� R� ( Rr R t wcp( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt sim_vol_wcp_set s (q R? R@ t VERSIONR Ry R� R� R� R� R� R� R R� R t MODE_HARDWARE_RAIDt SYS_MODER t WRITE_CACHE_POLICY_AUTOR t READ_CACHE_POLICY_ENABLEDR! t PHYSICAL_DISK_CACHE_DISABLEDR" R� Rn Rk RB RC RF RG RH RK RL t SUPPORTED_VCR_RAID_TYPESt SUPPORTED_VCR_STRIP_SIZESRu R{ R� R� R� R� R� R R� R: R� R� R� Rd R� R� R� Rw R� R� R� R� R� R� R R R R� R� R RO R R& R- R4 R5 R7 R' R; R) RE RF RH RM RP RW R\ R^ R_ Rb Rd R1 Rg Rz R� Rl Rn Rp Rr R� Rx R| R} R~ R� R� Rm R� R� R� R� R� R� R� R� R� R� R� ( ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyRP � s� * � � � � # ) # 2 R c B s% e Z e j d e j � 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 dO dO d � Z e d d � � Z e d d � � Z e d d � � Z e d d � � Z e d � � Z e d � � Z e d d � � Z e d � � Z e d � � Z e d � � Z e d d � � Z e d � � Z e d � � Z e d e! d d � � Z" e d d � � Z# e d d � � Z$ e d d � � Z% e d d � � Z& e d d � � Z' e d d � � Z( e d d! � � Z) e d d" � � Z* e d d# � � Z+ e d$ � � Z, e d% � � Z- e d e! d& � � Z. e d d' � � Z/ e d d( � � Z0 e d d) � � Z1 e d d* � � Z2 e d+ � � Z3 e d d, � � Z4 e d d- � � Z5 e d d. � � Z6 e d/ � � Z7 e d e! d0 � � Z8 e d d1 � � Z9 e d2 � � Z: e d d3 � � Z; e d d4 � � Z< e d d5 � � Z= e d6 � � Z> e d7 � � Z? e d d8 � � Z@ e d d9 � � ZA e d d: � � ZB e d d; � � ZC e d d< � � ZD e d d= � � ZE e d d> � � ZF e d d? � � ZG e d d@ � � ZH e dA � � ZI e dB � � ZJ e dC � � ZK e dD � � ZL e dE � � ZM e dF � � ZN e d dG � � ZO e d dH � � ZP e dI � � ZQ e dJ � � ZR e dK � � ZS e d dL � � ZT e d dM � � ZU e d dN � � ZV RS(P t LSM_SIM_DATAs /lsm_sim_datac C s4 y t | t j � SWn t k r/ | � n Xd S( N( Rg RP Rk t ValueError( t lsm_idt lsm_error( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _lsm_id_to_sim_id s c C s t j | t t j d � � S( Ns Job not found( R R� R R R� ( t job_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_job_id_of& s c C s t j | t t j d � � S( Ns Pool not found( R R� R R R� ( R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_pool_id_of+ s c C s t j | t t j d � � S( Ns Volume not found( R R� R R R ( R0 ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_vol_id_of0 s c C s t j | t t j d � � S( Ns File system not found( R R� R R Rh ( Rs ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_fs_id_of6 s c C s t j | t t j d � � S( Ns File system snapshot not found( R R� R R Rt ( t snap_id( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_fs_snap_id_of< s c C s t j | t t j d � � S( Ns File system export not found( R R� R R R� ( R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_exp_id_ofC s c C s t j | t t j d � � S( Ns File system export not found( R R� R R R� ( R/ ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_ag_id_ofJ s c C sM | d k r t j } n t | | � | _ | j j � | | _ | | _ d S( N( Rd R t SIM_DATA_FILERP R R� Rc RR ( Rr Rc RR ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyRu Q s c C s& | j j | | � } d t j | f S( Ns JOB_ID_%0*d( R R� RP Rk ( Rr R� t sim_data_idR� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _job_create[ s i c C s� t j | � } | j j | � \ } } } t j } | d k rK t j } n d } | t j k rr t j | � } nB | t j k r� t j | � } n! | t j k r� t j | � } n | | | f S( Nid ( R R� R R� R t INPROGRESSt COMPLETERd RP R� t _sim_vol_2_lsmR� t _sim_fs_2_lsmR� t _sim_fs_snap_2_lsm( Rr R� t flagsR� R� R� R R R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt job_status` s c C s7 | j j � | j j t j | � � | j j � d S( N( R R� R� R R� R� Rd ( Rr R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt job_freet s c C s1 t | j t t | d � � � | _ | | _ d S( Ni� ( RP Rc Rg R R RR Rd ( Rr t msR� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt time_out_set{ s $ c C s | j S( N( RR ( Rr R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt time_out_get� s c C s@ t | d | d | d | d d | d d t j d | d �S( NR} R~ R R� t _fw_versionRv t _modet _read_cache_pctR� ( R RP R� ( t sim_sys( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_sys_2_lsm� s c C s t d � | j j � D� � S( Nc s s | ] } t j | � Vq d S( N( R R� ( R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s ( R7 R Rw ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR| � s c C sa | j t j k r' t t j d � � n | j j � | j j d t j d | � | j j � d S( Ns System not foundR| R� ( R} RP R� R R t NOT_FOUND_SYSTEMR R� R� R� Rd ( Rr t systemt read_pctR� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt system_read_cache_pct_update� s c C sO t | d | d | d t j t t | d t j � � | d t j | d � S( Nt lsm_vol_idR~ R� R� R t lsm_pool_id( R RP R Rg R R� ( R% ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� � s c C s t d � | j j � D� � S( Nc s s | ] } t j | � Vq d S( N( R R� ( R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s ( R7 R R ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR � s c C s{ | d } | d } | d } | d } | d } | d } t j } | d } | d } t | | | | | | | | | � S( NR� R~ R� R R R� R� R� ( RP R� R ( R R R~ R� R R R� t sys_idR� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_pool_2_lsm� s c C s= | j j � | j j � } | j j � t d � | D� � S( Nc s s | ] } t j | � Vq d S( N( R R� ( R� R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s ( R R� R� R R7 ( Rr R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� � s c C s� t j } | d d k r) | t j O} n t | d | d | d t j t t | d t j � � | t j d | d d | d d | d d | d �S( NR� R� R~ R� R� t _vpd83R� t _locationR� t _rpmR� t _link_typeR� ( R R� Rd t STATUS_FREERP R Rg R R� ( t sim_diskt disk_status( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_disk_2_lsm� s c C s t d � | j j � D� � S( Nc s s | ] } t j | � Vq d S( N( R R� ( R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s ( R7 R R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� � s c C sy | t k r | j j � n | j j | | t j | � d | �} | rM | S| j t j | � } | j j � | d f S( s� The '_internal_use' parameter is only for SimArray internal use. This method will return the new sim_vol id instead of job_id when '_internal_use' marked as True. R N( R: R R� R& R R� R� RP R� R� Rd ( Rr R t vol_nameR t thinpR� t _internal_uset _is_hw_raid_volt new_sim_vol_idR� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_create� s c C sC | j j � | j j t j | � � | j � } | j j � | S( N( R R� R- R R� R� R� ( Rr R0 R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_delete� s c C s[ | j j � t j | � } | j j | | � | j t j | � } | j j � | d f S( N( R R� R R� R; R� RP R� R� Rd ( Rr R0 R9 R� R R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_resize� s c C s� | j j � t j | � } | j j | � } | j | | | d t j d t �} | j j | | | � | j t j | � } | j j � | d f S( NR� R� ( R R� R R� R� R� R t PROVISION_FULLRz RE R� RP R� R� Rd ( Rr t dst_pool_idRA R? t new_vol_nameR� R> t src_sim_volR, R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_replicate s c C s+ | t j k r$ t t j d � � n t j S( Ns System not found( RP R� R R R� R ( Rr R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt! volume_replicate_range_block_size s c C sU | j j � | j j t j | � t j | � | | � | j � } | j j � | S( N( R R� RE R R� R� R� ( Rr RA R? R< t rangesR� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_replicate_range# s c C s= | j j � | j j t j | � t j � | j j � d S( N( R R� RH R R� R R R� Rd ( Rr R0 R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_enable5 s c C s= | j j � | j j t j | � t j � | j j � d S( N( R R� RH R R� R t ADMIN_STATE_DISABLEDR� Rd ( Rr R0 R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_disable= s c C sF t j | � } | j j | � } x | D] } | | k r( t Sq( Wt S( N( R R� R R) Rz R: ( Rr R0 R� R> R+ R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_child_dependencyE s c C sC | j j � | j j t j | � � | j � } | j j � | S( N( R R� RF R R� R� R� ( Rr R0 R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_child_dependency_rm` s c C s0 t | d | d | d | d | d t j � S( Nt lsm_fs_idR~ R� R R� ( R RP R� ( Ro ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� k s c C s t d � | j j � D� � S( Nc s s | ] } t j | � Vq d S( N( R R� ( R� t f( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>s s ( R7 R Rg ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fsq s c C sm | s | j j � n | j j | | t j | � � } | rA | S| j t j | � } | j j � | d f S( N( R R� Rl R R� R� RP R� R� Rd ( Rr R t fs_nameR R� R� t new_sim_fs_idR� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_createu s c C sC | j j � | j j t j | � � | j � } | j j � | S( N( R R� Rn R R� R� R� ( Rr Rs R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_delete� s c C s[ t j | � } | j j � | j j | | � | j t j | � } | j j � | d f S( N( R R� R R� Rp R� RP R� R� Rd ( Rr Rs R9 R� Ri R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_resize� s c C s� | j j � d } | r+ t j | � } n t j | � } | j j | � } | d } | j | | | d d t �} | j j | | | � | j t j | � } | j j � | d f S( NR� R� R� ( R R� Rd R R� R� R� R Rz R� R� RP R� R� ( Rr R� R� R� R� Ru R� t src_sim_fsR R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_clone� s c C sj | j j � d } | r+ t j | � } n | j j t j | � | | | � | j � } | j j � | S( N( R R� Rd R R� R� R� R� R� ( Rr Rs R� R� R� R� Ru R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_file_clone� s c C s t | d | d | d � S( Nt lsm_fs_snap_idR~ R� ( R ( Rv ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� � s c C s) t d � | j j t j | � � D� � S( Nc s s | ] } t j | � Vq d S( N( R R� ( R� t s( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s ( R7 R Rr R R� ( Rr Rs R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_snapshots� s c C sW | j j � | j j t j | � | � } | j t j | � } | j j � | d f S( N( R R� Rx R R� R� RP R� R� Rd ( Rr Rs t snap_nameR� Ru R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_snapshot_create� s c C sO | j j � | j j t j | � t j | � � | j � } | j j � | S( N( R R� R} R R� R� R� R� ( Rr Rs R� R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_snapshot_delete� s c C sm | j j � d } | r+ t j | � } n | j j t j | � | | | | � | j � } | j j � | S( N( R R� Rd R R� R| R� R� R� ( Rr Rs R� Ry Rz R{ R� Ru R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_snapshot_restore� s c C s� t j | � } | t k r+ | j j � n | j j | � g k r{ | j j | � g k r{ | t k rw | j j � n t S| t k r� | j j � n t S( N( R R� R: R R� Rm Rr R Rz ( Rr Rs Ry R� R� Ri ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_child_dependency� s c C s� | j j � | j | | d t �t k r@ t t j d � � n t j | � } | j j | � | j j | � | j � } | j j � | S( s� Assuming API defination is break all clone relationship and remove all snapshot of this source file system. R� s9 No snapshot or fs clone target found for this file system( R R� R Rz R: R R R2 R R� R� R~ R� R� ( Rr Rs Ry R� R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_child_dependency_rm� s c C sM t | d | d | d | d | d | d | d | d | d | d � S( Nt lsm_exp_idR� R� R� R� R� R� R� R� R� ( R ( R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_exp_2_lsm s c C s) g | j j � D] } t j | � ^ q S( N( R R� R R ( Rr R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt exports s c C sl | j j � | j j t j | � | | | | | | | | � } | j j | � } | j j � t j | � S( N( R R� R� R R� R� R� R ( Rr Rs R� R� R� R� R� R� R� R� R� R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_export s c C s7 | j j � | j j t j | � � | j j � d S( N( R R� R� R R� R� Rd ( Rr R� R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt fs_unexport( s c C s) t | d | d | d | d t j � S( Nt lsm_ag_idR~ RJ RS ( R RP R� ( RL ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_ag_2_lsm/ s c C s t d � | j j � D� � S( Nc s s | ] } t j | � Vq d S( N( R R ( R� RQ ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>7 s ( R7 R RP ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR] 5 s c C su | t j k r$ t t j d � � n | j j � | j j | | | � } | j j | � } | j j � t j | � S( Ns System not found( RP R� R R R� R R� R^ R1 R� R R ( Rr R~ RV RS R� R� t new_sim_ag_idt new_sim_ag( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt access_group_create9 s c C s7 | j j � | j j t j | � � | j j � d S( N( R R� R_ R R� R� Rd ( Rr R/ R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt access_group_deleteE s c C s^ t j | � } | j j � | j j | | | � | j j | � } | j j � t j | � S( N( R R� R R� Rb R1 R� R ( Rr R/ RV RS R� R R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt access_group_initiator_addL s c C s[ t j | � } | j j � | j j | | � | j j | � } | j j � t j | � S( N( R R� R R� Rd R1 R� R ( Rr R/ RV RS R� R RL ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt access_group_initiator_deleteU s c C sC | j j � | j j t j | � t j | � � | j j � d S( N( R R� R4 R R� R� R� Rd ( Rr R/ R0 R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_mask_ s c C sC | j j � | j j t j | � t j | � � | j j � d S( N( R R� R5 R R� R� R� Rd ( Rr R/ R0 R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_unmaskh s c C sX | j j � | j j d t j | � � } | j j � g | D] } t j | � ^ q? S( NR ( R R� R R R� R R� ( Rr R/ R� R R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt" volumes_accessible_by_access_groupq s c C sX | j j � | j j d t j | � � } | j j � g | D] } t j | � ^ q? S( NR ( R R� RP R R� R R ( Rr R0 R� RP RQ ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt access_groups_granted_to_volume{ s c C s: | j j � | j j | | | | | � | j j � d S( N( R R� R\ R� Rd ( Rr RV RX RY RZ R[ R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt iscsi_chap_auth� s c C s7 t | d | d | d | d | d | d t j � S( Nt lsm_tgt_idR� R� R� R� R� ( R RP R� ( t sim_tgt( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_tgt_2_lsm� s c C s t d � | j j � D� � S( Nc s s | ] } t j | � Vq d S( N( R R% ( R� t t( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>� s ( R7 R R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt target_ports� s c C s= | j j t j | j t t j d � � � } t j } t j } | d t j k rk | j j | d � } n | d } | d } | d } | } | t j k s� | t j k r� | | | | | g S| t j k r� t t j d | d � � n | t j k s | t j k rt j } n t | d | � } | | | | | g S( Ns Pool not foundR� R� R< R= R� s; volume_raid_info(): Got unsupported RAID_TYPE_MIXED pool %sR� R> ( R R� R R� R R R R� RP R R t OPT_IO_SIZE_UNKNOWNR R t RAID_TYPE_UNKNOWNR t RAID_TYPE_MIXEDR RC RA Rg ( Rr t lsm_volR t min_io_sizet opt_io_sizeR< R= R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_raid_info� s4 c C s� | j j t j | j t t j d � � � } | d } g } | t j k r\ | d g } n1 | t j k r� | j j | d � } n t j } | d | | f S( Ns Pool not foundR� t parent_lsm_pool_idR} R< ( R R� R R� R} R R R� R R R R� t MEMBER_TYPE_UNKNOWN( Rr t lsm_poolR R� t member_ids( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt pool_member_info� s c C s7 | j t j k r' t t j d � � n t j t j f S( Ns System not found( R} RP R� R R R� R� R� ( Rr R� ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_raid_create_cap_get� s c C s� | t j k r$ t t j d � � n | t j k r? t j } n$ | t j k rc t t j d � � n | j j � d | } g | D]' } t j | j t t j d � � ^ q� } x: | D]2 } | j t j @s� t t j d | j � � q� q� WyD | j j d | d | d | d t j d t j t j Bd | � } Wn, t j k r]} t t j d | � � n X| j j | � } | j | d | | d d t j d t d d �} | j j | � } | j j � t j! | � S( Ns% Provided 'raid_type' is not supporteds& Provided 'strip_size' is not supporteds Pool for volume %ss Disk not founds' Disk %s is not in DISK.STATUS_FREE modeR~ R< R� R� R� R� s+ Name '%s' is already in use by other volumeR� R i R� R� i (" RP R� R R R8 R t VCR_STRIP_SIZE_DEFAULTR� R� R R� R R� R} t NOT_FOUND_DISKR R R� t DISK_NOT_FREER� R R� R� R� R R# R$ R� R� R� Rz R� R� R� ( Rr R~ R< R� R� t pool_nameR0 R� t diskR� R R R R% ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_raid_create� sP 1 c C s7 t j | j t t j d � � } | j j | � } d S( Ns Volume not found( R R� R} R R R R R� Rd ( Rr t volumeR� t sim_volume_idR% ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_ident_led_on s c C s7 t j | j t t j d � � } | j j | � } d S( Ns Volume not found( R R� R} R R R R R� Rd ( Rr R; R� R< R% ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_ident_led_off s c C s) t | d | d | d | d t j � S( Nt lsm_bat_idR~ R R ( R RP R� ( t sim_bat( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt _sim_bat_2_lsm! s c C s t d � | j j � D� � S( Nc s s | ] } t j | � Vq d S( N( R RA ( R� R& ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pys <genexpr>( s ( R7 R R� ( Rr ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR� & s c C s> | j j t j | j t t j d � � � } t j } t j } t } x3 | j j � D]" } | d t j k rU t } qU qU W| d t j k r� | r� t j } q� n> | d t j k r� t j } n | d t j k r� t j } n | d t j k r t j } n | d t j k r t j } n | d | | d | | d g S( Ns Volume not foundR R R R ( R R� R R� R} R R R R t WRITE_CACHE_STATUS_WRITE_THROUGHt READ_CACHE_STATUS_DISABLEDR: R� R R� Rz R� t WRITE_CACHE_STATUS_WRITE_BACKt WRITE_CACHE_POLICY_WRITE_BACKt WRITE_CACHE_POLICY_UNKNOWNt WRITE_CACHE_STATUS_UNKNOWNR� t READ_CACHE_STATUS_ENABLEDt READ_CACHE_POLICY_UNKNOWNt READ_CACHE_STATUS_UNKNOWN( Rr R+ R% t write_cache_statust read_cache_statust flag_battery_okR@ ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_cache_info* s2 c C sR | j j � t j | j t t j d � � } | j j | | � | j j � d S( Ns Volume not found( R R� R R� R} R R R R� R� ( Rr R; R� R� R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt! volume_physical_disk_cache_updateL s c C sR | j j � t j | j t t j d � � } | j j | | � | j j � d S( Ns Volume not found( R R� R R� R} R R R R� R� ( Rr R; R� R� R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_write_cache_policy_updateU s c C sR | j j � t j | j t t j d � � } | j j | | � | j j � d S( Ns Volume not found( R R� R R� R} R R R R� R� ( Rr R; R� R� R ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt volume_read_cache_policy_update^ s N(W R? R@ R[ R� t tempfilet gettempdirR� RO R� R� R� R� R� R� R� R� R! Ru Rd 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� 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" R% R' R. R3 R4 R: R= R> RA R� RN RO RP RQ ( ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyR s� & 4 "( R& RR R[ R� R t lsmR R R R R R R R R R R R R R R R R! R+ R3 t objectR4 RP R ( ( ( s; /usr/lib/python2.7/site-packages/lsm/plugin/sim/simarray.pyt <module> s$ d 8� � � � � � �