>OOf26UdZddlZddlZddlZddlZddlZddlZddlZddlZddlm Z m Z m Z m Z m Z mZmZmZmZmZedZGddeZeeefZeZeded<d d Zej6eGd dZGd d ej:Zy)aEnsure asyncio selector methods (add_reader, etc.) are available tornado 6.1 adds AddThreadSelectorEventLoop event loop, running select in a thread and defining these methods on the running event loop. This factors out the functionality of AddThreadSelectorEventLoop into a standalone SelectorThread object which can be attached to any running event loop. Vendored from tornado v6.4.0 Redistributed under license Apache-2.0 N) AnyCallableDictListOptionalProtocolSetTupleTypeVarUnion_TceZdZdefdZy) _HasFilenoreturncy)Nrselfs \/var/www/premiumrankchecker/venv/lib/python3.12/site-packages/curl_cffi/_asyncio_selector.pyfilenoz_HasFileno.fileno#sN)__name__ __module__ __qualname__intrrrrrr"srrSelectorThread_selector_loopscjtD]{}|j5d|_|jjddd |jj d|jb|jj}tjy#1swYcxYw#t $rYUwxYw)NTa) r _select_cond_closing_selectornotify_waker_wsendBlockingIOError_threadjoinclear)loops r_atexit_callbackr*.s      '%)D "    $ $ & '  MM  t $ << # LL      ' '    s"BB&B# & B21B2c eZdZdZdZdej ddfdZddZde jdfd Z dd Z dd Z dd Zdd ZdeedeeddfdZdedeeefddfdZdededdeddfdZdededdeddfdZdedefdZdedefdZy)raqDefine ``add_reader`` methods to be called in a background select thread. Instances of this class start a second thread to run a selector. This thread is completely hidden from the user; all callbacks are run on the wrapped event loop's thread. Typically used via ``AddThreadSelectorEventLoop``, but can be attached to a running asyncio loop. F real_looprNc&|_tj_d_d_d_j_dfd jjfdi_ i_ tj\__jj!djj!dt"j%j'jj(y)NFcVKjjd{y7wN)_thread_manager_handle __anext__rsrthread_manager_anextz5SelectorThread.__init__..thread_manager_anext[s!--779 9 9s )')cDjjSr/) _real_loop create_task)rr2srz)SelectorThread.__init__..cs$//*E*EFZF\*]rrN)r4 threading Conditionr _select_argsr!r&_thread_managerr0 call_soon_readers_writerssocket socketpair_waker_rr# setblockingradd add_reader_consume_waker)rr,r2s` @r__init__zSelectorThread.__init__Ps#%//1  "'37 &*&:&:&<# : !!"]^=? =? (.'8'8':$ t} !!%( !!%(D!  t':':;rc|jry|j5d|_|jjddd|j |j |j j tj||j|j|jj|jjd|_y#1swYxYw)NT) _closedr r!r"_wake_selectorr&r'rdiscard remove_readerrAcloser#rs rrLzSelectorThread.closeps <<     '%)D "    $ $ & '  << # LL   % 4==)    ' 's "C&&C/)NNcKtjdd|j|_|jj |j  dy#t $r|jwxYww)NzTornado selectorT)namedaemontarget)r8Thread _run_selectr&start _start_select GeneratorExitrLrs rr;zSelectorThread._thread_managersk !''###       JJL  sAA9AA9A66A9ct|jry |jjdy#t$rYywxYw)Nr)rHr#r$r%rs rrIzSelectorThread._wake_selectors5 <<   MM  t $   s + 77cZ |jjdy#t$rYywxYw)Ni)rArecvr%rs rrEzSelectorThread._consume_wakers+  MM  t $   s  **c,|j5|jJt|jj t|j j f|_|jj dddy#1swYyxYwr/)r r:listr=keysr>r"rs rrTzSelectorThread._start_selectsw   '$$, ,,!%dmm&8&8&:!;T$--BTBTBV=W XD     $ $ & ' ' 's A4B  Bc |j5|j?|js3|jj|j |js3|jr dddy|jJ|j\}}d|_ddd t j|\}}}||z} |jj|j||#1swYSxYw#t $rr}|j tt dt jk(r;t j|jjgggd\}}}|rg}nYd}~d}~wwxYw#t$rYt$rYwxYw)N WSAENOTSOCKr)r r:r!waitselectOSErrorerrnogetattrEBADFrArr4call_soon_threadsafe_handle_select RuntimeErrorAttributeError)rto_readto_writerswsxse_s rrRzSelectorThread._run_selects{"" )''/8N8N%%**,''/8N8N))  ) ) ((444$($5$5!$(! )  $]]7HhG B"W, 44T5H5H"bQc ) )4 77ge]EKKHH%}}dmm.B.B.D-Er2qQHB1  .   !   sIA C& C&0$C& C2>'E0&C/2 E-;A(E((E-0 F;FFrjrkc|D]}|j||j |D]}|j||j |jyr/) _handle_eventr=r>rT)rrjrkrws rrezSelectorThread._handle_selectsT 1A   q$-- 0 1 1A   q$-- 0 1 rfdcb_mapc< ||}|y#t$rYywxYwr/)KeyError)rrsrtcallbacks rrpzSelectorThread._handle_events+  bzH     s  rw.Nargscjtj|g||j|<|jyr/) functoolspartialr=rIrrsrwrys rrDzSelectorThread.add_reader.&--h>> b rcjtj|g||j|<|jyr/)r{r|r>rIr}s r add_writerzSelectorThread.add_writerr~rc^ |j|=|jy#t$rYywxYwNFT)r=rvrIrrss rrKzSelectorThread.remove_reader 8  b!    ,,c^ |j|=|jy#t$rYywxYwr)r>rvrIrs r remove_writerzSelectorThread.remove_writerrrr7)rrr__doc__rHasyncioAbstractEventLooprFrLtypingAsyncGeneratorr;rIrErTrRr_FileDescriptorLikererrrprrDrboolrKrrrrrrCs(G<'";";<<@ v'<'@&9!:EX@Y^b   ((23   %19)1DMP  %19)1DMP   3 3rceZdZdZhdZdedeffd ZdejddfdZ dd Z d d d e d deddfdZ d d d e d deddfdZd d defdZd d defdZxZS)AddThreadSelectorEventLoopaWrap an event loop to add implementations of the ``add_reader`` method family. Instances of this class start a second thread to run a selector. This thread is completely hidden from the user; all callbacks are run on the wrapped event loop's thread. This class is used automatically by Tornado; applications should not need to refer to it directly. It is safe to wrap any event loop with this class, although it only makes sense for event loops that do not implement the ``add_reader`` family of methods themselves (i.e. ``WindowsProactorEventLoop``) Closing the ``AddThreadSelectorEventLoop`` also closes the wrapped event loop. >rL _selectorr4rDrrKrrNrcr|tjvrt| |St |j |Sr/)r MY_ATTRIBUTESsuper__getattribute__rbr4)rrN __class__s rrz+AddThreadSelectorEventLoop.__getattribute__<s3 -;; ;7+D1 1t--rr,Nc2||_t||_yr/)r4rr)rr,s rrFz#AddThreadSelectorEventLoop.__init__As#' 2rcl|jj|jjyr/)rrLr4rs rrLz AddThreadSelectorEventLoop.closeEs"  rrsrrwrxryc>|jj||g|Sr/)rrDr}s rrDz%AddThreadSelectorEventLoop.add_readerI" )t~~((X===rc>|jj||g|Sr/)rrr}s rrz%AddThreadSelectorEventLoop.add_writerQrrc8|jj|Sr/)rrKrs rrKz(AddThreadSelectorEventLoop.remove_readerY~~++B//rc8|jj|Sr/)rrrs rrz(AddThreadSelectorEventLoop.remove_writer\rrr7)rrrrrstrrrrrrFrLrrDrrrKr __classcell__)rs@rrrs&M.S.S. 3'";";33 > !>9%> >  >> !>9%> >  >0 50$00 50$0rrr7)rratexitrar{r_r?r8rrrrrrrr r r r r rrrsetr__annotations__r*registerrrrrrrrs       T] CO,*-%&.$ !XXv?0!:!:?0r