AҐi8WddlmZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddl mZddlmZdd lmZdd lmZdd lmZdd lmZGd dZGddZGddej.Zy))futuresN)deque)datetime)partial)base)http)util)sock)wsgic$eZdZdZdZdZdZy)TConnc||_||_||_||_d|_d|_d|_d|_|jjdy)NF) cfgr clientservertimeoutparser initializedis_http2 setblocking)selfrr rrs Q/var/www/descvideos/venv/lib/python3.12/site-packages/gunicorn/workers/gthread.py__init__zTConn.__init__#sO        e$c|jryd|_|jjd|j-|jj rtj |j|j|_|jjs|jjtj|jr^d|_ tj|j|j|jd|_|jjytj|j|j|j|_yy)NT)http2_connection)rr rrris_sslssl_wrap_socketdo_handshake_on_connect do_handshakeis_http2_negotiatedrr get_parserrinitiate_connectionrs rinitz TConn.init1s     d# ;; xx 00DHHE xx77II**,++DII6$(DM"&//$))T[[4#DKKK335//$((DIIt{{KDK) rcdtj|jjz|_yN)time monotonicr keepaliverr&s r set_timeoutzTConn.set_timeoutNs~~'$((*<*<< rcBtj|jyr))r closer r&s rr/z TConn.closeRs 499rN)__name__ __module__ __qualname__rr'r-r/rrrr!s %L:=rrc6eZdZdZdZdZdZdZdZd dZ y) PollableMethodQueueaThread-safe queue that can wake up a selector. Uses a pipe to allow worker threads to signal the main thread when work is ready, enabling lock-free coordination. This approach is compatible with all POSIX systems including Linux, macOS, FreeBSD, OpenBSD, and NetBSD. The pipe is set to non-blocking mode to prevent worker threads from blocking if the pipe buffer fills up under extreme load. c.d|_d|_d|_yr))_read_fd _write_fd_queuer&s rrzPollableMethodQueue.__init__bs  rctj\|_|_tj|jdtj|jdt j |_y)zInitialize the pipe and queue.FN)ospiper7r8 set_blockingqueue SimpleQueuer9r&s rr'zPollableMethodQueue.initgsL(* % t~  u- .'') rc|j tj|j|j! tj|jyy#t$rY9wxYw#t$rYywxYw)z Close the pipe file descriptors.N)r7r;r/OSErrorr8r&s rr/zPollableMethodQueue.closeqsn == $ ' >> % ( &     s"AA* A'&A'* A65A6c|jS)z>Return the readable file descriptor for selector registration.)r7r&s rfilenozPollableMethodQueue.fileno~s }}rc|jjt|g| tj|j dy#t $rYywxYw)aDQueue a callback to be run on the main thread. The callback is added to the queue first, then a wake-up byte is written to the pipe. If the pipe write fails (buffer full), it's safe to ignore because the main thread will eventually drain the queue when it reads other wake-up bytes. N)r9putrr;writer8rA)rcallbackargss rdeferzPollableMethodQueue.defersI 0401  HHT^^W -   s A AAc0 tj|j|}d}|t |dzkr: |j j }||dz }|t |dzkr9yy#t$rYywxYw#tj$rYywxYw)zRun queued callbacks. Called when the pipe is readable. Drains all available wake-up bytes and runs corresponding callbacks. The max_callbacks limit prevents starvation of other event sources. Nr r) r;readr7rAlenr9 get_nowaitr>Empty)r_fileobj max_callbacksdata callbacks_runrHs r run_callbacksz!PollableMethodQueue.run_callbackss 774==-8D  c$i"n, ;;113 " c$i"n,    ;;  s" A0&A?0 A<;A<?BBN)2) r0r1r2__doc__rr'r/rCrJrUr3rrr5r5Vs%  *  rr5ceZdZfdZedZfdZdZdZfdZ dZ dZ d Z d Z d Zd Zd ZdZdZdZdZdZdZxZS) ThreadWorkerc2t||i||jj|_|jj|jjz |_d|_d|_t|_ t|_ d|_ d|_ y)NrF)superrrworker_connectionsthreadsmax_keepalivedtpoolpollerr5 method_queuerkeepalived_connsnr_conns _accepting)rrIkwargs __class__s rrzThreadWorker.__init__sy $)&)"&(("="="hh99DHHz*ThreadWorker.handle_exit..srN)aliverarJ)rsigframes r handle_exitzThreadWorker.handle_exits) ::DJ    # #L 1 rc^|jjdt| ||y)z$Handle SIGQUIT - immediate shutdown.FwaitN)r_shutdownr[ handle_quit)rrxryrfs rrzThreadWorker.handle_quits' ' C'rc||jk(ry|jD]f}|rG|jd|jj |t j |jL|jj|h||_y)z,Enable or disable accepting new connections.NF) rdsocketsrr`registerrn EVENT_READaccept unregister)renabledlisteners rset_accept_enabledzThreadWorker.set_accept_enabledsp doo %   1H$$U+ $$Xy/C/CT[[Q &&x0  1"rc~jjj}|jfdy)z0Submit connection to thread pool for processing.cRjjj|Sr))rarJfinish_request)futconnrs rrvz*ThreadWorker.enqueue_req..s"))//0C0CT3OrN)r_submithandleadd_done_callback)rrfss`` r enqueue_reqzThreadWorker.enqueue_reqs/ ZZ  t{{D 1  O Qrc |j\}}|xjdz c_|jdt|j|||j }|j |y#t$rF}|jtjtjtjfvrYd}~yd}~wwxYw)z/Accept a new connection from a listener socket.rTN) rrcrrr getsocknamerrAerrnoEAGAIN ECONNABORTED EWOULDBLOCK)rr client_sock client_addrres rrzThreadWorker.accepts '/'8 $K MMQ M  # #D ); X=Q=Q=STD   T " wwu||U-?-?ARARSST sA0A33 C< %jj KKM)@)@@JT__,'' 3  - -c - :'')  " " $!jj& & >>+dhh.G.GGmma !1DNN4D!DaHN"  - -n - E  " " $ mma '  ! A GGI rc: |j xr|j}|r|jr|jj d|j |j j||jj|jtjt|j|y|xjdzc_|jy#t $r(|xjdzc_|jYywxYw)zHHandle completion of a request (called via method_queue on main thread).FrN) cancelledresultrwr rr-rbappendr`rrnrrrrcr/ Exception)rrrr,s rrzThreadWorker.finish_requestTs LLN*:ryy{ITZZ %%e,  "%%,,T2 $$TYY 0D0D%,T-K-KT%RT "    MMQ M JJL sCC)%C)).DDcd} |jjd|j|jr|j |St |j }|sy|j||}|r|j jy y#tjj$r&}|jjd|Yd}~yd}~wt$r&}|jjd|Yd}~yd}~wtj $r}|j"dtj$k(r6|jjd|jj'nC|jjd|j)||j|j*|Yd}~yd}~wt,$r}|j.t.j0t.j2t.j4fvr|jj7d n|j.t.j2k(r|jjd nT|j.t.j4k(r|jjd n|jjd Yd}~yd}~wt8$r2}|j)||j|j*|Yd}~yd}~wwxYw) z:Handle a request on a connection. Runs in a worker thread.NTFz*Ignored premature client disconnection. %szClosing connection. %srzssl connection closedzError processing SSL request.z Socket error processing request.zIgnoring connection resetzIgnoring socket not connectedzIgnoring connection epipe)r rr'r handle_http2nextrhandle_request finish_bodyr errors NoMoreDatarjdebug StopIterationsslSSLErrorrI SSL_ERROR_EOFr/ handle_errorrrArEPIPE ECONNRESETENOTCONN exceptionr)rrreqr,rs rrzThreadWorker.handlefs-0 > II ! !$ ' IIK}}((..t{{#C++C6I '') :1{{%% L HHNNG K K.- 8 HHNN3Q 7 7*)|| BvvayC---67 !>?!!#tyy$++qA @wwu{{E,<,?WW.HHNN#BCHHNN#>? >   c499dkk1 = = >sVAB B$.BK'2C K'DK'BF44 K'C$J)) K'5(K""K'c |j} |js|jr|j}|D];} |j ||||j|jj=|js|j y |js |jry #t $rf}|j jd |j|jjdt|n#t $rYnwxYwYd}~d}~wwxYw#|j|jjwxYw#tjj $r|j j#dYy t$j&$rb}|j(dt$j*k(r|j j#dn|j j#d|Yd}~y d}~wt,$r`}|j.t.j0t.j2t.j4fvr|j jdYd}~y d}~wt $r|j jd Yy wxYw) aHandle an HTTP/2 connection. Runs in a worker thread. HTTP/2 connections are persistent and multiplex multiple streams. We handle all streams until the connection is closed. Returns: False (HTTP/2 connections don't use keepalive polling) zError handling HTTP/2 requestiNz"HTTP/2 connection closed by clientrzHTTP/2 SSL connection closedzHTTP/2 SSL error: %szHTTP/2 socket errorzHTTP/2 connection errorF)r is_closedrw receive_datahandle_http2_requestrrjr send_errorstream stream_idstrcleanup_streamr/r rrrrrrIrrArrrr)rrh2_connrequestsrrs rrzThreadWorker.handle_http2s++" :''DJJ"//1# EC E11#tWE ..szz/C/CD EzzMMOG''DJJF9%!**+JK!#..szz/C/CS#a&Q(! ! ! ..szz/C/CD{{%% A HHNN? @|| :vvayC---=>5q9  :wwu{{E,<,ThreadWorker.handle_http2_request..send_early_hints_h2s**9c7Crzwsgi.early_hintsc(j|y)z.Queue trailers to be sent after response body.N)extend)trailerspending_trailerss rsend_trailers_h2z;ThreadWorker.handle_http2_request..send_trailers_h2s ''1rzgunicorn.http2.send_trailersr,Autorestarting worker after current request.Fr__iter__r/z:status) end_streamException in post_request hook)#rrr pre_requestrrr creater rrnr max_requestsrwrjrstart_responsehasattrr/r status_coderrlowerr send_headersstreams_send_pending_data send_data send_trailers send_responseaccess post_requestrr)rrrrenvironresp request_startrrrespiter response_bodyitemresponse_headersnamevaluer request_timerrs ` @@rrz!ThreadWorker.handle_http2_requests6JJ(( T E HH s +$LLNM!KKTYY (, TXX?MD'*.G& '&)GN # D+>G& ' "  27GG2 3 GGqLGww$+++::HHMM"PQ!&DJyy$*=*=>H M %8Z0 (2)T1M28W-NN$ &/D4D4D0E$F#G #'<<HKD%$++TZZ\3u:,FGH,,Y8HUZ,[ 3##$4#G**,!OO--iSX-Y$$]u$E..0%%i1AB%%$$LL! $<<>M9L HHOOD#w = E%%dC$?O8W-NN$.P E""#CD E E%%dC$? E""#CD EsaDL./K"K" E8L.L"LL.$L+*L+.M90MM9$M63M95M66M9cri}d} |jj||tj}t j ||j |j|j|j\}}d|d<|xjdz c_ |j|jk\r>|jr"|jjdd|_ |j|jr|jjs|jn2t!|j"|j$k\r|j|j ||j&} t)||dr|j+|n|D]}|j-||j/tj|z }|jj1||||t3|dr|j/ |j5r<|jj7d |jj9||||y |jj9||||y#tj|z }|jj1||||t3|dr|j/wwxYw#t:$r|jj=d YywxYw#t>$r'tAjBtEjFYt:$r|r|jHr|jj=d  |j jKtLjN|j j/tQ#t>$r YtQwxYwwxYw#t:$r|jj=d YywxYw# |jj9||||w#t:$r|jj=d YwwxYwxYw) NTrrrFzwsgi.file_wrapperr/zClosing connection.rzError handling request))rrrrr rr rrrrrwrjr force_closer,rNrbr^r isinstance write_filerGr/rr should_closerrrrrAr reraisesysexc_info headers_sentr~socket SHUT_RDWRr) rrrrrrrrrs rrzThreadWorker.handle_request*sf7 E HH s +$LLNM KKTYY (, TXX?MD'*.G& ' GGqLGww$+++::HHMM"PQ!&DJ  "::TXX%7%7  "T**+t/B/BB  "yy$*=*=>H %h0C(DEOOH- () 4() '||~ = c7LA8W-NN$  "45" E%%dC$?)#& E%%dC$?; (||~ = c7LA8W-NN$.0 E""#CD E% * LL#,,. ) ))""#;<II&&v'7'78IIOO%$o%#o%   E""#CD E E%%dC$? E""#CD EsE&K6-A I56A=K65K O+O5AK  K6 $K32K36-N>#O+%1N>AN$ N>$ N9- N>8N99N>>O+$O('O(+P6-P  P6 $P30P62P33P6)r0r1r2r classmethodrkrprmrzrrrrrrrrrrrrrr __classcell__)rfs@rrYrYs{  OO H2( "Q $ -^$5n/bZEx<rrY) concurrentrrr;r>rnrrrr* collectionsrr functoolsrrr r r r rr5WorkerrYr3rrrsd  22jQQh|4;;|r