B ê¹`•Tã@sžddlmZddlZddlZddlZddlZddlmZddlm Z m Z m Z dddœZ e d ƒZGd d „d ƒZGd d „d ƒZGdd„deƒZGdd„deƒZdS)é)ÚdequeNé)ÚReadOnlyFileBasedBuffer)Úbuild_http_dateÚloggerÚ queue_loggerÚCONTENT_LENGTHÚ CONTENT_TYPE)rr )Ú connectionz keep-alivezproxy-authenticatezproxy-authorizationÚteZtrailersztransfer-encodingÚupgradec@sReZdZdZdZdZeZeZdd„Zdd„Z dd„Z d d „Z d d „Z ddd„Z dS)ÚThreadedTaskDispatcherz6A Task Dispatcher that creates a thread for each task.rcCs:tƒ|_tƒ|_t ¡|_t |j¡|_t |j¡|_ dS)N) ÚsetÚthreadsrÚqueueÚ threadingÚLockÚlockÚ ConditionÚqueue_cvÚthread_exit_cv)Úself©rúU/home/kop/projects/devel/pgwui/test_venv/lib/python3.7/site-packages/waitress/task.pyÚ__init__3s  zThreadedTaskDispatcher.__init__cCs*tj|d |¡|fd}d|_| ¡dS)Nz waitress-{})ÚtargetÚnameÚargsT)rÚThreadÚformatÚdaemonÚstart)rrÚ thread_noÚtrrrÚstart_new_thread:sz'ThreadedTaskDispatcher.start_new_threadc CsÐxÊ|jŠx:|jsD|jdkrD|jd8_|j ¡|jd7_q W|jdkr„|jd8_|jd8_|j |¡|j  ¡P|j  ¡}WdQRXy |  ¡Wqt k rÆ|j  d|¡YqXqWdS)NrrzException when servicing %r)rrÚ stop_countÚ active_countrÚwaitrÚdiscardrÚnotifyÚpopleftÚserviceÚ BaseExceptionrÚ exception)rr"ÚtaskrrrÚhandler_threadAs"     z%ThreadedTaskDispatcher.handler_threadc Cs¬|jœ|j}d}t|ƒ|j}xX||krxx||kr>|d}q,W| |¡|d7}| |j|¡|jd7_|d}q"W||krž|j||7_|j  ¡WdQRXdS)Nrr) rrÚlenr%Úaddr$r/r&rÚ notify_all)rÚcountrr"ÚrunningrrrÚset_thread_countXs     z'ThreadedTaskDispatcher.set_thread_countc Csf|jV|j |¡|j ¡t|jƒ}t|jƒ|j|j}||krX|j   d||¡WdQRXdS)NzTask queue depth is %d) rrÚappendrr)r0rr%r&rÚwarning)rr.Z queue_sizeZ idle_threadsrrrÚadd_taskks   zThreadedTaskDispatcher.add_taskTéc Cs¸| d¡|j}t ¡|}|jŒx4|rXt ¡|krJ|j dt|ƒ¡P|j d¡q&W|rª|j }t|ƒdkr‚|j dt|ƒ¡x|rš|  ¡}|  ¡q„W|j   ¡dSWdQRXdS)Nrz%d thread(s) still runninggš™™™™™¹?zCanceling %d pending task(s)TF)r5rÚtimerrr7r0rr'rr*Úcancelrr2)rZcancel_pendingÚtimeoutrZ expirationrr.rrrÚshutdownvs&      zThreadedTaskDispatcher.shutdownN)Tr9)Ú__name__Ú __module__Ú __qualname__Ú__doc__r%r&rrrr$r/r5r8r=rrrrr +s r c@s|eZdZdZdZdZdZdZdZdZ dZ dZ dZ e Z dd„Zdd„Zed d „ƒZd d „Zd d„Zdd„Zdd„Zdd„ZdS)ÚTaskFz200 OKrNcCs.||_||_g|_|j}|dkr$d}||_dS)N)z1.0z1.1z1.0)ÚchannelÚrequestÚresponse_headersÚversion)rrCrDrFrrrr›sz Task.__init__cCsHy| ¡| ¡| ¡Wn&tk rBd|_|jjjr>‚YnXdS)NT)r!ÚexecuteÚfinishÚOSErrorÚclose_on_finishrCÚadjZlog_socket_errors)rrrrr+¥s  z Task.servicecCs&|j d¡p"|j d¡p"|j d¡ S)NÚ1Z204Z304)ÚstatusÚ startswith)rrrrÚhas_body¯s  z Task.has_bodycsˆj}ˆjj dd¡ ¡}g‰d}d}d}d‰xxˆjD]n\}}d dd„| d¡Dƒ¡}|dkrnˆjr6|}nq6|dkrz|}|dkr†|}|d kr–| ¡‰ˆ  ||f¡q6W|dkr؈j dk r؈jrØt ˆj ƒ}ˆ  d|f¡‡‡‡fd d „}|d kr|d kr|s |ƒn ˆ  d¡n|ƒnP|dkrf|dkr8|ƒ|snˆjrVˆ  d¡dˆ_ ˆj sn|ƒntdƒ‚ˆjjjj} |s–| rªˆ  d| f¡nˆ  d| p¤df¡|sĈ  dtˆjƒf¡ˆˆ_dˆjˆjf} dd„tˆjdd„dDƒ} | g| } dd | ¡} |  d¡S)NZ CONNECTIONÚú-cSsg|] }| ¡‘qSr)Ú capitalize)Ú.0Úxrrrú Âsz.Task.build_response_header..zContent-LengthÚDateÚServerÚ Connectioncsˆdkrˆ d¡dˆ_dS)N)rXÚcloseT)r6rJr)Úconnection_close_headerrErrrrJÝs z3Task.build_response_header..close_on_finishz1.0z keep-alive)rXz Keep-Alivez1.1rY)zTransfer-EncodingÚchunkedTzneither HTTP/1.0 or HTTP/1.1ZViaZwaitressz HTTP/%s %scSsg|] }d|‘qS)z%s: %sr)rSZhvrrrrUscSs|dS)Nrr)rTrrrÚóz,Task.build_response_header..)Úkeyz%s z zlatin-1)rFrDÚheadersÚgetÚlowerrEÚjoinÚsplitrOr6Úcontent_lengthÚstrÚchunked_responserJÚAssertionErrorrCÚserverrKÚidentrÚ start_timerMÚsortedÚencode)rrFr Zcontent_length_headerZ date_headerZ server_headerZ headernameZ headervalrJriÚ first_lineZ next_linesÚlinesÚresr)rZrErrÚbuild_response_header·sn          zTask.build_response_headercCs>g}x.|jD]$\}}| ¡dkr"q | ||f¡q W||_dS)Nzcontent-length)rErar6)rrEÚ header_nameÚ header_valuerrrÚremove_content_length_headers  z!Task.remove_content_length_headercCst ¡|_dS)N)r:rj)rrrrr!#sz Task.startcCs&|js| d¡|jr"|j d¡dS)Nr]s0 )Ú wrote_headerÚwriterfrCÚ write_soon)rrrrrH&s z Task.finishcCs|jstdƒ‚|j}|js2| ¡}| |¡d|_|rÜ|jrÜ|}|j}|jr|t t |ƒƒdd…  ¡  d¡d}||d7}nP|dk rÌ|d||j …}|j t |ƒ7_ ||krÌ|jsÌ|j d|¡d|_|rÚ| |¡n8|r|j t |ƒ7_ |js|j d|j¡d|_dS)Nz1start_response was not called before body writtenTézlatin-1s z`application-written content exceeded the number of bytes specified by Content-Length header (%s)zfapplication-written content was ignored due to HTTP response that may not contain a message-body: (%s))ÚcompleteÚ RuntimeErrorrCrtrprvrOrdrfÚhexr0ÚupperrlÚcontent_bytes_writtenÚlogged_write_excessrr7Úlogged_write_no_bodyrM)rÚdatarCZrhZtowriteÚclrrrru-s<  "  z Task.write)r>r?r@rJrMrtrjrdr|r}r~rxrfrrr+ÚpropertyrOrprsr!rHrurrrrrBŽs&  b rBc@seZdZdZdZdd„ZdS)Ú ErrorTaskz(An error task produces an error responseTcCsX|jj}| ¡\}}}||_|j |¡|j d¡d|_t|ƒ|_ |  |  d¡¡dS)N)rXrYTzlatin-1) rDÚerrorZ to_responserMrEÚextendr6rJr0rdrurl)rÚerMr_ÚbodyrrrrG[s   zErrorTask.executeN)r>r?r@rArxrGrrrrr‚Vsr‚c@s$eZdZdZdZdd„Zdd„ZdS)ÚWSGITaskz8A WSGI task produces a response from a WSGI application.Nc sPˆ ¡}d ‡fdd„ }ˆjj ||¡}d}z|jtkrˆˆj}| |¡}|rˆ||krj|dk rdˆ ¡|ˆ_ˆ  d¡ˆj  |¡d}dSd}xX|D]P}|dkrÔt |ƒ}ˆjdkrÔd} t |dƒrÆt |ƒ} | dkrÔ|ˆ_|r’ˆ  |¡q’Wˆj}|dk r,ˆj |kr,dˆ_ˆjjdkr,ˆj d ˆj |f¡Wd|rJt |d ƒrJ| ¡XdS) Ncs4ˆjr|stdƒ‚|r8zˆjr(|d‚ngˆ_Wdd}Xdˆ_|jtk rTtd|ƒ‚d|ksdd|krltdƒ‚|ˆ_x®|D]¦\}}|jtk ržtd|||ffƒ‚|jtk r¼td |||ffƒ‚d|ksÌd|krÔtd ƒ‚d|ksäd|krìtd ƒ‚| ¡}|d kr t |ƒˆ_ qx|t krxtd |ƒ‚qxWˆj  |¡ˆj S)Nz?start_response called a second time without providing exc_info.rTzstatus %s is not a stringÚ ú z5carriage return/line feed character present in statusz$Header name %r is not a string in %rz%Header value %r is not a string in %rz;carriage return/line feed character present in header valuez:carriage return/line feed character present in header namezcontent-lengthzS%s is a "hop-by-hop" header; it cannot be used by a WSGI application (see PEP 3333))rxrgrtrEÚ __class__reÚ ValueErrorrMraÚintrdÚ hop_by_hopr„ru)rMr_Úexc_infoÚkÚvÚkl)rrrÚstart_responseqsL           z(WSGITask.execute..start_responseTr]FÚ__len__rÚHEADzVapplication returned too few bytes (%s) for specified Content-Length (%s) via app_iterrY)N)Úget_environmentrCrhZ applicationrŠrrdÚpreparersrurvr0Úhasattrr|rJrDÚcommandrr7rY) rÚenvironr’Zapp_iterZcan_close_app_iterr€ÚsizeZfirst_chunk_lenÚchunkZ app_iter_lenr)rrrGnsNA         zWSGITask.executec CsL|j}|dk r|S|j}|j}|j}|j}|jj}| d¡rJd| d¡}|r~||kr\d}n"|d}| |¡r~|t |ƒd…}|j d|j dt |j dƒ|j   ¡t |jƒ|j|jjd|j|||j|jdtjdd d | ¡tdd œ}xPt|jƒ ¡D]>\}} |  ¡} t |d¡} | dkr"d |} | |krô| || <qôW|jj|d <||_|S) zReturns a WSGI environment.Nú/rPrrzHTTP/%s)rrTF)Z REMOTE_ADDRZ REMOTE_HOSTZ REMOTE_PORTÚREQUEST_METHODZ SERVER_PORTZ SERVER_NAMEÚSERVER_SOFTWAREZSERVER_PROTOCOLZ SCRIPT_NAMEZ PATH_INFOÚ QUERY_STRINGzwsgi.url_schemez wsgi.versionz wsgi.errorszwsgi.multithreadzwsgi.multiprocessz wsgi.run_oncez wsgi.inputzwsgi.file_wrapperzwsgi.input_terminatedZHTTP_zwaitress.client_disconnected)r™rDÚpathrCrhrKÚ url_prefixrNÚlstripr0Úaddrrer˜r{Zeffective_portZ server_namerirFÚqueryÚ url_schemeÚsysÚstderrZget_body_streamrÚdictr_ÚitemsÚstripÚrename_headersr`Zcheck_client_disconnected) rr™rDr rCrhr¡Zurl_prefix_with_trailing_slashr^ÚvalueZmykeyrrrr•ës\       zWSGITask.get_environment)r>r?r@rAr™rGr•rrrrr‡is}r‡)Ú collectionsrÚsocketr¦rr:ÚbuffersrZ utilitiesrrrr«Ú frozensetrr rBr‚r‡rrrrÚs   cI