6hbXPSrSSKJr SSKrSSKrSSKrSSKrSSKJr SSK J r SSK J r J r Jr SSKJr \R"r\R$r\R&rSq"S S 5r"S S 5r"S S\\R.5r"SS\R25rSrSr"SS\R85rSrSrSSjrSr SSjr!\"S:Xa3SSK#r#\$"\RJS5r&\RJSr'\!"\'\&5 gg!\(\)4a \*"S\RJS-5 gf=f)aKAn HTTP handler for urllib2 that supports HTTP 1.1 and keepalive. >>> import urllib2 >>> from keepalive import HTTPHandler >>> keepalive_handler = HTTPHandler() >>> opener = urlreq.buildopener(keepalive_handler) >>> urlreq.installopener(opener) >>> >>> fo = urlreq.urlopen('http://www.python.org') If a connection to a given host is requested, and all of the existing connections are still in use, another connection will be opened. If the handler tries to use an existing connection but it fails in some way, it will be closed and removed from the pool. To remove the handler, simply re-run build_opener with no arguments, and install that opener. You can explicitly close connections by using the close_connection() method of the returned file-like object (described below) or you can use the handler methods: close_connection(host) close_all() open_connections() NOTE: using the close_connection and close_all methods of the handler should be done with care when using multiple threads. * there is nothing that prevents another thread from creating new connections immediately after connections are closed * no checks are done to prevent in-use connections from being closed >>> keepalive_handler.close_all() EXTRA ATTRIBUTES AND METHODS Upon a status of 200, the object returned has a few additional attributes and methods, which should not be used if you want to remain consistent with the normal urllib2-returned objects: close_connection() - close the connection to the host readlines() - you know, readlines() status - the return status (i.e. 404) reason - english translation of status (i.e. 'File not found') If you want the best of both worlds, use this inside an AttributeError-catching try: >>> try: status = fo.status >>> except AttributeError: status = None Unfortunately, these are ONLY there if status == 200, so it's not easy to distinguish between non-200 responses. The reason is that urllib2 tries to do clever things with error codes 301, 302, 401, and 407, and it wraps the object upon return. ) annotationsN)_)hex)pycompat urllibcompatutil)procutilc@\rSrSrSrSrSrSrSrSr S S jr S r g) ConnectionManagerlzH The connection manager must be able to: * keep track of all existing c[R"5Ul[R"[ 5Ul0Ul0UlgN) threadingLock_lock collections defaultdictlist_hostmap_connmap _readymapselfs 5/usr/lib/python3/dist-packages/mercurial/keepalive.py__init__ConnectionManager.__init__rs0^^% #//5  c URR5 URURU5 XRU'X0R U'URR 5 g!URR 5 f=fr)racquirerappendrrrelease)rhost connectionreadys raddConnectionManager.addxsg  ! MM$  & &z 2(,MM* %).NN: & JJ   DJJ   s :A11B cURR5 URUnURU URU URUR U5 URU(d URU URR5 g![ a N'f=f!URR5 f=fr)rr rrrremoveKeyErrorr")rr$r#s rr)ConnectionManager.removes  ! ,}}Z0MM*-NN:. d#**:6}}T* d+ JJ      JJ   s)B AB0 B-*B0,B--B00C cBX RU'g![a gf=fr)rr*)rr$r%s r set_readyConnectionManager.set_readys% ).NN: &   s  c,SnURR5 URUH*nURU(dMSURU'Un O URR 5 U$!URR 5 f=f)NF)rr rrr")rr#conncs rget_ready_conn ConnectionManager.get_ready_conns  !]]4(>>!$$(-DNN1%D ) JJ     JJ   s$A7A77BNc U(a[URU5$[URR5VVs0sHup#U[U5_M snn5$s snnfr)rrdictitems)rr#hconnss rget_allConnectionManager.get_allsT  d+, ,26--2E2E2GH2GJQDK2GH HsA" )rrrrr) __name__ __module__ __qualname____firstlineno____doc__rr&r)r-r2r9__static_attributes__rrr r ls%  !!  rr cX\rSrSrSSjrSrSrSrSrSSjr S r S r S r S r S rg)KeepAliveHandlerNcJ[5UlXlSUlSUlgNr)r _cm_timeout requestscountsentbytescount)rtimeouts rrKeepAliveHandler.__init__s!$& rcURR5R5VVs/sHupU[U54PM snn$s snnf)zlreturn a list of connected hosts and the number of connections to each. [('foo.com:80', 2), ('bar.org', 1)])rGr9r6len)rr#lis ropen_connections!KeepAliveHandler.open_connectionss>37((2B2B2D2J2J2LM2LJTs2w2LMMMsA cURRU5H.nURRU5 UR5 M0 g)zclose connection(s) to host is the host:port spec, as in 'www.cnn.com:8080' as passed in. no error occurs if there is no connection to that host.N)rGr9r)close)rr#r7s rclose_connection!KeepAliveHandler.close_connections6!!$'A HHOOA  GGI(rcURR5R5H9upUH.nURRU5 UR 5 M0 M; g)zclose all open connectionsN)rGr9r6r)rS)rr#r8r7s r close_allKeepAliveHandler.close_allsG88++-335KD" 6rc<URRUS5 g)z]tells us that this request is now closed and that the connection is ready for another requestTN)rGr-)rrequestr#r$s r_request_closed KeepAliveHandler._request_closeds :t,rchU(aUR5 URRU5 gr)rSrGr))rr#r$rSs r_remove_connection#KeepAliveHandler._remove_connections!       #rc.UR[U5$r)do_openHTTPConnection)rreqs r http_openKeepAliveHandler.http_opens||NC00rc[R"U5nU(d[RS5eURR U5nU(aiUR XBU5nU(aOUR5 URRU5 URR U5nU(aMiU"X0RS9n[(a [RSU[U55 URRX4S5 URXB5 UR5n[1USS5(aURRU5 [(a+[RSUR2UR45 XlX5lUR;5UlXElUR2Ul URBUl"UR4Ul!U$![ R"aDn[R[%S5[&R("UR*5-5eSnAf[,[ R.4an[RU5eSnAff=f) Ns no host given)rKs"creating new connection to %s (%d)Fsbad HTTP status line: %s will_closeTsSTATUS: %s, %s)#rgethosturlerrurlerrorrGr2_reuse_connectionrSr)rHDEBUGinfoidr&_start_transaction getresponsehttplib BadStatusLinerrsysbyteslineOSError HTTPExceptiongetattrstatusreason_handler_host get_full_url_url _connectioncodemsgheaders)r http_classrcr#r7rerrs rraKeepAliveHandler.do_opens##C(//"23 3 '''-A**148 "HH++D1!t]];5JJ=tRU Te,''/MMO 1lD ) ) HHOOA  5 JJ(!((AHH = !!# EE /$$ //-.1B1B3881LL ../ '//#& & 's1;G70A G7?A8G77J ?I  J'I<<JcURX5 UR5nUbURS:Xa/[ (a [ RSU[U55 SnU$[ (a [ RSU[U55 U$![[R4a SnN [ (a [ R SU[U55 URRU5 UR5 e=f)astart the transaction with a re-used connection return a response object (r) upon success or None on failure. This DOES not close or remove bad connections in cases where it returns. However, if an unexpected exception occurs, it will close and remove the connection before re-raising. Ns4unexpected exception - closing connection to %s (%d) s&failed to re-use connection to %s (%d)sre-using connection to %s (%d)) rorprurqrvrlerrorrnrGr)rSversionrm)rr7rcr#rs rrk"KeepAliveHandler._reuse_connections   # #A + A2 9 Q u =tRUA u 6KeepAliveHandler._start_transaction..KsK?41A?s!#)r#zaccept-encodingrskip_-rz content-typez Content-typez!application/x-www-form-urlencodedzcontent-lengthzContent-lengthz%d)rwr sortdictparent addheadersupdatesortedrr6unredirected_hdrsreplacerhasdatagetdata putrequest get_method getselector putheaderrNrurirj endheaderssendrIrJAttributeError) rr7rc oldbytescountr skipheadersrdatarkrs rro#KeepAliveHandler._start_transactionBs_#3Q7 -- 6 67vckk//123vc3399;<=--K7==?KK ,A|=> GaiiS&99:- '##C((#++C0 NN$ ,,S1" "0KK&(K$72KK 0$T2BC NN$ ,,S1"MMODA KK $     $ $ FF4L a wq*:A>NN  KK % % * % KK & &+Q/-?  & '//#& & '"   s22B#J96J9,A K 9 KKK K-,K-)rGrHrIrJrr)r;r<r=r>rrPrTrWr[r^rdrarkror@rArrrCrCs7 N - $ 17r0d4rrCc\rSrSrSrg) HTTPHandleriyrAN)r;r<r=r>r@rArrrrysrrcn^\rSrSrS SjrSrSrSrSrS U4Sjjr S SU4Sjjjr U4S jr S r U=r $) HTTPResponsei}c[RRXX$S9 URUlSUlSUlSUlSUlSUlSUl SUl SUl g)N) debuglevelmethodrri) rqrrfilenorreceivedbytescount_rbuf _rbufsizerzr{r}r~)rsockrstrictrs rrHTTPResponse.__init__sg%% : & kk  "#    rcUR(adURR5 SUlUR(a1URRXRUR 5 gggr)fprSrzr[r{r~rs rrSHTTPResponse.closesO 77 GGMMODG}} --**d&6&6 rc$UR5 grrSrs r _close_connHTTPResponse._close_conns  rcURRURURSS9 UR 5 g)Nrr)rzr^r{r~rSrs rrTHTTPResponse.close_connections. ((T5E5EQ(O rcUR$r)r}rs rgeturlHTTPResponse.geturls yyrcJ>[TU]U5nU=R[U5- slURb(UR=R[U5- slUR b2UR R =R[U5- slU$r)superreadrrNr~rzr)ramtr __class__s rrHTTPResponse.reads{w|C  3t9,    '    / /3t9 < / == $ MM 3 3s4y @ 3 rcF>[TU]US9nU=R[U5- slURb(UR=R[U5- slUR b2UR R =R[U5- slU$)N)limit)rreadlinerrNr~rzr)rrrrs rrHTTPResponse.readlineswe, 3t9,    '    / /3t9 < / == $ MM 3 3s4y @ 3 rc>[TU]U5nU=RU- slURbUR=RU- slURb)URR =RU- slU$r)rreadintorr~rzr)rdestgotrs rrHTTPResponse.readintospgt$ 3&    '    / /3 6 / == $ MM 3 3s : 3 r) r~rzr{rrr}rrrr)rrNr))rint)r;r<r=r>rrSrrTrrrrr@ __classcell__rs@rrr}s5  &rrc<[USS5bgURc2UR(aUR5 O[R eUR S:a[S[U55 Sn[USS5nUbvUR S:a [S5 U"U5nU(aKURRU5 U=R[U5- sl U"U5nU(aMJggURRU5 U=R[U5- sl g![aZ UR[R:XaSUlUR!5UlSnOS nUR#5 U(aegf=f) zXSend `str' to the server. Shamelessly ripped off from httplib to patch a bad behavior. _broken_pipe_respNrssend:i rssending a read()ableFT)rwr auto_openconnectrq NotConnectedrprintreprsendallrJrNBrokenPipeError_HTTPConnection__state _CS_REQ_SENTrrprS)rstr blocksizerrreraises rsafesendrsRt($/; yy >> LLN&& &  hS " sFD)  "-. ?D !!$'##s4y0#I$ II  c "   3s8 +     & &'*>*> >%)D "%)%5%5%7D "GG    s5BD7=9D77A!FFcJ^U4SjnTRRUlU$)z9Wraps getresponse in cls with a broken-pipe sane version.cJ>[USS5nUbU$TRU5$)Nr)rwrp)rrclss rsafegetresponse(wrapgetresponse..safegetresponses- D-t 4 =Ht$$r)rpr?)rrs` rwrapgetresponsers"%"oo55O rcZ^\rSrSr\r\r\"\ R5r Sr U4Sjr SrU=r$)rbi ch[RR"U/UQ70UD6 SUlSUlgrF)rqrbrrJr)rargskwargss rrHTTPConnection.__init__s0''>t>v>"#rc>[TU]5nSnURnU(aSUR5-nSXUR UR 4-$![a N(f=f)Nz (unconnected)z%s:%dz<%s: %s <--> %s:%d>)r__repr__r getsocknamerur#port)rbaselocalsrs rrHTTPConnection.__repr__sfw! II  !--/1%TYY 'JJJ  sA A"!A")rrJ)r;r<r=r>rresponse_classrrrrqrbrprrr@rrs@rrbrb s0 "N D!'"8"89K$ K KrrbcZ[RnSn[R5n[R U5 [R U5nUR 5nUR5 U"U5n[US[UR554-5 [R[55n[R U5 [R U5nUR 5nUR5 U"U5n[US[UR554-5 [R U5nSnUR5nU(aXW-nOOMUR5 U"U5n[US[UR554-5 g)Ns%25s: %ss normal urllibskeepalive readrskeepalive readline) hashlibmd5urlreq buildopener installopenerurlopenrrSrrdigestrr)urlrformatopenerfofoomfs r continuityr ,sD ++C F   !F   B '')CHHJ CA &$c!((*o6 67   .F   B '')CHHJ CA &%s188:7 78  B C  KKM 'C   HHJ CA &)3qxxz?; ;.FakeLoggeri~c[X-5 gr)r)rrrs rdebug&test_timeout..FakeLogger.debugs #* rrAN) r;r<r=r>r!rmwarningrr@rArr FakeLoggerr~s "'&&wrr$s- fetching the file to establish a connections; waiting %i seconds for the server to close the connectionrs %2ir s! fetching the file a second times data are identicals ERROR: DATA DIFFER) rlrrrrrSr r r flushrrstderr)rdbbackupr$rdata1rdata2s r test_timeoutr,zsH'' LE :;  B GGIEHHJ A H1 LM a%j1n- 1  Q a%  OO%  ./  B GGIEHHJ ~ %& E %& Erc[S5 [U5 [S5 [S5 [X5 [S5 [S5 [U5 g)Ns>performing continuity test (making sure stuff isn't corrupted)rsperforming speed comparisons#performing dropped-connection check)rr rr,)rrs rtestr.sA KLsO #J ()L #J 01r__main__z%s r) )+r? __future__rrrsysri18nrnoderrrr utilsr rqrirrlr rC httphandlerrrrrrbr rrr,r.r;rrargvrr IndexError ValueErrorrrArrr<s;47v#   ,,   >>BIIX "F$6$6 E7''EP3l"KW++K@!=H5&.#L z  hhqk S!   #2 "SXXa[012s$D D%$D%