⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.24
Server IP:
50.6.168.112
Server:
Linux server-617809.webnetzimbabwe.com 5.14.0-570.25.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 9 04:57:09 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.4.10
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib64
/
python3.9
/
asyncio
/
__pycache__
/
View File Name :
selector_events.cpython-39.opt-2.pyc
a ÕDOgLš ã @ s d Z ddlZddlZddlZddlZddlZddlZddlZz ddlZW n e y^ dZY n0 ddl m Z ddl m Z ddl m Z ddl mZ ddl mZ dd l mZ dd l mZ dd l mZ dd lmZ d d„ ZG dd„ de jƒZG dd„ dejejƒZG dd„ deƒZG dd„ deƒZ dS ))ÚBaseSelectorEventLoopé Né )Ú base_events)Ú constants)Úevents)Úfutures)Ú protocols)Ússlproto)Ú transports)Útrsock)Úloggerc C s6 z| |¡}W n ty" Y dS 0 t|j|@ ƒS d S ©NF)Úget_keyÚKeyErrorÚboolr )ÚselectorÚfdÚeventÚkey© r ú//usr/lib64/python3.9/asyncio/selector_events.pyÚ_test_selector_event s r c sŽ e Zd ZdR‡ fdd„ ZdSdddœdd„ZdTddddejdœd d „ZdUd d „Z‡ fd d„Z dd„ Z dd„ Z dd„ Z dd„ Z dd„ Zdddejfdd„Zdddejfd d „Zddejfd d „Zd d!„ Zd"d#„ Zd$d%„ Zd&d'„ Zd(d)„ Zd*d+„ Zd,d-„ Zd.d/„ Zd0d1„ Zd2d3„ ZdVd4d5„Z d6d7„ Z d8d9„ Z d:d;„ Z d<d=„ Z d>d?„ Z!d@dA„ Z"dBdC„ Z#dWdDdE„Z$dFdG„ Z%dHdI„ Z&dJdK„ Z'dLdM„ Z(dNdO„ Z)dPdQ„ Z*‡ Z+S )Xr Nc sF t ƒ ¡ |d u rt ¡ }t d|jj¡ || _| ¡ t ¡ | _ d S )NzUsing selector: %s) ÚsuperÚ__init__Ú selectorsÚDefaultSelectorr ÚdebugÚ __class__Ú__name__Ú _selectorÚ_make_self_pipeÚweakrefÚWeakValueDictionaryÚ _transports)Úselfr ©r r r r 1 s z BaseSelectorEventLoop.__init__©ÚextraÚserverc C s t | |||||ƒS ©N)Ú_SelectorSocketTransport)r$ ÚsockÚprotocolÚwaiterr' r( r r r Ú_make_socket_transport; s ÿz,BaseSelectorEventLoop._make_socket_transportF)Ú server_sideÚserver_hostnamer' r( Ússl_handshake_timeoutc C s0 t j| |||||| d} t| || ||d | jS )N)r1 r& )r Z SSLProtocolr* Z_app_transport) r$ Zrawsockr, Ú sslcontextr- r/ r0 r' r( r1 Z ssl_protocolr r r Ú_make_ssl_transport@ s ýÿz)BaseSelectorEventLoop._make_ssl_transportc C s t | |||||ƒS r) )Ú_SelectorDatagramTransport)r$ r+ r, Úaddressr- r' r r r Ú_make_datagram_transportM s ÿz.BaseSelectorEventLoop._make_datagram_transportc sL | ¡ rtdƒ‚| ¡ r d S | ¡ tƒ ¡ | jd urH| j ¡ d | _d S )Nz!Cannot close a running event loop)Z is_runningÚ RuntimeErrorÚ is_closedÚ_close_self_piper Úcloser ©r$ r% r r r: R s zBaseSelectorEventLoop.closec C sB | | j ¡ ¡ | j ¡ d | _| j ¡ d | _| jd8 _d S )Nr )Ú_remove_readerÚ_ssockÚfilenor: Ú_csockÚ _internal_fdsr; r r r r9 ] s z&BaseSelectorEventLoop._close_self_pipec C sN t ¡ \| _| _| j d¡ | j d¡ | jd7 _| | j ¡ | j¡ d S )NFr ) ÚsocketÚ socketpairr= r? Ú setblockingr@ Ú _add_readerr> Ú_read_from_selfr; r r r r e s z%BaseSelectorEventLoop._make_self_pipec C s d S r) r ©r$ Údatar r r Ú_process_self_datam s z(BaseSelectorEventLoop._process_self_datac C sT z"| j d¡}|sW qP| |¡ W q ty8 Y q Y q tyL Y qPY q 0 q d S )Ni )r= ÚrecvrH ÚInterruptedErrorÚBlockingIOErrorrF r r r rE p s z%BaseSelectorEventLoop._read_from_selfc C sL | j }|d u rd S z| d¡ W n& tyF | jrBtjddd Y n0 d S )Nó z3Fail to write a null byte into the self-pipe socketT©Úexc_info)r? ÚsendÚOSErrorÚ_debugr r )r$ Úcsockr r r Ú_write_to_self| s þz$BaseSelectorEventLoop._write_to_selféd c C s" | | ¡ | j||||||¡ d S r) )rD r> Ú_accept_connection)r$ Úprotocol_factoryr+ r2 r( Úbacklogr1 r r r Ú_start_servingŽ s þz$BaseSelectorEventLoop._start_servingc C s t |ƒD ]ú}z0| ¡ \}} | jr0t d|| |¡ | d¡ W nž tttfyX Y d S t yÚ } zl| j t j t j t j t jfv rÄ| d| t |¡dœ¡ | | ¡ ¡ | tj| j||||||¡ n‚ W Y d } ~ qd } ~ 0 0 d| i} | ||| |||¡} | | ¡ qd S )Nz#%r got a new connection from %r: %rFz&socket.accept() out of system resource)ÚmessageÚ exceptionrA Úpeername)ÚrangeÚacceptrQ r r rC rK rJ ÚConnectionAbortedErrorrP ÚerrnoZEMFILEZENFILEZENOBUFSZENOMEMÚcall_exception_handlerr ÚTransportSocketr< r> Z call_laterr ZACCEPT_RETRY_DELAYrX Ú_accept_connection2Z create_task) r$ rV r+ r2 r( rW r1 Ú_ÚconnÚaddrÚexcr' r] r r r rU • s@ ÿ ÿýý þz(BaseSelectorEventLoop._accept_connectionc à sô d }d }zr|ƒ }| ¡ } |r8| j|||| d|||d}n| j||| ||d}z| I d H W n tyv | ¡ ‚ Y n0 W nt ttfy’ ‚ Y n^ tyî } zF| jrÚd| dœ} |d urÀ|| d< |d urÐ|| d< | | ¡ W Y d } ~ n d } ~ 0 0 d S )NT)r- r/ r' r( r1 )r- r' r( z3Error on transport creation for incoming connection)rY rZ r, Ú transport) Ú create_futurer3 r. Ú BaseExceptionr: Ú SystemExitÚKeyboardInterruptrQ r` ) r$ rV rd r' r2 r( r1 r, rg r- rf Úcontextr r r rb Á s@ ýþ ýz)BaseSelectorEventLoop._accept_connection2c C sŠ |}t |tƒsHzt| ¡ ƒ}W n( tttfyF td|›ƒd ‚Y n0 z| j| }W n tyh Y n 0 | ¡ s†t d|›d|›ƒ‚d S )NzInvalid file object: zFile descriptor z is used by transport ) Ú isinstanceÚintr> ÚAttributeErrorÚ TypeErrorÚ ValueErrorr# r Ú is_closingr7 )r$ r r> rg r r r Ú_ensure_fd_no_transportê s ÿÿz-BaseSelectorEventLoop._ensure_fd_no_transportc G s’ | ¡ t ||| d ¡}z| j |¡}W n( tyP | j |tj|d f¡ Y n>0 |j|j }\}}| j ||tjB ||f¡ |d urŽ| ¡ |S r) ) Ú _check_closedr ÚHandler r r Úregisterr Ú EVENT_READrG ÚmodifyÚcancel© r$ r ÚcallbackÚargsÚhandler ÚmaskÚreaderÚwriterr r r rD ü s ÿ ÿz!BaseSelectorEventLoop._add_readerc C s’ | ¡ r dS z| j |¡}W n ty0 Y dS 0 |j|j }\}}|tj M }|sb| j |¡ n| j ||d |f¡ |d urŠ| ¡ dS dS d S ©NFT) r8 r r r r rG r rw Ú unregisterrx ry ©r$ r r r~ r r€ r r r r< s z$BaseSelectorEventLoop._remove_readerc G s’ | ¡ t ||| d ¡}z| j |¡}W n( tyP | j |tjd |f¡ Y n>0 |j|j }\}}| j ||tjB ||f¡ |d urŽ| ¡ |S r) ) rt r ru r r r rv r Ú EVENT_WRITErG rx ry rz r r r Ú _add_writer! s ÿ ÿz!BaseSelectorEventLoop._add_writerc C s’ | ¡ r dS z| j |¡}W n ty0 Y dS 0 |j|j }\}}|tj M }|sb| j |¡ n| j |||d f¡ |d urŠ| ¡ dS dS d S r ) r8 r r r r rG r r„ r‚ rx ry rƒ r r r Ú_remove_writer1 s z$BaseSelectorEventLoop._remove_writerc G s" | |¡ | j||g|¢R Ž d S r) )rs rD ©r$ r r{ r| r r r Ú add_readerH s z BaseSelectorEventLoop.add_readerc C s | |¡ | |¡S r) )rs r< ©r$ r r r r Ú remove_readerM s z#BaseSelectorEventLoop.remove_readerc G s" | |¡ | j||g|¢R Ž d S r) )rs r… r‡ r r r Ú add_writerR s z BaseSelectorEventLoop.add_writerc C s | |¡ | |¡S r) )rs r† r‰ r r r Ú remove_writerW s z#BaseSelectorEventLoop.remove_writerc à s˜ t |¡ | jr$| ¡ dkr$tdƒ‚z | |¡W S ttfyF Y n0 | ¡ }| ¡ }| |¡ | || j |||¡}| tj| j||d¡ |I d H S ©Nr ú the socket must be non-blocking©r} )r Ú_check_ssl_socketrQ Ú gettimeoutrq rI rK rJ rh r> rs rD Ú _sock_recvÚadd_done_callbackÚ functoolsÚpartialÚ_sock_read_done)r$ r+ ÚnÚfutr r} r r r Ú sock_recv\ s ÿz BaseSelectorEventLoop.sock_recvc C s |d u s| ¡ s| |¡ d S r) )Ú cancelledrŠ ©r$ r r˜ r} r r r r– r s z%BaseSelectorEventLoop._sock_read_donec C s„ | ¡ r d S z| |¡}W nZ ttfy2 Y d S ttfyH ‚ Y n8 tyt } z| |¡ W Y d }~nd }~0 0 | |¡ d S r) ) ÚdonerI rK rJ rj rk ri Ú set_exceptionÚ set_result)r$ r˜ r+ r— rG rf r r r r’ v s z BaseSelectorEventLoop._sock_recvc à s˜ t |¡ | jr$| ¡ dkr$tdƒ‚z | |¡W S ttfyF Y n0 | ¡ }| ¡ }| |¡ | || j |||¡}| tj| j||d¡ |I d H S r )r r rQ r‘ rq Ú recv_intorK rJ rh r> rs rD Ú_sock_recv_intor“ r” r• r– )r$ r+ Úbufr˜ r r} r r r Úsock_recv_into† s ÿz$BaseSelectorEventLoop.sock_recv_intoc C s„ | ¡ r d S z| |¡}W nZ ttfy2 Y d S ttfyH ‚ Y n8 tyt } z| |¡ W Y d }~nd }~0 0 | |¡ d S r) ) rœ rŸ rK rJ rj rk ri r rž )r$ r˜ r+ r¡ Únbytesrf r r r r › s z%BaseSelectorEventLoop._sock_recv_intoc à s¶ t |¡ | jr$| ¡ dkr$tdƒ‚z| |¡}W n ttfyL d}Y n0 |t|ƒkr^d S | ¡ }| ¡ }| |¡ | || j ||t|ƒ|g¡}| tj| j||d¡ |I d H S r )r r rQ r‘ rq rO rK rJ Úlenrh r> rs r… Ú _sock_sendallÚ memoryviewr“ r” r• Ú_sock_write_done)r$ r+ rG r— r˜ r r} r r r Ú sock_sendall¬ s& ÿÿz"BaseSelectorEventLoop.sock_sendallc C s´ | ¡ r d S |d }z| ||d … ¡}W n\ ttfyB Y d S ttfyX ‚ Y n0 ty† } z| |¡ W Y d }~d S d }~0 0 ||7 }|t|ƒkr¨| d ¡ n||d< d S )Nr ) rœ rO rK rJ rj rk ri r r¤ rž )r$ r˜ r+ ÚviewÚposÚstartr— rf r r r r¥ Ë s z#BaseSelectorEventLoop._sock_sendallc à s” t |¡ | jr$| ¡ dkr$tdƒ‚|jtjksBt jrt|jtj krt| j ||j|j |j | dI d H }|d \}}}}}| ¡ }| |||¡ |I d H S )Nr rŽ )ÚfamilyÚtypeÚprotoÚloop)r r rQ r‘ rq r¬ rA ÚAF_INETZ _HAS_IPv6ÚAF_INET6Z_ensure_resolvedr r® rh Ú _sock_connect)r$ r+ r5 Zresolvedrc r˜ r r r Ú sock_connectá s ÿ ÿþ z"BaseSelectorEventLoop.sock_connectc C s´ | ¡ }z| |¡ W nŽ ttfyb | |¡ | || j|||¡}| tj | j ||d¡ Y nN t t fyx ‚ Y n8 t y¤ } z| |¡ W Y d }~nd }~0 0 | d ¡ d S )Nr )r> ÚconnectrK rJ rs r… Ú_sock_connect_cbr“ r” r• r§ rj rk ri r rž )r$ r˜ r+ r5 r r} rf r r r r² ö s ÿÿ z#BaseSelectorEventLoop._sock_connectc C s |d u s| ¡ s| |¡ d S r) )rš rŒ r› r r r r§ s z&BaseSelectorEventLoop._sock_write_donec C s | ¡ r d S z,| tjtj¡}|dkr6t|d|› ƒ‚W nX ttfyN Y nN tt fyd ‚ Y n8 t y } z| |¡ W Y d }~nd }~0 0 | d ¡ d S )Nr zConnect call failed ) rœ Ú getsockoptrA Ú SOL_SOCKETÚSO_ERRORrP rK rJ rj rk ri r rž )r$ r˜ r+ r5 Úerrrf r r r rµ s z&BaseSelectorEventLoop._sock_connect_cbc à sB t |¡ | jr$| ¡ dkr$tdƒ‚| ¡ }| ||¡ |I d H S )Nr rŽ )r r rQ r‘ rq rh Ú _sock_accept)r$ r+ r˜ r r r Ú sock_accept" s z!BaseSelectorEventLoop.sock_acceptc C s | ¡ }z| ¡ \}}| d¡ W nŒ ttfyl | |¡ | || j||¡}| t j | j ||d¡ Y nR t t fy‚ ‚ Y n< ty® } z| |¡ W Y d }~nd }~0 0 | ||f¡ d S )NFr )r> r] rC rK rJ rs rD rº r“ r” r• r– rj rk ri r rž )r$ r˜ r+ r rd r5 r} rf r r r rº 1 s ÿ z"BaseSelectorEventLoop._sock_acceptc à sœ | j |j= | ¡ }| ¡ | ¡ I d H zL| j|j|||ddI d H W | ¡ |rZ| ¡ || j |j< S || j |j< n"| ¡ |rŠ| ¡ || j |j< 0 d S )NF)Úfallback) r# Ú_sock_fdÚ is_readingÚ pause_readingÚ_make_empty_waiterZ sock_sendfileÚ_sockÚ_reset_empty_waiterÚresume_reading)r$ ZtranspÚfileÚoffsetÚcountrà r r r Ú_sendfile_nativeB s* ÿ ú ýz&BaseSelectorEventLoop._sendfile_nativec C s€ |D ]v\}}|j |j }\}}|tj@ rL|d urL|jrB| |¡ n | |¡ |tj@ r|d ur|jrp| |¡ q| |¡ qd S r) ) ÚfileobjrG r rw Z _cancelledr< Z _add_callbackr„ r† )r$ Z event_listr r~ rÈ r r€ r r r Ú_process_eventsP s z%BaseSelectorEventLoop._process_eventsc C s | | ¡ ¡ | ¡ d S r) )r< r> r: )r$ r+ r r r Ú _stop_serving^ s z#BaseSelectorEventLoop._stop_serving)N)N)N)NNN)N)N),r Ú __module__Ú __qualname__r r. r ZSSL_HANDSHAKE_TIMEOUTr3 r6 r: r9 r rH rE rS rX rU rb rs rD r< r… r† rˆ rŠ r‹ rŒ r™ r– r’ r¢ r r¨ r¥ r³ r² r§ rµ r» rº rÇ rÉ rÊ Ú __classcell__r r r% r r + sh ÿ ÿü ÿ þ ý .ý ) r c s’ e Zd ZdZeZdZd ‡ fdd„ Zdd„ Zdd„ Z d d „ Z d d „ Z d d„ Z dd„ Z ejfdd„Zd dd„Zdd„ Zdd„ Zdd„ Zd d „ Z‡ ZS ) Ú_SelectorTransporti Nc sê t ƒ ||¡ t |¡| jd< z| ¡ | jd< W n tyL d | jd< Y n0 d| jvrŠz| ¡ | jd< W n tj yˆ d | jd< Y n0 || _ | ¡ | _ d| _ | |¡ || _| ¡ | _d| _d| _| jd urÚ| j ¡ | |j| j < d S )NrA Zsocknamer[ Fr )r r r ra Ú_extraÚ getsocknamerP Ú getpeernamerA ÚerrorrÁ r> r½ Ú_protocol_connectedÚ set_protocolÚ_serverÚ_buffer_factoryÚ_bufferÚ _conn_lostÚ_closingZ_attachr# )r$ r¯ r+ r, r' r( r% r r r o s, z_SelectorTransport.__init__c C sÖ | j jg}| jd u r | d¡ n| jr0| d¡ | d| j› ¡ | jd urÆ| j ¡ sÆt| jj | jt j ƒ}|rz| d¡ n | d¡ t| jj | jt j ƒ}|r¢d}nd}| ¡ }| d|› d |› d ¡ d d |¡¡S ) NÚclosedÚclosingzfd=z read=pollingz read=idleÚpollingZidlezwrite=<z , bufsize=ú>z<{}>ú )r r rÁ ÚappendrÙ r½ Ú_loopr8 r r r rw r„ Úget_write_buffer_sizeÚformatÚjoin)r$ ÚinforÜ ÚstateÚbufsizer r r Ú__repr__‰ s. ÿ þz_SelectorTransport.__repr__c C s | d ¡ d S r) )Ú _force_closer; r r r Úabort¥ s z_SelectorTransport.abortc C s || _ d| _d S ©NT)Ú _protocolrÓ ©r$ r, r r r rÔ ¨ s z _SelectorTransport.set_protocolc C s | j S r) )rë r; r r r Ú get_protocol¬ s z _SelectorTransport.get_protocolc C s | j S r) )rÙ r; r r r rr ¯ s z _SelectorTransport.is_closingc C sT | j r d S d| _ | j | j¡ | jsP| jd7 _| j | j¡ | j | jd ¡ d S ©NTr ) rÙ rà r< r½ r× rØ r† Ú call_soonÚ_call_connection_lostr; r r r r: ² s z_SelectorTransport.closec C s, | j d ur(|d| ›t| d | j ¡ d S )Nzunclosed transport )Úsource)rÁ ÚResourceWarningr: )r$ Ú_warnr r r Ú__del__¼ s z_SelectorTransport.__del__úFatal error on transportc C sN t |tƒr(| j ¡ r@tjd| |dd n| j ||| | jdœ¡ | |¡ d S )Nz%r: %sTrM )rY rZ rg r, ) rm rP rà Ú get_debugr r r` rë rè )r$ rf rY r r r Ú _fatal_errorÁ s üz _SelectorTransport._fatal_errorc C sd | j r d S | jr(| j ¡ | j | j¡ | jsBd| _| j | j¡ | j d7 _ | j | j |¡ d S rî ) rØ r× Úclearrà r† r½ rÙ r< rï rð ©r$ rf r r r rè Ï s z _SelectorTransport._force_closec C sŽ zN| j r| j |¡ W | j ¡ d | _d | _d | _| j}|d urŠ| ¡ d | _n:| j ¡ d | _d | _d | _| j}|d urˆ| ¡ d | _0 d S r) )rÓ rë Zconnection_lostrÁ r: rà rÕ Z_detach)r$ rf r( r r r rð Û s& ù z(_SelectorTransport._call_connection_lostc C s t | jƒS r) )r¤ r× r; r r r rá é s z(_SelectorTransport.get_write_buffer_sizec G s$ | j r d S | jj||g|¢R Ž d S r) )rÙ rà rD r‡ r r r rD ì s z _SelectorTransport._add_reader)NN)rõ )r rË rÌ Úmax_sizeÚ bytearrayrÖ rÁ r rç ré rÔ rí rr r: ÚwarningsÚwarnrô r÷ rè rð rá rD rÍ r r r% r rÎ c s rÎ c sª e Zd ZdZejjZd#‡ fdd„ Z‡ fdd„Z dd„ Z d d „ Z d d „ Z d d„ Z dd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd „ Z‡ fd d „Zd d „ Zd!d"„ Z‡ ZS )$r* TNc s~ d | _ tƒ |||||¡ d| _d| _d | _t | j¡ | j | j j | ¡ | j | j | j| j¡ |d urz| j tj|d ¡ d S r )Ú_read_ready_cbr r Ú_eofÚ_pausedÚ _empty_waiterr Z _set_nodelayrÁ rà rï rë Úconnection_maderD r½ Ú _read_readyr Ú _set_result_unless_cancelled)r$ r¯ r+ r, r- r' r( r% r r r ø s ÿ ÿz!_SelectorSocketTransport.__init__c s. t |tjƒr| j| _n| j| _tƒ |¡ d S r) )rm r ZBufferedProtocolÚ_read_ready__get_bufferrþ Ú_read_ready__data_receivedr rÔ rì r% r r rÔ s z%_SelectorSocketTransport.set_protocolc C s | j o| j S r) )r rÙ r; r r r r¾ s z#_SelectorSocketTransport.is_readingc C s> | j s | jrd S d| _| j | j¡ | j ¡ r:t d| ¡ d S )NTz%r pauses reading)rÙ r rà r< r½ rö r r r; r r r r¿ s z&_SelectorSocketTransport.pause_readingc C s@ | j s | jsd S d| _| | j| j¡ | j ¡ r<t d| ¡ d S )NFz%r resumes reading) rÙ r rD r½ r rà rö r r r; r r r rà " s z'_SelectorSocketTransport.resume_readingc C s | ¡ d S r) )rþ r; r r r r * s z$_SelectorSocketTransport._read_readyc C sV | j r d S z | j d¡}t|ƒs(tdƒ‚W nH ttfyB ‚ Y n2 tyr } z| |d¡ W Y d }~d S d }~0 0 z| j |¡}W n^ t t fyœ Y d S ttfy² ‚ Y n2 tyâ } z| |d¡ W Y d }~d S d }~0 0 | sö| ¡ d S z| j |¡ W nJ ttfy ‚ Y n2 tyP } z| |d¡ W Y d }~n d }~0 0 d S )Néÿÿÿÿz%get_buffer() returned an empty bufferz/Fatal error: protocol.get_buffer() call failed.ú$Fatal read error on socket transportz3Fatal error: protocol.buffer_updated() call failed.)rØ rë Z get_bufferr¤ r7 rj rk ri r÷ rÁ rŸ rK rJ Ú_read_ready__on_eofZbuffer_updated)r$ r¡ rf r£ r r r r - sB ÿ ÿz0_SelectorSocketTransport._read_ready__get_bufferc C sè | j r d S z| j | j¡}W n^ ttfy4 Y d S ttfyJ ‚ Y n2 tyz } z| |d¡ W Y d }~d S d }~0 0 |sŒ| ¡ d S z| j |¡ W nF ttfy´ ‚ Y n0 tyâ } z| |d¡ W Y d }~n d }~0 0 d S )Nr z2Fatal error: protocol.data_received() call failed.) rØ rÁ rI rú rK rJ rj rk ri r÷ r rë Z data_received)r$ rG rf r r r r R s, ÿz3_SelectorSocketTransport._read_ready__data_receivedc C sŽ | j ¡ rt d| ¡ z| j ¡ }W nH ttfy< ‚ Y n2 tyl } z| |d¡ W Y d }~d S d }~0 0 |r‚| j | j ¡ n| ¡ d S )Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) rà rö r r rë Z eof_receivedrj rk ri r÷ r< r½ r: )r$ Z keep_openrf r r r r k s ÿz,_SelectorSocketTransport._read_ready__on_eofc C s0 t |tttfƒs$tdt|ƒj›ƒ‚| jr2tdƒ‚| j d urDtdƒ‚|sLd S | j rz| j t j krht d¡ | j d7 _ d S | jsz| j |¡}W n\ ttfy¨ Y n^ ttfy¾ ‚ Y nH tyî } z| |d¡ W Y d }~d S d }~0 0 ||d … }|sd S | j | j| j¡ | j |¡ | ¡ d S )Nú/data argument must be a bytes-like object, not z%Cannot call write() after write_eof()z(unable to write; sendfile is in progressú socket.send() raised exception.r ú%Fatal write error on socket transport) rm Úbytesrû r¦ rp r r rÿ r7 r rØ r Ú!LOG_THRESHOLD_FOR_CONNLOST_WRITESr Úwarningr× rÁ rO rK rJ rj rk ri r÷ rà r… r½ Ú _write_readyÚextendÚ_maybe_pause_protocol)r$ rG r— rf r r r Úwrite€ s> ÿ z _SelectorSocketTransport.writec C s | j r d S z| j | j¡}W nˆ ttfy2 Y nà ttfyH ‚ Y nÊ ty¤ } zF| j | j ¡ | j ¡ | |d¡ | jd ur| j |¡ W Y d }~nvd }~0 0 |r¶| jd |…= | ¡ | js| j | j ¡ | jd urê| j d ¡ | jrü| d ¡ n| jr| j tj¡ d S )Nr )rØ rÁ rO r× rK rJ rj rk ri rà r† r½ rø r÷ r r Ú_maybe_resume_protocolrž rÙ rð rÿ ÚshutdownrA ÚSHUT_WR)r$ r— rf r r r r § s2 " z%_SelectorSocketTransport._write_readyc C s. | j s | jrd S d| _| js*| j tj¡ d S rê )rÙ rÿ r× rÁ r rA r r; r r r Ú write_eofÅ s z"_SelectorSocketTransport.write_eofc C s dS rê r r; r r r Ú can_write_eofÌ s z&_SelectorSocketTransport.can_write_eofc s* t ƒ |¡ | jd ur&| j tdƒ¡ d S )Nz Connection is closed by peer)r rð r r ÚConnectionErrorrù r% r r rð Ï s ÿz._SelectorSocketTransport._call_connection_lostc C s6 | j d urtdƒ‚| j ¡ | _ | js0| j d ¡ | j S )NzEmpty waiter is already set)r r7 rà rh r× rž r; r r r rÀ Õ s z+_SelectorSocketTransport._make_empty_waiterc C s d | _ d S r) )r r; r r r rÂ Ý s z,_SelectorSocketTransport._reset_empty_waiter)NNN)r rË rÌ Z_start_tls_compatibler Z _SendfileModeZ TRY_NATIVEZ_sendfile_compatibler rÔ r¾ r¿ rà r r r r r r r r rð rÀ r rÍ r r r% r r* ó s( ÿ %' r* c sF e Zd ZejZd ‡ fdd„ Zdd„ Zdd„ Zd dd „Z d d „ Z ‡ Z S )r4 Nc s^ t ƒ ||||¡ || _| j | jj| ¡ | j | j| j| j ¡ |d urZ| j t j |d ¡ d S r) ) r r Ú_addressrà rï rë r rD r½ r r r )r$ r¯ r+ r, r5 r- r' r% r r r å s ÿ ÿz#_SelectorDatagramTransport.__init__c C s t dd„ | jD ƒƒS )Nc s s | ]\}}t |ƒV qd S r) )r¤ )Ú.0rG rc r r r Ú <genexpr>ó ó zC_SelectorDatagramTransport.get_write_buffer_size.<locals>.<genexpr>)Úsumr× r; r r r rá ò s z0_SelectorDatagramTransport.get_write_buffer_sizec C s¼ | j r d S z| j | j¡\}}W nˆ ttfy6 Y n‚ tyd } z| j |¡ W Y d }~n\d }~0 t t fyz ‚ Y n> t y¨ } z| |d¡ W Y d }~nd }~0 0 | j ||¡ d S )Nz&Fatal read error on datagram transport)rØ rÁ Úrecvfromrú rK rJ rP rë Úerror_receivedrj rk ri r÷ Zdatagram_received©r$ rG re rf r r r r õ s "z&_SelectorDatagramTransport._read_readyc C s„ t |tttfƒs$tdt|ƒj›ƒ‚|s,d S | jrV|d | jfvrPtd| j› ƒ‚| j}| j rŠ| jrŠ| j t j krxt d¡ | j d7 _ d S | jsdz,| jd r¬| j |¡ n| j ||¡ W d S ttfyæ | j | j| j¡ Y n~ ty } z| j |¡ W Y d }~d S d }~0 t t fy0 ‚ Y n4 t yb } z| |d¡ W Y d }~d S d }~0 0 | j t|ƒ|f¡ | !¡ d S )Nr z!Invalid address: must be None or r r r[ ú'Fatal write error on datagram transport)"rm r rû r¦ rp r r r rq rØ r r r r r× rÏ rÁ rO ÚsendtorK rJ rà r… r½ Ú _sendto_readyrP rë r rj rk ri r÷ rß r r! r r r r# sJ ÿ ÿ ÿz!_SelectorDatagramTransport.sendtoc C s | j râ| j ¡ \}}z*| jd r.| j |¡ n| j ||¡ W q ttfyh | j ||f¡ Y qâY q t y˜ } z| j |¡ W Y d }~d S d }~0 t t fy® ‚ Y q tyÞ } z| |d¡ W Y d }~d S d }~0 0 q | ¡ | j s| j | j¡ | jr| d ¡ d S )Nr[ r" )r× ÚpopleftrÏ rÁ rO r# rK rJ Ú appendleftrP rë r rj rk ri r÷ r rà r† r½ rÙ rð r! r r r r$ 0 s0 ÿz(_SelectorDatagramTransport._sendto_ready)NNN)N) r rË rÌ Ú collectionsÚdequerÖ r rá r r# r$ rÍ r r r% r r4 á s ÿ +r4 ) Ú__all__r' r_ r” r rA rü r! ZsslÚ ImportErrorÚ r r r r r r r r Úlogr r Z BaseEventLoopr Z_FlowControlMixinZ TransportrÎ r* r4 r r r r Ú<module> sB <ÿ o