ó ­œž[c@`sfdZddlmZmZmZddlZddlZddlmZm Z m Z ddl m Z m Z ddlmZddlmZddlmZdd lmZmZdd lmZdd lmZmZd efd „ƒYZdefd„ƒYZdefd„ƒYZdejfd„ƒYZdej fd„ƒYZ!defd„ƒYZ"dS(sFClient and server implementations of HTTP/1.x. .. versionadded:: 4.0 i(tabsolute_importtdivisiontprint_functionN(tFuturetfuture_add_done_callbackt"future_set_result_unless_cancelled(t native_strtutf8(tgen(thttputil(tiostream(tgen_logtapp_log(t stack_context(tGzipDecompressortPY3t_QuietExceptioncB`seZd„ZRS(cC`sdS(N((tself((s6lib/python2.7/site-packages/tornado/http1connection.pyt__init__&s(t__name__t __module__R(((s6lib/python2.7/site-packages/tornado/http1connection.pyR%st_ExceptionLoggingContextcB`s)eZdZd„Zd„Zd„ZRS(s°Used with the ``with`` statement when calling delegate methods to log any exceptions with the given logger. Any exceptions caught are converted to _QuietException cC`s ||_dS(N(tlogger(RR((s6lib/python2.7/site-packages/tornado/http1connection.pyR/scC`sdS(N((R((s6lib/python2.7/site-packages/tornado/http1connection.pyt __enter__2scC`s8|dk r4|jjdd|||fƒt‚ndS(NsUncaught exceptiontexc_info(tNoneRterrorR(Rttyptvaluettb((s6lib/python2.7/site-packages/tornado/http1connection.pyt__exit__5s (RRt__doc__RRR(((s6lib/python2.7/site-packages/tornado/http1connection.pyR*s  tHTTP1ConnectionParameterscB`s,eZdZeddddded„ZRS(sDParameters for `.HTTP1Connection` and `.HTTP1ServerConnection`. cC`sO||_|pd|_|p!d|_||_||_||_||_dS(s; :arg bool no_keep_alive: If true, always close the connection after one request. :arg int chunk_size: how much data to read into memory at once :arg int max_header_size: maximum amount of data for HTTP headers :arg float header_timeout: how long to wait for all headers (seconds) :arg int max_body_size: maximum amount of data for body :arg float body_timeout: how long to wait while reading body (seconds) :arg bool decompress: if true, decode incoming ``Content-Encoding: gzip`` iN(t no_keep_alivet chunk_sizetmax_header_sizetheader_timeoutt max_body_sizet body_timeoutt decompress(RR!R"R#R$R%R&R'((s6lib/python2.7/site-packages/tornado/http1connection.pyR>s    N(RRRtFalseRR(((s6lib/python2.7/site-packages/tornado/http1connection.pyR ;s tHTTP1ConnectioncB`seZdZddd„Zd„Zejd„ƒZd„Z d„Z d„Z d„Z d„Z d „Zd „Zddd „Zd „Zdd „Zd„Zd„Zd„Zd„Zd„Zd„Zejd„ƒZejd„ƒZejd„ƒZRS(s…Implements the HTTP/1.x protocol. This class can be on its own for clients, or via `HTTP1ServerConnection` for servers. cC`sÝ||_||_|dkr*tƒ}n||_||_|j|_|jjp]|jj|_ |jj |_ t |_ t |_tƒ|_t |_|jƒd|_d|_d|_d|_d|_d|_dS(s :arg stream: an `.IOStream` :arg bool is_client: client or server :arg params: a `.HTTP1ConnectionParameters` instance or ``None`` :arg context: an opaque application-defined object that can be accessed as ``connection.context``. N(t is_clienttstreamRR tparamstcontextR!R%tmax_buffer_sizet_max_body_sizeR&t _body_timeoutR(t_write_finishedt_read_finishedRt_finish_futuret_disconnect_on_finisht_clear_callbackst_request_start_linet_response_start_linet_request_headerst_chunking_outputt_expected_content_remainingt_pending_write(RR+R*R,R-((s6lib/python2.7/site-packages/tornado/http1connection.pyR[s*                  cC`s1|jjr$t||jjƒ}n|j|ƒS(sHRead a single HTTP response. Typical client-mode usage is to write a request using `write_headers`, `write`, and `finish`, and then call ``read_response``. :arg delegate: a `.HTTPMessageDelegate` Returns a `.Future` that resolves to None after the full response has been read. (R,R't_GzipMessageDelegateR"t _read_message(Rtdelegate((s6lib/python2.7/site-packages/tornado/http1connection.pyt read_response‹s c c`sµt}zbyù|jjdd|jjƒ}|jjdkrF|V}nfy6tj|jj j ƒ|jj|dt j ƒV}Wn-tj k r«|jƒtjtƒ‚nX|j|ƒ\}}|jråtj|ƒ}||_n!tj|ƒ}||_||_|j||ƒ |_t}ttƒ+|j||ƒ}|dk rU|VnWdQX|jdkr‚t}tjtƒ‚nt}|jr3|jdk r»|jjdkr»t}n|j}|dkrÙt}n|dkre|dkred|ks d |krtj d |ƒ‚n|j!|ƒVqen2|j"d ƒd kre|j# re|jj$d ƒn|s2|j%|jrƒ|jnd||ƒ} | dk r2|j&dkrµ| Vq/y1tj|jj j ƒ|j&| dt j ƒVWq/tj k r+t'j(d|j)ƒ|jjƒtjtƒ‚q/Xq2nt|_*|j# sN|jrtt}ttƒ|j+ƒWdQXn|j,j-ƒ rÁ|jdk rÁ|jj.ƒ rÁ|jj/|j0ƒ|j,Vn|jrà|jrà|jƒn|jdkrtjtƒ‚nWnbtj k rf} t'j(d|j)| ƒ|jsJ|jj$dƒVn|jƒtjtƒ‚nXWd|r‘ttƒ|j1ƒWdQXnd}|j2ƒXtjtƒ‚dS(Ns ? ? t max_bytestquiet_exceptionstHEADi0idiÈsContent-LengthsTransfer-Encodings!Response code %d cannot have bodytExpects 100-continuesHTTP/1.1 100 (Continue) isTimeout reading body from %ss"Malformed HTTP message from %s: %ssHTTP/1.1 400 Bad Request (3R(R+tread_until_regexR,R#R$RRt with_timeouttio_loopttimeR tStreamClosedErrort TimeoutErrortclosetReturnt_parse_headersR*R tparse_response_start_lineR7tparse_request_start_lineR6R8t_can_keep_aliveR4tTrueRR theaders_receivedtmethodtcodetHTTPInputErrorR=tgetR1twritet _read_bodyR0R tinfoR-R2tfinishR3tdonetclosedtset_close_callbackt_on_connection_closeton_connection_closeR5( RR>tneed_delegate_closet header_futuret header_datat start_linetheaderst skip_bodyRSt body_futurete((s6lib/python2.7/site-packages/tornado/http1connection.pyR=šsº                 !              cC`sAd|_d|_d|_|jdk r=|jjdƒndS(sªClears the callback attributes. This allows the request handler to be garbage collected more quickly in CPython by breaking up reference cycles. N(Rt_write_callbackt _write_futuret_close_callbackR+R\(R((s6lib/python2.7/site-packages/tornado/http1connection.pyR5 s    cC`stj|ƒ|_dS(s$Sets a callback that will be run when the connection is closed. Note that this callback is slightly different from `.HTTPMessageDelegate.on_connection_close`: The `.HTTPMessageDelegate` method is called when the connection is closed while recieving a message. This callback is used when there is not an active delegate (for example, on the server side this callback is used if the client closes the connection after sending its request but before receiving all the response. N(R twrapRi(Rtcallback((s6lib/python2.7/site-packages/tornado/http1connection.pyR\s cC`s[|jdk r+|j}d|_|ƒn|jjƒsMt|jdƒn|jƒdS(N(RiRR3RZRR5(RRk((s6lib/python2.7/site-packages/tornado/http1connection.pyR]$s   cC`sO|jdk r|jjƒn|jƒ|jjƒsKt|jdƒndS(N(R+RRJR5R3RZR(R((s6lib/python2.7/site-packages/tornado/http1connection.pyRJ0s  cC`sB|jƒ|j}d|_|jjƒs>t|jdƒn|S(s>Take control of the underlying stream. Returns the underlying `.IOStream` object and stops all further HTTP processing. May only be called during `.HTTPMessageDelegate.headers_received`. Intended for implementing protocols like websockets that tunnel over an HTTP handshake. N(R5R+RR3RZR(RR+((s6lib/python2.7/site-packages/tornado/http1connection.pytdetach7s    cC`s ||_dS(stSets the body timeout for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N(R0(Rttimeout((s6lib/python2.7/site-packages/tornado/http1connection.pytset_body_timeoutFscC`s ||_dS(swSets the body size limit for a single request. Overrides the value from `.HTTP1ConnectionParameters`. N(R/(RR%((s6lib/python2.7/site-packages/tornado/http1connection.pytset_max_body_sizeMsc C`s,g}|jrj||_|jtd|d|dfƒƒ|jdkoad|koad|k|_nð||_|jtd |d|d fƒƒ|jjd koì|jd koì|jdks×|jdkoìd|koìd|k|_|jjd kr|j rd|d†scs`s|]}|jdƒVqdS(tlatin1N(tencode(Rvtl((s6lib/python2.7/site-packages/tornado/http1connection.pys ˆss sNewline in header: s<callback argument is deprecated, use returned Future insteads s (RpRqRr(iÌi0N()R*R6tappendRRRR9R7tversionRSR4R8RUtlowerR:tintRtget_allRtextendt ValueErrortreprR+R[RRht set_exceptionR RHt exceptiontwarningstwarntDeprecationWarningR RjRgtjoint _format_chunkRVR;Rt_on_write_complete( RRbRctchunkRktlinest header_linestlinetfuturetdata((s6lib/python2.7/site-packages/tornado/http1connection.pyt write_headersTsf  %  %  !             cC`sŒ|jdk rU|jt|ƒ8_|jdkrU|jjƒtjdƒ‚qUn|jr„|r„tdt|ƒƒd|dS|SdS(Nis,Tried to write more data than Content-Lengths%xs ( R:RtlenR+RJR tHTTPOutputErrorR9R(RRŒ((s6lib/python2.7/site-packages/tornado/http1connection.pyRŠ¡s  cC`sÁd}|jjƒrKtƒ}|_|jjtjƒƒ|jjƒnr|dk r|t j dt ƒt j |ƒ|_ntƒ}|_|jj|j|ƒƒ|_|jj|jƒ|S(sÒImplements `.HTTPConnection.write`. For backwards compatibility it is allowed but deprecated to skip `write_headers` and instead call `write()` with a pre-encoded header block. s<callback argument is deprecated, use returned Future insteadN(RR+R[RRhR„R RHR…R†R‡RˆR RjRgRVRŠR;tadd_done_callbackR‹(RRŒRkR((s6lib/python2.7/site-packages/tornado/http1connection.pyRV°s  cC`sþ|jdk rT|jdkrT|jjƒ rT|jjƒtjd|jƒ‚n|jrš|jjƒsš|jjdƒ|_ |j j |j ƒqšnt |_ |js¸t |_n|jjt ƒ|j dkrç|jdƒnt|j |jƒdS(s$Implements `.HTTPConnection.finish`.is0Tried to write %d bytes less than Content-Lengths0 N(R:RR+R[RJR R”R9RVR;R•R‹RPR1R2R4t set_nodelayt_finish_requestR(R((s6lib/python2.7/site-packages/tornado/http1connection.pyRYÇs$     cC`s¤|jƒ}|dk r8t|tjƒ r8|jƒn|jdk ro|j}d|_|jjj |ƒn|j dk r |j }d|_ t |dƒndS(N( R…Rt isinstanceR RHtresultRgR+RFt add_callbackRhR(RRtexcRk((s6lib/python2.7/site-packages/tornado/http1connection.pyR‹äs      cC`s£|jjrtS|jdƒ}|dk r:|jƒ}n|jdkrS|dkSd|ks•|jddƒjƒdks•t|ddƒd krŸ|d kStS( NRssHTTP/1.1RJsContent-LengthsTransfer-EncodingRtRuRRRBtGETs keep-alive(RBRœ(R,R!R(RURR~R}tgetattr(RRbRctconnection_header((s6lib/python2.7/site-packages/tornado/http1connection.pyROñs     cC`sa|jƒ|j r+|jr+|jƒdS|jjtƒ|jjƒs]t |jdƒndS(N( R5R*R4RJR+R–R(R3RZRR(RR((s6lib/python2.7/site-packages/tornado/http1connection.pyR—s  cC`s`t|jdƒƒjdƒ}|jdƒ}|| jdƒ}tjj||ƒ}||fS(NRys s s (RtdecodetlstriptfindtrstripR t HTTPHeaderstparse(RR‘teolRbRc((s6lib/python2.7/site-packages/tornado/http1connection.pyRL s c`s¤d|krúd|kr*tjdƒ‚nd|dkr—tjd|dƒ‰t‡fd†ˆDƒƒr†tjd|dƒ‚nˆd|d%ss$Multiple unequal Content-Lengths: %ris*Only integer Content-Length is allowed: %ssContent-Length too longiÌs*Response with code %d should not have bodyRtRu(Ni(R RTtretsplittanyRR‚R/Rt_read_fixed_bodyRUR~t_read_chunked_bodyR*t_read_body_until_close(RRSRcR>tcontent_length((R¨s6lib/python2.7/site-packages/tornado/http1connection.pyRWs@            cc`s›x”|dkr–|jjt|jj|ƒdtƒV}|t|ƒ8}|j sZ|jrt t ƒ(|j |ƒ}|dk rŠ|VnWdQXqqWdS(Nitpartial( R+t read_bytestminR,R"RPR“R1R*RR t data_receivedR(RR¯R>tbodytret((s6lib/python2.7/site-packages/tornado/http1connection.pyR¬Is   cc`smd}x`trh|jjdddƒV}t|jƒdƒ}|dkr~|jjdƒV}|dkrztjdƒ‚ndS||7}||jkr©tjdƒ‚n|}xŽ|r?|jjt ||j j ƒd tƒV}|t |ƒ8}|j s|jr²ttƒ(|j|ƒ}|dk r3|VnWdQXq²q²W|jjdƒV}|dks t‚q WdS( Nis R@i@iis%improperly terminated chunked requestschunked body too largeR°(RPR+t read_untilRtstripR±R RTR/R²R,R"R“R1R*RR R³RtAssertionError(RR>t total_sizet chunk_lentcrlft bytes_to_readRŒRµ((s6lib/python2.7/site-packages/tornado/http1connection.pyR­Us0        cc`sJ|jjƒV}|j s#|jrFttƒ|j|ƒWdQXndS(N(R+tread_until_closeR1R*RR R³(RR>R´((s6lib/python2.7/site-packages/tornado/http1connection.pyR®rs N(RRRRRR?Rt coroutineR=R5R\R]RJRlRnRoR’RŠRVRYR‹ROR—RLRWR¬R­R®(((s6lib/python2.7/site-packages/tornado/http1connection.pyR)Us.0 p     M     1 R<cB`sDeZdZd„Zd„Zejd„ƒZd„Zd„Z RS(sIWraps an `HTTPMessageDelegate` to decode ``Content-Encoding: gzip``. cC`s||_||_d|_dS(N(t _delegatet _chunk_sizeRt _decompressor(RR>R"((s6lib/python2.7/site-packages/tornado/http1connection.pyR}s  cC`sR|jdƒdkr?tƒ|_|jd|dƒ|d=n|jj||ƒS(NsContent-EncodingtgzipsX-Consumed-Content-Encoding(RURRÁtaddR¿RQ(RRbRc((s6lib/python2.7/site-packages/tornado/http1connection.pyRQ‚s     cc`sœ|jrr|}x†|rn|jj||jƒ}|r_|jj|ƒ}|dk r_|Vq_n|jj}qWn&|jj|ƒ}|dk r˜|VndS(N(RÁR'RÀR¿R³Rtunconsumed_tail(RRŒtcompressed_datat decompressedRµ((s6lib/python2.7/site-packages/tornado/http1connection.pyR³s      cC`sG|jdk r:|jjƒ}|r:|jj|ƒq:n|jjƒS(N(RÁRtflushR¿R³RY(Rttail((s6lib/python2.7/site-packages/tornado/http1connection.pyRYžs cC`s |jjƒS(N(R¿R^(R((s6lib/python2.7/site-packages/tornado/http1connection.pyR^ªs( RRRRRQRR¾R³RYR^(((s6lib/python2.7/site-packages/tornado/http1connection.pyR<zs    tHTTP1ServerConnectioncB`sJeZdZddd„Zejd„ƒZd„Zejd„ƒZ RS(sAn HTTP/1.x server.cC`s@||_|dkr!tƒ}n||_||_d|_dS(sÝ :arg stream: an `.IOStream` :arg params: a `.HTTP1ConnectionParameters` or None :arg context: an opaque application-defined object that is accessible as ``connection.context`` N(R+RR R,R-t_serving_future(RR+R,R-((s6lib/python2.7/site-packages/tornado/http1connection.pyR°s      cc`s1|jjƒy |jVWntk r,nXdS(smCloses the connection. Returns a `.Future` that resolves after the serving loop has exited. N(R+RJRÊt Exception(R((s6lib/python2.7/site-packages/tornado/http1connection.pyRJ¾s    cC`sJt|tjƒst‚|j|ƒ|_|jjj|jd„ƒdS(snStarts serving requests on this connection. :arg delegate: a `.HTTPServerConnectionDelegate` cS`s |jƒS(N(R™(tf((s6lib/python2.7/site-packages/tornado/http1connection.pytÕsN( R˜R tHTTPServerConnectionDelegateR¸t_server_request_loopRÊR+RFt add_future(RR>((s6lib/python2.7/site-packages/tornado/http1connection.pyt start_servingÌscc`sæzÑxÊtrÏt|jt|j|jƒ}|j||ƒ}y|j|ƒV}Wngtj tj fk rpdSt k r‹|j ƒdSt k r¹tjddtƒ|j ƒdSX|sÄdStjVqWWd|j|ƒXdS(NsUncaught exceptionR(RPR)R+R(R,R-t start_requestR?R RHtUnsatisfiableReadErrorRRJRËR RRtmomentton_close(RR>tconntrequest_delegateRµ((s6lib/python2.7/site-packages/tornado/http1connection.pyRÏ×s*      N( RRRRRRR¾RJRÑRÏ(((s6lib/python2.7/site-packages/tornado/http1connection.pyRÉ®s  (#Rt __future__RRRR©R†ttornado.concurrentRRRttornado.escapeRRttornadoRR R t tornado.logR R R t tornado.utilRRRËRtobjectRR tHTTPConnectionR)tHTTPMessageDelegateR<RÉ(((s6lib/python2.7/site-packages/tornado/http1connection.pyts&  ÿÿ'4