o
    7?e                     @   s   d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ G dd de	Z
G dd de
ZG dd deZG d	d
 d
e
Zdd ZdddZdddZdd Zdd ZdS )    N)utilc                   @   s@   e Zd ZdddZdd Zdd Zdd	d
Zdd Zdd ZdS )
BaseSocketNc                 C   sd   || _ || _|| _|d u rt| jtj}d}nt|| jtj}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   N/home/www/facesmatcher.com/pyenv/lib/python3.10/site-packages/gunicorn/sock.py__init__   s   
zBaseSocket.__init__c                 C   s   d| j   S )Nz<socket %d>)r   filenor   r   r   r   __str__"   s   zBaseSocket.__str__c                 C   s   t | j|S N)getattrr   )r   namer   r   r   __getattr__%   s   zBaseSocket.__getattr__Fc              
   C   s   | tjtjd | jjr;ttdr;z| tjtjd W n tjy: } z|j	t	j
t	jfvr0 W Y d }~nd }~ww |sB| | |d t|drQ|d || jj |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&   



zBaseSocket.set_optionsc                 C   s   | | j d S r   )r*   r   )r   r   r   r   r   r*   <   s   zBaseSocket.bindc              
   C   s`   | j d u rd S z| j   W n tjy* } z| jdt| W Y d }~nd }~ww d | _ d S )NzError while closing socket %s)r   r   r	   r&   r   infostr)r   er   r   r   r   ?   s   

zBaseSocket.closer   F)	__name__
__module____qualname__r   r   r   r   r*   r   r   r   r   r   r      s    

r   c                       s,   e Zd ZejZdd Zd fdd	Z  ZS )	TCPSocketc                 C   s2   | j jrd}nd}| j }d||d |d f S )Nhttpshttpz
%s://%s:%dr   r   )r   Zis_sslr   getsockname)r   schemeaddrr   r   r   r   O   s
   
zTCPSocket.__str__Fc                    s"   | tjtjd t j||dS )Nr   r   )r!   r	   IPPROTO_TCPTCP_NODELAYsuperr   )r   r   r   	__class__r   r   r   X   s   zTCPSocket.set_optionsr2   )	r3   r4   r5   r	   AF_INETr
   r   r   __classcell__r   r   r?   r   r6   K   s    	r6   c                   @   s   e Zd ZejZdd ZdS )
TCP6Socketc                 C   s   | j  \}}}}d||f S )Nzhttp://[%s]:%d)r   r9   )r   hostport_r   r   r   r   a   s   zTCP6Socket.__str__N)r3   r4   r5   r	   AF_INET6r
   r   r   r   r   r   rC   ]   s    rC   c                       s4   e Zd ZejZd fdd	Zdd Zdd Z  Z	S )	
UnixSocketNc              
      s   |d u r9zt |}W n ty& } z|jd tjkr W Y d }~nd }~ww t|jr3t | nt	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   zUnixSocket.__init__c                 C   s
   d| j  S )Nzunix:%s)r   r   r   r   r   r   x   s   
zUnixSocket.__str__c                 C   s@   t | jj}|| j t| j| jj| jj t | d S r   )	r   umaskr   r*   r   r   chownuidgid)r   r   Z	old_umaskr   r   r   r*   {   s   zUnixSocket.bindr   )
r3   r4   r5   r	   AF_UNIXr
   r   r   r*   rB   r   r   r?   r   rH   f   s
    rH   c                 C   sJ   t | trt| d rt}|S t}|S t | ttfrt}|S t	d|  )Nr   z Unable to create socket from: %r)

isinstancetupler   is_ipv6rC   r6   r0   bytesrH   	TypeError)r;   	sock_typer   r   r   
_sock_type   s   
r^   c                 C   s  g }| j }dd |D }|r|t|7 }dd |D }| jr,tj| js,td| j | jr=tj| js=td| j |rd|D ] }t	|tj
tj}| }	t|	}
|
|	| ||d}|| qA|S |D ]}t|}
d}tdD ]\}z|
|| |}W nQ tjy } zD|jd	 tjkr|d
t| |jd	 tjkr|dt| |dk rd}||jt|t|d |d td W Y d}~qrd}~ww  |du r|dt| 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|qS r   rX   int.0r*   r   r   r   
<listcomp>       z"create_sockets.<locals>.<listcomp>c                 S   s   g | ]	}t |ts|qS r   r_   ra   r   r   r   rc      rd   zcertfile "%s" does not existzkeyfile "%s" does not existrI   N   r   zConnection in use: %szInvalid address: %sz$connection to {addr} failed: {error})r;   r&   zRetrying in 1 second.r   zCan't connect to %s)r   listcertfiler   pathexistsrQ   keyfiler	   r   rW   r   r9   r^   appendranger&   rL   r'   
EADDRINUSEr0   ZEADDRNOTAVAILdebugformattimesleepsysexit)r   r   fds	listenersr;   Zfdaddrladdrr   r   	sock_namer]   Zlistenerir1   msgr   r   r   create_sockets   sT   


rz   Tc                 C   s8   | D ]}|  }|  |rt|tu rt| qd S r   )r9   r   r^   rH   r   unlink)ru   r{   r   rw   r   r   r   close_sockets   s   
r|   c                    s    fdd}   |S )Nc                     sD   t jt jj jd} | j j jd  j| _	 j
r |  j
 | S )N)cafile)rg   rj   )sslcreate_default_contextPurposeCLIENT_AUTHca_certsload_cert_chainrg   rj   	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|jd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~   rJ   rr   rp   Zgunicornr   objectr   r6   rC   rH   r^   rz   r|   r   r   r   r   r   r   <module>   s"   :	

A