Dfa<dZddlZddlZddlZddlZddlZddlZddlZddlm Z dZ GddZ e Z e ZGddejZGd d ZdS) z8A thread-based worker pool. .. spelling:: joinable N) pass_none) WorkerThread ThreadPoolceZdZdZdZdZdS) TrueyZerozDObject which equals and does math like the integer 0 but evals True.c|SNselfothers I/var/www/media/lib/python3.11/site-packages/cheroot/workers/threadpool.py__add__zTrueyZero.__add__ c|Sr r r s r__radd__zTrueyZero.__radd__rrN)__name__ __module__ __qualname____doc__rrr rrrrs8NNrrc6eZdZdZdZ dZ dZ dZdZdZ dS)raFThread which continuously polls a Queue for Connection objects. Due to the timing issues of polling a Queue, a WorkerThread does not check its own 'ready' flag after it has started. To stop the thread, it is necessary to stick a _SHUTDOWNREQUEST object onto the Queue (one for each running WorkerThread). NFcd_|_d_d_d_d_d_fdfdfdfddd d _tj dS) zInitialize WorkerThread instance. Args: server (cheroot.server.HTTPServer): web server object receiving this request FrNcLjjdurtp jjzSr ) requests_seen start_time trueyzeroconnsr s rz'WorkerThread.__init__..Is.$"44'+9*#rcVjjdurtpjjjzSr ) bytes_readrrrrfilers rr!z'WorkerThread.__init__..Ns/DO4'.9?-%rcVjjdurtpjjjzSr ) bytes_writtenrrrwfilers rr!z'WorkerThread.__init__..Ss0t'94'19?0(rcjjjdurtptjjz zSr ) work_timerrtimers rr!z'WorkerThread.__init__..Xs54>4'19;;0$rcL|d||d|pdz S)N Bytes Read Work Timeư>r r s rr!z'WorkerThread.__init__..]s/<););+q!!)T*rcL|d||d|pdz S)N Bytes Writtenr-r.r r/s rr!z'WorkerThread.__init__..`s1*, providing a full reproducer with as much context and details as possible.r; tracebackF)r5r4namer3&_process_connections_until_interruptedKeyboardInterrupt SystemExit __cause__ error_logloggingDEBUG interrupt BaseExceptionCRITICAL)r interrupt_excinterrupt_causeunderlying_excs rrunzWorkerThread.runfsE:> *+DI6    7 7 9 9 9 9!:. 4 4 4+5FO K ! !LLLm "   %4DK ! ! ! ! ! !    K ! !\%\\\ & "   %3DK !  "DJJJDJ    s8=C'C>B C' C8CCC'' C0c  |jj}|turdS||_|jjd}|rt j|_d} |}nd#t$r}d}|j d|j d|j d|dtj Yd}~|r|j|n||ry|xj|jz c_|xj|jjz c_|xj|jjz c_|xjt j|jz z c_d|_d|_ud}~wt.t0f$r^}d}|j d |j d|j d|dtj t1t5||d}~wt6$r}|j d |tjd Yd}~|r|j|n||ry|xj|jz c_|xj|jjz c_|xj|jjz c_|xjt j|jz z c_d|_d|_d}~wwxYw |r|j|n||ry|xj|jz c_|xj|jjz c_|xj|jjz c_|xjt j|jz z c_d|_d|_n#|r|j|n||ry|xj|jz c_|xj|jjz c_|xj|jjz c_|xjt j|jz z c_d|_d|_wxYwH) a Process incoming HTTP connections in an infinite loop. Retrieves incoming connections from thread pool, processing them one by one. :raises SystemExit: on the internal requests to stop the server instance TNEnabledFz8Got a connection error while handling a connection from :z ()r:z?Got a server shutdown request while handling a connection from z8Unhandled error while processing an incoming connection r<)r4requestsget_SHUTDOWNREQUESTrr5r*r communicateConnectionErrorrC remote_addr remote_portrDINFOput_conncloserr#r$r&r'r)r@rArEstrrGERROR)r ris_stats_enabledkeep_conn_openconnection_errorshutdown_requestunhandled_errors rr?z3WorkerThread._process_connections_until_interruptedsD !;'++--D'''DI#{0;  ."&)++"N: !!%!1!1!3!3"   !& %%E'+'7EE'EE.>EEE", & L"!K((....JJLLL#+&&$*<<&&OOtz'<EEE"- & !())'(!    %%7"177!-" & "!K((....JJLLL#+&&$*<<&&OOtz'< 0infrzIExpected an integer or the infinity value for the `max` argument but got .zmax=z must be > min=z (or infinity for no max))maxsizeN) ValueErrorfloat isinstanceint TypeErrorr4minmax_threadsqueueQueue_queue_queue_put_timeoutrR collectionsdeque_pending_shutdowns)r r4rorpaccepted_queue_sizeaccepted_queue_timeouts rr8zThreadPool.__init__s"& 777C77788 8 %,,   C%% -$'--- 1WW,,C 99MsMMSMMM   k*=>>> "8;?"-"3"5"5rcf|jrtd||jdS)zaStart the pool of threads. :raises RuntimeError: if the pool is already started z%Threadpools can only be started once.N)rq RuntimeErrorgrowror s rstartzThreadPool.starts8 = HFGG G $(rctd|jD}t|t|jz dS)z3Number of worker threads which are idle. Read-only.c g|] }|j | Sr r.0ts r z#ThreadPool.idle..#s@@@1Qrr)lenrqrprx)r idless ridlezThreadPool.idle sB@@ @@@AA53t6777;;;rcJ|j|d|jdS)zPut request into queue. Args: obj (:py:class:`~cheroot.server.HTTPConnection`): HTTP connection waiting to be processed T)blocktimeoutN)rtputru)r objs rrzThreadPool.put&s' 41HIIIIIrcd|jDD]F}|j| |j7#t$rYCwxYwdS)Nc:g|]}||Sr )is_alivers rrz2ThreadPool._clear_dead_threads..1s%???!**,,?!???r)rqremoverxpopleft IndexError)r rs r_clear_dead_threadszThreadPool._clear_dead_threads/s~??T]???  A M  # # # '//1111       sA  AAc4tjtjz d}t||}fdt |D}|D]$}|jst jd|j%j|dS)z.Spawn new worker threads (not above self.max).rc8g|]}Sr ) _spawn_worker)rir s rrz#ThreadPool.grow..=s%>>>A4%%''>>>rg?N) rprrqroranger3r*sleepextend)r amountbudgetn_newworkersworkers` rr}zThreadPool.grow8sTXDM 2 22A66FF##>>>>u>>>  Fl  2l  W%%%%%rct|j}d|j|_||S)NzCP Server {worker_name!s}) worker_name)rr4formatr>r)r rs rrzThreadPool._spawn_workerCs@dk** ' Fv{F + +     rcv|t|jz}||dkrdStt|j|jz d}t ||}t |D];}|jd|j t49;;)>N  N+++??$$"%%fk222KKMMM!      sAC77C?>C?c|jjrdS |jtjdS#t $r|jYdSwxYw#t $rYdSwxYwr )r$closedsocketshutdownSHUT_RDrnOSErrorrs rrzThreadPool._force_closes :   F  ' $$V^44444 ' ' ' $$&&&&&& '    DD s'$7#AA!AA!! A/.A/cR|jddgc}|jdd<d|DS)z3Clear self._threads and yield all joinable threads.Nc3DK|]}|tju|VdSr )r6current_thread)rthreads r z,ThreadPool._clear_threads..sB  Y57777 7777  r)rq)r threadss rrzThreadPool._clear_threadssG%)M!!!$4b!qqq!  !    rc4|jS)zReturn the queue size.)rtqsizer~s rrzThreadPool.qsizes{  """rN)rcrdrdrc)r)rrrrr8rpropertyrrrr}rrr staticmethodrrrrr rrrrs?A#%,6,6,6,6\<<X< JJJ & & &...,))))V  Y\    ##X###rr)rrvrDr6r*rrrrjaraco.functoolsr__all__rrobjectrSr7rrr rrrs"  &&&&&& ) IKK 688z!z!z!z!z!9#z!z!z!zH#H#H#H#H#H#H#H#H#H#r