dSrSSKJr SSKJr SSKJr SSKrSSKJr "SS5rS r S S jr g) z8Messages parallel workers might send to the main thread.)absolute_import)division)unicode_literalsN)thread_messagesc8\rSrSrSrSSjrSSjrSrg) FilesAndBytesProgressCallbacka Tracks file count and bytes progress info for large file operations. Information is sent to the status_queue, which will print aggregate it for printing to the user. Useful for heavy operations like copy or hash. Arguments similar to thread_messages.ProgressMessage. Nc |XlX lX0lX@lXPlX`lXplXlXlXl g)aeInitializes callback, saving non-changing variables. Args: status_queue (multiprocessing.Queue): Where to submit progress messages. If we spawn new worker processes, they will lose their reference to the correct version of this queue if we don't package it here. offset (int): Start of byte range to start operation at. length (int): Total size of file or component in bytes. source_url (StorageUrl): Represents source of data used by operation. destination_url (StorageUrl|None): Represents destination of data used by operation. None for unary operations like hashing. component_number (int|None): If a multipart operation, indicates the component number. total_components (int|None): If a multipart operation, indicates the total number of components. operation_name (task_status.OperationName|None): Name of the operation running on target data. process_id (int|None): Identifies process that produced the instance of this message (overridable for testing). thread_id (int|None): Identifies thread that produced the instance of this message (overridable for testing). N) _status_queue_offset_length _source_url_destination_url_component_number_total_components_operation_name _process_id _thread_id) self status_queueoffsetlength source_urldestination_urlcomponent_numbertotal_componentsoperation_name process_id thread_ids B&LL!+--)!OcTA[R"5nURR[R"UR UR UUURURURURURUURURS9 5 g)zSends operation progress information to global status queue. Args: current_byte (int): Index of byte being operated on. error_occurred (bool): Whether an error occurred during the operation. *args (list[any]): Unused. ) rr current_bytetimerrrrrerror_occurredrrN)r&r putrDetailedProgressMessager r rrrrrrr)rr%r'args current_times r __call__&FilesAndBytesProgressCallback.__call__Ns 99;L//<<<<%'' 11!33!33//)''oo ' (r#) rrr r rrrr rr)NNNNNN)F)__name__ __module__ __qualname____firstlineno____doc__r!r,__static_attributes__r#r rrs& $ $ $"* X(r#rcLUR[R"55 gN)r(rIncrementProgressMessage)rs r increment_count_callbackr8ks?;;=>r#cJUR[R"XS95 g)aTracks expected item count and bytes for large operations. Information is sent to the status_queue, which will aggregate it for printing to the user. Useful for heavy operations like copy. For example, this sets the "100" in "copied 5/100 files." Arguments similar to thread_messages.WorkloadEstimatorMessage. Args: status_queue (multiprocessing.Queue): Reference to global queue. item_count (int): Number of items to add to workload estimation. size (int|None): Number of bytes to add to workload estimation. ) item_countsizeN)r(rWorkloadEstimatorMessage)rr:r;s r workload_estimator_callbackr=os#..,-r#r6) r2 __future__rrrr&"googlecloudsdk.command_lib.storagerrr8r=r4r#r r@s0?&' >N(N(b?-r#