q&f'dZddlmZddlmZmZddlmZmZddl m Z m Z m Z ejZ ejZGdde jZy ) z4remote largefile store; the base class for wirestore)_)errorutil) stringutilurlutil) basestorelfutil localstorecXeZdZdZfdZdZdZdZdZdZ dZ d Z d Z d Z xZS) remotestorez)a largefile store accessed over a networkctt| |||d|_|;t j|j |j |j |_yyN)superr __init___lstorer uirepo)selfrrurl __class__s >/usr/lib/python3/dist-packages/hgext/largefiles/remotestore.pyrzremotestore.__init__"sJ k4)"dC8  %00$))TYYODL c4|j||r@tjtd|t j |j fz|jjtd|t j |j fzy)Ns0remotestore: could not put %s to remote store %ss'remotestore: put %s to remote store %s ) sendfilerAbortrr hidepasswordrrdebug)rsourcehashs rputzremotestore.put(s} == &++EF7//9:;   9 :w++DHH56 7 rcz|j|jDcic] \}}||dk( c}}Scc}}w)Nr)_statitems)rhasheshss rexistszremotestore.exists3sB**V,224 A qAvI   s7cb|jjd||fz tj|j|5}|j ||cdddS#1swYyxYw#t $r;}t jtd|tj|fzd}~wwxYw)Nsremotestore: sendfile(%s, %s) s'remotestore: could not open file %s: %s) rrr httpsendfile_putIOErrorrrrr forcebytestr)rfilenamer fdes rrzremotestore.sendfile:s  8Hd;KKL $$TWWh7 +2yyr* + + + ++<=Z44Q789  s5 A*A A*A'#A*'A** B.36B))B.c " |j|}tj ||S#tj$r:}tj|||j t j|d}~wtj$rF}tjdtj|j |jfzd}~wt$r:}tj|||j t j|d}~wwxYw)Ns%s: %s)_geturlerr httperrorr StoreErrorrrr-urlerrorrrrrreasonr,r copyandhash)rtmpfiler.r chunksr0s r_getfilezremotestore._getfileEs YYt_F&!!&'22% &&$**A*A!*D  ++W11$((;QXXFF  &&$**A*A!*D  s-)D5A11DAC D5D  Dcp|jj|}|Dcgc] }||s | }}|Scc}wr)rr()rr%existslocallymapr localhashess r_hashesavailablelocallyz#remotestore._hashesavailablelocally\s><<..v6(.I2B42HtI IJs 33cd}|Dcgc]\}}}| }}}}|j|}|j|Dcgc]}||vr| c}} |D]\}}}||vr(|||f} |jj|| g} | s0d}3| |} | s;| dk(r,|jj t d||fzd}l| dk(r,|jj t d||fzd}td| z|Scc}}}wcc}w)NFTrs"changeset %s: %s: contents differ schangeset %s: %s missing s6verify failed: unexpected response from statlfile (%r))r?r#r _verifyfilesrwarnr RuntimeError) rcontents filestocheckfailedcsetr. expectedhashexpectedhashesr>stats filetocheck verifyresultstats rrBzremotestore._verifyfilesas[=I  9T8\L  22>B  %3  {2  -9  (D(L{*#X|< #||88{m   !F\*qy DE#X./"& ;<h?OO"&*359:/ 6 O  s C> Dctd)z1Put file with the given hash in the remote store.abstract methodNotImplementedError)rr r/s rr+zremotestore._put!"455rctd)z/Get a iterator for content with the given hash.rPrQ)rr s rr2zremotestore._getrSrctd)zGet 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.rPrQ)rr%s rr#zremotestore._stats ""455r)__name__ __module__ __qualname____doc__rr!r(rr;r?rBr+r2r# __classcell__)rs@rr r s:3P    3. )V666rr N)rYmercurial.i18nr mercurialrrmercurial.utilsrrr r r r3urlreqr rrrasI;    z6)%%z6r