3xjwJZddlmZddlmZmZmZmZmZddlm Z m Z Gdde Z dS))BytesIO)linefeed_byte_valuecrlfcr_byte linefeed_byte cr_byte_value)ClosingContextManageruceZdZdZdZdZdZdZdZdZ dZ dZ dZ d Z d Zd Zd Zd ZdZdZdZdZdZdZdZd'dZd'dZd'dZd(dZdZdZdZdZ e!dZ"dZ#d Z$d!Z%d)d$Z&d%Z'd&Z(dS)* BufferedFilezc Reusable base class to implement Python-style file buffering around a simpler stream. i r @cd|_d|_|j|_t |_t |_d|_d|_ dx|_ |_ d|_ dS)NrF) newlines_flags_DEFAULT_BUFSIZE_bufsizer_wbufferbytes_rbuffer_at_trailing_cr_closed_pos_realpos_sizeselfs >C:\Projects\Historical\venv\Lib\site-packages\paramiko/file.py__init__zBufferedFile.__init__3sZ  -    $ %&% DM c.|dSN)closer!s r#__del__zBufferedFile.__del__Bs r%c2|jrtd|S)z Returns an iterator that can be used to iterate over the lines in this file. This iterator happens to return the file itself, since a file is its own iterator. :raises: ``ValueError`` -- if the file is closed. zI/O operation on closed file)r ValueErrorr!s r#__iter__zBufferedFile.__iter__Es" < =;<< < r%c<|d|_dS)zN Close the file. Future read and write operations will fail. TN)flushrr!s r#r(zBufferedFile.closeQs  r%c||jt|_dS)z{ Write out any data in the write buffer. This may do nothing if write buffering is not turned on. N) _write_allrgetvaluerr!s r#r.zBufferedFile.flushXs4  ..00111  r%c@|}|st|S)a Returns the next line from the input, or raises ``StopIteration`` when EOF is hit. Unlike python file objects, it's okay to mix calls to `.next` and `.readline`. :raises: ``StopIteration`` -- when the end of the file is reached. :returns: a line (`str`, or `bytes` if the file was opened in binary mode) read from the file. )readline StopIteration)r"lines r#__next__zBufferedFile.__next__as$}}   r%c2|j|jz|jkS)z Check if the file can be read from. :returns: `True` if the file can be read from. If `False`, `read` will raise an exception. )r FLAG_READr!s r#readablezBufferedFile.readablers dn,??r%c2|j|jz|jkS)z Check if the file can be written to. :returns: `True` if the file can be written to. If `False`, `write` will raise an exception. )r FLAG_WRITEr!s r#writablezBufferedFile.writable|s do-$/AAr%cdS)z Check if the file supports random access. :returns: `True` if the file supports random access. If `False`, `seek` will raise an exception. Fr!s r#seekablezBufferedFile.seekables ur%c|t|}||dt|<t|S)z Read up to ``len(buff)`` bytes into ``bytearray`` *buff* and return the number of bytes read. :returns: The number of bytes read. N)readlen)r"buffdatas r#readintozBufferedFile.readintos;yyT## [s4yy[4yyr%Nc0|jrtd|j|jzstd||dkrt |j}t |_|xjt|z c_ | |j }n#t$rd}YnwxYw|t|dkrnP| ||xj t|z c_ |xjt|z c_t |S|t|jkrB|jd|}|j|d|_|xjt|z c_|St|j|kr|t|jz }|j|jzrt|j|} | |}n#t$rd}YnwxYw|t|dkrnE|xj|z c_|xj t|z c_ t|j|k|jd|}|j|d|_|xjt|z c_|S)a Read at most ``size`` bytes from the file (less if we hit the end of the file first). If the ``size`` argument is negative or omitted, read all the remaining data in the file. .. note:: ``'b'`` mode flag is ignored (``self.FLAG_BINARY`` in ``self._flags``), because SSH treats all files as binary, since we have no idea what encoding the file is in, or even if the file is text data. :param int size: maximum number of bytes to read :returns: data read from the file (as bytes), or an empty string if EOF was encountered immediately File is closedzFile is not open for readingNr)rIOErrorrr8 bytearrayrrrrB_readrEOFErrorextendr FLAG_BUFFEREDmaxr)r"sizeresultnew_data read_sizes r#rAzBufferedFile.reads" < ,*++ + dn, :899 9 LdQhht}--F!GGDM IIV $II +$#zz$*?@@HH$$$#HHH$$#h--1*<*< h''' X.  S]]*  +== 3t}%% % %]5D5)F M$%%0DM IIV $IIM$-  4''s4=111I{T// : y99  ::i00     c(mmq&8&8 MMX %MM MMS]] *MM$-  4''uu% dee,  S[[  s$B B-,B-G)) G87G8c|jrtd|j|jzstd|j}d} |jry|j|jzrjt|dkrW|dtkr%|dd}| tn| td|_|H|dkrBt||kr||d|_|d|}d}n|t|z }n|j }t|vs|j|jzr t|vrn ||}n#t$rd}YnwxYw|t|dkrPt!|_|xjt|z c_|j|jzr|nt'|S||z }|xjt|z c_|t}|j|jzr.|t}|dkr||ks|dkr|}|dkr=|xjt|z c_|j|jzr|nt'|S|dz}||t,kr)|t|kr||tkr|dz }|r||d|jz|_n||d|_|||} |d|tz}t|jdkr| tkrd|_n| | |xjt|z c_|j|jzr|nt'|S) a Read one entire line from the file. A trailing newline character is kept in the string (but may be absent when a file ends with an incomplete line). If the size argument is present and non-negative, it is a maximum byte count (including the trailing newline) and an incomplete line may be returned. An empty string is returned only when EOF is encountered immediately. .. note:: Unlike stdio's ``fgets``, the returned string contains null characters (``'\0'``) if they occurred in the input. :param int size: maximum length of returned string. :returns: next line of the file, or an empty string if the end of the file has been reached. If the file was opened in binary (``'b'``) mode: bytes are returned Else: the encoding of the file is assumed to be UTF-8 and character strings (`str`) are returned rGzFile not open for readingFTrr N)rrHrr8rrFLAG_UNIVERSAL_NEWLINErBr_record_newlinerrrrrJrKrr FLAG_BINARYr rfindr) r"rOr5 truncatednrQposrposxposlfs r#r3zBufferedFile.readlines. < ,*++ + dn, 7566 6} ' +$ -K$"== -IIMM71118D((....((111',$ tqyyt99$$$(KDM;D $I3t99$M$$ d99%>Eoo ::a==     c(mmq&8&8 %  SYY& #{T-==Jtt1T77J H D MMS]] *MMO' +Rii && ;4 4 99W%%D s cAgg "99 IIT "II;)99F44qww FQw I & &s4yy  T 111 AID  ( K$-7DMM KDM #d(^DSDzM)   ! # #"--$(D   $ $ $ SYY {T%55Btt1T77Bs3E EEcg}d} |}t|dkrn1|||t|z }|||krnY|S)a Read all remaining lines using `readline` and return them as a list. If the optional ``sizehint`` argument is present, instead of reading up to EOF, whole lines totalling approximately sizehint bytes (possibly after rounding up to an internal buffer size) are read. :param int sizehint: desired maximum number of bytes to read. :returns: list of lines read from the file. r)r3rBappend)r"sizehintlines byte_countr5s r# readlineszBufferedFile.readlines@ss  ==??D4yyA~~ LL    #d)) #J$:+A+A  r%c td)a Set the file's current position, like stdio's ``fseek``. Not all file objects support seeking. .. note:: If a file is opened in append mode (``'a'`` or ``'a+'``), any seek operations will be undone at the next write (as the file position will move back to the end of the file). :param int offset: position to move to within the file, relative to ``whence``. :param int whence: type of movement: 0 = absolute; 1 = relative to the current position; 2 = relative to the end of the file. :raises: ``IOError`` -- if the file doesn't support random access. zFile does not support seeking.rH)r"offsetwhences r#seekzBufferedFile.seekVs$6777r%c|jS)z Return the file's current position. This may not be accurate or useful if the underlying file doesn't support random access, or was opened in append mode. :returns: file position (`number ` of bytes). )rr!s r#tellzBufferedFile.telljs yr%c6t|tr|d}|jrt d|j|jzst d|j|jzs||dS|j ||j|j zr| t}|dkr|j }|t|t|z z }||d|dzt!|_ |j ||dzddS|j |jkr|dS)a8 Write data to the file. If write buffering is on (``bufsize`` was specified and non-zero), some or all of the data may not actually be written yet. (Use `flush` or `close` to force buffered data to be written out.) :param data: ``str``/``bytes`` data to write zutf-8rGzFile not open for writingNrr ) isinstancestrencoderrHrr;rMr0rwriteFLAG_LINE_BUFFEREDrfindrr1rBrrkrr.)r"rDlast_newline_poswbufs r#rpzBufferedFile.writets dC  (;;w''D < ,*++ + do- 7566 6 d00  OOD ! ! ! F D!!! ;0 0 #zz-88 1$$}--// CIID $99 %;'7!';%; <=== '   ##D)9A)=)?)?$@AAA F =    4= 0 0 JJLLLr%c:|D]}||dS)a? Write a sequence of strings to the file. The sequence can be any iterable object producing strings, typically a list of strings. (The name is intended to match `readlines`; `writelines` does not add line separators.) :param sequence: an iterable sequence of strings. N)rp)r"sequencer5s r# writelineszBufferedFile.writeliness-  D JJt    r%c|S)z Identical to ``iter(f)``. This is a deprecated file interface that predates Python iterator support. r>r!s r# xreadlineszBufferedFile.xreadliness  r%c|jSr')rr!s r#closedzBufferedFile.closeds |r%ct)z (subclass override) Read data from the stream. Return ``None`` or raise ``EOFError`` to indicate EOF. )rK)r"rOs r#rJzBufferedFile._reads jjr%c td)zI (subclass override) Write data into the stream. zwrite not implementedrf)r"rDs r#_writezBufferedFile._writes -...r%cdS)ai (subclass override) Return the size of the file. This is called from within `_set_mode` if the file is opened in append mode, so the file position can be tracked and `seek` and `tell` will work correctly. If the file is a stream that can't be randomly accessed, you don't need to override this method, rr>r!s r# _get_sizezBufferedFile._get_sizes qr%rrTc|j|_|dkrd}|dkr|xj|j|jzzc_n]|dkr3||_|xj|jzc_|xj|jzc_n$|dkr|xj|j|jzzc_d|vsd|vr|xj|jzc_d|vsd|vr|xj|jzc_d|vrI|xj|j|jzzc_||_ |j x|_ |_ d|vr|xj|j zc_d|vr|xj|j zc_d |_d Sd S) zM Subclasses call this method to initialize the BufferedFile. rr r+wabUN)rrrrMrqr8r; FLAG_APPENDrr rrrWrUr)r"modebufsizes r# _set_modezBufferedFile._set_modes~ - Q;;G a<< KK4-0GG GKKK q[[#DM KK4- -KK KKD33 3KKK \\ KKT/$2IIJ JKK 4KKSD[[ KK4> )KK 4KKSD[[ KK4? *KK $;; KK4?T-== =KK))DJ(, 2DI $;; KK4+ +KK $;; KK46 6KK!DMMM ;r%cTt|}t|dkr||}||d}|j|jzr$|xj|z c_|jx|_|_n |xj|z c_|xj|z c_t|dkdS)Nr) memoryviewrBr~rrr rr)r"raw_datarDcounts r#r0zBufferedFile._write_alls(##$ii!mmKK%%Er%r#r r s HHHIJKKM!      "@@@BBB   9999vgCgCgCgCR,8888("""H   X ///   &!&!&!&!P    ( ( ( ( (r%r N) iorparamiko.commonrrrrr paramiko.utilr r r r>r%r#rs$32222222q(q(q(q(q((q(q(q(q(q(r%