File: //home/arjun/projects/env/lib/python3.10/site-packages/gunicorn/__pycache__/sock.cpython-310.pyc
o
%we� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ G dd� de �Z
G dd� de
�Z G dd� de �Z G d d
� d
e
�Z
d d � Zdd
d�Zddd�Zdd� Zdd� ZdS )� N)�utilc @ s@ e Zd Zddd�Zdd� Zdd� Zdd d
�Zd d � Zd
d� ZdS )�
BaseSocketNc C sd || _ || _|| _|d u rt�| jtj�}d}nt�|| jtj�}t�|� d}| j ||d�| _
d S )NFT��bound) �log�conf�cfg_addr�socket�FAMILY� SOCK_STREAM�fromfd�os�close� set_options�sock)�self�addressr r �fdr r � r �F/home/arjun/projects/env/lib/python3.10/site-packages/gunicorn/sock.py�__init__ s
zBaseSocket.__init__c C s d| j �� S )Nz <socket %d>)r �fileno�r r r r �__str__" s zBaseSocket.__str__c C s t | j|�S �N)�getattrr )r �namer r r � __getattr__% s zBaseSocket.__getattr__Fc
C s� |� tjtjd� | jjr;ttd�r;z |� tjtjd� W n tjy: } z|j t j
t j fvr0� W Y d }~nd }~ww |sB| � |� |�
d� t|d�rQ|�d� |�| jj� |S )N� � SO_REUSEPORTr �set_inheritableT)�
setsockoptr �
SOL_SOCKET� SO_REUSEADDRr �
reuse_port�hasattrr �error�errno� ENOPROTOOPT�EINVAL�bind� setblockingr �listen�backlog)r r r �errr r r r ( s& � ���
zBaseSocket.set_optionsc C s |� | j� d S r )r* r )r r r r r r* < s zBaseSocket.bindc
C s` | j d u rd S z| j �� W n tjy* } z| j�dt|�� W Y d }~nd }~ww d | _ d S )Nz Error while closing socket %s)r r r r& r �info�str)r �er r r r ? s
��
zBaseSocket.closer �F) �__name__�
__module__� __qualname__r r r r r* r r r r r r s
r c s, e Zd ZejZdd� Zd� fdd� Z� ZS )� TCPSocketc C s2 | j jrd}nd}| j�� }d||d |d f S )N�https�httpz
%s://%s:%dr r )r �is_sslr � getsockname)r �scheme�addrr r r r O s
zTCPSocket.__str__Fc s" |� tjtjd� t� j||d�S )Nr r )r! r � IPPROTO_TCP� TCP_NODELAY�superr )r r r �� __class__r r r X s zTCPSocket.set_optionsr2 ) r3 r4 r5 r �AF_INETr
r r �
__classcell__r r r@ r r6 K s r6 c @ s e Zd ZejZdd� ZdS )�
TCP6Socketc C s | j �� \}}}}d||f S )Nzhttp://[%s]:%d)r r: )r �host�port�_r r r r a s zTCP6Socket.__str__N)r3 r4 r5 r �AF_INET6r
r r r r r rD ] s rD c s4 e Zd ZejZd� fdd� Zdd� Zdd� Z� Z S ) �
UnixSocketNc
s� |d u r9zt �|�}W n ty& } z|jd tjkr � W Y d }~nd }~ww t�|j�r3t �|� nt d| ��t
� j ||||d� d S )Nr z%r is not a socket�r ) r
�stat�OSError�argsr' �ENOENT�S_ISSOCK�st_mode�remove�
ValueErrorr? r )r r< r r r �str1 r@ r r r j s ��� zUnixSocket.__init__c C s
d| j S )Nzunix:%s)r r r r r r x s
zUnixSocket.__str__c C s@ t �| jj�}|�| j� t�| j| jj| jj� t �|� d S r ) r
�umaskr r* r r �chown�uid�gid)r r � old_umaskr r r r* { s zUnixSocket.bindr )
r3 r4 r5 r �AF_UNIXr
r r r* rC r r r@ r rI f s
rI c C sJ t | t�rt�| d �rt}|S t}|S t | ttf�r t}|S t d| ��)Nr z Unable to create socket from: %r)
�
isinstance�tupler �is_ipv6rD r6 r0 �bytesrI � TypeError)r< � sock_typer r r �
_sock_type� s
�� �r` c C s� g }| j }dd� |D �}|r|t|�7 }dd� |D �}| jr,tj�| j�s,td| j ��| jr=tj�| j�s=td| j ��|rd|D ] }t� |tj
tj �}|� � } t
| �}
|
| | ||d�} |�| � qA|S |D ]}t
|�}
d}td�D ]\} z|
|| |�}W nQ tjy� }
zD|
jd tjkr�|�d
t|�� |
jd tjkr�|�d t|�� | dk r�d }|�|jt|�t|
�d
�� |�d� t�d� W Y d}
~
qrd}
~
ww |du r�|�dt|�� t�d� |�|� qf|S )z�
Create a new socket for the configured addresses or file descriptors.
If a configured address is a tuple then a TCP socket is created.
If it is a string, a Unix socket is created. Otherwise, a TypeError is
raised.
c S s g | ] }t |t�r|�qS r �rZ �int��.0r* r r r �
<listcomp>� � z"create_sockets.<locals>.<listcomp>c S s g | ] }t |t�s|�qS r ra rc r r r re � rf z certfile "%s" does not existzkeyfile "%s" does not existrJ N� r zConnection in use: %szInvalid address: %sz$connection to {addr} failed: {error})r< r& zRetrying in 1 second.r zCan't connect to %s) r �list�certfiler
�path�existsrR �keyfiler r rY r r: r` �append�ranger& rM r' �
EADDRINUSEr0 �
EADDRNOTAVAIL�debug�format�time�sleep�sys�exit)r r �fds� listenersr< �fdaddr�laddrr r � sock_namer_ �listener�ir1 �msgr r r �create_sockets� sT
��
r Tc C s8 | D ]}|� � }|�� |rt|�tu rt�|� qd S r )r: r r` rI r
�unlink)rx r� r r{ r r r �
close_sockets� s
��r� c s � fdd�}� � � |�S )Nc sD t jt jj� jd�} | j� j� jd� � j| _ � j
r | � � j
� | S )N)�cafile)ri rl ) �ssl�create_default_context�Purpose� CLIENT_AUTH�ca_certs�load_cert_chainri rl � cert_reqs� verify_mode�ciphers� set_ciphers)�context�r r r �default_ssl_context_factory� s z0ssl_context.<locals>.default_ssl_context_factory)� ssl_context)r r� r r� r r� � s r� c C s t |�j| d|j|jd�S )NT)� server_side�suppress_ragged_eofs�do_handshake_on_connect)r� � wrap_socketr� r� )r r r r r �ssl_wrap_socket� s
�r� r )T)r' r
r r� rK ru rs �gunicornr �objectr r6 rD rI r` r r� r� r� r r r r �<module> s" :
A