U
��,a� � @ s" d dl Z d dlZG dd� d�ZdS )� Nc @ s� e Zd ZdZdZejd�dd�Zdd� 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"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 )]�TransportSocketz�A 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 �3/opt/alt/python38/lib64/python3.8/asyncio/trsock.py�__init__ s zTransportSocket.__init__c C s t jd|� d�t| 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)�warnings�warn�DeprecationWarning)r Zwhatr r r �_na s
�zTransportSocket._nac C s | j jS r )r �family�r r r r r s zTransportSocket.familyc C s | j jS r )r �typer r r r r s zTransportSocket.typec C s | j jS r )r �protor r r r r " s zTransportSocket.protoc C s� d| � � � d| j�d| j�d| j� �}| � � dkr�z | �� }|rN|� d|� �}W n tjk
rf Y nX z | �� }|r�|� d|� �}W n tjk
r� Y nX |� d�S ) Nz <asyncio.TransportSocket fd=z , family=z, type=z, proto=���z, laddr=z, raddr=�>)�filenor r r � getsockname�socket�error� getpeername)r �sZladdrZraddrr r r �__repr__& s $� zTransportSocket.__repr__c C s t d��d S )Nz/Cannot serialize asyncio.TransportSocket object)� TypeErrorr r r r � __getstate__= s z TransportSocket.__getstate__c C s
| j �� S r )r r r r r r r @ s zTransportSocket.filenoc C s
| j �� S r )r �dupr r r r r C s zTransportSocket.dupc C s
| j �� S r )r �get_inheritabler r r r r F s 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||�S r )r �
getsockopt�r �args�kwargsr r r r" N s zTransportSocket.getsockoptc O s | j j||� d S r )r �
setsockoptr# r r r r& Q s zTransportSocket.setsockoptc C s
| j �� S r )r r r r r r r T s zTransportSocket.getpeernamec C s
| j �� S r )r r r r r r r W s zTransportSocket.getsocknamec C s
| j �� S r )r �
getsockbynamer r r r r' Z s z TransportSocket.getsockbynamec C s | � d� | j�� S )Nzaccept() method)r r �acceptr r r r r( ] s
zTransportSocket.acceptc O s | � d� | jj||�S )Nzconnect() method)r r �connectr# r r r r) a s
zTransportSocket.connectc O s | � d� | jj||�S )Nzconnect_ex() method)r r �
connect_exr# r r r r* e s
zTransportSocket.connect_exc O s | � d� | jj||�S )Nz
bind() method)r r �bindr# r r r r+ i s
zTransportSocket.bindc O s | � d� | jj||�S )Nzioctl() method)r r �ioctlr# r r r r, m s
zTransportSocket.ioctlc O s | � d� | jj||�S )Nzlisten() method)r r �listenr# r r r r- q s
zTransportSocket.listenc C s | � d� | j�� S )Nzmakefile() method)r r �makefiler r r r r. u s
zTransportSocket.makefilec O s | � d� | jj||�S )Nzsendfile() method)r r �sendfiler# r r r r/ y s
zTransportSocket.sendfilec C s | � d� | j�� S )Nzclose() method)r r �closer r r r r0 } s
zTransportSocket.closec C s | � d� | j�� S )Nzdetach() method)r r �detachr r r r r1 � s
zTransportSocket.detachc O s | � d� | jj||�S )Nzsendmsg_afalg() method)r r �
sendmsg_afalgr# r r r r2 � s
z TransportSocket.sendmsg_afalgc O s | � d� | jj||�S )Nzsendmsg() method)r r �sendmsgr# r r r r3 � s
zTransportSocket.sendmsgc O s | � d� | jj||�S )Nzsendto() method)r r �sendtor# r r r r4 � s
zTransportSocket.sendtoc O s | � d� | jj||�S )Nz
send() method)r r �sendr# r r r r5 � s
zTransportSocket.sendc O s | � d� | jj||�S )Nzsendall() method)r r �sendallr# r r r r6 � s
zTransportSocket.sendallc O s | � d� | jj||�S )Nzset_inheritable() method)r r �set_inheritabler# r r r r7 � s
z TransportSocket.set_inheritablec C s | � d� | j�|�S )Nzshare() method)r r �share)r Z
process_idr r r r8 � s
zTransportSocket.sharec O s | � d� | jj||�S )Nzrecv_into() method)r r � recv_intor# r r r r9 � s
zTransportSocket.recv_intoc O s | � d� | jj||�S )Nzrecvfrom_into() method)r r �
recvfrom_intor# r r r r: � s
z TransportSocket.recvfrom_intoc O s | � d� | jj||�S )Nzrecvmsg_into() method)r r � recvmsg_intor# r r r r; � s
z TransportSocket.recvmsg_intoc O s | � d� | jj||�S )Nzrecvmsg() method)r r �recvmsgr# r r r r< � s
zTransportSocket.recvmsgc O s | � d� | jj||�S )Nzrecvfrom() method)r r �recvfromr# r r r r= � s
zTransportSocket.recvfromc O s | � d� | jj||�S )Nz
recv() method)r r �recvr# r r r r> � s
zTransportSocket.recvc C s |dkr d S t d��d S )Nr z<settimeout(): only 0 timeout is allowed on transport sockets��
ValueError)r �valuer r r �
settimeout� s
�zTransportSocket.settimeoutc C s dS )Nr r r r r r �
gettimeout� s zTransportSocket.gettimeoutc C s |sd S t d��d S )Nz3setblocking(): transport sockets cannot be blockingr? )r �flagr r r � setblocking� s
�zTransportSocket.setblockingc C s | � d� | j�� S �Nzcontext manager protocol)r r � __enter__r r r r rG � s
zTransportSocket.__enter__c G s | � d� | jj|� S rF )r r �__exit__)r �errr r r rH � s
zTransportSocket.__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( r) r* r+ r, r- r. r/ r0 r1 r2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= r> rB rC rE rG rH r r r r r sb
r )r r r r r r r �<module> s