jKj8 ddlZddlmZddlmZmZddlmZddlm Z ddl m Z m Z ddl mZddlmZmZmZmZd d lmZmZeed ej0Zeed xr eed ZeGddeZGddeZGddeZy)N) defaultdict)IntEnumunique)BytesIO) ThreadPool)LockRLock)MappingProxyType)AnyCallableOptionalUnion)AbstractContextAbstractOperation fdatasyncpreadpwritec eZdZdZdZdZdZdZy)OpCoderrN)__name__ __module__ __qualname__READWRITEFSYNCFDSYNCNOOP`/Users/ahmed/devFolder/Ultron/claude-voice/.venv/lib/python3.12/site-packages/caio/python_aio.pyrrs D E E F Dr#rc 6eZdZdZdZddedefdZedefdZddZ e rd Z d Z nd Z d Z dd Z ddZddZddZddZdefdZdefdZdZdZeej0e ej2eej4eej6eej8eiZy)Contextz+ python aio context implementation max_requests pool_sizec||jksJ||_t||_d|_d|_t |_ts$t|_ tt|_ yy)NrF) MAX_POOL_SIZE_Context__max_requestsrpool _in_progress_closedr _closed_lockNATIVE_PREAD_PWRITEr _locks_cleanerr_locks)selfr(r)s r$__init__zContext.__init__!sa4-----*y)   F""''D %e,DK#r#returnc|jSN)r,r4s r$r(zContext.max_requests.s"""r#cjj}fd}fd}jjkDr t dxjdz c_j j |f||y)Ncnxjdzc_|_d_jdy)Nrr)r. exceptionwrittencallback)exc operationr4s r$on_errorz"Context._execute..on_error5s2    " "%I  !I    t $r#c`xjdzc_|_j|y)Nr)r.r=r>)resultr@r4s r$ on_successz$Context._execute..on_success;s*    "  &I    v &r#z/Maximum simultaneous requests have been reachedr)argsr>error_callback)_OP_MAPopcoder.r, RuntimeErrorr- apply_async)r4r@handlerrArDs`` r$_executezContext._execute2s,,y//0 %  '   t22 2A  Q  4+#  r#c0tj|||Sr8)osrr4fdsizeoffsets r$__preadzContext.__preadNs88Bf- -r#c0tj|||Sr8)rNrr4rPbytesrRs r$__pwritezContext.__pwriteQs99R/ /r#c |j|5tj|dtjtj||tjtj||cdddS#1swYyxYwNr)r3rNlseekSEEK_SETreadrOs r$rSzContext.__preadTsMRQ ,VR[[1wwr4(! A A::Bc |j|5tj|dtjtj||tjtj||cdddS#1swYyxYwrY)r3rNrZr[writerUs r$rWzContext.__pwriteZsMRQ ,VR[[1xxE*!r]c|jj|j|j|j|j Sr8)bufferr__Context__preadfilenonbytesrRr4r@s r$ _handle_readzContext._handle_read`sB%% LL         r#c|j|j|jj|jSr8)_Context__pwritercragetvaluerRres r$ _handle_writezContext._handle_writeis5}}   i..7799;K;K  r#c@tj|jSr8)rNfsyncrcres r$ _handle_fsynczContext._handle_fsyncnsxx (())r#c,t|jSr8)fdsyncrcres r$_handle_fdsynczContext._handle_fdsyncqsi&&''r#cyr8r"res r$ _handle_noopzContext._handle_nooptsr#cg}|D]/}t|ts td||j|1d}|D]}|j ||dz }|S)NzInvalid Operation %rrr) isinstance Operation ValueErrorappendrL)r4aio_operations operationsr@counts r$submitzContext.submitwsd 'Ii3 !7CC   i ( ( #I MM) $ QJE$ r#cy)z Cancels multiple Operations. Returns Operation.cancel(aio_op1, aio_op2, aio_opN, ...) -> int (Always returns zero, this method exists for compatibility reasons) rr")r4rxs r$cancelzContext.cancelsr#c|jry|j5|jjd|_dddy#1swYyxYwNT)r/r0r-closer9s r$rz Context.closes6 <<     IIOO DL  s "AAcZ|jjr|jyyr8)r-rr9s r$__del__zContext.__del__s 99??  JJL r#N) )r@ru)rrr__doc__r+intr5propertyr(rLr1rbrhrfrjrmrprrr{r}rrr rrrrr r!rGr"r#r$r&r&sM -S -# -#c## 6 . 0 )  +   *(   \ m m ~ \  Gr#r&cbeZdZdZ ddedeedeededeedeef d Ze ddededed dfd Z e dd ededed dfd Z e dded dfdZ e dded dfdZ d eeeffdZed efdZed efdZed eefdZed efdZdeegefd efdZy)ruz- python aio operation implementation NrPrdrRrHpayloadprioritycd|_t|_|tjk(r|rt||_||_||_|xsd|_||_|xsd|_ |xsd|_ d|_ d|_ yrY) r>rrarrrH_Operation__fileno_Operation__offset_Operation__opcode_Operation__nbytes_Operation__priorityr<r=)r4rPrdrRrHrrs r$r5zOperation.__init__sr i V\\ !g!'*DK   !   ! "-a r#r6c8||||tj|S)zC Creates a new instance of Operation on read mode. rHr)rr)clsrdrPrRrs r$r\zOperation.reads2vvfkkHMMr# payload_bytescL||t|||tj|S)zG Creates a new instance of AIOOperation on write mode. )rrHr)lenrr)rrrPrRrs r$r_zOperation.writes,    !<<   r#c8||ddtj|S)zG Creates a new instance of AIOOperation on fsync mode. Nr)rrrrPrs r$rlzOperation.fsyncs 2tT&,,JJr#c8||ddtj|S)zH Creates a new instance of AIOOperation on fdsync mode. Nr)rr rs r$rozOperation.fdsyncs 2tT&--(KKr#c|jr |j|jtjk(r |jS|j y|j j S)zP Method returns a bytes value of AIOOperation's result or None. N)r<rHrrr=rarir9s r$ get_valuezOperation.get_valuesO >>.. ;;&,, &<<  ;;  {{##%%r#c|jSr8)rr9s r$rczOperation.fileno }}r#c|jSr8)rr9s r$rRzOperation.offsetrr#c6|jjSr8)ra getbufferr9s r$rzOperation.payloads{{$$&&r#c|jSr8)rr9s r$rdzOperation.nbytesrr#r>c||_yr)r>)r4r>s r$ set_callbackzOperation.set_callback s   r#)NN)r)rrrrrr rrVr5 classmethodr\r_rlrorrrrcrR memoryviewrrdr r boolrr"r#r$rurus$("&      % 3-09:NN!N+.N NNBC  !  '*  47      KsK;KKLLKLL &5, &'*-''XseSj%9dr#ru)rN collectionsrenumrriormultiprocessing.poolr threadingrr typesr typingr r r rabstractrrgetattrrlrohasattrr1rr&rur"r#r$rs # +!"118 ["(( +b'*Dwr8/DWIoIZf!fr#