File: //usr/lib/python2.7/dist-packages/mercurial/streamclone.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 m Z m
Z
e d „ Z d „ Z
d „ Z d „ Z d
„ Z d „ Z d d
„ Z d „ Z d „ Z d „ Z d e f d „ ƒ YZ d S( i ( t absolute_importNi ( t _( t branchmapt errort storet utilc C@ sA | j } | j } t } | j rH d | j j d g ƒ k rH t } qH n | r^ | r^ t d f St | ƒ rt t d f S| j r‡ t d f S| j
} | d k r® | j d ƒ } n | s¾ t d f St ƒ } | j d ƒ ræ | j
d ƒ nQ | j d ƒ } | st d f St | j d ƒ ƒ } | | j r1t d f S| } t | f S( s÷ Whether it is possible to perform a streaming clone as part of pull.
``bailifbundle2supported`` will cause the function to return False if
bundle2 stream clones are supported. It should only be called by the
legacy stream clone code path.
Returns a tuple of (supported, requirements). ``supported`` is True if
streaming clone is supported and False otherwise. ``requirements`` is
a set of repo requirements from the remote, or ``None`` if stream clone
isn't supported.
t v1t streams stream-preferredt revlogv1t
streamreqst ,N( t repot remotet Falset
canusebundle2t remotebundle2capst gett Truet Nonet lent headst streamclonerequestedt capablet sett addt splitt supportedformats( t pullopt bailifbundle2supportedR R t bundle2supportedt streamrequestedt requirementsR ( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt canperformstreamclone s8
c C@ s t | ƒ \ } } | s d S| j } | j } d } | j d ƒ rR | j ƒ } n | j j t d ƒ ƒ | j ƒ } | j
ƒ } y t | ƒ } Wn) t k
r» t
j t d ƒ | ƒ ‚ n X| d k rà t
j t d ƒ ƒ ‚ nH | d k rt
j t d ƒ ƒ ‚ n$ | d k r(t
j t d
ƒ ƒ ‚ n | j
ƒ } y% t t | j d d ƒ ƒ \ } }
Wn/ t t f k
rŠt
j t d ƒ | ƒ ‚ n X| j ƒ f t | | | |
ƒ | | j | j B| _ | j ƒ | j ƒ | rït j | | ƒ n | j ƒ Wd QXd S( sð Possibly perform a legacy stream clone operation.
Legacy stream clones are performed as part of pull but before all other
operations.
A legacy stream clone will not be performed if a bundle2 stream clone is
supported.
NR s streaming all changes
s' unexpected response from remote server:i s operation forbidden by serveri s$ locking the remote repository failedi s% the server sent an unknown error codet ( R R R R R R t uit statusR t
stream_outt readlinet intt
ValueErrorR t
ResponseErrort Abortt mapR t TypeErrort lockt consumev1R R t _applyopenerreqst _writerequirementst replacecachet
invalidate( R t supportedR R R t
rbranchmapt fpt lt respt filecountt bytecount( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt maybeperformlegacystreamclone^ sJ
%
c C@ s | j d d t d t ƒS( s5 Whether streaming clones are allowed from the server.t servert uncompressedt untrusted( t
configboolR ( R" ( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt allowservergenerationœ s c C@ s
| j j ƒ S( N( R t walk( R ( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt _walkstreamfiles¡ s c @ sí g ‰ d } ˆ j ƒ [ ˆ j j d ƒ xC t ˆ ƒ D]5 \ } } } | r6 ˆ j | | f ƒ | | 7} q6 q6 WWd QXˆ j j d t ˆ ƒ | f ƒ ˆ j ‰ ˆ j ‰ ˆ j j ‰ t ˆ _ ‡ ‡ ‡ ‡ ‡ f d † } t ˆ ƒ | | ƒ f S( sË Emit content for version 1 of a streaming clone.
This returns a 3-tuple of (file count, byte size, data iterator).
The data iterator consists of N entries for each file being transferred.
Each file entry starts as a line with the file name and integer size
delimited by a null byte.
The raw file data follows. Following the raw file data is the next file
entry, or EOF.
When used on the wire protocol, an additional line indicating protocol
success will be prepended to the stream. This function is not responsible
for adding it.
This function will obtain a repository lock to ensure a consistent view of
the store is captured. It therefore may raise LockError.
i s scanning
Ns %d files, %d bytes to transfer
c 3@ sÇ z¶ x¯ ˆ D]§ \ } } ˆ r9 ˆ j j d | | f ƒ n d t j | ƒ | f V| d k r† ˆ | d ƒ } | j | ƒ VWd QXq
x( t j ˆ | ƒ d | ƒD] } | Vq¢ Wq
WWd ˆ ˆ _ Xd S( Ns sending %s (%d bytes)
s %s %d
i t rbt limit( R" t debugR t encodedirt readR t
filechunkitert mustaudit( t namet sizeR4 t chunk( t debugflagt entriest oldauditR t svfs( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt emitrevlogdataÉ s "(
R, R" RC R@ t appendR RN RG RK R
( R t total_bytesRH t enameRI RO ( ( RK RL RM R RN s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt
generatev1¤ s
c c@ s> t | ƒ \ } } } d | | f Vx | D] } | Vq+ Wd S( s¸ Emit content for version 1 of streaming clone suitable for the wire.
This is the data output from ``generatev1()`` with a header line
indicating file count and byte size.
s %d %d
N( RS ( R R7 R8 t itRJ ( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt generatev1wireprotoÛ s
t UNc @ sb ˆ d k r t d ƒ ‚ n ˆ j ˆ j @} d j t | ƒ ƒ ‰ ‡ ‡ ‡ f d † } | | ƒ f S( s@ Emit content for version 1 of a stream clone bundle.
The first 4 bytes of the output ("HGS1") denote this as stream clone
bundle version 1.
The next 2 bytes indicate the compression type. Only "UN" is currently
supported.
The next 16 bytes are two 64-bit big endian unsigned integers indicating
file count and byte count, respectively.
The next 2 bytes is a 16-bit big endian unsigned short declaring the length
of the requirements string, including a trailing . The following N bytes
are the requirements string, which is ASCII containing a comma-delimited
list of repo requirements that are needed to support the data.
The remaining content is the output of ``generatev1()`` (which may be
compressed in the future).
Returns a tuple of (requirements, data generator).
RV s. we do not support the compression argument yetR
c 3@ s( d Vˆ Vt ˆ ƒ \ } } } ˆ j j t d ƒ | | f ƒ t j d | | ƒ Vt j d t ˆ ƒ d ƒ Vˆ d Vˆ d k s‰ t ‚ d } ˆ j j t d ƒ d d
| d t d ƒ ƒxN | D]F } | t | ƒ 7} ˆ j j t d ƒ | d
| d t d ƒ ƒ| VqÁ Wˆ j j t d ƒ d ƒ d S(
Nt HGS1s writing %d bytes for %d files
s >QQs >Hi s RV i t bundlet totalt unitt bytes(
RS R" R# R t structt packR t AssertionErrort progressR ( R7 R8 RT t seenRJ ( t compressionR t requires( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt gen s" +
( R' R R t joint sorted( R Ra R Rc ( ( Ra R Rb s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt generatebundlev1æ s c C@ sƒ | j ƒ q| j j t d ƒ | t j | ƒ f ƒ d } | j j t d ƒ d d | d t d ƒ ƒt j ƒ } | j d ƒ ~| j j
| j d | ƒLxDt | ƒ D]6} | j ƒ } y( | j
d d ƒ \ } } t | ƒ } Wn/ t t f k
rt j t d
ƒ | ƒ ‚ n X| j j rJ| j j d | t j | ƒ f ƒ n t j | ƒ }
| j |
d d
t ƒo } xe t j | d | ƒD]N } | t | ƒ 7} | j j t d ƒ | d | d t d ƒ ƒ| j | ƒ qŠWWd QXq¬ WWd QX| j d t ƒ Wd QXt j ƒ | }
|
d k r'd }
n | j j t d ƒ d ƒ | j j t d ƒ t j | ƒ |
t j | |
ƒ f ƒ Wd QXd S( s Apply the contents from version 1 of a streaming clone file handle.
This takes the output from "streamout" and applies it to the specified
repository.
Like "streamout," the status line added by the wire protocol is not handled
by this function.
s! %d files to transfer, %s of data
i t cloneRY RZ R[ t
expectedcounts i s' unexpected response from remote server:s adding %s (%s)
t wt backgroundcloseRB Nt clearfilecachegü©ñÒMbP?s( transferred %s in %.1f seconds (%s/sec)
( R, R" R# R R R8 R_ t timet transactionRN t backgroundclosingt xrangeR% R R& R' R+ R R( RK RC R t decodedirR RF R t writeR1 R ( R R4 R7 R8 t
handled_bytest startt iR5 RH RI t patht ofpRJ t elapsed( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyR- sD
+ ! c C@ sØ | j d ƒ } | d k r7 t j t d ƒ | ƒ ‚ n t j d | j d ƒ ƒ \ } } t j d | j d ƒ ƒ d } | j | ƒ } | j d ƒ s t j t d ƒ ƒ ‚ n t | j d ƒ j d
ƒ ƒ } | | | f S( Ni RV s< only uncompressed stream clone bundles are supported; got %ss >QQi s >Hi s s@ malformed stream clone bundle: requirements not properly encodedR
(
RE R R) R R\ t unpackt endswithR t rstripR ( R4 Ra R7 R8 t requireslenRb R ( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt readbundle1header_ s
! c C@ sŽ t | ƒ r$ t j t d ƒ ƒ ‚ n t | ƒ \ } } } | | j } | rw t j t d ƒ d j t | ƒ ƒ ƒ ‚ n t | | | | ƒ d S( sº Apply the content from a stream clone bundle version 1.
We assume the 4 byte header has been read and validated and the file handle
is at the 2 byte compression identifier.
s2 cannot apply stream clone bundle on non-empty repos4 unable to apply stream clone: unsupported format: %ss , N( R R R) R R| R Rd Re R- ( R R4 R7 R8 R t missingreqs( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt
applybundlev1q s
t streamcloneapplierc B@ s e Z d Z d „ Z d „ Z RS( s¿ Class to manage applying streaming clone bundles.
We need to wrap ``applybundlev1()`` in a dedicated type to enable bundle
readers to perform bundle type-specific functionality.
c C@ s
| | _ d S( N( t _fh( t selft fh( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt __init__Š s c C@ s t | | j ƒ S( N( R~ R€ ( R R ( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt apply s ( t __name__t
__module__t __doc__Rƒ R„ ( ( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyR „ s ( t
__future__R R\ Rl t i18nR t R R R R R
R R9 R> R@ RS RU Rf R- R| R~ t objectR ( ( ( s9 /usr/lib/python2.7/dist-packages/mercurial/streamclone.pyt <module> s " I > 7 8 A