OwlCyberSecurity - MANAGER
Edit File: socket.cpython-37.opt-2.pyc
B YI~dMk � @ sl d dl Z d dl T d dlZd dlZd dlZd dlZd dlmZmZ y d dlZW n e k rd dZY nX e edd�Z e edd�Z e edd�Z d d d d d gZe�e�e �� e�d edd� � e�d edd� � e�dedd� � e�dedd� � dZdZdd� ZeZej�� �d��r�i Zded< d ed < d ed < d ed!< d"ed#< d$ed%< d&ed'< d(ed)< d*ed+< d,ed-< d.ed/< d0ed1< d2ed3< d4ed5< d6ed7< e� d8� G d9d:� d:e �Z G d;d<� d<e j�ZdLd=d �Z e e jd>��r�d?d@� Z!e� d@� e e dA��rde"d fdBdA�Z#ne$e"d fdCdA�Z#e� dA� dDe#_%e e hZ&G dEdF� dFej'�Z(dMdHd �Z)e*� Z+e+dfdId �Z,dNdJdK�Z-dS )O� N)�*)�IntEnum�IntFlag�EBADF� �EAGAIN� � EWOULDBLOCK�fromfd�getfqdn�create_connection� AddressFamily� SocketKindc C s | � � o| �d�S )NZAF_)�isupper� startswith)�C� r �+/opt/alt/python37/lib64/python3.7/socket.py�<lambda>L � r c C s | � � o| �d�S )NZSOCK_)r r )r r r r r Q r ZMsgFlagc C s | � � o| �d�S )NZMSG_)r r )r r r r r V r Z AddressInfoc C s | � � o| �d�S )NZAI_)r r )r r r r r [ r z 127.0.0.1z::1c C s" y|| �S t k r | S X d S )N)� ValueError)�valueZ enum_klassr r r �_intenum_convertera s r �winz The operation was interrupted.i' z A bad file handle was passed.i' zPermission denied.i ' z!A fault occurred on the network??i ' z#An invalid operation was attempted.i&' z The socket operation would blocki3' z,A blocking operation is already in progress.i4' z The network address is in use.i@' z The connection has been reset.iF' z The network has been shut down.iJ' zThe operation timed out.iL' zConnection refused.iM' zThe name is too long.iO' zThe host is down.iP' zThe host is unreachable.iQ' �errorTabc @ s e Zd ZdS )�_GiveupOnSendfileN)�__name__� __module__� __qualname__r r r r r � s r c s( e Zd ZdddgZd8dd�Zdd � Zd d � Zd d � Zdd� Zdd� Z dd� Z d9dddd�dd�Z e e d�rvd:dd�Zn d;d d�Zd<d d �Zd d � Zd=d!d"�Zd#d$� Zejfd%d&�Zd'd(� Z� fd)d*�Ze� fd+d,��Ze� fd-d.��Ze jd/k�rd0d1� Z d2d3� Z nd4d1� Z d5d3� Z d6e _ d7e _ � Z S )>�socket� __weakref__�_io_refs�_closed���Nc C sP |d kr,|dkrt }|dkr t}|dkr,d}tj�| ||||� d| _d| _d S )Nr# r F)�AF_INET� SOCK_STREAM�_socketr �__init__r! r" )�self�family�type�proto�filenor r r r' � s zsocket.__init__c C s | S )Nr )r( r r r � __enter__� s zsocket.__enter__c G s | j s| �� d S )N)r" �close)r( �argsr r r �__exit__� s zsocket.__exit__c C s� t | dd�}d| jj| jj|r"dnd| �� | j| j| jf }|s�y | �� }|r^|dt |� 7 }W n t k rt Y nX y | � � }|r�|dt |� 7 }W n t k r� Y nX |d7 }|S ) Nr" Fz,<%s.%s%s fd=%i, family=%s, type=%s, proto=%iz [closed]� z , laddr=%sz , raddr=%s�>) �getattr� __class__r r r, r) r* r+ � getsockname�str�errorZ getpeername)r( �closed�sZladdrZraddrr r r �__repr__� s0 zsocket.__repr__c C s t d��d S )Nz Cannot serialize socket object)� TypeError)r( r r r � __getstate__� s zsocket.__getstate__c C s6 t | �� �}| j| j| j| j|d�}|�| �� � |S )N)r, )�dupr, r4 r) r* r+ � settimeout� gettimeout)r( �fd�sockr r r r= � s z socket.dupc C sF | � � \}}t| j| j| j|d�}t� d kr>| �� r>|�d� ||fS )N)r, T)Z_acceptr r) r* r+ Zgetdefaulttimeoutr? � setblocking)r( r@ �addrrA r r r �accept� s z socket.accept�r)�encoding�errors�newlinec C s� t |�dddhks td|f ��d|k}d|kp4| }d|k}d} |rN| d7 } |rZ| d7 } t| | �} | jd7 _|d kr~d}|dk r�tj}|dkr�|s�td ��| S |r�|r�t�| | |�} n |r�t�| |�} n t�| |�} |r�| S t� | |||�} || _ | S ) NrE �w�bz&invalid mode %r (only r, w, b allowed)r1 � r# r z!unbuffered streams must be binary) �setr �SocketIOr! �io�DEFAULT_BUFFER_SIZE�BufferedRWPair�BufferedReader�BufferedWriter� TextIOWrapper�mode) r( rT � bufferingrF rG rH ZwritingZreadingZbinaryZrawmode�raw�buffer�textr r r �makefile� s< zsocket.makefile�sendfiler c C s� | � |||� | �� }y |�� }W n0 ttjfk rR } z t|��W d d }~X Y nX yt�|�j}W n* t k r� } z t|��W d d }~X Y nX |s�dS |s�|n|}| � � } | dkr�t d��t t d�r�t �� } nt �� } | �|t j� d} | j} tj} z�x�| �r| | ��st�d��|�r.|| }|dk�r.P y| ||||�}W n^ tk �rd | �s^| � w�Y q� t k �r� } z | dk�r�t|��|d �W d d }~X Y q�X |dk�r�P ||7 }| |7 } q�W | S | dk�r�t |d��r�|�|� X d S )Nr z&non-blocking sockets are not supported� PollSelectorz timed out�seek)�_check_sendfile_paramsr, �AttributeErrorrN �UnsupportedOperationr �os�fstat�st_size�OSErrorr? r �hasattr� selectorsr[ ZSelectSelector�registerZ EVENT_WRITEZselectrZ r& �timeout�BlockingIOErrorr\ )r( �file�offset�countZsocknor, �errZfsize� blocksizerg Zselector� total_sentZselector_selectZ os_sendfile�sentr r r �_sendfile_use_sendfile s` z socket._sendfile_use_sendfilec C s t d��d S )Nz,os.sendfile() not available on this platform)r )r( ri rj rk r r r rp J s c C s | � |||� | �� dkr"td��|r0|�|� |r>t|d�nd}d}|j}| j}z�x�|rrt|| |�}|dkrrP t||��}|s�P xLy ||�} W n tk r� w�Y q�X || 7 }| t |�k r�|| d � }q�P q�W qVW |S |dkr�t |d�r�|�|| � X d S )Nr z&non-blocking sockets are not supportedi r\ ) r] r? r r\ �min�read�send� memoryviewrh �lenrd ) r( ri rj rk rm rn Z file_readZ sock_send�dataro r r r �_sendfile_use_sendN s< zsocket._sendfile_use_sendc C sd dt |dd�krtd��| jt@ s*td��|d k r`t|t�sJtd�|���|dkr`td�|���d S )NrJ rT z$file should be opened in binary modez+only SOCK_STREAM type sockets are supportedz+count must be a positive integer (got {!r})r )r3 r r* r% � isinstance�intr; �format)r( ri rj rk r r r r] r s z socket._check_sendfile_paramsc C s2 y| � |||�S tk r, | �|||�S X d S )N)rp r rw )r( ri rj rk r r r rZ s zsocket.sendfilec C s* | j dkr| j d8 _ | jr&| �� d S )Nr rK )r! r" r. )r( r r r �_decref_socketios� s zsocket._decref_socketiosc C s |� | � d S )N)r. )r( Z_ssr r r � _real_close� s zsocket._real_closec C s d| _ | jdkr| �� d S )NTr )r" r! r| )r( r r r r. � s z socket.closec s d| _ t� �� S )NT)r" �super�detach)r( )r4 r r r~ � s z socket.detachc s t t� jt�S )N)r r} r) r )r( )r4 r r r) � s z socket.familyc s t t� jt�S )N)r r} r* r )r( )r4 r r r* � s z socket.type�ntc C s t �| �� �S )N)r` Zget_handle_inheritabler, )r( r r r �get_inheritable� s zsocket.get_inheritablec C s t �| �� |� d S )N)r` Zset_handle_inheritabler, )r( � inheritabler r r �set_inheritable� s zsocket.set_inheritablec C s t �| �� �S )N)r` r� r, )r( r r r r� � s c C s t �| �� |� d S )N)r` r� r, )r( r� r r r r� � s z&Get the inheritable flag of the socketz&Set the inheritable flag of the socket)r# r# r# N)rE N)r N)r N)r N)r N) r r r � __slots__r' r- r0 r: r< r= rD rY rd r` rp rw r] rZ r{ r& r r| r. r~ �propertyr) r* �namer� r� �__doc__� __classcell__r r )r4 r r � s: ) A $ r c C s t | �}t||||�S )N)r= r )r@ r) r* r+ Znfdr r r r � s Zsharec C s t ddd| �S )Nr )r )�infor r r � fromshare� s r� � socketpairc C sh | d kr*yt } W n tk r( t} Y nX t�| ||�\}}t| |||�� �}t| |||�� �}||fS )N)ZAF_UNIX� NameErrorr$ r& r� r r~ )r) r* r+ �arJ r r r r� � s c C s | t krt}n| tkr t}ntd��|tkr4td��|dkrDtd��t| ||�}z�|�|df� |�� |� � d d� \}}t| ||�}yP|� d� y|� ||f� W n t t fk r� Y nX |� d� |�� \}} W n |�� � Y nX W d |�� X ||fS )Nz?Only AF_INET and AF_INET6 socket address families are supportedz)Only SOCK_STREAM socket type is supportedr z Only protocol zero is supported� FT)r$ � _LOCALHOSTZAF_INET6� _LOCALHOST_V6r r% r �bindZlistenr5 rB �connectrh �InterruptedErrorrD r. ) r) r* r+ �hostZlsockrC �portZcsockZssock�_r r r r� � s8 a8 socketpair([family[, type[, proto]]]) -> (socket object, socket object) Create a pair of socket objects from the sockets returned by the platform socketpair() function. The arguments are the same as for socket() except the default family is AF_UNIX if defined on the platform; otherwise, the default is AF_INET. c sl e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Z� fd d �Zd d� Z e dd� �Z e dd� �Z dd� Z � ZS )rM c C sZ |dkrt d| ��tj�| � || _d|kr6|d7 }|| _d|k| _d|k| _d| _d S )N)rE rI �rw�rb�wbZrwbzinvalid mode: %rrJ rE rI F) r rN � RawIOBaser' �_sock�_mode�_reading�_writing�_timeout_occurred)r( rA rT r r r r' 3 s zSocketIO.__init__c C s� | � � | �� | jr td��xby | j�|�S tk rH d| _� Y q tk r| } z|jd t krjd S � W d d }~X Y q X q W d S )Nz!cannot read from timed out objectTr ) � _checkClosed�_checkReadabler� rc r� Z recv_intorg r7 r/ �_blocking_errnos)r( rJ �er r r �readinto? s zSocketIO.readintoc C sX | � � | �� y | j�|�S tk rR } z|jd tkr@d S � W d d }~X Y nX d S )Nr )r� �_checkWritabler� rs r7 r/ r� )r( rJ r� r r r �writeV s zSocketIO.writec C s | j rtd��| jS )Nz I/O operation on closed socket.)r8 r r� )r( r r r �readablef s zSocketIO.readablec C s | j rtd��| jS )Nz I/O operation on closed socket.)r8 r r� )r( r r r �writablem s zSocketIO.writablec s | j rtd��t� �� S )Nz I/O operation on closed socket.)r8 r r} �seekable)r( )r4 r r r� t s zSocketIO.seekablec C s | � � | j�� S )N)r� r� r, )r( r r r r, { s zSocketIO.filenoc C s | j s| �� S dS d S )Nr# )r8 r, )r( r r r r� � s z SocketIO.namec C s | j S )N)r� )r( r r r rT � s z SocketIO.modec C s* | j r d S tj�| � | j�� d | _d S )N)r8 rN r� r. r� r{ )r( r r r r. � s zSocketIO.close)r r r r' r� r� r� r� r� r, r� r� rT r. r� r r )r4 r rM " s rM r1 c C sn | � � } | r| dkrt� } yt| �\}}}W n tk r@ Y n*X |�d|� x|D ]} d| krTP qTW |} | S )Nz0.0.0.0r �.)�stripZ gethostnameZ gethostbyaddrr7 �insert)r� Zhostname�aliasesZipaddrsr r r r � s c C s� | \}}d }x�t ||dt�D ]�}|\}}} } } d } y>t||| �} |tk rR| �|� |r`| �|� | �| � d }| S tk r� } z| }| d k r�| �� W d d } ~ X Y q X q W |d k r�z|�W d d }X ntd��d S )Nr z!getaddrinfo returns an empty list) � getaddrinfor% r �_GLOBAL_DEFAULT_TIMEOUTr> r� r� r7 r. )Zaddressrg Zsource_addressr� r� rl �res�af�socktyper+ � canonname�sarA r� r r r r � s. c C sT g }xJt �| |||||�D ]2}|\}} }} } |�t|t�t| t�|| | f� qW |S )N)r& r� �appendr r r ) r� r� r) r* r+ �flagsZaddrlistr� r� r� r� r� r r r r� � s r� )r )r1 )r r r r ).r& r` �sysrN re �enumr r �errno� ImportErrorr3 r r r �__all__�extend�_get_exports_list�_convertr r� r� r r Z _realsocket�platform�lowerr r r� � Exceptionr r rd r� r% r� r$ r� r� r� rM r �objectr� r r� r r r r �<module>1 s� F $ u +