tSSKJr SSKJr SSKJr SSKJr SSKJr SSKrSSKrSSK r SSK r SSK r SSK r SSK r SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJr SSKrSSKrSSKrSS KJr SS KJr SSK r SS K!J"r" SS K!J#r# SS K$J%r% SSK&J'r( SSK)J*r* SSK+J,r,J-r- SSK.J/r/ SSK0J1r1 SSK2J3r3 SSK4J5r5 \3(dmSSK6r6SSK7r7Sr8Sr9Sr:Sr;\*Rx"5 \="\*R|S5r?\ R"5rA\%"S5rB\%"S5rC\%"S5rD\%"S5rESoSjrFSpSjrGSpS jrHS!rI\1"\I5rJS"rK\1"\K5rLS#rM\1"\M5rNS$rO\1"\O5rPS%rQS&rRS'rSS(rTS)rUS*rVS+rWS,rXS-rYS.rZS/r[S0r\S1r]S2r^S3r_S4r`S5raS6rbS6rcSrdSreS7rfS8rgS9rhS:riS;rjS\l5rm\mR4S?jroS@rpSArq\RRSBSCS5=(a \RRSBSDS5rt\RRSBSESF5RSG5rv\-"5rw\RRSBSHS5SLrx\RRSBSIS5SLry\RRSJSKSL5R5SM:gr{SNr|SOr}\}"5r~SPrSQrSRr"SSST\ GR5r\"5r"SUSV\ GR 5rSWrSXrSYrSZrS[rS\r\S]5r\SqS^j5r\S_5r\S`5rSarSbrScr\Sd5rSerSfr"SgSh\l5r"SiSj\l5r"SkSl\l5r"SmSn\5rg)r)absolute_import)print_function)division)unicode_literals)contextmanagerN)urllib) cStringIO)KmsApi)PopulateProjectId)ResumableDownloadException)ResumableUploadException) LazyWrapper) posix_util)UsingCrcmodExtensionHasUserSpecifiedGsHost)UTF8)#Base64Sha256FromBase64EncryptionKey) IS_WINDOWS)MakeHumanReadablec>[[R"5Vs/sHoRPM sn5nSnUS:a0X!;aUS- nM[R"U5 US- nUS:aM0[S5es snf![ a Us$[ a M*f=f)Nilr TzUnable to generate GID for )sortedgrpgetgrallgr_gidgetgrgidKeyError OverflowError Exception)groupall_gidgids #platform/gsutil/gslib/tests/util.py GetInvalidGidr$@s ?ull?@G C    q  S q  $ 1 221@"  sA<B B BBc[5n[5n[U5S:XaU$[U5Vs/sH o"U:wdM UPM snS$s snf)Nrr) GetPrimaryGid GetUserGroupslenlist) primary_gid user_groupsgs r#GetNonPrimaryGidr-\sN /K/K ;1 K( =(!,r>ss#,,w"7"?"?r3c[[R"5Vs/sHoRPM sn5SS-$s snf)Nr)rr:getpwallpw_uid)users r#r>r>xs-fclln=ndkkn=>rBQF=s?c[5$r/)r$r2r3r#r>r>}MOr3c[5$r/)r'r2r3r#r>r>rEr3FcU(aSnO![RRSSS5nSSRU5SS/n[R SSS[ 5-/U-U-n[5(d[[R5/U-nOUnUVs/sHn[R"U5PM sn$s snf) zFAdds config options to a list of strings defining a gsutil subcommand.FGSUtiluse_gcloud_storagez-ozGSUtil:use_gcloud_storage={}z#GSUtil:hidden_shim_mode=no_fallbackz--testexceptiontraceszGSUtil:default_project_id=) botoconfiggetboolformatgslib GSUTIL_PATHr InvokedFromParFilestrsys executablesix ensure_str) raw_command force_gsutilrIgcloud_storage_settinggsutil_command#gsutil_command_with_executable_pathparts r#GetGsutilCommandr\s,,X7K-24 $++,>? +  0$"%6%88 ++.   +.s~~+>*?.*P'*8'+N O+N4#.. +N OO Os B<c [RR5nU(aURU5 [ 5n[ R "U5H2upE[ R"U5U[ R"U5'M4 [[S5(a[ROSn[R"U[R[R[RUUS9$)zCReturns a subprocess.Popen object for for running a gsutil command.setsidN)stdoutstderrstdinenv preexec_fn) r0environcopyupdatedictrT iteritemsrUhasattrr^ subprocessPopenPIPE)cmdenv_varsrbenvstrkvrcs r#GetGsutilSubprocessrrs # JJx 6&mmC da #q 1F3>>! !$B11ryyt*   #!+!+ *$%/  11r3c ^UbU[R(a+[U[5(dUR [ 5nOUR [ 5nSU0nU4Sjn[R(aSUS'O'[ R"SU5nUR5 TR"S0UD6n[R(dWR5 UVs/sHn[R"U5PM nnU$s snf![aE UVs/sH.n[R"U[R"S55PM0 Os snfnnU$f=f)Ninputc>[R"[R"TR5[R 5 gr/)r0killpggetpgidpidsignalSIGKILL)processsr#Kill$CommunicateWithTimeout..Kills"IIbjj%v~~6r3ihtimeoutFr2)rTPY3 isinstancebytesencoder threadingTimerstart communicatecancel ensure_textUnicodeDecodeErrorlocalegetpreferredencoding)r{ra comm_kwargsr|timerc_outoutputs` r#CommunicateWithTimeoutrs  ww u % % T"ll4 e% +7 WW K  OOC &E KKM    , ,%  LLN38 95S__V $5E 9 , :  F  ; ;E BC E E , s0D " DD D E5EEEs,iMSM9eeXliDZHSBJZO71R98tfeW/+87VXTpk5chGd6Y=s,4TSaQ3S4U+5oxAbByA7HgIigD51zfzGed/c03Ts2TXc=s,HO4Q2X28N/6SmuAJ1v1CTuJjf5emQcXf7YriKzT1gj0=s,U6zIErjZCK/IpIeDS0pJrDayqlZurY8M9dvPJU0SXI8=s,MTIzNDU2Nzg5MDEyMzQ1Njc4OTAxMjM0NTY3ODkwMTI=sdnF5x6K/8ZZRzpfSlMMM+w==sbarzN7UdGUp1E+RbVvZSTy1R8g==zCrcTMQ==sbar2zIk4lOfUiA+szcorNIotEMg==zQScXtg==sbar3z9iW6smjfu9hm0A//VQTQfw==zs0yUtQ==sbar4zkPCx6uZiUOU7W6E+cDCZFg==zZ4bwXg==sbar5z758XbXQOVkp8fTKMm83NXA==zle1zXQ==Tz&/tmp/.boto.parallel_upload_test_configzPThis sync will orphan file(s), please fix their permissions before trying again.z$Mode for %s won't allow read access.z+GID for %s doesn't exist on current system.z+UID for %s doesn't exist on current system.z,Insufficient access with uid/gid/mode for %sc0\rSrSrSrSrSrSrSrSr Sr S r g ) KmsTestingResourcesizCConstants for KMS resource names to be used in integration testing.z us-central1z$keyring-for-gsutil-integration-testsz key-for-gsutil-integration-testsz!key-for-gsutil-integration-tests2zkey-for-gsutil-no-authz-cryptokey-for-gsutil-integration-tests-%d%d%dr2N) __name__ __module__ __qualname____firstlineno____doc__KEYRING_LOCATION KEYRING_NAMECONSTANT_KEY_NAMECONSTANT_KEY_NAME2"CONSTANT_KEY_NAME_DO_NOT_AUTHORIZEMUTABLE_KEY_NAME_TEMPLATE__static_attributes__r2r3r#rrs2K"8,9:(@$ Nr3rc[[R"55nUR[ S5[ R [ RS9nURX 5n[SSSU/SS9n[U5n[U5 U$)zAEnsures test keys exist and that the service agent is authorized.N)locationkms authorizez-kT)rW) r logging getLogger CreateKeyRingr rrrCreateCryptoKeyr\rrr)key_namekms_apikeyring_fully_qualified_namekey_fully_qualified_namermr{s r#"AuthorizeProjectToUseTestingKmsKeyr)s 7$$& ''!(!6!6&&"33"7"5 %44".%d4LM&* ,#  $'! !!r3cF[R"U[U5-5$)zBuilds a regex to match a file name for a file that would be orphaned. Args: obj: Object uri. err_str: The error string to search for. Returns: A regex that will match the file name and with the error text for a file that would be orphaned. )recompile ObjectToURI)objerr_strs r#BuildErrorRegexr<s Gk#.. //r3ch^[U4SjUR5RS555$)aReturns set of object name tails. Tails can be compared between source and dest, past the point at which the command was done. For example if test ran {cp,mv,rsync} gs://bucket1/dir gs://bucket2/dir2, the tails for listings from bucket1 would start after "dir", while the tails for listings from bucket2 would start after "dir2". Args: start_point: The target of the cp command, e.g., for the above command it would be gs://bucket1/dir for the bucket1 listing results and gs://bucket2/dir2 for the bucket2 listing results. listing: The listing over which to compute tail. Returns: Object name tails. c3>># UHo[T5Sv M g7fr/)r().0l start_points r# TailSet..\s G+Fas; !+Fs )r5stripsplit)rlistings` r#TailSetrJs'$ G7==?+@+@+F G GGr3 Credentialsaws_access_key_idaws_secret_access_keygs_service_key_filez.p12gs_hostgs_portrH prefer_apijsonXMLcJ[(a[R"U5$S$)NcU$r/r2funcs r#r>!SkipForP12Creds..rr3) HAS_P12_CREDSunittestskipreasons r#SkipForP12Credsrns] ==  r3c\Sn[(d SSKnUSL$USL$![a USL$f=f)Nr)r argcomplete ImportError)rs r#_ArgcompleteAvailablertsJ+   D  D     D   s  ++c\URSS5n[[RR U55n[ R "US5US'USRS5(a USSSUS'[RRU5nURSS5nU$)zNormalizes the path component of a URI. Args: uri: URI to normalize. Returns: Normalized URI. Examples: gs://foo//bar -> gs://foo/bar gs://foo/./bar -> gs://foo/bar zgs://zfile://z//rN) replacer)rparseurlparse posixpathnormpath startswith urlunparse)uriparsedunparseds r# _NormalizeURIrs& GY'#  %%c* +&  +&) AY$q !" F1I \\ $ $V ,(   i 1( /r3cUR(d"UR(dURS:XagUR=(d UR$)zReturns a the generation for a StorageUri. Args: uri: boto.storage_uri.StorageURI object to get the URI from. Returns: Generation string for the URI. s3null) generation version_idscheme)rs r#GenerationFromURIrs3 ..CNN zzT   )3>>)r3c[U5(aWSR[RR [RR "UR /UQ7655$[U[R5(a0SR[RR "U/UQ765$[R"UR5nU(aDUVs/sHn[R"U5PM nn[SR U/U-55nURS5(aUSSnU$s snf)aReturns the storage URI string for a given StorageUri or file object. Args: obj: The object to get the URI from. Can be a file object, a subclass of boto.storage_uri.StorageURI, or a string. If a string, it is assumed to be a local on-disk path. *suffixes: Suffixes to append. For example, ObjectToUri(bucketuri, 'foo') would return the URI for a key name 'foo' inside the given bucket. Returns: Storage URI string. z file://{}/Nr@)is_filerMr0pathabspathjoinnamerrT string_typesrrrendswith)rsuffixesrsuffix suffixes_lists r#rrs S\\   bggoobggll388/FSUS'SUl[[U]"U0UD6 g)Ngsproviderr)debugsuperr__init__)selfargskwargs __class__s r#rGSMockConnection.__init__s)F:DJ D*D;F;r3)r)rrrrrr __classcell__)rs@r#rrs <r3cg)NUSr2rrs r# get_location#GSMockBucketStorageUri.get_location r3cR[RRR5$r/)rJrcorsCorsrs r#get_corsGSMockBucketStorageUri.get_corss 77<<   r3cR[RRR5$r/)rJrencryptionconfigEncryptionConfigrs r#get_encryption_config,GSMockBucketStorageUri.get_encryption_configs 77 # # 4 4 66r3cgr/r2rs r#get_lifecycle_config+GSMockBucketStorageUri.get_lifecycle_configrr3cgr/r2rs r#get_website_config)GSMockBucketStorageUri.get_website_configrr3cgr/r2rs r#get_versioning_config,GSMockBucketStorageUri.get_versioning_configrr3r2)NNr/) rrrrr rrrr#r&r)r,rr2r3r#rrs*7r3rTestRemoveSectionc[RRXS5n[RRU5(d7UR U[ S45 [RR U5 UR XU45 Uc [RRX5 g[RRXU5 g)awSets boto configuration temporarily for testing. SetBotoConfigForTest should be called by tests instead of this function. This will ensure that the configuration is reverted to its original setting using _RevertBotoConfig. Args: section: Boto config section to set name: Boto config name to set value: Value to set revert_list: List for tracking configs to revert. N) rJrKget has_sectionappendTEST_BOTO_REMOVE_SECTION add_section remove_optionr5)sectionrvalue revert_list prev_values r#_SetBotoConfigr:s{{wd3*   ) )!94@AKKG$ gZ01 ]KKg,KKOOG5)r3c2/nUHgup#nUc>U[:XaURU5 M&[RR X#5 MG[RR X#U5 Mi UH"n[RR U5 M$ g)zReverts boto config modifications made by _SetBotoConfig. Args: revert_list: List of boto config modifications created by calls to _SetBotoConfig. N)r3r2rJrKr5r5remove_section)r8sections_to_remover6rr7s r#_RevertBotoConfigr>sw)gU } ) )!!'* !!'0 kkoogU+*$gKKw'$r3cF^[R"T5U4Sj5nU$)aPDecorator for tests that perform file to object transfers, or vice versa. This forces the test to run once normally, and again with special boto config settings that will ensure that the test follows the parallel composite upload and/or sliced object download code paths. Args: func: Function to wrap. Returns: Wrapped function. c>T"U0UD6 [(d/[5(a[/SQ5 T"U0UD6 SSS5 ggg!,(df  g=f)N))rH#parallel_composite_upload_threshold1)rH sliced_object_download_thresholdrB)rH%sliced_object_download_max_components3)rH check_hashesalways) RUN_S3_TESTSrSetBotoConfigForTest)rrrs r#Wrapper.SequentialAndParallelTransfer..Wrapper1sX $& <022 ! df   3<  s A A) functoolswraps)rrJs` r#SequentialAndParallelTransferrN#s' ??4   .r3cb0nUH&nUSUSUSpTnX1;a0X'UcMXQUU'M( U$)aConverts the input config list to a dict that is easy to write to a file. This is used to reset the boto config contents for a test instead of preserving the existing values. Args: boto_config_list: list of tuples of: (boto config section to set, boto config name to set, value to set) If value to set is None, no entry is created. Returns: Dictionary of {section: {keys: values}} for writing to the file. rrrr2)boto_config_listsections config_entryr6keyr7s r#_SectionDictFromConfigListrTCsR(&l'?LO\!_%Gh $w ' /r3c &[US5n[R"U5HQup4URSU-5 [R"U5HupVURU<SU<S35 M MS SSS5 g!,(df  g=f)zFWrites a section dict from _SectionDictFromConfigList to tmp_filename.wz[%s] z = rN)openrTrhwrite) section_dict tmp_filenametmp_filer6key_value_pairsrSr7s r#_WriteSectionDictToFiler]\sh L#($'MM,$? nnX'( o6*#c5127%@s A,B Bc#`# [S/5 Sv SSS5 g!,(df  g=f7f)zHSets a dummy project in boto config for the duration of a 'with' clause.)rHdefault_project_id dummy_projN)rIr2r3r#SetDummyProjectForUnitTestraes" KLM NMMs . . +.c#8# /nSn[R"SS9upC[R"U5 U(aUH[nUSn[R (a*[ U[5(aUR[5n[USUSUU5 M] [US5n[RRU5 SSS5 O[[!U5U5 [#U5 Sv SSS5 [%U5 U(a[R&"U5 gg!,(df  NQ=f!,(df  NJ=f![(a gf=f![%U5 U(a([R&"U5 f![(a ff=ff=f7f)a+Sets the input list of boto configs for the duration of a 'with' clause. This preserves any existing boto configuration unless it is overwritten in the provided boto_config_list. Args: boto_config_list: list of tuples of: (boto config section to set, boto config name to set, value to set) use_existing_config: If True, apply boto_config_list to the existing configuration, preserving any original values unless they are overwritten. Otherwise, apply boto_config_list to a blank configuration. Yields: Once after config is set. Nzgsutil-temp-cfg)prefixrrrrV)tempfilemkstempr0closerTrrrdecoderr:rWrJrKrXr]rT_SetBotoConfigFileForTestr>removeOSError)rPuse_existing_configrevert_configsrZtmp_fd boto_config boto_valuer[s r#rIrInsV"., #++3DEFHHV)+ ^ 77  E * *#**40J{1~{1~z% ' *  c "h (# # "89IJ*, #< 0  1n%  , # " 1 0   n%  ,    sFB E( D))E1D:6E>FE 'F) D73E: EE EFEFF/FF FFFFFc#^# U4Sjn0mUH%n[RRU5TU'M' U"U5 Sv U"T5 g!U"T5 f=f7f)z0Sets OS environment variables for a single test.c>[R"U5Hfup[RR U5TU'UbU[RU'M?U[R;dMU[RU Mh gr/)rTrhr0rdr0) dict_to_applyrprq old_valuess r#_ApplyDictToEnvironment6SetEnvironmentForTest.._ApplyDictToEnvironmentsV m,jjnnQ'jm  1  ? JJqM -r3N)r0rdr0)env_variable_dictrtrprss @r#SetEnvironmentForTestrwsT* aJJNN1%JqM (-. J'J's4A A  A AAc## [RSnSnU[RS'Sv U(aW[RS'g[RRSS5 g![a SnNbf=f!U(aW[RS'f[RRSS5 f=f7f)auSets a given file as the boto config file for a single test. This function applies only the configuration in boto_config_path and will ignore existing configuration. It should not be called directly by tests; instead, use SetBotoConfigForTest. Args: boto_config_path: Path to config file to use. Yields: When configuration has been applied, and again when reverted. BOTO_CONFIGTFN)r0rdrpop)boto_config_pathold_boto_config_env_variableboto_config_was_sets r#rhrhs #%::m#< /"**]* ">bjjjjnn]D)   ">bjjjjnn]D)s=B?A-B?A?.*)$r) rrpkgutil iter_modules gslib_tests__path__matchr2r )matchernames_modnamems r# GetTestNamesrsd JJ- .' %++K,@,@Ama! gAq ll1776?#B ,r3c[R(a[U[5$[U[R 5$r/)rTPY2rfileioIOBase)rs r#rrs'WW c4  C ##r3c[U[R[R45(a UR SS5R 5$[ SR[U555e)a Returns a copy of the given name with any invalid characters replaced. Args: name Union[str, unicode, bytes]: The bucket name to transform into a valid name. Returns: Union[str, unicode, bytes] The version of the bucket name containing only valid characters. r-z*Unable to format name. Incorrect Type: {0}) rrT text_type binary_typerlower TypeErrorrMtype)rs r#MakeBucketNameValidrsZs}}coo677 <<S ! ' ' )) @GG T  r3c#B# Sn[R"5nU(a[R"U5 Sv U(aU(a[R"U5 ggg![a NUf=f!U(aU(a[R"U5 fff=f7f)aChanges the working directory for the duration of a 'with' call. Args: new_working_directory: The directory to switch to before executing wrapped code. A None value indicates that no switching is necessary. Yields: Once after working directory has been changed. N)r0getcwdrjchdir)new_working_directoryprev_working_directorys r#WorkingDirectoryrs  YY[ HH "#' !7hh%&"8   !7hh%&"8s=BA$BA4'B$ A1.B0A11B4(BBcx[5RSS5nU(dgSURR;$)N __loader__F zipimport)globalsr0rr)loaders r#rPrPs1 9==t ,&   ((33 33r3cR[5(a[R"U5$S$)NcU$r/r2rs r#r> SkipForParFile..rr3)rPrrrs r#SkipForParFilers  ==  r3c$\rSrSrSrSrSrSrg)HaltingCopyCallbackHandleri#zFTest callback handler for intentionally stopping a resumable transfer.cXlX lgr/) _is_upload _halt_at_byte)r is_upload halt_at_bytes r#r#HaltingCopyCallbackHandler.__init__&s O%r3c XR:ao[RRSUR<S[ U5<S[ U5<S35 UR (a [ S5e[S5eg)a0Forcibly exits if the transfer has passed the halting point. Note that this function is only called when the conditions in gslib.progress_callback.ProgressCallbackWithTimeout.Progress are met, so self._halt_at_byte is only precise if it's divisible by gslib.progress_callback._START_BYTES_PER_CALLBACK. zHalting transfer after byte z. rz transferred. zArtifically halting upload.Artifically halting download.N)rrRr`rXrrr r )rtotal_bytes_transferred total_sizes r#callHaltingCopyCallbackHandler.call+sg"4"44 jj   01HI Z ( *+ &'DEE()HII5r3)rrNrrrrrrrrr2r3r#rr#sN& Jr3rc$\rSrSrSrSrSrSrg)#HaltOneComponentCopyCallbackHandleri>z=Test callback handler for stopping part of a sliced download.cSUlXlgr/)_last_progress_byter)rrs r#r,HaltOneComponentCopyCallbackHandler.__init__As#D%r3cURbNURURs=:aU:a-O O*[RR S5 [ S5eXlg)zCForcibly exits if the passed the halting point since the last call.NzHalting transfer. r)rrrRr`rXr )rcurrent_progress_bytetotal_size_unuseds r#r(HaltOneComponentCopyCallbackHandler.callGsM   ,   4#5#5M8MM jj./ &'F GG4r3)rrNrr2r3r#rr>sE& 5r3rc"\rSrSrSrSSjrSrg) TestParamsiPa_Allows easier organization of test parameters. This class allows grouping of test parameters, which include args and kwargs to be used, as well as the expected result based on those arguments. For example, to test an Add function, one might do: params = TestParams(args=(1, 2, 3), expected=6) self.assertEqual(Add(*(params.args)), params.expected) NcUc [5OUUlUc [5OUUlX0l[ U[[ 45(d [S5e[ UR[5(d [S5eg)Nz'TestParam args must be a tuple or list.z TestParam kwargs must be a dict.)tuplerrgrexpectedrr)r)rrrrs r#rTestParams.__init__\sd<TDI"N$&DKM dUDM * * ? @@ dkk4 ( ( 8 99 )r3)rrr)NNN)rrrrrrrr2r3r#rrPs  :r3rc$\rSrSrSrSrSrSrg) CaptureStdoutigzContext manager. For example, this function has the lines printed by the function call stored as a list in output: with CaptureStdout() as output: function(input_to_function) cd[RUl[5=[lUlU$r/)rRr__stdoutr _stringio)rs r# __enter__CaptureStdout.__enter__qs"::DL"++-CJ Kr3cURURR5R55 U?UR[ lgr/)extendrgetvalue splitlinesrrRr_)rrs r#__exit__CaptureStdout.__exit__vs4KK'')4467 CJr3)rrN)rrrrrrrrr2r3r#rrgs r3r)Fr/)T) __future__rrrr contextlibrrLrrr0rrrrryrjrRrdrrrT six.movesrr rJcrcmodrN gslib.kms_apir gslib.project_idr mock_storage_servicegslib.cloud_apir r gslib.lazy_wrapperr gslib.teststestsr gslib.utilsrgslib.utils.boto_utilrrgslib.utils.constantsrgslib.utils.encryption_helperrgslib.utils.system_utilrgslib.utils.unit_utilrrr:r$r-r&r'InitializeDefaultModeintSYSTEM_POSIX_MODE DEFAULT_MODEgetuidr<r6 INVALID_UID INVALID_GID USER_GROUPSr\rrrTEST_ENCRYPTION_KEY1TEST_ENCRYPTION_KEY1_SHA256_B64TEST_ENCRYPTION_KEY2TEST_ENCRYPTION_KEY2_SHA256_B64TEST_ENCRYPTION_KEY3TEST_ENCRYPTION_KEY3_SHA256_B64TEST_ENCRYPTION_KEY4TEST_ENCRYPTION_KEY4_SHA256_B64TEST_ENCRYPTION_KEY_S3TEST_ENCRYPTION_KEY_S3_MD5TEST_ENCRYPTION_CONTENT1TEST_ENCRYPTION_CONTENT1_MD5TEST_ENCRYPTION_CONTENT1_CRC32CTEST_ENCRYPTION_CONTENT2TEST_ENCRYPTION_CONTENT2_MD5TEST_ENCRYPTION_CONTENT2_CRC32CTEST_ENCRYPTION_CONTENT3TEST_ENCRYPTION_CONTENT3_MD5TEST_ENCRYPTION_CONTENT3_CRC32CTEST_ENCRYPTION_CONTENT4TEST_ENCRYPTION_CONTENT4_MD5TEST_ENCRYPTION_CONTENT4_CRC32CTEST_ENCRYPTION_CONTENT5TEST_ENCRYPTION_CONTENT5_MD5TEST_ENCRYPTION_CONTENT5_CRC32CRUN_INTEGRATION_TESTSRUN_UNIT_TESTSrHUSE_MULTIREGIONAL_BUCKETS%PARALLEL_COMPOSITE_UPLOAD_TEST_CONFIG ORPHANED_FILEPOSIX_MODE_ERRORPOSIX_GID_ERRORPOSIX_UID_ERRORPOSIX_INSUFFICIENT_ACCESS_ERRORobjectrrrrrrKr0 HAS_S3_CREDSrrHAS_NON_DEFAULT_GS_HOST HAS_GS_HOST HAS_GS_PORTupperUSING_JSON_APIrrARGCOMPLETE_AVAILABLErrrMockConnectionrr MockBucketStorageUrirr3r:r>rNrTr]rarIrwrhrrrrrPrrrrr)rr2r3r#rs '%'%      .64*!"N&M.3  38 AN ""$Z1115, IIK'?@)FH+ 34+34+P>1, LG"E#G"E#G"E#G"E#I8!9","9","9","9","9", !(P%( ;@@"PN&N.! 2 2"& 0H*  /BDIN  /FM   /DbIRRSYZ 02kkoomY=TI kkoomY=TI $ &''64JJ65&5$::.Dr3