o
0i @ s" d dl Z d dlZG dd dZdS ) Nc @ s e Zd ZdZdZdejfddZdd Zedd Z ed
d Z
ed d
Z dd Z dd Z
dd Zdd Zdd Zdd Zdd Zd d Zd d Zd d! Zd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd,d- Zd.d/ Z d0d1 Z d2d3 Z d4d5 Z d6d7 Z d8d9 Z!d:d; Z"dd? Z$d@dA Z%dBdC Z&dDdE Z'dFdG Z(dHdI Z)dJdK Z*dLdM Z+dNdO Z,dPdQ Z-dRdS Z.dTdU Z/dVdW Z0dXdY Z1dZd[ Z2d\S )]TransportSocketzA socket-like wrapper for exposing real transport sockets.
These objects can be safely returned by APIs like
`transport.get_extra_info('socket')`. All potentially disruptive
operations (like "socket.close()") are banned.
_socksockc C s
|| _ d S Nr )selfr r 5/opt/alt/python310/lib64/python3.10/asyncio/trsock.py__init__
zTransportSocket.__init__c C s t jd| dt| d d S )NzUsing z on sockets returned from get_extra_info('socket') will be prohibited in asyncio 3.9. Please report your use case to bugs.python.org.)source)warningswarnDeprecationWarning)r Zwhatr r r _na s
zTransportSocket._nac C | j jS r )r familyr r r r r zTransportSocket.familyc C r r )r typer r r r r r zTransportSocket.typec C r r )r protor r r r r " r zTransportSocket.protoc C s d| d| jd| jd| j }| dkrMz| }|r'| d| }W n
tjy2 Y nw z| }|rA| d| }W n
tjyL Y nw | dS ) Nz )filenor r r getsocknamesocketerror getpeername)r sZladdrZraddrr r r __repr__& s4
zTransportSocket.__repr__c C s t d)Nz/Cannot serialize asyncio.TransportSocket object) TypeErrorr r r r __getstate__= s z TransportSocket.__getstate__c C
| j S r )r r r r r r r @ r zTransportSocket.filenoc C r" r )r dupr r r r r# C r zTransportSocket.dupc C r" r )r get_inheritabler r r r r$ F r z TransportSocket.get_inheritablec C s | j | d S r )r shutdown)r Zhowr r r r% I s zTransportSocket.shutdownc O s | j j|i |S r )r
getsockoptr argskwargsr r r r& N s zTransportSocket.getsockoptc O s | j j|i | d S r )r
setsockoptr' r r r r* Q s zTransportSocket.setsockoptc C r" r )r r r r r r r T r zTransportSocket.getpeernamec C r" r )r r r r r r r W r zTransportSocket.getsocknamec C r" r )r
getsockbynamer r r r r+ Z r z TransportSocket.getsockbynamec C | d | j S )Nzaccept() method)r r acceptr r r r r- ]
zTransportSocket.acceptc O | d | jj|i |S )Nzconnect() method)r r connectr' r r r r0 a
zTransportSocket.connectc O r/ )Nzconnect_ex() method)r r
connect_exr' r r r r2 e r1 zTransportSocket.connect_exc O r/ )Nz
bind() method)r r bindr' r r r r3 i r1 zTransportSocket.bindc O r/ )Nzioctl() method)r r ioctlr' r r r r4 m r1 zTransportSocket.ioctlc O r/ )Nzlisten() method)r r listenr' r r r r5 q r1 zTransportSocket.listenc C r, )Nzmakefile() method)r r makefiler r r r r6 u r. zTransportSocket.makefilec O r/ )Nzsendfile() method)r r sendfiler' r r r r7 y r1 zTransportSocket.sendfilec C r, )Nzclose() method)r r closer r r r r8 } r. zTransportSocket.closec C r, )Nzdetach() method)r r detachr r r r r9 r. zTransportSocket.detachc O r/ )Nzsendmsg_afalg() method)r r
sendmsg_afalgr' r r r r: r1 z TransportSocket.sendmsg_afalgc O r/ )Nzsendmsg() method)r r sendmsgr' r r r r; r1 zTransportSocket.sendmsgc O r/ )Nzsendto() method)r r sendtor' r r r r< r1 zTransportSocket.sendtoc O r/ )Nz
send() method)r r sendr' r r r r= r1 zTransportSocket.sendc O r/ )Nzsendall() method)r r sendallr' r r r r> r1 zTransportSocket.sendallc O r/ )Nzset_inheritable() method)r r set_inheritabler' r r r r? r1 z TransportSocket.set_inheritablec C s | d | j|S )Nzshare() method)r r share)r Z
process_idr r r r@
zTransportSocket.sharec O r/ )Nzrecv_into() method)r r recv_intor' r r r rB r1 zTransportSocket.recv_intoc O r/ )Nzrecvfrom_into() method)r r
recvfrom_intor' r r r rC r1 z TransportSocket.recvfrom_intoc O r/ )Nzrecvmsg_into() method)r r recvmsg_intor' r r r rD r1 z TransportSocket.recvmsg_intoc O r/ )Nzrecvmsg() method)r r recvmsgr' r r r rE r1 zTransportSocket.recvmsgc O r/ )Nzrecvfrom() method)r r recvfromr' r r r rF r1 zTransportSocket.recvfromc O r/ )Nz
recv() method)r r recvr' r r r rG r1 zTransportSocket.recvc C s |dkrd S t d)Nr z r? r@ rB rC rD rE rF rG rK rL rN rP rQ r r r r r sd
r )r r
r r r r r s