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

6�h�h��l�SrSSKJr SSKrSSKrSSKrSSKrSSKJr SSK	J
r
Jr SSKJ
r
JrJrJrJrJrJrJrJrJrJrJrJrJrJrJrJrJrJr  SSK!J"r" SS	KJ#r$ "S
S\R85r%"SS
\%\R5r&"SS\%\RN5r("SS\R*5r)"SS\RT5r+"SS\RX5r-Sr.\/r0\Rb(a\Rdr0"SS\05r3S"Sjr4Sr5"SS5r6"SS5r7S#Sjr8S r9S"S!jr:g)$z�Repository class for viewing uncompressed bundles.

This provides a read-only repository interface to bundles as if they
were part of the actual repository.
�)�annotationsN�)�_)�hex�nullrev)�bundle2�changegroup�	changelog�cmdutil�	discovery�encoding�error�exchange�filelog�	localrepo�manifest�mdiff�pathutil�phases�pycompat�revlog�revlogutils�util�vfs)�urlutil)�	constantsc�^�\rSrSrSSjr\RU4Sj5rU4SjrSr	U4Sjr
SrSrS	r
S
rSrU=r$)
�bundlerevlog�9c�X�[R"U5n[RRXX#S9 X@l[U5nUS-
Ul[5UlUR5GH�nUup�p�p�p�[U
5nUR5U-
nURRU5(a6URRURRU55 MX�:Xa[nOU"U5nX�4HNnURRU5(aM%[ R""UUR$['S55e URRU5(d*[ R""X�R$['S55eURU5n[(R*"UUUUUURU	5URU
5US9nURR-U5 URRU5 US-
nGM� g)N)�target�radixrsunknown parentsunknown delta base)�flags�data_offset�data_compressed_length�data_delta_base�link_rev�parent_rev_1�parent_rev_2�node_id)�vfsmod�readonlyvfsr�__init__�bundle�len�
repotiprev�set�
bundlerevs�	deltaiter�tell�index�has_node�add�revrr�LookupError�
display_idrr�entry�append)�self�openerr!r"�
cgunpacker�
linkmapper�n�	deltadata�node�p1�p2�cs�	deltabase�deltar#�sidedata�size�start�linkrev�p�baserev�es                      �6/usr/lib/python3/dist-packages/mercurial/bundlerepo.pyr-�bundlerevlog.__init__:s����#�#�F�+���
�
���t�F��H� ����I���a�%����%���#�-�-�/�I�BK�?�D�b�i���u�:�D��O�O�%��,�E��z�z�"�"�4�(�(����#�#�D�J�J�N�N�4�$8�9���z�!��$�R�.���X���z�z�*�*�1�-�-��+�+��4�?�?�A�.?�,@�����:�:�&�&�y�1�1��'�'�����2G�0H����h�h�y�)�G��!�!��!�'+� '� �!�X�X�b�\�!�X�X�b�\��	�A�
�J�J���a� ��O�O����"�
��F�A�Q0�c#�># �URS:aSv� g[TU]	5nUv� SSS5 g!,(df   g=f7f)Nr)r0�super�reading)r=�x�	__class__s  �rPrU�bundlerevlog.readingvs1�����?�?�Q������"�a���#�"�"�s�$A�5�	A�
A�Ac�>�XR::a[TU]RU5$URRUR
U55 URRURU55$�N)	r0rT�_inner�_chunkr.�seekrK�read�length)r=r8rWs  �rPr\�bundlerevlog._chunk~s\����/�/�!��7�>�(�(��-�-���������C��)��{�{������C� 0�1�1rRc�v�XR:�a8X R:�a)URUSnX1:XaURU5$O>XR::a/X R::a [RR	XU5$[
R"URU5URU55$)z1return or calculate a delta between two revisions�)r0r5r\r�revdiffr�textdiff�rawdata)r=�rev1�rev2�revbs    rPrc�bundlerevlog.revdiff�s����/�/�!�d�_�_�&<��:�:�d�#�A�&�D��|��{�{�4�(�(��
�_�_�
$����)@��=�=�(�(��T�:�:��~�~�d�l�l�4�0�$�,�,�t�2D�E�ErRc�t>�UcURU5nSnSn/nUnX`R:�a�URR(a7URRSU:XaURRSnO4UR	U5 UR
USnX`R:�aM�U[:XaSnO'Uc$[T
U]!URU5U5nUup�nU(aSnU(a?URUR55n	[R"XI/5nU(aM?X$U4$)NFr�rbrR)r8r0r[�_revisioncacher<r5rrT�_rawtextrCr\�popr�patches)r=rCr8�	validated�rawtext�chain�iterrev�r�__rHrWs          �rPrm�bundlerevlog._rawtext�s����;��(�(�4�.�C��	����������'����*�*��K�K�.�.�q�1�W�<��+�+�4�4�Q�7����L�L��!��j�j��)�!�,�G����'��g���G�
�_��� ��	�	�'�"���A�&'�"�B����I���K�K��	�	��,�E��m�m�G�W�5�G��e��Y�&�&rRc��[erZ��NotImplementedError�r=�args�kwargss   rP�addrevision�bundlerevlog.addrevision����!�!rRc��[erZrxrzs   rP�addgroup�bundlerevlog.addgroup�rrRc��[erZrxrzs   rP�strip�bundlerevlog.strip�rrRc��[erZrx�r=s rP�	checksize�bundlerevlog.checksize�rrR)r.r2r0)r>z
typing.Any)�__name__�
__module__�__qualname__�__firstlineno__r-�
contextlib�contextmanagerrUr\rcrmr}r�r�r��__static_attributes__�
__classcell__�rWs@rPrr9sU���:� �:�x������2�
F�'�@"�"�"�"�"rRrc��\rSrSrSrSrg)�bundlechangelog�c��[RRX5 Sn[RUU[RS4UR
UU5 g)Nc��U$rZ�)rVs rP�<lambda>�*bundlechangelog.__init__.<locals>.<lambda>�s��qrR)r
r-r�revlog_constants�KIND_CHANGELOGr")r=r>r?r@s    rPr-�bundlechangelog.__init__�sJ�����$�$�T�2� �
������
�
,�
,�d�3��J�J���
	
rRr�N�r�r�r�r�r-r�r�rRrPr�r��s��

rRr�c�6^�\rSrSrSSjrU4SjrSrU=r$)�bundlemanifest��c�<�[RRXX&S9 [RUU[R
U4URRUU5 Uc10nURRS:Xa[UR5nXPlX@lg)N)�trees03)
r�manifestrevlogr-rr��KIND_MANIFESTLOG�_revlogr"r.�version�_getfilestarts�
_dirlogstarts�_linkmapper)r=�
nodeconstantsr>r?r@�dirlogstarts�dirs       rPr-�bundlemanifest.__init__�s���	���(�(��f�(�O������
�
.�
.��4��L�L�����
	
����L��{�{�"�"�e�+�-�d�k�k�:��)��%�rRc	�>�XR;ahURRURU5 [URUR
URURURUS9$[TU]!U5$)N)r�)	r�r.r]r�r�r>r�rT�dirlog)r=�drWs  �rPr��bundlemanifest.dirlog�sv����"�"�"��K�K���T�/�/��2�3�!��"�"�������� � ��"�"��
�
��w�~�a� � rR)r�r�)NrR)r�r�r�r�r-r�r�r�r�s@rPr�r��s�����&�6!�!rRr�c��\rSrSrSrSrg)�
bundlefilelog�c��[RRXU5 [U[RU4UR
RUUS9Ulg)N)r!r"r?r@)rr-rr��KIND_FILELOGr�r")r=r>�pathr?r@s     rPr-�bundlefilelog.__init__�sF����� � ��t�4�#��$�1�1�4�8��,�,�$�$�!�!�

��rR)r�Nr�r�rRrPr�r��s��	
rRr�c��\rSrSrSrSrg)�
bundlepeeric��g�NFr�r�s rP�canpush�bundlepeer.canpush���rRr�N)r�r�r�r�r�r�r�rRrPr�r�s��rRr�c�>^�\rSrSrU4SjrSrSrSSjrSrU=r	$)�bundlephasecachei
c�>�[TU]"U0UD6 [US5(a&[R"UR
5Ulgg)Nr>)rTr-�hasattrr+r,r>)r=r{r|rWs   �rPr-�bundlephasecache.__init__s=���
���$�)�&�)��4��"�"� �,�,�T�[�[�9�D�K�#rRc��[erZrx)r=�repos  rP�write�bundlephasecache.writerrRc��[erZrx)r=r��fps   rP�_write�bundlephasecache._writerrRc�\�X0RU'U(aUR5 SUlg)NT)�_phaseroots�
invalidate�dirty)r=r��phase�newroots�trr�s      rP�_updateroots�bundlephasecache._updaterootss$��"*�������O�O����
rR)r�r>)T)
r�r�r�r�r-r�r�r�r�r�r�s@rPr�r�
s���:�
"�"��rRr�c�^�0n[TR05H1nUSnTR5X'[U4Sj05HnM M3 U$)Nsfilenamec�&>�TRS5$rZ)�
deltachunk)r?s�rPr�� _getfilestarts.<locals>.<lambda>"s���*�"7�"7��"=rR)�iter�
filelogheaderr4)r?�filespos�	chunkdata�fname�chunks`    rPr�r�sT����H��*�2�2�B�7�	��+�&��$�/�/�+����=�r�B�E��C�8�
�OrRc�@^�\rSrSrSrSrSrSrSrSSjr	\
RS5r\
RS	5r
S
r\
RS5rSr\
RS
5r\
RS5rSrU4SjrSrSrSSjrSrSU4SjjrSrU=r$)�bundlerepositoryi-aA repository instance that is a union of a local repo and a bundle.

Instances represent a read-only repository composed of a local repository
with the contents of a bundle file applied. The repository instance is
conceptually similar to the state of a repository after an
``hg unbundle`` operation. However, the contents of the bundle are never
applied to the actual base repository.

Instances constructed directly are not usable as repository objects.
Use instance() or makebundlerepository() to create instances.
c�r�X0lX lURRSSSS5 0UlSUlSUlSUl[R"US5n[R"URXA5n[U[R5(a�XPlSnURSS9H]nUR S:XaUR#XW5 M&UR S	:XdM8U(a[%S
5eUnUR'XW5 M_ U(d[(R*"[-S55eUR/S[0R25 g[U[4R65(aUR9XQ5 g[(R*"[-S
5[!U5-5e)N�phasesspublishFs
bundlerepo�rbT)�seekable�phase-heads�changegroups#can't process multiple changegroupssNo changegroups foundrsbundle type %r cannot be read)�_tempparent�_url�ui�	setconfig�_cgfilespos�_bundlefile�_cgunpacker�tempfiler�	posixfiler�
readbundle�
isinstancer�
unbundle20�	iterparts�type�_handle_bundle2_phase_partry�_handle_bundle2_cg_partr�Abortrr]�os�SEEK_SETr	�cg1unpacker�_handle_bundle1)r=�
bundlepath�url�
tempparent�fr.�cgpart�parts        rPr-�bundlerepository.__init__:sb��%���	������)�Z��
�F������������
��N�N�:�u�-���$�$�T�W�W�a�<���f�g�0�0�1�1�%���F��(�(�$�(�7���9�9��.��3�3�F�A��Y�Y�.�0��1�B���"�F��0�0��>�8���k�k�!�$<�"=�>�>�
�K�K��2�;�;�'�
��� 7� 7�
8�
8�� � ��4��+�+��2�3�d�6�l�B��
rRc
��UR5(aGURURSSS9n[R"UR
X2UR5nXlXlURRS-Ul[R"US[RXRSVs/sHoDR5PM sn5 gs snf)Ns.hg10un�HG10UN)�headerr)�
compressed�_writetempbundler^rr�r�rr�r�r
r0�firstnewrevr�retractboundary�draftrC)r=r.r�r�ctxs     rPr�� bundlerepository._handle_bundle1hs���������%�%�f�k�k�:�i�%�P�A��(�(����!����J�F�!��!���>�>�4�4�q�8���������L�L�#'�(8�(8�(:�#;�<�#;�C�X�X�Z�#;�<�		
��
=s�8Cc
�T�URS:XdeUnURRS5n[U5nUc[
RnU[
R;a%[S5nXT-n[R"U5eURRSS5n[R"U5nXg;a#[S5n[R"X�-5eUR5(aURURSU-5n[R "XcS5UlUR$R&S	-Ul[
R*"USUXR(SV	s/sHo�R-5PM sn	5 g![a GNef=fs sn	f)
Nr�stargetphasesunsupported targetphase: %dsversions01s#Unsupported changegroup version: %ss.cg%sunsUNr)r��params�get�int�	TypeErrorrr�	allphasesrrr�r	�supportedincomingversionsrr	r^�getunbundlerr�r
r0r
rrC)
r=r.r�cgstream�targetphase�mr��legalcgvers�msgr
s
          rPr��(bundlerepository._handle_bundle2_cg_partxsi���y�y�N�*�*�*����k�k�o�o�n�5��	��k�*�K��� �,�,�K��f�.�.�.��0�1�A�
��A��+�+�a�.� ��+�+�/�/�*�e�4��!�;�;�D�A���%��:�;�C��+�+�c�m�,�,�������,�,�T�Y�Y�
�W�8L�M�H�&�3�3�G�u�M����>�>�4�4�q�8���������#'�(8�(8�(:�#;�<�#;�C�X�X�Z�#;�<�		
��'�	��	��.
=s�F�3F%�
F"�!F"c��URS:XdeUR5n[R"U5n[R"USU5 g)Nr�c��grZr�r�rRrPr��=bundlerepository._handle_bundle2_phase_part.<locals>.<lambda>�s��$rR)r��
unfilteredr�binarydecode�updatephases)r=r.r�unfi�headsbyphases     rPr��+bundlerepository._handle_bundle2_phase_part�sB���y�y�N�*�*�*���� ���*�*�4�0�����D�,��=rRc�Z�URRSUS9upEXPl[R"US5nURU5 U"S5nU(dOURU5 M#SSS5 URR
URSS9$!,(df   N2=f)zWrite a temporary file to disks
hg-bundle-)�prefix�suffix�wbiNr�)�mode)r�mkstempr�r��fdopenr��open)r=�readfnr(r�fdtemp�temp�fptempr�s        rPr	�!bundlerepository._writetempbundle�s����x�x�'�'�}�V�'�L����
�
�Y�Y�v�t�
$���L�L�� ���u�
�������U�#�	�%��x�x�}�}�T�]�]��}�7�7�%�
$�s�6B�
B*c�,�[XR5$rZ)r��_phasedefaultsr�s rP�_phasecache�bundlerepository._phasecache�s����&9�&9�:�:rRc��URR5 [URUR5nURR	5UlU$rZ)r��changelogheaderr��svfsr4�manstart)r=�cs  rPr
�bundlerepository.changelog�sG��	
���(�(�*��D�I�I�t�'7�'7�8���(�(�-�-�/��
��rRc��grZr�r�s rP�_refreshchangelog�"bundlerepository._refreshchangelog�s��	
rRc��URRUR5 URR5 UR	5R
Rn[URURURU5nURR5Ul[R"URXUR55$rZ)r�r]r:�manifestheaderr r
r8r�r�r9r4�	filestartr�manifestlog�narrowmatch)r=r@�	rootstores   rPrC�bundlerepository.manifestlog�s��������d�m�m�,����'�'�)��_�_�&�0�0�4�4�
�"�����	�	�4�+;�+;�Z�
�	��)�)�.�.�0����#�#��I�I�t��(8�(8�(:�
�	
rRc��URRUR5 URR5 URR	5HnM URR5Ulg)z_Consumes the manifest portion of the bundle, setting filestart so the
file portion can be read.N)r�r]r:rAr3r4rB)r=rHs  rP�_consumemanifest�!bundlerepository._consumemanifest�s`��	
�����d�m�m�,����'�'�)��%�%�/�/�1�E��2��)�)�.�.�0��rRc�2�UR UR$rZ)r
r:r�s rPr:�bundlerepository.manstart�s������}�}�rRc�r�UR SUR;aUR5 UR$)NrB)rC�__dict__rHrBr�s rPrB�bundlerepository.filestart�s/������d�m�m�+��!�!�#��~�~�rRc��UR$rZ)r�r�s rPr��bundlerepository.url�s���y�y�rRc�>�UR(d?URRUR5 [	UR5UlXR;amURRURU5 UR5RRn[URXRU5$[TU]-U5$rZ)r�r�r]rBr�r r
r8r�r9rT�file)r=rr@rWs   �rPrR�bundlerepository.file�s����������!�!�$�.�.�1�-�d�.>�.>�?�D��� � � ����!�!�$�"2�"2�1�"5�6����*�4�4�8�8�J� ����A�/?�/?��L�L��7�<��?�"rRc��URR5 URb%URR	UR5 UR
(a"[R"UR
S5 gg)z'Close assigned bundle file immediately.NT)r��closer�r�unlinkr��shutil�rmtreer�s rPrU�bundlerepository.close�sT������� ��=�=�$��H�H�O�O�D�M�M�*�����M�M�$�*�*�D�1�rRc��gr�r�r�s rP�cancopy�bundlerepository.cancopyr�rRc��[XUS9$)N)r��remotehidden)r�)r=r�r^s   rP�peer�bundlerepository.peers���$��E�ErRc�,�[R"5$rZ)r
�getcwdr�s rPrb�bundlerepository.getcwds����� � rRc��>�UcURnURRU5nURRU5n[S5nURRU:a'UR
R
U[U5-5 URRU:a'UR
R
U[U5-5 [TU]%X5$)Ns9setting parent to node %s that only exists in the bundle
)
�nullidr
r8rr0r��warnrrT�
setparents)r=rDrE�p1rev�p2revrrWs      �rPrg�bundlerepository.setparents
s����
�:����B����"�"�2�&�����"�"�2�&���M�N���>�>�$�$�u�,��G�G�L�L��s�2�w��'��>�>�$�$�u�,��G�G�L�L��s�2�w��'��w�!�"�)�)rR)	r�r�r�r�r�rBr
r:r�)rRr�rZ)r�r�r�r��__doc__r-r�r�r�r	r�unfilteredpropertycacher5r
r>rCrHr:rBr�rRrUr[r_rbrgr�r�r�s@rPr�r�-s����
�,�\
� 
�@>�
8��&�&�;�'�;��&�&��'��
�
�&�&�
�'�
�1��&�&��'���&�&�
�'�
��
#�2��F�!�
*�
*rRr�c�x�U(a[R"[S55eURSS5nU(d.[R
"[R"55nUcSnU(aW[R"5nXV:XaSnO:[R"U5nURU5(aU[U5Sn[R"U5nUR5nURS:Xa,UR!SS5n[U5S:XaXXSp�OUup�OXQp�[#X	U
5$)Ns#cannot create new bundle repositorysbundlesmainreporootrR�+rr)rr�r�configr�findrepor
rbr�normasprefix�
startswithr/rr��	localpath�scheme�split�makebundlerepository)r�r��create�intents�
createopts�
parentpath�cwd�u�s�repopath�
bundlenames           rP�instancer�s��
��k�k�!�B�C�D�D����9�o�6�J���%�%�h�o�o�&7�8�
����J���o�o������J��'�'��,�C��$�$�S�)�)�'��C��
�3�
����D��A��;�;�=�D��x�x�9���J�J�t�Q����q�6�Q�;�#-��t�j�#$� �H�j�)�*���j�9�9rRc���U(aS[R"U5U4-nOSU-n[R"XSS9nSn"SS[UR5nXdl
[RXBX55 U$![R
a e[RaS [R"5n[R"XSS9nN�![a [R"U5 ef=ff=f)	z?Make a bundle repository object based on repo and bundle paths.sbundle:%s+%ss	bundle:%sF)rwNTc��\rSrSrSrg)�5makebundlerepository.<locals>.derivedbundlerepositoryiXr�N)r�r�r�r�r�r�rRrP�derivedbundlerepositoryr�Xs��rRr�)r�
expandpathrr�r�RequirementError�	RepoErrorr�mkdtemp�	ExceptionrWrXr�rWr-)r�r~r�r�r�rr�s       rPrvrv9s���������!:�J� G�G���Z�'����!�!�"�u�=���
�
�"2�D�N�N�
�-�N����d��@��K��!�!�!��
��?�?���%�%�'�
�	��%�%�b�T�B�D���	��M�M�*�%��	��	�s�A9�9=C4�7C�"C0�0C4c�&�\rSrSrSrSrSrSrg)�bundletransactionmanageriac��grZr�r�s rP�transaction�$bundletransactionmanager.transactionbs��rRc��[erZrxr�s rPrU�bundletransactionmanager.closeerrRc��[erZrxr�s rP�release� bundletransactionmanager.releasehrrRr�N)r�r�r�r�r�rUr�r�r�rRrPr�r�as���"�"rRr�c� �\rSrSrSrSrSrg)�getremotechanges_state_trackerilc�z�SUlSUlXlUR5UlX lX0lX@lgrZ)r.�
bundlerepor_�localr�incoming�common�rheads)r=r_r�r�r�s     rPr-�'getremotechanges_state_tracker.__init__ms5���������	�������!�
����rRc��UR(aURR5 UR(a [R"UR5 UR
R5 g!UR
R5 f=f!UR(a [R"UR5 UR
R5 f!UR
R5 f=f=frZ)r�rUr.r�rVr_r�s rP�cleanup�&getremotechanges_state_tracker.cleanup~s���	"�������%�%�'�
"��;�;��I�I�d�k�k�*��	�	���!���	�	���!��	
"��;�;��I�I�d�k�k�*��	�	���!���	�	���!�s.�+B�1A:�:B�D�1C'�D�'D�D)r.r�r�r�rr_r�N)r�r�r�r�r-r�r�r�rRrPr�r�ls���"	"rRr�c��[R"XX5S9nUupxn	U(d-U(a[R"U5 U/UR
4$[
U5n
U	Vs/sHo�U
;dM
UPM n	n[X(Xy5n[X�XUS9n
URX�R4$![a Nof=fs snf! UR5 e=f)aobtains a bundle of changes incoming from peer

"onlyheads" restricts the returned changes to those reachable from the
  specified heads.
"bundlename", if given, stores the bundle to this file path permanently;
  otherwise it's stored to a temp file and gets deleted again when you call
  the returned "cleanupfn".
"force" indicates whether to proceed on unrelated repos.

Returns a tuple (local, csets, cleanupfn):

"local" is a local repo from which to obtain the actual incoming
  changesets; it is a bundlerepo for the obtained bundle when the
  original "peer" is remote.
"csets" lists the incoming changeset node ids.
"cleanupfn" must be called without arguments when you're done processing
  the changes; it closes both the original "peer" and the one returned
  here.
)�heads�force�r�	onlyheads)r�findcommonincomingr�rV�OSErrorrUr1r��_getremotechanges_slowpathrr�)r�r�r_r�rr��tmpr�r�r��	commonsetrV�state�csetss              rP�getremotechangesr��s���,�
&�
&�t��
P�C�"��F�f��	���	�	�*�%��R����#�#��F��I��
6��A�I�#5�a��F�
6�*�4�6�J�E��*��t�i�
������
�
�6�6���	��	��
7���
�
�
��
�s)�B#�	B3�+B3�"B8�#
B0�/B0�8Cc���URSS5nSU;=(a SU;nU(+=(a= URRS5=(a URRS5nU(a�URR5nUR	SSUR
UR[R"USS9S	S
.5R5n	[R"XR5U5=o�l
SSS5 GO�URRS5(a\URR5nUR	SSUR
URS.5R5nSSS5 O�UcxURRS5(dXURR5nUR	S
URSS.5R5nSSS5 SUlO[URR5nUR	SURURSS.5R5nSSS5 UR(aSnOSn[ R""UWX<5=o�l
U(aSUl
W
$!,(df   N=f!,(df   Nc=f!,(df   N�=f!,(df   N�=f)Nsdevelslegacy.exchangesbundle2sbundle1s	getbundlesincomingsclient)�roleT)�source�common�headss
bundlecapsscg)r�r�r�schangegroupsubsetr�)snodesr�)sbasesr�r�sHG10BZr)�
configlistr_�capable�commandexecutor�callcommandr�r�r�
caps20to10�resultr	�writechunks�_forwardchunksr.r�rr�writebundle)
r�r�r�rr��legexc�forcebundle1�
canbundle2rO�b2r��cg�
bundletypes
             rP�_create_bundler��sn���]�]�8�%7�
8�F��V�+�D�
�f�0D�L���	+��J�J���|�,�	+��J�J���z�*��
�
�Z�Z�
'�
'�
)�Q�����*�$�|�|�#�l�l�#+�#6�#6�t�)�#L���	��f�h�
�$/�#:�#:��%�%�'��$�
�E�L�*�
)� �:�:���l�+�+����+�+�-���]�]� �#.�#(�<�<�"'�,�,����&�(��.�-��
�u�z�z�'9�'9�:N�'O�'O����+�+�-���]�]�"�"'�.�.�#.����&�(�
�.� �E�L����+�+�-���]�]�(�"'�.�.�"'�,�,�#.����&�(��.��?�?�"�J�"�J�&�2�2���J� 
�	
��������L�{*�
)��".�-��.�-��.�-�s1�A9J)�
9J:�.K�$9K�)
J7�:
K�
K�
K*c��U(dUR(d`[UUUUUS9nUR(dB[URURU5=UlUlUR
5UlUR(aURR5UlURRRURUR5nUR
(a�UR
nXwRSVs/sHo�R5PM n	nURR5n
U
R!SSS05R#5nSSS5 [$R&"XpRSU	S9n[)5Ul[$R,"UW5 U$s snf!,(df   N[=f)Nr�slistkeyss	namespacer�)r�r�)rr�rv�baseui�rootr�r�r�r r
�findmissingr�r
rCr_r�r�r�r�
pulloperationr��	trmanager�_pullapplyphases)
r�r�r�rr�r�r�r�r
�	reponodesrO�remotephases�pullops
             rPr�r�sh����������!��
�����1E����T�Y�Y��2�
�E�O�e�.�
 �:�:�<�E�L���� �/�/�4�4�6����O�O�%�%�1�1�%�,�,����M�E�����%�%�
�+5�6L�6L�6N�+O�P�+O�C�X�X�Z�+O�	�P�
�Z�Z�
'�
'�
)�Q��=�=�� �)���
�f�h�
�*��'�'��
�
��Y�
��4�5����!�!�&�,�7��L��!Q�
)�
)�s�F8�#F=�=
G)NN)NNF);rk�
__future__rr�r�rW�typing�i18nrrCrr�rr	r
rrr
rrrrrrrrrrrrrr+�utilsrrr�rr�r�r�r��	localpeerr��
phasecacher�r��object�_bundle_repo_baseclass�
TYPE_CHECKING�localrepositoryr�r�rvr�r�r�r�r�r�rRrP�<module>r�s*���#��	�
�
���
������*��
D"�6�=�=�D"�N
�l�I�$7�$7�
�'!�\�8�#:�#:�'!�T

�G�O�O�

���$�$��
�v�(�(��&� ��	���&�6�6��g*�-�g*�T:�D%�P"�"�"�"�><A�,�^I�Z15�.rR

Youez - 2016 - github.com/yon3zu
LinuXploit