SrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKJ r SSK J r SS K J r SS K Jr SS KJr SS KJr SS KJr SSKJr SSKJr /SQr"SS\5rg)z)Helper for cat and cp streaming download.)absolute_import)print_function)division)unicode_literalsN)config)EncryptionException)CommandException)NO_URLS_MATCHED_TARGET)StorageUrlFromString)CryptoKeyWrapperFromKey)FindMatchingCSEKInBotoConfig)ObjectIsGzipEncoded) text_util)bucketcontentEncodingcrc32ccustomerEncryption generationmd5Hashnamesizec6\rSrSrSrSrSrSSjrSrg) CatHelper0zDProvides methods for the "cat" command and associated functionality.cXlg)zaInitializes the helper object. Args: command_obj: gsutil command instance of calling command. N command_obj)selfrs )platform/gsutil/gslib/utils/cat_helper.py__init__CatHelper.__init__3s #cUR[R5nU(dg[R"X#5 M?)axCopies contents of the source to the destination via buffered IO. Buffered reads are necessary in the case where you're reading from a source that produces more data than can fit into memory all at once. This method does not close either file when finished. Args: src_fd: The already-open source file to read from. dst_fd: The already-open destination file to write to. N)readioDEFAULT_BUFFER_SIZEr write_to_fd)rsrc_fddst_fdbufs r_WriteBytesBufferedFileToFile'CatHelper._WriteBytesBufferedFileToFile;s4  KK.. /c  F( r"NcSnUc[Rn[Rn[R[lU(a+USS;a"UR[RU5 GO_UGHXnSn UR R U5R[S9GHn Sn U R(aU RR(aU RRR(a{[U RRR[5n U (d;[SU RRR<SU R<35e[!U 5n Sn U(a!U(a [#5 [#S U -5 SnU Rn S[%U S S 5s=:aU::aO O U[lg['U R5nUR)5(a|[+U 5nUR R,R/U R0U R2UUUUU R4UR6U UR8S 9 UR;5 GM[=UR>S 5nURUU5 SSS5 GM U (aGMI[A[BU-5e U[lg!,(df  GMG=f!U[lf=f)aPrints each of the url strings to stdout. Args: url_strings: String iterable. show_header: If true, print a header per file. start_byte: Starting byte of the file to print, used for constructing range requests. end_byte: Ending byte of the file to print; used for constructing range requests. If this is negative, the start_byte is ignored and and end range is sent over HTTP (such as range: bytes -9) cat_out_fd: File descriptor to which output should be written. Defaults to stdout if no file descriptor is supplied. Returns: 0 on success. Raises: CommandException if no URLs can be found. FNr)-zfile://-)bucket_listing_fieldsz(Missing decryption key with SHA256 hash z#. No decryption key matches object Tz ==> %s <==r)compressed_encoding start_byteend_byte object_sizerdecryption_tupleproviderrb)"sysstdoutstderrr+stdinrWildcardIterator IterObjects_CAT_BUCKET_LISTING_FIELDS root_objectr keySha256r rr url_stringr printgetattrr IsCloudUrlr gsutil_apiGetObjectMediarrrrschemeflushopen object_namer r )r url_strings show_headerr2r3 cat_out_fd printed_one old_stdouturl_str did_some_workblrdecryption_keywrapperdecryption_key cat_object storage_urlr1fs r CatUrlStringsCatHelper.CatUrlStringsLsg0K::jJCJ7 Q+<< **399jA"G-%%66w?KK$>L@c$( !COO$F$F22<<;//44>> Hn#)__77AA^^%&& '>n&M# ML3&' kJ7:vr2@j@.cj-/s~~>K%%''$7 $C!))88##//&9'#(oo(33#8&--9 /  //6!221jA76W@Z"#9G#CD Dc#fcj 76 cjs2F K0Bobjectrr`r"rrjsM0&%' /,22AF9! w w r"