⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.103
Server IP:
45.79.8.107
Server:
Linux localhost 5.15.0-161-generic #171-Ubuntu SMP Sat Oct 11 08:17:01 UTC 2025 x86_64
Server Software:
nginx/1.18.0
PHP Version:
8.1.2-1ubuntu2.22
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.10
/
asyncio
/
__pycache__
/
View File Name :
windows_events.cpython-310.pyc
o ir @ s d Z ddlZejdkredddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZ ddl mZ ddl mZ dd l mZ dd l mZ dd l mZ dd l mZ dd l mZ ddlmZ dZdZdZdZdZ dZ dZ G dd dej Z G dd dej Z!G dd de!Z"G dd d e!Z#G d d d e$Z%G d d d ej&Z'G d!d" d"ej(Z)G d#d$ d$Z*G d%d& d&ej+Z,e'Z-G d'd( d(ej.Z/G d)d* d*ej.Z0e0Z1dS )+z.Selector and proactor event loops for Windows. Nwin32z win32 only )events)base_subprocess)futures) exceptions)proactor_events)selector_events)tasks) windows_utils)logger)SelectorEventLoopProactorEventLoop IocpProactorDefaultEventLoopPolicy WindowsSelectorEventLoopPolicy WindowsProactorEventLoopPolicy i i gMbP?g?c s` e Zd ZdZdd fdd Z fddZdd Zd fd d Z fd d Z fddZ Z S )_OverlappedFuturezSubclass of Future which represents an overlapped operation. Cancelling it will immediately cancel the overlapped operation. Nloopc s& t j|d | jr| jd= || _d S Nr )super__init___source_traceback_ov)selfovr __class__ -/usr/lib/python3.10/asyncio/windows_events.pyr 6 s z_OverlappedFuture.__init__c sH t }| jd ur"| jjrdnd}|dd| d| jjdd |S )Npending completedr z overlapped=<z, #x>)r _repr_infor r# insertaddressr infostater r! r" r' < s z _OverlappedFuture._repr_infoc C st | j d u rd S z| j W n& ty4 } zd|| d}| jr$| j|d< | j| W Y d }~nd }~ww d | _ d S )Nz&Cancelling an overlapped future failedmessage exceptionfuturesource_traceback)r cancelOSErrorr _loopcall_exception_handler)r exccontextr! r! r" _cancel_overlappedC s z$_OverlappedFuture._cancel_overlappedc | t j|dS N)msg)r8 r r2 r r; r r! r" r2 S z_OverlappedFuture.cancelc s t | | d S N)r set_exceptionr8 r r/ r r! r" r? W s z _OverlappedFuture.set_exceptionc s t | d | _d S r> )r set_resultr r resultr r! r" rA [ s z _OverlappedFuture.set_resultr> ) __name__ __module__ __qualname____doc__r r' r8 r2 r? rA __classcell__r! r! r r" r 0 s r c sp e Zd ZdZdd fdd Zdd Z fdd Zd d Zd d Zd fdd Z fddZ fddZ Z S )_BaseWaitHandleFuturez2Subclass of Future which represents a wait handle.Nr c s8 t j|d | jr| jd= || _|| _|| _d| _d S )Nr r T)r r r r _handle _wait_handle _registered)r r handle wait_handler r r! r" r c s z _BaseWaitHandleFuture.__init__c C s t | jdt jkS Nr )_winapiWaitForSingleObjectrJ WAIT_OBJECT_0r r! r! r" _pollq s z_BaseWaitHandleFuture._pollc sd t }|d| jd | jd ur!| rdnd}|| | jd ur0|d| jd |S )Nzhandle=r% signaledwaitingz wait_handle=)r r' appendrJ rT rK r* r r! r" r' v s z _BaseWaitHandleFuture._repr_infoc C s d | _ d S r> )r r futr! r! r" _unregister_wait_cb s z)_BaseWaitHandleFuture._unregister_wait_cbc C s | j sd S d| _ | j}d | _zt| W n3 tyH } z'|jtjkr>d|| d}| jr1| j|d< | j | W Y d }~d S W Y d }~nd }~ww | d d S NFz$Failed to unregister the wait handler- r1 ) rL rK _overlappedUnregisterWaitr3 winerrorERROR_IO_PENDINGr r4 r5 rZ r rN r6 r7 r! r! r" _unregister_wait s* z&_BaseWaitHandleFuture._unregister_waitc r9 r: )ra r r2 r< r r! r" r2 r= z _BaseWaitHandleFuture.cancelc | t | d S r> )ra r r? r@ r r! r" r? z#_BaseWaitHandleFuture.set_exceptionc rb r> )ra r rA rB r r! r" rA rc z _BaseWaitHandleFuture.set_resultr> ) rD rE rF rG r rT r' rZ ra r2 r? rA rH r! r! r r" rI ` s rI c sF e Zd ZdZdd fdd Zdd Z fdd Z fd d Z ZS ) _WaitCancelFuturezoSubclass of Future which represents a wait for the cancellation of a _WaitHandleFuture using an event. Nr c s t j||||d d | _d S )Nr )r r _done_callback)r r eventrN r r r! r" r s z_WaitCancelFuture.__init__c C s t d)Nz'_WaitCancelFuture must not be cancelled) RuntimeErrorrS r! r! r" r2 s z_WaitCancelFuture.cancelc ( t | | jd ur| | d S d S r> )r rA re rB r r! r" rA z _WaitCancelFuture.set_resultc rh r> )r r? re r@ r r! r" r? ri z _WaitCancelFuture.set_exception) rD rE rF rG r r2 rA r? rH r! r! r r" rd s rd c s6 e Zd Zdd fdd Z fddZdd Z ZS ) _WaitHandleFutureNr c s< t j||||d || _d| _td ddd | _d | _d S )Nr TF)r r _proactor_unregister_proactorr\ CreateEvent_event _event_fut)r r rM rN proactorr r r! r" r s z_WaitHandleFuture.__init__c sF | j d urt| j d | _ d | _| j| j d | _t | d S r> ) rn rP CloseHandlero rk _unregisterr r rZ rX r r! r" rZ s z%_WaitHandleFuture._unregister_wait_cbc C s | j sd S d| _ | j}d | _z t|| j W n3 tyJ } z'|jtjkr@d|| d}| jr3| j|d< | j | W Y d }~d S W Y d }~nd }~ww | j | j| j | _d S r[ )rL rK r\ UnregisterWaitExrn r3 r^ r_ r r4 r5 rk _wait_cancelrZ ro r` r! r! r" ra s. z"_WaitHandleFuture._unregister_wait)rD rE rF r rZ ra rH r! r! r r" rj s rj c @ s< e Zd ZdZdd Zdd Zdd Zdd Zd d ZeZ d S ) PipeServerzXClass representing a pipe server. This is much like a bound, listening socket. c C s, || _ t | _d | _d | _| d| _d S NT)_addressweakrefWeakSet_free_instances_pipe_accept_pipe_future_server_pipe_handle)r r) r! r! r" r s zPipeServer.__init__c C s | j | d}| _ |S )NF)r{ r} )r tmpr! r! r" _get_unconnected_pipe s z PipeServer._get_unconnected_pipec C sr | rd S tjtjB }|r|tjO }t| j|tjtjB tj B tj t j t j tj tj}t |}| j| |S r> )closedrP PIPE_ACCESS_DUPLEXFILE_FLAG_OVERLAPPED FILE_FLAG_FIRST_PIPE_INSTANCECreateNamedPiperw PIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITPIPE_UNLIMITED_INSTANCESr BUFSIZENMPWAIT_WAIT_FOREVERNULL PipeHandlerz add)r firstflagshpiper! r! r" r} s" z PipeServer._server_pipe_handlec C s | j d u S r> )rw rS r! r! r" r zPipeServer.closedc C sV | j d ur | j d | _ | jd ur)| jD ]}| qd | _d | _| j d S d S r> )r| r2 rw rz closer{ clear)r r r! r! r" r " s zPipeServer.closeN) rD rE rF rG r r r} r r __del__r! r! r! r" ru s ru c @ s e Zd ZdZdS )_WindowsSelectorEventLoopz'Windows version of selector event loop.N)rD rE rF rG r! r! r! r" r 1 r c sJ e Zd ZdZd fdd Z fddZdd Zd d Z d d d Z Z S )r z2Windows version of proactor event loop using IOCP.Nc s |d u rt }t | d S r> )r r r )r rp r r! r" r 8 s zProactorEventLoop.__init__c s z2| j d u sJ | | j t W | j d ur1| j j}| j |d ur,| j| d | _ d S d S | j d urN| j j}| j |d urK| j| d | _ w r> ) _self_reading_future call_soon_loop_self_readingr run_foreverr r2 rk rr r r r r! r" r = s z ProactorEventLoop.run_foreverc s: | j |}|I d H }| }| j||d|id}||fS )Naddrextra)rk connect_pipe_make_duplex_pipe_transport)r protocol_factoryr) fr protocoltransr! r! r" create_pipe_connectionP s z(ProactorEventLoop.create_pipe_connectionc s0 t d fdd gS )Nc sT d }z7| r'| }j| r| W d S }j||d id }|d u r2W d S j|} W nf t yT |rL| dkrL| Y d S t y } z-|rq| dkrq d||d | n jr|tjd|dd W Y d }~d S d }~w tjy |r| Y d S Y d S w | _| d S ) Nr r r zPipe accept failed)r. r/ r z Accept pipe failed on pipe %rT)exc_info)rC rz discardr r r r rk accept_pipeBrokenPipeErrorfilenor r3 r5 _debugr warningr CancelledErrorr| add_done_callback)r r r r6 r) loop_accept_piper r serverr! r" r [ sR z>ProactorEventLoop.start_serving_pipe.<locals>.loop_accept_piper> )ru r )r r r) r! r r" start_serving_pipeX s -z$ProactorEventLoop.start_serving_pipec sx | } t| |||||||f| |d| } z| I d H W | S ttfy) ty; | | I d H w )N)waiterr ) create_future_WindowsSubprocessTransport SystemExitKeyboardInterrupt BaseExceptionr _wait) r r argsshellstdinstdoutstderrbufsizer kwargsr transpr! r! r" _make_subprocess_transport s& z,ProactorEventLoop._make_subprocess_transportr> ) rD rE rF rG r r r r r rH r! r! r r" r 5 s 5r c @ s e Zd ZdZd;ddZdd Zdd Zd d Zd<d d Zdd Z d=ddZ d=ddZ d=ddZ d>ddZ d=ddZdd Zd d Zd d Zd!d" Zd#d$ Zd<d%d&Zd'd( Zd)d* Zd+d, Zd-d. Zd/d0 Zd1d2 Zd<d3d4Zd5d6 Z d7d8 Z d9d: Z d S )?r z#Proactor implementation using IOCP.r c C sD d | _ g | _ttjtd|| _i | _t | _ g | _ t | _ d S rO ) r4 _resultsr\ CreateIoCompletionPortINVALID_HANDLE_VALUEr _iocp_cacherx ry rL _unregistered_stopped_serving)r concurrencyr! r! r" r s zIocpProactor.__init__c C s | j d u r tdd S )NzIocpProactor is closed)r rg rS r! r! r" _check_closed s zIocpProactor._check_closedc C sF dt | j dt | j g}| jd u r|d d| jjd|f S )Nzoverlapped#=%sz result#=%sr z<%s %s> )lenr r r rW r rD join)r r+ r! r! r" __repr__ s zIocpProactor.__repr__c C s || _ d S r> )r4 )r r r! r! r" set_loop r zIocpProactor.set_loopNc C s. | j s| | | j }g | _ z|W d }S d }w r> )r rT )r timeoutr~ r! r! r" select s zIocpProactor.selectc C s | j }|| |S r> )r4 r rA )r valuerY r! r! r" _result zIocpProactor._resultr c C | | | tt}zt|tjr|| || n|| | W n t y2 | d Y S w dd }| |||S )N c S B z| W S ty } z|jtjtjfv rt|j d }~ww r> getresultr3 r^ r\ ERROR_NETNAME_DELETEDERROR_OPERATION_ABORTEDConnectionResetErrorr r keyr r6 r! r! r" finish_recv z&IocpProactor.recv.<locals>.finish_recv) _register_with_iocpr\ Overlappedr isinstancesocketWSARecvr ReadFiler r _registerr connnbytesr r r r! r! r" recv zIocpProactor.recvc C r )Nr c S r r> r r r! r! r" r r z+IocpProactor.recv_into.<locals>.finish_recv) r r\ r r r r WSARecvIntor ReadFileIntor r r )r r bufr r r r! r! r" recv_into r zIocpProactor.recv_intoc C s^ | | tt}z || || W n ty# | d Y S w dd }| |||S )N)r Nc S r r> r r r! r! r" r r z*IocpProactor.recvfrom.<locals>.finish_recv) r r\ r r WSARecvFromr r r r r r! r! r" recvfrom s zIocpProactor.recvfromc C s> | | tt}|| ||| dd }| |||S )Nc S r r> r r r! r! r" finish_send r z(IocpProactor.sendto.<locals>.finish_send)r r\ r r WSASendTor r )r r r r r r r r! r! r" sendto s zIocpProactor.sendtoc C sZ | | tt}t|tjr|| || n|| | dd }| |||S )Nc S r r> r r r! r! r" r & r z&IocpProactor.send.<locals>.finish_send) r r\ r r r r WSASendr WriteFiler )r r r r r r r! r! r" send s zIocpProactor.sendc sv | | j tt}| fdd}dd }| ||}|| }t j || j d |S )Nc sD | td } tjtj| fS )Nz@P) r structpackr setsockoptr SOL_SOCKETr\ SO_UPDATE_ACCEPT_CONTEXT settimeout gettimeout getpeername)r r r r r listenerr! r" finish_accept8 s z*IocpProactor.accept.<locals>.finish_acceptc s. z| I d H W d S t jy | w r> )r r r )r0 r r! r! r" accept_coroA s z(IocpProactor.accept.<locals>.accept_coror ) r _get_accept_socketfamilyr\ r r AcceptExr r r ensure_futurer4 )r r r r r r0 coror! r r" accept2 s zIocpProactor.acceptc s j tjkrt | | j }|d |S | z t j W n" t yL } z|j tjkr9 d dkrB W Y d }~nd }~ww tt}| | fdd}| | |S )Nr r c s | tjtjd S rO )r r r r r\ SO_UPDATE_CONNECT_CONTEXTr r r r r! r" finish_connectd s z,IocpProactor.connect.<locals>.finish_connect)typer SOCK_DGRAMr\ WSAConnectr r4 r rA r BindLocalr r3 r^ errno WSAEINVAL getsocknamer r ConnectExr )r r r) rY er r r! r r" connectN s( zIocpProactor.connectc C sb | | tt}|d@ }|d? d@ }|| t| |||dd dd }| |||S )Nr r c S r r> r r r! r! r" finish_sendfilew r z.IocpProactor.sendfile.<locals>.finish_sendfile) r r\ r r TransmitFiler msvcrt get_osfhandler ) r sockfileoffsetcountr offset_low offset_highr r! r! r" sendfilem s zIocpProactor.sendfilec sJ | tt}| }|r| S fdd}| | |S )Nc s | S r> )r r r r! r" finish_accept_pipe s z4IocpProactor.accept_pipe.<locals>.finish_accept_pipe)r r\ r r ConnectNamedPiper r r )r r r connectedr( r! r' r" r s zIocpProactor.accept_pipec st t } zt|}W n) ty$ } z |jtjkr W Y d }~nd }~ww t|d t}t |I d H qt |S )NT ) CONNECT_PIPE_INIT_DELAYr\ ConnectPiper3 r^ ERROR_PIPE_BUSYminCONNECT_PIPE_MAX_DELAYr sleepr r )r r) delayrM r6 r! r! r" r s zIocpProactor.connect_pipec C s | ||dS )zWait for a handle. Return a Future object. The result of the future is True if the wait completed, or False if the wait did not complete (on timeout). F)_wait_for_handle)r rM r r! r! r" wait_for_handle s z IocpProactor.wait_for_handlec C s | |d d}||_|S rv )r3 re )r rf done_callbackrY r! r! r" rt s zIocpProactor._wait_cancelc s | |d u r tj}nt|d }tt}t|| j |j |}|r.t |||| j d n t |||| | j d jr? jd= fdd} |d|f| j|j < S )N @@r r c s S r> )rT r r r! r" finish_wait_for_handle s z=IocpProactor._wait_for_handle.<locals>.finish_wait_for_handler )r rP INFINITEmathceilr\ r r RegisterWaitWithQueuer r) rd r4 rj r r )r rM r _is_cancelmsr rN r8 r! r7 r" r3 s$ z IocpProactor._wait_for_handlec C s4 || j vr| j | t| | jdd d S d S rO )rL r r\ r r r r objr! r! r" r s z IocpProactor._register_with_iocpc C s | t|| jd}|jr|jd= |js:z|d d |}W n ty4 } z || W Y d }~n d }~ww || ||||f| j|j < |S r ) r r r4 r r# r3 r? rA r r) )r r r@ callbackr r r r! r! r" r s zIocpProactor._registerc C s | | j| dS )a Unregister an overlapped object. Call this method when its future has been cancelled. The event can already be signalled (pending in the proactor event queue). It is also safe if the event is never signalled (because it was cancelled). N)r r rW r r! r! r" rr s zIocpProactor._unregisterc C s t |}|d |S rO )r r )r r sr! r! r" r r z IocpProactor._get_accept_socketc C s |d u rt }n|dk rtdt|d }|t kr td t| j|}|d u r+nd}|\}}}}z | j|\}} } } W n) t yh | j rZ| j dd||||f d |dtj fvrft| Y q w | | jv rs| n=| sz5z| ||| } W n ty } z|| | j| W Y d } ~ nd } ~ ww || | j| W d }nd }w q | jD ] } | j| jd q| j d S ) Nr znegative timeoutr6 ztimeout too bigTz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r. status)r9 ValueErrorr: r; r\ GetQueuedCompletionStatusr r popKeyErrorr4 get_debugr5 r rP rq r r2 doner3 r? r rW rA r r) r )r r r> rC err transferredr r) r r r@ rA r r r! r! r" rT sZ )zIocpProactor._pollc C s | j | d S r> )r r r? r! r! r" _stop_servingI s zIocpProactor._stop_servingc C s | j d u rd S t| j D ]D\}\}}}}| rqt|tr!qz| W q tyR } z | j d urHd||d}|j rB|j |d< | j | W Y d }~qd }~ww d}t } | | } | jr| t krwtd| t | t | } | | | js`g | _t| j d | _ d S )NzCancelling a future failedr- r1 g ?z,%r is running after closing for %.1f seconds)r listr items cancelledr rd r2 r3 r4 r r5 time monotonicr debugrT r rP rq ) r r) rY r r@ rA r6 r7 msg_update start_timenext_msgr! r! r" r O sD zIocpProactor.closec C s | d S r> )r rS r! r! r" r ~ s zIocpProactor.__del__)r r> )r )r N) rD rE rF rG r r r r r r r r r r r r r r& r r r4 rt r3 r r rr r rT rL r r r! r! r! r" r s: " 9 /r c @ s e Zd Zdd ZdS )r c sP t j|f|||||d| _ fdd} jjt jj} | | d S )N)r r r r r c s j } | d S r> )_procpoll_process_exited)r returncoderS r! r" rA s z4_WindowsSubprocessTransport._start.<locals>.callback) r PopenrV r4 rk r4 intrJ r ) r r r r r r r r rA r r! rS r" _start s z"_WindowsSubprocessTransport._startN)rD rE rF r\ r! r! r! r" r s r c @ e Zd ZeZdS )r N)rD rE rF r _loop_factoryr! r! r! r" r r r c @ r] )r N)rD rE rF r r^ r! r! r! r" r r r )2rG sysplatform ImportErrorr\ rP r r: r r r rP rx r r r r r r r r logr __all__r r9 ERROR_CONNECTION_REFUSEDERROR_CONNECTION_ABORTEDr, r0 Futurer rI rd rj objectru BaseSelectorEventLoopr BaseProactorEventLoopr r BaseSubprocessTransportr r BaseDefaultEventLoopPolicyr r r r! r! r! r" <module> sZ 0J4;j f