403Webshell
Server IP : 74.208.236.16  /  Your IP : 216.73.217.15
Web Server : Apache
System : Linux info 3.0 #1337 SMP Tue Jan 01 00:00:00 CEST 2000 all GNU/Linux
User : u102440577 ( 7172810)
PHP Version : 8.4.26
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : OFF  |  Pkexec : OFF
Directory :  /kunden/lib/python3/dist-packages/mercurial/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

Current File : /kunden/lib/python3/dist-packages/mercurial/__pycache__/httppeer.cpython-313.pyc
�

6�h�T����SSKJr SSKrSSKrSSKrSSKrSSKrSSKJr SSK	J
r
 SSKJrJ
r
JrJrJrJrJrJr SSKJr \R.(aSSKJr \R2r\R4r\R6rS	r"S
S5rSS
jrSr"SS\
R@5r!Sr""SS\RF5r$"SS\RJ5r&Sr'S\RPS4Sjr)SSjr*g)�)�annotationsN)�futures�)�_)�bundle2�error�httpconnection�pycompat�statichttprepo�url�util�wireprotov1peer)�urlutil)�Setc
�,�[R"U5S-nU[US-5-
[S5-
n/nSn[S[U5U5H?nUS-
nUR	U[U5-[R"XXt-545 MA U$)aKEncode a string value into multiple HTTP headers.

``value`` will be encoded into 1 or more HTTP headers with the names
``header-<N>`` where ``<N>`` is an integer starting at 1. Each header
name + value will be at most ``limit`` bytes long.

Returns an iterable of 2-tuples consisting of header names and
values as native strings.
z-%s�000s: 
rr)r
�strurl�len�range�append�str)�value�header�limit�fmt�valuelen�result�n�is        �4/usr/lib/python3/dist-packages/mercurial/httppeer.py�encodevalueinheadersr!)s����/�/�&�
!�F�
*�C��s�3��;�'�'�#�i�.�8�H�
�F�	�A�
�1�c�%�j�(�
+��	�Q����
�
�s�S��V�|�X�_�_�U�q�|�5L�%M�N�O�,��M�c�T�\rSrSrSr\S5rSSjr\R4Sjr
Srg)	�
_multifile�Fc�~�UH*n[US5(aM[S[U5U5e XlSUlg)N�lengthsO_multifile only supports file objects that have a length but this one does not:r)�hasattr�
ValueError�type�	_fileobjs�_index)�self�fileobjs�fs   r �__init__�_multifile.__init__GsC���A��1�h�'�'� �<���G��	���"����r"c�:�[SUR55$)Nc3�8# �UHoRv� M g7f�N)r'��.0r/s  r �	<genexpr>�$_multifile.length.<locals>.<genexpr>Us���4�^��8�8�^�s�)�sumr+�r-s r r'�_multifile.lengthSs���4�T�^�^�4�4�4r"Nc���US::a"SRSUR55$/nU(a�UR[UR5:a�UR	URURRU55 [US5nX1:aU=RS-
slX-nU(a%UR[UR5:aM�SRU5$)Nrr"c3�@# �UHoR5v� M g7fr4)�readr5s  r r7�"_multifile.read.<locals>.<genexpr>Ys���=�n��F�F�H�H�n�s����r)�joinr+r,rrr>)r-�amt�parts�gots    r r>�_multifile.readWs����!�8��8�8�=�d�n�n�=�=�=����d�k�k�C����$7�7��L�L�������4�9�9�#�>�?��e�B�i�.�C��y����q� ���J�C��d�k�k�C����$7�7��x�x���r"c��U[R:wa[S5eUS:wa[S5eURHnUR	S5 M SUlg)NsP_multifile does not support anything other than os.SEEK_SET for whence on seek()rsQ_multifile only supports seeking to start, but that could be fixed if you need it)�os�SEEK_SET�NotImplementedErrorr+�seekr,)r-�offset�whencer/s    r rJ�_multifile.seekcs]���R�[�[� �%�:��
��Q�;�%�1��
����A�
�F�F�1�I� ���r")r+r,r4)�__name__�
__module__�__qualname__�__firstlineno__r0�propertyr'r>rGrHrJ�__static_attributes__�r"r r$r$Fs.��
��5��5�
�#%�+�+�
r"r$Fc�r�US:XaSUS'URSS5nURS05n	URSU-5 SU4/n
U(aU
RS5 S	nUSL=(a S
U;nU(a�U(a�[R	[UR
555n
U(dU
nOn[U[5(a([R"U5n[U5UlUn[R"U
5n[U
5Ul[X�5n[U
5U	S'O�U(a�US:wdeU"S
5nU(a[URSS5S	5nUS	:�aI[R	[UR
555n[!USU5HunnUU	U'M
 OU
[UR
55-
n
S[R	U
5-nSUU4-nS	n[#US5(a
URnOUb[U5nUbSU	;aSU	S'[%5n[%5nUbKU"S5nU(a+UR'S5 [%URS55nUR'S5 SU;aUR'S5 SU;a�U"S5(ax[(R*R-[(R.5Vs/sHnUR15R2PM nnUR'SSR5U5-5 U(a?[!SR5[U55SU=(d S5nUHunnUU	U'M
 /nU	H:nUR75R9S 5(dM)URU5 M< U(aS!R5[U55U	S"'U"[:R<"U5X�5nUb)URS#U-5 UR?S$S%U-5 UUU4$s snf)&a?Make an HTTP request to run a command for a version 1 client.

``caps`` is a set of known server capabilities. The value may be
None if capabilities are not yet known.

``capablefn`` is a function to evaluate a capability.

``cmd``, ``args``, and ``data`` define the command, its arguments, and
raw data to pass to it.
spushkeyr"sdataNsheadersssending %s command
scmd)z
access-hidden�1r�httppostargsz
X-HgArgs-Post�capabilitiess
httpheader�,rsX-HgArgs?%ss%s%sr'�Content-Type�application/mercurial-0.1s
httpmediatypes0.1spartial-pulls0.2txs0.2scompressionscomp=%s� s	X-HgProto�zx-hg�,�Varyssending %d bytes
zContent-Lengthz%d) �pop�debugr�urlreq�	urlencode�sorted�items�
isinstance�bytes�io�BytesIOrr'r$�int�splitr!r(�set�addr
�compengines�supportedwireengines�
CLIENTROLE�wireprotosupport�namerA�lower�
startswithr
r�add_unredirected_header)�ui�requestbuilder�caps�	capablefn�repobaseurl�cmd�args�remotehidden�data�headers�q�
headersize�
postargsok�strargsr�argsio�
httpheader�encoded_argsrr�qs�cu�size�protoparams�
mediatypes�mt�e�comps�protoheaders�varyheaders�reqs                               r �makev1commandrequestr�ss���(�j����W�
��8�8�G�T�"�D��h�h�z�2�&�G��H�H�
$�s�
*�+�
�#���A��	���'�(��J��T�!�=�o��&=�J��d��"�"�6�$�*�*�,�#7�8����D��$��&�&��J�J�t�$���t�9������Z�Z��(�F���L�F�M��f�+�D�#&�w�<��� �	
��o�%�%�%��}�-�
���Z�-�-�d�A�6�q�9�:�J���>�!�+�+�F�4�:�:�<�,@�A�L�!5��j�*�"�
���#(����"�
���
�
��%�%�A�	�&�"�"�1�%�	%�B�	�K��$�	$�B��D��t�X����{�{��	
�	��4�y����N�'�9�"=�����%�K���J���
�'�
(��
��O�O�F�#��R�X�X�d�^�,�J�����(��:��������:��)�N�";�";��%�%�:�:�4�?�?�K�
�K��
��� �%�%�K�	�
�	���
�T�Y�Y�u�%5�5�6��+��I�I�f�[�)�*�L�*�:L��
��*�M�F�E�#�G�F�O�*��K����<�<�>�$�$�V�,�,����v�&����(�(�6�+�#6�7����
�����,�d�
<�C���
���&��-�.��#�#�$4�d�T�k�B���B�;���7
s�1$P4c�H�URnSnUR(GaTURSS5(Ga<U"US-[R"UR55[R"UR
554-5 Sn[UR55Hkupg[R"U5n[R"U5nURS5(aUcSnU[U5-
nM\U"US-Xg4-5 Mm UbU"US	-U-5 URnUb)[US
S5n	U	c[U5n	U"US-U	-5 [R"5n
SnURU5nUR(aRURSS5(a;U(aUR$OSn
U"US-[R"5W
-
U
4-5 [8R:"U5 U$![ R"a5nUR$S:Xa[&R("[+S
55eeSnAf[,R.aWnURS[0R2"UR
55-5 UR55 [7SU5eSnAff=f!UR(aTURSS5(a<U(aUR$OSn
U"US-[R"5W
-
U
4-5 fff=f)z<Send a prepared HTTP request.

Returns the response object.
sdevel-peer-request: %s
sdevelsdebug.peer-requests%s %sNsX-hgarg-rs  %s %ss+  %d bytes of commands arguments in headersr's  %d bytes of datai�sauthorization failedshttp error requesting %s
r@s  finished in %.4f seconds (%d))ra�	debugflag�
configboolr
�bytesurl�
get_method�get_full_urlrd�header_itemsrtrr~�getattrr
�timer�open�urlerr�	httperror�coder�Abortr�httplib�
HTTPExceptionr�hidepassword�	traceback�OSError�urlmod�wrapresponse)rv�openerr��dbg�line�
hgargssizerrr~r'�start�res�instr�s              r �sendrequestr��s���

�(�(�C�&�D�	�|�|�|��
�
�h�0E�F�F����
��!�!�#�.�.�"2�3��!�!�#�"2�"2�"4�5��
�	
��
�#�C�$4�$4�$6�7�M�F��&�&�v�.�F��%�%�e�,�E�� � ��-�-��%�!"�J��c�%�j�(�
��D�:�%���7�8�8��!���@�A���
�
�x�x�����T�8�T�2�F��~��T�����,�,�v�5�6��
�
���
�C���k�k�#����<�<�B�M�M�(�4I�J�J�"�3�8�8��D���4�5��:�:�<�%�'��.�/�
�������J��/�����9�9����+�+�a� 7�8�9�9�
��� � �"�
���)��"�"�3�#3�#3�#5�6�
7�	
�	�����d�D�!�!��
"���<�<�B�M�M�(�4I�J�J�"�3�8�8��D���4�5��:�:�<�%�'��.�/�
�K�<�s2�8H�J7�0I	�	J7� AJ2�2J7�7J:�:A'L!c�(^�\rSrSrU4SjrSrU=r$)�RedirectedRepoErroriAc�0>�[TU]U5 X lgr4)�superr0�respurl)r-�msgr��	__class__s   �r r0�RedirectedRepoError.__init__Bs���
������r")r�)rNrOrPrQr0rS�
__classcell__�r�s@r r�r�As
����r"r�c��Sn[R"UR55nURU5(aUS[	U5*nSnOSnURS5URS5:wa0SnUR(dUR[S5U-5 [R"URSS55n	[R"U5n
U	RS5(a$[ R""UR%55eU	RS5(dUR'S	[R"U5-5 [S
5X�=(d SUR%S54-nU(aU(a[)X�5e[ R*"U5eU	R-S
S5Sn[/UR-S5V
s/sHn
[1U
5PM sn
5nUS:Xa*U(a"[4R6SR9U5nO�US:Xav[:R<"S[4R>"US55Sn[4R>"XO5n[4R6RAU5nUR9U5nO#[ R*"[S5X�4-5eXyU4$![a4 [R"URRSS55n	GN?f=fs sn
f![2a$ [ R*"[S5X�4-5ef=f)NFT�/sreal URL is %s
zcontent-type�sapplication/hg-error�application/mercurial-srequested URL: '%s'
sI'%s' does not appear to be an hg repository:
---%%<--- (%s)
%s
---%%<---
sno content-typer]�-r�.s+'%s' sent a broken Content-Type header (%s))rrszlib)r��Brs'%s' uses newer protocol %s)!r
r��geturl�endswithr�rstrip�quiet�warnr�	getheader�AttributeErrorr�getrr�rtr�OutOfBandErrorr>rar��	RepoErrorrk�tuplerjr)r
rn�decompressorreader�struct�unpack�readexactly�forwiretype)rv�baseurl�requrlr��resp�compressible�
redirectedr��	qsdropped�proto�safeurlr��subtyper�version_info�elen�ename�engines                  r �parsev1commandresponser�Gs����J�������
�.�G��������*�S��W�H�%���	��	��~�~�d��w�~�~�d�3�3��
��x�x��G�G�A�)�*�W�4�5�H��!�!�$�.�.���"D�E���"�"�7�+�G����/�0�0��"�"�4�9�9�;�/�/����5�6�6�
���)�G�,@�,@��,H�H�I��
/�
��1�1�4�9�9�T�?�C�D���)�%�c�3�3��/�/�#�&�&�
��+�+�d�A�&�q�)���g�m�m�D�.A�B�.A��c�!�f�.A�B�C���v����#�#�G�,�?�?��E�D��	��	��}�}�T�4�#3�#3�D�!�#<�=�a�@��� � ��,���!�!�-�-�e�4���(�(��.���o�o�
�,�-��0B�B�
�	
��4����g�H��!�!�$�,�,�"2�"2�>�2�"F�G��H��4C���
��o�o�
�<�=��@P�P�
�	
�
�s0�&&K�2-L�L�4L�:L�L�L�.Mc�^�\rSrSrSU4SjjrSrSrSrSrSr	SSjr
S	rSS
jrSr
SrS
rSrSrSrU=r$)�httppeeri�c�>�[TU]XUS9 X0lX`lUSL=(a SU;UlX@lXPlXplg)N)�pathr}rW)r�r0�_url�_caps�limitedarguments�
_urlopener�_requestbuilder�
_remotehidden)	r-rvr�rr�rwrxr}r�s	        �r r0�httppeer.__init__�sI���	����\��B��	��
� $�D� 0� P�_�D�5P��� ��-��)�r"c��URRH&nUR5 [USS5"5 M( g)N�	close_allc��gr4rTrTr"r �<lambda>�"httppeer.__del__.<locals>.<lambda>�s��Dr")r��handlers�closer�)r-�hs  r �__del__�httppeer.__del__�s.�����)�)�A�
�G�G�I��A�{�L�1�3�*r"c�.�URR$r4)r��locr:s r r�httppeer.url�s���y�y�}�}�r"c��gr4rTr:s r �local�httppeer.local����r"c��g)NTrTr:s r �canpush�httppeer.canpush�r�r"c��URRURRURRp2nUR
R
[S5XU4-5 g![a gf=f)NsE(sent %d HTTP requests and %d bytes; received %d bytes in responses)
)r��
requestscount�sentbytescount�receivedbytescountr�rv�noter)r-�reqs�sent�recvs    r r��httppeer.close�sw��	����-�-����.�.����2�2��D�	
�����
�5�
��4� �	
!�	
���	��	�s�AA-�-
A:�9A:c��UR$r4)r�r:s r �capabilities�httppeer.capabilities�s���z�z�r"c��URS5nU(a0UR[R"[	S5U55 gg)Nr�unexpected response:)r>�_abortr�
ResponseErrorr)r-�stream�chunks   r �_finish_inline_clone_bundle�$httppeer._finish_inline_clone_bundle�s8�����A�����K�K��+�+�A�.E�,F��N�O�r"c
�j�[R"U5n[URURUR
URURUUUR5upEn[URURU5n[URURXVXr5uUlp�U$r4)r
�byteskwargsr�rvr�r��capabler�r�r�r�r�)	r-r{�
_compressibler|r�r�r�r��cts	         r �_callstream�httppeer._callstream�s����#�#�D�)��*��G�G�� � ��J�J��L�L��I�I������	
�����4�7�7�D�O�O�S�9��4��G�G�T�Y�Y���
���	�2��r"c��UR"U40UD6nUR5UR5 $!UR5 f=fr4)rr>r�)r-r{r|�fps    r �_call�httppeer._call�s:��
�
�
�c�
*�T�
*��	��7�7�9�
�H�H�J��B�H�H�J�s	�5�Ac���URS5nURS5nSnUHnU[R;dMUn O [R
"URUSU5n[R"URUS5nSS0n	UR"U4X�S.UD6n
U
RSS	5n[U5S
:a [R"[S5U
5eUUR5 [R "U5 $![a S/nN�f=f!["R$a e[&a�nUR(S[*R,[*R.4;a/[R0"[S
5UR(S	-5e[R0"UR(S	5eSnAff=f!UR5 [R "U5 f=f)NsunbundlerYr"�rbrZr[�r~r�
rr�rrspush failed: %s)rrkr�r�bundletypes�writebundlervr	�httpsendfilerrrrrr�rG�unlinkr�r�r�r|�errno�
ECONNRESET�EPIPEr�)
r-r{�cgr|�typesr*�x�tempnamerr�r�vals�errs
             r �	_callpush�httppeer._callpush�s������[�)��	��K�K��%�E����A��G�'�'�'�����
�&�&�t�w�w��D�$�?��
�
(�
(����(�E�
B��!�#>�?��	 ��
�
�3�A�R�A�D�A�A��7�7�5�!�$�D��4�y�1�}��)�)�!�,C�*D�a�H�H��
�H�H�J��I�I�h���E�	��E�E�		��.���	�
��	+��x�x��{�u�/�/����=�=��k�k�!�$6�"7�#�(�(�1�+�"E�F�F��+�+�c�h�h�q�k�*�*��	+��

�H�H�J��I�I�h��s7�D�AD"�
D�D�"G�BG�G�G�(G3c�X�[R"SSS9upE[R"US5nUR	S5nU(a+URU5 UR	S5nU(aM+SSS5 [R"URUS5nSS0n	UR"U4X�S	.UD6sSSS5 [R"U5 $!,(df   Ni=f!,(df   O=f[R"U5 g![R"U5 f=f)
Ns
hg-bundle-s.hg)�prefix�suffix�wbirrZr[r )r
�mkstemprG�fdopenr>�writer	r$rvrr%)
r-r{rr|�fd�filename�fh�d�fp_rs
          r �_calltwowaystream�httppeer._calltwowaystreams����'�'�}�V�L���	 ����2�t�$���G�G�D�M����H�H�Q�K�����
�A��a�%� �,�,�T�W�W�h��F�#�)�+F�G���'�'��O�#�O�$�O�G�F�
�I�I�h��%�$��G�F��F�
�I�I�h���B�I�I�h��s;�D�AC�4*D�C(�7	D�
C%�!D�(
C6�2D�D)c�,�UR"U4SS0UD6$)NrT)r)r-r{r|s   r �_callcompressable�httppeer._callcompressable$s������@�4�@�4�@�@r"c��Uer4rT)r-�	exceptions  r r
�httppeer._abort's���r")r�r�r�r�r�r��F)�returnz
Set[bytes])rNrOrPrQr0r�rr�r�r�r	rrrr0r>rAr
rSr�r�s@r r�r��sT���HM�	*�4����
�*�
P��,�) �V � A��r"r�c�"�\rSrSrSrSSjrSrg)�queuedcommandfuturei+z@Wraps result() on command futures to trigger submission on call.Nc��UR5(a[RRX5$URR5 URU5$r4)�doner�Futurer�
_peerexecutor�sendcommands)r-�timeouts  r r�queuedcommandfuture.result.sE���9�9�;�;��>�>�(�(��7�7����'�'�)��{�{�7�#�#r"rTr4)rNrOrPrQ�__doc__rrSrTr"r rIrI+s
��J�$r"rIc
��SnSn0n[XXEUSU5upxn	[XU5n
[XX�U
SS9up�n
U
R5nU
R
5 URS5(d[R"SU-5eS[UR550nX�4$![aAn
[XXEU
RSU5upxn	[XU5n
[XX�U
SS9up�n
Sn
A
N�Sn
A
ff=f!U
R
5 f=f)Nc�.�[R"S5e)Nsshould not be called)r�ProgrammingError)r+s r r�!performhandshake.<locals>.capable>s���$�$�%<�=�=r"rXF)r�r�sunexpected content-type: %s�v1capabilities)r�r�r�r�r�r>r�rtrrTrlrk)rvrr�rwrxrr|r�r�r�r�r�rr��rawdata�infos                r �performhandshakerY9s���D�>��D�*�
�D�3����O�C���r�3�'�D�
�2��V��E�
���T���)�)�+���
�
��
�=�=�2�3�3��$�$�%C�b�%H�I�I��s�7�=�=�?�3�4�D��=���'�
�.���q�y�y�/�4�
���R��2�s�+��2��V��E�
���T��
��	
�
�
��s"�B$�C2�$
C/�.7C*�*C/�2Dc
��URR(dURR(aV[S5nXQRR=(d URR-n[R
"U5eURR
5upgURSU-5 U=(d [R"X5n[XX#5up�[UUUUUU	SUS9$)aConstruct an appropriate HTTP peer instance.

``opener`` is an ``url.opener`` that should be used to establish
connections, perform HTTP requests.

``requestbuilder`` is the type used for constructing HTTP requests.
It exists as an argument so extensions can override the default.
sunsupported URL component: "%s"s	using %s
rV�r})r�query�fragmentrrr��authinforar�r�rYr�)
rvr�r�rwr}r�rr^r�rXs
          r �
_make_peerr_ns����x�x�~�~����*�*��2�3���x�x�~�~�2����!2�!2�2���k�k�#����H�H�%�%�'�M�C��H�H�]�S�
 �!�
�
2�v�}�}�R�2�F�$�R�f�E�M�G��
������
��!��r"c��U(a[R"[S55eURRS:Xa4[
R(d[R"[S55e[XUS9nU$![RatnURSUR-S9n[R"XU5nUR[S55 UsSnA$![Ra Uef=fSnAff=f)Ns!cannot create new http repositoryshttpss1Python support for SSL and HTTPS is not installedr[sstatic-)�new_raw_locations(falling back to static-http)
)rr�rr�schemer��	has_httpsr_r��copy�rawlocr�	make_peerr)	rvr��create�intents�
createoptsr}r��
httpexceptionr-s	         r rfrf�s�����k�k�!�@�A�B�B� ��8�8�?�?�h�&�v�/?�/?��+�+��F�G��
��"��>������?�?� �	 ��9�9�j�4�;�;�.F�9�G�D��(�(��6�:�A��G�G�A�8�9�:��H�����	 ���	 ��
 �s+�AB�D
�AC+�%D
�+D�D�D
rF)NNF)+�
__future__rr&rhrGr��typing�
concurrentr�i18nrr�rrr	r
rrr�r
r�utilsr�
TYPE_CHECKINGrr�r�rbr!r$r�r�r�r�r��wirepeerr�rLrIrY�requestr_rfrTr"r �<module>rss���#��	�	�
�
���	�	�	��	�����,�,��	
����	
�����:*�*�j�B�JF�R�%�/�/��D �NZ��'�'�Z�z$�'�.�.�$�2�l�&�.�.�u� �HCH� r"

Youez - 2016 - github.com/yon3zu
LinuXploit