File manager - Edit - /opt/gsutil/gslib/tests/__pycache__/util.cpython-39.pyc
Back
a +(Wg t � @ s� d dl mZ d dl mZ d dl mZ d dl mZ d dlmZ d dlZd dlZd dl Z d dl Z d dl Z d dl Z d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d dlmZ d dlZd dlZd dlZd d l m Z d d l m Z d dl Z d d l!m"Z" d d l!m#Z# d d l$m%Z% d dl&m'Z( d dl)m*Z* d dl+m,Z,m-Z- d dl.m/Z/ d dl0m1Z1 d dl2m3Z3 d dl4m5Z5 e3�sd dl6Z6d dl7Z7dd� Z8dd� Z9dd� Z:dd� Z;e*�<� e=e*j>d �Z?e �@� ZAe%d d � �ZBe%d d � �ZCe%d d � �ZDe%d!d � �ZEd�d#d$�ZFd�d%d&�ZGd�d'd(�ZHd)ZIe1eI�ZJd*ZKe1eK�ZLd+ZMe1eM�ZNd,ZOe1eO�ZPd-ZQd.ZRd/ZSd0ZTd1ZUd2ZVd3ZWd4ZXd5ZYd6ZZd7Z[d8Z\d9Z]d:Z^d;Z_d<Z`d=Zad>Zbd>Zcd"Zdd"Zed?Zfd@ZgdAZhdBZidCZjdDZkG dEdF� dFel�ZmemjnfdGdH�ZodIdJ� ZpdKdL� Zqejr�sdMdNd��o ejr�sdMdOd�Ztejr�sdMdPdQ��udR�Zve-� Zwejr�sdMdSd�duZxejr�sdMdTd�duZyejr�sdUdVdW��z� dXkZ{dYdZ� Z|d[d\� Z}e}� Z~d]d^� Zd_d`� Z�dadb� Z�G dcdd� dde j��Z�e�� Z�G dedf� dfe j��Z�dgZ�dhdi� Z�djdk� Z�dldm� Z�dndo� Z�dpdq� Z�edrds� �Z�ed�dtdu��Z�edvdw� �Z�edxdy� �Z�dzd{� Z�d|d}� Z�d~d� Z�ed�d�� �Z�d�d�� Z�d�d�� Z�G d�d�� d�el�Z�G d�d�� d�el�Z�G d�d�� d�el�Z�G d�d�� d�e��Z�dS )�� )�absolute_import)�print_function)�division)�unicode_literals)�contextmanagerN)�urllib)� cStringIO)�KmsApi)�PopulateProjectId)�ResumableDownloadException)�ResumableUploadException)� LazyWrapper)� posix_util)�UsingCrcmodExtension�HasUserSpecifiedGsHost)�UTF8)�#Base64Sha256FromBase64EncryptionKey)� IS_WINDOWS)�MakeHumanReadablec C s� t dd� t�� D ��} d}|dk rx|| v r4|d7 }qzt�|� |d7 }W q ty` | Y S tyt Y qxY q0 qtd��d S )Nc S s g | ] }|j �qS � )�gr_gid)�.0�groupr r � /opt/gsutil/gslib/tests/util.py� <listcomp>B � z!GetInvalidGid.<locals>.<listcomp>i� l r T � zUnable to generate GID for )�sorted�grp�getgrall�getgrgid�KeyError� OverflowError� Exception)Zall_gid�gidr r r � GetInvalidGid@ s r% c s6 t � � t� } t| �dkr � S � fdd�t| �D �d S )Nr c s g | ]}|� kr|�qS r r �r �g�Z primary_gidr r r g r z$GetNonPrimaryGid.<locals>.<listcomp>r )� GetPrimaryGid� GetUserGroups�len�list)Z user_groupsr r( r �GetNonPrimaryGid\ s r- c C s t �� S �N)�os�getgidr r r r r) i s r) c C s t t� gdd� t�� D � �S )Nc S s g | ]}t � |jv r|j�qS r )� USER_NAME�gr_memr r& r r r r n r z!GetUserGroups.<locals>.<listcomp>)�setr) r r r r r r r* l s �r* � c C s t �t�jS r. )�pwd�getpwuid�USER_ID�pw_namer r r r �<lambda>s r r9 c C s t dd� t�� D ��d d S )Nc S s g | ] }|j �qS r )�pw_uid)r �userr r r r x r z <lambda>.<locals>.<listcomp>���r )r r5 �getpwallr r r r r9 x r c C s t � S r. )r% r r r r r9 } r c C s t � S r. )r* r r r r r9 � r Fc C sr |r d}nt j�ddd�}dd�|�ddg}tjdddt� g| | }t� s`tt j �g| }n|}d d � |D �S ) zFAdds config options to a list of strings defining a gsutil subcommand.F�GSUtil�use_gcloud_storagez-oz GSUtil:use_gcloud_storage={}z#GSUtil:hidden_shim_mode=no_fallbackz--testexceptiontraceszGSUtil:default_project_id=c S s g | ]}t �|��qS r )�six� ensure_str)r �partr r r r � r z$GetGsutilCommand.<locals>.<listcomp>) �boto�config�getbool�format�gslib� GSUTIL_PATHr �InvokedFromParFile�str�sys� executable)Z raw_command� force_gsutilr? Zgcloud_storage_settingZgsutil_commandZ#gsutil_command_with_executable_pathr r r �GetGsutilCommand� s* �����rN c C sv t j�� }|r|�|� t� }t�|�D ] \}}t�|�|t�|�< q(tt d�rVt j nd}t j | t j t j t j ||d�S )zCReturns a subprocess.Popen object for for running a gsutil command.�setsidN)�stdout�stderr�stdin�env� preexec_fn) r/ �environ�copy�update�dictr@ � iteritemsrA �hasattrrO � subprocess�Popen�PIPE)�cmd�env_varsrS �envstr�k�vrT r r r �GetGsutilSubprocess� s �rc c s� |d ur.t jr$t|t�s.|�t�}n |�t�}d|i}� fdd�}t jrRd|d< nt�d|�}|�� � j f i |��}t js�|� � zdd� |D �}W n t y� dd� |D �}Y n0 |S ) N�inputc s t �t �� j�tj� d S r. )r/ �killpg�getpgid�pid�signal�SIGKILLr ��processr r �Kill� s z$CommunicateWithTimeout.<locals>.Kill� �timeoutc S s g | ]}t �|��qS r �r@ � ensure_text�r �outputr r r r � r z*CommunicateWithTimeout.<locals>.<listcomp>c S s g | ]}t �|t�d ���qS )F)r@ rp �locale�getpreferredencodingrq r r r r � s �) r@ �PY3� isinstance�bytes�encoder � threading�Timer�start� communicate�cancel�UnicodeDecodeError)rk rR Z comm_kwargsrl �timerZc_outr rj r �CommunicateWithTimeout� s* � r� s, iMSM9eeXliDZHSBJZO71R98tfeW/+87VXTpk5chGd6Y=s, 4TSaQ3S4U+5oxAbByA7HgIigD51zfzGed/c03Ts2TXc=s, HO4Q2X28N/6SmuAJ1v1CTuJjf5emQcXf7YriKzT1gj0=s, U6zIErjZCK/IpIeDS0pJrDayqlZurY8M9dvPJU0SXI8=s, MTIzNDU2Nzg5MDEyMzQ1Njc4OTAxMjM0NTY3ODkwMTI=s dnF5x6K/8ZZRzpfSlMMM+w==s barzN7UdGUp1E+RbVvZSTy1R8g==zCrcTMQ==s bar2zIk4lOfUiA+szcorNIotEMg==zQScXtg==s bar3z9iW6smjfu9hm0A//VQTQfw==zs0yUtQ==s bar4zkPCx6uZiUOU7W6E+cDCZFg==zZ4bwXg==s bar5z758XbXQOVkp8fTKMm83NXA==zle1zXQ==Tz&/tmp/.boto.parallel_upload_test_configzPThis sync will orphan file(s), please fix their permissions before trying again.z$Mode for %s won't allow read access.z+GID for %s doesn't exist on current system.z+UID for %s doesn't exist on current system.z,Insufficient access with uid/gid/mode for %sc @ s( e Zd ZdZdZdZdZdZdZdZ dS ) �KmsTestingResourceszCConstants for KMS resource names to be used in integration testing.z us-central1z$keyring-for-gsutil-integration-testsz key-for-gsutil-integration-testsz!key-for-gsutil-integration-tests2zkey-for-gsutil-no-authz-cryptokey-for-gsutil-integration-tests-%d%d%dN) �__name__� __module__� __qualname__�__doc__�KEYRING_LOCATION� KEYRING_NAME�CONSTANT_KEY_NAMEZCONSTANT_KEY_NAME2Z"CONSTANT_KEY_NAME_DO_NOT_AUTHORIZEZMUTABLE_KEY_NAME_TEMPLATEr r r r r� s r� c C sX t t�� �}|jtd�tjtjd�}|�|| �}t ddd|gdd�}t |�}t |� |S )zAEnsures test keys exist and that the service agent is authorized.N)�location�kms� authorizez-kT)rM ) r �logging� getLogger� CreateKeyRingr r� r� r� �CreateCryptoKeyrN rc r� )�key_name�kms_apiZ keyring_fully_qualified_nameZkey_fully_qualified_namer^ rk r r r �"AuthorizeProjectToUseTestingKmsKey) s �� �r� c C s t �|t| � �S )a Builds a regex to match a file name for a file that would be orphaned. Args: obj: Object uri. err_str: The error string to search for. Returns: A regex that will match the file name and with the error text for a file that would be orphaned. )�re�compile� ObjectToURI)�objZerr_strr r r �BuildErrorRegex< s r� c s t � fdd�|�� �d�D ��S )a� Returns set of object name tails. Tails can be compared between source and dest, past the point at which the command was done. For example if test ran {cp,mv,rsync} gs://bucket1/dir gs://bucket2/dir2, the tails for listings from bucket1 would start after "dir", while the tails for listings from bucket2 would start after "dir2". Args: start_point: The target of the cp command, e.g., for the above command it would be gs://bucket1/dir for the bucket1 listing results and gs://bucket2/dir2 for the bucket2 listing results. listing: The listing over which to compute tail. Returns: Object name tails. c 3 s | ]}|t � �d � V qd S r. )r+ )r �l�� start_pointr r � <genexpr>\ r zTailSet.<locals>.<genexpr>� )r3 �strip�split)r� �listingr r� r �TailSetJ s r� � Credentials�aws_access_key_id�aws_secret_access_key�gs_service_key_file� z.p12�gs_host�gs_portr> � prefer_api�json�XMLc C s t rt�| �S dd� S d S )Nc S s | S r. r ��funcr r r r9 r r z!SkipForP12Creds.<locals>.<lambda>)� HAS_P12_CREDS�unittest�skip��reasonr r r �SkipForP12Credsn s r� c C s0 d } t s(z dd l} W n ty& Y n0 | d uS )Nr )r � argcomplete� ImportError)r� r r r �_ArgcompleteAvailablet s r� c C sl | � dd�} ttj�| ��}t�|d �|d< |d �d�rP|d dd� |d< tj�|�}|� dd�}|S )z�Normalizes the path component of a URI. Args: uri: URI to normalize. Returns: Normalized URI. Examples: gs://foo//bar -> gs://foo/bar gs://foo/./bar -> gs://foo/bar zgs://zfile://� z//r N) �replacer, r �parse�urlparse� posixpath�normpath� startswith� urlunparse)�uri�parsedZunparsedr r r � _NormalizeURI� s r� c C s& | j s| js| jdkrdS | j p$| jS )z�Returns a the generation for a StorageUri. Args: uri: boto.storage_uri.StorageURI object to get the URI from. Returns: Generation string for the URI. �s3�null)� generation� version_id�scheme)r� r r r �GenerationFromURI� s r� c G s� t | �r,d�tj�tjj| jg|�R � ��S t| tj �rRd�tjj| g|�R � �S t� | j �}|r�dd� |D �}t d�|g| ��}|� d�r�|dd� }|S )a� Returns the storage URI string for a given StorageUri or file object. Args: obj: The object to get the URI from. Can be a file object, a subclass of boto.storage_uri.StorageURI, or a string. If a string, it is assumed to be a local on-disk path. *suffixes: Suffixes to append. For example, ObjectToUri(bucketuri, 'foo') would return the URI for a key name 'foo' inside the given bucket. Returns: Storage URI string. z file://{}c S s g | ]}t �|��qS r ro )r �suffixr r r r � r z ObjectToURI.<locals>.<listcomp>�/Nr< )�is_filerF r/ �path�abspath�join�namerv r@ � string_typesrp r� r� �endswith)r� �suffixesr� Z suffixes_listr r r r� � s � r� c s e Zd Z� fdd�Z� ZS )�GSMockConnectionc s( d|d< d| _ tt| �j|i |�� d S )N�gs�providerr )�debug�superr� �__init__)�self�args�kwargs�� __class__r r r� � s zGSMockConnection.__init__)r� r� r� r� � __classcell__r r r� r r� � s r� c @ s\ e Zd Zddd�Zddd�Zddd�Zddd �Zdd d �Zdd d �Zddd�Z ddd�Z dS )�GSMockBucketStorageUriNc C s t S r. )�mock_connection)r� � access_key_id�secret_access_keyr r r �connect� s z GSMockBucketStorageUri.connectc C s | � � S )z:Dummy implementation to allow parallel uploads with tests.)�new_key)r� � components�headersr r r �compose� s z GSMockBucketStorageUri.composec C s dS )N�USr �r� r� r r r � get_location� s z#GSMockBucketStorageUri.get_locationc C s t jj�� S r. )rC r� �cors�Corsr� r r r �get_cors� s z GSMockBucketStorageUri.get_corsc C s t jj�� S r. )rC r� �encryptionconfig�EncryptionConfigr� r r r �get_encryption_config� s z,GSMockBucketStorageUri.get_encryption_configc C s d S r. r r� r r r �get_lifecycle_config� s z+GSMockBucketStorageUri.get_lifecycle_configc C s d S r. r r� r r r �get_website_config� s z)GSMockBucketStorageUri.get_website_configc C s d S r. r r� r r r �get_versioning_config� s z,GSMockBucketStorageUri.get_versioning_config)NN)N)N)N)N)N)N)N) r� r� r� r� r� r� r� r� r� r� r� r r r r r� � s r� ZTestRemoveSectionc C st t j�| |d�}t j�| �s8|�| tdf� t j�| � |�| ||f� |du r`t j�| |� nt j�| ||� dS )a� Sets boto configuration temporarily for testing. SetBotoConfigForTest should be called by tests instead of this function. This will ensure that the configuration is reverted to its original setting using _RevertBotoConfig. Args: section: Boto config section to set name: Boto config name to set value: Value to set revert_list: List for tracking configs to revert. N) rC rD �get� has_section�append�TEST_BOTO_REMOVE_SECTION� add_section� remove_optionr3 )�sectionr� �value� revert_listZ prev_valuer r r �_SetBotoConfig� s r� c C sj g }| D ]F\}}}|du r>|t kr.|�|� qNtj�||� qtj�|||� q|D ]}tj�|� qTdS )z�Reverts boto config modifications made by _SetBotoConfig. Args: revert_list: List of boto config modifications created by calls to _SetBotoConfig. N)r� r� rC rD r� r3 �remove_section)r� Zsections_to_remover� r� r� r r r �_RevertBotoConfig s r� c s t �� �� fdd��}|S )a` Decorator for tests that perform file to object transfers, or vice versa. This forces the test to run once normally, and again with special boto config settings that will ensure that the test follows the parallel composite upload and/or sliced object download code paths. Args: func: Function to wrap. Returns: Wrapped function. c sV � | i |�� t sRt� rRtg d��� � | i |�� W d � n1 sH0 Y d S )N))r> �#parallel_composite_upload_threshold�1)r> � sliced_object_download_thresholdr� )r> �%sliced_object_download_max_components�3)r> � check_hashes�always)� RUN_S3_TESTSr �SetBotoConfigForTest)r� r� r� r r �Wrapper1 s z.SequentialAndParallelTransfer.<locals>.Wrapper)� functools�wraps)r� r r r� r � SequentialAndParallelTransfer# s r c C sR i }| D ]D}|d |d |d }}}||vr8i ||< |dur||| |< q|S )a� Converts the input config list to a dict that is easy to write to a file. This is used to reset the boto config contents for a test instead of preserving the existing values. Args: boto_config_list: list of tuples of: (boto config section to set, boto config name to set, value to set) If value to set is None, no entry is created. Returns: Dictionary of {section: {keys: values}} for writing to the file. r r r� Nr )�boto_config_list�sectionsZ config_entryr� �keyr� r r r �_SectionDictFromConfigListC s r c C sv t |d��X}t�| �D ]<\}}|�d| � t�|�D ]\}}|�d||f � q6qW d � n1 sh0 Y dS )zFWrites a section dict from _SectionDictFromConfigList to tmp_filename.�wz[%s] z%s = %s N)�openr@ rY �write)Z section_dict� tmp_filename�tmp_filer� Zkey_value_pairsr r� r r r �_WriteSectionDictToFile\ s r c c s4 t dg�� dV W d � n1 s&0 Y dS )zHSets a dummy project in boto config for the duration of a 'with' clause.)r> �default_project_idZ dummy_projN)r r r r r �SetDummyProjectForUnitTeste s r c c sN g }d}�z t jdd�\}}t�|� |r�| D ]<}|d }tjrTt|t�rT|�t �}t |d |d ||� q.t |d�� }t j �|� W d � q�1 s�0 Y ntt| �|� t|�� dV W d � n1 s�0 Y W t|� |�rJzt�|� W n t�y Y n0 n4t|� |�rHzt�|� W n t�yF Y n0 0 dS )aA Sets the input list of boto configs for the duration of a 'with' clause. This preserves any existing boto configuration unless it is overwritten in the provided boto_config_list. Args: boto_config_list: list of tuples of: (boto config section to set, boto config name to set, value to set) use_existing_config: If True, apply boto_config_list to the existing configuration, preserving any original values unless they are overwritten. Otherwise, apply boto_config_list to a blank configuration. Yields: Once after config is set. Nzgsutil-temp-cfg)�prefixr� r r r )�tempfile�mkstempr/ �closer@ ru rv rw �decoder r� r rC rD r r r �_SetBotoConfigFileForTestr� �remove�OSError)r Zuse_existing_configZrevert_configsr Ztmp_fd� boto_configZ boto_valuer r r r r n sB � ,� &�r c # sT � fdd�}i � | D ]}t j�|�� |< qz|| � dV W |� � n |� � 0 dS )z0Sets OS environment variables for a single test.c sN t �| �D ]>\}}tj�|�� |< |d ur6|tj|< q |tjv r tj|= q d S r. )r@ rY r/ rU r� )Z dict_to_applyra rb �Z old_valuesr r �_ApplyDictToEnvironment� s z6SetEnvironmentForTest.<locals>._ApplyDictToEnvironmentN)r/ rU r� )Zenv_variable_dictr! ra r r r �SetEnvironmentForTest� s r" c c s� zt jd }d}W n ty( d}Y n0 | t jd< z(dV W |rN|t jd< q~t j�dd� n |rn|t jd< nt j�dd� 0 dS )a� Sets a given file as the boto config file for a single test. This function applies only the configuration in boto_config_path and will ignore existing configuration. It should not be called directly by tests; instead, use SetBotoConfigForTest. Args: boto_config_path: Path to config file to use. Yields: When configuration has been applied, and again when reverted. � BOTO_CONFIGTFN)r/ rU r! �pop)Zboto_config_pathZ old_boto_config_env_variableZboto_config_was_setr r r r � s � r c C sH t �d�} g }t�tj�D ](\}}}| �|�}|r|�|�d�� q|S )z?Returns a list of the names of the test modules in gslib.tests.z^test_(?P<name>.*)$r� ) r� r� �pkgutil� iter_modules� gslib_tests�__path__�matchr� r )�matcher�names�_�modname�mr r r � GetTestNames� s r/ c C s t jrt| t�S t| tj�S r. )r@ �PY2rv �file�io�IOBase)r� r r r r� � s r� c C s8 t | tjtjf�r"| �dd��� S td�t| ����dS )a Returns a copy of the given name with any invalid characters replaced. Args: name Union[str, unicode, bytes]: The bucket name to transform into a valid name. Returns: Union[str, unicode, bytes] The version of the bucket name containing only valid characters. r, �-z*Unable to format name. Incorrect Type: {0}N) rv r@ � text_type� binary_typer� �lower� TypeErrorrF �type)r� r r r �MakeBucketNameValid� s �r: c c sh d}z t �� }W n ty" Y n0 | r2t �| � z dV W | rd|rdt �|� n| rb|rbt �|� 0 dS )a Changes the working directory for the duration of a 'with' call. Args: new_working_directory: The directory to switch to before executing wrapped code. A None value indicates that no switching is necessary. Yields: Once after working directory has been changed. N)r/ �getcwdr �chdir)Znew_working_directoryZprev_working_directoryr r r �WorkingDirectory� s �r= c C s" t � �dd �} | sdS d| jjv S )N� __loader__F� zipimport)�globalsr� r� r� )�loaderr r r rI s rI c C s t � rt�| �S dd� S d S )Nc S s | S r. r r� r r r r9 r z SkipForParFile.<locals>.<lambda>)rI r� r� r� r r r �SkipForParFile s rB c @ s e Zd ZdZdd� Zdd� ZdS )�HaltingCopyCallbackHandlerzFTest callback handler for intentionally stopping a resumable transfer.c C s || _ || _d S r. )� _is_upload� _halt_at_byte)r� � is_upload� halt_at_byter r r r� & s z#HaltingCopyCallbackHandler.__init__c C sF || j krBtj�d| j t|�t|�f � | jr:td��ntd��dS )aD Forcibly exits if the transfer has passed the halting point. Note that this function is only called when the conditions in gslib.progress_callback.ProgressCallbackWithTimeout.Progress are met, so self._halt_at_byte is only precise if it's divisible by gslib.progress_callback._START_BYTES_PER_CALLBACK. z4Halting transfer after byte %s. %s/%s transferred. zArtifically halting upload.� Artifically halting download.N)rE rK rQ r r rD r r )r� �total_bytes_transferred� total_sizer r r �call+ s ��� z HaltingCopyCallbackHandler.callN�r� r� r� r� r� rK r r r r rC # s rC c @ s e Zd ZdZdd� Zdd� ZdS )�#HaltOneComponentCopyCallbackHandlerz=Test callback handler for stopping part of a sliced download.c C s d | _ || _d S r. )�_last_progress_byterE )r� rG r r r r� A s z,HaltOneComponentCopyCallbackHandler.__init__c C sD | j dur:| j | j k r"|k r:n ntj�d� td��|| _ dS )zCForcibly exits if the passed the halting point since the last call.NzHalting transfer. rH )rN rE rK rQ r r )r� Zcurrent_progress_byteZtotal_size_unusedr r r rK G s �� z(HaltOneComponentCopyCallbackHandler.callNrL r r r r rM > s rM c @ s e Zd ZdZddd�ZdS )� TestParamsak Allows easier organization of test parameters. This class allows grouping of test parameters, which include args and kwargs to be used, as well as the expected result based on those arguments. For example, to test an Add function, one might do: params = TestParams(args=(1, 2, 3), expected=6) self.assertEqual(Add(*(params.args)), params.expected) Nc C s\ |d u rt � n|| _|d u r"t� n|| _|| _t|t tf�sDtd��t| jt�sXtd��d S )Nz'TestParam args must be a tuple or list.z TestParam kwargs must be a dict.)�tupler� rX r� �expectedrv r, r8 )r� r� r� rQ r r r r� \ s zTestParams.__init__)NNN)r� r� r� r� r� r r r r rO P s rO c @ s e Zd ZdZdd� Zdd� ZdS )� CaptureStdoutz�Context manager. For example, this function has the lines printed by the function call stored as a list in output: with CaptureStdout() as output: function(input_to_function) c C s t j| _t� t _| _| S r. )rK rP �_stdoutr � _stringio)r� r r r � __enter__q s zCaptureStdout.__enter__c G s$ | � | j�� �� � | `| jt_d S r. )�extendrT �getvalue� splitlinesrS rK rP )r� r� r r r �__exit__v s zCaptureStdout.__exit__N)r� r� r� r� rU rY r r r r rR g s rR )F)N)N)T)�� __future__r r r r � contextlibr r rs r� r/ r% r� r� r2 rh r[ rK r ry r� r@ � six.movesr r rC �crcmodrG � gslib.kms_apir �gslib.project_idr Zmock_storage_service�gslib.cloud_apir r �gslib.lazy_wrapperr � gslib.tests�testsr' Z gslib.utilsr Zgslib.utils.boto_utilr r �gslib.utils.constantsr � gslib.utils.encryption_helperr �gslib.utils.system_utilr �gslib.utils.unit_utilr r r5 r% r- r) r* �InitializeDefaultMode�int�SYSTEM_POSIX_MODE� DEFAULT_MODE�getuidr7 r1 Z INVALID_UIDZ INVALID_GID� USER_GROUPSrN rc r� ZTEST_ENCRYPTION_KEY1Z TEST_ENCRYPTION_KEY1_SHA256_B64ZTEST_ENCRYPTION_KEY2Z TEST_ENCRYPTION_KEY2_SHA256_B64ZTEST_ENCRYPTION_KEY3Z TEST_ENCRYPTION_KEY3_SHA256_B64ZTEST_ENCRYPTION_KEY4Z TEST_ENCRYPTION_KEY4_SHA256_B64ZTEST_ENCRYPTION_KEY_S3ZTEST_ENCRYPTION_KEY_S3_MD5ZTEST_ENCRYPTION_CONTENT1Z TEST_ENCRYPTION_CONTENT1_MD5Z TEST_ENCRYPTION_CONTENT1_CRC32CZTEST_ENCRYPTION_CONTENT2Z TEST_ENCRYPTION_CONTENT2_MD5Z TEST_ENCRYPTION_CONTENT2_CRC32CZTEST_ENCRYPTION_CONTENT3Z TEST_ENCRYPTION_CONTENT3_MD5Z TEST_ENCRYPTION_CONTENT3_CRC32CZTEST_ENCRYPTION_CONTENT4Z TEST_ENCRYPTION_CONTENT4_MD5Z TEST_ENCRYPTION_CONTENT4_CRC32CZTEST_ENCRYPTION_CONTENT5Z TEST_ENCRYPTION_CONTENT5_MD5Z TEST_ENCRYPTION_CONTENT5_CRC32C�RUN_INTEGRATION_TESTSZRUN_UNIT_TESTSr �USE_MULTIREGIONAL_BUCKETSZ%PARALLEL_COMPOSITE_UPLOAD_TEST_CONFIGZ ORPHANED_FILEZPOSIX_MODE_ERRORZPOSIX_GID_ERRORZPOSIX_UID_ERRORZ POSIX_INSUFFICIENT_ACCESS_ERROR�objectr� r� r� r� r� rD r� � HAS_S3_CREDSr� r� ZHAS_NON_DEFAULT_GS_HOSTZ HAS_GS_HOSTZ HAS_GS_PORT�upperZUSING_JSON_APIr� r� ZARGCOMPLETE_AVAILABLEr� r� r� ZMockConnectionr� r� ZMockBucketStorageUrir� r� r� r� r r r r r r" r r/ r� r: r= rI rB rC rM rO r, rR r r r r �<module> s, � &����� � �� .
| ver. 1.4 |
Github
|
.
| PHP 8.2.28 | Generation time: 0.02 |
proxy
|
phpinfo
|
Settings