CURRENT PATH:
/
opt
/
gsutil
/
gslib
/
__pycache__
/
[ ⬅ KEMBALI ]
|
[ HOME ]
Upload File:
Upload Ke Sini
Dir Baru
File Baru
Editing:
progress_callback.cpython-39.pyc
a +(WgQ � @ s� d Z ddlmZ ddlmZ ddlmZ ddlmZ ddlZddlmZ ddl m Z d Z d Z d Z d ZG d d� de�ZG dd� de�ZdS )z(Helper functions for progress callbacks.� )�absolute_import)�print_function)�division)�unicode_literalsN)�ProgressMessage)�parallelism_framework_utili i @� �A c @ s& e Zd ZdZeefdd�Zdd� ZdS )�ProgressCallbackWithTimeoutz�Makes progress callbacks at least once every _TIMEOUT_SECONDS. This prevents wrong throughput calculation while not being excessively overwhelming. c C s8 || _ || _|| _t�� | _|| _d| _d| _d| _dS )a� Initializes 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. r N) �_bytes_per_callback�_callback_func� _total_size�time� _last_time�_timeout� _bytes_processed_since_callback�_callbacks_made�_total_bytes_processed)�self� total_sizeZ callback_funcZstart_bytes_per_callback�timeout� r �&/opt/gsutil/gslib/progress_callback.py�__init__, s z$ProgressCallbackWithTimeout.__init__c C s� | j |7 _ t�� }| j | jksN| jdur>| j| j | jksN| j| | jkr�| j| j 7 _| jdurxt| j| j�}n| j}| �|| j� d| _ | j d7 _ || _dS )z@Tracks byte processing progress, making a callback if necessary.Nr r ) r r r r r r r �minr r )r Zbytes_processedZcur_timeZ bytes_sentr r r �ProgressE s* ����� z$ProgressCallbackWithTimeout.ProgressN)�__name__� __module__� __qualname__�__doc__�_START_BYTES_PER_CALLBACK�_TIMEOUT_SECONDSr r r r r r r % s � r c @ s" e Zd ZdZddd�Zdd� ZdS ) �FileProgressCallbackHandlerz�Tracks 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. r Nc C s4 || _ || _|| _|| _|| _|| _|| _d| _dS )aC Initializes 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_byteZoverride_total_size�src_url� component_num�dst_url�operation_namer r r r c s z$FileProgressCallbackHandler.__init__c C sd | j r dS | jr| j}t�| jt||| j | jt�� | j | j | j d�� |r`|| j |kr`d| _ dS )a� Gathers 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)r. r0 r/ T) r* r% r �PutToQueueWithTimeoutr# r r$ r' r r& r) r( )r Zlast_byte_processedr r r r �call� s" �� z FileProgressCallbackHandler.call)r NNNNN)r r r r r r2 r r r r r" \ s � r" )r � __future__r r r r r Zgslib.thread_messager � gslib.utilsr r Z_MAX_BYTES_PER_CALLBACKr! Z MAX_PROGRESS_INDICATOR_COLUMNS�objectr r" r r r r �<module> s 7
SIMPAN
[ BATAL ]