K"hWUddlmZddlZddlZddlZddlmZddlmZm Z m Z dddZ e d Z Gd d ZGd d ZGddeZGddeZdS))dequeN)ReadOnlyFileBasedBuffer)build_http_datelogger queue_loggerCONTENT_LENGTH CONTENT_TYPE)r r ) connection keep-alivezproxy-authenticatezproxy-authorizationtetrailersztransfer-encodingupgradecHeZdZdZdZdZeZeZdZdZ dZ dZ dZ d d Z d S) ThreadedTaskDispatcherz6A Task Dispatcher that creates a thread for each task.rct|_t|_t j|_t j|j|_t j|j|_ dSN) setthreadsrqueue threadingLocklock Conditionqueue_cvthread_exit_cvselfs Gc:\xampp_lite_8_4\www\timesheet\venv\Lib\site-packages\waitress/task.py__init__zThreadedTaskDispatcher.__init__2sVuu WW N$$ !+DI66 '1$)<<crtj|d||f}d|_|dS)Nz waitress-)targetnameargsT)rThreaddaemonstart)rr# thread_nots rstart_new_threadz'ThreadedTaskDispatcher.start_new_thread9sE   7I 7 7yl     r!c |j5|jsV|jdkrK|xjdzc_|j|xjdz c_|js |jdkK|jdkra|xjdzc_|xjdzc_|j||j  ddddS|j }dddn #1swxYwY | n+#t$r|j d|YnwxYwD)NTrrzException when servicing %r)rr stop_count active_countrwaitrdiscardrnotifypopleftservice BaseExceptionr exception)rr)tasks rhandler_threadz%ThreadedTaskDispatcher.handler_thread@s K , ,*+A)=)=%%*%%M&&(((%%*%% *+A)=)=?Q&&%%*%%OOq(OOL((333'..000 , , , , , , , ,z))++ , , , , , , , , , , , , , , ,  K   K K K %%&CTJJJJJ K' Ks*B=C8C88C<?C<D%EEc|j5|j}d}t||jz }||kr]||vr |dz}||v |||dz }||j||xjdz c_|dz}||k]||kr,|xj||z z c_|j ddddS#1swxYwYdS)Nrr) rrlenr-addr+r7r.r notify_all)rcountrr)runnings rset_thread_countz'ThreadedTaskDispatcher.set_thread_countWsE Y + +lGI'llT_4GE//7** )A I 7** I&&&1 %%d&99EEE!!Q&!!%M E//7U?2 ((***! + + + + + + + + + + + + + + + + + +sB6C  CCcd|j5|j||jt |j}t |j|jz |jz }||kr|j d||z ddddS#1swxYwYdS)NzTask queue depth is %d) rrappendrr1r9rr-r.rwarning)rr6 queue_size idle_threadss radd_taskzThreadedTaskDispatcher.add_taskjs Y   J  d # # # M " " "TZJt|,,t>ARRLL((!)),j<.G                   sBB%%B),B)Tc|d|j}tj|z}|j5|r\tj|kr)|jdt |n|jd|\|r|j }t |dkr(|jdt ||r*| }| |*|j  ddddS dddn #1swxYwYdS)Nrz%d thread(s) still runningg?zCanceling %d pending task(s)TF)r>rtimerrrAr9rr/rr2cancelrr;)rcancel_pendingtimeoutr expirationrr6s rshutdownzThreadedTaskDispatcher.shutdownus a   ,Y[[7* Y   .9;;*,,K''(Dc'llSSS#((---  .   u::>>K''(FE SSS" ==??DKKMMM" ((***                          usC)D==EEN)TrE)__name__ __module__ __qualname____doc__r-r.rrr r+r7r>rDrLr!rrr*s@@JL FL===KKK.+++&   r!rceZdZdZdZdZdZdZdZdZ dZ dZ dZ e Z dZdZedZdd Zd Zd Zd Zd ZdZdS)TaskFz200 OKrNcX||_||_g|_|j}|dvrd}||_dS)N)1.01.1rU)channelrequestresponse_headersversion)rrWrXrZs rr z Task.__init__s:  "/ . ( (G r!c |||dS#t$rd|_|jjjrYdSwxYw)NT)r(executefinishOSErrorclose_on_finishrWadjlog_socket_errorsrs rr3z Task.servicesw  JJLLL LLNNN KKMMMMM   #'D |1     s @ @% I((**l::.7oo.?.?+&.%,,-DEEE#r!cf|j}|jjdd}g}d}d}d}|jD]o\}}dd|dD}|dkr |jr|}nH|dkr|}|dkr|}| ||fp||_|>|j 7|jr0t|j }|j d|f|dkrM|d kr2|s| n|j d n| nu|d kr`|d kr| |sC|jr!|j d d|_ |js| ntd|jjjj} |s| r|j d| fn|j d| pdf|s.|j dt)|jfd|jd|j} dt/|jdD} | g| z} dd| z} | dS)N CONNECTION-c6g|]}|SrQ)rn).0xs r z.Task.build_response_header..s "Q"Q"Qa1<<>>"Q"Q"Qr!zContent-LengthDateServerrUr )rkz Keep-AliverVrl)zTransfer-EncodingchunkedTzneither HTTP/1.0 or HTTP/1.1ViawaitresszHTTP/ cg|]}d|zS)z%s: %srQ)ryhvs rr{z.Task.build_response_header..s)    HrM   r!c|dS)NrrQ)rzs rz,Task.build_response_header..s PQRSPTr!)keyz%s z latin-1)rZrXheadersgetrorYjoinsplitrhr@content_lengthstrrschunked_responser_AssertionErrorrWserverr`identr start_timerfsortedencode)rrZr rYcontent_length_header date_header server_headerrqrrr first_line next_lineslinesress rbuild_response_headerzTask.build_response_headers?,\)--lB??EEGG  $  %)%: = = !J "Q"Q:;K;KC;P;P"Q"Q"QRRJ---=,5))V##' X%% )   # #Z$; < < < <!1 " )#/ 0%((;$<$< !  ! ( (*:???  ! ( (%1D*)E F F F U  ! ( (&/$/2R2R)S T T T9T\99DK99   $*4+@nn$U$U$U    z)V[[///zz)$$$r!cg}|jD]5\}}|dkr|||f6||_dS)Ncontent-length)rYror@)rrY header_name header_values rremove_content_length_headerz!Task.remove_content_length_headersf)-)> A A %K  ""&666  # #[,$? @ @ @ @ 0r!c6tj|_dSr)rGrrs rr(z Task.start's)++r!c|js|d|jr|jddSdS)Nr!s0 )rmwriterrW write_soonrs rr]z Task.finish*sM   JJsOOO   2 L # #L 1 1 1 1 1 2 2r!c*|jstd|j}|js0|}||d|_|r|jr|}|j}|jrUtt|dd ddz}||dzz }nb|`|d||j z }|xj t|z c_ ||kr+|js$|jd|zd|_|r||dSdS|rO|xj t|z c_ |js-|jd|jzd|_dSdSdS)Nz1start_response was not called before body writtenTrs 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 RuntimeErrorrWrmrrrhrrhexr9upperrcontent_bytes_writtenlogged_write_excessrrAlogged_write_no_bodyrf)rdatarWrhtowritecls rrz Task.write1s} TRSS S,  %++--B   r " " " $D   1DM 1G$B$ 4c$ii..,2244;;IFFP4'>)@d&@!@@A**c'll:**d??4+C?K''HJLM04D, ,""7+++++ , ,  1  & &#d)) 3 & &, 1 ##IKO;W-1))) 1 1  1 1r!)riN)rMrNrOr_rfrmrrrrrrrrr r3propertyrhrsrrr(r]rrQr!rrSrSsO FLJN H F  X  $ $ $ $Y%Y%Y%v111&&&222&1&1&1&1&1r!rSceZdZdZdZdZdS) ErrorTaskz(An error task produces an error responseTc8|jjjj}|jj}||\}}}||_|j || t||_ | |dSr)rWrr`rrXerror to_responserfrYextendrsr9rr)rrerfrbodys rr\zErrorTask.execute_s #'- L  ! e 4 4  $$W---   """!$ii 4r!N)rMrNrOrPrr\rQr!rrrZs.22Hr!rc"eZdZdZdZdZdZdS)WSGITaskz8A WSGI task produces a response from a WSGI application.Nc2}d fd }jj||}d} t |t rj}||}|r||kr||_ dj |d} |r&t|dr| dSdSdSd}|D]_}|Dt|}j.d} t|drt|} | dkr|_|r |`j}|`j|krUjjdkrEjjdkr!jd j||r&t|dr| dSdSdS#|r%t|dr| wwwxYw) Ncjr|std|r" jr|dg_ d}n#d}wxYwd_t |t std|zd|vsd|vrt d|_|D]\}}t |t std|d ||ft |t std |d ||fd|vsd|vrt d d|vsd|vrt d |}|d krt|_ |tvrtd|z։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 z is not a string in z Header value z;carriage return/line feed character present in header valuez:carriage return/line feed character present in header namerzS%s is a "hop-by-hop" header; it cannot be used by a WSGI application (see PEP 3333))rrrmrY isinstancer ValueErrorrfrointr hop_by_hoprr)rfrexc_infokvklrs rstart_responsez(WSGITask.execute..start_responsers)} X $U $ $(3 'qk)13--#HHtHOOOO DMfc** K$%@6%IJJJv~~ K!DK   1!!S))(JqJJAJJ"!S))(KKK!QKK199 $U199 $TWWYY)))*-a&&D'':%%(<>?@&  ! ( ( 1 1 1: s7;Tr!Frl__len__rHEADzVapplication returned too few bytes (%s) for specified Content-Length (%s) via app_iterr)get_environmentrWr applicationrrrpreparerrrhasattrrlr9rrXcommandrsrrA) renvironrapp_itercan_close_app_iterrsizefirst_chunk_lenchunk app_iter_lens ` rr\zWSGITask.executeos&&((> > > > > > B<&227NKK!5 !($;<< (''++ Tzz> ==???.2+JJsOOO L++H555).&H" !gh&@&@ !      ! ! ! !E#O! & &"*&)%jjO *2'+ "8Y779+.x==L'1,,2AD/&JJu%%%$B~-33 8LPV8V8V,,...|+v55 ++M 6 " !gh&@&@ !      ! ! ! !! !gh&@&@ !     ! !sBG,3C G,,*Hc|j}||S|j}|j}|j}|j}|jj}|drd|dz}|r:||krd}n1|dz}||r|t|d}id|j dd|j ddt|j dd |j d t|jd |jd |jjd d|jzd|d|d|jd|jd|jdddt*jddddd|t0dd}t3|jD]0\}} t8|d} | d|z} | |vr| || <1|jj|d<||_|S)zReturns a WSGI environment.N/rv REMOTE_ADDRr REMOTE_HOST REMOTE_PORTrREQUEST_METHOD SERVER_PORT SERVER_NAMESERVER_SOFTWARESERVER_PROTOCOLzHTTP/%s SCRIPT_NAME PATH_INFO REQUEST_URI QUERY_STRINGzwsgi.url_schemez wsgi.version)rrz wsgi.errorszwsgi.multithreadTzwsgi.multiprocessF)z wsgi.run_oncez wsgi.inputzwsgi.file_wrapperzwsgi.input_terminatedHTTP_zwaitress.client_disconnected)rrXpathrWrr` url_prefixrglstripr9addrrrreffective_port server_namerrZ request_uriquery url_schemesysstderrget_body_streamrdictritemsrename_headersrcheck_client_disconnected) rrrXrrWrrurl_prefix_with_trailing_slashrvaluemykeys rrzWSGITask.get_environments,  N,|,Z* ??3   *S)))D  3z!! 2w//5577 ' 'JC"&&sD11E}# G##!& 37,2X./ r!)rMrNrOrPrr\rrQr!rrrjsFBBG|!|!|!|OOOOOr!r) collectionsrrrrGbuffersr utilitiesrrrr frozensetrrrSrrrQr!rrs]  ,,,,,,<<<<<<<<<<'" Y    ````````FJ1J1J1J1J1J1J1J1Z         RRRRRtRRRRRr!