QSrSSKJr SSKJr SSKJr SSKJr SSKrSSKJr SSK J r S r S r S r S r"S S\5r"SS\5rg)z(Helper functions for progress callbacks.)absolute_import)print_function)division)unicode_literalsN)ProgressMessage)parallelism_framework_utilii@Ac,\rSrSrSr\\4SjrSrSr g)ProgressCallbackWithTimeout%zMakes progress callbacks at least once every _TIMEOUT_SECONDS. This prevents wrong throughput calculation while not being excessively overwhelming. cX0lX lXl[R"5UlX@lSUlSUlSUlg)afInitializes the callback with timeout. Args: total_size: Total bytes to process. If this is None, size is not known at the outset. callback_func: Func of (int: processed_so_far, int: total_bytes) used to make callbacks. start_bytes_per_callback: Lower bound of bytes per callback. timeout: Number maximum of seconds without a callback. rN) _bytes_per_callback_callback_func _total_sizetime _last_time_timeout_bytes_processed_since_callback_callbacks_made_total_bytes_processed)self total_size callback_funcstart_bytes_per_callbacktimeouts *platform/gsutil/gslib/progress_callback.py__init__$ProgressCallbackWithTimeout.__init__,s@ 8'!iikDOM+,D(D"#Dc\U=RU- sl[R"5nURUR:dQURb'URUR-UR:dUR U- UR :aU=RUR- slURb![URUR5nO URnURX0R5 SUlU=RS- sl X lgg)z@Tracks byte processing progress, making a callback if necessary.Nrr ) rrrrrrrminrr)rbytes_processedcur_time bytes_sents rProgress$ProgressCallbackWithTimeout.ProgressEs((O;(yy{H ,,t/G/GG   %$*E*E - -+.151A1A+B 8 #t}}4 !!T%I%II!    %44d6F6FG 00  *&6&67-.d* a o 5r )rrrrrrrrN) __name__ __module__ __qualname____firstlineno____doc___START_BYTES_PER_CALLBACK_TIMEOUT_SECONDSrr&__static_attributes__r rr r %s)B' $2!r r c4\rSrSrSrSSjrSrSrg)FileProgressCallbackHandler\zTracks progress info for large operations like file copy or hash. Information is sent to the status_queue, which will print it in the UI Thread. NcfXlX lX0lXPlX@lX`lXplSUlg)aInitializes the callback handler. Args: status_queue: Queue for posting status messages for UI display. start_byte: The beginning of the file component, if one is being used. override_total_size: The size of the file component, if one is being used. src_url: FileUrl/CloudUrl representing the source file. component_num: Indicates the component number, if any. dst_url: FileUrl/CloudUrl representing the destination file, or None for unary operations like hashing. operation_name: String representing the operation name FN) _status_queue _start_byte_override_total_size_component_num_src_url_dst_url_operation_name_last_byte_written)r status_queue start_byteoverride_total_sizesrc_url component_numdst_urloperation_names rr$FileProgressCallbackHandler.__init__cs4(&! 3'MM)#Dr c UR(agUR(a URn[R"UR[ UXR - UR[R"5URURURS95 U(aXR - U:XaSUlggg)atGathers information describing the operation progress. Actual message is printed to stderr by UIThread. Args: last_byte_processed: The last byte processed in the file. For file components, this number should be in the range [start_byte:start_byte + override_total_size]. total_size: Total size of the ongoing operation. N)rArCrBT) r<r7rPutToQueueWithTimeoutr5rr6r9rr8r;r:)rlast_byte_processedrs rcall FileProgressCallbackHandler.calls     ,,j44  +.>.>>  &*&9&9'+';'; $  /0),<,<< J $dKzr )r8r:r<r;r7r9r6r5)rNNNNN)r(r)r*r+r,rrHr/r0r rr2r2\s%#'!"$>%r r2)r, __future__rrrrrgslib.thread_messager gslib.utilsrr-_MAX_BYTES_PER_CALLBACKr.MAX_PROGRESS_INDICATOR_COLUMNSobjectr r2r0r rrPsV/&%' 02'+"$4!&4!nD%&D%r