korsygfhrtzangaiide
Elepffwdsff
/
lib64
/
python2.7
/
site-packages
/
mercurial
/
Upload FileeE
HOME
� Hq�Qc @ s� d Z d d l m Z d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d e j f d � � YZ d e e j f d � � YZ d e e j f d � � YZ d e e j f d � � YZ d e j f d � � YZ d e j f d � � YZ d � Z d d e d � Z d S( s� Repository class for viewing uncompressed bundles. This provides a read-only repository interface to bundles as if they were part of the actual repository. i����( t nullid( t _Nt bundlerevlogc B sY e Z d � Z d � Z d � Z d � Z d d d d � Z d � Z d � Z d � Z RS( c C s t j | � } t j j | | | � | | _ t | � } | d | _ d } t � | _ x�t r| j | � } | s{ Pn | d } | d } | d } | d } | d } | d } t | � } | j � | } | | � } | | j k r| } | j j | j | � q\ n xD | | f D]6 } | | j k r t j | | j t d � � � q q W| | j k r�t | | j t d � � � n | j | � } t j | d � | d | | | j | � | j | � | f } | j j d | � | | j | <| j j | � | } | d 7} q\ Wd S( Ni t nodet p1t p2t cst deltabaset deltas unknown parents unknown delta basei i����( t scmutilt readonlyvfst revlogt __init__t bundlet lent repotiprevt Nonet sett bundlerevst Truet deltachunkt tellt nodemapt addt errort LookupErrort indexfileR t revt offset_typet indext insert( t selft openerR R t linkmappert nt chaint chunkdataR R R R R R t sizet startt linkt pt baserevt e( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR sN ! c C sT | | j k r" t j j | | � S| j j | j | � � | j j | j | � � S( N( R R t _chunkR t seekR& t readt length( R R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR+ L s c C s� | | j k rK | | j k rK | j | d } | | k r | j | � Sn4 | | j k r | | j k r t j j | | | � St j | j | j | � � | j | j | � � � S( s1 return or calculate a delta between two revisionsi ( R R R+ R t revdifft mdifft textdifft revisionR ( R t rev1t rev2t revb( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR/ U s c C sC t | t � r' | } | j | � } n | } | j | � } | t k rL d Sd } g } | } x^ | | j k r� | j r� | j d | k r� | j d } Pn | j | � | j | d } qa W| d k r� t j j | | � } n x4 | r| j | j � � } t j | | g � } q� W| j | | | � | | | f | _ | S( sT return an uncompressed revision of a given node or revision number. t i i i N( t isinstancet intR R R R R t _cachet appendR R R2 R+ t popR0 t patchest _checkhash( R t nodeorrevR R t textR# t iterrevR ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR2 b s0 c C s t � d S( N( t NotImplementedError( R R? t transactionR' R R t d( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt addrevision� s c C s t � d S( N( RA ( R t revsR! RB ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt addgroup� s c C s t � d S( N( RA ( R R t minlink( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt strip� s c C s t � d S( N( RA ( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt checksize� s N( t __name__t __module__R R+ R/ R2 R RD RF RH RI ( ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR s 7 # t bundlechangelogc B s e Z d � Z RS( c C s< t j j | | � d � } t j | | | j | | � d S( Nc S s | S( N( ( t x( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt <lambda>� s ( t changelogR R R ( R R R R! ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR � s ( RJ RK R ( ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRL � s t bundlemanifestc B s e Z d � Z RS( c C s3 t j j | | � t j | | | j | | � d S( N( t manifestR R R ( R R R R! ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR � s ( RJ RK R ( ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRP � s t bundlefilelogc B s e Z d � Z d � Z RS( c C s? t j j | | | � t j | | | j | | � | | _ d S( N( t filelogR R R t _repo( R R t pathR R! t repo( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR � s c C s | j j | � d S( N( RT t file( R t f( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt _file� s ( RJ RK R RY ( ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRR � s t bundlepeerc B s e Z d � Z RS( c C s t S( N( t False( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt canpush� s ( RJ RK R\ ( ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRZ � s t bundlerepositoryc B s� e Z d � Z e j d � � Z e j d � � Z e j d � � Z e j d � � Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s� d | _ y t j j | | | � WnR t j k rw t j � | _ t j | | j d � t j j | | | j � n X| j j d d t � | r� d t j | � d | | _ n d | | _ d | _ t j | d � } t j | | � | _ | j j � r�t j d d d d d | j � \ } } | | _ t j | d � } zG | j d � x3 t r�| j j d � } | sxPn | j | � qVWWd | j � Xt j | j d � } t j | | � | _ n i | _ d S( Ni t phasest publishs bundle:t +t rbt prefixs hg-bundle-t suffixs .hg10unt dirt wbt HG10UNi i i ( R t _tempparentt localrepot localrepositoryR R t RepoErrort tempfilet mkdtempt instancet uit setconfigR[ t utilt expandpatht _urlt posixfilet changegroupt readbundleR t compressedt mkstempRU t ost fdopent writeR R- t closet bundlefilespos( R Rn RU t bundlenameRX t fdtempt tempt fptempt chunk( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR � s< ! c C s8 | j j � t | j | j � } | j j � | _ | S( N( R t changelogheaderRL t sopenerR t manstart( R t c( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRO � s c C sT | j j | j � | j j � t | j | j | j j � } | j j � | _ | S( N( R R, R� t manifestheaderRP R� RO R R t filestart( R t m( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRQ � s c C s | j | j S( N( RO R� ( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR� � s c C s | j | j S( N( RQ R� ( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR� � s c C s | j S( N( Rr ( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt url� s c C s� | j s� | j j | j � xo t r� | j j � } | s> Pn | d } | j j � | j | <x& t r� | j j d � } | sa Pqa qa Wq Wn | | j k r� | j j | j | � t | j | | j | j j | � St j | j | � Sd S( Nt filename( R| R R, R� R t filelogheaderR R R RR R� RO R RS ( R RX R$ t fnameR� ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRW � s" c C sR | j j � | j d k r/ t j | j � n | j rN t j | j t � n d S( s' Close assigned bundle file immediately.N( R R{ Rk R Rx t unlinkRg t shutilt rmtreeR ( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR{ s c C s t S( N( R[ ( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt cancopy s c C s t | � S( N( RZ ( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt peer s c C s t j � S( N( Rx t getcwd( R ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR� s ( RJ RK R Rh t unfilteredpropertycacheRO RQ R� R� R� RW R{ R� R� R� ( ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR] � s ( c C sU | r t j t d � � � n | j d d d � } | sf t j t j � � } | d k rf d } qf n | r� t j � } | | k r� d } q� t j j | d � } | j | � r� | t | � } q� n t j | � } | j � } | j d k r8| j d d � } t | � d k r)| | d } } qE| \ } } n | | } } t | | | � S( Ns# cannot create new bundle repositoryR t mainreporootR6 R` i i ( Rp t AbortR t configt cmdutilt findrepoRx R� R RU t joint startswithR R� t localpatht schemet splitR] ( Rn RU t createt parentpatht cwdt ut st repopathR} ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRm s. c s� t j | � d | d | �} | \ } } } | sq y | rL t j | � n Wn t k r` n X| g � j f Sd � d � � j � } | s� | r}� j d � r� � j d d | d | �} nL | d k r� � j d � r� � j | d � } d } n � j | | d � } | rd p d } t j | | | � } � | rId � n | s}t | j | j | � } � | j � } q}n | r�| j � } n | j j | | � } � � � f d � } | | | f S( sG obtains a bundle of changes incoming from other "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 "other" 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 "other" and the one returned here. t headst forcet getbundlet incomingt commont changegroupsubsett HG10BZRf c s7 � r � j � n � r) t j � � n � j � d S( N( R{ Rx R� ( ( R t bundlerepot other( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt cleanupw s N( t discoveryt findcommonincomingRx R� t OSErrorR{ R t localt capableR� Rt R� t writebundleR] t baseuit rootR� t unfilteredRO t findmissing( Rn RV R� t onlyheadsR} R� t tmpR� R� t rheadsRh t cgt bundletypeR� t csetsR� ( ( R R� R� s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt getremotechanges6 sB ( t __doc__R R t i18nR Rx Rk R� Rt Rp R0 R� R� R Rh RO RQ RS R R R RL RP RR t localpeerRZ Ri R] Rm R R[ R� ( ( ( s: /usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt <module> s $HHz n