o iO$@sddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ej Z GdddZ Gddde Z Gddde ZGd d d e Zd d Zdd dZdddZddZddZddZddZddZdS)N)utilc@sHeZdZdddZddZddZdd d Zd d Zd dZddZ dS) BaseSocketNcCsd||_||_||_|durt|jtj}d}nt||jtj}t|d}|j ||d|_ dS)NFTbound) logconfcfg_addrsocketFAMILY SOCK_STREAMfromfdosclose set_optionssock)selfaddressrrfdrrrA/home/ubuntu/.local/lib/python3.10/site-packages/gunicorn/sock.py__init__s zBaseSocket.__init__cCsd|jS)Nz )rfilenorrrr__str__$szBaseSocket.__str__cCs t|j|SN)getattrr)rnamerrr __getattr__'s zBaseSocket.__getattr__Fc Cs|tjtjd|jjr:ttdr:z |tjtjdWnty9}z|j t j t j fvr/WYd}~nd}~ww|sA| || dt|drP|d||jj|S)N SO_REUSEPORTrset_inheritableT) setsockoptr SOL_SOCKET SO_REUSEADDRr reuse_porthasattrrOSErrorerrno ENOPROTOOPTEINVALbind setblockingr listenbacklog)rrrerrrrrr*s&     zBaseSocket.set_optionscCs||jdSr)r*r)rrrrrr*>szBaseSocket.bindc Cs^|jdurdSz|jWnty)}z|jdt|WYd}~nd}~wwd|_dS)NzError while closing socket %s)rrr&rinfostr)rerrrrAs  zBaseSocket.closecCdSNrrrrr get_backlogLzBaseSocket.get_backlogrF) __name__ __module__ __qualname__rrrrr*rr5rrrrrs   rcsLeZdZejZddZd fdd ZedkrddZ Z Sd dZ Z S) TCPSocketcCs2|jjrd}nd}|j}d||d|dfS)Nhttpshttpz %s://%s:%drr)ris_sslr getsockname)rschemeaddrrrrrTs  zTCPSocket.__str__Fcs"|tjtjdtj||dS)Nrr)r!r IPPROTO_TCP TCP_NODELAYsuperr)rrr __class__rrr]szTCPSocket.set_optionslinuxc CsN|jr%d}z|jtjtjd}t||dWSttfy$YdSwdS)N BBBBBBBBIIIIIIIIIIIIIIIIIIIIIIIIh r) r getsockoptr rBTCP_INFOstructunpackAttributeErrorr&)rfmttcp_info_structrrrr5bs zTCPSocket.get_backlogcCr2r3rrrrrr5or6r7) r8r9r:r AF_INETr rrPLATFORMr5 __classcell__rrrErr;Ps  r;c@seZdZejZddZdS) TCP6SocketcCs|j\}}}}d||fS)Nzhttp://[%s]:%d)rr?)rhostport_rrrrws zTCP6Socket.__str__N)r8r9r:r AF_INET6r rrrrrrUss rUcs4eZdZejZdfdd ZddZddZZ S) UnixSocketNc s|dur9zt|}Wnty&}z|jdtjkrWYd}~nd}~wwt|jr3t|nt d|t j ||||ddS)Nrz%r is not a socketr) r statr&argsr'ENOENTS_ISSOCKst_moderemove ValueErrorrDr)rrArrrstr1rErrrs    zUnixSocket.__init__cCs d|jS)Nzunix:%s)rrrrrrs zUnixSocket.__str__cCs@t|jj}||jt|j|jj|jjt|dSr) r umaskrr*rrchownuidgid)rr old_umaskrrrr*s zUnixSocket.bindr) r8r9r:r AF_UNIXr rrr*rTrrrErrZ|s rZcCsJt|trt|drt}|St}|St|ttfrt}|St d|)Nrz Unable to create socket from: %r) isinstancetupleris_ipv6rUr;r0bytesrZ TypeError)rA sock_typerrr _sock_types  rpc Csg}|j}dd|D}|r|t|7}dd|D}|jr,tj|js,td|j|jr=tj|js=td|j|rd|D] }t |tj tj }| } t | } | | |||d} || qA|S|D]~}t |} d}tdD][} z| |||}WnPty} zD| jd tjkr|d t|| jd tjkr|d t|d }||jt|t| d | dkr|dtdWYd} ~ qrd} ~ ww|dur|dt|td||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. cSsg|] }t|tr|qSrrjint.0r*rrr z"create_sockets..cSsg|] }t|ts|qSrrqrsrrrrurvzcertfile "%s" does not existzkeyfile "%s" does not existr[NrzConnection in use: %szInvalid address: %sz$connection to {addr} failed: {error})rAerrorzRetrying in 1 second.rzCan't connect to %s)rlistcertfiler pathexistsrbkeyfiler r rir r?rpappendranger&r]r' EADDRINUSErxr0 EADDRNOTAVAILformatdebugtimesleepsysexit)rrfds listenersrAfdaddrladdrrr sock_namerolistenerir1msgrrrcreate_socketssT        rTcCs8|D]}|}||rt|turt|qdSr)r?rrprZr unlink)rrrrrrr close_socketss rcCsdddlm}|j}|s gSd|vrgSddlm}|sgSg}|D] }||vr/|||q"|S)zGet ALPN protocol list from configuration. Returns list of ALPN protocol identifiers based on http_protocols setting. Returns empty list if HTTP/2 is not configured or available. r)ALPN_PROTOCOL_MAPh2)is_http2_available)gunicorn.configrhttp_protocolsgunicorn.http2rr~)rrrralpn_protocolsprotorrr_get_alpn_protocolss  rcsfdd}|S)NcsZtjtjjjd}|jjjdj|_ j r | j t }|r+| ||S)N)cafile)rzr})sslcreate_default_contextPurpose CLIENT_AUTHca_certsload_cert_chainrzr} cert_reqs verify_modeciphers set_ciphersrset_alpn_protocols)contextrrrrdefault_ssl_context_factory s  z0ssl_context..default_ssl_context_factory) ssl_context)rrrrrr s  rcCst|j|d|j|jdS)NT) server_sidesuppress_ragged_eofsdo_handshake_on_connect)r wrap_socketrr)rrrrrssl_wrap_sockets rc Cs6t|tjsdSz|WSttjfyYdSw)zGet the negotiated ALPN protocol from an SSL socket. Returns: str: The negotiated protocol name ('h2', 'http/1.1', etc.) or None if no protocol was negotiated. N)rjr SSLSocketselected_alpn_protocolrOSSLError) ssl_socketrrrget_negotiated_protocol$s  rcCst|}|dkS)zyCheck if HTTP/2 was negotiated on an SSL socket. Returns: bool: True if HTTP/2 was negotiated via ALPN. r)r)rprotocolrrris_http2_negotiated4srr)T)r'r r rr\rMrrgunicornrplatformrSrr;rUrZrprrrrrrrrrrrs, =#  A