mò óRÅDc@s:dkTdkTdklZdkTeeƒdƒeeƒdƒdeifd„ƒYZ d„Z ddd„Z de ifd „ƒYZd e ifd „ƒYZeed ƒZeo9d eifd„ƒYZdeeifd„ƒYZndefd„ƒYZdefd„ƒYZdefd„ƒYZdS((t*(sgettexts/hg os urllib urllib2 urlparse zlib util httplibserrno keepalive tempfile sockett passwordmgrcBstZd„Zd„ZRS(NcCstii|ƒ||_dS(N(turllib2tHTTPPasswordMgrWithDefaultRealmt__init__tselftui(RR((t6/usr/lib/python2.4/site-packages/mercurial/httprepo.pyRscCstii|||ƒ}|\}}|o|o||fSn|i i pt i t dƒƒ‚n|i it dƒƒ|i it dƒ|ƒ|o|i it dƒ|ƒn|i it dƒddƒ}|p|i iƒ}n|i||||ƒ||fS(Nshttp authorization requiredshttp authorization required s realm: %s s user: %s suser:tdefault(RRtfind_user_passwordRtrealmtauthuritauthinfotusertpasswdRt interactivetutiltAbortt_twritetstatustprompttNonetgetpasst add_password(RR R RR R ((RR s  (t__name__t __module__RR (((RRs cCsû|idƒ}|djod\}}nz|| ||d}}|idƒ}|djoti |ƒd}}n+ti || ƒ}ti ||dƒ}|idƒ}|djo|d}}n|| ||d}}||||fS(s/split [user[:passwd]@]host[:port] into 4-tuple.t@iÿÿÿÿit:N(NN( tnetloctfindtaRR Rtuserpasstcturllibtunquotethosttport(RRRR!R$R R R%((Rt netlocsplit+s   cCst|o|d|}n|}|oJ|o$ti|ƒdti|ƒ}nti|ƒ}|d|Sn|S(s?turn host, port, user, passwd into [user[:passwd]@]host[:port].RRN(R%R$thostportR RR"tquoteR (R$R%R RR'R ((Rt netlocunsplit@s$thttpconnectioncBstZd„ZRS(NcCset|tƒotii||ƒn;|idƒx*ti |ƒD]}tii||ƒqDWdS(Ni( t isinstancetdatatstrt keepalivetHTTPConnectiontsendRtseekRt filechunkitertchunk(RR,R3((RR0Qs  (RRR0(((RR*NstbasehttphandlercBstZd„ZRS(NcCs|it|ƒS(N(Rtdo_openR*treq(RR6((Rt http_open[s(RRR7(((RR4Zst HTTPSHandlerthttpsconnectioncBstZeiZd„ZRS(NcCset|tƒotii||ƒn;|idƒx*ti |ƒD]}tii||ƒqDWdS(Ni( R+R,R-thttplibtHTTPSConnectionR0RR1RR2R3(RR,R3((RR0ds  (RRR.t HTTPResponsetresponse_classR0(((RR9`s t httphandlercBstZd„ZRS(NcCs|it|ƒS(N(RR5R9R6(RR6((Rt https_openns(RRR?(((RR>mscBstZRS(N(RR(((RR>qsthttprepositorycBswtZd„Zd„ZeeƒZd„Zd„Zd„Zd„Z d„Z d„Z d „Z d „Z d „ZRS( Nc CsÛd|_ti|ƒ\}}}}}|p|o$t i t dƒ|p|ƒ‚n|p d}nt|ƒ\}} }}ti|t|| ƒ|ddfƒ|_||_|iddƒp tidƒ}d}tƒ}|oì|idƒp |idƒpd|d}nti|ƒ}|\}}}}}t|ƒ} | \} }}}|p(|idd ƒ}|idd ƒ}nd d g} | i+g}|i-dd ƒD]}||i/ƒq¹~ƒ| i+g}tiddƒi0dƒD]*}|i1ƒo||i1ƒi/ƒqüqü~ƒ|i2ddƒ o.|i/ƒ| jo|i3t dƒ|ƒqÙti|t| |||pdƒ|||fƒ}t4i5h||<ƒ}|i3t dƒ|ƒnxRdddgD]A}y%ti7i8|ƒoti7|=nWqét9j oqéXqéWt:|ƒ} |oV|i3t dƒ||odt<|ƒpdfƒ| i=d|||pdƒnt4i>|t4i?| ƒt4i@| ƒƒ}dg|_Bt4iC|ƒdS(Nsunsupported URL component: "%s"t/tt http_proxyR$shttp:shttps:shttp://R Rt localhosts 127.0.0.1tnotno_proxyt,talwayssdisabling proxy for %s sproxying through %s t HTTP_PROXYs http auth: user %s, password %s Rsnot sets User-agentsmercurial/proto-1.0(s User-agentsmercurial/proto-1.0(DRRtcapsturlparseturlsplittpathtschemeRturlpathtquerytfragRRRR&R$R%R Rt urlunsplitR)turlRtconfigtostgetenvtproxyurlt proxyauthinfoR>thandlert startswithtsnpqft proxyschemet proxynetloct proxypatht proxyqueryt proxyfragthpupt proxyhostt proxyportt proxyusert proxypasswdtno_listtextendt_[1]t configlisttptlowertsplittstript configbooltdebugRt ProxyHandlertenvtenvironthas_keytOSErrorRtpassmgrtlenRt build_openertHTTPBasicAuthHandlertHTTPDigestAuthHandlertopenert addheaderstinstall_opener( RRRMRcR_RORWRPReR%RfRaRuRbRdRYRqR[RNRQRXRRR$RzR R^R\RjRhR]R`((RRus^ $ * "    :Z'"  5!   cCs‰|idjory|idƒiƒ|_Wntij of|_nX|iit dƒdi |ipdgƒƒn|iS(Nt capabilitiesscapabilities: %s t tnone( RRJRtdo_readRlthgt RepoErrorRRoRtjoin(R((Rtget_capsÂs4cCstitdƒƒ‚dS(Ns!operation not supported over http(RRR(R((RtlockÎsc Ks|iddƒ}|idhƒ} |iitdƒ|ƒhd|<} | i |ƒt i | ƒ} d|i| f}y"titi||| ƒƒ}Wn‘tij o5}|idjotitdƒƒ‚n‚nOtij o?}|iitdƒ|ƒ|iiƒtd|ƒ‚nXy|id ƒ}Wn t j o|id }nX|i!d ƒ oB|i!d ƒ o1|i!d ƒ o t"i#td ƒ|iƒ‚n|i!d ƒoG|d}t%|ƒdjo&t"i#tdƒ|i|fƒ‚qn|S(NR,theadersssending %s command tcmds%s?%si‘sauthorization faileds$http error while sending %s command s content-typesapplication/mercurials text/plainsapplication/hg-changegroups+'%s' does not appear to be an hg repositoryif0.10000000000000001s'%s' uses newer protocol %s(&targstpopRR,R†RRRoRR‡tqtupdateR"t urlencodetqsRStcuRturlopentRequesttrespt HTTPErrortinsttcodeRRR:t HTTPExceptiont print_exctIOErrort getheadertprototAttributeErrorRZRR‚tversiontfloat( RR‡RˆR‘RŽR™R›R“R,RRŠR†((Rtdo_cmdÑs8 " 3  *cKs2|i||}z|iƒSWd|iƒXdS(N(RRR‡Rˆtfptreadtclose(RR‡RˆRž((RR€÷s cCs`|idƒ}ytt|d idƒƒSWn,|iitdƒ|d dƒ‚nXdS(NtheadsiÿÿÿÿR~sunexpected response: is ... ( RR€tdtmaptbinRlRtwarnR(RR¢((RR¡ÿs "cCs§ditt|ƒƒ}|idd|ƒ}yGg}|i ƒD]%}|t tt |i dƒƒƒqA~}|SWn,|iitdƒ|d dƒ‚nXdS(NR~tbranchestnodessunexpected response: is ... (RƒR£thexR§tnRR€R¢Rht splitlinestbttupleR¤RltbrRR¥R(RR§R«R¢R©RhR­((RR¦s?"cCsÓdig}|D]}|ditt|ƒƒq~ƒ}|idd|ƒ}yOg}|i ƒD]-}||ott |i dƒƒpgqe~}|SWn,|iitdƒ|d dƒ‚nXdS( Ns t-tbetweentpairsR~sunexpected response: is ... (RƒRhR°RjR£R¨R©RR€R¢RªtlR¤RlRR¥R(RR°R¢R±R©RhRj((RR¯s<G"cCsXditt|ƒƒ}|idd|ƒ}d}d„}t i |t i |ƒƒƒS(NR~t changegrouptrootsiccsltiƒ}y"x|D]}|i|ƒVqWWn-tij o}t dt dƒƒ‚nX|i ƒVdS(Nsconnection ended unexpectedly( tzlibt decompressobjtzdtftchnkt decompressR:R•R“R—RRtflush(R·R¶R¸R“((Rt zgenerator s ( RƒR£R¨R§R©RRR·tbytesR»Rt chunkbufferR2(RR§tkindR·R¼R»R©((RR²s  c Csrtiddƒ\} } ti| dƒ}z)x$ti|ƒD]} |i | ƒq=W|i ƒ}y‡|idd|dhd|<dd tremoterepositoryR@R×( R@R>RR×R&R4R)R*R9RØR((Rt?s"    Ø