File: //usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyc
ó
ÛXc @@ s d Z d d l m Z d d l m Z d d l m Z m Z m Z d d l m
Z
m Z m Z e j
Z
e j Z d e
j
f d „ ƒ YZ d S(
s4 remote largefile store; the base class for wirestorei ( t absolute_import( t _( t errort utilt wireprotoi ( t basestoret lfutilt
localstoret remotestorec B@ sq e Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z
RS( s) a largefile store accessed over a networkc C@ sA t t | ƒ j | | | ƒ t j | j | j | j ƒ | _ d S( N( t superR t __init__R t uit repot _lstore( t selfR R t url( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyR
s c C@ sp | j | | ƒ r@ t j t d ƒ | t j | j ƒ f ƒ ‚ n | j j t d ƒ | t j | j ƒ f ƒ d S( Ns0 remotestore: could not put %s to remote store %ss' remotestore: put %s to remote store %s
( t sendfileR t AbortR R t hidepasswordR R t debug( R t sourcet hash( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyt put! s c C@ s# t d „ | j | ƒ j ƒ Dƒ ƒ S( Nc s@ s' | ] \ } } | | d k f Vq d S( i N( ( t .0t ht s( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pys <genexpr>+ s ( t dictt _statt iteritems( R t hashes( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyt exists* s c C@ s‹ | j j d | | f ƒ y2 t j | j | ƒ } | j | | ƒ SWd QXWn8 t k
r† } t j t d ƒ | t | ƒ f ƒ ‚ n Xd S( Ns remotestore: sendfile(%s, %s)
s' remotestore: could not open file %s: %s(
R R R t httpsendfilet _putt IOErrorR R R t str( R t filenameR t fdt e( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyR . s c C@ sÍ y | j | ƒ } Wn§ t j k
rL } t j | | | j t | ƒ ƒ ‚ nq t j k
r‰ } t j d t
j | j ƒ | j f ƒ ‚ n4 t
k
r¼ } t j | | | j t | ƒ ƒ ‚ n Xt j | | ƒ S( Ns %s: %s( t _gett urlerrt httperrorR t
StoreErrorR R" t urlerrorR R R R t reasonR! R t copyandhash( R t tmpfileR# R t chunksR% ( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyt _getfile8 s $ "%c C@ s9 | j j | ƒ } g | D] } | | r | ^ q } | S( N( R
R ( R R t existslocallymapR t localhashes( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyt _hashesavailablelocallyJ s #c
C@ sU t } g | D] \ } } } | ^ q
} | j | ƒ } | j g | D] } | | k rD | ^ qD ƒ } xé | D]á \ } } } | | k rÀ | | | f }
| j j | |
g ƒ } | rMt } qMql | | } | rl | d k r| j j t d ƒ | | f ƒ t } qM| d k r:| j j t d ƒ | | f ƒ t } qMt d | ƒ ‚ ql ql W| S( Ni s" changeset %s: %s: contents differ
i s changeset %s: %s missing
s6 verify failed: unexpected response from statlfile (%r)(
t FalseR2 R R
t _verifyfilest TrueR t warnR t RuntimeError(
R t contentst filestocheckt failedt csetR# t expectedhasht expectedhashesR1 t statst filetocheckt verifyresultt stat( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyR4 O s8
c C@ s
t j | ƒ S( s Support for remote batching.( R t remotebatch( R ( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyt batchp s c C@ s t d ƒ ‚ d S( s1 Put file with the given hash in the remote store.s abstract methodN( t NotImplementedError( R R R$ ( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyR t s c C@ s t d ƒ ‚ d S( s/ Get a iterator for content with the given hash.s abstract methodN( RD ( R R ( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyR& x s c C@ s t d ƒ ‚ d S( s× Get information about availability of files specified by
hashes in the remote store. Return dictionary mapping hashes
to return code where 0 means that file is available, other
values if not.s abstract methodN( RD ( R R ( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyR | s ( t __name__t
__module__t __doc__R
R R R R/ R2 R4 RC R R& R ( ( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyR s
! N( RG t
__future__R t mercurial.i18nR t mercurialR R R t R R R R' t urlreqR ( ( ( s@ /usr/lib/python2.7/dist-packages/hgext/largefiles/remotestore.pyt <module> s