o
    $if                     @   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   F/var/www/html/corbot_env/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   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   r:   )r   hostport_r   r   r   r   a   s   zTCP6Socket.__str__N)r3   r4   r5   r	   AF_INET6r
   r   r   r   r   r   rD   ]   s    rD   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   	old_umaskr   r   r   r*   {   s   zUnixSocket.bindr   )
r3   r4   r5   r	   AF_UNIXr
   r   r   r*   rC   r   r   r@   r   rI   f   s
    rI   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_ipv6rD   r6   r0   bytesrI   	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   rZ   int.0r*   r   r   r   
<listcomp>       z"create_sockets.<locals>.<listcomp>c                 S   s   g | ]	}t |ts|qS r   ra   rc   r   r   r   re      rf   zcertfile "%s" does not existzkeyfile "%s" does not existrJ   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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 ]}|  }|  |rt|tu rt| qd S r   )r:   r   r`   rI   r   unlink)rx   r   r   r{   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)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|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   rK   ru   rs   gunicornr   objectr   r6   rD   rI   r`   r   r   r   r   r   r   r   r   <module>   s"   :	

A