U xʹj'@sddlZddlZddlZddlZddlZddlZddlmZmZddl m Z m Z m Z m Z ddlmZddlmZedZGddde Zd d d efd d Zd dZedkrddlZeejdddS)N)EIOENOENT)FUSE FuseOSError LoggingMixIn Operations) __version__) url_to_fs fsspec.fusec@s|eZdZdddZdddZddZd d Zd d Zd dZddZ dddZ ddZ d ddZ ddZ ddZddZdS)!FUSErFcCs8||_i|_|dd|_d|_td|||_dS)N/rzStarting FUSE at %s)fscacherstriprootcounterloggerinfo _ready_file)selfr path ready_filerJ/var/www/html/bwave/python/venv/lib/python3.8/site-packages/fsspec/fuse.py__init__s  zFUSEr.__init__Nc CsXtd||jr$|dkr$dddSd|j|dgd}z|j|}Wn,t k r|}zt t |W5d}~XYnX| dd | d d d }| d d }|ddkrt j|B|d<d|d<d|d<n*t j|B|d<|d|d<d|d<d|d<d|kr |dnt|d<d|kr*|dnt|d<d|krH|dnt|d<|S)Nz getattr %sz /.fuse_readyz .fuse_readyfile)typest_sizer uidigid)st_uidst_gidmodeirst_moderr st_blksizesizeiPst_nlinkatimest_atimectimest_ctimemtimest_mtime)rdebugrjoinrlstriprr rFileNotFoundErrorrrgetstatS_IFDIRS_IFREGtime)rrfhrexcdatapermrrrgetattrs,      z FUSEr.getattrcCsJtd|d|j|dg}|j|d}dd|D}ddg|S) Nz readdir %sr r FcSsg|]}tj|dqS)r )osrbasenamer).0frrr :sz!FUSEr.readdir...z..)rr1r2rr3r Zls)rrr:filesrrrreaddir6s  z FUSEr.readdircCs&d|j|dg}|j|dSNr r r)r2rr3r mkdirrrr%rrrrH=s z FUSEr.mkdircCs&d|j|dg}|j|dSrG)r2rr3r rmdir)rrrrrrJBs z FUSEr.rmdircCsFtd|||f|jr$|dkr$dS|j|}||||}|S)Nzread %srsready)rr1rrseekread)rrr(offsetr:rBoutrrrrLGs   z FUSEr.readcCs6td||f|j|}||||t|S)Nzwrite %s)rr1rrKwritelen)rrr<rMr:rBrrrrORs    z FUSEr.writecCsdtd||fd|j|dg}|j||j|d}||j|j <|j d7_ |j dS)Nz create %sr r wbr)) rr1r2rr3r touchopenrr)rrflagsfifnrBrrrcreateYs  z FUSEr.createcCsjtd||fd|j|dg}|ddkr8d}nd}|j|||j|j<|jd7_|jdS) Nzopen %sr r rrbrQr)) rr1r2rr3r rSrr)rrrTrVr%rrrrSbs z FUSEr.opencCs2d|j|dg}|dkr"t|j|dSrG)r2rr3NotImplementedErrorr rR)rrlengthr:rVrrrtruncateoszFUSEr.truncatec Cs^d|j|dg}z|j|dWn0ttfk rX}ztt|W5d}~XYnXdS)Nr r F) r2rr3r ZrmOSErrorr4rr)rrrVr;rrrunlinkvs z FUSEr.unlinkc Cs\z,||jkr*|j|}||j|Wn*tk rV}z t|W5d}~XYnXdS)Nr)rclosepop Exceptionprint)rrr:rBerrrrelease}s  z FUSEr.releasecCs8t|jdr0d|j|dg}|j||StdS)Nchmodr r )hasattrr r2rr3rerZrIrrrres z FUSEr.chmod)F)N)N)N)__name__ __module__ __qualname__rr>rFrHrJrLrOrWrSr\r^rdrerrrrr s      r TFc s^fdd}s:tj|d}d|_||Sz |Wntk rXYnXdS)amMount stuff in a local directory This uses fusepy to make it appear as if a given path on an fsspec instance is in fact resident within the local file-system. This requires that fusepy by installed, and that FUSE be available on the system (typically requiring a package to be installed with apt, yum, brew, etc.). Parameters ---------- fs: file-system instance From one of the compatible implementations path: str Location on that file-system to regard as the root directory to mount. Note that you typically should include the terminating "/" character. mount_point: str An empty directory on the local file-system where the contents of the remote path will appear. foreground: bool Whether or not calling this function will block. Operation will typically be more stable if True. threads: bool Whether or not to create threads when responding to file operations within the mounter directory. Operation will typically be more stable if False. ready_file: bool Whether the FUSE process is ready. The ``.fuse_ready`` file will exist in the ``mount_point`` directory if True. Debugging purpose. ops_class: FUSEr or Subclass of FUSEr To override the default behavior of FUSEr. For Example, logging to file. cstd dS)N)r)Z nothreads foreground)rrrjr mount_point ops_classrrthreadsrrs  zrun..)targetTN) threadingThreaddaemonstartKeyboardInterrupt) r rrlrjrnrrmfuncthrrkrruns,  rxc CsGdddtj}|dtjd}|jddtd|jdtd d |jd td d |jd tdd |jddddd|jddtdd |jddddd|jddddd|jdddd d||}i}|jpgD]}| d!\}}}|s|j d"|d#| }| d$r(t |d%td$ }n"| d&rJ|d%td& d'k}d(|kr|d(d)\} } | |kr|||| | <n | |i|| <q|||<q|jrtjtj|jd*d+Gd,d-d-tt} | } nt} t|jf|\} }td.|t|jt| |j|j|j|j|j| d/d%S)0aMount filesystem from chained URL to MOUNT_POINT. Examples: python3 -m fsspec.fuse memory /usr/share /tmp/mem python3 -m fsspec.fuse local /tmp/source /tmp/local \ -l /tmp/fsspecfuse.log You can also mount chained-URLs and use special settings: python3 -m fsspec.fuse 'filecache::zip::file://data.zip' \ / /tmp/zip \ -o 'filecache-cache_storage=/tmp/simplecache' You can specify the type of the setting by using `[int]` or `[bool]`, (`true`, `yes`, `1` represents the Boolean value `True`): python3 -m fsspec.fuse 'simplecache::ftp://ftp1.at.proftpd.org' \ /historic/packages/RPMS /tmp/ftp \ -o 'simplecache-cache_storage=/tmp/simplecache' \ -o 'simplecache-check_files=false[bool]' \ -o 'ftp-listings_expiry_time=60[int]' \ -o 'ftp-username=anonymous' \ -o 'ftp-password=xieyanbo' cseZdZfddZZS)z*main..RawDescriptionArgumentParsercs,t}|d}|j|d<d|S)Nz r))super format_helpsplit descriptionrr2)rusageparts __class__rrrzs  z6main..RawDescriptionArgumentParser.format_help)rgrhrirz __classcell__rrrrRawDescriptionArgumentParsersrr )progr|z --versionversion)actionrurlzfs url)rhelp source_pathzsource directory in fsrlzlocal directoryz-oz--optionappendz3Any options of protocol included in the chained URL)rrz-lz --log-filez%Logging FUSE debug info (Default: '')z-fz --foreground store_falsez-Running in foreground or not (Default: False)z-tz --threadsz-Running with threads support (Default: False)z-rz --ready-filezZThe `.fuse_ready` file will exist after FUSE is ready. (Debugging purpose, Default: False)=zWrong option: )messagez[int]Nz[bool])1yestrue-r)z%(asctime)s %(message)s)levelfilenameformatc@s eZdZdS)zmain..LoggingFUSErN)rgrhrirrrr LoggingFUSEr-srzMounting %s to %s)rjrnrrm) argparseArgumentParsermain__doc__ add_argumentrstr parse_argsoption partitionerrorlowerendswithintrPr{Zlog_filelogging basicConfigDEBUGr rr rrr1rlrxrrjrnr)argsrparserkwargsitemkeysepvaluevalZfs_nameZ setting_namerZfuserr Zurl_pathrrrrs      r__main__r))rrr?r6rqr9errnorrZfuserrrrZfsspecrZ fsspec.corer getLoggerrr rxrrgsysargvrrrrs*    >u