+
    P(i#                       a  R t*0 t ^ RIt^ RIt^ RIHt ^ RIHt ^ RIHt ^ RIH	t	 ^ RI
Ht ^ RIHtHtHtHtHtHtHtHtHtHt ^ RIHt ^ RIt^ R	IHt ]! R
4      tRtRt]]]3,          t]! RR4      t R R lt! ! R R4      t"]]PF                  ]PH                  3,          t%/ t&] ^ k ]PH                  PN                  3R R llt(R R lt)R# )    N)
namedtuple)Executor)partial)strerror)Path)
Any	AwaitableBinaryIOCallableDict	GeneratorOptionalTextIOTypeVarUnion)finalize)AsyncioContextBase_TFileModec                0    V ^8  d   QhR\         R\        /# )   modereturn)strr   )formats   "Q/Users/agent/.openclaw/workspace/venv/lib/python3.14/site-packages/aiofile/aio.py__annotate__r   &   s     K KS KX K    c           
        \         P                  pRpRpRpRpRpRpRpV  EFM  p	V	R8X  d3   RpRpRpV\         P                  \         P                  ,          ,          pV	R8X  d   V'       d   \	        R4      hRpRpV	R8X  dD   V'       d   \	        R4      hRpRpV\         P                  \         P
                  ,          ,          pV	R8X  dF   V'       d   \	        R4      hRpRpRpV\         P                  \         P                  ,          ,          pV	R8X  d   V'       d   \	        R4      hRpRpRpV	R	8X  g   EK  Rp\        \         R
4      '       g   EK6  V\         P                  ,          pEKP  	  V'       d!   V'       d   V\         P                  ,          pM7V'       d   V\         P                  ,          pMV\         P                  ,          p\        VVVVVVVR7      # )zMRewritten from `cpython fileno`_

.. _cpython fileio: https://bit.ly/2JY2cnp
FxTrzBad modewa+bO_BINARYreadablewritableplus	appendingcreatedflagsbinary)osO_RDONLYO_EXCLO_CREAT	ExceptionO_TRUNCO_APPENDhasattrr&   O_RDWRO_WRONLYr   )
r   r-   rwar)   r(   r*   r+   r,   r.   ms
   &         r   
parse_moder;   &   s    KKE
CHHDIGF8CGHRYY++E8
++CH8
++CHRZZ"**,,E8
++CHIRZZ"++--E8
++HHD8Fr:&&$S V H	 r   c                     a  ] tR t^tt o R0V 3R lR llt]V 3R lR 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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R1V 3R lR lltR1V 3R lR lltR2V 3R  lR! lltV 3R" lR# ltV 3R$ lR% ltR2V 3R& lR' lltV 3R( lR) ltV 3R* lR+ ltR2V 3R, lR- lltV 3R. ltR/tV tR# )3AIOFileNc                n   < V ^8  d   QhRS[ S[S[3,          RS[RS[RS[S[,          RS[S[,          /# )r   filenamer   encodingcontextexecutor)r   r   r   r   r   r   )r   __classdict__s   "r   r   AIOFile.__annotate__|   sM     " "c4i(""#&" ,-" 8$	"r   c                    T;'       g    \        4       V n        R V n        \        V4      V n        W n        \        V4      V n        R V n        RV n	        W0n
        WPn        R # )NT)get_default_context_AIOFile__context_AIOFile__open_resultr   _fname
_open_moder;   r   	_file_obj_file_obj_owner	_encoding	_executor)selfr?   r   r@   rA   rB   s   &&&&&&r   __init__AIOFile.__init__|   sT     !99$7$9!(mt$	#!!r   c                *   < V ^8  d   QhRS[ RS[RR/# )r   fpkwargsr   r=   )
FileIOTyper   )r   rC   s   "r   r   rD      s"       s y r   c                ~    V ! VP                   VP                  3/ VB pWn        VP                  Vn        R Vn        V# )F)namer   rK   rJ   rL   )clsrS   rT   afps   &&, r   from_fpAIOFile.from_fp   s8    "''277-f-#
r   c                .   < V ^8  d   QhRRRS[ RS[ RR/# )r   funczCallable[..., _T]argsrT   r   zasyncio.Future[_T])r   )r   rC   s   "r   r   rD      s-     
 
+
47
CF
	
r   c                |    V P                   P                  P                  V P                  \	        V.VO5/ VB 4      # N)rG   looprun_in_executorrN   r   )rO   r]   r^   rT   s   &&*,r   _run_in_threadAIOFile._run_in_thread   s9     ~~""22NNGD:4:6:
 	
r   c                    < V ^8  d   QhRS[ /# r   r   r   )r   rC   s   "r   r   rD      s      c r   c                    V P                   # r`   rI   rO   s   &r   rW   AIOFile.name   s    {{r   c                4   < V ^8  d   QhRS[ P                  /# rf   )asyncioAbstractEventLoop)r   rC   s   "r   r   rD      s     # #g// #r   c                .    V P                   P                  # r`   )rG   ra   rj   s   &r   ra   AIOFile.loop   s    ~~"""r   c                    < V ^8  d   QhRS[ /# rf   rg   )r   rC   s   "r   r   rD      s      # r   c                    V P                   # r`   )rM   rj   s   &r   r@   AIOFile.encoding   s    ~~r   c                0   < V ^8  d   QhRS[ S[,          /# rf   )r   int)r   rC   s   "r   r   rD      s      HSM r   c                  "   V P                   e5   V P                   P                  '       d   \        P                  ! R4      hR # V P                  fk   V P                  \        V P                  V P                  4      V n        V P                  G R j  xL
 V n         R V n        V P                   P                  4       # V P                  G R j  xL
  R #  L@ L5iNzAIOFile closed)
rK   closedrm   InvalidStateErrorrH   rc   openrI   rJ   filenorj   s   &r   rz   AIOFile.open   s     >>%~~$$$//0@AA%!%!4!4"D
 $(#5#55DN!%D>>((**     6 	!s)   *CA%CC9CCCCc                    < V ^8  d   QhRS[ /# rf   rg   )r   rC   s   "r   r   rD      s     - -# -r   c                (    R V P                   ,          # )z<AIOFile: %r>ri   rj   s   &r   __repr__AIOFile.__repr__   s    ,,r   c                   < V ^8  d   QhRR/# r   r   N )r   rC   s   "r   r   rD      s     8 8T 8r   c                  "   V P                   e   V P                  '       g   R # V P                  P                  '       d   V P	                  4       G R j  xL
  V P                  V P                   P                  4      G R j  xL
  R #  L3 L5ir`   )rK   rL   r   r)   fdsyncrc   closerj   s   &r   r   AIOFile.close   sb     >>!)=)=)=99++-!!$.."6"6777  7s.    BBBB,BB
B
Bc                    < V ^8  d   QhRS[ /# rf   )ru   )r   rC   s   "r   r   rD      s     ' ' 'r   c                ~    V P                   f   \        P                  ! R4      hV P                   P                  4       # rw   )rK   rm   ry   r{   rj   s   &r   r{   AIOFile.fileno   s1    >>!++,<==~~$$&&r   c                6   < V ^8  d   QhRS[ RS[R3,          /# )r   r   Nr=   )r   r   )r   rC   s   "r   r   rD      s       9T3	%9: r   c              #  ^   "   V P                  4       P                  4        R j  xL
  V #  L5ir`   )rz   	__await__rj   s   &r   r   AIOFile.__await__   s'     99;((*** 	+s   "-+-c                   < V ^8  d   QhRR/# )r   r   r=   r   )r   rC   s   "r   r   rD      s      ) r   c                B   "   V P                  4       G R j  xL
  V #  L5ir`   )rz   rj   s   &r   
__aenter__AIOFile.__aenter__   s     iik 	s   c                6   < V ^8  d   QhRS[ RS[S[ ,          /# )r   r^   r   )r   r	   )r   rC   s   "r   r   rD      s#     B Bs By~ Br   c                f    \         P                  ! 4       P                  V P                  4       4      # r`   )rm   get_event_loopcreate_taskr   )rO   r^   s   &*r   	__aexit__AIOFile.__aexit__   s"    %%'33DJJLAAr   c                B   < V ^8  d   QhRS[ RS[ RS[S[S[3,          /# r   sizeoffsetr   )ru   r   bytesr   )r   rC   s   "r   r   rD      s0     E Es E EU5#:=N Er   c                   "   V P                  W4      G R j  xL
 pV P                  P                  '       d   V# V P                  V4      #  L35ir`   )
read_bytesr   r.   decode_bytes)rO   r   r   datas   &&& r   readAIOFile.read   s@     __T22yy'''tDT->->t-DD 3s   AAAAc                ,   < V ^8  d   QhRS[ RS[ RS[/# r   )ru   r   )r   rC   s   "r   r   rD      s'     F FS Fs F5 Fr   c                6  "   VR8  d   \        RV,          4      hVR8X  dA   V P                  \        P                  V P	                  4       4      G Rj  xL
 P
                  pV P                  P                  WP	                  4       V4      G Rj  xL
 #  L@ L5i)   zUnsupported value %d for sizeN)
ValueErrorrc   r/   statr{   st_sizerG   r   )rO   r   r   s   &&&r   r   AIOFile.read_bytes   s     "9<tCDD2:))GGKKM  g  ^^(({{}fEEE Fs$   ABB;BBBBc                B   < V ^8  d   QhRS[ S[S[3,          RS[RS[/# r   r   r   r   )r   r   r   ru   )r   rC   s   "r   r   rD      s+     
: 
:c5j 1 
:3 
:s 
:r   c                $  "   V P                   P                  '       d%   \        V\        4      '       g   \	        R 4      hTpM2\        V\
        4      '       g   \	        R4      hV P                  V4      pV P                  W24      G Rj  xL
 #  L5i)z!Data must be bytes in binary modezData must be str in text modeN)r   r.   
isinstancer   r   r   encode_byteswrite_bytes)rO   r   r   
bytes_datas   &&& r   writeAIOFile.write   ss     99dE** !DEEJdC(( !@AA**40J%%j9999s   BB	B
Bc                &   < V ^8  d   QhRS[ RS[/# r   r   r   )r   r   )r   rC   s   "r   r   rD      s     + + + +r   c                8    VP                  V P                  4      # r`   )encoderM   rO   r   s   &&r   r   AIOFile.encode_bytes       {{4>>**r   c                &   < V ^8  d   QhRS[ RS[/# r   )r   r   )r   rC   s   "r   r   rD      s     + + +3 +r   c                8    VP                  V P                  4      # r`   )decoderM   r   s   &&r   r   AIOFile.decode_bytes   r   r   c                ,   < V ^8  d   QhRS[ RS[RS[/# r   )r   ru   )r   rC   s   "r   r   rD      s"     $ $e $S $ $r   c                P  "   \        V4      pV^ 8X  d   ^ # ^ pWC8  d   V P                  P                  WR V P                  4       W$,           4      G Rj  xL
 pV^ 8X  d   \	        RWV4      hV^ 8  d$   V) p\        V\        V4      V P                  4      hWE,          pK  V#  LN5i)r   NzWrite operation returned 0)lenrG   r   r{   RuntimeErrorOSErrorr   rI   )rO   r   r   	data_sizewrittenreserrnos   &&&    r   r   AIOFile.write_bytes   s     I	> !,,Xv/? C ax"0$  q eXe_dkkBBNG!s   AB&B$AB&c                   < V ^8  d   QhRR/# r   r   )r   rC   s   "r   r   rD   #  s     9 9T 9r   c                p   "   V P                   P                  V P                  4       4      G R j  xL
 #  L5ir`   )rG   fsyncr{   rj   s   &r   r   AIOFile.fsync#  s&     ^^))$++-8888   -646c                   < V ^8  d   QhRR/# r   r   )r   rC   s   "r   r   rD   &  s     : :d :r   c                p   "   V P                   P                  V P                  4       4      G R j  xL
 #  L5ir`   )rG   r   r{   rj   s   &r   r   AIOFile.fdsync&  s&     ^^**4;;=9999r   c                4   < V ^8  d   QhRS[ RS[R,          /# )r   lengthr   N)ru   r	   )r   rC   s   "r   r   rD   )  s     
 
s 
9T? 
r   c                `    V P                  \        P                  V P                  4       V4      # r`   )rc   r/   	ftruncater{   )rO   r   s   &&r   truncateAIOFile.truncate)  s&    ""LL$++-
 	
r   c                   < V ^8  d   Qh/ S[ S[,          ;R&   S[;R&   S[;R&   S[ S[,          ;R&   S[;R&   R;R&   # )r   rK   rL   rM   rN   r   z$Optional[asyncio.Future[FileIOType]]rH   )r   rU   boolr   r   r   )r   rC   s   "r   r   rD   t   sW     
##   N  !!	 
 N  :9 r   )		__context__open_resultrM   rN   rK   rL   rI   rJ   r   )r!   zutf-8NN)r   r   )r   )__name__
__module____qualname____firstlineno__rP   classmethodrZ   rc   propertyrW   ra   r@   rz   r   r   r{   r   r   r   r   r   r   r   r   r   r   r   r   __annotate_func____static_attributes____classdictcell__)rC   s   @r   r=   r=   t   s    " "&  
 
   # #   &- -8 8' '
  B BE EF F
: 
:+ ++ +$ $L9 9: :
 
k  r   r=   c                D    V ^8  d   QhR\         R\        P                  /# )r   max_requestsr   )ru   caioAsyncioContext)r   s   "r   r   r   3  s"      	r   c                    a \         P                  ! 4       p\        P                  ! WR 7      oR V3R llp\	        W4       S\
        V&   S# ))ra   c                    V ^8  d   QhRR/# r   r   )r   s   "r   r   $create_context.<locals>.__annotate__9  s     1 1t 1r   c                  T   < S P                  4        \        P                  S R 4       R # r`   )r   DEFAULT_CONTEXT_STOREpop)rA   s   r   	finalizer!create_context.<locals>.finalizer9  s    !!'40r   )rm   r   r   r   r   r   )r   ra   r   rA   s   &  @r   create_contextr   3  sG     !!#D!!,:G1 1 T")$Nr   c                8    V ^8  d   QhR\         P                  /# rf   )r   r   )r   s   "r   r   r   B  s      T00 r   c                  v    \         P                  ! 4       p \        P                  V 4      pVe   V# \	        4       # r`   )rm   r   r   getr   )ra   rA   s     r   rF   rF   B  s4    !!#D#''-Gr   c                @    V ^8  d   Qh/ ^ \         9   d
   \        ;R&   # )r   r   )__conditional_annotations__ContextStoreType)r   s   "r   r   r      s    ^	 - ,' ,_	 r   r   r'   )+r   rm   r/   collectionsr   concurrent.futuresr   	functoolsr   r   pathlibr   typingr   r	   r
   r   r   r   r   r   r   r   weakrefr   r   caio.asyncio_baser   r   AIO_FILE_NOT_OPENEDAIO_FILE_CLOSEDrU   r   r;   r=   rn   r   r   r   MAX_REQUESTS_DEFAULTr   rF   r   )r   s   @r   <module>r     s     	 " '        0 T] 68#$
 
K\x
 x
v 1143F3FFG *,  , ++@@r   