| Server IP : 80.87.202.40 / Your IP : 216.73.216.169 Web Server : Apache System : Linux rospirotorg.ru 5.14.0-539.el9.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Dec 5 22:26:13 UTC 2024 x86_64 User : bitrix ( 600) PHP Version : 8.2.27 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/lib64/python3.9/site-packages/mercurial/__pycache__/ |
Upload File : |
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