Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/storage/drivers/__pycache__/cloudfiles.cpython-39.pyc
Ðазад
a q�h�� � @ s� d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ z d dl Z W n e yn d dl Z Y n0 d dlm Z d dlm Z d dlmZ e r�d d lmZ d d lmZ d d lmZmZ d d lmZmZ d d lmZ d dl m Z m Z m Z d dl m!Z! d dl m"Z" d dl m#Z# d dl m$Z$ d dl m%Z% d dl m&Z& d dl'm(Z( d dl'm)Z) d dl*m+Z+ dZ,dZ-dZ.dZ/G d d � d e�Z0G d d � d e0e�Z1G d d!� d!e(�Z2G d"d#� d#e2�Z3G d$d%� d%e e)�Z4G d&d'� d'e4�Z5G d(d)� d)e6�Z7G d*d+� d+e6�Z8dS ),� N)�time)�sha1)�httplib)� urlencode)�PY3)�b��urlquote)�FileIO)�read_in_chunks)�MalformedResponseError� LibcloudError)�Response� RawResponse)�Provider)�Object� Container� StorageDriver)�ContainerAlreadyExistsError)�ContainerDoesNotExistError)�ContainerIsNotEmptyError)�ObjectDoesNotExistError)�ObjectHashMismatchError)�InvalidContainerNameError)�OpenStackBaseConnection)�OpenStackDriverMixin)�AUTH_URLzcdn.clouddrive.comzv1.0Z internalURLZ publicURLc @ s( e Zd ZejejgZdd� Zdd� ZdS )�CloudFilesResponsec C s, t | j�}d| ko dkn p*|| jv S )N�� i+ )�int�status�valid_response_codes)�self�i� r$ ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/storage/drivers/cloudfiles.py�successA s zCloudFilesResponse.successc C s� | j s d S d| jv rd}nd| jv r*d}ntd��| j| }|�d�dkrX|�d�d }|dkr�zt�| j �}W q� ty� td| j t d ��Y q�0 n|d kr�| j }n| j }|S ) N� content-type� Content-Type�Missing content-type header�;���r �application/jsonzFailed to parse JSON)�body�driverz text/plain) r- �headersr �find�split�json�loads� Exceptionr �CloudFilesStorageDriver)r" �key� content_type�datar$ r$ r% � parse_bodyE s, �z CloudFilesResponse.parse_bodyN) �__name__� __module__� __qualname__r � NOT_FOUND�CONFLICTr! r& r9 r$ r$ r$ r% r > s r c @ s e Zd ZdS )�CloudFilesRawResponseN)r: r; r< r$ r$ r$ r% r? c s r? c sH e Zd ZdZeZeZeZ dZ d� fdd� Z dd� Z d� fd d � Z � ZS )�OpenStackSwiftConnectionz< Connection class for the OpenStack Swift endpoint. �1.0Tc sh |� dd � tt| �j||fd|i|�� t| _d| _| jp>d| _| j pJd| _ | j r^| j | _ nd | _ d S )N�use_internal_url�securer, � object-store�swift) �pop�superr@ �__init__� API_VERSION� api_version� accept_formatZ_ex_force_service_type� _service_typeZ_ex_force_service_name� _service_name�_ex_force_service_region�_service_region)r" �user_idr6 rC �kwargs�� __class__r$ r% rH s s �� z!OpenStackSwiftConnection.__init__c O sr d| j v sd| j v r.| jj| j| j| jd�}n.d| j v sBd| j v rX| jj| j| jd�}nd }|rf|jS td��d S )N�2.0z3.x)� service_type�name�regionz1.1rA )rV rW �!Could not find specified endpoint)� _auth_version�service_catalog� get_endpointrL rM rO �urlr )r" �argsrQ Zendpointr$ r$ r% r[ � s ��z%OpenStackSwiftConnection.get_endpointN� �GETFc sX |si }|si }|| _ d|d< |dv r<d|vr<|�ddi� tt| �j||||||d�S )Nr2 �format��POST�PUTr( � application/json; charset=UTF-8)�action�paramsr8 �methodr/ �raw)� cdn_request�updaterG r@ �request�r" re rf r8 r/ rg rh ri rR r$ r% rk � s �z OpenStackSwiftConnection.request)T)Nr^ Nr_ FF�r: r; r< �__doc__r Z responseClsr? ZrawResponseClsr Zauth_urlrY rH r[ rk � __classcell__r$ r$ rR r% r@ g s �r@ c sH e Zd ZdZeZeZeZ dZ d� fdd� Z dd� Z d� fd d � Z � ZS )�CloudFilesConnectionz: Base connection class for the Cloudfiles driver. rT TFc s: t t| �j||fd|i|�� t| _d| _d| _|| _d S )NrC r, F)rG rp rH rI rJ rK ri rB )r" rP r6 rC rB rQ rR r$ r% rH � s �z CloudFilesConnection.__init__c C s~ | j �� }| jrd}nd}d| jv rN| jjdd||d�}| jjdd||d�}ntd | j ��| jrf|}|rp|jsxtd ��|jS ) NZinternalZexternalrT rD Z cloudFiles)rU rV rW � endpoint_typezrax:object-cdnZ cloudFilesCDNz Auth version "%s" not supportedrX ) rN �upperrB rY rZ r[ r ri r\ )r" rW rq �epZcdn_epr$ r$ r% r[ � s2 ��� z!CloudFilesConnection.get_endpointNr^ r_ c sZ |si }|si }|| _ d|d< |dv r<d|vr<|�ddi� tt| �j|||||||d�S )Nr2 r` ra r( rd )re rf r8 rg r/ rh ri )ri rj rG rp rk rl rR r$ r% rk � s �z CloudFilesConnection.request)TF)Nr^ Nr_ FFrm r$ r$ rR r% rp � s � �rp c sl e Zd ZdZdZdZeZdZdZ dT� fd d � Z e d d � �Z d d� Z dd� Zdd� ZdUdd�Zdd� ZdVdd�Zdd� Zdd � ZdWd d �ZdXd d �ZdYd!d"�ZdZd#d$�Zd[d%d&�Zd\d'd(�Zd)d*� Zd]d+d,�Z d-d.� Z d^d0d1�Z d_d3d4�Z d`d6d7�Z d8d9� Z!dad<d=�Z"dbd>d?�Z#dcd@dA�Z$dddBdC�Z%dedDdE�Z&dFdG� Z'dHdI� Z(dJdK� Z)dLdM� Z*dNdO� Z+dPdQ� Z,dRdS� Z-� Z.S )fr5 z CloudFiles driver. Z CloudFileszhttp://www.rackspace.com/�md5TN�ordFc sP d|v r|d }|| _ tj| fi |�� tt| �jf ||||||d�|�� dS )z� @inherits: :class:`StorageDriver.__init__` :param region: ID of the region which should be used. :type region: ``str`` �ex_force_service_region�r6 �secretrC �host�portrW N)rB r rH rG r5 ) r" r6 rx rC ry rz rW rB rQ rR r$ r% rH � s ��z CloudFilesStorageDriver.__init__c C s g d�S )N)ru ZdfwZiadZlonZhkgZsydr$ )�clsr$ r$ r% � list_regions s z$CloudFilesStorageDriver.list_regionsc C sL | j �d�}|jtjkr g S |jtjkr:| �t�|j ��S t d|j ��d S )Nr^ �Unexpected status code: %s) � connectionrk r r � NO_CONTENT�OK�_to_container_listr2 r3 r- r )r" �responser$ r$ r% �iterate_containers s z*CloudFilesStorageDriver.iterate_containersc C sf | � |�}| jjd| dd�}|jtjkr<| �||j�}|S |jtjkrTt d | |��t d|j ��d S )N�/%s�HEAD�rg r} ) �_encode_container_namer~ rk r r r �_headers_to_containerr/ r= r r )r" �container_name�container_name_encodedr� � containerr$ r$ r% � get_container s � � z%CloudFilesStorageDriver.get_containerc C s� | � |�}| �|�}| �|�}| jjd||f dd�}|jtjtjfv r\| � |||j �}|S |jtj krtt d | |��t d|j ��d S )N�/%s/%sr� r� r} )r� r� �_encode_object_namer~ rk r r r� r �_headers_to_objectr/ r= r r )r" r� � object_namer� r� �object_name_encodedr� �objr$ r$ r% � get_object+ s ��� z"CloudFilesStorageDriver.get_objectc C sz | � |j�}| jjd| ddd�}|jtjkrL|r>|jd }n |jd }|S |jtjkrht d|j| d��t d |j ��d S ) Nr� r� T)rg ri z x-cdn-ssl-uriz x-cdn-urir^ ��valuer� r. r} ) r� rV r~ rk r r r r/ r= r r )r" r� Z ex_ssl_urir� r� Zcdn_urlr$ r$ r% �get_container_cdn_url< s � �z-CloudFilesStorageDriver.get_container_cdn_urlc C s | j |jd�}d||jf S )N)r� z%s/%s)r� r� rV )r" r� Zcontainer_cdn_urlr$ r$ r% �get_object_cdn_urlP s z*CloudFilesStorageDriver.get_object_cdn_urlc C sJ | � |j�}ddi}|r ||d< | jjd| d|dd�}|jtjtjfv S )z� @inherits: :class:`StorageDriver.enable_container_cdn` :param ex_ttl: cache time to live :type ex_ttl: ``int`` z X-CDN-Enabled�TruezX-TTLr� rc T�rg r/ ri )r� rV r~ rk r r �CREATED�ACCEPTED)r" r� Zex_ttlr� r/ r� r$ r$ r% �enable_container_cdnT s �z,CloudFilesStorageDriver.enable_container_cdnc C sr | � |�}| jjd| dd�}|jtjkrDddi}t||| d�}|S |jtjkr`td | |�}|�t d|j ��d S )Nr� rc r� � object_countr �rV �extrar. r} ) r� r~ rk r r r� r r� r r )r" r� r� r� r� r� �errorr$ r$ r% �create_containeri s � � z(CloudFilesStorageDriver.create_containerc C sj | � |j�}| jjd| dd�}|jtjkr0dS |jtjkrLtd|| d��n|jtj krft d|| d��d S )Nr� �DELETEr� Tr^ r� ) r� rV r~ rk r r r r= r r> r )r" r� rV r� r$ r$ r% �delete_container| s � �z(CloudFilesStorageDriver.delete_containerc C sN |j j}|j}| jjd||f ddd�}| j|| j|||j|||d�tjd�S )Nr� r_ T�rg rh )r� r� �destination_path�overwrite_existing�delete_on_failure�r� �callbackr� �callback_kwargsZsuccess_status_code) r� rV r~ rk � _get_object� _save_objectr� r r� )r" r� r� r� r� r� r� r� r$ r$ r% �download_object� s" ����z'CloudFilesStorageDriver.download_objectc C sJ |j j}|j}| jjd||f ddd�}| j|t||�|�|d�tjd�S )Nr� r_ Tr� ��iterator� chunk_sizer� ) r� rV r~ rk r� r � iter_contentr r� )r" r� r� r� r� r� r$ r$ r% �download_object_as_stream� s �����z1CloudFilesStorageDriver.download_object_as_streamc C sp | j ||d� |jj}|j}d| �||�i} | jjd||f d| dd�} | j|| j| || j|||dd�t j d�S ) N�� start_bytes� end_bytes�Ranger� r_ T)rg r/ rh )r� r� r� r� r� Zpartial_downloadr� ) � _validate_start_and_end_bytesr� rV �_get_standard_range_strr~ rk r� r� r� r �PARTIAL_CONTENT) r" r� r� r� r� r� r� r� r� r/ r� r$ r$ r% �download_object_range� s2 �� ����z-CloudFilesStorageDriver.download_object_rangec C sj | j ||d� |jj}|j}d| �||�i}| jjd||f |ddd�}| j|t||�|�|d�t j d�S ) Nr� r� r� r_ T)r/ rg rh r� r� ) r� r� rV r� r~ rk r� r r� r r� ) r" r� r� r� r� r� r� r/ r� r$ r$ r% � download_object_range_as_stream� s, �� ����z7CloudFilesStorageDriver.download_object_range_as_streamc C s | j ||||||d�S )zq Upload an object. Note: This will override file with a same name if it already exists. )r� r� r� � file_path� verify_hashr/ �� _put_object)r" r� r� r� r� r� r/ r$ r$ r% � upload_object� s �z%CloudFilesStorageDriver.upload_objectc C s& t |t�rt|�}| j|||||d�S )N)r� r� r� �streamr/ )� isinstance�file�iterr� )r" r� r� r� r� r/ r$ r$ r% �upload_object_via_stream� s �z0CloudFilesStorageDriver.upload_object_via_streamc C sn | � |jj�}| �|j�}| jjd||f dd�}|jtjkrBdS |jtj kr\t d|| d��t d|j ��d S )Nr� r� r� Tr^ �r� r� r. r} ) r� r� rV r� r~ rk r r r r= r r )r" r� r� r� r� r$ r$ r% � delete_object� s � �z%CloudFilesStorageDriver.delete_objectc C sR | � |jj�}| �|j�}|r&d|ini }| jjd||f d|dd�}|jtjkS )z� Purge edge cache for the specified object. :param email: Email where a notification will be sent when the job completes. (optional) :type email: ``str`` z X-Purge-Emailr� r� Tr� ) r� r� rV r� r~ rk r r r )r" r� �emailr� r� r/ r� r$ r$ r% �ex_purge_object_from_cdn s ��z0CloudFilesStorageDriver.ex_purge_object_from_cdnc C s� | j jddd�}|jtjkrn|j�dd�}|j�dd�}|j�dd�}|j�dd �}t|�t|�t|�|d �S td |j ��d S ) z9 Get meta data :rtype: ``dict`` r^ r� r� zx-account-container-count�unknownzx-account-object-countzx-account-bytes-usedzx-account-meta-temp-url-keyN)�container_countr� � bytes_used� temp_url_keyr} ) r~ rk r r r r/ �getr r )r" r� r� r� r� r� r$ r$ r% �ex_get_meta_data s( �����z(CloudFilesStorageDriver.ex_get_meta_data� c C sj t j�|�}||k r(| j|||||d�S t||�}t|�D ] \} } | j||| | |d� q:| j||||d�S )N)r� r� )r� r� � part_numberr� r� )r� r� r� r� )�os�path�getsizer� �FileChunkReader� enumerate�_upload_object_part�_upload_object_manifest) r" r� r� r� r� r� r� Z object_sizeZiter_chunk_reader�indexr� r$ r$ r% �ex_multipart_upload_object. s$ � ��z2CloudFilesStorageDriver.ex_multipart_upload_object� index.htmlc C s8 |j }d|i}| jjd| d|dd�}|jtjtjfv S )aF Enable serving a static website. :param container: Container instance :type container: :class:`Container` :param index_file: Name of the object which becomes an index page for every sub-directory in this container. :type index_file: ``str`` :rtype: ``bool`` zX-Container-Meta-Web-Indexr� rb Fr� �rV r~ rk r r r� r� )r" r� Z index_filer� r/ r� r$ r$ r% �ex_enable_static_websiteD s �z0CloudFilesStorageDriver.ex_enable_static_website� error.htmlc C s8 |j }d|i}| jjd| d|dd�}|jtjtjfv S )af Set a custom error page which is displayed if file is not found and serving of a static website is enabled. :param container: Container instance :type container: :class:`Container` :param file_name: Name of the object which becomes the error page. :type file_name: ``str`` :rtype: ``bool`` zX-Container-Meta-Web-Errorr� rb Fr� r� )r" r� � file_namer� r/ r� r$ r$ r% �ex_set_error_page\ s �z)CloudFilesStorageDriver.ex_set_error_pagec C s6 d|i}| j jdd|dd�}|jtjtjtjtjfv S )z� Set the metadata header X-Account-Meta-Temp-URL-Key on your Cloud Files account. :param key: X-Account-Meta-Temp-URL-Key :type key: ``str`` :rtype: ``bool`` zX-Account-Meta-Temp-URL-Keyr^ rb Fr� )r~ rk r r r� r r� r� )r" r6 r/ r� r$ r$ r% �$ex_set_account_metadata_temp_url_keyt s � �z<CloudFilesStorageDriver.ex_set_account_metadata_temp_url_keyr_ �< c C s� | j �� tt� | �}d| j j|jj|jf }z | �� d }|dusJJ �W n tyf t d��Y n0 d|||f }t � t |�t |�t ��� }t||d��} d| j j| j j |jj|j| f } | S )as Create a temporary URL to allow others to retrieve or put objects in your Cloud Files account for as long or as short a time as you wish. This method is specifically for allowing users to retrieve or update an object. :param obj: The object that you wish to make temporarily public :type obj: :class:`Object` :param method: Which method you would like to allow, 'PUT' or 'GET' :type method: ``str`` :param timeout: Time (in seconds) after which you want the TempURL to expire. :type timeout: ``int`` :rtype: ``bool`` z%s/%s/%sr� Nz�You must first set the X-Account-Meta-Temp-URL-Key header on your Cloud Files account using ex_set_account_metadata_temp_url_key before you can use this method.z%s %s %s)Z temp_url_sigZtemp_url_expireszhttps://%s/%s/%s?%s)r~ Z!_populate_hosts_and_request_pathsr r � request_pathr� rV r� r4 �KeyError�hmac�newr r � hexdigestr ry ) r" r� rg �timeout�expiresr� r6 Z hmac_body�sigrf Ztemp_urlr$ r$ r% �ex_get_object_temp_url� s* � � ��z.CloudFilesStorageDriver.ex_get_object_temp_urlc C s, |d| }ddi}| j |||||d� d S )Nz/%08dr7 zapplication/octet-stream)r� r� r� r� r� r� )r" r� r� r� r� r� Z part_namer� r$ r$ r% r� � s �z+CloudFilesStorageDriver._upload_object_partc C s� |pi }|� d�}| �|j�}| �|�}d||f }| jjd||f d�} d} | jj|d| | dd�} d } |r�| �� } | �t | �� | � � }| j � d �} | |kr�t d || f || d ��t |d | d ||| d �}|S )N� meta_datar� z%s/%s/)z X-Auth-TokenzX-Object-Manifestr^ rc T)rg r8 r/ rh �etag�9MD5 hash checksum does not match (expected=%s, actual=%s)r� r �rV �size�hashr� r� r� r. )r� r� rV r� r~ Z auth_tokenrk Z_get_hash_functionrj r r� r/ r r )r" r� r� r� r� r� r� r� r� r/ r8 r� Z object_hashZ hash_function� data_hashr� r$ r$ r% r� � sD ���� �� �z/CloudFilesStorageDriver._upload_object_manifestc c s� | � ||�}i }|r ||d< | �|j�}| jjd| |d�}|jtjkrLq�q |jtjkr�| � t � |j �|�}t |�dkrzq�|D ] }|V q~|j|d< q td|j ��q dS )a Return a generator of objects for the given container. :param container: Container instance :type container: :class:`Container` :param prefix: Only get objects with names starting with prefix :type prefix: ``str`` :param ex_prefix: (Deprecated.) Only get objects with names starting with ex_prefix :type ex_prefix: ``str`` :return: A generator of Object instances. :rtype: ``generator`` of :class:`Object` �prefixr� )rf r �markerr} N)Z_normalize_prefix_argumentr� rV r~ rk r r r r� �_to_object_listr2 r3 r- �lenr ) r" r� r� Z ex_prefixrf r� r� �objectsr� r$ r$ r% �iterate_container_objects� s2 ��� � �z1CloudFilesStorageDriver.iterate_container_objectsc C sh |pi }| � |j�}| �|�} |�dd �} |�dd �} |�dd �} |pHi }| rtt| �� �D ]\} }d| } ||| < qZ| d ur�| |d< d|| f }| j|| |d|||d�}|d }|d }|d j�d d �}|jt j kr�t d | d ��n�|r�|s�t d| d ��nj|�r*|d |k�r*t d|d |f || d��n:|jt j k�rRt|||d | || d�}|S t d|j | d��d S )Nr7 r� �content_dispositionzX-Object-Meta-%szContent-Dispositionr� rc )r� r7 r� �request_methodr/ r� r� r� �bytes_transferredr� r) )r� r. zServer didn't return etagr� r� r� r� zstatus_code=%s)r. )r� rV r� r� �list�itemsZ_upload_objectr/ r r �EXPECTATION_FAILEDr r r� r )r" r� r� r� r� r� r� r/ r� r� r7 r� r� r6 r� r� Z result_dictr� r� Z server_hashr� r$ r$ r% r� s^ � �� ��� �z#CloudFilesStorageDriver._put_objectc C sX |� d�r|dd� }t|�}|�d�dkr:td|| d��t|�dkrTtd|| d��|S ) zV Encode container name so it can be used as part of the HTTP request. �/� Nr+ z%Container name cannot contain slashesr� � z.Container name cannot be longer than 256 bytes)� startswithr r0 r r� �r" rV r$ r$ r% r� L s � �z.CloudFilesStorageDriver._encode_container_namec C s t |�}|S �Nr r r$ r$ r% r� ` s z+CloudFilesStorageDriver._encode_object_namec c s< |D ]2}t |d �t |d �d�}t|d || d�V qd S )N�count�bytes�r� r� rV r� )r r )r" r� r� r� r$ r$ r% r� d s �z*CloudFilesStorageDriver._to_container_listc C s\ g }|D ]N}|d }t |d �}|d }|d |d d�}|�t||||d || d�� q|S )NrV r r� r7 � last_modified�r7 r r� )r �appendr ) r" r� r� r� r� rV r� r� r� r$ r$ r% r� k s �� z'CloudFilesStorageDriver._to_object_listc C s< t |�dd��}t |�dd��}||d�}t||| d�}|S )Nzx-container-bytes-usedr zx-container-object-countr r� )r r� r )r" rV r/ r� r� r� r� r$ r$ r% r� z s �z-CloudFilesStorageDriver._headers_to_containerc C s� t |�dd��}|�dd �}|�dd �}|�dd �}i }t|�� �D ]*\} } | �d�dkrD| �dd�} | || < qD||d �} t|||| ||| d �} | S ) Nzcontent-lengthr z last-modifiedr� r' zx-object-meta-r+ r^ r r� )r rF r� r� r0 �replacer ) r" rV r� r/ r� r r� r7 r� r6 r� r� r� r$ r$ r% r� � s �z*CloudFilesStorageDriver._headers_to_objectc C s | � � }| j|d< | j|d< |S )Nrv rB )Zopenstack_connection_kwargsrW rB )r" rQ r$ r$ r% �_ex_connection_class_kwargs� s z3CloudFilesStorageDriver._ex_connection_class_kwargs)NTNNru F)F)N)FT)N)NFT)NN)NTN)NN)N)r� NT)r� )r� )r_ r� )T)NT)NN)NNNTN)/r: r; r< rn rV Zwebsiterp � connectionClsZ hash_typeZsupports_chunked_encodingrH � classmethodr| r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r ro r$ r$ rR r% r5 � s~ � � � � � � � - � � ( � 2 � 3 r5 c s0 e Zd ZdZejZdZeZ d� fdd� Z � Z S )�OpenStackSwiftStorageDriverz1 Storage driver for the OpenStack Swift. zOpenStack SwiftNTc s( t t| �jf ||||||d�|�� d S )Nrw )rG r rH )r" r6 rx rC ry rz rW rQ rR r$ r% rH � s ��z$OpenStackSwiftStorageDriver.__init__)NTNNN) r: r; r< rn r ZCLOUDFILES_SWIFT�typerV r@ r rH ro r$ r$ rR r% r � s �r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) r� c C s* || _ tj�|�| _|| _d| _d| _d S )Nr F)r� r� r� r� �totalr� � bytes_read�stop_iteration)r" r� r� r$ r$ r% rH � s zFileChunkReader.__init__c C s | S r r$ �r" r$ r$ r% �__iter__� s zFileChunkReader.__iter__c C sT | j r t�| j}|| j }|| jkr0| j}d| _ | j|| 7 _t| j||dd�S )NTi )r� � start_block� end_blockr� )r � StopIterationr r� r �ChunkStreamReaderr� )r" r r r$ r$ r% �next� s �zFileChunkReader.nextc C s | � � S r �r r r$ r$ r% �__next__� s zFileChunkReader.__next__N�r: r; r< rH r r r r$ r$ r$ r% r� � s r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S ) r c C sP t |d�| _| j�|� || _|| _|| _d| _d| _dd� }t� || j� d S )N�rbr Fc S s$ z | � � W n ty Y n0 d S r )�closer4 )�fdr$ r$ r% � close_file� s z.ChunkStreamReader.__init__.<locals>.close_file) �openr �seekr r r� r r �atexit�register)r" r� r r r� r! r$ r$ r% rH � s zChunkStreamReader.__init__c C s | S r r$ r r$ r$ r% r � s zChunkStreamReader.__iter__c C sf | j r| j�� t�| j}| j| | j| j krH| j| j | j }d| _ | j�|�}| j|7 _|S )NT) r r r r r� r r r �read)r" � block_size�blockr$ r$ r% r � s � zChunkStreamReader.nextc C s | � � S r r r r$ r$ r% r � s zChunkStreamReader.__next__Nr r$ r$ r$ r% r � s r )9r$ r� r� r �hashlibr Zlibcloud.utils.py3r r Z simplejsonr2 � ImportErrorr r r �ior r� Zlibcloud.utils.filesr Zlibcloud.common.typesr r Zlibcloud.common.baser r Zlibcloud.storage.providersr Zlibcloud.storage.baser r r Zlibcloud.storage.typesr r r r r r Zlibcloud.common.openstackr r Zlibcloud.common.rackspacer ZCDN_HOSTrI ZINTERNAL_ENDPOINT_KEYZPUBLIC_ENDPOINT_KEYr r? r@ rp r5 r �objectr� r r$ r$ r$ r% �<module> s\ %BH 0
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка