+SrSSKJr SSKJr SSKJr SSKJr SSKrSSKrSSKrSSK r SSK r SSK J r SSK Jr SS K Jr SS K Jr SS KJr SS KJr SS KJr SrSrSR15r"SS\5r"SS\5r"SS\5r"SS\5r"SS\R>5r "SS\!5r""SS\5r#"SS \5r$"S!S"\5r%S#r&S$r'g)%zShell tab completion.)absolute_import)print_function)division)unicode_literalsN)CannedACLStrings)IsFileUrlString)StorageUrlFromString) StripOneSlash)GetTabCompletionCacheFilename)GetTabCompletionLogFilename)CreateWildcardIteratoriz Tab completion aborted (took >%ss), you may complete the command manually. The timeout can be adjusted in the gsutil configuration file. c,\rSrSrSrSrSrSrSrSr Sr g ) CompleterType/ cloud_bucket cloud_objectcloud_or_local_object local_objectlocal_object_or_canned_aclno_opN) __name__ __module__ __qualname____firstlineno__ CLOUD_BUCKET CLOUD_OBJECTCLOUD_OR_LOCAL_OBJECT LOCAL_OBJECTLOCAL_OBJECT_OR_CANNED_ACLNO_OP__static_attributes__r%platform/gsutil/gslib/tab_complete.pyrr/s",,1,; %r$rc$\rSrSrSrSrSrSrg)LocalObjectCompleter8z!Completer object for local files.c(SSKJn U"5Ulg)Nr)FilesCompleter)argcomplete.completersr*files_completer)selfr*s r%__init__LocalObjectCompleter.__init__;s6)+Dr$c (UR"U40UD6$Nr,)r-prefixkwargss r%__call__LocalObjectCompleter.__call__Bs    1& 11r$r2Nrrrr__doc__r.r5r#rr$r%r'r'8s),2r$r'c$\rSrSrSrSrSrSrg)LocalObjectOrCannedACLCompleterFzxCompleter object for local files and canned ACLs. Currently, only Google Cloud Storage canned ACL names are supported. c"[5Ulgr1)r'local_object_completer)r-s r%r.(LocalObjectOrCannedACLCompleter.__init__Ls "6"8Dr$c UR"U40UD6n[Vs/sHoDRU5(dMUPM nnX5-$s snfr1)r=r startswith)r-r3r4 local_objectsacl canned_aclss r%r5(LocalObjectOrCannedACLCompleter.__call__OsE//A&AM"2M"23nnV6L3"2KM  &&Ns AA)r=Nr7rr$r%r:r:Fs 9'r$r:c@\rSrSrSrSr\S5rSrSr Sr Sr g ) TabCompletionCacheUz!Cache for tab completion results.c4XlX lX0lX@lgr1)r3results timestamppartial_results)r-r3rIrJrKs r%r.TabCompletionCache.__init__XsKLN*r$c [US5n[R"UR55nUSnUSnUSnUSnSSS5 [ WWWW5$!,(df  N=f![a Sn/nSnSnN3f=f) zInstantiates the cache from a file. Args: filename: The file to load. Returns: TabCompletionCache instance with loaded data or an empty cache if the file cannot be loaded rr3rIrJpartial-resultsNrF)openjsonloadsread ExceptionrF)filenamefp cache_dictr3rIrJrKs r% LoadFromFileTabCompletionCache.LoadFromFile^s # "ZZ * H%Y'{+ $%67  fgy/ JJ   fgios. A.9AA. A+'A.+A..BBc[R"5nX R- [:agSnXR:Xa URnOUR (dUR UR5(aaURS5URRS5:Xa3URVs/sHoDR U5(dMUPM nnUb[R"5UlU$gs snf)z>Returns the cached results for prefix or None if not in cache.N/)timerJTAB_COMPLETE_CACHE_TTLr3rIrKr@count)r-r3 current_timerIxs r%GetCachedResults#TabCompletionCache.GetCachedResultszs99;Lnn$(>> G  g""v'8'8'E'E ,,s t{{005 5 LLALqLL,@LgA yy{dn n Bs 8C=C=c\XlX lX0l[R"5Ulg)zBUpdates the in-memory cache with the results for the given prefix.N)r3rIrKr\rJ)r-r3rIrKs r% UpdateCacheTabCompletionCache.UpdateCachesKL*YY[DNr$c[R"URURURUR S.5n[ US5nURU5 SSS5 g!,(df  g=f![a gf=f)z'Writes out the cache to the given file.)r3rIrOrJwN) rQdumpsr3rIrKrJrPwriteIOError)r-rUjson_strrVs r% WriteToFileTabCompletionCache.WriteToFilesmzz++<<//^^ H # "        s0 A=A,#A=, A:6A=:A== B  B )rKr3rIrJN) rrrrr8r. staticmethodrXrardrlr#rr$r%rFrFUs/)+ KK6,!  r$rFc2^\rSrSrSrU4SjrSrSrU=r$)CloudListingRequestThreadz@Thread that performs a listing request for the given URL string.c^>[[U] 5 SUlXlX lSUlg)zInstantiates Cloud listing request thread. Args: wildcard_url_str: The URL to list. gsutil_api: gsutil Cloud API instance to use. TN)superrpr.daemon_wildcard_url_str _gsutil_apirI)r-wildcard_url_str gsutil_api __class__s r%r."CloudListingRequestThread.__init__s- #T35DK-!DLr$c[URUR5RS/S9n[R "U[ 5Vs/sHn[U5PM snUlgs snf)Nname)bucket_listing_fields) r rurvIterAll itertoolsislice_TAB_COMPLETE_MAX_RESULTSstrrI)r-itcs r%runCloudListingRequestThread.runsd    !''A"((-FGG1AGDLs A*)rvrurtrI) rrrrr8r.rr# __classcell__)rys@r%rprpsH r$rpc\rSrSrSrg) TimeoutErrorrN)rrrrr#rr$r%rrsr$rc.\rSrSrSrSSjrSrSrSrg) CloudObjectCompleterz Completer object for Cloud URLs.cXlX lg)zInstantiates completer for Cloud URLs. Args: gsutil_api: gsutil Cloud API instance to use. bucket_only: Whether the completer should only match buckets. N)rv _bucket_only)r-rx bucket_onlys r%r.CloudObjectCompleter.__init__s"#r$c[XR5nUR5 URU5 UR 5(a&SSKnUR [U-5 [5eURnU$)aPerform a remote listing request for the given wildcard URL. Args: wildcard_url: The wildcard URL to list. timeout: Time limit for the request. Returns: Cloud resources matching the given wildcard URL. Raises: TimeoutError: If the listing does not finish within the timeout. rN) rprvstartjoinis_alive argcompletewarn_TIMEOUT_WARNINGrrI)r- wildcard_urltimeoutrequest_threadrrIs r%_PerformCloudListing)CloudObjectCompleter._PerformCloudListingsn/|=M=MNN   ''12 N$$G Nr$c .U(dSnO[U5(a/$US-n[U5nUR(aUR5(d/$[R R SSS5nUS:Xa/$[R"5n[R[55nURU5nSn UbUn Sn OeURX55n UR(a[U 5S :Xa[U S5/n [U 5[:Hn UR!XU 5 UR%[55 [R"5n [U 5n X- n['S XUX- U4-5 U $!["a S n /n Ncf=f) Nzgs://*GSUtiltab_completion_timeoutrz (from cache)z (request timeout)z:%s results%s in %.2fs, %.2f results/second for prefix: %s )rr rIsBucketbotoconfiggetintr\rFrXr rarlenr rrdrrl_WriteTimingLog)r-r3r4rurlr start_timecachecached_resultstiming_log_entry_typerIrKend_time num_resultselapsed_secondss r%r5CloudObjectCompleter.__call__s~ f  iCrs&%'  (-2+?=:  FH F 26 2 'f 'O O d 0 029U6Up'&'&FB6r$