Dashboard
PHP:
8.2.30
OS:
Linux
User:
dh_nv8b2m
/
/
usr
/
lib
/
python3
/
dist-packages
/
mercurial
/
__pycache__
📤 Upload
📝 New File
📁 New Folder
Close
Editing: statichttprepo.cpython-310.pyc
o �]Lb� � @ 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/lib/python3/dist-packages/mercurial/statichttprepo.py�__init__' s zhttprangereader.__init__c C s | S �Nr �r r r r � __enter__. � zhttprangereader.__enter__c C s | � � d S r )�close)r �exc_type� exc_value� tracebackr r r �__exit__1 � 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 }| js|r$|�dd| j|f � z| j�|�}|� � }|j }W n0 t j yQ } z|j dkrDt jpEd }t|t|���d }~w t jyc } ztd |j��d }~ww |dkr}|ru|| j| j| � }n|| jd � }n|r�|d |� }| jt|�7 _|S )N� r �Rangez bytes=%d-%si� �� )�urlreq�requestr �strurlr r � add_headerr �open�read�code�urlerr� httperror�errno�ENOENT�IOError�str�urlerror�reason�len) r �bytes�req�end�f�datar/ �inst�numr r r r. 7 s4 � �� zhttprangereader.readc C s | � � �d�S )NT)r. � splitlinesr r r r � readlinesX s zhttprangereader.readlinesc C s t | �� �S r )�iterrA r r r r �__iter__[ r$ zhttprangereader.__iter__c C � d S r r r r r r r ^ r zhttprangereader.closer ) �__name__� __module__� __qualname__r r r# r% r. rA rC r r r r r r & s ! r c @ s e Zd ZdZdS )� _RangeErrorz6Error raised when an unsatisfiable range is requested.N)rE rF rG �__doc__r r r r rH e s rH 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) � addinfourl� get_full_urlr/ �msg)r r: �fpr/ rM �hdrs�rr r r �http_error_206r s z _HTTPRangeHandler.http_error_206c C s t d��)Ns Requested Range Not Satisfiable)rH )r r: rN r/ rM rO r r r �http_error_416y s z _HTTPRangeHandler.http_error_416N)rE rF rG rI rQ rR r r r r rJ i s rJ 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 rS r r r r � s z,build_opener.<locals>.statichttpvfs.__init__� rc s0 |dvrt d��d�| jt�|�f�}t|� �S )N)rU s rbs Permission denied� /)r4 �joinrS r) �quoter )r �path�mode�args�kwr< �� urlopenerr r �__call__� s z,build_opener.<locals>.statichttpvfs.__call__c S s |r t �| j|�S | jS r )r rW rS )r rY r r r rW � s z(build_opener.<locals>.statichttpvfs.joinN)rU )rE rF rG r r_ rW r r] r r � statichttpvfs� s r` )r r � add_handlerrJ �vfsmod� abstractvfs)�ui�authinfor` r r] r � build_opener~ s rf c @ s e Zd Zdd� Zdd� ZdS )�statichttppeerc C rD r r r r r r �local� r zstatichttppeer.localc C � dS �NFr r r r r �canpush� r zstatichttppeer.canpushN)rE rF rG rh rk r r r r rg � s rg c s` e Zd ZejjZdd� Z� fdd�Zdd� Z dd� Z d d � Z dd d �Z ddd�Z dd� Z� ZS )�statichttprepositoryc C s> || _ || _|| _t�|�d�d �}|�� \| _}t||�}|| j�| _ || j � d��| _ g | _ t � � | _d | _d | _t� | _t� | _z t| j �d��� �}W nK ty� } z?|jtjkr_� t� }z| � d�}|�d� |�� W n ty� } z|jtjkr�� td�| } t� | ��d }~ww W Y d }~nd }~ww 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 ) NrV s /.hgs caches requiress 00changelog.ir s+ '%s' does not appear to be an hg repositorys store)<�_urlrd �rootr r �rstripre rY rf r rW �cachevfs�_phasedefaultsr �names� filtername�_extrafilterid�set�_wanted_sidedata�featuresr. r@ r4 r2 r3 r r r � RepoError�requirementsmod�SHARESAFE_REQUIREMENTr �gathersupportedrequirements� ensurerequirementsrecognized� ensurerequirementscompatibler � nodeconstants�nullid� makestore�store�spathr �svfs�sjoin� _filecacher r �manifestrevlog� manifestlog� narrowmatchr �_tags� nodetagscacher �BranchMapCache� _branchcaches�_revbranchcache� encodepats� decodepats� _transref) r rd rY �ure �vfsclassr r> rN rM �storevfs�supportedrequirements� rootmanifestr r r r � s| �� ��� � � z statichttprepository.__init__c s t t| ��|�}|�dg�S )Ns pushkey)�superrl �_restrictcapabilities� difference)r �caps�� __class__r r r� � s z*statichttprepository._restrictcapabilitiesc C s | j S r )rm r r r r r � s zstatichttprepository.urlc C ri rj r r r r r rh � r zstatichttprepository.localc C s t | �S r )rg r r r r �peer� s zstatichttprepository.peerTc C � t �dtd�dtd����Nr s lock not availables locks" cannot lock static-http repository�r �LockUnavailabler �r �waitr r r �wlock� � �zstatichttprepository.wlockc C r� r� r� r� r r r �lock� r� zstatichttprepository.lockc C rD r r r r r r � _writecaches r z!statichttprepository._writecaches)T)rE rF rG r �localrepository�_basesupported� supportedr r� r rh r� r� r� r� � __classcell__r r r� r rl � s F rl c C s$ |r t �td���t| |dd � �S )Ns( cannot create new static-http repository� )r �Abortr rl )rd rY �create�intents� createoptsr r r �instance s r� )NN)'� __future__r r2 �i18nr �noder � r r r r r r r r r ry r r r rb �utilsr r0 r) �objectr r4 rH � basehandlerrJ rf � localpeerrg r� �revlogfilestoragerl r� r r r r �<module> s" 8 ? �l
Save
Cancel