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__/wireprotov1peer.cpython-313.pyc
�

6�h'X��R�SSKJr SSKrSSKrSSKJr SSKJr SSKJ	r	 SSK
JrJr
JrJrJrJrJrJr SSKJr SS	KJr \R2rS
rSr"SS
\R85r"SS\R<5r"SS\R@\RB\RD5r#g)�)�annotationsN)�futures�)�_)�bin)�bundle2�changegroup�encoding�error�pushkey�pycompat�util�wireprototypes)�
repository)�hashutilc�\^�U4Sjn[UST5 [USTR5 U$)a|annotation for batchable methods

Such methods must implement a coroutine as follows:

@batchable
def sample(self, one, two=None):
    # Build list of encoded arguments suitable for your wire protocol:
    encoded_args = [('one', encode(one),), ('two', encode(two),)]
    # Return it, along with a function that will receive the result
    # from the batched request.
    return encoded_args, decode

The decorator returns a function which wraps this coroutine as a plain
method, but adds the original method as an attribute called "batchable",
which is used by remotebatch to split the call into separate encoding and
decoding phases.
c�>�T"U0UD6up#U(dU$USn[R"TR5nURXR5nU"U5$)Nr)r
�bytesurl�__name__�
_submitone)�args�opts�encoded_args_or_res�decode�self�cmd�encoded_res�fs       ��;/usr/lib/python3/dist-packages/mercurial/wireprotov1peer.py�plain�batchable.<locals>.plain5sU���&'��&6��&6�#���&�&��A�w������
�
�+���o�o�c�?���k�"�"��	batchabler)�setattrr)rr s` rr#r#"s+���&#��E�;��"��E�:�q�z�z�*��Lr"c�^�[Rm/nUH_up#[U4SjU55(deSRU4SjUR	555nURSX$4-5 Ma SRU5$)z;Return a ``cmds`` argument value for the ``batch`` command.c3�:># �UHnT"U5U:Hv� M g7f�N�)�.0�k�	escapeargs  �r�	<genexpr>�"encodebatchcmds.<locals>.<genexpr>Ls����7�h��9�Q�<�1�$�h�s��,c3�N># �UHupST"U5T"U54-v� M g7f)s%s=%sNr()r)r*�vr+s   �rr,r-Ns)����
�@P���H�	�!��i��l�3�3�@P�s�"%s%s %s�;)r�escapebatcharg�all�join�items�append)�req�cmds�op�argsdictrr+s     @r�encodebatchcmdsr;Cs����-�-�I�
�D�����7�h�7�7�7�7�7��y�y�
�@H���@P�
�
��	
���H��z�)�*���9�9�T�?�r"c�.�\rSrSr%SrS\S'SSjrSrg)	�unsentfuture�VaA Future variation to represent an unsent command.

Because we buffer commands and don't submit them immediately, calling
``result()`` on an unsent future could deadlock. Futures for buffered
commands are represented by this type, which wraps ``result()`` to
call ``sendcommands()``.
�peerexecutor�
_peerexecutorNc��UR5(a[RRX5$URR5 URU5$r')�doner�Future�resultr@�sendcommands)r�timeouts  rrD�unsentfuture.resultasE���9�9�;�;��>�>�(�(��7�7����'�'�)�
�{�{�7�#�#r"r(r')r�
__module__�__qualname__�__firstlineno__�__doc__�__annotations__rD�__static_attributes__r(r"rr=r=Vs��� ��	$r"r=c�>�\rSrSrSrSrSrSrSrSr	Sr
S	rg
)r?�mc��XlSUlSUl/Ul[R
"5UlSUlSUlg)NF)	�_peer�_sent�_closed�_calls�weakref�WeakSet�_futures�_responseexecutor�
_responsef)r�peers  r�__init__�peerexecutor.__init__ns9���
���
����������)��
�!%�����r"c��U$r'r(�rs r�	__enter__�peerexecutor.__enter__ws���r"c�$�UR5 gr')�close)r�exctype�excvalee�exctbs    r�__exit__�peerexecutor.__exit__zs���
�
�r"c�.^^^^�TR(a[R"S5eTR(a[R"S5e[	TR
[R"T5S5mT(d[R"ST-5eUUUU4Sjn[	TSS5(aU"5n[Ul	TUl
U$TR(a[R"ST-5eU"5nTR5 U$)Ns4callcommand() cannot be used after commands are sents*callcommand() cannot be used after close()sAcannot call command %s: method of same name not available on peerc�>�[R"5nTRRU5 TRRTTTU45 U$r')rrCrW�addrTr6)rr�command�fnrs ����r�addcall�)peerexecutor.callcommand.<locals>.addcall�sA������ �A��M�M���a� ��K�K�����r�1�5�6��Hr"r#FsX%s is not batchable and cannot be called on a command executor along with other commands)
rRr�ProgrammingErrorrS�getattrrQr
�sysstrr=�	__class__r@rTrE)rrkrrmrrls```  @r�callcommand�peerexecutor.callcommand}s�����:�:��(�(�G��
��<�<��(�(�=��
�
�T�Z�Z�����!9�4�
@����(�(��$�%��
�	�	��2�{�E�*�*��	�A�'�A�K�"�A�O����{�{��,�,�:�<C�D���
�	�A�
�����r"c���UR(agUR(dgSUlURH6n[U[5(dM[
RUlSUlM8 URnSUl[U5S:XaMUSup4pQUR5(dgU"S0[R"U5D6nURU5 g/n/nUH�up4pQUR5(dMUR$"UR&40[R"U5D6up�U
(dURU	5 MkUR)X945 UR)X1[$U
45 M� U(dgUR*R-U5n[
R."S5UlUR0R3UR4X�5Ulg![a0 [R"U[ R""5SS5 gf=f![a1 [R"U[ R""5SS5  gf=f)NTrrr()rRrTrW�
isinstancer=rrCrrr@�len�set_running_or_notify_cancelr
�	strkwargs�
set_result�	Exception�future_set_exception_info�sys�exc_infor#�__self__r6rQ�_submitbatch�ThreadPoolExecutorrX�submit�_readbatchresponserY)rr�callsrkrrlrD�requests�statesrr�wireresultss            rrE�peerexecutor.sendcommands�s	���:�:���{�{����
����A��!�\�*�*�%�n�n���"&����
��������u�:��?�#(��8� �G�2��1�1�3�3��
%��7�h�0�0��6�7�����V�$������$)� �G�2��1�1�3�3��
�.0�l�l��K�K�/�#+�#5�#5�d�#;�/�+�#�����0�1����� >�?��
�
�w�9�f�=�>�#%*�&���j�j�-�-�h�7��")�!;�!;�A�!>����0�0�7�7��#�#�V�
����a�
J��2�2�1�c�l�l�n�Q�R�6H�I�
�
J��4�
��2�2�1�c�l�l�n�Q�R�6H�I��
�s$�3G*�3H'�*7H$�#H$�'7I"�!I"c
��UR5 UR(agSUlUR(dgURR5 URceURRSS9 SUlSUlURHInUR5(aMUR[R"[S5S55 MK SUlg!URceURRSS9 SUlSUlURHInUR5(aMUR[R"[S5S55 MK SUlf=f)NT)�wait�"unfulfilled batch command response)rErSrYrDrX�shutdownrWrB�
set_exceptionr�
ResponseErrorr)rrs  rrb�peerexecutor.closesF�������<�<���������	!��O�O�"�"�$��)�)�5�5�5��"�"�+�+��+�6�"�D�O�%)�D�"��]�]���v�v�x�x��O�O��+�+��C�D�d���#�!�D�M���)�)�5�5�5��"�"�+�+��+�6�"�D�O�%)�D�"��]�]���v�v�x�x��O�O��+�+��C�D�d���#�!�D�M�s�C.�.AF�;Fc	�d�UH,up4pV[U5nU"U5nURU5 M. g![a1 [R"U[
R"5SS5 Mkf=f![a3 UR[R"[S5S55 M�f=f)Nrr�)�nextrzr{r
r|r}r~�
StopIterationr�rr�r)	rr�r�rkrr#r�remoteresultrDs	         rr��peerexecutor._readbatchresponse)s���.4�)�G�	�
)�#�K�0��)�#�L�1�F��L�L��(�).4��"!�N��6�6�q�#�,�,�.���:L�M�N��!�
�����'�'��?�@�$���	
�s �A2�4�7A/�.A/�29B/�.B/)rTrSrWrQrXrYrRN)rrHrIrJr[r_rfrsrErbr�rMr(r"rr?r?ms)�����5�nP
�d!!�F)r"r?c���\rSrSrSrSrSrSrSr\	S5r
\	S5r\	S	5r\	S
5r
\	S5r\	S5rS
rSrSrSrSrSrSrSrSrSSjrSrSrSrSrSrSrSr g) �wirepeeriCz�Client-side interface for communicating with a peer repository.

Methods commonly call wire protocol commands of the same name.

See also httppeer.py and sshpeer.py for protocol-specific
implementations of this interface.
c��[U5$r')r?r^s r�commandexecutor�wirepeer.commandexecutorNs
���D�!�!r"c��URS5(aURS5$URS[S55 URS5$)Nsclonebundles_manifestsclonebundless
clone bundles)�capable�_call�
requirecaprr^s r�clonebundles�wirepeer.clonebundlesSsE���<�<�0�1�1��:�:�6�7�7��O�O�O�Q�/?�-@�A��:�:�o�.�.r"c��gr'r()r�streams  r�_finish_inline_clone_bundle�$wirepeer._finish_inline_clone_bundleZs��r"c#�# �URSUS9n[R"U5n[R"X#S9Shv�N UR	U5 gN7f)Nsget_cached_bundle_inline)�path)�limit)�_callstreamr�uvarintdecodestream�
filechunkiterr�)rr�r��lengths    r�get_cached_bundle_inline�!wirepeer.get_cached_bundle_inline]sT����!�!�"=�D�!�I���)�)�&�1���%�%�f�;�;�;��(�(��0�	<�s�>A�A�Ac�z^�TRS[S55 U4SjnS[R"U50U4$)Nslookupslook up remote revisionc�>�USSRSS5up[U5(a[U5$TR[R
"U55 g)N���� r)�split�intr�_abortr�	RepoError)�d�success�datars   �rr�wirepeer.lookup.<locals>.decodejsC����c�r�F�L�L��q�1�M�G��7�|�|��4�y� ����E�O�O�D�1�2r"�key)r�rr
�	fromlocal)r�keyrs`  r�lookup�wirepeer.lookupfs9������	�1�%?�#@�A�	3���*�*�3�/�0�&�8�8r"c�^�U4Sjn0U4$)Nc�>�[R"USS5$![a2 TR[R
"[
S5U55 gf=f)Nr��unexpected response:)r�
decodelist�
ValueErrorr�rr�r)r�rs �rr�wirepeer.heads.<locals>.decodeusP���
P�%�0�0��3�B��8�8���
P����E�/�/��2I�0J�A�N�O�
P�s��9A�Ar(�rrs` r�heads�wirepeer.headsss���	P��6�z�r"c�D^�U4SjnS[R"U50U4$)Nc�>�[R"U5Vs/sHn[[U55PM sn$s snf![a2 TR[R"[S5U55 gf=f)Nr�)	r
�iterbytestr�boolr�r�r�rr�r)r��brs  �rr�wirepeer.known.<locals>.decodesf���
P�.6�.B�.B�1�.E�F�.E���S��V��.E�F�F��F���
P����E�/�/��2I�0J�A�N�O�
P�s�A�<�A�A�9A=�<A=�nodes)r�
encodelist)r�nodesrs`  r�known�wirepeer.known}s&���	P��.�3�3�E�:�;�V�C�Cr"c�^�U4Sjn0U4$)Nc�h>�0nUR5HZnURSS5up4[R"[RU55n[R"U5nXAU'M\ U$![a2 TR[R"[S5U55 gf=f)Nr�rr�)
�
splitlinesr�r
�tolocal�urlreq�unquoterr��	TypeErrorr�rr�r)r��	branchmap�
branchpart�
branchname�branchheadsrs     �rr�"wirepeer.branchmap.<locals>.decode�s����	
P��	�"#�,�,�.�J�.8�.>�.>�t�Q�.G�+�J�!)�!1�!1�&�.�.��2L�!M�J�"0�";�";�K�"H�K�,7�j�)�	#1�
!� ���
P����E�/�/��2I�0J�A�N�O�
P�s�A1A5�59B1�0B1r(r�s` rr��wirepeer.branchmap�s���
	P��6�z�r"c�^^�TRS5(d0S4$TRRST-5 UU4SjnS[R"T50U4$)N�pushkeyspreparing listkeys for "%s"
c�>�TRRST[U54-5 [R"U5$)Ns$received listkey for "%s": %i bytes
)�ui�debugrw�
pushkeymod�
decodekeys)r��	namespacers ��rr�!wirepeer.listkeys.<locals>.decode�s7����G�G�M�M�8�I�s�1�v�;N�N�
��(�(��+�+r"�	namespace�r�r�r�r
r�)rr�rs`` r�listkeys�wirepeer.listkeys�sS����|�|�J�'�'��t�8�O����
�
�6��B�C�	,��h�0�0��;�<�f�D�Dr"c�.^�TRS5(dgTRRSX4-5 U4Sjn[R"U5[R"U5[R"U5[R"U5S.U4$)Nr�)FNspreparing pushkey for "%s:%s"
c�0>�URSS5up[[U55nURS5H(nTRR[
S5U5 M* U$![a! [R
"[
S5U5ef=f)N�
r�"push failed (unexpected response):T�remote: )
r�r�r�r�rr�rr�r��status)r��output�lrs   �rr� wirepeer.pushkey.<locals>.decode�s��������q�)�I�A�
���Q��L��
�&�&�t�,�������q��~�q�1�-��H��
�
��)�)��;�<�a���
�s�A*�*+B)r�r�soldsnewr�)rr�r��old�newrs`     rr�wirepeer.pushkey�s�����|�|�J�'�'�����
�
�8�I�;K�K�L�
	�#�,�,�Y�7��&�&�s�+��&�&�s�+��&�&�s�+�	
�
��	r"c�$�URS5$)Ns
stream_out)r�r^s r�
stream_out�wirepeer.stream_out�s�����
�.�.r"c�N�[R"U5nURS[S55 0nUR	S5=(d
 [5nUR
5H�upVUcM
[RR	U5nUc[R"SU-5eUS:Xa[R"U5nObUS:XaSRU5nOJUS:XaSR[U55nO)US	:XaS
[U5-nOUS:wa[SU-5eXcU'M� UR "S0[R""U5D6n[%S
U55(a![&R("UR*U5$[,R."US5$)N�	getbundle�look up remote changess
bundlecapss$Unexpectedly None keytype for key %sr�scsvr.sscsvsbooleans%isplains unknown getbundle option type %sc3�B# �UHoRS5v� M g7f)sHG2N)�
startswith)r)�caps  rr,�%wirepeer.getbundle.<locals>.<genexpr>�s���<��#�~�~�f�%�%��s��UN)r�)r
�byteskwargsr�r�get�setr5r�GETBUNDLE_ARGUMENTSrror�r4�sortedr��KeyError�_callcompressablery�anyr�getunbundlerr��changegroupmod�cg1unpacker)	r�source�kwargsr�
bundlecapsr��value�keytypers	         r�	getbundle�wirepeer.getbundle�sk���%�%�f�-������a�(A�&B�C����Z�Z�
�.�7�#�%�
� �,�,�.�J�C��}��$�8�8�<�<�S�A�G����,�,�;�c�A����H�$�&�1�1�%�8���F�"��	�	�%�(���G�#��	�	�&��-�0���J�&���U��+���H�$��B�W�L�M�M���I�%)�&
�"�"�L�8�3E�3E�d�3K�L���<��<�<�<��'�'�����3�3�!�-�-�a��7�7r"c
��US/:waiURS5(aS[R"S[R"SR[
U555R5/5nO[R"U5n[US5(a�URSXS9upEUS:Xa [R"[S5U5e[U5nURS
5H(nUR R#[S5U5 M* U$UR%SXS9n[&R("UR U5nU$![a! [R"[S	5U5ef=f)a�Send cg (a readable file-like object representing the
changegroup to push, typically a chunkbuffer object) to the
remote server as a bundle.

When pushing a bundle10 stream, return an integer indicating the
result of the push (see changegroup.apply()).

When pushing a bundle20 stream, return a bundle20 stream.

`url` is the url the client thinks it's pushing to, which is
visible to hooks.
sforcesunbundlehashshashedr"�deltaheadersunbundle)r�spush failed:r�Tr�)r�rr�r�sha1r4r�digest�hasattr�	_callpushrr�rr�r�r�r�r��_calltwowaystreamrr)r�bundler��url�retr�r�r�s        r�unbundle�wirepeer.unbundle�sH���X�J��4�<�<��#@�#@�"�-�-��H�M�M�#�(�(�6�%�=�*A�B�I�I�K�L��E�#�-�-�e�4�E��6�=�)�)��.�.��f�.�J�K�C��c�z��)�)�!�O�*<�f�E�E�
��#�h���&�&�t�,�������q��~�q�1�-��
��+�+�K��+�M�F��&�&�t�w�w��7�C��
���
��)�)��;�<�c���
�s�E�+E9c�V�[R"U5nURSUS9nUR5Vs/sH"n[	[R
"U55PM$ nnU$s snf![a2 UR[R"[S5U55 gf=f)Nsbranches)r�r�)rr�r�r��tupler�r�r�rr�r)rr��nr�r��brs      r�branches�wirepeer.branchess����%�%�e�,���J�J�{�!�J�,��	L�?@�|�|�~�N�~�!�%��1�1�!�4�5�~�B�N��I��O���	L��K�K��+�+�A�.E�,F��J�K�	L�s"�A,�)A'�#A,�'A,�,9B(�'B(c
��Sn/n[S[U5U5HunSRXXB-Vs/sHn[R"US5PM sn5nURSUS9nUR
SUR555 Mw U$s snf![a3 UR[R"[S5U55 M�f=f)	N�rr��-sbetween)�pairsc3�r# �UH-nU=(a [R"U5=(d /v� M/ g7fr')rr�)r)r�s  rr,�#wirepeer.between.<locals>.<genexpr>!s/����+���6�.�3�3�A�6�<�"�<�+�s�57r�)
�rangerwr4rr�r��extendr�r�r�rr�r)rr*�batch�r�i�pr#r�s        r�between�wirepeer.betweens��������q�#�e�*�e�,�A��	�	�#�q�y�1��1��#�-�-�a��6�1���A��
�
�:�Q�
�/�A�
P������\�\�^���-�������
P����E�/�/��2I�0J�A�N�O�
P�s�!B
�*&B�9C�Cc�|�[R"U5nURSUS9n[R"US5$)Nschangegroup)�rootsr)rr�r	rr
)rr�rr#rs     rr	�wirepeer.changegroup)s:���%�%�e�,���"�"�>��"�;���)�)�!�U�3�3r"c���URS[S55 [R"U5n[R"U5nUR	SXS9n[
R"US5$)Nschangegroupsubsetr�)�basesr�r)r�rrr�r	rr
)rr9r�rrs     r�changegroupsubset�wirepeer.changegroupsubset.sf�����,�a�0I�.J�K��)�)�%�0���)�)�%�0���"�"� ��
#�
���)�)�!�U�3�3r"c#��# �URnUR(aSURSS5(a<URS5 UH%up4SnURXS[	U54-5 M' [
RnURS[U5S9nURS5nU/n	U(a�SU;a8U(a1URS5nU	RU5 SU;a	U(aM1S	RU	5n
SU
;a&U
RSS
5up�U"U5v� SU
;aM&URS5nX�/n	U(aM�U"S	RU	55v� g7f)zarun batch request <req> on the server

Returns an iterator of the raw responses from the server.
sdevelsdebug.peer-requests$devel-peer-request: batched-content
s+devel-peer-request:    - %s (%d arguments)
sbatch)r8ir1r"rN)
r��	debugflag�
configboolr�rwr�unescapebatchargr�r;�readr6r4r�)rr7r�r9r�msg�unescapearg�rsp�chunk�work�merged�ones            rr��wirepeer._submitbatch9s:���
�W�W��
�<�<�B�M�M�(�4I�J�J��H�H�=�>����E������C��I��.�/� �%�5�5�����x�o�c�.B��C���������w����e�#�����������E�"��e�#����X�X�d�^�F��&�.�$�l�l�4��3���!�#�&�&��&�.��H�H�T�N�E��?�D��e��#�(�(�4�.�)�)�s�C1E)�5;E)�2E)�E)c�P�UR"U40[R"U5D6$r')r�r
ry)rr9rs   rr�wirepeer._submitoneVs!���z�z�"�9�� 2� 2�4� 8�9�9r"Nc�J�0nUbX6S'UbXFS'UR"SXS.UD6$)N�three�four)rG�two)s
debugwireargs)r�)rrGrNrLrM�fivers       r�
debugwireargs�wirepeer.debugwireargsYs8������!��M�����L��z�z�E��E��E�Er"c��[5e)zvexecute <cmd> on the server

The command is expected to return a simple string.

returns the server reply as a string.��NotImplementedError�rrrs   rr��wirepeer._callbs
��"�#�#r"c��[5e)z�execute <cmd> on the server

The command is expected to return a stream. Note that if the
command doesn't return a stream, _callstream behaves
differently for ssh and http peers.

returns the server reply as a file like object.
rSrUs   rr��wirepeer._callstreamj�
��"�#�#r"c��[5e)aexecute <cmd> on the server

The command is expected to return a stream.

The stream may have been compressed in some implementations. This
function takes care of the decompression. This is the only difference
with _callstream.

returns the server reply as a file like object.
rSrUs   rr	�wirepeer._callcompressableus
��"�#�#r"c��[5e)z�execute a <cmd> on server

The command is expected to be related to a push. Push has a special
return method.

returns the server reply as a (ret, output) tuple. ret is either
empty (error) or a stringified int.
rS�rr�fprs    rr�wirepeer._callpush�rYr"c��[5e)zaexecute <cmd> on server

The command will send a stream to the server and get a stream in reply.
rSr]s    rr�wirepeer._calltwowaystream�s
��
"�#�#r"c��[5e)zBclearly abort the wire protocol connection and raise the exceptionrS)r�	exceptions  rr��wirepeer._abort�s��!�#�#r"r()NNN)!rrHrIrJrKr�r�r�r�r#r�r�r�r�r�rr�rrr%r3r	r:r�rrPr�r�r	rrr�rMr(r"rr�r�Cs����"�
/�
�1��
9��
9������D��D��
��
��E��E�����0/�8�<'�ZL��(4�
4�*�::�F�$�	$�$�	$�$�$r"r�)$�
__future__rr}rU�
concurrentr�i18nr�noder�rr	rr
rrr�r
rr�
interfacesr�utilsrr�r#r;rCr=�ipeercommandexecutorr?rZ�
ipeercommands�ipeerlegacycommandsr�r(r"r�<module>ros���#�
�����	�	�	���	
�����B�&$�7�>�>�$�.S)�:�2�2�S)�lS$��O�O�Z�-�-�z�/M�/M�S$r"

Youez - 2016 - github.com/yon3zu
LinuXploit