Why Gemfury?
Push, build, and install
RubyGems
npm packages
Python packages
Maven artifacts
PHP packages
Go Modules
Debian packages
RPM packages
NuGet packages
triliodata-3-3 / contego deb
Repository URL to install this package:
|
Version:
3.3.30 ▾
|
ó
ˍEYc @ sÚ d Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l Z d d l m
Z
d d l m Z d d l m
Z
e j e Z d e j f d YZ d e f d
YZ d e f d YZ d S(
s# Remote filesystem client utilities.iÿÿÿÿN( t log( t exception( t executor( t _t RemoteFsClientc B s} e Z d d Z d Z d Z d Z d Z d d Z d d d Z d d Z
d Z d Z d d
Z
RS( c O s÷ t t | j | d | | | i d d 6d d 6d d 6d d 6d d 6d d 6} | | k rs t j d | n | | _ | | } | j | d
| _ | j sÄ t j d t d | n | j | d
| _
| d k ró | j n d S( Nt executet nfst smbfst cifst glusterfst vzstoraget quobytet scalityt protocolt _mount_point_baset errs %s_mount_point_base requiredt _mount_options( t superR t __init__R t ProtocolNotSupportedt _mount_typet gett _mount_baset InvalidParameterValueR R t _check_nfs_options( t selft
mount_typet root_helperR t argst kwargst mount_type_to_option_prefixt
option_prefix( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR # s(
c C s | j S( N( R ( R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyt get_mount_baseA s c C s7 t | t j r$ | j d } n t j | j S( sU Return a string that represents hash of base_str
(in a hex format).
s utf-8( t
isinstancet sixt text_typet encodet hashlibt md5t hexdigest( R t base_str( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyt
_get_hash_strD s c C s t j j | j | j | S( sV Get Mount Point.
:param device_name: example 172.18.194.100:/var/nfs
( t ost patht joinR R) ( R t device_name( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyt get_mount_pointM s c C s | j d d d \ } } | j d } i } xM | D]E } | j } d t | k r7 | d } | d } | | | <q7 q7 W| S( Nt mountt check_exit_codei s
i ( t _executet splitt len( R t outt _errt linest mountst linet tokenst devicet mnt_point( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyt _read_mountsU s
c C s | j | } | | j k r5 t j d | d S| j d d | d d | j d k rs | j | | | n | j | j | | | j | d S( s Mount given share.s Already mounted: %sNt mkdirs -pR0 i R ( R. R< t LOGt infoR1 R t
_mount_nfst _do_mountR ( R t sharet flagst
mount_path( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR/ a s c C s d d | g } | d k r1 | j d | g n | d k rM | j | n | j | | g | j d | j d t d d | d S( s+ Mounts share based on the specified params.R/ s -ts -oR t run_as_rootR0 i N( t Nonet extendR1 t _root_helpert True( R R RB RD t
mount_optionsRC t mnt_cmd( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyRA p s c C sÜ i } x¨ t | j j d t D] } | j | } y? | j d | | | | t j d i | d 6| d 6 d SWq" t k
r¬ } t j | | | <t j d | q" Xq" Wt
j t d i | d 6| d 6 d S(
s* Mount nfs share using present mount types.t reverseR s" Mounted %(sh)s using %(mnt_type)s.t sht mnt_typeNs Failed to do %s mount.s4 NFS mount failed for share %(sh)s. Error - %(error)st error(
t sortedt _nfs_mount_type_optst keysRI RA R> t debugt ExceptionR" R# R t BrickExceptionR ( R t nfs_shareRD RC t
mnt_errorsRN t optionst e( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR@ } s "
c C s i | j d 6| _ d d d g } x' | D] } | j | j | r) d Sq) W| j | j d d } | j | d d } | | j d
<d S( s+ Checks and prepares nfs mount type options.R s ^nfsverss ^verss ^v[\d]Nt verst 4t minorversiont 1t pnfs( R RQ t _option_existst _update_option( R t nfs_vers_opt_patternst optt pnfs_opts( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR s
c C su | r. g | j d D] } | j ^ q n g } d } x4 | D], } | d } t j | | d d rA | SqA Wd S( s@ Checks if the option exists in nfs options and returns position.t ,i i RC ( R2 t stript ret match( R RX t opt_patternt xt posRb ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR_ ¢ s 4
c C s° | r. g | j d D] } | j ^ q n g } | j | | } | r` | j | d n | rv d | | f n | } | j | t | d k r¨ d j | S| d S( s= Update option if exists else adds it and returns new options.Rd i s %s=%si ( R2 Re R_ t popt appendR3 R, ( R RX t optiont valueRi t optsRj Rb ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR` ¬ s 4
N( t __name__t
__module__RF R R R) R. R< R/ RA R@ R R_ R` ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR ! s
t ScalityRemoteFsClientc B s) e Z d d Z d Z d d Z RS( c O s} t t | j | | d | | | | | _ | j d d j d | _ | j sp t j d t d n d | _ d S( NR t scality_mount_point_baset t /R s! scality_mount_point_base required( R Rr R R R t rstripR R R R RF R ( R R R R R R ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR ¸ s
c C s t j j | j | d S( Nt 00( R* R+ R, R ( R R- ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR. Å s c C sk | j | j k r, t j d | j d S| j d d | j d d t t | j d d | j d S( s÷ Mount the Scality ScaleOut FS.
The `share` argument is ignored because you can't mount several
SOFS at the same type on a single server. But we want to keep the
same method signature for class inheritance purpose.
s Already mounted: %sNR= s -pR0 i t sofss /etc/sfused.conf( R R< R> R? R1 R Rr RA ( R RB RC ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyR/ Ê s N( Rp Rq RF R R. R/ ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyRr · s t VZStorageRemoteFSClientc B s e Z d Z d d d Z RS( c
C s t j d d } t j j | d } t | d ) } x | D] } | j | d q@ WWd QXt j j d | } t j j | rÅ t j j | d } | j d d | | d | j d
t
n% | j d d | | d | j d
t
| j d d
d | d | j d
t
d S( Nt prefixs
vzstorage-t bs_listt ws
s /etc/pstorage/clusterst cps -fR RE s -rft chowns -Rs root:root( t tempfilet mkdtempR* R+ R, t opent writet existsR1 RH RI ( R t cluster_namet mdsst tmp_dirt tmp_bs_patht ft mdst conf_dirt bs_path( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyt _vzstorage_write_mds_listÚ s
c C s! t j d | } | s: t d | } t j | n | j d } | j d } | j d }
| r | j d } | j | | n |
rÆ | j d d | d d
d |
d | j d
t
n d d | g } | rë | j | n | j | g | j d | j d
t
d d | d S( Ns( (?:(\S+):\/)?([a-zA-Z0-9_-]+)(?::(\S+))?sh Invalid Virtuozzo Storage share specification: %r.Must be: [MDS1[,MDS2],...:/]<CLUSTER NAME>[:PASSWORD].i i i Rd t pstorages -cs auth-nodes -Pt
process_inputR RE s pstorage-mountR0 i ( Rf t searchR R RU t groupR2 R R1 RH RI RG ( R R t vz_shareRD RJ RC t mt msgR
R t passwdRK ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyRA ì s* N( Rp Rq R RF RA ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyRy Ù s ( t __doc__R% R* Rf R t oslo_logR t loggingR" t os_brickR R t
os_brick.i18nR t getLoggerRp R> t ExecutorR Rr Ry ( ( ( sO /home/tvault/.virtenv/lib/python2.7/site-packages/os_brick/remotefs/remotefs.pyt <module> s "