OcIc@sdZddkZddkZddkZddkZddkZddkZddkZddkZddk Z ddk Z ddk Z ddk Z ddk Z ddkZddkZyddkZddkZWnej onXdefdYZdefdYZdZdZd Zd Zd d Zd d ZdZdZdZdZd dZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dfdYZ)de)fdYZ*dfd YZ+d!ei,fd"YZ,d#fd$YZ-d%Z.d&Z/d'Z0d(Z1d)Z2d*Z3d+Z4d,Z5d-Z6dS(.sSWrapper class around a real path like "/usr/bin/env" The RPath (short for Remote Path) and associated classes make some function calls more convenient and also make working with files on remote systems transparent. For instance, suppose rp = RPath(connection_object, "/usr/bin/env") Then rp.getperms() returns the permissions of that file, and rp.delete() deletes that file. Both of these will work the same even if "usr/bin/env" is on a different computer. So many rdiff-backup functions use rpaths so they don't have to know whether the files they are dealing with are local or remote. iNtSkipFileExceptioncBseZdZRS(sSignal that the current file should be skipped but then continue This exception will often be raised when there is problem reading an individual file, but it makes sense for the rest of the backup to keep going. (t__name__t __module__t__doc__(((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR.stRPathExceptioncBseZRS((RR(((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR8scCs;ti}x+|i|}|pPn|i|q dS(s6Copies file inputfp to outputfp in blocksize intervalsN(tGlobalst blocksizetreadtwrite(tinputfptoutputfpRtinbuf((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt copyfileobj:s  cCsUti}xE|i|}|i|}||jodSq |pdSq q dS(s2True if file objects fp1 and fp2 contain same dataiN(RRRtNone(tfp1tfp2Rtbuf1tbuf2((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt cmpfileobjBs  cGs<x5|D]-}|iptd|iqqWdS(s4Make sure that all the rps exist, raise error if notsFile %s does not existN(tlstatRt get_indexpath(trpstrp((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytcheck_for_filesKs cCsEyt||Wn-tij ot|||inXdS(s(Move rpin to rpout, renaming if possibleN(trenametosterrortcopytdelete(trpintrpout((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytmoveQs  icCstid|i|ifd|ip#|io|indSn|io4|ipt|| o|iqdSn|iot|||Sn8|i o|i n|i oZt i otid|i@}n|i|it i oti|qn|io)|i\}}|id||n|io)|i\}}|id||nJ|io|in/|io|intd|idS(sCopy RPath rpin to rpout. Works for symlinks, dirs, etc. Returns close value of input for regular file, which can be used to pass hashes on. sRegular copying %s to %siNitctbsFile %s has unknown type(tlogtLogtindextpathRRtisregtcmpt copy_reg_filetisdirtmkdirtissymRt symlink_permsRtumasktgetpermstsymlinktreadlinkt ischardevt getdevnumstmakedevtisblkdevtisfifotmkfifotissocktmksockR(RRtcompresst orig_umasktmajortminor((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRXs<             c Csy]|i|ijoF|itij o3|iii|i|i|}|i|SnWntj onXy |i|i dd|SWnFt j o:}|i t i jot iid|iqnXdS(s=Copy regular file rpin to rpout, possibly avoiding connectiontrbR9s'IOError - Result too large' while reading %s. If you are using a Mac, this is probably the result of HFS+ filesystem corruption. Please exclude this file from your backup before proceeding.N(tconnRtlocal_connectiontrpathR(R%tsetdatatAttributeErrortwrite_from_fileobjtopentIOErrorterrnotERANGER"R#t FatalError(RRR9tvte((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR({s!    cCst|||iou|ipdSn|id|id}}t||}|ip |iotdn|Sn|io|iSn|io'|io|i |i jSn|i o'|i o|i |i jSn~|i o'|i o|i |i jSnJ|i o|i Sn/|io|iSntd|idS(sTrue if rpin has the same data as rpout cmp does not compare file ownership, permissions, or times, or examine the contents of a directory. R=sError closing filesFile %s has unknown typeN(RR&R RDRtcloseRR)R+R0R1R2R4R5R7R%(RRRRtresult((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR's,     ' ' '  cCstid|i|ifd|i|ijp|ipttio |i |i i i |nti o|i|in|iodSntio1|io$|io|i|intio1|io$|io|i|in|i|itio|i|in|ip|i |i!nti"o|i#|i$ndS(sChange file attributes of rpout to match rpin Only changes the chmoddable bits, uid/gid ownership, and timestamps, so both must already exist. s Copying attributes from %s to %siN(%R"R#R$R%Rt isspecialtAssertionErrorRtchange_ownershiptchownR>t user_groupt map_rpatht eas_writetwrite_eatget_eaR+tresource_forks_writeR&thas_resource_forktwrite_resource_forktget_resource_forktcarbonfile_writethas_carbonfiletwrite_carbonfiletget_carbonfiletchmodR.t acls_writet write_acltget_acltisdevtsetmtimetgetmtimetwin_acls_writet write_win_aclt get_win_acl(RR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt copy_attribss* -         cCstid|i|ifdt||tiot|i|i nti o|i |i n|i odSntio>|io1|io$|io|i|intio>|io1|io$|io|i|in|io)|i o|i|id@n|i|itio|i|iddn|ip|i|indS(sChange file attributes of rpout to match rpin Like above, but used to give increments the same attributes as the originals. Therefore, don't copy all directory acl and permissions. sCopying inc attrs from %s to %siNit map_namesi( R"R#R$R%RRROtapplyRPt getuidgidRSRTRUR+RVR&RWRXRYRZR[R\R]R)R^R.R_R`RaRbRcRd(RR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytcopy_attribs_incs*       cCs't||tio#|i|ijo d}n|i|ijo d}n|io|io d}nz|io|io d}nV|io|io d}n2|i |i jo|i |i j}t i d|i |i |fd|S(sTrue if rp1 has the same file attributes as rp2 Does not compare file access times. If not changing ownership, do not check user/group id. is Compare attribs of %s and %s: %siN(RRRORkR R.R+R4R1tgetctimeRdR"R#R(trp1trp2RL((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt cmp_attribss  #       cCs2t||||iot||ndS(s'Copy file and then copy over attributesN(RRRh(RRR9((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytcopy_with_attribss csiijpttifddipinCioZiijoAidjo.tidiifdiny iii iiWnt j o}|i t i jo'tidiifdniii idiiiiiii iinXi_hd d <_d S( sRename rp_source to rp_destcsdiifS(sRenaming %s to %s(R%((trp_destt rp_source(s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytsiis4Warning: Attempt to rename over same inode: %s to %sisOSError while renaming %s to %siittypeN(R>RNR"R#RRtgetinodeR%RRtOSErrorRFtEEXISTR^tunlinktdataR (RsRrR((RsRrs7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRs* &   ! cCsttidjoZyti|SWqjtj o6}|itijo|itijoqfqjXnt|S(sGenerate the data dictionary for the given RPath This is a global function so that os.name can be called locally, thus avoiding network lag and so that we only need to send the filename over the network, thus avoiding the need to pickle an (incomplete) rpath object. tnt( RtnametCtmake_file_dictRwRFtEILSEQtEINVALtmake_file_dict_python(tfilenameR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR~s&cCsyti|}Wn#tij ohddRR?RNtsockettAF_UNIXt SOCK_STREAMtbindR%RRtstr(R@Rtexc((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytmake_socket_local\s cCs*|itijptt|idS(s7Return open GzipFile. See security note directly aboveR=(R>RR?RNtGzipFileR%(R@((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytgzip_open_local_readiscCs*|itijptt|idS(s0Return open file (provided for security reasons)R=(R>RR?RNRDR%(R@((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytopen_local_readnscCs1|id}|ddjo8d}t|djodSn|dd!\}}n2d}t|djodSn|d\}}ti|djodSn|d jp1|d jp$|d jp|d jp |d jpdSn|odi|d }ndi|d }||||fS(sGReturns None or tuple of (is_compressed, timestr, type, and basename)t.itgziiiiitsnapshotRtmissingtdiffRzN(tsplittlenR tTimet stringtotimetjoin(tbasenametdotsplitt compressedt timestringtexttbasestr((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytget_incfile_infoss&'cCs?|ipt|iotdn|idS(sSDeletes the directory at rp.path if empty. Raises if the directory contains files.sDirectory contains files.N(R)RNtcontains_filesRR(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytdelete_dir_no_filess tRORPathc BseZdZdHdZdZdZdZdZdZ ddddddddd d Z d d Z d Z d Z dZdZdZdZdZeZdZdZdZdZdZdZdZdZdZdZdZdZdZ d Z!d!Z"d"Z#d#Z$d$Z%d%Z&d&Z'd'Z(d(Z)d)Z*d*Z+d+Z,d,Z-d-Z.d.Z/d/Z0d0Z1d1Z2d2Z3d3Z4d4Z5d5Z6d6Z7d7Z8d8Z9d9Z:d:Z;d;Z<d<Z=d=Z>d>Z?d?Z@d@ZAdAZBdBZCdCZDdDZEdEZFdFZGdGZHRS(Is.Read Only RPath - carry information about a path These contain information about a file, and possible the file's data, but do not have a connection and cannot be written to or changed. The advantage of these objects is that they can be communicated by encoding their index and data dictionary. cCs<||_|o ||_nhdd<|_d|_dS(NRu(R$RzR tfile(tselfR$Rz((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt__init__s   cCshdd<|_d|_dS(sSet inside of self to type NoneRuN(R RzR(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytzeroscCs#|ii|_d|id|id}|djp$|djp|djp |djS(s4True if the file is a sock, symlink, device, or fifoRuRRRR(Rz(RRu((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRMhs cCs*|iido|idSndSdS(sReturn permission block of fileRiN(RzR(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR.nscCs-y|idSWntj o dSnXdS(s"Return username that owns the fileRN(RzRR (R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytgetunamesscCs-y|idSWntj o dSnXdS(s#Return groupname that owns the fileRN(RzRR (R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytgetgnamexscCs|iidS(s"True if rpath has a size parameterR(RzR(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pythassize}scCs |idS(sReturn length of file in bytesR(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRscCs|id|idfS(sReturn userid/groupid of fileRR(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRkscCs |idS(sReturn access time in secondsR(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytgetatimescCs |idS(s#Return modification time in secondsR(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRdscCs |idS(sReturn change time in secondsR(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRmscCs |idS(sReturn inode number of fileR(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRvscCs |idS(sDevice number file resides onR(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt getdevlocscCs*|iido|idSndSdS(s#Number of places inode is linked toRiN(RzR(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRscCs |idS(sWrapper around os.readlink()R(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR0scCs|iddS(s4Return a devices major/minor numbers from dictionaryRi(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR2scsG|o i ptfd}t||_d_dS(s:Right now just set self.file to be the already opened filecs d_dS(N(R tfile_already_open((R(s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt closing_hooksN(RRNt RPathFileHookR R (RRR((Rs7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytsetfilescCs"|ipdSndi|iS(s[Return path of index portion For instance, if the index is ("a", "b"), return "a/b". Rt/(R$R(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRs cCs |idS(sIf there is a file attached, say what it is Currently the choices are 'snapshot' meaning an exact copy of something, and 'diff' for an rdiff style diff. tfiletype(Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytget_attached_filetypescCs||iddZdZdZ dZ dZ dZ dZ d Zd Zd Zd Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!dZ"dZ#dZ$d?d Z%d!Z&d@d"Z'd#Z(d$Z)d>d%Z*d>d&Z+d>d'Z,d(Z-d)Z.d*Z/d+Z0d,Z1d-Z2d.Z3d>d/Z4d>d0Z5d>d1Z6d>d2Z7d3Z8d4d5Z9d6Z:d7Z;d8Z<d9Z=d:Z>d;Z?d<Z@RS(As!Remote Path class - wrapper around a possibly non-local pathname This class contains a dictionary called "data" which should contain all the information about the file sufficient for identification (i.e. if two files have the the same (==) data dictionary, they are the same file). s [\\\"\$`]cCs||_||_||_|dj oD|djoddi||_qldi|f||_nd|_|p |djo ||_n |idS(sRPath constructor connection = self.conn is the Connection the RPath will use to make system calls, and index is the name of the rpath used for comparison, and should be a tuple consisting of the parts of the rpath after the base split up. For instance ("foo", "bar") for "foo/bar" (no base), and ("local", "bin") for "/usr/local/bin" if the base is "/usr". For the root directory "/", the index is empty and the base is "/". RN( R>R$tbaseR RR%RRzRA(Rt connectionR0R$Rz((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR^s       cCsd|i|i|ifS(NsPath: %s Index: %s Data: %s(R%R$Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRvscCs|ii|i|i|ifS(sReturn picklable state The rpath's connection will be encoded as its conn_number. It and the other information is put in a tuple. Data and any attached file won't be saved. (R>t conn_numberR0R$Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRzscCsN|\}|_|_|_ti||_di|if|i|_dS(s(Reproduce RPath from __getstate__ outputRN(R0R$RzRtconnection_dictR>RR%(Rt rpath_stateR2((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRscCsC|iii|i|_|io|iii|ndS(s%Set data dictionary using the wrapperN(R>R@R~R%RzRt setdata_local(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRAs cCsP|id}|i||idjp!td|i||idfdS(sRaise an error if consistency of rp broken This is useful for debugging when the cache and disk get out of sync and you need to find out where it happened. Rus Name: %s Old: %s --> New: %s N(RzRARNR%(Rttemptype((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytcheck_consistencys   cCsy$|iii|i|ti@Wntj ov}|idjoZ|i oLt i d|i||d@fd|iii|i|d@ti@qnX||i dRR^R%Rtpermission_maskRwtstrerrorR)R"R#Rz(Rt permissionsRJ((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR^s$ cCstid|i|fdy#|iii|i||fWn6tj o*tid|i||ffdnX||id<||id32bit conversioniRRN(R"R#R%R>Rtutimet OverflowErrorRz(Rt accesstimetmodtime((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytsettimes#  cstifdddjotididny/iiiittifWnmtj o$tidifdnLt j o2iii djpi oqnXi dR(s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRtsiis.Warning: modification time of %s isbefore 1970isICannot change mtime of %s to %s - problem is probably64->32bit conversionR{RN( R"R#R%R>RR;RttimeR<RwR|R)Rz(RR>((R>Rs7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRcs / $ cCs|ioQy |iii|i||Wqttj otid|idqtXnti |i||||i d<||i dR}tlchownR%RBR"R#RRPRz(RRR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRPs    cCs;tid|id|iii|i|idS(NsMaking directory i(R"R#R%R>RR*RA(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR*scCs;tid|id|iii|i|idS(NsMaking directory path i(R"R#R%R>RtmakedirsRA(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRBscCsCtid|id|iii|ihdd<|_dS(NsRemoving directory iRu(R"R#R%R>RtrmdirR Rz(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRCscCs|iii|iS(s2Return list of string paths returned by os.listdir(R>RtlistdirR%(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRDscCs;|iii||i|i|iptdS(s.Make symlink at self.path pointing to linktextN(R>RR/R%RAR+RN(Rtlinktext((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR/s cCsDtid|i|fd|iii||i|idS(s,Make self into a hardlink joined to linkpathsHard linking %s to %siN(R"R#R%R>RtlinkRA(Rtlinkpath((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pythardlinkscCs8|iii|i|i|iptdS(sMake a fifo at self.pathN(R>RR6R%RAR5RN(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR6s cCs5|iii||i|iptdS(sMake a socket at self.pathN(R>R@RRAR7RN(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR8s cCs[tid|id|ii|idi|i|ip t|idS(s"Make sure file at self.path existss Touching itwN( R"R#R%R>RDRKRAR&RN(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyttouchs cCsb|io|iddjSn:|io|iddjSn|iddjSdS(s?Return true if current process has full permissions on the fileiii@i8iiN(tisownerR.tisgroup(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt hasfullpermss   cCsb|io|iddjSn:|io|iddjSn|iddjSdS(s?Return true if current process has read permissions on the fileiii@i iiN(RKR.RL(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytreadable s   cCsb|io|iddjSn:|io|iddjSn|iddjSdS(s6Return true if current process has execute permissionsii@iiiiN(RKR.RL(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt executables   cCsay|iii}Wntj o tSnX|djp$|iido||idjS(s5Return true if current process is owner of rp or rootiR(R>RtgetuidRBtTrueRzR(RR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRKs   cCs3|iido |id|iiidjS(s&Return true if process has group of rpRtprocess_groups(RzRR>RR(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRL"scCstid|id|ioYy|iWqtij o5tio|i n|i i i |iqXnyy|i ii |iWn[tj oO}|ititifjo'|id|i ii |iqnX|idS(s;Delete file at self.path. Recursively deletes directories.s Deleting %siiN(R"R#R%R)RCRRRtfsync_directoriestfsyncR>tshutiltrmtreeRyRwRFtEPERMtEACCESR^RA(RR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR's    cCstid|id|iptSn|i}xG|D]?}|i|}|iptSq?|iotSq?q?WtS(s<Returns true if self (or subdir) contains any regular files.s+Determining if directory contains files: %si( R"R#R%R)tFalseRDtappendRQR(Rt dir_entriestentrytchild_rp((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR<s     cCsd|iid|iS(s0Return quoted self.path for use with os.system()s"%s"cSsd|idS(s\i(tgroup(tm((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRtNs(tregex_chars_to_quotetsubR%(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytquoteKs cCsgditd|iid}|iddjod|}n|p d}n|i|S(sReturn RPath canonical version of self.path This just means that redundant /'s will be removed, including the trailing one, even for directories. ".." components will be retained. RcSs|o |djS(R((tx((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRtXsiR(RtfilterR%Rtnewpath(RRe((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt normalizePs cCsc|i}|iiddjod|ifSn|iid}di|d |dfS(sReturns a tuple of strings (dirname, basename) Basename is never '' unless self is root, so it is unlike os.path.basename. If path is just above root (so dirname is root), then dirname is ''. In all other cases dirname is not the empty string. Also, dirsplit depends on the format of self, so basename could be ".." and dirname could be a subdirectory. For an atomic relative path, dirname will be '.'. RiR(RfR%tfindRR(Rtnormedtcomps((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytdirsplit^s cCss|io$|i|i|i|id Sn|id}|o|i|i|Sn|i|idSdS(s(Return new RPath of directory self is iniiRN(R$t __class__R>R0Rj(Rtdirname((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt get_parent_rpos  $cCs|i|i||S(s<Return new RPath with the same connection but different path(RkR>(RReR$((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRewscCs#|i|i|i|i|fS(s4Return new RPath with same connection by adjoing ext(RkR>R0R$(RR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRZ{scCs(|i|idi|i|f|S(s4Like append, but add ext to path instead of to indexR(RkR>RR0(RRt new_index((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt append_pathscCs|i|i|i|S(s'Return similar RPath but with new index(RkR>R0(RR$((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRnscCs%|i|i|i|hdd<S(s>Return similar RPath with given index, but initialize to emptyRuN(RkR>R0R (RR$((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytnew_index_emptyscCs|itijo/|ot|i|SqBt|i|Sn|oN|djp |djo|iii|Sq|iii|i|SnH|djp |djo|iii|Sn|ii|i|SdS(sReturn open file. Supports modes "w" and "r". If compress is true, data written/read will be gzip compressed/decompressed on the fly. The extra complications below are for security reasons - try to make the extent of the risk apparent from the remote call. trR=N( R>RR?RR%RDR@RR(RRR9((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRDs cCstid|id|i ptd|i|idd|}t|||iotdn|i |iS(sReads fp and writes to self.path. Closes both when done If compress is true, fp will be gzip compressed before being written to self. Returns closing value of fp. sWriting file object to isFile %s already existstwbR9sError closing file( R"R#R%RRNRDR RKRRA(RtfpR9toutfp((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRCs   cCsg|i ptd|if|idd|}|i||i pt|idS(sWrite string s into rpathsFile %s already existsRrR9N(RRNR%RDRRKRA(RRR9Rt((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt write_strings " cCse|io|id}n |i}t|}|o&|\|_|_|_|_dSndSdS(svReturn true if path looks like an increment file Also sets various inc information used by the *inc* functions. iiN(R$R0Rtinc_compressedt inc_timestrtinc_typet inc_basestrR (RRtinc_info((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt isincfiles   cCs|iS(s%Return true if inc file is compressed(Rv(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytisinccompressedscCs|iS(s Return type of an increment file(Rx(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt getinctypescCsti|iS(s+Return time in seconds of an increment file(RRRw(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt getinctimescCsR|io.|i|i|i|id |ifSn|i|i|iSdS(s8Return the base filename of an increment file in rp formiN(R$RkR>R0Ry(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyt getincbases cCs7|i}|io|idSn|idSdS(s4Return the base filename string of an increment fileiiN(RR$Rj(RR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytgetincbase_strs  c Cs|djod}tidB}n+|djod}tidB}nty2|iii|i||iii||Wnct t fj oQ}t |t p|i t i jo%tid|id|iqnX|idS( s=Make a special file with specified type, and major/minor numsR tchriR!tblks)unable to mknod %s -- using touch insteadiN(RtS_IFCHRtS_IFBLKRR>RtmknodR%R3RwRBt isinstanceRFRWR"R#RJRA(RRuR;R<tdatatypeRRJ((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR3s  2#cCs8|p|iiii|nti|idS(sfsync the current file or directory If fp is none, get the file description by opening the file. This can be useful for directories. N(R>R@R/t fsync_localRRTtfileno(RRs((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRTscCsy|itijpty6ti|iti}ti|ti |Wn"t j o}t i doti |n|i t it it ifjp |ion|io d}n;|i}|p|i|i}n|idti|iti}|dj o|i|n|o |nti|ti |nXdS(sfsync current file, run locally If thunk is given, run it before syncing but after gathering the file's file descriptor. tfdiN(R>RR?RNRRDR%tO_RDONLYRTRKRwtlocalsRRFRWRXtEBADFR)RMR R.RAR^tO_RDWR(RtthunkRRJtoldperms((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRs2 "        cCs/|i|tio|iindS(s&fsync self and directory self is underN(RTRRSRm(RRs((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytfsync_with_dir s  cCs7|id|}|i}|i pt|S(s:Open file as a regular file, read data, close, return dataR=(RDRRKRN(RRRsR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytget_data%s cCsBy|id}Wn*tj ot|}|idRDRR%RRRKRERw(RR trfork_fpRJ((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRY`s!   cCswtid|ifd|iitii|iddd}|i||i pt |i |dS(sWrite new resource fork to selfsWriting resource fork to %sis ..namedforkRRrN( R"R#R$R>RDRR%RRRKRNR!(Rt rfork_dataRs((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRXns * cCsBy|id}Wn*tj ot|}|ideZdZddZdZdZdZdZRS(sRepresent a file object that may or may not be compressed We don't want to compress 0 length files. This class lets us delay the opening of the file until either the first write (so we know it has data and should be compressed), or close (when there's no data). cCs@|i p t|||_||_d|_d|_dS(s6Return file-like object with filename based on base_rpiN(RRNtbase_rptcallbackR Rtclosed(RRR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRs    cCs+|djo|iiSn t|dS(NR(RRRB(RR|((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRs cCsZ|iio9|iid |iiddf}|ii|Sn|iidSdS(s*Return gzipped rp by adding .gz to base_rpis.gzN(RR$RnRo(Rtnewind((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pytget_gzipped_rps %cCs||io|ii|Sn|pdSn|i}|io|i|n|iddd|_|ii|S(sWrite buf to fileobjNRrR9i(RRRRRD(RRtnew_rp((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRs   cCse|iodSnd|_|io|iiSn|io|i|in|iidS(s(Close related fileobj, pass return valueiN(RR RRKRRRJ(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRKs    N( RRRR RRRRRK(((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRs    cCs|itijptti|id|idRR?RNRQt uid2unameRzt gid2gnameteas_connRt acls_connRt win_acls_connRtresource_forks_connR&RYtcarbonfile_conntcarbonfile_get(R@((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR5s   c Csddkl}ddkl}ddk}ddk}y||i}|i}||i|ii \}}} } h|i d<|i d<|i d<|i d<|id d <} | SWn4|ij o%tid |ifd dSnXdS( s'Return carbonfile value for local rpathi(R(RNRRuRRiRs*Cannot read carbonfile information from %si(RRRRRR%RRRRRRRRRtErrorR"R#R ( R@RRRRRRRRRRR((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRs$   '    cCsdptdS(Ni(RN(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRscCsdptdS(Ni(RN(R$((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRscCsdptdS(Ni(RN(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRscCsdptdS(Ni(RN(R$((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRscCsdptdS(Ni(RN(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRscCsdptdS(Ni(RN(R((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyRfscCsdptdS(Ni(RN(((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pyR#s(7RRRRtsysRUtgzipRR@RFRRtstaticR"RQR}RRt ImportErrort ExceptionRRR RRRRR(R'RhRlRpRqRR~RRRRRRRR/RRRR5RRRRRRRfR#(((s7/var/lib/python-support/python2.5/rdiff_backup/rpath.pys$sXlH     #         5    0 0