//usr/lib64/python3.9/asyncio/__pycache__
90 items
NAME ↑ SIZE MODIFIED PERMS ACTIONS
.. / Parent Directory
__init__.cpython-39.opt-1.pyc — 781 B
2026-04-27 17:40 · rw-r--r--
781 B 2026-04-27 17:40 rw-r--r--
__init__.cpython-39.opt-2.pyc — 725 B
2026-04-27 17:40 · rw-r--r--
725 B 2026-04-27 17:40 rw-r--r--
__init__.cpython-39.pyc — 781 B
2026-04-27 17:40 · rw-r--r--
781 B 2026-04-27 17:40 rw-r--r--
__main__.cpython-39.opt-1.pyc — 3.14 KB
2026-04-27 17:40 · rw-r--r--
3.14 KB 2026-04-27 17:40 rw-r--r--
__main__.cpython-39.opt-2.pyc — 3.14 KB
2026-04-27 17:40 · rw-r--r--
3.14 KB 2026-04-27 17:40 rw-r--r--
__main__.cpython-39.pyc — 3.14 KB
2026-04-27 17:40 · rw-r--r--
3.14 KB 2026-04-27 17:40 rw-r--r--
base_events.cpython-39.opt-1.pyc — 50.95 KB
2026-04-27 17:40 · rw-r--r--
50.95 KB 2026-04-27 17:40 rw-r--r--
base_events.cpython-39.opt-2.pyc — 42.14 KB
2026-04-27 17:40 · rw-r--r--
42.14 KB 2026-04-27 17:40 rw-r--r--
base_events.cpython-39.pyc — 51.07 KB
2026-04-27 17:40 · rw-r--r--
51.07 KB 2026-04-27 17:40 rw-r--r--
base_futures.cpython-39.opt-1.pyc — 1.87 KB
2026-04-27 17:40 · rw-r--r--
1.87 KB 2026-04-27 17:40 rw-r--r--
base_futures.cpython-39.opt-2.pyc — 1.62 KB
2026-04-27 17:40 · rw-r--r--
1.62 KB 2026-04-27 17:40 rw-r--r--
base_futures.cpython-39.pyc — 1.87 KB
2026-04-27 17:40 · rw-r--r--
1.87 KB 2026-04-27 17:40 rw-r--r--
base_subprocess.cpython-39.opt-1.pyc — 9.12 KB
2026-04-27 17:40 · rw-r--r--
9.12 KB 2026-04-27 17:40 rw-r--r--
base_subprocess.cpython-39.opt-2.pyc — 9.03 KB
2026-04-27 17:40 · rw-r--r--
9.03 KB 2026-04-27 17:40 rw-r--r--
base_subprocess.cpython-39.pyc — 9.19 KB
2026-04-27 17:40 · rw-r--r--
9.19 KB 2026-04-27 17:40 rw-r--r--
base_tasks.cpython-39.opt-1.pyc — 1.9 KB
2026-04-27 17:40 · rw-r--r--
1.9 KB 2026-04-27 17:40 rw-r--r--
base_tasks.cpython-39.opt-2.pyc — 1.9 KB
2026-04-27 17:40 · rw-r--r--
1.9 KB 2026-04-27 17:40 rw-r--r--
base_tasks.cpython-39.pyc — 1.9 KB
2026-04-27 17:40 · rw-r--r--
1.9 KB 2026-04-27 17:40 rw-r--r--
constants.cpython-39.opt-1.pyc — 583 B
2026-04-27 17:40 · rw-r--r--
583 B 2026-04-27 17:40 rw-r--r--
constants.cpython-39.opt-2.pyc — 583 B
2026-04-27 17:40 · rw-r--r--
583 B 2026-04-27 17:40 rw-r--r--
constants.cpython-39.pyc — 583 B
2026-04-27 17:40 · rw-r--r--
583 B 2026-04-27 17:40 rw-r--r--
coroutines.cpython-39.opt-1.pyc — 6.42 KB
2026-04-27 17:40 · rw-r--r--
6.42 KB 2026-04-27 17:40 rw-r--r--
coroutines.cpython-39.opt-2.pyc — 6.19 KB
2026-04-27 17:40 · rw-r--r--
6.19 KB 2026-04-27 17:40 rw-r--r--
coroutines.cpython-39.pyc — 6.48 KB
2026-04-27 17:40 · rw-r--r--
6.48 KB 2026-04-27 17:40 rw-r--r--
events.cpython-39.opt-1.pyc — 27.42 KB
2026-04-27 17:40 · rw-r--r--
27.42 KB 2026-04-27 17:40 rw-r--r--
events.cpython-39.opt-2.pyc — 18.54 KB
2026-04-27 17:40 · rw-r--r--
18.54 KB 2026-04-27 17:40 rw-r--r--
events.cpython-39.pyc — 27.5 KB
2026-04-27 17:40 · rw-r--r--
27.5 KB 2026-04-27 17:40 rw-r--r--
exceptions.cpython-39.opt-1.pyc — 2.5 KB
2026-04-27 17:40 · rw-r--r--
2.5 KB 2026-04-27 17:40 rw-r--r--
exceptions.cpython-39.opt-2.pyc — 1.87 KB
2026-04-27 17:40 · rw-r--r--
1.87 KB 2026-04-27 17:40 rw-r--r--
exceptions.cpython-39.pyc — 2.5 KB
2026-04-27 17:40 · rw-r--r--
2.5 KB 2026-04-27 17:40 rw-r--r--
format_helpers.cpython-39.opt-1.pyc — 2.27 KB
2026-04-27 17:40 · rw-r--r--
2.27 KB 2026-04-27 17:40 rw-r--r--
format_helpers.cpython-39.opt-2.pyc — 2.03 KB
2026-04-27 17:40 · rw-r--r--
2.03 KB 2026-04-27 17:40 rw-r--r--
format_helpers.cpython-39.pyc — 2.27 KB
2026-04-27 17:40 · rw-r--r--
2.27 KB 2026-04-27 17:40 rw-r--r--
futures.cpython-39.opt-1.pyc — 11.35 KB
2026-04-27 17:40 · rw-r--r--
11.35 KB 2026-04-27 17:40 rw-r--r--
futures.cpython-39.opt-2.pyc — 7.93 KB
2026-04-27 17:40 · rw-r--r--
7.93 KB 2026-04-27 17:40 rw-r--r--
futures.cpython-39.pyc — 11.5 KB
2026-04-27 17:40 · rw-r--r--
11.5 KB 2026-04-27 17:40 rw-r--r--
locks.cpython-39.opt-1.pyc — 14.13 KB
2026-04-27 17:40 · rw-r--r--
14.13 KB 2026-04-27 17:40 rw-r--r--
locks.cpython-39.opt-2.pyc — 8.04 KB
2026-04-27 17:40 · rw-r--r--
8.04 KB 2026-04-27 17:40 rw-r--r--
locks.cpython-39.pyc — 14.13 KB
2026-04-27 17:40 · rw-r--r--
14.13 KB 2026-04-27 17:40 rw-r--r--
log.cpython-39.opt-1.pyc — 228 B
2026-04-27 17:40 · rw-r--r--
228 B 2026-04-27 17:40 rw-r--r--
log.cpython-39.opt-2.pyc — 189 B
2026-04-27 17:40 · rw-r--r--
189 B 2026-04-27 17:40 rw-r--r--
log.cpython-39.pyc — 228 B
2026-04-27 17:40 · rw-r--r--
228 B 2026-04-27 17:40 rw-r--r--
proactor_events.cpython-39.opt-1.pyc — 23.62 KB
2026-04-27 17:40 · rw-r--r--
23.62 KB 2026-04-27 17:40 rw-r--r--
proactor_events.cpython-39.opt-2.pyc — 23.23 KB
2026-04-27 17:40 · rw-r--r--
23.23 KB 2026-04-27 17:40 rw-r--r--
proactor_events.cpython-39.pyc — 23.84 KB
2026-04-27 17:40 · rw-r--r--
23.84 KB 2026-04-27 17:40 rw-r--r--
protocols.cpython-39.opt-1.pyc — 8.24 KB
2026-04-27 17:40 · rw-r--r--
8.24 KB 2026-04-27 17:40 rw-r--r--
protocols.cpython-39.opt-2.pyc — 3.28 KB
2026-04-27 17:40 · rw-r--r--
3.28 KB 2026-04-27 17:40 rw-r--r--
protocols.cpython-39.pyc — 8.24 KB
2026-04-27 17:40 · rw-r--r--
8.24 KB 2026-04-27 17:40 rw-r--r--
queues.cpython-39.opt-1.pyc — 8.27 KB
2026-04-27 17:40 · rw-r--r--
8.27 KB 2026-04-27 17:40 rw-r--r--
queues.cpython-39.opt-2.pyc — 5.65 KB
2026-04-27 17:40 · rw-r--r--
5.65 KB 2026-04-27 17:40 rw-r--r--
queues.cpython-39.pyc — 8.27 KB
2026-04-27 17:40 · rw-r--r--
8.27 KB 2026-04-27 17:40 rw-r--r--
runners.cpython-39.opt-1.pyc — 2.16 KB
2026-04-27 17:40 · rw-r--r--
2.16 KB 2026-04-27 17:40 rw-r--r--
runners.cpython-39.opt-2.pyc — 1.49 KB
2026-04-27 17:40 · rw-r--r--
1.49 KB 2026-04-27 17:40 rw-r--r--
runners.cpython-39.pyc — 2.16 KB
2026-04-27 17:40 · rw-r--r--
2.16 KB 2026-04-27 17:40 rw-r--r--
selector_events.cpython-39.opt-1.pyc — 28.98 KB
2026-04-27 17:40 · rw-r--r--
28.98 KB 2026-04-27 17:40 rw-r--r--
selector_events.cpython-39.opt-2.pyc — 27.37 KB
2026-04-27 17:40 · rw-r--r--
27.37 KB 2026-04-27 17:40 rw-r--r--
selector_events.cpython-39.pyc — 29.02 KB
2026-04-27 17:40 · rw-r--r--
29.02 KB 2026-04-27 17:40 rw-r--r--
sslproto.cpython-39.opt-1.pyc — 21.21 KB
2026-04-27 17:40 · rw-r--r--
21.21 KB 2026-04-27 17:40 rw-r--r--
sslproto.cpython-39.opt-2.pyc — 14.43 KB
2026-04-27 17:40 · rw-r--r--
14.43 KB 2026-04-27 17:40 rw-r--r--
sslproto.cpython-39.pyc — 21.38 KB
2026-04-27 17:40 · rw-r--r--
21.38 KB 2026-04-27 17:40 rw-r--r--
staggered.cpython-39.opt-1.pyc — 3.92 KB
2026-04-27 17:40 · rw-r--r--
3.92 KB 2026-04-27 17:40 rw-r--r--
staggered.cpython-39.opt-2.pyc — 1.83 KB
2026-04-27 17:40 · rw-r--r--
1.83 KB 2026-04-27 17:40 rw-r--r--
staggered.cpython-39.pyc — 4.06 KB
2026-04-27 17:40 · rw-r--r--
4.06 KB 2026-04-27 17:40 rw-r--r--
streams.cpython-39.opt-1.pyc — 19.88 KB
2026-04-27 17:40 · rw-r--r--
19.88 KB 2026-04-27 17:40 rw-r--r--
streams.cpython-39.opt-2.pyc — 14.13 KB
2026-04-27 17:40 · rw-r--r--
14.13 KB 2026-04-27 17:40 rw-r--r--
streams.cpython-39.pyc — 20.11 KB
2026-04-27 17:40 · rw-r--r--
20.11 KB 2026-04-27 17:40 rw-r--r--
subprocess.cpython-39.opt-1.pyc — 7.15 KB
2026-04-27 17:40 · rw-r--r--
7.15 KB 2026-04-27 17:40 rw-r--r--
subprocess.cpython-39.opt-2.pyc — 7.03 KB
2026-04-27 17:40 · rw-r--r--
7.03 KB 2026-04-27 17:40 rw-r--r--
subprocess.cpython-39.pyc — 7.17 KB
2026-04-27 17:40 · rw-r--r--
7.17 KB 2026-04-27 17:40 rw-r--r--
tasks.cpython-39.opt-1.pyc — 23.68 KB
2026-04-27 17:40 · rw-r--r--
23.68 KB 2026-04-27 17:40 rw-r--r--
tasks.cpython-39.opt-2.pyc — 16.6 KB
2026-04-27 17:40 · rw-r--r--
16.6 KB 2026-04-27 17:40 rw-r--r--
tasks.cpython-39.pyc — 23.72 KB
2026-04-27 17:40 · rw-r--r--
23.72 KB 2026-04-27 17:40 rw-r--r--
threads.cpython-39.opt-1.pyc — 980 B
2026-04-27 17:40 · rw-r--r--
980 B 2026-04-27 17:40 rw-r--r--
threads.cpython-39.opt-2.pyc — 514 B
2026-04-27 17:40 · rw-r--r--
514 B 2026-04-27 17:40 rw-r--r--
threads.cpython-39.pyc — 980 B
2026-04-27 17:40 · rw-r--r--
980 B 2026-04-27 17:40 rw-r--r--
transports.cpython-39.opt-1.pyc — 12.23 KB
2026-04-27 17:40 · rw-r--r--
12.23 KB 2026-04-27 17:40 rw-r--r--
transports.cpython-39.opt-2.pyc — 6.81 KB
2026-04-27 17:40 · rw-r--r--
6.81 KB 2026-04-27 17:40 rw-r--r--
transports.cpython-39.pyc — 12.24 KB
2026-04-27 17:40 · rw-r--r--
12.24 KB 2026-04-27 17:40 rw-r--r--
trsock.cpython-39.opt-1.pyc — 8.37 KB
2026-04-27 17:40 · rw-r--r--
8.37 KB 2026-04-27 17:40 rw-r--r--
trsock.cpython-39.opt-2.pyc — 8.12 KB
2026-04-27 17:40 · rw-r--r--
8.12 KB 2026-04-27 17:40 rw-r--r--
trsock.cpython-39.pyc — 8.37 KB
2026-04-27 17:40 · rw-r--r--
8.37 KB 2026-04-27 17:40 rw-r--r--
unix_events.cpython-39.opt-1.pyc — 40.75 KB
2026-04-27 17:40 · rw-r--r--
40.75 KB 2026-04-27 17:40 rw-r--r--
unix_events.cpython-39.opt-2.pyc — 35.65 KB
2026-04-27 17:40 · rw-r--r--
35.65 KB 2026-04-27 17:40 rw-r--r--
unix_events.cpython-39.pyc — 41.06 KB
2026-04-27 17:40 · rw-r--r--
41.06 KB 2026-04-27 17:40 rw-r--r--
windows_events.cpython-39.opt-1.pyc — 24.14 KB
2026-04-27 17:40 · rw-r--r--
24.14 KB 2026-04-27 17:40 rw-r--r--
windows_events.cpython-39.opt-2.pyc — 23.06 KB
2026-04-27 17:40 · rw-r--r--
23.06 KB 2026-04-27 17:40 rw-r--r--
windows_events.cpython-39.pyc — 24.15 KB
2026-04-27 17:40 · rw-r--r--
24.15 KB 2026-04-27 17:40 rw-r--r--
windows_utils.cpython-39.opt-1.pyc — 4.33 KB
2026-04-27 17:40 · rw-r--r--
4.33 KB 2026-04-27 17:40 rw-r--r--
windows_utils.cpython-39.opt-2.pyc — 3.91 KB
2026-04-27 17:40 · rw-r--r--
3.91 KB 2026-04-27 17:40 rw-r--r--
windows_utils.cpython-39.pyc — 4.4 KB
2026-04-27 17:40 · rw-r--r--
4.4 KB 2026-04-27 17:40 rw-r--r--
ONLINE
__pycache__
90 items
02:11:02
TERMINAL FM
NAVIGATION
ACTIONS
SELECTION
Edit
Preview
Download
Rename
Copy
Chmod
Delete
a iL@s dZddlZddlZddlZddlZddlZddlZddlZz ddlZWne y^dZYn0ddl m Z ddl m Z ddl m Z ddl mZddl mZdd l mZdd l mZdd l mZdd lmZd dZGddde jZGdddejejZGdddeZGdddeZdS))BaseSelectorEventLoopN) base_events) constants)events)futures) protocols)sslproto) transports)trsock)loggercCs6z||}Wnty"YdS0t|j|@SdSNF)get_keyKeyErrorboolr)selectorfdeventkeyr//usr/lib64/python3.9/asyncio/selector_events.py_test_selector_event s  rcseZdZdRfdd ZdSdddddZdTddddejdd d ZdUd d Zfd dZ ddZ ddZ ddZ ddZ ddZdddejfddZdddejfddZddejfddZd d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.d/Zd0d1Zd2d3ZdVd4d5Zd6d7Zd8d9Zd:d;Zdd?Z!d@dAZ"dBdCZ#dWdDdEZ$dFdGZ%dHdIZ&dJdKZ'dLdMZ(dNdOZ)dPdQZ*Z+S)XrNcsFt|durt}td|jj||_| t |_ dS)NzUsing selector: %s) super__init__ selectorsDefaultSelectorr debug __class____name__ _selector_make_self_pipeweakrefWeakValueDictionary _transports)selfrrrrr1s zBaseSelectorEventLoop.__init__extraservercCst||||||SN)_SelectorSocketTransport)r$sockprotocolwaiterr'r(rrr_make_socket_transport;s z,BaseSelectorEventLoop._make_socket_transportF) server_sideserver_hostnamer'r(ssl_handshake_timeoutc Cs0tj||||||| d} t||| ||d| jS)N)r1r&)r Z SSLProtocolr*Z_app_transport) r$Zrawsockr, sslcontextr-r/r0r'r(r1Z ssl_protocolrrr_make_ssl_transport@sz)BaseSelectorEventLoop._make_ssl_transportcCst||||||Sr))_SelectorDatagramTransport)r$r+r,addressr-r'rrr_make_datagram_transportMsz.BaseSelectorEventLoop._make_datagram_transportcsL|rtd|rdS|t|jdurH|jd|_dS)Nz!Cannot close a running event loop)Z is_running RuntimeError is_closed_close_self_pipercloserr$r%rrr:Rs   zBaseSelectorEventLoop.closecCsB||j|jd|_|jd|_|jd8_dS)Nr)_remove_reader_ssockfilenor:_csock _internal_fdsr;rrrr9]s   z&BaseSelectorEventLoop._close_self_pipecCsNt\|_|_|jd|jd|jd7_||j|jdS)NFr) socket socketpairr=r? setblockingr@ _add_readerr>_read_from_selfr;rrrr es   z%BaseSelectorEventLoop._make_self_pipecCsdSr)rr$datarrr_process_self_datamsz(BaseSelectorEventLoop._process_self_datacCsTz"|jd}|sWqP||Wqty8YqYqtyLYqPYq0qdS)Ni)r=recvrHInterruptedErrorBlockingIOErrorrFrrrrEps   z%BaseSelectorEventLoop._read_from_selfcCsL|j}|durdSz|dWn&tyF|jrBtjdddYn0dS)Nz3Fail to write a null byte into the self-pipe socketTexc_info)r?sendOSError_debugr r)r$csockrrr_write_to_self|s z$BaseSelectorEventLoop._write_to_selfdc Cs"|||j||||||dSr))rDr>_accept_connection)r$protocol_factoryr+r2r(backlogr1rrr_start_servings z$BaseSelectorEventLoop._start_servingc Cst|D]}z0|\}} |jr0td|| ||dWntttfyXYdSt y} zl| j t j t j t j t jfvr|d| t|d|||tj|j||||||nWYd} ~ qd} ~ 00d| i} |||| |||} || qdS)Nz#%r got a new connection from %r: %rFz&socket.accept() out of system resource)message exceptionrApeername)rangeacceptrQr rrCrKrJConnectionAbortedErrorrPerrnoZEMFILEZENFILEZENOBUFSZENOMEMcall_exception_handlerr TransportSocketr<r>Z call_laterrZACCEPT_RETRY_DELAYrX_accept_connection2Z create_task) r$rVr+r2r(rWr1_connaddrexcr'r]rrrrUs@    z(BaseSelectorEventLoop._accept_connectionc sd}d}zr|}|} |r8|j|||| d|||d}n|j||| ||d}z| IdHWntyv|Yn0WntttfyYn^ty} zF|jrd| d} |dur|| d<|dur|| d<|| WYd} ~ n d} ~ 00dS)NT)r-r/r'r(r1)r-r'r(z3Error on transport creation for incoming connection)rYrZr, transport) create_futurer3r. BaseExceptionr: SystemExitKeyboardInterruptrQr`) r$rVrdr'r2r(r1r,rgr-rfcontextrrrrbs@  z)BaseSelectorEventLoop._accept_connection2c Cs|}t|tsHzt|}Wn(tttfyFtd|dYn0z|j|}WntyhYn0|st d|d|dS)NzInvalid file object: zFile descriptor z is used by transport ) isinstanceintr>AttributeError TypeError ValueErrorr#r is_closingr7)r$rr>rgrrr_ensure_fd_no_transports   z-BaseSelectorEventLoop._ensure_fd_no_transportc Gs|t|||d}z|j|}Wn(tyP|j|tj|dfYn>0|j|j }\}}|j ||tjB||f|dur| |Sr)) _check_closedrHandlerrrregisterr EVENT_READrGmodifycancel r$rcallbackargshandlermaskreaderwriterrrrrDs   z!BaseSelectorEventLoop._add_readercCs|r dSz|j|}Wnty0YdS0|j|j}\}}|tjM}|sb|j|n|j ||d|f|dur| dSdSdSNFT) r8rrrrrGrrw unregisterrxryr$rrr~rrrrrr< s  z$BaseSelectorEventLoop._remove_readerc Gs|t|||d}z|j|}Wn(tyP|j|tjd|fYn>0|j|j }\}}|j ||tjB||f|dur| |Sr)) rtrrurrrrvr EVENT_WRITErGrxryrzrrr _add_writer!s   z!BaseSelectorEventLoop._add_writercCs|r dSz|j|}Wnty0YdS0|j|j}\}}|tjM}|sb|j|n|j |||df|dur| dSdSdSr) r8rrrrrGrrrrxryrrrr_remove_writer1s  z$BaseSelectorEventLoop._remove_writercGs"|||j||g|RdSr))rsrDr$rr{r|rrr add_readerHs z BaseSelectorEventLoop.add_readercCs||||Sr))rsr<r$rrrr remove_readerMs z#BaseSelectorEventLoop.remove_readercGs"|||j||g|RdSr))rsrrrrr add_writerRs z BaseSelectorEventLoop.add_writercCs||||Sr))rsrrrrr remove_writerWs z#BaseSelectorEventLoop.remove_writerc st||jr$|dkr$tdz ||WSttfyFYn0|}| }| || ||j |||}| tj|j||d|IdHSNrthe socket must be non-blockingr})r_check_ssl_socketrQ gettimeoutrqrIrKrJrhr>rsrD _sock_recvadd_done_callback functoolspartial_sock_read_done)r$r+nfutrr}rrr sock_recv\s   zBaseSelectorEventLoop.sock_recvcCs|dus|s||dSr)) cancelledrr$rrr}rrrrrsz%BaseSelectorEventLoop._sock_read_donec Cs|r dSz||}WnZttfy2YdSttfyHYn8tyt}z||WYd}~nd}~00||dSr)) donerIrKrJrjrkri set_exception set_result)r$rr+rrGrfrrrrvs z BaseSelectorEventLoop._sock_recvc st||jr$|dkr$tdz ||WSttfyFYn0|}| }| || ||j |||}| tj|j||d|IdHSr)rrrQrrq recv_intorKrJrhr>rsrD_sock_recv_intorrrr)r$r+bufrrr}rrrsock_recv_intos   z$BaseSelectorEventLoop.sock_recv_intoc Cs|r dSz||}WnZttfy2YdSttfyHYn8tyt}z||WYd}~nd}~00||dSr)) rrrKrJrjrkrirr)r$rr+rnbytesrfrrrrs z%BaseSelectorEventLoop._sock_recv_intoc st||jr$|dkr$tdz||}WnttfyLd}Yn0|t|kr^dS| }| }| || ||j ||t||g}|tj|j||d|IdHSr)rrrQrrqrOrKrJlenrhr>rsr _sock_sendall memoryviewrrr_sock_write_done)r$r+rGrrrr}rrr sock_sendalls&     z"BaseSelectorEventLoop.sock_sendallc Cs|r dS|d}z|||d}Wn\ttfyBYdSttfyXYn0ty}z||WYd}~dSd}~00||7}|t|kr| dn||d<dS)Nr) rrOrKrJrjrkrirrr)r$rr+viewposstartrrfrrrrs    z#BaseSelectorEventLoop._sock_sendallcst||jr$|dkr$td|jtjksBtjrt|jtj krt|j ||j|j |j |dIdH}|d\}}}}}| }|||||IdHS)Nrr)familytypeprotoloop)rrrQrrqrrAAF_INETZ _HAS_IPv6AF_INET6Z_ensure_resolvedrrrh _sock_connect)r$r+r5Zresolvedrcrrrr sock_connects     z"BaseSelectorEventLoop.sock_connectc Cs|}z||Wnttfyb|||||j|||}|tj |j ||dYnNt t fyxYn8t y}z||WYd}~nd}~00|ddS)Nr)r>connectrKrJrsr_sock_connect_cbrrrrrjrkrirr)r$rr+r5rr}rfrrrrs    z#BaseSelectorEventLoop._sock_connectcCs|dus|s||dSr))rrrrrrr sz&BaseSelectorEventLoop._sock_write_donec Cs|r dSz,|tjtj}|dkr6t|d|WnXttfyNYnNtt fydYn8t y}z| |WYd}~nd}~00| ddS)NrzConnect call failed ) r getsockoptrA SOL_SOCKETSO_ERRORrPrKrJrjrkrirr)r$rr+r5errrfrrrrs z&BaseSelectorEventLoop._sock_connect_cbcsBt||jr$|dkr$td|}||||IdHS)Nrr)rrrQrrqrh _sock_accept)r$r+rrrr sock_accept"s   z!BaseSelectorEventLoop.sock_acceptc Cs|}z|\}}|dWnttfyl|||||j||}|t j |j ||dYnRt t fyYn<ty}z||WYd}~nd}~00|||fdS)NFr)r>r]rCrKrJrsrDrrrrrrjrkrirr)r$rr+rrdr5r}rfrrrr1s   z"BaseSelectorEventLoop._sock_acceptc s|j|j=|}||IdHzL|j|j|||ddIdHW||rZ|||j|j<S||j|j<n"||r|||j|j<0dS)NF)fallback) r#_sock_fd is_reading pause_reading_make_empty_waiterZ sock_sendfile_sock_reset_empty_waiterresume_reading)r$Ztranspfileoffsetcountrrrr_sendfile_nativeBs*   z&BaseSelectorEventLoop._sendfile_nativecCs|D]v\}}|j|j}\}}|tj@rL|durL|jrB||n |||tj@r|dur|jrp||q||qdSr)) fileobjrGrrwZ _cancelledr<Z _add_callbackrr)r$Z event_listrr~rrrrrr_process_eventsPs    z%BaseSelectorEventLoop._process_eventscCs|||dSr))r<r>r:)r$r+rrr _stop_serving^sz#BaseSelectorEventLoop._stop_serving)N)N)N)NNN)N)N),r __module__ __qualname__rr.rZSSL_HANDSHAKE_TIMEOUTr3r6r:r9r rHrErSrXrUrbrsrDr<rrrrrrrrrrrrrrrrrrrrrr __classcell__rrr%rr+sh        . )  rcseZdZdZeZdZdfdd ZddZddZ d d Z d d Z d dZ ddZ ejfddZdddZddZddZddZddZZS) _SelectorTransportiNcst||t||jd<z||jd<WntyLd|jd<Yn0d|jvrz||jd<Wntj yd|jd<Yn0||_ | |_ d|_ ||||_||_d|_d|_|jdur|j||j|j <dS)NrAZsocknamer[Fr)rrr ra_extra getsocknamerP getpeernamerAerrorrr>r_protocol_connected set_protocol_server_buffer_factory_buffer _conn_lost_closingZ_attachr#)r$rr+r,r'r(r%rrros,       z_SelectorTransport.__init__cCs|jjg}|jdur |dn|jr0|d|d|j|jdur|jst|jj |jt j }|rz|dn |dt|jj |jt j }|rd}nd}| }|d|d |d d d |S) Nclosedclosingzfd=z read=pollingz read=idlepollingZidlezwrite=z<{}> )rrrappendrr_loopr8rrrrwrget_write_buffer_sizeformatjoin)r$inforstatebufsizerrr__repr__s.      z_SelectorTransport.__repr__cCs|ddSr)) _force_closer;rrrabortsz_SelectorTransport.abortcCs||_d|_dSNT) _protocolrr$r,rrrrsz_SelectorTransport.set_protocolcCs|jSr))rr;rrr get_protocolsz_SelectorTransport.get_protocolcCs|jSr))rr;rrrrrsz_SelectorTransport.is_closingcCsT|jr dSd|_|j|j|jsP|jd7_|j|j|j|jddSNTr) rrr<rrrr call_soon_call_connection_lostr;rrrr:sz_SelectorTransport.closecCs,|jdur(|d|t|d|jdS)Nzunclosed transport )source)rResourceWarningr:)r$_warnrrr__del__s z_SelectorTransport.__del__Fatal error on transportcCsNt|tr(|jr@tjd||ddn|j||||jd||dS)Nz%r: %sTrM)rYrZrgr,) rmrPr get_debugr rr`rr)r$rfrYrrr _fatal_errors  z_SelectorTransport._fatal_errorcCsd|jr dS|jr(|j|j|j|jsBd|_|j|j|jd7_|j|j |dSr) rrclearrrrrr<rrr$rfrrrrs z_SelectorTransport._force_closecCszN|jr|j|W|jd|_d|_d|_|j}|dur|d|_n:|jd|_d|_d|_|j}|dur|d|_0dSr))rrZconnection_lostrr:rrZ_detach)r$rfr(rrrrs&  z(_SelectorTransport._call_connection_lostcCs t|jSr))rrr;rrrrsz(_SelectorTransport.get_write_buffer_sizecGs$|jr dS|jj||g|RdSr))rrrDrrrrrDsz_SelectorTransport._add_reader)NN)r)rrrmax_size bytearrayrrrrrrrrrr:warningswarnrrrrrrDrrrr%rrcs    rcseZdZdZejjZd#fdd ZfddZ ddZ d d Z d d Z d dZ ddZddZddZddZddZddZddZfddZdd Zd!d"ZZS)$r*TNcs~d|_t|||||d|_d|_d|_t|j|j |j j ||j |j |j|j|durz|j tj|ddSr )_read_ready_cbrr_eof_paused _empty_waiterrZ _set_nodelayrrrrconnection_maderDr _read_readyr_set_result_unless_cancelled)r$rr+r,r-r'r(r%rrrs   z!_SelectorSocketTransport.__init__cs.t|tjr|j|_n|j|_t|dSr))rmrZBufferedProtocol_read_ready__get_bufferr_read_ready__data_receivedrrrr%rrrs  z%_SelectorSocketTransport.set_protocolcCs|j o|j Sr))rrr;rrrrsz#_SelectorSocketTransport.is_readingcCs>|js |jrdSd|_|j|j|jr:td|dS)NTz%r pauses reading)rrrr<rrr rr;rrrrs   z&_SelectorSocketTransport.pause_readingcCs@|js |jsdSd|_||j|j|jr      z_SelectorSocketTransport.writec Cs|jr dSz|j|j}Wnttfy2YnttfyHYnty}zF|j |j |j | |d|jdur|j|WYd}~nvd}~00|r|jd|=||js|j |j |jdur|jd|jr|dn|jr|jtjdS)Nr )rrrOrrKrJrjrkrirrrrrrr_maybe_resume_protocolrrrrshutdownrASHUT_WR)r$rrfrrrrs2   "    z%_SelectorSocketTransport._write_readycCs.|js |jrdSd|_|js*|jtjdSr)rrrrrrArr;rrr write_eofs  z"_SelectorSocketTransport.write_eofcCsdSrrr;rrr can_write_eofsz&_SelectorSocketTransport.can_write_eofcs*t||jdur&|jtddS)NzConnection is closed by peer)rrrrConnectionErrorrr%rrrs   z._SelectorSocketTransport._call_connection_lostcCs6|jdurtd|j|_|js0|jd|jS)NzEmpty waiter is already set)rr7rrhrrr;rrrrs    z+_SelectorSocketTransport._make_empty_waitercCs d|_dSr))rr;rrrrsz,_SelectorSocketTransport._reset_empty_waiter)NNN)rrrZ_start_tls_compatiblerZ _SendfileModeZ TRY_NATIVEZ_sendfile_compatiblerrrrrrrrr rrrrrrrrrrr%rr*s( %' r*csFeZdZejZd fdd ZddZddZd dd Z d d Z Z S)r4Ncs^t||||||_|j|jj||j|j|j|j |durZ|jt j |ddSr)) rr_addressrrrrrDrrrr)r$rr+r,r5r-r'r%rrrs  z#_SelectorDatagramTransport.__init__cCstdd|jDS)Ncss|]\}}t|VqdSr))r).0rGrcrrr zC_SelectorDatagramTransport.get_write_buffer_size..)sumrr;rrrrsz0_SelectorDatagramTransport.get_write_buffer_sizec Cs|jr dSz|j|j\}}Wnttfy6Yntyd}z|j|WYd}~n\d}~0t t fyzYn>t y}z| |dWYd}~nd}~00|j ||dS)Nz&Fatal read error on datagram transport)rrrecvfromrrKrJrPrerror_receivedrjrkrirZdatagram_receivedr$rGrerfrrrrs "z&_SelectorDatagramTransport._read_readyc Cst|tttfs$tdt|j|s,dS|jrV|d|jfvrPtd|j|j}|j r|jr|j t j krxt d|j d7_ dS|jsdz,|jdr|j|n|j||WdSttfy|j|j|jYn~ty}z|j|WYd}~dSd}~0ttfy0Yn4tyb}z||dWYd}~dSd}~00|j t||f|!dS)Nr z!Invalid address: must be None or r rr['Fatal write error on datagram transport)"rmr rrrprrrrqrrrr rrrrrOsendtorKrJrrr _sendto_readyrPrr rjrkrirrrr!rrrr#sJ      z!_SelectorDatagramTransport.sendtoc Cs|jr|j\}}z*|jdr.|j|n|j||Wqttfyh|j||fYqYqt y}z|j |WYd}~dSd}~0t t fyYqty}z||dWYd}~dSd}~00q||js|j|j|jr|ddS)Nr[r")rpopleftrrrOr#rKrJ appendleftrPrr rjrkrirrrrrrrr!rrrr$0s0  z(_SelectorDatagramTransport._sendto_ready)NNN)N) rrr collectionsdequerrrrr#r$rrrr%rr4s  +r4)__all__r'r_rrrArr!Zssl ImportErrorrrrrrr r r logr rZ BaseEventLooprZ_FlowControlMixinZ Transportrr*r4rrrrsB             <o