ó gbc@sÿdZddlZddlZddlZddlZddlZddgZddddd f\ZZZ Z Z ddf\Z Z d „Zd „Zd „Zd „Zd„Zd„Zddd„Zdfd„ƒYZd„ZedkrûeƒndS(s"Functions that read and write gzipped files. The user of the file doesn't have to worry about the compression, but random access is not allowed. This consisted on a patched version of of standard gzip python module based on Andrew Kuchling's minigzip.py distributed with the zlib module iÿÿÿÿNtGzipFiletopeniiiiicCs|dkr|d7}n|S(s‹Return i as an unsigned integer, assuming it fits in 32 bits. If it's >= 2GB when viewed as a 32-bit unsigned int, return a long. ili l((ti((s,lib/python2.7/site-packages/obitools/gzip.pytU32s  cCs|d@S(s>Return the low-order 32 bits of an int, as a non-negative int.lÿÿ((R((s,lib/python2.7/site-packages/obitools/gzip.pytLOWU32 scCs|jtjd|ƒƒdS(Ns(treprR/thextid(R4ts((s,lib/python2.7/site-packages/obitools/gzip.pyt__repr__ŒscCsW|ddkr|d}n||_tjdƒ|_d|_g|_d|_dS(Niýÿÿÿs.gzRi(RR(tcrc32tcrctsizetwritebuftbufsize(R4R((s,lib/python2.7/site-packages/obitools/gzip.pyR's    cCsµ|jjdƒ|jjdƒ|jd }d}|rBt}n|jjt|ƒƒt|jttjƒƒƒ|jjdƒ|jjdƒ|r±|jj|dƒndS(Ns‹siýÿÿÿissÿs(R/RRtFNAMEtchrR tlongttime(R4tfnametflags((s,lib/python2.7/site-packages/obitools/gzip.pyR3™s  cCstjdƒ|_d|_dS(NRi(R(R=R>R?(R4((s,lib/python2.7/site-packages/obitools/gzip.pyt _init_read§scCst|jƒ|kr@|j|jj|t|jƒƒ7_n|j| }t|ƒdkr||jt|ƒ||_n |d|_|j||_|S(Niiøÿÿÿ(tlenR1R/R R2(R4R?tchunk((s,lib/python2.7/site-packages/obitools/gzip.pyt_read_internal«s+  cCs~|jdƒ}t|ƒdkr-td‚n|dkrEtd‚nt|jdƒƒ}|dkrrtd‚nt|jdƒƒ}|jdƒ|t@ràt|jdƒƒ}|d t|jdƒƒ}|j|ƒn|t@r x3tr|jdƒ}| s|d kríPqíqíWn|t@r`x3tr\|jdƒ}| sU|d kr-Pq-q-Wn|t @rz|jdƒndS( Nis Reached EOFs‹sNot a gzipped fileiisUnknown compression methodiis( RKRItEOFErrorR.tordtFEXTRARBR!tFCOMMENTtFHCRC(R4tmagictmethodtflagtxlenR;((s,lib/python2.7/site-packages/obitools/gzip.pyt_read_gzip_header·s4              cCsÃ|jtkr0ddl}t|jdƒ‚n|jdkrKtd‚nt|ƒdkr¿|j t|ƒ|_ t j ||j ƒ|_ |jj |jj|ƒƒ|jt|ƒ7_ndS(Niÿÿÿÿs$write() on read-only GzipFile objects!write() on closed GzipFile objecti(RR&terrnoR.tEBADFR/Rt ValueErrorRIR?R(R=R>RR-R0(R4tdataRV((s,lib/python2.7/site-packages/obitools/gzip.pyRÛs  iÿÿÿÿcCsd|jtkr0ddl}t|jdƒ‚n|jdkrR|jdkrRdSd}|dkr¸y4x-tr–|j |ƒt |j |dƒ}qjWWq$t k r´|j}q$Xnly=x6||jkró|j |ƒt |j |dƒ}q¾WWn,t k r#||jkr$|j}q$nX|j | }|j ||_ |j||_|j|7_|S(Niÿÿÿÿs$read() on write-only GzipFile objectiRii(RR RVR.RWR$R/RR!t_readtmintmax_read_chunkRLR#R0(R4R?RVtreadsizeRJ((s,lib/python2.7/site-packages/obitools/gzip.pyR ès2        cCs?||j|_t|ƒ|j|_|jt|ƒ8_dS(N(R#RIR$R0(R4R((s,lib/python2.7/site-packages/obitools/gzip.pyt_unreadscCs|jdkrtd‚n|jrZ|jƒ|jƒtjtj ƒ|_ t |_n|j |ƒ}|dkr§|j j ƒ}|j ƒ|j|ƒtd‚n|j j |ƒ}|j|ƒ|j jdkr|j j|j|_|j dƒ|j ƒt|_ndS(Ns Reached EOFRi(R/RRLR"RHRUR(t decompressobjR+t decompresstFalseRKtflusht _read_eoft_add_read_datat unused_dataR1R!(R4R?Rt uncompress((s,lib/python2.7/site-packages/obitools/gzip.pyRZ s(            cCsXtj||jƒ|_|j||_|jt|ƒ|_|jt|ƒ|_dS(N(R(R=R>R#R$RIR?(R4RY((s,lib/python2.7/site-packages/obitools/gzip.pyRd6scCsxt|jd ƒ}tt|jdƒƒ}t|ƒt|jƒkrStd‚n!|t|jƒkrttd‚ndS(NisCRC check faileds!Incorrect length of data produced(RR2RR>R.RR?(R4R=tisize((s,lib/python2.7/site-packages/obitools/gzip.pyRc<s  cCs§|jtkrf|jj|jjƒƒt|jt|jƒƒt|jt|j ƒƒd|_n|jt krd|_n|j r£|j j ƒd|_ ndS(N(RR&R/RR-RbR RR>R?RR Rtclose(R4((s,lib/python2.7/site-packages/obitools/gzip.pyRhIs    cCsIy&|jdkr%|jdkr%dSWntk r:dSX|jƒdS(N(RRR/tAttributeErrorRh(R4((s,lib/python2.7/site-packages/obitools/gzip.pyt__del__\s cCs?|jtkr.|jj|jj|ƒƒn|jjƒdS(N(RR&R/RR-Rb(R4t zlib_mode((s,lib/python2.7/site-packages/obitools/gzip.pyRbescCs |jjƒS(s¥Invoke the underlying file object's fileno() method. This will raise AttributeError if the underlying file object doesn't support fileno(). (R/tfileno(R4((s,lib/python2.7/site-packages/obitools/gzip.pyRlkscCstS(N(Ra(R4((s,lib/python2.7/site-packages/obitools/gzip.pytisattysscCs|jS(N(R0(R4((s,lib/python2.7/site-packages/obitools/gzip.pyttellvscCsV|jtkrtdƒ‚n|jjdƒt|_d|_d|_d|_ dS(s[Return the uncompressed stream file position indicator to the beginning of the filesCan't rewind in write modeiRN( RR R.R/tseekR!R"R#R$R0(R4((s,lib/python2.7/site-packages/obitools/gzip.pytrewindys   cCsö|jtkr~||jkr-tdƒ‚n||j}x)t|dƒD]}|jddƒqKW|j|ddƒnt|jtkrò||jkr©|jƒn||j}x%t|dƒD]}|jdƒqÇW|j|dƒndS(NsNegative seek in write modeis( RR&R0R.trangeRR RpR (R4R0tcountR((s,lib/python2.7/site-packages/obitools/gzip.pyRo„s   cCsF|dkr!tj}|j}n|}g}xÛ|dkr |j|ƒ}|jdƒ}||ks„|dkr‘t|ƒ|kr‘|d}n|dks©|dkr×|j||d ƒ|j||dƒPn|j|ƒ|t|ƒ}t||dƒ}q0W||jkr9t||jddƒ|_ndj |ƒS(Nis iÿÿÿÿiRii( tsystmaxintR%R tfindRItappendR^R[tjoin(R4R?R]tbufstcR((s,lib/python2.7/site-packages/obitools/gzip.pytreadline•s(   *  icCsn|dkrtj}ng}xI|dkri|jƒ}|dkrIPn|j|ƒ|t|ƒ}q!W|S(NiR(RsRtRzRvRI(R4tsizehinttLtline((s,lib/python2.7/site-packages/obitools/gzip.pyt readlines´s     cCs"x|D]}|j|ƒqWdS(N(R(R4R|R}((s,lib/python2.7/site-packages/obitools/gzip.pyt writelinesÂs cCs|S(N((R4((s,lib/python2.7/site-packages/obitools/gzip.pyt__iter__ÆscCs |jƒ}|r|St‚dS(N(Rzt StopIteration(R4R}((s,lib/python2.7/site-packages/obitools/gzip.pytnextÉs Ni(i ("t__name__t __module__t__doc__RRR\R5R<R'R3RHRKRURR R^RZRdRcRhRjR(t Z_SYNC_FLUSHRbRlRmRnRpRoRzR~RR€R‚(((s,lib/python2.7/site-packages/obitools/gzip.pyR;s<G    $  )           cCs¬tjd}|o |ddk}|r6|d}n|sHdg}nx]|D]U}|rÞ|dkr‘tddddd tjƒ}tj}q9|d d kr¶d Gt|ƒGHqOnt|dƒ}tj|d d ƒ}n[|dkrtj}tdddd d tjƒ}n%tj|dƒ}t|d d ƒ}x0trk|j dƒ}|s[Pn|j |ƒq<W|tjk rˆ|j ƒn|tjk rO|j ƒqOqOWdS(Niis-dt-RRRRR/iýÿÿÿs.gzsfilename doesn't end in .gz:twbi( RstargvRtstdintstdoutR8RRR!R RRh(targsR`targtftgRJ((s,lib/python2.7/site-packages/obitools/gzip.pyt_testÑs<        !  t__main__(R…RRsRER(Rt__all__tFTEXTRPRNRBROR R&RRR R RRRRRRƒ(((s,lib/python2.7/site-packages/obitools/gzip.pyt s$$   $      ÿ— &