o
    Hb                     @   s"   d dl Z d dlZG dd dZdS )    Nc                   @   s  e Zd ZdZdZdejfddZdd Zedd	 Z	ed
d Z
edd Zdd Zdd Zdd Zdd Zdd Zdd Zdd Zdd Zdd Zd d! Zd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd,d- Zd.d/ Zd0d1 Zd2d3 Zd4d5 Zd6d7 Z d8d9 Z!d:d; Z"d<d= Z#d>d? 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.
    _socksockc                 C   s
   || _ d S Nr   )selfr    r   %/usr/lib/python3.10/asyncio/trsock.py__init__      
zTransportSocket.__init__c                 C   s   t jd| dt| d d S )NzUsing 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)warningswarnDeprecationWarning)r   Zwhatr   r   r	   _na   s   

zTransportSocket._nac                 C      | j jS r   )r   familyr   r   r   r	   r         zTransportSocket.familyc                 C   r   r   )r   typer   r   r   r	   r      r   zTransportSocket.typec                 C   r   r   )r   protor   r   r   r	   r   "   r   zTransportSocket.protoc                 C   s   d|    d| jd| jd| j }|   dkrMz|  }|r'| d| }W n
 tjy2   Y nw z|  }|rA| d| }W n
 tjyL   Y nw | dS )	Nz<asyncio.TransportSocket fd=z	, family=z, type=z, proto=z, laddr=z, raddr=>)filenor   r   r   getsocknamesocketerrorgetpeername)r   sZladdrZraddrr   r   r	   __repr__&   s4   
zTransportSocket.__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   zTransportSocket.filenoc                 C   r"   r   )r   dupr   r   r   r	   r#   C   r   zTransportSocket.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   Zhowr   r   r	   r%   I   s   zTransportSocket.shutdownc                 O   s   | j j|i |S r   )r   
getsockoptr   argskwargsr   r   r	   r&   N   s   zTransportSocket.getsockoptc                 O   s   | j j|i | d S r   )r   
setsockoptr'   r   r   r	   r*   Q   s   zTransportSocket.setsockoptc                 C   r"   r   )r   r   r   r   r   r	   r   T   r   zTransportSocket.getpeernamec                 C   r"   r   )r   r   r   r   r   r	   r   W   r   zTransportSocket.getsocknamec                 C   r"   r   )r   getsockbynamer   r   r   r	   r+   Z   r   zTransportSocket.getsockbynamec                 C      |  d | j S )Nzaccept() method)r   r   acceptr   r   r   r	   r-   ]      

zTransportSocket.acceptc                 O      |  d | jj|i |S )Nzconnect() method)r   r   connectr'   r   r   r	   r0   a      
zTransportSocket.connectc                 O   r/   )Nzconnect_ex() method)r   r   
connect_exr'   r   r   r	   r2   e   r1   zTransportSocket.connect_exc                 O   r/   )Nzbind() method)r   r   bindr'   r   r   r	   r3   i   r1   zTransportSocket.bindc                 O   r/   )Nzioctl() method)r   r   ioctlr'   r   r   r	   r4   m   r1   zTransportSocket.ioctlc                 O   r/   )Nzlisten() method)r   r   listenr'   r   r   r	   r5   q   r1   zTransportSocket.listenc                 C   r,   )Nzmakefile() method)r   r   makefiler   r   r   r	   r6   u   r.   zTransportSocket.makefilec                 O   r/   )Nzsendfile() method)r   r   sendfiler'   r   r   r	   r7   y   r1   zTransportSocket.sendfilec                 C   r,   )Nzclose() method)r   r   closer   r   r   r	   r8   }   r.   zTransportSocket.closec                 C   r,   )Nzdetach() method)r   r   detachr   r   r   r	   r9      r.   zTransportSocket.detachc                 O   r/   )Nzsendmsg_afalg() method)r   r   sendmsg_afalgr'   r   r   r	   r:      r1   zTransportSocket.sendmsg_afalgc                 O   r/   )Nzsendmsg() method)r   r   sendmsgr'   r   r   r	   r;      r1   zTransportSocket.sendmsgc                 O   r/   )Nzsendto() method)r   r   sendtor'   r   r   r	   r<      r1   zTransportSocket.sendtoc                 O   r/   )Nzsend() method)r   r   sendr'   r   r   r	   r=      r1   zTransportSocket.sendc                 O   r/   )Nzsendall() method)r   r   sendallr'   r   r   r	   r>      r1   zTransportSocket.sendallc                 O   r/   )Nzset_inheritable() method)r   r   set_inheritabler'   r   r   r	   r?      r1   zTransportSocket.set_inheritablec                 C   s   |  d | j|S )Nzshare() method)r   r   share)r   Z
process_idr   r   r	   r@         
zTransportSocket.sharec                 O   r/   )Nzrecv_into() method)r   r   	recv_intor'   r   r   r	   rB      r1   zTransportSocket.recv_intoc                 O   r/   )Nzrecvfrom_into() method)r   r   recvfrom_intor'   r   r   r	   rC      r1   zTransportSocket.recvfrom_intoc                 O   r/   )Nzrecvmsg_into() method)r   r   recvmsg_intor'   r   r   r	   rD      r1   zTransportSocket.recvmsg_intoc                 O   r/   )Nzrecvmsg() method)r   r   recvmsgr'   r   r   r	   rE      r1   zTransportSocket.recvmsgc                 O   r/   )Nzrecvfrom() method)r   r   recvfromr'   r   r   r	   rF      r1   zTransportSocket.recvfromc                 O   r/   )Nzrecv() method)r   r   recvr'   r   r   r	   rG      r1   zTransportSocket.recvc                 C   s   |dkrd S t d)Nr   z<settimeout(): only 0 timeout is allowed on transport sockets
ValueError)r   valuer   r   r	   
settimeout   s
   zTransportSocket.settimeoutc                 C   s   dS )Nr   r   r   r   r   r	   
gettimeout   s   zTransportSocket.gettimeoutc                 C   s   |sd S t d)Nz3setblocking(): transport sockets cannot be blockingrH   )r   flagr   r   r	   setblocking   s
   zTransportSocket.setblockingc                 C   r,   Nzcontext manager protocol)r   r   	__enter__r   r   r   r	   rP      r.   zTransportSocket.__enter__c                 G   s   |  d | jj| S rO   )r   r   __exit__)r   errr   r   r	   rQ      rA   zTransportSocket.__exit__N)3__name__
__module____qualname____doc__	__slots__r   r
   r   propertyr   r   r   r   r!   r   r#   r$   r%   r&   r*   r   r   r+   r-   r0   r2   r3   r4   r5   r6   r7   r8   r9   r:   r;   r<   r=   r>   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	   <module>   s    