"SrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK J r SSK J r SS K Jr "S S \5rg) z-Helper class for streaming resumable uploads.)absolute_import)print_function)division)unicode_literalsN)CommandException)GetJsonResumableChunkSize)UTF8cn\rSrSrSrS Sjr\S5rS SjrSr Sr \ R4Sjr S rS rg )#ResumableStreamingJsonUploadWrapperaWraps an input stream in a buffer for resumable uploads. This class takes a non-seekable input stream, buffers it, and exposes it as a stream with limited seek capabilities such that it can be used in a resumable JSON API upload. max_buffer_size bytes of buffering is supported. cXlU(d*U[5:a[SU<S[5<S35eX l[R "5UlSUlSUlSUl g)aZInitializes the wrapper. Args: stream: Input stream. max_buffer_size: Maximum size of internal buffer; should be >= the chunk size of the resumable upload API to ensure that at least one full chunk write can be replayed in the event of a server error. test_small_buffer: Skip check for buffer size vs. chunk size, for testing. z4Resumable streaming upload created with buffer size z#, JSON resumable upload chunk size z`. Buffer size must be >= JSON resumable upload chunk size to ensure that uploads can be resumed.rN) _orig_fprr_max_buffer_size collectionsdeque_buffer _buffer_start _buffer_end _position)selfstreammax_buffer_sizetest_small_buffers 3platform/gsutil/gslib/resumable_streaming_upload.py__init__,ResumableStreamingJsonUploadWrapper.__init__)sfM 3L3N!N  ./H/J L MM,$$&DLDDDNc0[URSS5$)z>rcg)z/Returns true since limited seek support exists.Tr!s rseekable,ResumableStreamingJsonUploadWrapper.seekables rc (U[R:XaQXR:dXR:a,[ SU<SUR<SUR<S35eXlg U[R :XaXR:a[ SU<SUR<S35eURUR5(a#URUR5(aM#U=R U-slg [ SU<S U<S 35e) zSeeks on the buffered stream. Args: offset: The offset to seek to; must be within the buffer bounds. whence: Must be os.SEEK_SET. Raises: CommandException if an unsupported seek mode or position is used. z]Unable to resume upload because of limited buffering available for streaming uploads. Offset z# was requested, but only data from z to z is buffered.zInvalid SEEK_END offset z on streaming upload. Only z can be buffered.z-Invalid seek mode on streaming upload. (mode z , offset )N) osSEEK_SETrrrrSEEK_ENDrr()roffsetwhences rseek(ResumableStreamingJsonUploadWrapper.seeks $$ $1A1A(A!'(:(:Drbs64&%' ,;&x!&x!r