/
lib64
/
python3.9
/
site-packages
/
mercurial
/
__pycache__
/
Upload File
HOME
a �+�b� � @ s� d dl mZ d dlZddlmZ ddlmZ ddlmZm Z m Z m Z m Z m Z mZmZmZmZmZmZ ddlmZ ejZejZG dd � d e�ZG d d � d e �Z G d d � d ej �Z dd� Z G dd� de j!�Z"G dd� de j#e j$�Z%ddd�Z&dS )� )�absolute_importN� )�_)�sha1nodeconstants) � branchmap� changelog�error� localrepo�manifest� namespaces�pathutil�pycompat� requirements�url�util�vfs)�urlutilc @ sN e Zd Zdd� Zdd� Zdd� Zdd� Zdd d �Zd d � Zdd� Z dd� Z d S )�httprangereaderc C s || _ d| _|| _|| _d S )Nr )r �pos�opener�name)�selfr r � r �>/usr/lib64/python3.9/site-packages/mercurial/statichttprepo.py�__init__' s zhttprangereader.__init__c C s | S �Nr �r r r r � __enter__. s zhttprangereader.__enter__c C s | � � d S r )�close)r �exc_type� exc_value� tracebackr r r �__exit__1 s zhttprangereader.__exit__c C s || _ d S r )r )r r r r r �seek4 s zhttprangereader.seekNc C s> t �t�| j��}d}|r(| j| d }| js2|rH|�dd| j|f � z | j�|�}|� � }|j }W nx t j y� } z.|j dkr�t jp�d }t|t|���W Y d }~n:d }~0 t jy� } ztd |j��W Y d }~n d }~0 0 |dk�r|�r|| j| j| � }n|| jd � }n|�r(|d |� }| jt|�7 _|S )N� r ZRangez bytes=%d-%si� �� )�urlreqZrequestr Zstrurlr r Z add_headerr �open�read�code�urlerrZ httperror�errno�ENOENT�IOError�strZurlerror�reason�len) r �bytes�req�end�f�datar) �instZnumr r r r( 7 s. "" zhttprangereader.readc C s | � � �d�S )NT)r( � splitlinesr r r r � readlinesX s zhttprangereader.readlinesc C s t | �� �S r )�iterr8 r r r r �__iter__[ s zhttprangereader.__iter__c C s d S r r r r r r r ^ s zhttprangereader.close)N) �__name__� __module__� __qualname__r r r" r# r( r8 r: r r r r r r & s !r c @ s e Zd ZdZdS )� _RangeErrorz6Error raised when an unsatisfiable range is requested.N)r; r< r= �__doc__r r r r r> e s r> c @ s e Zd ZdZdd� Zdd� ZdS )�_HTTPRangeHandlera Handler that enables HTTP Range headers. This was extremely simple. The Range header is a HTTP feature to begin with so all this class does is tell urllib2 that the "206 Partial Content" response from the HTTP server is what we expected. c C s" t �|||�� �}||_||_|S r )r& Z addinfourlZ get_full_urlr) �msg)r r2 �fpr) rA �hdrs�rr r r �http_error_206r s z _HTTPRangeHandler.http_error_206c C s t d��d S )Ns Requested Range Not Satisfiable)r> )r r2 rB r) rA rC r r r �http_error_416y s z _HTTPRangeHandler.http_error_416N)r; r< r= r? rE rF r r r r r@ i s r@ c s2 t �| |�� � �t� � G � fdd�dtj�}|S )Nc s* e Zd Zdd� Zd � fdd� Zdd� ZdS ) z#build_opener.<locals>.statichttpvfsc S s || _ i | _d S r )�base�options)r rG r r r r � s z,build_opener.<locals>.statichttpvfs.__init__� rc s0 |dvrt d��d�| jt�|�f�}t|� �S )N)rI s rbs Permission denied� /)r- �joinrG r& �quoter )r �path�mode�args�kwr4 �Z urlopenerr r �__call__� s z,build_opener.<locals>.statichttpvfs.__call__c S s |rt �| j|�S | jS d S r )r rK rG )r rM r r r rK � s z(build_opener.<locals>.statichttpvfs.joinN)rI )r; r< r= r rR rK r rQ r r � statichttpvfs� s rS )r r Z add_handlerr@ �vfsmodZ abstractvfs)�ui�authinforS r rQ r � build_opener~ s rW c @ s e Zd Zdd� Zdd� ZdS )�statichttppeerc C s d S r r r r r r �local� s zstatichttppeer.localc C s dS �NFr r r r r �canpush� s zstatichttppeer.canpushN)r; r< r= rY r[ r r r r rX � s rX c s` e Zd ZejjZdd� Z� fdd�Zdd� Z dd� Z d d � Z dd d �Z ddd�Z dd� Z� ZS )�statichttprepositoryc C sR || _ || _|| _t�|�d�d �}|�� \| _}t||�}|| j�| _ || j � d��| _ g | _ t � � | _d | _d | _t� | _t� | _zt| j �d��� �}W n� t�yH } z�|jtjkr�� t� }z | � d�}|�d� |�� W nL t�y2 } z2|jtjk�r� td�| } t� | ��W Y d }~n d }~0 0 W Y d }~n d }~0 0 t j |v �r||| j � d��} |t| �d��� �O }t � |�} t �!|| � t �"||� t#| _$| j$j%| _%t �&|| j|�| _'| j'j| _(| j'j)| _*| j'j | _+i | _,|| _-t.�/| j$| j*�} t.�0| j*| | | �1� �| _0t2�2| j*�| _2d | _3d | _4t5�6� | _7d | _8d | _9d | _:d | _;d S ) NrJ s /.hgs caches requiress 00changelog.ir s+ '%s' does not appear to be an hg repositorys store)<�_urlrU �rootr r �rstriprV rM rW r rK ZcachevfsZ_phasedefaultsr �namesZ filternameZ_extrafilterid�setZ_wanted_sidedataZfeaturesr( r7 r- r+ r, r r r Z RepoError�requirementsmodZSHARESAFE_REQUIREMENTr ZgathersupportedrequirementsZ ensurerequirementsrecognizedZ ensurerequirementscompatibler Z nodeconstantsZnullidZ makestore�storeZspathr ZsvfsZsjoinZ _filecacher r ZmanifestrevlogZ manifestlogZ narrowmatchr Z_tagsZ nodetagscacher ZBranchMapCacheZ _branchcachesZ_revbranchcacheZ encodepatsZ decodepatsZ _transref) r rU rM �urV Zvfsclassr r6 rB rA ZstorevfsZsupportedrequirementsZ rootmanifestr r r r � sr 6 � � z statichttprepository.__init__c s t t| ��|�}|�dg�S )Ns pushkey)�superr\ �_restrictcapabilities� difference)r Zcaps�� __class__r r rf � s z*statichttprepository._restrictcapabilitiesc C s | j S r )r] r r r r r � s zstatichttprepository.urlc C s dS rZ r r r r r rY � s zstatichttprepository.localc C s t | �S r )rX r r r r �peer� s zstatichttprepository.peerTc C s t �dtd�dtd���d S �Nr s lock not availables locks" cannot lock static-http repository�r ZLockUnavailabler �r �waitr r r �wlock� s �zstatichttprepository.wlockc C s t �dtd�dtd���d S rk rl rm r r r �lock� s �zstatichttprepository.lockc C s d S r r r r r r � _writecaches s z!statichttprepository._writecaches)T)T)r; r< r= r �localrepositoryZ_basesupportedZ supportedr rf r rY rj ro rp rq � __classcell__r r rh r r\ � s F r\ c C s$ |rt �td���t| |dd � �S )Ns( cannot create new static-http repository� )r ZAbortr r\ )rU rM ZcreateZintentsZ createoptsr r r �instance s ru )NN)'Z __future__r r+ Zi18nr Znoder � r r r r r r r r r rb r r r rT Zutilsr r* r& �objectr r- r> Z basehandlerr@ rW Z localpeerrX rr Zrevlogfilestorager\ ru r r r r �<module> s 8 ? �l