³ò OÉcIc@sµdZddkZddkZddkZeiZdefd„ƒYZddd„ƒYZdefd„ƒYZ d efd „ƒYZ d efd „ƒYZ d dd„ƒYZ dS(sÆProvides a high-level interface to some librsync functions This is a python wrapper around the lower-level _librsync module, which is written in C. The goal was to use C as little as possible... iÿÿÿÿNt librsyncErrorcBseZdZRS(s Signifies error in internal librsync processing (bad signature, etc.) underlying _librsync.librsyncError's are regenerated using this class because the C-created exceptions are by default unPickleable. There is probably a way to fix this in _librsync, but this scheme was easier. (t__name__t __module__t__doc__(((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR stLikeFilecBsYeZdZdZd Zd d„Zd d„Zdd„Zd„Z d„Z d„Z RS( s:File-like object used by SigFile, DeltaFile, and PatchFiletrbcCsX|i||ƒ||_d|_|_d|_tidƒ|_d|_|_ dS(s1LikeFile initializer - zero buffers, set eofs offttcN( t check_filetinfiletNonetclosedt infile_closedtinbuftarraytoutbufteoft infile_eof(tselfR t need_seek((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyt__init__4s   cCslt|dƒptdƒ‚nt|dƒptdƒ‚n|o!t|dƒ otdƒ‚ndS(s:Raise type error if file doesn't have necessary attributestreads$Basis file must have a read() methodtcloses%Basis file must have a close() methodtseeks$Basis file must have a seek() methodN(thasattrt TypeError(RtfileR((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR=s iÿÿÿÿcCs¨|djo/x|ip|iƒqWt|iƒ}nLx0|i o$t|iƒ|jo|iƒq?Wt|t|iƒƒ}|i| iƒ}|i|4|S(s/Build up self.outbuf, return first length bytesiÿÿÿÿ(Rt_add_to_outbuf_oncetlenRtminttostring(Rtlengthtreal_lent return_val((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyRFs  ! cCsŽ|ip|iƒny%|ii|iƒ\|_}}Wn*tij o}tt|ƒƒ‚nX|i||_|i i |ƒdS(s.Add one cycle's worth of output to self.outbufN( Rt _add_to_inbuftmakertcycleR Rt _librsyncRtstrRt fromstring(Rtlen_inbuf_readt cycle_outte((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyRTs %cCs…|i pt‚xlt|iƒtjoU|iitƒ}|p)d|_|iiƒ|_d|_ Pn|i|7_qWdS(s&Make sure len(self.inbuf) >= blocksizeiN( RtAssertionErrorRR t blocksizeR RRtinfile_closevalR (Rtnew_in((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR"\s  cCs/d|_|io |iSn|iiƒSdS(s+Close infile and pass on infile close valueiN(R R R-R R(R((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyRhs  N( RRRtmodeR R#RRRRR"R(((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR,s   tSigFilecBseZdZeid„ZRS(sCFile-like object which incrementally generates a librsync signaturecCsWti||ƒyti|ƒ|_Wn*tij o}tt|ƒƒ‚nXdS(s¦SigFile initializer - takes basis file basis file only needs to have read() and close() methods. It will be closed when we come to the end of the signature. N(RRR%t new_sigmakerR#RR&(RR R,R*((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyRqs (RRRR%tRS_DEFAULT_BLOCK_LENR(((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR0ost DeltaFilecBseZdZd„ZRS(s?File-like object which incrementally generates a librsync deltacCs¥ti||ƒt|ƒtijo |}n/|i|ƒ|iƒ}|iƒ pt‚yt i |ƒ|_ Wn*t i j o}t t |ƒƒ‚nXdS(sõDeltaFile initializer - call with signature and new file Signature can either be a string or a file with read() and close() methods. New_file also only needs to have read() and close() methods. It will be closed when self is closed. N(RRttypettypest StringTypeRRRR+R%tnew_deltamakerR#RR&(Rt signaturetnew_filet sig_stringR*((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR~s   (RRRR(((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR3|st PatchedFilecBseZdZd„ZRS(s=File-like object which applies a librsync delta incrementallycCsšti||ƒt|dƒo |i}nt|ƒtij otdƒ‚nyti |ƒ|_ Wn*ti j o}t t |ƒƒ‚nXdS(sáPatchedFile initializer - call with basis delta Here basis_file must be a true Python file, because we may need to seek() around in it a lot, and this is done in C. delta_file only needs read() and close() methods. Rs basis_file must be a (true) fileN( RRRRR4R5tFileTypeRR%tnew_patchmakerR#RR&(Rt basis_filet delta_fileR*((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR’s (RRRR(((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR;st SigGeneratorcBs8eZdZeid„Zd„Zd„Zd„ZRS(syCalculate signature. Input and output is same as SigFile, but the interface is like md5 module, not filelike object cCsbyti|ƒ|_Wn*tij o}tt|ƒƒ‚nXd|_d|_d|_dS(sReturn new signature instanceRN( R%R1t sig_makerRR&R tgotsigtbufferR:(RR,R*((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyRªs  cCsh|iotdƒ‚n|i|7_x8t|iƒtjo!|iƒotdƒ‚q,q,WdS(s6Add buf to data that signature will be calculated overs'SigGenerator already provided signatures%Premature EOF received from sig_makerN(RBRRCRR,tprocess_buffer(Rtbuf((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pytupdate²s  cCsry"|ii|iƒ\}}}Wn*tij o}tt|ƒƒ‚nX|i||_|i|7_|S(s9Run self.buffer through sig_maker, add to self.sig_string(RAR$RCR%RR&R:(RRt len_buf_readR)R*((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyRD»s"cCsx|iƒpqW|iS(s Return signature over given data(RDR:(R((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pytgetsigÃs ( RRRR%R2RRFRDRH(((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyR@£s  ((( RR5RR%tRS_JOB_BLOCKSIZER,t ExceptionRRR0R3R;R@(((s:/var/lib/python-support/python2.5/rdiff_backup/librsync.pyss   C