o +ke}*@srddlZddlZddlZddlZddlmZddlmZ dZe edej Z ddl m Z dd d d Zdd d d Zdd ddZd0ddZd0ddZz ddlmZd1ddZWneyfd1ddZYnwd1ddZddZddZGdddZGd d!d!Zd"d#Zd2d%d&ZeZeeZe d'dZej!"d(Z#e#sed)e$Z#d*d+Z%d,d-Z&d.d/Z'dS)3N) safe_unlink)is_win32z1.2_05 fdatasync)ENOATTRF)follow_symlinkscCsgS)a Return xattr names of a file (list of bytes objects). *path* can either be a path (bytes) or an open file descriptor (int). *follow_symlinks* indicates whether symlinks should be followed and only applies when *path* is not an open file descriptor. )pathrrr6usr/lib/python3.10/site-packages/borg/platform/base.py listxattrsr cCstttt|)a: Read xattr and return its value (as bytes). *path* can either be a path (bytes) or an open file descriptor (int). *name* is the name of the xattr to read (bytes). *follow_symlinks* indicates whether symlinks should be followed and only applies when *path* is not an open file descriptor. )OSErrorrosstrerror)r namerrrr getxattr's rcCdS)aP Write xattr on *path*. *path* can either be a path (bytes) or an open file descriptor (int). *name* is the name of the xattr to read (bytes). *value* is the value to write (bytes). *follow_symlinks* indicates whether symlinks should be followed and only applies when *path* is not an open file descriptor. Nr)r rvaluerrrr setxattr5rcCr)zl Saves ACL Entries If `numeric_ids` is True the user/group field is not preserved only uid/gid Nr)r itemst numeric_idsfdrrr acl_getArrcCr)zz Restore ACL Entries If `numeric_ids` is True the stored uid/gid is used instead of the user/group names Nr)r rrrrrr acl_setIrrlchflagscCst||dSNrr Z bsd_flagsrrrr set_flagsUsrcCsdSrrrrrr rXcCs t|ddS)zHReturn BSD-style file flags for path or stat without following symlinks.st_flagsr)getattr)r rrrrr get_flags\s r#c CstrdSt|tj}z1zt|Wnty,}z |jtjkr"WYd}~n d}~wwWt|dSWt|dSt|wr) rr openO_RDONLYfsyncr errnoEINVALclose)r rZos_errorrrr sync_diras  r*cCsHttdr"ttd|}z t||||WdSty!YdSwdS)N posix_fadviseZ POSIX_FADV_)hasattrr r"r+r )roffsetlenZadvicerrr safe_fadvisers  r/c@sHeZdZdZdddddZddZd d Zd d Zd dZddZ dS)SyncFilea( A file class that is supposed to enable write ordering (one way or another) and data durability after close(). The degree to which either is possible varies with operating system, file system and hardware. This fallback implements a naive and slow way of doing this. On some operating systems it can't actually guarantee any of the above, since fsync() doesn't guarantee it. Furthermore it may not be possible at all to satisfy the above guarantees on some hardware or operating systems. In these cases we hope that the thorough checksumming implemented catches any corrupted data due to misordered, delayed or partial writes. Note that POSIX doesn't specify *anything* about power failures (or similar failures). A system that routinely loses files or corrupts file on power loss is POSIX compliant. Calling SyncFile(path) for an existing path will raise FileExistsError, see comment in __init__. TODO: Use F_FULLSYNC on OSX. TODO: A Windows implementation should use CreateFile with FILE_FLAG_WRITE_THROUGH. NFrbinarycCsJ|rdnd}||_|durt||d|_ntj||d|_|j|_dS)aJ Open a SyncFile. :param path: full path/filename :param fd: additionally to path, it is possible to give an already open OS-level fd that corresponds to path (like from os.open(path, ...) or os.mkstemp(...)) :param binary: whether to open in binary mode, default is False. xbxN)mode)r r$fr fdopenfilenor)selfr rr2r5rrr __init__s zSyncFile.__init__cCs|Srr)r9rrr __enter__r zSyncFile.__enter__cCs |dSr)r))r9exc_typeexc_valexc_tbrrr __exit__s zSyncFile.__exit__cCs|j|dSr)r6write)r9datarrr r@szSyncFile.writecCs6ddlm}|j||jt|jddddS)z Synchronize file contents. Everything written prior to sync() must become durable before anything written after sync(). platformrZDONTNEEDN)rDr6flushrrr/)r9rDrrr syncs   z SyncFile.syncc Csfddlm}d}ztj|j}|W|j|r#||dSdS|j|r2||ww)zsync() and close.rBrCN) rErDr r dirnamerGr6r)r*)r9rDrHrrr r)s     zSyncFile.close) __name__ __module__ __qualname____doc__r:r;r?r@rGr)rrrr r0s r0c@s*eZdZdZd ddZddZddZd S) SaveFilea Update file contents atomically. Must be used as a context manager (defining the scope of the transaction). On a journaling file system the file contents are always updated atomically and won't become corrupted, even on power failures or crashes (for caveats see SyncFile). SaveFile can safely by used in parallel (e.g. by multiple processes) to write to the same target path. Whatever writer finishes last (executes the os.replace last) "wins" and has successfully written its content to the target path. Internally used temporary files are created in the target directory and are named -.tmp and cleaned up in normal and error conditions. FcCsB||_||_tj||_tj|d|_d|_d|_d|_ dS)N-) r2r r rHdirbasename tmp_prefixtmp_fd tmp_fnamer6)r9r r2rrr r:s zSaveFile.__init__cCsRddlm}ddlm}||jd|jdd\|_|_|j|j|j|j d|_ |j S)NrBrC) mkstemp_modez.tmpi)prefixsuffixrOr5r1) rErDZ helpers.fsrTrQrOrRrSr0r2r6)r9rDrTrrr r;s  zSaveFile.__enter__c Csddlm}|jd|_|durt|jdSz!z t|j|j Wn t y1t|jwW| |j dS| |j w)NrBrC) rErDr6r)rRrrSr replacer r r*rO)r9r<r=r>rDrrr r?s     zSaveFile.__exit__N)F)rIrJrKrLr:r;r?rrrr rMs   rMcCst|S)z}terminal output width of string For western scripts, this is just len(s), but for cjk glyphs, 2 cells are used. )r.)srrr swidthsrYrEcCsr|}|r |dkrt}zt|ddtjdtj}Wn ty&Y|Sw|D] }|dr6|d}|Sq)|S)zpGet fully qualified domain name from name. An empty argument is interpreted as meaning the local host. z0.0.0.0Nr)stripsocket gethostname getaddrinfo SOCK_DGRAM AI_CANONNAMEr )raddrsaddrrrr getfqdns   rc.Z BORG_HOST_ID@cCsd}t}t||fS)z Return identification tuple (hostname, pid, thread_id) for 'us'. This always returns the current pid, which might be different from before, e.g. if daemonize() was used. Note: Currently thread_id is *always* zero. r)r getpidhostid)Z thread_idpidrrr get_process_id(s ricCt)ze Check if the (host, pid, thread_id) combination corresponds to a potentially alive process. NotImplementedError)hostrhthreadrrr process_alive4srocCrj)zReturn whether *pid* is alive.rk)rhrrr local_pid_alive;srp)FNr)rE)(r'r r\uuidZ borg.helpersrZborg.platformflagsrZ API_VERSIONr"r&rZxattrrr rrrrrr ImportErrorr#r*r/r0rMrYrcr]hostnameZfqdnsplitenvirongetrgZgetnoderirorprrrr sJ         G2