D_ hWUSSKJr SSKrSSKrSSKrSSKJr SSKJrJ r J r SSS.r \ "S 5r "S S 5r"S S 5r"SS\5r"SS\5rg))dequeN)ReadOnlyFileBasedBuffer)build_http_datelogger queue_loggerCONTENT_LENGTH CONTENT_TYPE)r r ) connection keep-alivezproxy-authenticatezproxy-authorizationtetrailersztransfer-encodingupgradecP\rSrSrSrSrSr\r\rSr Sr Sr Sr Sr S S jrS rg ) ThreadedTaskDispatcher*z6A Task Dispatcher that creates a thread for each task.rc[5Ul[5Ul[R "5Ul[R"UR 5Ul[R"UR 5Ul gN) setthreadsrqueue threadingLocklock Conditionqueue_cvthread_exit_cvselfs K/var/www/html/fileupload/venv/lib/python3.13/site-packages/waitress/task.py__init__ThreadedTaskDispatcher.__init__2sOu W NN$ !++DII6 '11$))<cf[R"USU3U4S9nSUlUR5 g)Nz waitress-)targetnameargsT)rThreaddaemonstart)rr% thread_nots r start_new_thread'ThreadedTaskDispatcher.start_new_thread9s4   )I; 7yl   r#cUR UR(dwURS:XagU=RS-slURR 5 U=RS- slUR(dURS:XaMgURS:aiU=RS-slU=RS-slUR RU5 URR5 SSS5 gURR5nSSS5 WR5 GMD!,(df  N"=f![a URRSW5 NARARRL(!!)),j.G YYs BB33 CcURS5 URn[R"5U-nUR U(ac[R"5U:a&URR S[ U55 O$URRS5 U(aMcU(aURn[ U5S:a%URR S[ U55 U(a)UR5nUR5 U(aM)URR5 SSS5 gSSS5 g!,(df  g=f)Nrz%d thread(s) still runningg?zCanceling %d pending task(s)TF)rBrtimerrrFr=rr2rr5cancelrr?)rcancel_pendingtimeoutr expirationrr9s r shutdownThreadedTaskDispatcher.shutdownus a ,,YY[7* YY99;*,KK''(Dc'lS##((- '  u:>KK''(FE S ==?DKKMe ((*Y   !Y sA)E-A5E$E E )rrrrrN)T)__name__ __module__ __qualname____firstlineno____doc__r0r1rrr!r-r:rBrIrQ__static_attributes__r#r rr*s8@JL FL=K.+& r#rc\rSrSrSrSrSrSrSrSr Sr Sr Sr Sr \rSrSr\S5rSS jrS rS rS rS rSrSrg)TaskFz200 OKrNc^XlX l/UlURnUS;aSnX0lg)N)1.01.1r_)channelrequestresponse_headersversion)rrarbrds r r! Task.__init__s/  "// . (G r#cUR5 UR5 UR5 g![a0 SUlUR R R(aegf=f)NT)r*executefinishOSErrorclose_on_finishraadjlog_socket_errorsrs r r6 Task.servicesT  JJL LLN KKM #'D ||112 s037A-,A-cURRS5=(d= URRS5=(d URRS5(+$)N1204304)status startswithrs r has_body Task.has_bodysN KK " "3 ' -{{%%e, -{{%%e,  r#cUR(d[SnURH+up#UR5S:XdMUR5nM- UcURR S5 SUlg)N Connection)rwcloseT) wrote_headerrc capitalizelowerrErj)rconnection_close_header headername headervals r set_close_on_finishTask.set_close_on_finishsi  &* #)-)>)>% ((*l:.7oo.?+*?'.%%,,-DE#r#cfURnURRRSS5R 5n/nSnSnSnUR HupxSR URS5V s/sHoR5PM sn 5nUS:XaUR(aUnOM_US:XaUnUS:XaUnURXx45 M X0lUcPURbCUR(a2[UR5nUR RSU45 US:XaKUS:Xa4U(dUR5 OUR RS 5 OUR5 OUS :XarUS :XaUR5 U(dTUR(a"UR RS 5 S UlUR(dUR5 O [!S5eUR"R$R&R(n U(d%U (aUR RSU 45 O&UR RSU =(d S45 U(d0UR RS[+UR,545 SURSUR.3n [1UR SS9V s/sHn SU -PM n n U /U -nSSR U5-nUR3S5$s sn fs sn f)N CONNECTION-zContent-LengthDateServerr_r )rwz Keep-Aliver`rx)zTransfer-EncodingchunkedTzneither HTTP/1.0 or HTTP/1.1ViawaitresszHTTP/ c US$)NrrZ)xs r ,Task.build_response_header..s PQRSPTr#)keyz%s: %sz%s z latin-1)rdrbheadersgetr{rcjoinsplitrzrtrEcontent_lengthstrrchunked_responserjAssertionErrorraserverrkidentr start_timerrsortedencode)rrdr rccontent_length_header date_header server_headerr}r~rr first_linehv next_lineslinesress r build_response_headerTask.build_response_headers,,\\))--lB?EEG  $  %)%:%: !J:;K;KC;P"Q;Pa<<>;P"QRJ--==,5)V#' X% )   # #Z$; ?  ! ! ( (%1D*)E F  ! ! ( (&/$//2R)S TT\\N!DKK=9 %+4+@+@n$U $UbHrM$U   z)V[[//zz)$$_#RR s 8L) -L.c/nURH-up#UR5S:XaMURX#45 M/ Xlg)Ncontent-length)rcr{rE)rrc header_name header_values r remove_content_length_header!Task.remove_content_length_headersI)-)>)> %K  "&66  # #[$? @*? !1r#c8[R"5Ulgr)rLrrs r r* Task.start's))+r#cUR(dURS5 UR(aURR S5 gg)Nr#s0 )rywriterra write_soonrs r rh Task.finish*s6  JJsO  LL # #L 1 !r#cUR(d [S5eURnUR(d(UR 5nUR U5 SUlU(aUR (aUnURnUR(a?[[U55SSR5RS5S-nXAS-- nOmUbjUSXPR- nU=R[U5- sl XA:wa6UR(d%URR!SU-5 SUlU(aUR U5 ggU(a`U=R[U5- sl UR"(d0URR!SUR$-5 SUlggg)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 RuntimeErrorraryrrrtrrhexr=upperrcontent_bytes_writtenlogged_write_excessrrFlogged_write_no_bodyrr)rdatararhtowritecls r r Task.write1s}}RS S,,  ++-B   r " $D  DMMG$$B$$c$i.,224;;IFP'>)@&@&@!@A**c'l:*?4+C+CKK''HJLM04D,""7+   & &#d) 3 &,, ##IKO;;W-1) - r#) rarrjrrrbrcrrdry)returnN)rTrUrVrWrjrrryrrrrrrrrr!r6propertyrtrrrr*rhrrYrZr#r r\r\s{O FLJN H F   $Y%v1&2&1r#r\c"\rSrSrSrSrSrSrg) ErrorTaskiZz(An error task produces an error responseTcPURRRRnURR nUR U5up4nX0lURRU5 UR5 [U5Ul URU5 gr)rarrkrrberror to_responserrrcextendrr=rr)rrerrrbodys r rgErrorTask.execute_s| ##''-- LL   ! e 4  $$W-   "!$i 4r#)rrrN)rTrUrVrWrXrrgrYrZr#r rrZs2Hr#rc(\rSrSrSrSrSrSrSrg)WSGITaskijz8A WSGI task produces a response from a WSGI application.Nc^TR5nS U4SjjnTRRRX5nSn[ U[ 5(aTR nURU5nU(ayXV:waUbTR5 UTlTRS5 TRRU5 SnU(a#[US5(aUR5 gggSnUHcnUcC[U5nTR c+Sn [US5(a [U5n U S:XaUTlU(dMRTRU5 Me TR nUb{TRU:wakTRR S:waQTR#5 TRR S:wa'TR$R'S TRU5 U(a#[US5(aUR5 ggg!U(a#[US5(aUR5 fff=f) Nc>TR(aU(d [S5eU(a!TR(aUSe/TlSnSTl[ U[ 5(d[SU-5eSU;dSU;a [ S5eUTlUHup4[ U[ 5(d[SU<S X44<35e[ U[ 5(d[S U<S X44<35eSU;dSU;a [ S 5eSU;dSU;a [ S 5eUR5nUS :Xa[U5Tl MU[;dM[SU-5e TRRU5 TR$!Snf=f)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))rrryrc isinstancer ValueErrorrrr{intr hop_by_hoprr)rrrexc_infokvklrs r start_response(WSGITask.execute..start_responsers}}X$U $(( 'qk)13-#H DMfc**$%@6%IJJv~ K!DK !!S))(&qe+?zJ"!S))('u,@! K19 $U19 $TWWY))*-a&D':%(<>?@/ 8  ! ! ( ( 1:: [ $Hs FF Tr#Frx__len__rHEADzVapplication returned too few bytes (%s) for specified Content-Length (%s) via app_iterr)get_environmentrar applicationrrrpreparerrrhasattrrxr=rrbcommandrrrF) renvironrapp_itercan_close_app_iterrsizefirst_chunk_lenchunk app_iter_lens ` r rgWSGITask.executeos&&(> B<<&&227K!5 !($;<<((''+z> ==?.2+JJsO LL++H5).&H"gh&@&@ 'A!E#O!"*&)%jO **2'+ "8Y77+.x=L'1,2AD/5JJu%!"$$$B~--3 8L8LPV8V,,.||++v5 ++M 66 "gh&@&@ 'A!!gh&@&@ 'A!sBH4AH BH,Ic`URnUbU$URnURnURnURnUR R nURS5(aSURS5-nU(a1X6:XaSnO)US-nURU5(aU[U5Sn0SURS_SURS_S[URS5_S URR5_S [UR5_S UR_S UR R _S SUR"-_SU_SU_SUR$_SUR&_SUR(_SS_S[*R,_SS_SS_SUR/5[0SS.En[3UR45R75H.up[8R;US5n U cSU-n X;dM*XU 'M0 URR<US'XlU$)zReturns a WSGI environment.N/r 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)rrbpathrarrk url_prefixrslstripr=addrrrreffective_port server_namerrd request_uriquery url_schemesysstderrget_body_streamrdictritemsrename_headersrcheck_client_disconnected) rrrbrrarrurl_prefix_with_trailing_slashrvaluemykeys r rWSGITask.get_environmentsl,,  N,,||,,ZZ** ??3  S))D ! 2w/557JC"&&sD1E}# #!& 837,,2X2X./ r#)rrrrcrr) rTrUrVrWrXrrgrrYrZr#r rrjsBG|!|Or#r) collectionsrrrrLbuffersr utilitiesrrrr  frozensetrrr\rrrZr#r rsp  ,<<'"    ``FJ1J1Z   RtRr#