AҐi<ddlZejded ddlZddlmZeejedkredejddl m Z ddl Z dd lmZmZdd lmZddlZddlZdd lmZdd lmZeej2d dZeej2ddZddZdZdZdZGddeZ y#e $r edwxYw)NzThe eventlet worker is deprecated and will be removed in Gunicorn 26.0. Please migrate to gevent, gthread, or another supported worker type. See: https://docs.gunicorn.org/en/stable/design.html#choosing-a-worker-type) stacklevel)parsez0.40.3z2eventlet worker requires eventlet 0.40.3 or higher)partial)hubs greenthread) GreenSocket) AsyncWorker)ssl_wrap_socket WSGI_LOCALALREADY_HANDLEDc&|jdk(r td|r|j||r t|dnd}d}|j}|j } |rt||z |}|dkrn:t ||}|sn& ||} || z }| t|kr|| d}nn$Q||dkDr"t|dr|j||zSSS#t$rYZwxYw#|dkDr"t|dr|j||zwwwxYw)Nrz&non-blocking sockets are not supportedi seek) gettimeout ValueErrorrminreadsend memoryviewlenBlockingIOErrorhasattr) selffileoffsetcount blocksize total_sent file_read sock_senddatasents S/var/www/descvideos/venv/lib/python3.12/site-packages/gunicorn/workers/geventlet.py_eventlet_socket_sendfiler$7s= AABB  &$)E4 tIJ I I+ 2I> >i 23D $T?D$&Jc$i'#DE{& >gdF3 IIfz) *4>' >gdF3 IIfz) *4>s0-C' CC' C$!C'#C$$C'')Dcztjj|}tjj } |j \}}|j |||}|jt||d\}}}E#tj$r#|j|jYywxYw)z Serve requests forever. This code is nearly identical to ``eventlet.convenience.serve`` except that it attempts to join the pool at the end, which allows for gunicorn graceful shutdowns. )NNNN) eventlet greenpool GreenPoolr getcurrentacceptspawnlink_eventlet_stop StopServeclosewaitall)sockhandle concurrencypool server_gtconnaddrgts r#_eventlet_server9]s    ' ' 4D$$//1I  JD$FD$/B GGNIt 4-ND$  !!  JJL LLN  sAB3B:9B:c |j|jy#|jwxYw#tj$rYyt$r+t j |gtjYywxYw)z Stop a greenlet handling a request and close its connection. This code is lifted from eventlet so as not to depend on undocumented functions in the library. N) waitr/greenlet GreenletExit Exceptionrkillsysexc_info)clientserverr6s r#r-r-ts`2  KKM JJLDJJL    21#,,.12s!$969B0BBcDttdstt_yy)Nsendfile)rr r$rEr#patch_sendfilerHs ; +8  ,rGcXeZdZdZfdZfdZfdZfdZdZfdZ dZ xZ S) EventletWorkerc@tjtyN)ruse_hubrHrs r#patchzEventletWorker.patchs rGc~ttddr t|tk(r tt||S)Nalready_handled)getattrEVENTLET_WSGI_LOCAL StopIterationEVENTLET_ALREADY_HANDLEDsuperis_already_handled)rrespiter __class__s r#rWz!EventletWorker.is_already_handleds: &(94 @/ ! / // !w)(33rGcx|jjd|jt|y)NzThe eventlet worker is DEPRECATED and will be removed in Gunicorn 26.0. Please migrate to gevent, gthread, or another supported worker type.)logwarningrOrV init_process)rrYs r#r]zEventletWorker.init_processs1  S   rGcDtjt| ||yrL)r&r+rV handle_quitrsigframerYs r#r_zEventletWorker.handle_quituw*C7rGcDtjt| ||yrL)r&r+rV handle_usr1r`s r#rezEventletWorker.handle_usr1rcrGc^tj|jjxsddS)NF)r&Timeoutcfg keepaliverNs r# timeout_ctxzEventletWorker.timeout_ctxs$ 2 2 :dEBBrGc|jjrt||j}t||||yrL)rhis_sslr rVr2)rlistenerrBr7rYs r#r2zEventletWorker.handles. 88??$VTXX6F x.rGcBg}|jD]}t|}|jdt|j|}t j t|||j}|j|t jd|jr2|jt jd|jr2|jd} t j|jj5}|D]%}|j!t j"'|D]}|j% dddy#1swYyxYw#t j$r'}||k7r|D]}|j!Yd}~yd}~wwxYw)Ngg?)socketsr setblockingrr2r&r+r9worker_connectionsappendsleepalivenotifyrgrhgraceful_timeoutr?r.r;) r acceptorsr1gsockhfunacceptortates r#runzEventletWorker.runs[ LL D%E   a 4;;.D~~oud&*&=&=?H   X & NN3  jj KKM NN3 jj  !!$((";";< "1AFF8--/01"AFFH     Qw   s7#)E$ AEE$E!E$!E$$F7FF) __name__ __module__ __qualname__rOrWr]r_rerjr2r __classcell__)rYs@r#rJrJs,488C/ rGrJ)rN)!warningswarnDeprecationWarningr&packaging.versionr parse_version __version__ RuntimeError ImportError monkey_patch functoolsrr@rreventlet.greenior eventlet.wsgir<gunicorn.workers.base_asyncr gunicorn.sockr rRwsgirSrUr$r9r-rHrJrFrGr#rs  R Q9X))*]8-DDOPP &(3)hmm\4@"8==2CTJ#+L.2$ 9E[EyM K LLMs CC