관리-도구
편집 파일: simulator.pyo
� .�P`c @ sm d d l m Z m Z m Z m Z m Z m Z m Z m Z m Z d d l m Z d e e f d � � YZ d S( i����( t uri_parset VERSIONt Capabilitiest INfst IStorageAreaNetworkt search_propertyt Clientt LsmErrort ErrorNumber( t SimArrayt SimPluginc B sJ e Z d Z d � Z d d � Z d d � Z d d � Z d d � Z e d � � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z dA dA d d � Z dA dA d d � Z dA dA d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z dA dA d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z! d d � Z" d d � Z# d d! � Z$ d d" � Z% d d# � Z& d d$ � Z' dA dA d d% � Z( d d& � Z) d d' � Z* d d( � Z+ dA d d) � Z, dA d d* � Z- d d+ � Z. d d, � Z/ d d- � Z0 e1 d d. � Z2 d d/ � Z3 d d0 � Z4 d d1 � Z5 dA dA d d2 � Z6 d d3 � Z7 d d4 � Z8 dA dA d d5 � Z9 d d6 � Z: d d7 � Z; d d8 � Z< d d9 � Z= d d: � Z> d d; � Z? dA dA e@ jA d< � ZB e@ jA d= � ZC e@ jA d> � ZD e@ jA d? � ZE e@ jA d@ � ZF RS(B sU Simple class that implements enough to allow the framework to be exercised. c C s d | _ d | _ d | _ d S( N( t Nonet urit passwordt sim_array( t self( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt __init__ s i c C s� | | _ | | _ t | � } d | k rk d | d k rk | d d d k rk t | d d | � | _ n t d | � | _ d S( Nt parameterst statefile( R R R R R R ( R R R t timeoutt flagst qp( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt plugin_register" s c C s d S( N( ( R R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt plugin_unregister1 s c C s | j j | | � S( N( R t job_status( R t job_idR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR 4 s c C s | j j | | � S( N( R t job_free( R R R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR 7 s c C s | S( s Fake converter. SimArray already do SimData to LSM data convert. We move data convert to SimArray to make this sample plugin looks clean. But in real world, data converting is often handled by plugin itself rather than array. ( ( t sim_data( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt _sim_data_2_lsm: s c C s | j j | | � d S( N( R t time_out_setR ( R t msR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR E s c C s | j j | � S( N( R t time_out_get( R R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR I s c C s t � } | j � | j t j t j � | j t j t j � | j t j t j � | j t j t j � | j t j t j � | j t j t j � | j t j t j � | j t j t j � | j t j t j � | j t j t j � | j t j t j � | S( N( R t enable_allt sett POOLS_QUICK_SEARCHt UNSUPPORTEDt VOLUMES_QUICK_SEARCHt DISKS_QUICK_SEARCHt FS_QUICK_SEARCHt ACCESS_GROUPS_QUICK_SEARCHt NFS_EXPORTS_QUICK_SEARCHt TARGET_PORTS_QUICK_SEARCHt. VOLUME_PHYSICAL_DISK_CACHE_UPDATE_SYSTEM_LEVELt, VOLUME_WRITE_CACHE_POLICY_UPDATE_IMPACT_READt0 VOLUME_WRITE_CACHE_POLICY_UPDATE_WB_IMPACT_OTHERt, VOLUME_READ_CACHE_POLICY_UPDATE_IMPACT_WRITE( R t systemR t rc( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt capabilitiesL s( c C s d t f S( Ns Storage simulator( R ( R R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt plugin_infob s c C s/ | j j � } g | D] } t j | � ^ q S( N( R t systemsR R ( R R t sim_sysst s( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR2 e s c C s | j j | | � S( N( R t system_read_cache_pct_update( R R. t read_pctR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR5 i s c C s> | j j | � } t g | D] } t j | � ^ q | | � S( N( R t poolsR R R ( R t search_keyt search_valueR t sim_poolst p( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR7 l s c C s; | j j � } t g | D] } t j | � ^ q | | � S( N( R t volumesR R R ( R R8 R9 R t sim_volst v( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR< r s c C s; | j j � } t g | D] } t j | � ^ q | | � S( N( R t disksR R R ( R R8 R9 R t sim_diskst d( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR? x s c C s. | j j | j | | | | � } t j | � S( N( R t volume_createt idR R ( R t poolt volume_namet size_bytest provisioningR t sim_vol( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRB ~ s c C s | j j | j | � S( N( R t volume_deleteRC ( R t volumeR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRI � s c C s( | j j | j | | � } t j | � S( N( R t volume_resizeRC R R ( R RJ t new_size_bytesR RH ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRK � s c C s@ | d k r | j } n | j } | j j | | | j | | � S( N( R RC t pool_idR t volume_replicate( R RD t rep_typet volume_srct nameR t dst_pool_id( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRN � s c C s | j j | j | � S( N( R t! volume_replicate_range_block_sizeRC ( R R. R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRS � s c C s" | j j | | j | j | | � S( N( R t volume_replicate_rangeRC ( R RO RP t volume_destt rangesR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRT � s c C s | j j | j | � S( N( R t volume_enableRC ( R RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRW � s c C s | j j | j | � S( N( R t volume_disableRC ( R RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRX � s c C s; | j j � } t g | D] } t j | � ^ q | | � S( N( R t agsR R R ( R R8 R9 R t sim_agst a( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt access_groups� s c C s. | j j | | | | j | � } t j | � S( N( R t access_group_createRC R R ( R RQ t init_idt init_typeR. R t sim_ag( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR] � s c C s | j j | j | � S( N( R t access_group_deleteRC ( R t access_groupR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRa � s c C s+ | j j | j | | | � } t j | � S( N( R t access_group_initiator_addRC R R ( R Rb R^ R_ R R` ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRc � s c C s+ | j j | j | | | � } t j | � S( N( R t access_group_initiator_deleteRC R R ( R Rb R^ R_ R R` ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRd � s c C s | j j | j | j | � S( N( R t volume_maskRC ( R Rb RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRe � s c C s | j j | j | j | � S( N( R t volume_unmaskRC ( R Rb RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRf � s c C s8 | j j | j | � } g | D] } t j | � ^ q S( N( R t" volumes_accessible_by_access_groupRC R R ( R Rb R R= R> ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRg � s c C s8 | j j | j | � } g | D] } t j | � ^ q S( N( R t access_groups_granted_to_volumeRC R R ( R RJ R R= R> ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRh � s c C sX | r9 | r9 | d k s$ | d k r9 t t j d � � n | j j | | | | | | � S( Ns? out_user and out_password only supported if inbound is supplied( R R R t INVALID_ARGUMENTR t iscsi_chap_auth( R R^ t in_usert in_passwordt out_usert out_passwordR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRj � s c C s | j j | j | � S( N( R t volume_child_dependencyRC ( R RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRo � s c C s | j j | j | � S( N( R t volume_child_dependency_rmRC ( R RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRp � s c C s; | j j � } t g | D] } t j | � ^ q | | � S( N( R t fsR R R ( R R8 R9 R t sim_fsst f( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRq � s c C s( | j j | j | | � } t j | � S( N( R t fs_createRC R R ( R RD RQ RF R t sim_fs( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRt � s c C s | j j | j | � S( N( R t fs_deleteRC ( R Rq R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRv � s c C s( | j j | j | | � } t j | � S( N( R t fs_resizeRC R R ( R Rq RL R Ru ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRw � s c C sG | d k r( | j j | j | d | � S| j j | j | | j | � S( N( R R t fs_cloneRC ( R t src_fst dest_fs_namet snapshotR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyRx � s c C sM | d k r+ | j j | j | | d | � S| j j | j | | | j | � S( N( R R t fs_file_cloneRC ( R Rq t src_file_namet dest_file_nameR{ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR| � s c C s8 | j j | j | � } g | D] } t j | � ^ q S( N( R t fs_snapshotsRC R R ( R Rq R t sim_snapsR4 ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR s c C s | j j | j | | � S( N( R t fs_snapshot_createRC ( R Rq t snapshot_nameR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� s c C s | j j | j | j | � S( N( R t fs_snapshot_deleteRC ( R Rq R{ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� s c C s% | j j | j | j | | | | � S( N( R t fs_snapshot_restoreRC ( R Rq R{ t filest restore_filest all_filesR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� s c C s | j j | j | | � S( N( R t fs_child_dependencyRC ( R Rq R� R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� s c C s | j j | j | | � S( N( R t fs_child_dependency_rmRC ( R Rq R� R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� s c C s d g S( Nt standard( ( R R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt export_auth s c C s> | j j | � } t g | D] } t j | � ^ q | | � S( N( R t exportsR R R ( R R8 R9 R t sim_expst e( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� s c C s= | j j | | | | | | | | | d d � } t j | � S( NR i ( R t fs_exportR R ( R t fs_idt export_patht root_listt rw_listt ro_listt anon_uidt anon_gidt auth_typet optionsR t sim_exp( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt export_fs# s c C s | j j | j | � S( N( R t fs_unexportRC ( R t exportR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt export_remove* s c C s; | j j � } t g | D] } t j | � ^ q | | � S( N( R t target_portsR R R ( R R8 R9 R t sim_tgtst t( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� - s c C s | j j | � S( N( R t volume_raid_info( R RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� 3 s c C s | j j | � S( N( R t pool_member_info( R RD R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� 6 s c C s | j j | � S( N( R t volume_raid_create_cap_get( R R. R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� 9 s c C s | j j | | | | � S( N( R t volume_raid_create( R RQ t raid_typeR? t strip_sizeR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� < s c C s | j j | � S( N( R t volume_ident_led_on( R RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� A s c C s | j j | � S( N( R t volume_ident_led_off( R RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� D s c C s; | j j � } t g | D] } t j | � ^ q | | � S( N( R t batteriesR R R ( R R8 R9 R t sim_batteriest b( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� G s c C s | j j | � S( N( R t volume_cache_info( R RJ R ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� N s c C s | j j | | � S( N( R t! volume_physical_disk_cache_update( R RJ t pdcR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� Q s c C s | j j | | � S( N( R t volume_read_cache_policy_update( R RJ t rcpR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� U s c C s | j j | | � S( N( R t volume_write_cache_policy_update( R RJ t wcpR ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR� Y s N(G t __name__t __module__t __doc__R R R R R t staticmethodR R R R0 R1 R2 R5 R R7 R< R? RB RI RK RN RS RT RW RX R\ R] Ra Rc Rd Re Rf Rg Rh Rj Ro Rp Rq Rt Rv Rw Rx R| R R� R� t FalseR� R� R� R� R� R� R� R� R� R� R� R� R� R� R t FLAG_RSVDR� R� R� R� R� ( ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyR s� N( t lsmR R R R R R R R R t lsm.plugin.sim.simarrayR R ( ( ( s< /usr/lib/python2.7/site-packages/lsm/plugin/sim/simulator.pyt <module> s @