UN d dl Z e j dk r ed d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl
Z
d dl Z ddl m
Z
ddl mZ ddl mZ ddl mZ dd l mZ dd
l mZ dd l mZ dd l mZ dd
lmZ dZej Zej ZdZdZdZ dZ G d dej Z G d dej Z G d de Z! G d de Z" G d d e# Z$ G d d ej% Z& G d d ej' Z( G d! d" Z) G d# d$ej* Z+e&Z, G d% d&e
j- Z. G d' d(e
j- Z/e/Z0dS )) Nwin32z
win32 only )events)base_subprocess)futures)
exceptions)proactor_events)selector_events)tasks)
windows_utils)logger)SelectorEventLoopProactorEventLoop IocpProactorDefaultEventLoopPolicy WindowsSelectorEventLoopPolicy WindowsProactorEventLoopPolicyi i gMbP?g?c V e Zd Z dd fd
Z fdZd Zd fd Z fdZ fdZ xZ S )
_OverlappedFutureNloopc x t | | j r| j d= || _ d S Nr )super__init___source_traceback_ov)selfovr __class__s =/opt/alt/python311/lib64/python3.11/asyncio/windows_events.pyr z_OverlappedFuture.__init__6 s?
d### ! +&r* c t }| j 8| j j rdnd}| dd| d| j j dd |S )Npending completedr z overlapped=)r
_repr_infor r% insertaddressr infostater! s r" r) z _OverlappedFuture._repr_info< sh ww!!## 8 !%!1BII{E KKI%II483CIIII J J J r# c | j d S | j nH# t $ r;}d|| d}| j r
| j |d< | j | Y d }~nd }~ww xY wd | _ d S )Nz&Cancelling an overlapped future failedmessage exceptionfuturesource_traceback)r cancelOSErrorr _loopcall_exception_handler)r exccontexts r" _cancel_overlappedz$_OverlappedFuture._cancel_overlappedC s 8 F
7 HOO 7 7 7C G
%
E.2.D*+ J - -g 6 6 6 6 6 6 6 6 7 s %
A*1A%%A*c p | t | S N)msg)r; r r5 r r> r! s r" r5 z_OverlappedFuture.cancelS s- !!!ww~~#~&&&r# c r t | | d S N)r
set_exceptionr; r r2 r! s r" rB z _OverlappedFuture.set_exceptionW s3
i((( !!!!!r# c X t | d | _ d S rA )r
set_resultr r resultr! s r" rE z _OverlappedFuture.set_result[ s&
6"""r# rA )
__name__
__module__ __qualname__r r) r; r5 rB rE
__classcell__r! s @r" r r 0 s
$( ' ' ' ' ' '" " " " " r# r c b e Zd Z dd fd
Zd Z fdZd Zd Zd fd Z fd Z fd
Z
xZ S ) _BaseWaitHandleFutureNr c t | | j r| j d= || _ || _ || _ d| _ d S )Nr r T)r r r r _handle _wait_handle _registered)r r handle wait_handler r! s r" r z _BaseWaitHandleFuture.__init__c s\
d### ! +&r* ' r# c R t j | j d t j k S Nr )_winapiWaitForSingleObjectrP
WAIT_OBJECT_0r s r" _pollz_BaseWaitHandleFuture._pollq s$ +DL!<<%& 'r# c 6 t }| d| j d | j -| rdnd}| | | j | d| j d |S )Nzhandle=r' signaledwaitingz wait_handle=)r r) appendrP r[ rQ r, s r" r) z _BaseWaitHandleFuture._repr_infov s ww!!## /dl///000 < #"&**,,=JJIE KK ( KK=t'8=== > > > r# c d | _ d S rA )r )r futs r" _unregister_wait_cbz)_BaseWaitHandleFuture._unregister_wait_cb s r# c ^ | j sd S d| _ | j }d | _ t j | nc# t $ rV}|j t j k r7d|| d}| j r
| j |d< | j | Y d }~d S Y d }~nd }~ww xY w|
d d S NFz$Failed to unregister the wait handler0 r4 ) rR rQ _overlappedUnregisterWaitr6 winerrorERROR_IO_PENDINGr r7 r8 rb r rT r9 r: s r" _unregister_waitz&_BaseWaitHandleFuture._unregister_wait s F ' &{ 3 3 3 3
|{ ;;; E!$ "
) I262HG ./
11'::: <;;;;
&&&&&s 5
BABBc p | t | S r= )rj r r5 r? s r" r5 z _BaseWaitHandleFuture.cancel s- ww~~#~&&&r# c r | t | d S rA )rj r rB rC s r" rB z#_BaseWaitHandleFuture.set_exception s3
i(((((r# c r | t | d S rA )rj r rE rF s r" rE z _BaseWaitHandleFuture.set_result s3
6"""""r# rA ) rH rI rJ r r[ r) rb rj r5 rB rE rK rL s @r" rN rN ` s <8< ' ' '
' ' '0' ' ' ' ' ') ) ) ) )# # # # # # # # #r# rN c @ e Zd Z dd fd
Zd Z fdZ fdZ xZS )_WaitCancelFutureNr c ` t |||| d | _ d S )Nr )r r _done_callback)r r eventrT r r! s r" r z_WaitCancelFuture.__init__ s2
UKd;;; "r# c t d )Nz'_WaitCancelFuture must not be cancelled) RuntimeErrorrZ s r" r5 z_WaitCancelFuture.cancel s DEEEr# c t | | j | | d S d S rA )r rE rq rF s r" rE z _WaitCancelFuture.set_result sF
6""" * % % % % % + *r# c t | | j | | d S d S rA )r rB rq rC s r" rB z _WaitCancelFuture.set_exception sF
i((( * % % % % % + *r# )rH rI rJ r r5 rE rB rK rL s @r" ro ro s 8< # # # # # # #
F F F& & & & &
& & & & & & & & &r# ro c 4 e Zd Zdd fd
Z fdZd Z xZS )_WaitHandleFutureNr c t |||| || _ d| _ t j d ddd | _ d | _ d S )Nr TF)r r _proactor_unregister_proactorre CreateEvent_event
_event_fut)r r rS rT proactorr r! s r" r z_WaitHandleFuture.__init__ sV
V[t<<<!$(!!-dD%FF r# c | j 't j | j d | _ d | _ | j | j d | _ t | d S rA ) r} rW CloseHandler~ rz _unregisterr r rb )r ra r! s r" rb z%_WaitHandleFuture._unregister_wait_cb sk ; " , , , DK "DO
""48,,,
##C(((((r# c | j sd S d| _ | j }d | _ t j || j nc# t
$ rV}|j t j k r7d|| d}| j r
| j |d< | j
| Y d }~d S Y d }~nd }~ww xY w| j | j | j
| _ d S rd )rR rQ re UnregisterWaitExr} r6 rg rh r r7 r8 rz _wait_cancelrb r~ ri s r" rj z"_WaitHandleFuture._unregister_wait s F ' (dk B B B B
|{ ;;; E!$ "
) I262HG ./
11'::: <;;;;
.55dk6:6NP Ps ;
BABB)rH rI rJ r rb rj rK rL s @r" rx rx st BF ) ) ) ) )$P P P P P P Pr# rx c 2 e Zd Z d Zd Zd Zd Zd ZeZdS )
PipeServerc || _ t j | _ d | _ d | _ | d | _ d S NT)_addressweakrefWeakSet_free_instances_pipe_accept_pipe_future_server_pipe_handle)r r+ s r" r zPipeServer.__init__ sC
& 0 0
#' --d33
r# c J | j | d c}| _ |S NF)r r )r tmps r" _get_unconnected_pipez PipeServer._get_unconnected_pipe s&
*d&>&>u&E&ETZ
r# c
| rd S t j t j z }|r|t j z }t j | j |t j t j z t j z t j
t j t j t j
t j }t j | }| j | |S rA )closedrW PIPE_ACCESS_DUPLEXFILE_FLAG_OVERLAPPED FILE_FLAG_FIRST_PIPE_INSTANCECreateNamedPiper PIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITPIPE_UNLIMITED_INSTANCESr BUFSIZENMPWAIT_WAIT_FOREVERNULL
PipeHandler add)r firstflagshpipes r" r z PipeServer._server_pipe_handle
s ;;== 4*W-II ; W: :E # M5 %(E E
, !=#8 (',
8
8 '** &&& r# c | j d u S rA )r rZ s r" r zPipeServer.closed s
%&r# c | j | j d | _ | j G| j D ]}| d | _ d | _ | j d S d S rA )r r5 r r closer clear)r r s r" r zPipeServer.close" s # / $ + + - - -'+D $ = $ ,
DJ DM & & ( ( ( ( ( % $r# N) rH rI rJ r r r r r __del__ r# r" r r se 4 4 4 $' ' '
)
)
) GGGr# r c e Zd ZdS )_WindowsSelectorEventLoopN)rH rI rJ r r# r" r r 1 s 11r# r c B e Zd Z d fd Z fdZd Zd Z ddZ xZS )r Nc j |t }t | d S rA )r r r )r r r! s r" r zProactorEventLoop.__init__8 s0 #~~H
"""""r# c | | j t | j Q| j j }| j |!|j s| j | d | _ d S d S # | j O| j j }| j |!|j s| j | d | _ w xY wrA )
call_soon_loop_self_readingr run_forever_self_reading_futurer r5 r% rz r )r r r! s r" r z ProactorEventLoop.run_forever= s 1 NN42 3 3 3 GG ! ! !(4.2)00222 >"*>N..r222,0))) 54t(4.2)00222 >"*>N..r222,0)0000s :B AC/c K | j | }| d {V } | }| ||d|i }||fS )Naddrextra)rz connect_pipe_make_duplex_pipe_transport)r protocol_factoryr+ fr protocoltranss r" create_pipe_connectionz(ProactorEventLoop.create_pipe_connectionP sl N ' ' 0 0wwwwww##%%00x8>7H 1 J Jh r# c r K t d fd gS )Nc d } | r|| }j | r| d S } ||di }|d S j | } | _ |
d S # t $ rG |r,| dk r|
Y d S t $ r}|rF| dk r. d||d | n j rt# j d|d
Y d }~d S d }~wt& j $ r |r| Y d S Y d S w xY w) Nr r r zPipe accept failed)r1 r2 r z Accept pipe failed on pipe %rT)exc_info)rG r discardr r r r rz accept_piper add_done_callbackBrokenPipeErrorfilenor r6 r8 _debugr
warningr CancelledError) r r r r9 r+ loop_accept_piper r servers r" r z>ProactorEventLoop.start_serving_pipe..loop_accept_pipe[ sJ D)
6 A 88::D*224888 }}
/ / 1 1H44 hvw.? 5 A A A 3355<FN..t44* ./*##$455555+ #
1
1
1 !DKKMMR / /JJLLL /000000
1
1
1 8DKKMMR / ///#7%( $1 1
JJLLLL[ 8N#B#'$8 8 8 8 /000000000 ,
!
!
! !JJLLLLLL! ! !
!s2 AC :C C A
G # G ,A;F--(G G rA )r r )r r r+ r r s ```@@r" start_serving_pipez$ProactorEventLoop.start_serving_pipeX sg G$$+ 6 + 6 + 6 + 6 + 6 + 6 + 6 + 6 + 6 + 6Z
'(((xr# c
K | }
t | |||||||f|
|d| } |
d {V nN# t t f$ r t $ r0 | | d {V w xY w| S )N)waiterr )
create_future_WindowsSubprocessTransport
SystemExitKeyboardInterrupt
BaseExceptionr _wait) r r argsshellstdinstdoutstderrbufsizer kwargsr transps r" _make_subprocess_transportz,ProactorEventLoop._make_subprocess_transport s ##%%,T8T5-2FFG74:%7 7 067 7 LLLLLLLL -. LLNNN,,..
s
8 A BrA ) rH rI rJ r r r r r rK rL s @r" r r 5 s <# # # # # #
1 1 1 1 1& 1 1 1j 04 r# r c e Zd Z efdZd Zd Zd Zd dZd Z d d Z
d d
Z d d Z d d Z
d!d
Zd dZd Zd Zd Zd Zd Zd dZd Zd Zd Zd Zd Zd Zd dZ d Z d Z d Z dS )"r c d | _ g | _ t j t j t
d| | _ i | _ t j | _
g | _ t j | _ d S rV )
r7 _resultsre CreateIoCompletionPortINVALID_HANDLE_VALUEr _iocp_cacher r rR
_unregistered_stopped_serving)r concurrencys r" r zIocpProactor.__init__ sg
7 ,dA{D D
"?,, ' 1 1 r# c 2 | j t d d S )NzIocpProactor is closed)r rt rZ s r"
_check_closedzIocpProactor._check_closed s! : 788 8 r# c dt | j z dt | j z g}| j | d d| j j dd | dS )Nzoverlapped#=%sz
result#=%sr < r( )lenr r r r_ r! rH join)r r- s r" __repr__zIocpProactor.__repr__ sl 3t{#3#33 s4= 1 113 : KK ! ! ! N 3 3 3SXXd^^^^DDr# c || _ d S rA )r7 )r r s r" set_loopzIocpProactor.set_loop s
r# Nc n | j s| | | j }g | _ |d }S # d }w xY wrA )r r[ )r timeoutr s r" selectzIocpProactor.select sJ } JJw m
CC$CJJJJs 0 4c b | j }| | |S rA )r7 r rE )r valuera s r" _resultzIocpProactor._result s, j&&(( u
r# r c | | t j t } t |t
j r*| | || n(| | | n%# t $ r |
d cY S w xY wd }| ||| S )Nr# c | S # t $ r3}|j t j t j fv rt
|j d }~ww xY wrA getresultr6 rg re ERROR_NETNAME_DELETEDERROR_OPERATION_ABORTEDConnectionResetErrorr r keyr r9 s r" finish_recvz&IocpProactor.recv..finish_recv f
||~~%
B?c | | t j t } t |t
j r*| | || n(| | | n%# t $ r |
d cY S w xY wd }| ||| S )Nr c | S # t $ r3}|j t j t j fv rt
|j d }~ww xY wrA r r s r" r z+IocpProactor.recv_into..finish_recv r r ) r re r r r r
WSARecvIntor ReadFileIntor r r
r r bufr r r s r" recv_intozIocpProactor.recv_into s &&&
#D
)
) #$
..
4t{{}}c59999
s333 # # #<<?? " " " # ~~b$ 444r c 2 | | t j t } | | || n%# t $ r | d cY S w xY wd }| ||| S )Nr# Nc | S # t $ rN}|j t j k rY d }~dS |j t j t j fv rt |j d }~ww xY w)Nr r r6 rg re ERROR_PORT_UNREACHABLEr r r r r s r" r z*IocpProactor.recvfrom..finish_recv s
||~~%
<;#EEE$99999.finish_recv s
||~~%
<;#EEE"77777.finish_send. r r )r re r r WSASendTor r
)r r r r r r r* s r" sendtozIocpProactor.sendto( sm &&&
#D
)
)
T[[]]C555 ~~b$ 444r# c j | | t j t }t |t
j r*| | || n(| | | d }| ||| S )Nc | S # t $ r3}|j t j t j fv rt
|j d }~ww xY wrA r r s r" r* z&IocpProactor.send..finish_sendB r r )
r re r r r r
WSASendr WriteFiler
)r r r r r r* s r" sendzIocpProactor.send: s &&&
#D
)
) dFM * * - JJt{{}}c5 1 1 1 1 LL , , , ~~b$ 444r# c | | j t j t
}| fd}d }| || } || }t j
|| j |S )Nc J | t j d } t
j t j |
fS )Nz@P) r structpackr
setsockoptr
SOL_SOCKETre SO_UPDATE_ACCEPT_CONTEXT
settimeout
gettimeout getpeername)r r r r r listeners r"
finish_acceptz*IocpProactor.accept..finish_acceptT s LLNNN+dHOO$5$566C OOF - ' @#
G
G
G OOH / / 1 1 2 2 2))+++ +r# c l K | d {V d S # t j $ r | w xY wrA )r r r )r3 r s r" accept_coroz(IocpProactor.accept..accept_coro] sN
,
s %3r ) r _get_accept_socketfamilyre r r AcceptExr r
r
ensure_futurer7 )r r< r r= r? r3 coror s ` @r" acceptzIocpProactor.acceptN s ***&&x77
#D
)
)
HOO%%t{{}}555 , , , , , , Hm<<{64((
Dtz2222
r# c j t j k rWt j | | j }| d |S | t j
j nL# t $ r?}|j
t j k r d dk r Y d }~nd }~ww xY wt j t$ }| | fd}| || S )Nr r c | t j t j d S rV )r r6 r
r7 re SO_UPDATE_CONNECT_CONTEXT)r r r r s r" finish_connectz,IocpProactor.connect..finish_connect s; LLNNN OOF - ' A1
F
F
FKr# )typer
SOCK_DGRAMre
WSAConnectr r7 r rE r BindLocalrA r6 rg errno WSAEINVAL getsocknamer r ConnectExr
)r r r+ ra er rI s ` r" connectzIocpProactor.connectj sS 9) ) )
"4;;==' : : :***,,C NN4 J &&& !$++-- = = = = zU_,, !!!$)) *))))
#D
)
)
T[[]]G,,, ~~b$777s ,B1 1
C:;5C55C:c N | | t j t }|dz }|dz dz }| | t
j | |||dd d }| ||| S )Nl r c | S # t $ r3}|j t j t j fv rt
|j d }~ww xY wrA r r s r" finish_sendfilez.IocpProactor.sendfile..finish_sendfile r r ) r re r r TransmitFiler msvcrt
get_osfhandler
) r sockfileoffsetcountr
offset_low offset_highrW s r" sendfilezIocpProactor.sendfile s &&&
#D
)
)k)
|{2
,T[[]];;"K q! % % %
~~b$888r# c | t j t }| }|r| S fd}| || S )Nc 0 | S rA )r )r r r r s r" finish_accept_pipez4IocpProactor.accept_pipe..finish_accept_pipe s LLNNNKr# )r re r r ConnectNamedPiper r r
)r r r connectedrd s ` r" r zIocpProactor.accept_pipe s &&&
#D
)
)''
66 & <<%% % ~~b$(:;;;r# c * K t } t j | }n`# t $ r }|j t j k r Y d }~nd }~ww xY wt
|dz t }t j | d {V vt j | S )NT ) CONNECT_PIPE_INIT_DELAYre ConnectPiper6 rg ERROR_PIPE_BUSYminCONNECT_PIPE_MAX_DELAYr sleepr r )r r+ delayrS r9 s r" r zIocpProactor.connect_pipe s '
%
$099
<;#>>> ?>>>>
#9::E+e$$ $ $ $ $ $ $ $
% '///s !
A AA c 2 | ||d S r )_wait_for_handle)r rS r s r" wait_for_handlez IocpProactor.wait_for_handle s!
$$VWe<<.finish_wait_for_handle s 7799 r# r )r rW INFINITEmathceilre r r RegisterWaitWithQueuer r+ ro r7 rx r r ) r rS r
_is_cancelmsr rT rx r s @r" rq z IocpProactor._wait_for_handle s ?!BB 7S=))B
#D
)
)!7 DJ
B0 0 3!"fk
KKKAA!"fk4'+z3 3 3A (#B' $%b!-C"D BJ r# c || j vrJ| j | t j | | j dd d S d S rV )rR r re r r r r objs r" r z IocpProactor._register_with_iocp sX d& & & % % % .szz||TZA N N N N N ' &r# c L | t || j }|j r|j d= |j sP |d d | }| | n,# t $ r }| | Y d }~nd }~ww xY w||||f| j |j < |S r )
r r r7 r r% rE r6 rB r r+ )r r r callbackr r rR s r" r
zIocpProactor._register s
btz 2 2 2 (#B'z
$
$ tR00 U####
#
#
#""""""""
# $%b#x"8 BJ s
A% %
B/B Bc d | | j | d S rA )r r r_ )r r s r" r zIocpProactor._unregister s8
!!"%%%%%r# c X t j | }| d |S rV )r
r9 )r rA ss r" r@ z IocpProactor._get_accept_socket' s% M& ! ! Qr# c $ |t }nF|dk rt d t j |dz }|t k rt d t j | j | }|n]d}|\ }}}} | j | \ }} }
} nq# t $ rd | j
r$| j
dd||||fz d |dt j
fvrt j | Y w xY w|
| j v r| n| s | ||| } | | | j | nF# t, $ r9}
| |
| j | Y d }
~
nd }
~
ww xY wd }n# d }w xY w{| j D ]"} | j | j d #| j d S ) Nr znegative timeoutrv ztimeout too bigTz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r1 status)ry
ValueErrorrz r{ re GetQueuedCompletionStatusr r popKeyErrorr7 get_debugr8 r rW r r r5 donerE r r_ r6 rB r r+ r )r r r~ r err transferredr r+ r r r r r rR s r" r[ zIocpProactor._poll, sy ?BB
q[[ /00 0 7S=))BX~~ !2333& :4:rJJF~B-3 *Cc7
'+{w'?'?$2sHH
:'')) J55%7#N&);W%E$F7 7 q+"B CCC',,,
d+++
VVXX
$H[#r : :E
LL'''M((++++ , , ,OOA&&&M((++++++++, AAAHHHHM& R $ . .B KOOBJ - - - - """""sC : B A+DD>
E; 0G ;
F>/F94G 9F>>G Gc : | j | d S rA )r r r s r"
_stop_servingzIocpProactor._stop_servinge s!
!!#&&&&&r# c | j d S t | j D ]\ }}}}| r t |t r2 | H# t $ rB}| j 1d||d}|j
r
|j
|d< | j | Y d }~d }~ww xY wd}t j
}||z } | j rs| t j
k r@t j d| t j
|z
t j
|z } | | | j sg | _ t% j | j d | _ d S )NzCancelling a future failedr0 r4 g ?z,%r is running after closing for %.1f seconds)r listr values cancelledr ro r5 r6 r7 r r8 time monotonicr
debugr[ r rW r )
r ra r r r r9 r:
msg_update
start_timenext_msgs
r" r zIocpProactor.closek s : F '+4;+=+=+?+?&@&@ C C "CS(}}
CC!233
C CJJLLLL C C Cz-'C),&)# #
0 P:=:OG$6 7
99'BBB C
^%%
*k #4>++++ K !4>#3#3j#@B B B >++j8
JJz " " " k #
DJ'''
s #A88
C8B??Cc . | d S rA )r rZ s r" r zIocpProactor.__del__ s
r# rA )r r$ ) rH rI rJ ry r r r r r r r r r! r' r, r1 rE rS ra r r rr r rq r r
r r@ r[ r r r r r# r" r r s -#+ 2 2 2 29 9 9E E E
5 5 5 5.5 5 5 5.5 5 5 505 5 5 505 5 5 5$5 5 5 5( 8 8 8 8>9 9 9*< < <"0 0 0&= = = = DO O O @& & &
7# 7# 7# 7#r' ' ' - - -^ r# r c e Zd Zd ZdS )r c t j |f|||||d| _ fd} j j t
j j } | | d S )N)r r r r r c d j } | d S rA )_procpoll_process_exited)r
returncoder s r" r z4_WindowsSubprocessTransport._start..callback s. **J , , , , ,r# ) r Popenr r7 rz rr intrP r )
r r r r r r r r r r s
` r" _startz"_WindowsSubprocessTransport._start s "( ' U6&' ' %' '
- - - - -
J 0 0TZ5G1H1H I I H%%%%%r# N)rH rI rJ r r r# r" r r s#
&
&
&
&
&r# r c e Zd ZeZdS )r N)rH rI rJ r
_loop_factoryr r# r" r r %MMMr# r c e Zd ZeZdS )r N)rH rI rJ r r r r# r" r r r r# r )1sysplatform ImportErrorre rW rN rz rY r
r4 r r r r r r r r
r r logr
__all__r ry ERROR_CONNECTION_REFUSEDERROR_CONNECTION_ABORTEDri rm Futurer rN ro rx objectr BaseSelectorEventLoopr BaseProactorEventLoopr r BaseSubprocessTransportr r BaseDefaultEventLoopPolicyr r r r r# r" r su 4
<7
+l
#
##
| - - - - - - - -`G# G# G# G# G#GN G# G# G#T& & & & &- & & &01P 1P 1P 1P 1P- 1P 1P 1Ph8 8 8 8 8 8 8 8v2 2 2 2 2 E 2 2 2g g g g g= g g gT| | | | | | | |~ & & & & &/"I & & & . & & & & &V%F & & && & & & &V%F & & & 8 r#