pSrSSKJr SSKJr SSKJr SSKrSSKJr SSKJr SSK J r S r "S S 5r g) z.Utilities for representing a part of a stream.)absolute_import)division)unicode_literalsN)errors) hash_util) installersic\rSrSrSrSSjrSrSrSSjrSr S r S r SS jr \ R4S jrSS jrSrSrSrg) UploadStreamzImplements a subset of the io.IOBase API, adding functionality for uploads. When data is read from a stream, this class 1. Updates hash digesters. 2. Executes a progress callbacks if a byte threshold is passed. NcXlX lUbUO0UlX@lSUlSUlSUlSUlSUlg)aInitializes a FilePart instance. Args: stream (io.IOBase): The underlying stream wrapped by this class. length (int|None): The total number of bytes in the UploadStream. digesters (dict[util.HashAlgorithm, hashlib hash object]|None): Values are updated with with data as it's read. progress_callback (func[int]|None): Accepts an amount of processed bytes and submits progress information for aggregation. NrF) _stream_length _digesters_progress_callback(_bytes_read_since_last_progress_callback_progress_updated_with_end_byte_checkpoint_digesters_checkpoint_absolute_index _start_byte)selfstreamlength digestersprogress_callbacks 7lib/googlecloudsdk/command_lib/storage/upload_stream.py__init__UploadStream.__init__&sJLL#,#8ibDO/45D1+0D(!%D&'D#Dc6URR5$)a:Returns absolute position in the stream. Hashing and progress reporting logic relies on absolute positions. Since child classes overwrite `tell` to make it return relative positions, we need to write hashing and progress reporting in a way that does not reference `self.tell`, which this function makes possible. )r tellrs r_get_absolute_position#UploadStream._get_absolute_positionAs <<   rc8URRU5$)aSeeks to a position in the underlying stream. Catching up digesters sometimes requires seeking to a specific position in self._stream. Child classes wrap streams which are not seekable, and have different strategies to make it appear that a seek has occured, which can be supported by overriding this method. Args: offset (int): the position to seek to. Returns: the new position in the stream. )r seek)roffsets r_update_absolute_position&UploadStream._update_absolute_positionKs <<  V $$rc8URRU5$)a<Reads bytes from the underlying stream. Child classes do not always read directly from the stream. Progress reporting and hashing logic can be reused by overriding only this method. Args: size (int): the number of bytes to read. If less than 0, all bytes are returned. Returns: bytes from self._stream. )r read)rsizes r _get_dataUploadStream._get_data[s <<  T ""rcUR(dgUR5Ul[R"UR5Ulg)zEUpdates checkpoint that holds old hashes to optimize backwards seeks.N)rr"rrcopy_digestersrr!s r_save_digesters_checkpoint'UploadStream._save_digesters_checkpointjs4 ?? &*&A&A&CD#!*!9!9$//!JDrcUR(dgXR:a<URUR5 [R "UR5 OXR 5:afURUR5 URRUR5 [R"UR5UlOXR 5:XagUR5 UR[XR 5- [R55nU(dg[R"URU5 Md)z6Digests data between last and current stream position.N)rrr'rrreset_digestersr"updaterr/r0r,minrWRITE_BUFFER_SIZEupdate_digesters)rnew_absolute_indexdatas r_catch_up_digesters UploadStream._catch_up_digestersqs  ?? ;;; $$T%5%560 99; ; $$T%D%DE  ooT778#,#;#;  $ $$&d ::< <  ##%  ^^  #>#>#@@** ,-d   $7 rc"UR5$)z+Returns the current position in the stream.)r"r!s rr UploadStream.tells  & & ((rcUR5 URU5nU(a[R"URU5 UR (azU=R [U5- slUR [:aHSUlUR UR55 UR5UR:HUl U$)z0Returns `size` bytes from the underlying stream.r) r0r,rr7rrrlen_PROGRESS_CALLBACK_THRESHOLDr"r rr)rr+r9s rr*UploadStream.reads##% >>$ D   $7  55TB5  9 9 ( ):;$ 7  ! !$"="="? @15 1L$ . Krc.U[R:Xa6UR(aXR-nO@[R"S5eU[R :XaUR 5U-nOUnURU5 URU5$)a)Goes to a specific point in the stream. Args: offset (int): The number of bytes to move. whence: Specifies the position offset is added to. os.SEEK_SET: offset is added to the current byte. os.SEEK_END, os.SEEK_CUR are not supported. Returns: The new position in the stream (int). zASEEK_END is not supported if the length of the stream is unknown.) osSEEK_ENDrrErrorSEEK_CURr"r:r')rr&whencer8s rr%UploadStream.seeks #ll2ll OQ Q 2;; 6686A!/0  ) )*< ==rcUR(a>UR(d-U(dURUR55 SUlURR 5$)zCloses the underlying stream.T)rrr"r close)r caught_errors rrJUploadStream.closesH (L(L   ; ; =>-1d* <<   rcU$)Nr!s r __enter__UploadStream.__enter__s Krc4UR[U5S9 g)N)rK)rJbool)r error_type unused_argss r__exit__UploadStream.__exit__sJJD,J-r) rrrrrrrrr )NNN))F)__name__ __module__ __qualname____firstlineno____doc__rr"r'r,r0r:r r*rCSEEK_SETr%rJrOrU__static_attributes__rNrrr r sY!% 6% #K 8D) !# >6 .rr ) r\ __future__rrrrC"googlecloudsdk.command_lib.storagerrgooglecloudsdk.core.updaterrr@r rNrrrbs15&' 582'p.p.r