File: //usr/lib/python2.7/dist-packages/mercurial/exchange.pyc
Xc @@ s d d l m Z d d l Z d d l Z d d l m Z d d l m Z m Z d d l m
Z
m Z m
Z
m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z m Z e j Z e j Z i d d 6d d 6d
d 6Z i d d
6d d 6d d 6d d 6Z! e" e# d Z$ d d Z% d Z& d Z' d Z( d Z) d e* f d YZ+ i e d e d f d 6e d e d f d 6e d! e d" f d# 6Z, e# d e# d` d d$ Z- g Z. i Z/ d% Z0 d& Z1 e0 d' d( Z2 e0 d) d* Z3 e0 d+ d, Z4 e0 d- d. Z5 d/ Z6 g Z7 i Z8 d d0 Z9 d1 Z: e9 d' d2 Z; e9 d) d3 Z< e9 d4 d5 Z= e9 d- d6 Z> d7 Z? d8 Z@ d9 ZA e jB d: ZC d; ZD d< ZE d= e* f d> YZF d? e* f d@ YZG d e# da d d dA ZH g ZI i ZJ dB ZK dC ZL eK dD dE ZM eK dF dG ZN dH ZO dI ZP dJ ZQ dK ZR dL ZS dM ZT dN ZU dO ZV g ZW i ZX d dP ZY dQ ZZ d d d dR Z[ eY dF d d d d dS Z\ eY dT d d dU Z] eY d4 d d d dV Z^ eY dW d d d d dX Z_ dY Z` dZ Za d[ Zb d\ Zc d] Zd d^ Ze d_ Zf d S(b i ( t absolute_importNi ( t _( t hext nullid( t base85t bookmarkst bundle2t changegroupt discoveryt errort lockt obsoletet phasest pushkeyt scmutilt sslutilt streamclonet tagst urlt utilt nonet BZt bzip2t GZt gzipt 01t v1t 02t v2t s1t packed1R c
C@ s d } | r7 d | k r7 t j t d | n d | k r | j d d \ } } | t k r t j t d | n | | \ } } | t k r[t j t d | q[n | s t | | \ } } | t k r| } d } d | j k r[d } q[nI | t k rB| d
k r3d } n d } | } n t j t d
| | d
k rd | k rt | d j d } | | j
} | rt j t d d j t | qn | st | } t | } n | | | f S( sg Parse a bundle string specification into parts.
Bundle specifications denote a well-defined bundle/exchange format.
The content of a given specification should not change over time in
order to ensure that bundles produced by a newer version of Mercurial are
readable from an older version.
The string currently has the form:
<compression>-<type>[;<parameter0>[;<parameter1>]]
Where <compression> is one of the supported compression formats
and <type> is (currently) a version string. A ";" can follow the type and
all text afterwards is interpretted as URI encoded, ";" delimited key=value
pairs.
If ``strict`` is True (the default) <compression> is required. Otherwise,
it is optional.
If ``externalnames`` is False (the default), the human-centric names will
be converted to their internal representation.
Returns a 3-tuple of (compression, version, parameters). Compression will
be ``None`` if not in strict mode and a compression isn't defined.
An ``InvalidBundleSpecification`` is raised when the specification is
not syntactically well formed.
An ``UnsupportedBundleSpecification`` is raised when the compression or
bundle type/version is not recognized.
Note: this function will likely eventually return a more complex data
structure, including bundle2 part information.
c S@ s d | k r | i f Si } | j d d \ } } x | j d D]n } d | k rr t j t d | n | j d d \ } } t j | } t j | } | | | <qD W| | f S( Nt ;i t =s: invalid bundle specification: missing "=" in parameter: %s( t splitR t InvalidBundleSpecificationR t urlreqt unquote( t st paramst versiont paramstrt pt keyt value( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt parseparamsX s
t -sC invalid bundle specification; must be prefixed with compression: %si s %s compression is not supporteds% %s is not a recognized bundle versionR t generaldeltaR R R R s+ %s is not a recognized bundle specificationt requirementst ,s+ missing support for repository features: %ss , (
R R" R R! t _bundlespeccompressionst UnsupportedBundleSpecificationt _bundlespeccgversionst AssertionErrorR/ t sett supportedformatst joint sorted(
t repot spect strictt
externalnamesR, t compressionR' R& R/ t missingreqs( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt parsebundlespec5 sN #
c C@ sd t j | d } d } | sg d } | j d r | j d r t j | | } d } d } q n | r | j | } n | d d !| d d !} } | d k r t j t d | n | d
k r | d k r t j | d } n t j | | S| j d r(t
j | | d | | S| d
k rAt j
| St j t d | | f d S( Ni t streamt HGs t HG10t UNi i s %s: not a Mercurial bundlet 10t 2t magicstringt S1s %s: unknown bundle version %s( R t readexactlyt Nonet
startswitht headerlessfixupR7 R t AbortR t cg1unpackerR t getunbundlerR t streamcloneapplier( t uit fht fnamet vfst headert algt magicR' ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
readbundle s,
c
C@ s d } t | | d } t | t j r | j } | d k rK d } n | | } | sy t j t d | n d | St | t j
rd | j k r | | j d } | s t j t d | q n d } d } xm | j D]_ } | j
d k r | j d } | d k r*d } qRt j t d
| d t d q q W| stt j t d n d | | f St | t j rt j | d } d d j t | } d t j | St j t d | d S( s Infer the bundlespec from a bundle file handle.
The input file handle is seeked and the original seek position is not
restored.
c S@ s1 x* t j D] \ } } | | k r
| Sq
Wd S( N( R1 t itemsRI ( RU t kt v( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt speccompression s t _truncatedBZR s! unknown compression algorithm: %ss %s-v1t CompressionR R R' R R R s7 changegroup version %s does not have a known bundlespect hints# try upgrading your Mercurial clients0 could not identify changegroup version in bundles %s-%si s requirements=%sR0 s none-packed1;%ss unknown bundle type: %sN( R R ( RW RI t
isinstanceR RM t _typeR RL R R t
unbundle20R& t iterpartst typeR RO t readbundle1headerR7 R8 R# t quote(
RP RQ R[ t bRU t compR' t partR/ R& ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
getbundlespec sB
c C@ sq | rm t j | j } t j | } | d k rB t d n t j | t d | } | j d d | Sd S( s add an obsmarker part to the bundler with <markers>
No part is created if markers is empty.
Raises ValueError if the bundler doesn't support any known obsmarker format.
s0 bundler does not support common obsmarker formatR' t
obsmarkerst dataN(
R t obsmarkersversiont capabilitiesR t
commonversionRI t
ValueErrort
encodemarkerst Truet newpart( t bundlert markerst remoteversionsR' R@ ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt buildobsmarkerspart s c C@ sq | j } | r@ | j } g | D] } | | r | ^ q } n t g } | s^ | j } n t j | | | S( s Computes which revs are outgoing given a set of common
and a set of heads.
This is a separate function so extensions can have access to
the logic.
Returns a discovery.outgoing object.
( t changelogt hasnodeR t headsR t outgoing( R9 Ry t commont clRx t n( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _computeoutgoing s ( c C@ sS | j j } t } | j d d } d | k o9 d | k } | pR | j j d S( ss return true if a pull/push must use bundle1
This function is used to allow testing of the older bundle versiont devels legacy.exchangeR t bundle1( R9 RP t Falset
configlistt remotet capable( t opRP t forcebundle1t exchange( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
_forcebundle1 s
t
pushoperationc B@ sV e Z d Z e d e d d Z e j d Z e j d Z e
d Z RS( s A object that represent a single push operation
Its purpose is to carry push related state and very common operations.
A new pushoperation should be created at the beginning of each push and
discarded afterward.
c C@ s | | _ | j | _ | | _ | | _ | | _ | | _ | | _ d | _ t | _
d | _ d | _ d | _
d | _ d | _ d | _ d | _ t | _ g | _ d | _ i | _ d S( N( R9 RP R t forcet revsR t newbranchRI t locallockedR5 t stepsdonet cgresultt bkresultRz t remoteheadst incomingt outdatedphasest fallbackoutdatedphasest
outobsmarkerst outbookmarkst trmanagert pkfailcb( t selfR9 R R R R R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt __init__0 s( c C@ s
| j j S( s2 future remote heads if the changeset push succeeds( Rz t missingheads( R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt futureheadsa s c C@ s | j d k r | j j S| j j } | j j } | j j j } g | j D] } | | | k rM | ^ qM } | j d | j j | j j
} | j d | D | S( s/ future remote heads if the changeset push failss %ln and parents(roots(%ln))c s@ s | ] } | j Vq d S( N( t node( t .0t c( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pys <genexpr> s N( R RI Rz t commonheadsR9 t
unfilteredR{ Rw t nodemapR5 t missingt extend( R t unfiR{ t nmR t cheadst revset( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
fallbackheadsf s
, c C@ s | j r | j S| j Sd S( s3 set of all common heads after changeset bundle pushN( R R R ( R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s N( ( t __name__t
__module__t __doc__R RI R R t
propertycacheR R t propertyR ( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR ' s 0 s updating bookmark %s
s updating bookmark %s failed!
t updates exporting bookmark %s
s exporting bookmark %s failed!
t exports deleting remote bookmark %s
s$ deleting remote bookmark %s failed!
t deletec C@ s | d k r i } n t | | | | | | | } | j j r t | j j | j j j } | r t d d j t
| } t j | q n | j j
s t j t d n d }
} yV | j j d d } t | r | r | j j }
n | j j } t | _ WnN t k
ru}
t | _ |
j t j k rX n d |
} | j j | n Xz | j rt | j d | j j | _ n | j j | d } | j j d } | s| j j } n zO t | t | s t | n t! | t" | t# | t$ | Wd | d k rQ| j% n X| j rk| j j& n Wd | j r| j j% n | d k r| j% n |
d k r|
j% n X| S(
sW Push outgoing changesets (limited by revs) from a local
repository to remote. Return an integer:
- None means nothing to push
- 0 means HTTP error
- 1 means we pushed and remote head count is unchanged *or*
we have outgoing changesets but refused to push
- other values as described by addchangegroup()
s: required features are not supported in the destination: %ss , s! destination does not support pusht experimentals bundle2.pushbacks" cannot lock source repository: %s
s
push-responset unbundleN(' RI R R t localR5 R9 R/ t supportedR R7 R8 R RL t canpushRP t
configboolR t wlockR
Rq R t IOErrorR t errnot EACCESt debugt transactionmanagerR R t checkpushR t _pushdiscoveryt _pushbundle2t _pushchangesett _pushsyncphaset
_pushobsoletet
_pushbookmarkt releaset close( R9 R R R R R t opargst pushopR t msgt
localwlockt locallockt maypushbackt errR
R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt push sn
c @ s f d } | S( s| decorator for function performing discovery before push
The function is added to the step -> function mapping and appended to the
list of steps. Beware that decorated function will be added in order (this
may matter).
You can only use this decorator for a new step, if you want to wrap a step
from an extension, change the pushdiscovery dictionary directly.c @ s- t k s t | t <t j | S( N( t pushdiscoverymappingR4 t pushdiscoveryordert append( t func( t stepname( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt dec s
( ( R R ( ( R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
pushdiscovery s c C@ s) x" t D] } t | } | | q Wd S( s Run all discovery stepsN( R R ( R R t step( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s
t changesetc C@ s t j } | | j | j d | j } | \ } } } t j } | | j | j d | j d | d | j } | | _ | | _ | | _ d S( s- discover the changeset that need to be pushedR t onlyheadst commonincN(
R t findcommonincomingR9 R R t findcommonoutgoingR Rz R R ( R t fciR R{ t incR t fcoRz ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pushdiscoverychangeset s t phasec C@ sd | j } | j j } | j j d } | j d t } | j j d d t r} | r} | j j r} | r} i d d 6} n t
j | j | j | } | \ } } d } | s d } n d | } t
| j | | | j }
| j s |
} n[ t
| j d | j | } g | D] }
|
j ^ q} t
| j | | | j } | | _ |
| _ d
S( sp discover the phase that needs to be pushed
(computed for both success and failure case for changesets push)R t
publishingRP t _usedassubrepoRq t s
and public()s heads((%%ln::%%ln) %s)s roots(%ln + %ln::)N( Rz R9 R R t listkeyst getR RP R R R t analyzeremotephasesR t listR5 R R R R ( R Rz R t remotephasesR t anat pheadst drootst extracondR t fallbackt futuret fdrootst f( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pushdiscoveryphase s4
t obsmarkerc C@ s t j | j t j r | j j r d | j j d k r | j } d | j d | j D } | j j j | | _
n d S( NR t
namespacesc s@ s | ] } | j Vq d S( N( R ( R R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pys <genexpr>Q s s ::%ln( R t isenabledR9 t exchangeoptt obsstoreR R R5 R t relevantmarkersR ( R R9 t nodes( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pushdiscoveryobsmarkersI s R c C@ s | j } | j j } | j } | j d d } | j rp t | j j | j } | j j | d t
} n | j d } t g | j
D] } | j j | ^ q } t j | | j | d t } | \ }
} } }
} } } } xl | D]d \ } } } | | k r| j | n | s8| | j | k r | j j | | | f q q WxL |
D]D \ } } } | | k r_| j | | j j | d | f q_q_WxT |
| | D]D \ } } } | | k r| j | | j j | | | f qqWxL | D]D \ } } } | | k r| j | | j j | | d f qqWx3 | D]+ \ } } } | | k rT| j | qTqTW| rt | } | j t d | d d | _ n | j j d S(
Ns checking for updated bookmarks
t inclusiveR t srchexR s> bookmark %s does not exist on the local or remote repository!
i i ( ( RP R9 R R R R t mapRw t revt ancestorsRq R R5 R t
_bookmarkst
expandnamet bookmodt compareR t removeR R R8 t warnR R t sort( R RP R9 R R t revnumst remotebookmarkt bookmarkt explicitRg t addsrct adddstt advsrct advdstt diverget differt invalidt sameRf t scidt dcid( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pushdiscoverybookmarksT sN
(
c C@ s | j } | j j } | j s> t j | j | | j t S| j s | j
r t d } i t d d 6t d d 6t d d 6} xp | j D]b } | | } | j
r t j | | q | j r t j | | j d | q q Wn t j | n t S( Ns% push includes obsolete changeset: %s!s% push includes unstable changeset: %s!t unstables# push includes bumped changeset: %s!t bumpeds& push includes divergent changeset: %s!t divergenti ( Rz R9 R R R t nochangesfoundRP t excludedR R R R R R R RL t troubledt troublesR t
checkheadsRq ( R Rz R t msot mstR t ctx( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pushcheckoutgoing s&
+c @ s f d } | S( sw decorator for function generating bundle2 part
The function is added to the step -> function mapping and appended to the
list of steps. Beware that decorated functions will be added in order
(this may matter).
You can only use this decorator for new steps, if you want to wrap a step
from an extension, attack the b2partsgenmapping dictionary directly.c @ sL t k s t | t < d k r8 t j n t j | S( N( t b2partsgenmappingR4 RI t b2partsgenorderR t insert( R ( t idxR ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s
( ( R R$ R ( ( R$ R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt b2partsgenerator s c C@ s, | j s( | j d d t | j n d S( sd Generate race condition checking parts
Exists as an independent function to aid extensions
s check:headsRk N( R Rr t iterR ( R Rs ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pushb2ctxcheckheads s c @ sb d j k r d S j j d t s3 d S j j t | t j j } d } | j d } | r g | D]$ } | t
j j k r | ^ q } | s t t
d n t | } n t
j j d j d | } | j d d | | r' j d | n d j j k rL j d d
n f d } | S( sw handle changegroup push through bundle2
addchangegroup result is stored in the ``pushop.cgresult`` attribute.
t
changesetsNR R s no common changegroup versionR R' Rk t treemanifestt 1c @ sJ | j j j } t | d d k s1 t | d d d _ d S( s0 extract addchangegroup returns from server replyR i i t returnN( t recordst
getrepliest idt lenR4 R ( R t cgreplies( t cgpartR ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt handlereply s ( R t addR R9 t prepushoutgoinghooksR' R t bundle2capsR R R t supportedoutgoingversionsRo R t maxt getlocalchangegrouprawRz Rr t addparamR/ ( R Rs t b2capsR' t
cgversionsRZ t cgR2 ( ( R1 R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
_pushb2ctx s6
c @ s2 d j k r d St j j } d | k r5 d S j j d g f d } t j } x j D] } | j d } | j d | d | j d | | j
| j d | t t j
| j d | t t j j | j | f | j | j <qm W f d } | S(
s! handle phase push through bundle2R NR
c @ sR t | j } x< D]4 \ } } | | k r t j t d | q q Wd S( Ns updating %s to public failed( t intt partidR RL R ( R t exct targetidR? R ( t part2node( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
handlefailure s t namespaceR* t oldt newc @ s x D] \ } } | j j | } | d } t | d k sG t d } | sf t d | } n' t | d d s t d | } n | d k r j j | q q Wd S( NR
i s' server ignored update of %s to public!
i R+ s updating %s to public failed!
( R, R- R/ R4 RI R R> RP R ( R R? R t partrept resultsR ( RB R ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR2 s
( R R R5 R R3 R
t encodeR Rr R9 R t strR t draftt publicR R. R ( R Rs R: RC t enct
newremoteheadRh R2 ( ( RB R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
_pushb2phases s& Rj c C@ sz d | j k r d St j | j } t j | d k r> d S| j j d | j rv t | j } t
| | n d S( NRj ( R R Rl Rm R Rn RI R3 R R8 Rv ( R Rs Ru Rt ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pushb2obsmarkers s c @ sJ d j k r d St j j } d | k r5 d S j j d g t j } f d } x j D] \ } } } | j d } | j d | d | j d | | | j d | | | j d | | d } | s d
} n | sd } n j
| j | | f | j | j <qm W f d }
|
S(
s$ handle bookmark push through bundle2R NR
c @ si t | j } xG D]? \ } } } | | k r t j t | d j | q q Wt se t d S( Ni ( R> R? R RL t
bookmsgmapt rstripR R4 ( R R@ RA R? t bookt action( t part2book( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyRC 4 s
(RD R* RE RF R R R c @ s j } x D] \ } } } | j j | } | d } t | d k sS t | sv j j t d | q t | d d } | r | j t | d | q | j t | d | j
d k r d _
q q Wd S( NR
i s" server ignored bookmark %s update
i R+ ( RP R, R- R/ R4 R R R> t statusRQ R RI ( R RP R? RS RT RG RH t ret( RU R ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR2 J s
(
R R R5 R R3 R
RI R Rr R9 R R. R ( R Rs R: RM RC RS RE RF Rh RT R2 ( ( RU R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pushb2bookmarks( s0 c C@ sk t j | j t j | j } | j o< | j j d d } t j t j | j d | } | j
d d | g } xC t D]; } t | } | | | } t
| r | j | q q W| j d k r d St j | j } yy( | j j | d g | j j } Wn/ t j k
rC}
t j t d |
n Xy7 d } | rb| j j } n t j | j | | } Wn| t j k
r}
t j t d |
nN t j k
r}
| j j t d
|
t j t d d |
j n XWnN t j k
rK}
t |
j! }
|
| j" k r4 n | j" |
| |
n Xx | D] } | | qSWd S(
s push data to the remote using bundle2
The only currently supported type of data is changegroup but this will
evolve in the future.R s bundle2.pushbackt
allowpushbackt replycapsRk i NR s missing support for %ss remote: %s
s push failed on remoteR^ (# R t bundle20RP R5 R R R t
encodecapst getrepocapsR9 Rr R" R! t callableR t nbpartsR t chunkbuffert getchunksR R R t BundleValueErrorRL R RI t transactiont
processbundlet
AbortFromPartRV R^ t
PushkeyFailedR> R? R ( R Rs t pushbackt capsblobt
replyhandlerst partgennamet partgenRW R@ t replyR@ t trgetterR R? t rephand( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR ] sL !
&
c C@ sS d | j k r d S| j j d t | s3 d S| j j | | j } | j j d } d } | j d k r | j
p | j j j r t
j | j | } t
j | j | | d d t } n t
j | j d | | } | r+| j r d g } n | j } | j j | | | j j | _ n$ | j j | d | j j | _ d S( s7 Make the actual push of changeset bundle to remote repoR( NR R t fastpathR ( R R3 R R9 R4 Rz R R RI R R Rw t filteredrevsR t cg1packert getsubsetRq t getlocalchangegroupR R R R R t addchangegroup( R Rz R t
bundlecapsRs R< R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s6 c
C@ s | j } | j j d } | j j d d t rj | rj | j d k rj | j d t rj i d d 6} n | s t | | n9t
j | j | | } | \ } } | j d t r t | | n t | | t | | t
j
| j rd | j k rd S| j } n | j } | j j d g | D] } | j | k r.| ^ q.} xd | D]\ } | j j d | j t t
j
t t
j } | sY| j j t d | qYqYWd S( s2 synchronise phase information locally and remotelyR RP R R Rq Ns updating %s to public failed!
( R R R RP R R R RI R t _localphasemoveR R R9 RK R R R R3 R R
R RJ RL R R (
R R R R R R t outdatedR RN t r( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s>
+
c C@ s | j r. t j | j | j j | | nb g | D]% } | | j | j k r5 | ^ q5 } t j | } | r | j j t d | n d S( s0 move <nodes> to <phase> in the local source repos8 cannot lock source repo, skipping local %s phase update
N(
R R t advanceboundaryR9 Rc R t
phasenamesRP RV R ( R R R R} t actualmovest phasestr( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyRv s
2
c C@ s d | j k r d S| j } | j } | j j d | j r | j j d g } t j t | j } xC t | d t
D]/ } | | } | j | j d | d | q Wg | D] } | s | ^ q r t
d } | j j | q n d S( s5 utility function to push obsolete markers to a remoteRj Ns' try to push obsolete markers to remote
t reverseR R s& failed to push some obsolete markers!
( R R9 R R3 R RP R R t _pushkeyescapeR8 Rq R R
R R ( R R9 R t rsltst
remotedataR* Rk Rx R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s
# c C@ s | j d k s d | j k r" d S| j j d | j } | j } x | j D] \ } } } d } | sr d } n | s d } n | j d | | | r | j t | d | qN | j t | d | | j
d k rN d | _
qN qN Wd S( s" Update bookmark position on remotei R NR R R i ( R R R3 RP R R R
RV RQ R R RI ( R RP R Rf RE RF RT ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s t
pulloperationc B@ se e Z d Z d e d d d d Z e j d Z e j d Z e j d Z
d Z RS( s A object that represent a single pull operation
It purpose is to carry pull related state and very common operation.
A new should be created at the beginning of each pull and discarded
afterward.
c C@ s | | _ | | _ | | _ g | D] } | j j | ^ q" | _ | | _ | | _ d | _ d | _
d | _ d | _ | | _
d | _ t | _ t | _ d S( N( R9 R Ry R R t explicitbookmarksR t streamclonerequestedRI R R{ t rheadst fetcht remotebookmarksR R5 R R t clonebundleattempted( R R9 R Ry R R R R R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR 6 s % c C@ sl | j d k ra t | j } t | j } x- | j D]" } | | k r7 | j | q7 q7 W| S| j Sd S( s0 heads of the set of changeset target by the pullN( Ry RI R5 R{ R R R ( R R RW R} ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt pulledsubsetV s c C@ s t | S( N( R ( R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
canusebundle2h s c C@ s t j | j S( N( R R5 R ( R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt remotebundle2capsl s c C@ s
| j j S( N( R Rc ( R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt gettransactionp s N( ( R R R RI R R R R R R R R ( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR - s R c B@ s2 e Z d Z d Z d Z d Z d Z RS( s An object to manage the life cycle of a transaction
It creates the transaction on demand and calls the appropriate hooks when
closing the transaction.c C@ s( | | _ | | _ | | _ d | _ d S( N( R9 t sourceR RI t _tr( R R9 R R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR y s c C@ sm | j sf d | j t j | j f } | j j | | _ | j | j j d <| j | j j d <n | j S( s< Return an open transaction object, constructing if necessarys %s
%sR R ( R R R t hidepasswordR R9 Rc t hookargs( R t trname( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyRc s c C@ s# | j d k r | j j n d S( s close transaction if createdN( R RI R ( R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s c C@ s# | j d k r | j j n d S( s release transaction if createdN( R RI R ( R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s ( R R R R Rc R R ( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR t s
c
C@ so | d k r i } n t | | | | d | d | | } | j j r t | j j | j j } | r t d d j t
| } t j | q n d }
} z | j j
}
| j j } t | d | j | _ t j | t | t | | j rt | n t | t | t | t | | j j Wd t j | j | |
X| S( s Fetch repository data from a remote.
This is the main function used to retrieve data from a remote repository.
``repo`` is the local repository to clone into.
``remote`` is a peer instance.
``heads`` is an iterable of revisions we want to pull. ``None`` (the
default) means to pull everything from the remote.
``bookmarks`` is an iterable of bookmarks requesting to be pulled. By
default, all remote bookmarks are pulled.
``opargs`` are additional keyword arguments to pass to ``pulloperation``
initialization.
``streamclonerequested`` is a boolean indicating whether a "streaming
clone" is requested. A "streaming clone" is essentially a raw file copy
of revlogs from the server. This only works when the local repository is
empty. The default value of ``None`` means to respect the server
configuration for preferring stream clones.
Returns the ``pulloperation`` created for this pull.
R R s: required features are not supported in the destination: %ss , t pullN( RI R R R R5 R/ R9 R R R7 R8 R RL R R
R R R R t maybeperformlegacystreamclonet _maybeapplyclonebundlet _pulldiscoveryR t _pullbundle2t _pullchangesett
_pullphaset _pullbookmarkst
_pullobsoleteR t lockmodR ( R9 R Ry R R R R t pullopR R R R
( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s6
c @ s f d } | S( s| decorator for function performing discovery before pull
The function is added to the step -> function mapping and appended to the
list of steps. Beware that decorated function will be added in order (this
may matter).
You can only use this decorator for a new step, if you want to wrap a step
from an extension, change the pulldiscovery dictionary directly.c @ s- t k s t | t <t j | S( N( t pulldiscoverymappingR4 t pulldiscoveryorderR ( R ( R ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s
( ( R R ( ( R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt
pulldiscovery s c C@ s) x" t D] } t | } | | q Wd S( s Run all discovery stepsN( R R ( R R R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s
s b1:bookmarksc C@ sH | j d k r d S| j r/ d | j k r/ d S| j j d | _ d S( s fetch bookmark data in bundle1 case
If not using bundle2, we have to fetch bookmarks before changeset
discovery to reduce the chance and impact of race conditions.NR R ( R RI R R R R ( R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pullbookmarkbundle1 s
R c C@ s t j | j | j d | j d | j } | \ } } } | j j j j } | r | r t | } g } xF | D]> } | | k r | | k r | j
| q qs | j
| qs W| s g } n | } n | | _ | | _ | | _
d S( s~ discovery phase for the pull
Current handle changeset discovery only, will change handle all discovery
at some point.Ry R N( R R R9 R Ry R R Rw R R5 R R{ R R ( R t tmpR{ R R R t scommont filteredrheadsR} ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _pulldiscoverychangegroup s(
c C@ s- i t | j d 6} t j | \ } } | j j d | j | d <| j pW | j | d <| j | d <d | j
k r d g | d <| j d k r | d j
d q n | j j d r | j d k r t | j t g k r | j | d
<n | r| j j j t d nq | j sF| j j j t d d
| _ nC | j d k rt | j t g k r| j j j t d n t j | j t j rt j | j
} t j | d k rt | d <| j j d qn t | | | j j d | } y t j | j | | j! } Wn/ t" j# k
rZ} t" j$ t d | n X| j rg | j% d D] } | d ^ qr} t& j' | | _ n x7 | j% d D]( \ }
} |
d k rt( | | qqWx3 | j% d D]$ \ }
} |
d k r| | _ qqW| j d k r)t) | n d S( sN pull data using bundle2
For now, the only supported data are changegroup.Ru R R{ Ry R< R R R t clonebundlest cbattempteds streaming all changes
s no changes found
i s requesting all changes
Rj R s missing support for %sR+ N(* t
caps20to10R9 R t canperformstreamcloneR R3 R{ Ry R R R R RI R R R R R R RP RV R R R R R R Rl Rn Rq t _pullbundle2extrapreparet getbundleRd R R Rb RL R, R t combineresultst _pullapplyphasesR ( R t kwargst streamingt
streamreqsRu t bundleR R@ R< RH RD R+ ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR sT
' '
$ c C@ s d S( s> hook function so that extensions can extend the getbundle callN( ( R R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR a s c C@ s d | j k r d S| j j d | j sR | j j j t d d | _ d S| j | j d k r t | j t
g k r | j j j t d n0 | j d k r | j j d r | j | _ n | j j d r| j j d d | j d
| j p| j } nr | j d k r;| j j | j d } nH | j j d set j t d n | j j | j | j d } | j | j d | j j | _ d S( s0 pull changeset from unbundle into the local repoR Ns no changes found
i s requesting all changes
t changegroupsubsetR R R{ Ry sW partial pull cannot be done because other repository doesn't support changegroupsubset.( R R3 R R9 RP RV R R R Ry RI R R{ R R R R R R R RL R t applyR ( R R< ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR e s*
' ! c C@ s6 d | j k r d S| j j d } t | | d S( NR ( R R R R ( R R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s c
C@ s d | j k r d S| j j d t | j d t } | ru | ru t j | j | j | \ } } | j } n | j } g } | j j } | j
j } | j j
j } t j } t j }
g | D]' } | | | | | k r | ^ q } | r"| j } t j | j | | | n g | D]' } | | | | |
k r)| ^ q)} | r| j } t j | j | |
| n d S( s/ apply phase movement from observed remote stateR NR ( R R3 t boolR R R R R9 R R t _phasecacheR Rw R RL RK R Ry (
R R R R t _drt dheadsR R R RL RK t pnt tr( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s0
4 4 c C@ sj d | j k r d S| j j d | j } | j } t j | j | | | j j | j d | j
d S( s? process the remote bookmark information to update the local oneR NR ( R R3 R9 R R t updatefromremoteRP R R R R ( R R9 R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s c C@ s d | j k r d S| j j d d } t j | j t j r| j j j d | j j
d } d | k r| j } g } x^ t | d t
D]J } | j d r t j | | } t j | \ } } | | 7} q q W| r| j j j | | n | j j qn | S( sV utility function to pull obsolete markers from a remote
The `gettransaction` is function that return the pull transaction, creating
one if necessary. We return the transaction to inform the calling code that
a new transaction have been created (when applicable).
Exists mostly to allow overriding for experimentation purposeRj Ns! fetching remote obsolete markers
R t dump0R} t dump( R R3 RI R R R9 R RP R R R R R8 Rq RJ R t b85decodet _readmarkersR t invalidatevolatilesets( R R t remoteobsRt R* Rk R' t newmarks( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s& c C@ sE t d g } t j t j | } | j d t j | | S( sF return a set with appropriate options to use bundle20 during getbundlet HG20s bundle2=( R5 R R\ R] R3 R# Re ( R9 t capsRh ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s c @ s f d } | S( s decorator for function generating bundle2 part for getbundle
The function is added to the step -> function mapping and appended to the
list of steps. Beware that decorated functions will be added in order
(this may matter).
You can only use this decorator for new steps, if you want to wrap a step
from an extension, attack the getbundle2partsmapping dictionary directly.c @ sL t k s t | t < d k r8 t j n t j | S( N( t getbundle2partsmappingR4 RI t getbundle2partsorderR R# ( R ( R$ R ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s
( ( R R$ R ( ( R$ R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt getbundle2partsgenerator s c C@ s$ | d k r t d | D St S( Nc s@ s | ] } | j d Vq d S( t HG2N( RJ ( R t cap( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pys <genexpr> s ( RI t anyR ( Ru ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt bundle2requested s c
K@ sv t | } | s | r@ | j d t r@ t t d n | rt t t d d j t | j n t | | | } t j
d | | } t j | | | | Si } xO | D]G }
|
j d r t
j |
t d } | j t j | q q Wt j | j | } | | d <| | d <x7 t D]/ } t | }
|
| | | d | d
| | q9W| j S( s Return chunks constituting a bundle's raw data.
Could be a bundle HG10 or a bundle HG20 depending on bundlecaps
passed.
Returns an iterator over raw chunks (of varying sizes).
R< s- request for bundle10 must include changegroups# unsupported getbundle arguments: %ss , R s bundle2=Ry R{ Ru R: ( R R Rq Ro R R7 R8 t keysR~ R t
getbundlert getsubsetrawRJ R# R$ R/ R R t
decodecapsR[ RP R R Ra ( R9 R Ry R{ Ru R t
usebundle2Rz Rs R: t bcapst blobt nameR ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt getbundlechunks s. "
c K@ sC d } | j d t r d } | j d }
|
r g |
D]! } | t j | k r: | ^ q: }
|
s| t t d n t |
} n t | | | } t j | | | d | d | } n | r?| j
d d | }
|
r |
j d | n |
j d t t
| j d t d
| j k r?|
j d
d q?n d S(
s. add a changegroup part to the requested bundleR< R R s no common changegroup versionRu R' Rk t nbchangest mandatoryR) R* N( RI R Rq R R6 Ro R R7 R~ R8 Rr R9 RJ R/ R R R/ ( Rs R9 R Ru R: Ry R{ R R< R' R; RZ Rz Rh ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _getbundlechangegrouppart' s*
! %R c
K@ sm | j d d } xT | D]L } | j d } | j d | | j | j } t j | | _ q Wd S( s@ add parts containing listkeys namespaces to the requested bundleR RD N( ( R Rr R9 R RX R
t
encodekeysRk (
Rs R9 R Ru R: R R RD Rh R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _getbundlelistkeyspartsC s
c
K@ s | j d t r | d k r- | j } n g | j d | D] } | j ^ q@ } | j j | } t | } t | | n d S( s8 add an obsolescence markers part to the requested bundleRj s ::%lnN(
R R RI Ry R5 R R R R8 Rv (
Rs R9 R Ru R: Ry R R t subsetRt ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _getbundleobsmarkerpartN s + t hgtagsfnodesc
K@ s | j d t o d | k s" d St | | | } | j sA d St j | j } g }
xH | j D]= } | j | d t } | d k rf |
j
| | g qf qf W|
r | j d d d j |
n d S( s Transfer the .hgtags filenodes mapping.
Only values for heads in this bundle will be transferred.
The part data consists of pairs of 20 byte changeset node and .hgtags
filenodes raw values.
R< R Nt computemissingRk R (
R Rq R~ R R t hgtagsfnodescacheR t getfnodeR RI R Rr R7 (
Rs R9 R Ru R: Ry R{ R Rz t cachet chunksR t fnode( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt _getbundletagsfnodesZ s c C@ sw | j } t j d j t | j } | d g k pZ | | k pZ | d | g k ss t j d | n d S( sV check if the heads of a repo have been modified
Used by peer for unbundling.
R R t hasheds. repository changed while %s - please try againN( Ry t hashlibt sha1R7 R8 t digestR t PushRaced( R9 t their_headst contextRy t
heads_hash( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt check_heads s $ c
@ s* d d d d g d } j j d d t } j d sQ j d rZ t } n zt | d t j | d rd y f d } j j d d s | n t j
| d
| } z t j | d | } Wd | j | r< d k r< j j
d
t d t f d } n X d d k r^ d j n Wqt k
r} t | _ | r d k r j | _ f d } n qXn% j d <| j Wd t j d d d | d k r%| j j n X S( s Apply a bundle to a repo.
this function makes sure the repo is locked during the application and have
mechanism to check that no push race occurred between the creation of the
bundle and its application.
If the push was raced as PushRaced exception is raised.i R s bundle2-output-captures remote:http:s
remote:https:s uploading changesR& c @ s{ d ss j d < j d < j d < d j d < d j d <d d j d <n d S( Ni i i R R R* R ( R R
Rc R ( ( t lockandtrR9 R R ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s
t bundle2lazylockingt
captureoutputR NR t subprocc @ s j d d | d t d S( Nt outputRk R ( Rr R ( R ( Rx ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt recordout s i c @ s, t j d d | d t } j | d S( NR Rk R ( R t
bundlepartR R ( R Rh ( t parts( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s i ( RI RP R R RJ Rq R R t safehasattrR t bundleoperationRd Rl t
pushbufferR t
BaseExceptiont duringunbundle2t
salvageoutputt _bundle2salvagedoutputR
R R R t popbuffer(
R9 R< Ry R R R R R R R@ ( ( R R Rx R9 R R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR sJ
c C@ s | j } | j } | j j d d t s. d St | r> d S| j rK d S| j d s^ d S| j d } t | _ t
| | } | s | j j t d d St
| | } | s | j j t d | j j t d d St | j | } | d d } | j j t d | t | j | | rR| j j t d
nR | j j d d t r| j j t d n! t j t d
d t d d S( s0 Apply a clone bundle from a remote, if possible.RP R NsD no clone bundles available on remote; falling back to regular clone
sO no compatible clone bundles available on server; falling back to regular clone
s5 (you may want to report this to the server operator)
i t URLs applying clone bundle from %s
s finished applying clone bundle
t clonebundlefallbacks falling back to normal clone
s error applying bundleR^ s} if this error persists, consider contacting the server operator or disable clone bundles via "--config ui.clonebundles=false"( R9 R RP R Rq R/ Ry R t _callR t parseclonebundlesmanifestt noteR t filterclonebundleentriesR t sortclonebundleentriesRV t trypullbundlefromurlR R RL ( R R9 R t rest entriesR ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s< c C@ s g } x| j D] } | j } | s1 q n i | d d 6} x | d D] } | j d d \ } } t j | } t j | } | | | <| d k rM y6 t | | d t \ } }
} | | d <|
| d <Wqt j k
r qt j k
r qXqM qM W| j | q W| S( s Parses the raw text of a clone bundles manifest.
Returns a list of dicts. The dicts have a ``URL`` key corresponding
to the URL and other keys are the attributes for the entry.
i R i R t
BUNDLESPECR< t COMPRESSIONt VERSION(
t
splitlinesR! R# R$ R? Rq R R" R2 R ( R9 R% t mt linet fieldst attrst rawattrR* R+ Rg R' R& ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s.
c C@ s g } x | D] } | j d } | r y t | | d t Wq t j k
rt } | j j t | d q
q t j k
r } | j j d | d t | f q
q Xn d | k r t j
r | j j d | d q
n | j | q
W| S( su Remove incompatible clone bundle manifest entries.
Accepts a list of entries parsed with ``parseclonebundlesmanifest``
and returns a new list consisting of only the entries that this client
should be able to apply.
There is no guarantee we'll be able to apply all returned entries because
the metadata we use to filter on may be missing or wrong.
R R; s
s1 filtering %s because unsupported bundle spec: %s
R t
REQUIRESNIs' filtering %s because SNI not supported
( R R? Rq R R" RP R RJ R2 R t hassniR ( R9 R t
newentriest entryR: t e( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR < s&
c @ sl | j d d d g s( t | Sg D] } | j d d ^ q/ f d } t | d | S( NRP t clonebundlepreferst defaultR i c @ s x D] \ } } | j | } | j | } | d k rY | d k rY | | k rY d S| d k r | d k r | | k r d S| d k s | d k r q n | | k r q n | | k r d S| | k r d Sq q Wd S( Nii i ( R RI ( t aRf t prefkeyt prefvaluet avaluet bvalue( t prefers( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt compareentrye s" $$ t cmp( R R R! R8 ( RP R R) R ( ( R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR ] s
%"c @ sL | j } z.| j d z
y t j | | } t | | d } t | t j ry t j | | f d n5 t | t j
r | j | n | j | d | j t
SWnf t j k
r } | j t d t | n4 t j k
r%} | j t d | j d n Xt SWd j XWd | j Xd S( s% Attempt to apply a bundle from a URL.t bundleurlR@ c @ s S( N( ( ( R ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt <lambda> s R s HTTP error fetching bundle: %s
s error fetching bundle: %s
i N( R
Rc t urlmodt openRW R_ R Ra Rd R RO R R Rq t urlerrt httperrorR R RJ t urlerrort reasonR R ( RP R9 R R
RQ R< R ( ( R s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyR s*
"( ( (g t
__future__R R R t i18nR R R R R R R R R R R R R
R R R R
R R R R R R R R R# RI R1 R3 Rq R R? RW Ri Rv R~ R t objectR RQ R R R R R R R R R R R" R! R% R' R= RO RP RX R R R RL Rv R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R R ( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/exchange.pyt <module> s j
o 5 h U
1 4 )) 5 / / 8 G 8 & D ! # (
) E @ $ ! ,