+
    O(i8                     .   ^ RI t ^ RIHt ^ RIHtHt ^ RIHt ^ RIH	t	 ^ RI
HtHt ^ RIHt ^ RIHtHtHtHt ^R	IHtHt ]! ] R
] P0                  4      t]! ] R4      ;'       d
    ]! ] R4      t] ! R R]4      4       t ! R R]4      t ! R R]4      tR# )    N)defaultdict)IntEnumunique)BytesIO)
ThreadPool)LockRLock)MappingProxyType)AnyCallableOptionalUnion)AbstractContextAbstractOperation	fdatasyncpreadpwritec                   *    ] tR t^t^ t^t^t^tRtRt	R# )OpCode N)
__name__
__module____qualname____firstlineno__READWRITEFSYNCFDSYNCNOOP__static_attributes__r       U/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/caio/python_aio.pyr   r      s    DEEFDr"   r   c                     a  ] tR t^t o Rt^tRV 3R lR llt]V 3R lR l4       tV 3R lR lt	]
'       d   R tR	 tMR
 tR tV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltV 3R lR ltR tR t]! ]P0                  ]]P2                  ]]P4                  ]]P6                  ]]P8                  ]/4      tRtV tR# )Contextz#
python aio context implementation
c                &   < V ^8  d   QhRS[ RS[ /# )   max_requests	pool_sizeint)format__classdict__s   "r#   __annotate__Context.__annotate__!   s     - -S -# -r"   c                    W P                   8  g   Q hWn        \        V4      V n        ^ V n        RV n        \        4       V n        \        '       g&   \        4       V n
        \        \        4      V n        R# R# )r   FN)MAX_POOL_SIZE_Context__max_requestsr   pool_in_progress_closedr   _closed_lockNATIVE_PREAD_PWRITEr	   _locks_cleanerr   _locks)selfr(   r)   s   &&&r#   __init__Context.__init__!   s`    -----*y)	 F"""''D%e,DK #r"   c                    < V ^8  d   QhRS[ /# r'   returnr*   )r,   r-   s   "r#   r.   r/   /   s     # #c #r"   c                    V P                   # N)r2   r:   s   &r#   r(   Context.max_requests.   s    """r"   c                   < V ^8  d   QhRR/# r'   	operation	Operationr   )r,   r-   s   "r#   r.   r/   2   s     
 
+ 
r"   c                   a a S P                   SP                  ,          pVV 3R  lpVV 3R lpS P                  S P                  8  d   \	        R4      hS ;P                  ^,          un        S P
                  P                  VS S3VVR7       R# )c                 x   < S;P                   ^,          un         V Sn        ^ Sn        SP                  R4       R#    N)r4   	exceptionwrittencallback)excrF   r:   s   &r#   on_error"Context._execute.<locals>.on_error5   s2    ""%I !It$r"   c                 j   < S;P                   ^,          un         V Sn        SP                  V 4       R# rJ   )r4   rM   rN   )resultrF   r:   s   &r#   
on_success$Context._execute.<locals>.on_success;   s*    " &Iv&r"   z/Maximum simultaneous requests have been reached)argsrN   error_callbackN)_OP_MAPopcoder4   r2   RuntimeErrorr3   apply_async)r:   rF   handlerrP   rT   s   ff   r#   _executeContext._execute2   s    ,,y//0	%	'
 t222A  	Q		4+# 	 	
r"   c                0    \         P                  ! WV4      # rA   )osr   r:   fdsizeoffsets   &&&&r#   __preadContext.__preadN   s    88Bf--r"   c                0    \         P                  ! WV4      # rA   )r`   r   r:   rb   bytesrd   s   &&&&r#   __pwriteContext.__pwriteQ   s    99R//r"   c                8   V P                   V,          ;_uu_ 4        \        P                  ! V^ \        P                  4       \        P                  ! W\        P                  4       \        P                  ! W4      uuRRR4       #   + '       g   i     R# ; ir   N)r9   r`   lseekSEEK_SETreadra   s   &&&&r#   re   rf   T   sM    RQ,R[[1wwr( !   A!BB	c                8   V P                   V,          ;_uu_ 4        \        P                  ! V^ \        P                  4       \        P                  ! W\        P                  4       \        P                  ! W4      uuRRR4       #   + '       g   i     R# ; irm   )r9   r`   rn   ro   writerh   s   &&&&r#   rj   rk   Z   sM    RQ,R[[1xx* !rq   c                   < V ^8  d   QhRR/# rE   r   )r,   r-   s   "r#   r.   r/   `   s     
 
k 
r"   c                    VP                   P                  V P                  VP                  VP                  VP
                  4      4      # rA   )bufferrs   _Context__preadfilenonbytesrd   r:   rF   s   &&r#   _handle_readContext._handle_read`   sB    %%LL      
 	
r"   c                   < V ^8  d   QhRR/# rE   r   )r,   r-   s   "r#   r.   r/   i   s     
 
{ 
r"   c                    V P                  VP                  VP                  P                  4       VP                  4      # rA   )_Context__pwriterx   rv   getvaluerd   rz   s   &&r#   _handle_writeContext._handle_writei   s5    }}i..7799;K;K
 	
r"   c                   < V ^8  d   QhRR/# rE   r   )r,   r-   s   "r#   r.   r/   n   s     * *{ *r"   c                B    \         P                  ! VP                  4      # rA   )r`   fsyncrx   rz   s   &&r#   _handle_fsyncContext._handle_fsyncn   s    xx	(())r"   c                   < V ^8  d   QhRR/# rE   r   )r,   r-   s   "r#   r.   r/   q   s     ( ( (r"   c                ,    \        VP                  4      # rA   )fdsyncrx   rz   s   &&r#   _handle_fdsyncContext._handle_fdsyncq   s    i&&''r"   c                   < V ^8  d   QhRR/# rE   r   )r,   r-   s   "r#   r.   r/   t   s      k r"   c                    R # rA   r   rz   s   &&r#   _handle_noopContext._handle_noopt   s    r"   c                    < V ^8  d   QhRS[ /# r>   r*   )r,   r-   s   "r#   r.   r/   w   s       r"   c                    . pV F6  p\        V\        4      '       g   \        R V4      hVP                  V4       K8  	  ^ pV F  pV P	                  V4       V^,          pK  	  V# )zInvalid Operation %r)
isinstancerG   
ValueErrorappendr]   )r:   aio_operations
operationsrF   counts   &*   r#   submitContext.submitw   sg    
'Ii33 !7CCi(	 ( #IMM)$QJE $ r"   c                    < V ^8  d   QhRS[ /# r>   r*   )r,   r-   s   "r#   r.   r/      s       r"   c                    ^ # )z
Cancels multiple Operations. Returns

 Operation.cancel(aio_op1, aio_op2, aio_opN, ...) -> int

(Always returns zero, this method exists for compatibility reasons)
r   )r:   r   s   &*r#   cancelContext.cancel   s     r"   c                    V P                   '       d   R # V P                  ;_uu_ 4        V P                  P                  4        RV n         R R R 4       R #   + '       g   i     R # ; i)NT)r5   r6   r3   closerB   s   &r#   r   Context.close   s>    <<<IIOODL s   "AA&	c                j    V P                   P                  4       '       d   V P                  4        R # R # rA   )r3   r   rB   s   &r#   __del__Context.__del__   s!    99??JJL r"   )__max_requestsr5   r6   r4   r9   r8   r3   N)       ) r   r   r   r   __doc__r1   r;   propertyr(   r]   r7   rw   r   r{   r   r   r   r   r   r   r   r   r
   r   r   r   r   r   r    rX   r!   __classdictcell__r-   s   @r#   r%   r%      s      M- - # #
 
6 	.	0	)	+
 

 

* *( (      \mm~\  Gr"   r%   c                   N  a  ] tR t^t o RtRV 3R lR llt]RV 3R lR ll4       t]RV 3R lR ll4       t]RV 3R	 lR
 ll4       t	]RV 3R lR ll4       t
V 3R lR lt]V 3R lR l4       t]V 3R lR l4       t]V 3R lR l4       t]V 3R lR l4       tV 3R lR ltRtV tR# )rG   z%
python aio operation implementation
Nc                ~   < V ^8  d   QhRS[ RS[S[ ,          RS[S[ ,          RS[RS[S[,          RS[S[ ,          /# )r'   rb   ry   rd   rY   payloadpriority)r+   r   r   ri   )r,   r-   s   "r#   r.   Operation.__annotate__   sW        	
  % 3-r"   c                2   R V n         \        4       V n        V\        P                  8X  d   V'       d   \        V4      V n        W@n        Wn        T;'       g    ^ V n        W@n        T;'       g    ^ V n	        T;'       g    ^ V n
        R V n        ^ V n        R # rA   )rN   r   rv   r   r   rY   _Operation__fileno_Operation__offset_Operation__opcode_Operation__nbytes_Operation__priorityrL   rM   )r:   rb   ry   rd   rY   r   r   s   &&&&&&&r#   r;   Operation.__init__   sr     iV\\!g!'*DK!!"--ar"   c                0   < V ^8  d   QhRS[ RS[ RS[ RR/# )r'   ry   rb   rd   r?   rG   r*   )r,   r-   s   "r#   r.   r      s3     N NN!N+.N	Nr"   c                6    V ! W!V\         P                  VR7      # )z3
Creates a new instance of Operation on read mode.
rY   r   )r   r   )clsry   rb   rd   r   s   &&&&&r#   rp   Operation.read   s     2vfkkHMMr"   c                0   < V ^8  d   QhRS[ RS[RS[RR/# )r'   payload_bytesrb   rd   r?   rG   )ri   r+   )r,   r-   s   "r#   r.   r      s-     
 
!
'*
47
	
r"   c           	     L    V ! V\        V4      VV\        P                  VR7      # )z7
Creates a new instance of AIOOperation on write mode.
)r   rY   r   )lenr   r   )r   r   rb   rd   r   s   &&&&&r#   rs   Operation.write   s,     !<<
 	
r"   c                $   < V ^8  d   QhRS[ RR/# r'   rb   r?   rG   r*   )r,   r-   s   "r#   r.   r      s     K Ks K; Kr"   c                8    V ! VRR\         P                  VR7      # )z7
Creates a new instance of AIOOperation on fsync mode.
Nr   )r   r   r   rb   r   s   &&&r#   r   Operation.fsync   s     2tT&,,JJr"   c                $   < V ^8  d   QhRS[ RR/# r   r*   )r,   r-   s   "r#   r.   r      s     L L LK Lr"   c                8    V ! VRR\         P                  VR7      # )z8
Creates a new instance of AIOOperation on fdsync mode.
Nr   )r   r   r   s   &&&r#   r   Operation.fdsync   s     2tT&--(KKr"   c                6   < V ^8  d   QhRS[ S[S[3,          /# r>   )r   ri   r+   )r,   r-   s   "r#   r.   r      s     & &5, &r"   c                    V P                   '       d   V P                   hV P                  \        P                  8X  d   V P                  # V P
                  f   R# V P
                  P                  4       # )z@
Method returns a bytes value of AIOOperation's result or None.
N)rL   rY   r   r   rM   rv   r   rB   s   &r#   	get_valueOperation.get_value   sQ     >>>.. ;;&,,&<<;;{{##%%r"   c                    < V ^8  d   QhRS[ /# r>   r*   )r,   r-   s   "r#   r.   r             r"   c                    V P                   # rA   )r   rB   s   &r#   rx   Operation.fileno       }}r"   c                    < V ^8  d   QhRS[ /# r>   r*   )r,   r-   s   "r#   r.   r      r   r"   c                    V P                   # rA   )r   rB   s   &r#   rd   Operation.offset   r   r"   c                0   < V ^8  d   QhRS[ S[,          /# r>   )r   
memoryview)r,   r-   s   "r#   r.   r     s     ' '*- 'r"   c                6    V P                   P                  4       # rA   )rv   	getbufferrB   s   &r#   r   Operation.payload  s    {{$$&&r"   c                    < V ^8  d   QhRS[ /# r>   r*   )r,   r-   s   "r#   r.   r     r   r"   c                    V P                   # rA   )r   rB   s   &r#   ry   Operation.nbytes  r   r"   c                >   < V ^8  d   QhRS[ S[.S[3,          RS[/# )r'   rN   r?   )r   r+   r   bool)r,   r-   s   "r#   r.   r     s&      XseSj%9 d r"   c                    Wn         R # )T)rN   )r:   rN   s   &&r#   set_callbackOperation.set_callback  s
     r"   )
__fileno__nbytes__offset__opcode
__priorityrv   rN   rL   rY   rM   )NN)r   )r   r   r   r   r   r;   classmethodrp   rs   r   r   r   r   rx   rd   r   ry   r   r!   r   r   s   @r#   rG   rG      s      0 N N N 
 
 
 K K K L L L& &     ' '   r"   rG   )r`   collectionsr   enumr   r   ior   multiprocessing.poolr   	threadingr   r	   typesr
   typingr   r   r   r   abstractr   r   getattrr   r   hasattrr7   r   r%   rG   r   r"   r#   <module>r      s    	 #    + ! " 1 1 8 
["((	+b'*DDwr8/D  W  Io IZf! fr"   