OXIESEC PANEL

Name	Size	Modified	Perms
📁 ..	-	02/11/2025 08:19:48 AM	rwxr-xr-x
📄 __init__.cpython-39.pyc	2.94 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 __main__.cpython-39.pyc	20.78 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 boto_resumable_upload.cpython-39.pyc	14.86 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 boto_translation.cpython-39.pyc	47.41 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 bucket_listing_ref.cpython-39.pyc	4.23 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 cloud_api.cpython-39.pyc	41.26 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 cloud_api_delegator.cpython-39.pyc	21.69 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 command.cpython-39.pyc	63.61 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 command_argument.cpython-39.pyc	4.25 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 command_runner.cpython-39.pyc	15.75 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 context_config.cpython-39.pyc	6.98 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 cred_types.cpython-39.pyc	851 bytes	02/11/2025 08:19:49 AM	rw-r--r--
📄 cs_api_map.cpython-39.pyc	3.25 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 daisy_chain_wrapper.cpython-39.pyc	8.35 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 devshell_auth_plugin.cpython-39.pyc	1.24 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 discard_messages_queue.cpython-39.pyc	989 bytes	02/11/2025 08:19:49 AM	rw-r--r--
📄 exception.cpython-39.pyc	5.84 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 file_part.cpython-39.pyc	4.04 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 gcs_json_api.cpython-39.pyc	53.37 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 gcs_json_credentials.cpython-39.pyc	13.84 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 gcs_json_media.cpython-39.pyc	19.41 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 help_provider.cpython-39.pyc	2.36 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 iamcredentials_api.cpython-39.pyc	7.62 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 impersonation_credentials.cpython-39.pyc	1.79 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 kms_api.cpython-39.pyc	9.34 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 lazy_wrapper.cpython-39.pyc	2.27 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 metrics.cpython-39.pyc	26.95 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 metrics_tuple.cpython-39.pyc	491 bytes	02/11/2025 08:19:48 AM	rw-r--r--
📄 name_expansion.cpython-39.pyc	20.03 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 no_op_credentials.cpython-39.pyc	936 bytes	02/11/2025 08:19:49 AM	rw-r--r--
📄 parallel_tracker_file.cpython-39.pyc	8.89 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 plurality_checkable_iterator.cpython-39.pyc	3.2 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 progress_callback.cpython-39.pyc	4.35 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 project_id.cpython-39.pyc	841 bytes	02/11/2025 08:19:48 AM	rw-r--r--
📄 pubsub_api.cpython-39.pyc	7.69 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 resumable_streaming_upload.cpython-39.pyc	5.23 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 seek_ahead_thread.cpython-39.pyc	4.09 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 sig_handling.cpython-39.pyc	4.62 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 storage_url.cpython-39.pyc	16.48 KB	02/11/2025 08:19:48 AM	rw-r--r--
📄 tab_complete.cpython-39.pyc	10.35 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 thread_message.cpython-39.pyc	12.17 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 tracker_file.cpython-39.pyc	17.01 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 tz_utc.cpython-39.pyc	2.05 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 ui_controller.cpython-39.pyc	30.35 KB	02/11/2025 08:19:49 AM	rw-r--r--
📄 wildcard_iterator.cpython-39.pyc	23.94 KB	02/11/2025 08:19:48 AM	rw-r--r--

Editing: seek_ahead_thread.cpython-39.pyc

����+(Wgt����������������������@���s����d�Z�ddlmZ�ddlmZ�ddlmZ�ddlmZ�ddlZddlZddlm	Z	�ddl
mZ�dd	l
mZ�ej
ZG�d
d��de�ZG�dd
��d
ej�ZdS�)zIThreading code for estimating total work of long-running gsutil commands.�����)�absolute_import)�print_function)�division)�unicode_literalsN)�thread_message)�	constants)�parallelism_framework_utilc�������������������@���s���e�Zd�ZdZddd�ZdS�)�SeekAheadResultz�Result class for seek_ahead_iterator results.

A class is used instead of a namedtuple, making it easier to document
  and use default keyword arguments.
  ����r���c�����������������C���s���||�_�||�_dS�)a���Create a SeekAheadResult.

Args:
      est_num_ops: Number of operations the iterated result represents.
          Operation is loosely defined as a single API call for a single
          object. The total number of API calls may not be known at the time of
          iteration, so this number is approximate.
      data_bytes: Number of data bytes that will be transferred (uploaded,
          downloaded, or rewritten) for this iterated result.
    N)�est_num_ops�
data_bytes)�selfr���r�����r����&/opt/gsutil/gslib/seek_ahead_thread.py�__init__'���s����zSeekAheadResult.__init__N)r
���r���)�__name__�
__module__�__qualname__�__doc__r���r���r���r���r���r	��� ���s���r	���c�����������������������s(���e�Zd�ZdZ��fdd�Zdd��Z���ZS�)�SeekAheadThreada���Thread to estimate total work to be performed by all processes and threads.

Because the ProducerThread can only buffer a certain number of tasks on the
  global task queue, it cannot reliably provide the total count or size of
  iterated results for operations involving many iterated arguments until it
  nears the end of iteration.

This thread consumes an iterator that should be functionally identical
  to the ProducerThread, but iterates to the end without adding tasks to the
  global task queue in an effort to estimate the amount of total work that the
  call to Apply will perform. It should be used only for large operations, and
  thus it is created by the main ProducerThread only when the number of
  iterated arguments exceeds a threshold.

This thread may produce an inaccurate estimate if its iterator produces
  different results than the iterator used by the ProducerThread. This can
  happen due to eventual listing consistency or due to the source being
  modified as iteration occurs.

This thread estimates operations for top-level objects only;
  sub-operations (such as a parallel composite upload) should be reported via
  the iterator as a single object including the total number of bytes affected.
  c��������������������s2���t�t|������||�_||�_||�_d|�_|�����dS�)ay��Initializes the seek ahead thread.

Args:
      seek_ahead_iterator: Iterator matching the ProducerThread's args_iterator,
          but returning only object name and/or size in the result.
      cancel_event: threading.Event for signaling the
          seek-ahead iterator to terminate.
      status_queue: Status queue for posting summary of fully iterated results.
    FN)�superr���r����status_queue�seek_ahead_iterator�cancel_event�	terminate�start)r
���r���r���r�����	__class__r���r���r���O���s����
zSeekAheadThread.__init__c��������������
���C���s����d}d}zR|�j�D�]F}|�jr"�W�d�S�|tj�dkrB|�j���rB�W�d�S�||j7�}||j7�}qW�n&�ty��}�zW�Y�d�}~d�S�d�}~0�0�|�j���r�d�S�t	|�j
t�||t
�
�����d�S�)Nr���)r���r���r����NUM_OBJECTS_PER_LIST_PAGEr����isSetr���r����OSError�_PutToQueueWithTimeoutr���r����SeekAheadMessage�time)r
����num_objectsZnum_data_bytesZseek_ahead_result�er���r���r����runb���s*����

��zSeekAheadThread.run)r���r���r���r���r���r&����
__classcell__r���r���r���r���r���6���s���r���)r����
__future__r���r���r���r����	threadingr#����gslibr����gslib.utilsr���r����PutToQueueWithTimeoutr!����objectr	����Threadr���r���r���r���r����<module>���s���