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

6�h�F��v�SSKJr SSKrSSKrSSKrSSKJr SSKJrJ	r	J
r
JrJrJ
r
 SSKJrJr \R"r\R$r\R&rSrSrS	rS
r\R0rSr"SS
\R45rSrSrSrSrSr Sr!Sr""SS\R45r#SSjr$"SS5r%g)�)�annotationsN�)�_)�encoding�error�pycompat�util�wireprototypes�wireprotov1server)�compression�
stringutil��sapplication/mercurial-0.1sapplication/mercurial-0.2sapplication/hg-errorc���/nSnURRSX4-5nUcO,UR[R"U55 US-
nMOSRU5$)zbDecode a long value from multiple HTTP request headers.

Returns the value as a bytes, not a str.
rs%s-%d�)�headers�get�appendr�bytesurl�join)�req�headerprefix�chunks�i�vs     �;/usr/lib/python3/dist-packages/mercurial/wireprotoserver.py�decodevaluefromheadersr)si��
�F�	�A�
��K�K�O�O�H��'8�8�9���9���
�
�h�'�'��*�+�	�Q�����8�8�F��rc�|�\rSrSrSr\SSj5rSrSrSr	Sr
\RS5r
S	rS
rSrSrg
)�httpv1protocolhandler�:c�6�XlX lX0lSUlg�N)�_req�_ui�
_checkperm�
_protocaps)�selfr�ui�	checkperms    r�__init__�httpv1protocolhandler.__init__;s���	���#����rc��g)Nshttp-v1��r&s r�name�httpv1protocolhandler.nameAs��rc��UR5n0nUR5nUHInUS:Xa70nUR5HnUS:wdMXt;dMX'SXg'M XcS'M@X%SX5'MK UVs/sHoSUPM	 sn$s snf)N�*�cmdr)�_args�split�keys)r&�args�	knownargs�datar5�k�star�keys        r�getargs�httpv1protocolhandler.getargsEs����J�J�L�	����z�z�|���A��D�y���$�>�>�+�C��f�}���$-�N�1�$5��	�,�"�T�
�#�,�q�/����"&�&��A�Q���&�&��&s�6Bc��URRR5n[URRRSS55nU(aHUR
[RURRRU5SS95 U$[URS5nUR
[RUSS95 U$)N�
X-HgArgs-PostrT)�keep_blank_valuessX-HgArg)r"�qsparams�
asdictoflists�intrr�update�urlreq�parseqs�bodyfh�readr)r&r6�postlen�argvalues    rr3�httpv1protocolhandler._argsTs����y�y�!�!�/�/�1���d�i�i�'�'�+�+�,<�a�@�A����K�K�����I�I�$�$�)�)�'�2�d���
�
�K�)�$�)�)�Z�@�����F�N�N�8�t�N�D�E��rc��URc5[URS5n[UR	S55UlUR$)Ns	X-HgProto� )r%rr"�setr4)r&�values  r�getprotocaps�"httpv1protocolhandler.getprotocapscs;���?�?�"�*�4�9�9�l�C�E�!�%�+�+�d�"3�4�D�O����rc��[URRS5nU[URRRSS55-n[R
"URRUS9$)NsContent-Lengthr?r)�limit)rCr"rrr	�
filechunkiterrG)r&�lengths  r�
getpayload� httpv1protocolhandler.getpayloadisb���T�Y�Y�&�&�'8�9�:��	�#�d�i�i�'�'�+�+�,<�a�@�A�A���!�!�$�)�)�"2�"2�&�A�Arc#�b# �URRnURRn[R"5nX0RlX0RlUv� XRlX Rlg!XRlX Rlf=f7fr!)r#�fout�ferrr	�stringio)r&�oldout�olderr�outs    r�mayberedirectstdio�(httpv1protocolhandler.mayberedirectstdiorsm����������������m�m�o��	#��H�H�M��H�H�M��I�"�H�H�M�"�H�H�M��#�H�H�M�"�H�H�M�s�AB/�$B
�)!B/�
"B,�,B/c��SURR[RURR=(d S5[RURR
=(d S54-$)Nsremote:%s:%s:%sr)r"�	urlschemerE�quote�
remotehost�
remoteuserr-s r�client�httpv1protocolhandler.client�sW��!��I�I����L�L����-�-�4��5��L�L����-�-�4��5�%
�
�	
rc���URS5 URSURRSS5-5 URRSS5(aURS5 URS5 [R
"UR[R5nU(a,SRS	U55nURS
U-5 U$)N�batchs
httpheader=%d�serversmaxhttpheaderlensexperimentalshttppostargsshttpmediatype=0.1rx,0.1tx,0.2tx�,c3�|# �UH2n[RUR5R5v� M4 g7fr!)rErc�wireprotosupportr.)�.0�es  r�	<genexpr>�8httpv1protocolhandler.addcapabilities.<locals>.<genexpr>�s.���"�AL�A����Q�/�/�1�6�6�7�7��s�:<scompression=%s)	rr'�	configint�
configboolr
�supportedcompenginesr�
SERVERROLEr)r&�repo�caps�compengines�	comptypess     r�addcapabilities�%httpv1protocolhandler.addcapabilities�s������H������t�w�w�0�0��<O�P�P�	
��7�7���o��?�?��K�K��(�	
���6�7�$�9�9��G�G�[�+�+�
����	�	�"�AL�"��I�
�K�K�)�I�5�6��rc�$�URU5$r!)r$�r&�perms  rr(�httpv1protocolhandler.checkperm�s�����t�$�$r)r$r%r"r#N��return�bytes)�__name__�
__module__�__qualname__�__firstlineno__r)�propertyr.r<r3rPrV�
contextlib�contextmanagerr_rfrzr(�__static_attributes__r,rrrr:sY�������
'�
��B����#��#�
��0%rrc�(�U[R;$r!)r�commands)�cmds r�iscmdr��s���#�,�,�,�,rc�^^^�SSKJn TRnSTR;agTRSn[	U5(dgTR
(a>UR
S5Ul[URS'URSS-5 g	[TURUUU4S
j5n[UTX'U5 g	!URa�nURHup�X�RU	'M UR
UR[ R""U55UlURS[ R""U5-5 SnAg	SnAff=f)aqPossibly process a wire protocol request.

If the current request is a wire protocol request, the request is
processed by this function.

``req`` is a ``parsedrequest`` instance.
``res`` is a ``wsgiresponse`` instance.

Returns a bool indicating if the request was serviced. If set, the caller
should stop processing the request, as a response has already been issued.
r��commonr2Fi��Content-Type�0
%s
s	Not FoundTc�>�T"TTU5$r!r,)r~r(�rctxrs ���r�<lambda>�#handlewsgirequest.<locals>.<lambda>�s���9�T�3��#=rN)�hgwebr�rvrAr��dispatchpath�
statusmessage�status�HGTYPEr�setbodybytesrr'�	_callhttp�
ErrorResponse�coder
�forcebytestr)r�r�resr(�hgwebcommonrvr��protoror9rs`` `       r�handlewsgirequestr��s1���-��9�9�D�
�S�\�\�!��

�,�,�v�
�C���:�:����� �.�.�s�3��
�'-����O�$�	����l�2�3��!��T�W�W�=�
�E�
B��$��S��-����$�$�B��I�I�D�A��K�K��N�� �.�.�
�F�F�J�+�+�A�.�
��
�
	����j�&=�&=�a�&@�@�A�A���B�s�4C�E�BE�Ec��SUR5;a�U(a[[R"504$[R
"U5n[R"U[R5HWnUR5RU;dM#0nURSSUR5-5nUbXeS'[XE4s $ SURSS50n[[RSU4$)z{Determine the appropriate response type and compression settings.

Returns a tuple of (mediatype, compengine, engineopts).
s0.2rjs%slevelslevels	zliblevelszlib)rP�HGTYPE2r�_noopenginer�clientcompressionsupportr
rtrurmr.rrr�r	rx)r'r��prefer_uncompressed�compformats�engine�opts�levels       r�_httpresponsetyper��s�����#�#�%�%���K�3�3�5�r�9�9�(�@�@��G��$�9�9���&�&�
�F��&�&�(�-�-��<������Y�
�V�[�[�]�0J�K���$�%*��N���,�,�
�"
�b�l�l�9�l�;�<�D��4�#�#�G�,�d�2�2rc�F^^
�SSKJm
 SnSU
U4Sjjn[RR	XC5(dU"[
[[S55 gUR[RUR5 T
RX5n[R"XXG5n[U[5(aU"[
[US9 g[U[R 5(aU"[
[UR"S9 g[U[R$5(aU"[
[UR&S9 g[U[R(5(a_UR&n	[+UR,X8R.5up�nUR1X�5n	U
[2:Xa	U"X�U5n	U"[
X�S9 g[U[R45(a,SUR6UR84-nU"[
[US9 g[U[R:5(a'S	UR6-nS
TlU"[
[US9 g[U[R>5(aU"[
[UR@S9 g[BRD"SU5e)
Nrr�c3��# �UR5RnS[U5s=:aS:de e[R"S[U55v� Uv� UShv�N gN7f)Nr��B)rmr.�len�struct�pack)�genr��
engineoptsr.s    r�genversion2�_callhttp.<locals>.genversion2sY����&�&�(�-�-���3�t�9�"�s�"�"�"�"�"��k�k�$��D�	�*�*��
����s�A!A+�#A)�$A+c��>�U[:XaSTlOTRU5TlUTRS'UbTR	U5 UbTRU5 gg)Ns200 Script output followsr�)�HTTP_OKr�r�rr��
setbodygen)r��contenttype�	bodybytes�bodygenr�r�s    ��r�setresponse�_callhttp.<locals>.setresponse$s\����7�?�5�C�J�$�2�2�4�8�C�J�'2����O�$�� ����Y�'����N�N�7�#�rs:requested wire protocol command is not available over HTTP)r�)r�s%d
%sr�Tshgweb.protocol internal failure)NN)#r�r�rr��commandavailabler��	HGERRTYPErr(�
permission�hashiddenaccess�dispatch�
isinstancer�r�r
�
bytesresponser8�streamreslegacyr��	streamresr�r'r��compressstreamr��pushresr��output�pusherr�drain�ooberror�messager�ProgrammingError)rvrr�r�r�r�r��accesshidden�rspr��	mediatyper�r�r�s  `          @rr�r�s����,��$�$��%�%�6�6�s�B�B����
��
�	
�	�	�O�O�%�.�.�s�3�>�>�?��.�.�t�9�L�
�
$�
$�T�#�
D�C��#�u����G�V�s�3�	�C��5�5�	6�	6��G�V�s�x�x�8�	�C��7�7�	8�	8��G�V�S�W�W�5�	�C��1�1�	2�	2��g�g��):��G�G�U�3�3�)
�%�	�:��#�#�C�4������c�:�6�C��G�Y�4�	�C��/�/�	0�	0��3�7�7�C�J�J�/�/���G�V�s�3�	�C��/�/�	0�	0��3�7�7�"����	��G�V�s�3�	�C��0�0�	1�	1��G�Y�#�+�+�>��$�$�%G��M�Mrc��URS[U5-5 URU5 UR5 g)z-Send a bytes response for protocol version 1.s%d
N)�writer��flush)rYrOs  r�_sshv1respondbytesr�bs,���J�J�w��U��#�$��J�J�u���J�J�Lrc�r�URnURHnU"U5 M
 UR5 gr!)r�r�r�)rY�sourcer��chunks    r�_sshv1respondstreamr�is)���J�J�E�����
�e����J�J�Lrc��URSU-5 UR5 URS5 UR5 g)Ns%s
-
�
)r�r�)rYrZr�s   r�_sshv1respondooberrorr�ps1���J�J�z�C�� ��J�J�L��J�J�u���J�J�Lrc�z�\rSrSrSrSr\SSj5rSrSr	Sr
\RS5r
S	rS
rSrSrg
)�sshv1protocolhandleriwz<Handler for requests services via version 1 of SSH protocol.c�F�XlX lX0l[5Ulgr!)r#�_fin�_foutrNr%)r&r'�finrYs    rr)�sshv1protocolhandler.__init__zs�����	��
��%��rc�"�[R$r!)r
�SSHV1r-s rr.�sshv1protocolhandler.name�s���#�#�#rc��0nUR5n[[U55GHnURR	5SSnUR5upgXc;a"[
R"[S5U-5eUS:Xaz0n[[U55HZn	URR	5SSnUR5upgURR[U55n
X�U'M\ X�S'M�URR[U55n
X�U'GM UV	s/sHo�U	PM	 sn	$s sn	f)N���sunexpected parameter %rr1)
r4�ranger�r��readliner�AbortrrCrH)r&r6r8r5�n�argline�arg�lr:r9�vals           rr<�sshv1protocolhandler.getargs�s
�����z�z�|���s�4�y�!�A��i�i�(�(�*�3�B�/�G��]�]�_�F�C����k�k�!�$>�"?�#�"E�F�F��d�{����s�1�v��A�"�i�i�0�0�2�3�B�7�G�$�]�]�_�F�C��)�)�.�.��Q��0�C� #��I�	'�
"�T�
��i�i�n�n�S��V�,���S�	�"� "&�&��A�Q���&�&��&s�2Ec��UR$r!)r%r-s rrP�!sshv1protocolhandler.getprotocaps�s�����rc#� # �[URS5 [URR	55nU(aJURRU5v� [URR	55nU(aMIgg7f)Nr)r�r�rCr�r�rH)r&�counts  rrV�sshv1protocolhandler.getpayload�sb���	�4�:�:�s�+��D�I�I�&�&�(�)����)�)�.�.��'�'���	�	�*�*�,�-�E��e�s�BB�Bc#�# �Sv� g7fr!r,r-s rr_�'sshv1protocolhandler.mayberedirectstdio�s
����
�s�c�r�[RRSS5RSS5SnSU-$)Ns
SSH_CLIENTrrMrrsremote:ssh:)r�environrr4)r&rfs  rrf�sshv1protocolhandler.client�s7���!�!�%�%�m�S�9�?�?��a�H��K����&�&rc��UR[R:XaURS5 URS5 U$)Ns	protocapsri)r.r
r�r)r&rvrws   rrz�$sshv1protocolhandler.addcapabilities�s1���9�9��,�,�,��K�K��%����H���rc��gr!r,r}s  rr(�sshv1protocolhandler.checkperm�s��r)r�r�r%r#Nr�)r�r�r�r��__doc__r)r�r.r<rPrVr�r�r_rfrzr(r�r,rrr�r�wsV��F� ��$��$�'�*�.� ������'��
rr�c�.�Sn[XU5nUR5(GdqUS:XGa1UR5SSnU(dSnM;[RRX�5n	U	(d[
US5 Mo[R"XX�S9n
URRR5 URRR5 [U
[5(a
[
X:5 GO�[U
[R5(a[
X:R 5 GOJ[U
[R"5(a
[%X:5 GO[U
[R&5(a[%X:5 O�[U
[R(5(a&[
US5 [
USU
R*-5 O�[U
[R,5(a[
X:R*5 Oy[U
[R.5(a![1X0RU
R25 O9[4R6"SU
-5eUS:Xag[4R6"SU-5eUR5(dGMpgg)	Nsprotov1-servingr�sshutdownr)r�s%ds6unhandled response type from wire protocol command: %ssunhandled ssh server state: %s)r��is_setr�rr�r�r�r�r'rYr�rZr�r�r
r�r8r�r�r�r�r�r�r�r�r�rr�)r'rvr�rY�evr��stater��request�	availabler�s           r�
_runsshserverr�s���$
�E� ��$�/�E��i�i�k�k��&�&��l�l�n�S�b�)�G��#���)�2�2�C�C���I��"�4��-��#�,�,��W��C�
�G�G�L�L��� ��G�G�L�L��� ��#�u�%�%�"�4�-��C��!=�!=�>�>�"�4���2��C��!9�!9�:�:�#�D�.��C��!?�!?�@�@�#�D�.��C��!7�!7�8�8�"�4��-�"�4������9��C��!7�!7�8�8�"�4���1��C��!8�!8�9�9�%�d�G�G�S�[�[�A��,�,�1�36�7���
�k�
!���(�(�1�E�9��
�g�i�i�k�krc�*�\rSrSrSSjrSrSrSrg)�	sshserveriNc�4�XlX lX@lX0lgr!)r#�_repo�
_accesshidden�_logfh)r&r'rv�logfhr�s     rr)�sshserver.__init__s�����
�)���rc�L�UR[R"55 gr!)�
serveuntil�	threading�Eventr-s r�
serve_forever�sshserver.serve_forevers�����	���)�*rc	��URR5up#UR(ae[R"URUSSS9n[R"URURR
SSS9URl[
URURUUUUR5 SSS5 g!,(df   g=f)z%Serve until a threading.Event is set.�oT)�logdata�eN)	r#�protectedfinoutrr	�makeloggingfileobjectrZrrr)r&rr�rYs    rr�sshserver.serveuntils���
�X�X�
%�
%�
'�;�C��{�{��1�1��K�K��� �	��!%� :� :��K�K��H�H�M�M�� �	!����
�
�����
�
�����"�"�

�(�
'�
'�s�B'C�
C)rrrr#)NF)r�r�r�r�r)rrr�r,rrrrs���+�rr)F)&�
__future__rr�r�r�i18nr�rrrr	r
r�utilsrr
r[�urlerrrEr�r�r�r�r�r�baseprotocolhandlerrr�r�r�r�r�r�r�r�rrr,rr�<module>r(s���#��
������
�=�=��	
����	
����

��	%��
&��#�	������"g%�N�>�>�g%�\-�C�L!3�HIN�X���D
�>�=�=�D
�NJ�Z"�"r

Youez - 2016 - github.com/yon3zu
LinuXploit